Browse Source

兼容mssql

mssql
Yen 3 years ago
parent
commit
a249821893
  1. 4
      pom.xml
  2. 10
      src/main/java/com/qs/serve/common/util/WarpUtil.java
  3. 4
      src/main/java/com/qs/serve/controller/AdminPortalController.java
  4. 16
      src/main/java/com/qs/serve/modules/qms/controller/QmsGroupController.java
  5. 2
      src/main/java/com/qs/serve/modules/qms/entity/QmsGroup.java
  6. 8
      src/main/java/com/qs/serve/modules/sys/controller/SysUserController.java
  7. 2
      src/main/java/com/qs/serve/modules/sys/service/impl/SysRoleServiceImpl.java
  8. 4
      src/main/java/com/qs/serve/modules/wx/api/WxSvcUserApi.java
  9. 3
      src/main/java/com/qs/serve/modules/wx/controller/WxUserController.java

4
pom.xml

@ -24,7 +24,7 @@
<httpclient.version>4.5.7</httpclient.version> <httpclient.version>4.5.7</httpclient.version>
<commons-httpclient.version>3.1</commons-httpclient.version> <commons-httpclient.version>3.1</commons-httpclient.version>
<fastjson.version>1.2.49</fastjson.version> <fastjson.version>1.2.49</fastjson.version>
<mybatis-plus.version>3.4.1</mybatis-plus.version> <mybatis-plus.version>3.5.2</mybatis-plus.version>
<skipTests>true</skipTests> <skipTests>true</skipTests>
<wx.java.version>4.2.0</wx.java.version> <wx.java.version>4.2.0</wx.java.version>
</properties> </properties>
@ -109,7 +109,7 @@
<dependency> <dependency>
<groupId>com.github.pagehelper</groupId> <groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId> <artifactId>pagehelper-spring-boot-starter</artifactId>
<version>1.4.5</version> <version>1.4.4</version>
<exclusions> <exclusions>
<exclusion> <exclusion>
<groupId>org.mybatis</groupId> <groupId>org.mybatis</groupId>

10
src/main/java/com/qs/serve/common/util/WarpUtil.java

@ -40,11 +40,11 @@ public class WarpUtil extends AnnotationQueryStorage {
String orderType = ServletUtils.getParameter(ORDER_TYPE_NAME); String orderType = ServletUtils.getParameter(ORDER_TYPE_NAME);
if(StringUtils.isNotEmpty(columnsString)){ if(StringUtils.isNotEmpty(columnsString)){
String[] columns = columnsString.split(","); String[] columns = columnsString.split(",");
if(orderType.equals(ORDER_DESC)){ // if(orderType.equals(ORDER_DESC)){
queryWrapper.orderByDesc(columns); // queryWrapper.orderByDesc(columns);
}else { // }else {
queryWrapper.orderByAsc(columns); // queryWrapper.orderByAsc(columns);
} // }
} }
} }
return queryWrapper; return queryWrapper;

4
src/main/java/com/qs/serve/controller/AdminPortalController.java

@ -95,8 +95,8 @@ public class AdminPortalController {
public R<?> phoneCode(@PathVariable("phone") String phone){ public R<?> phoneCode(@PathVariable("phone") String phone){
LambdaQueryWrapper<SysUser> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<SysUser> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(SysUser::getAccount,phone); wrapper.eq(SysUser::getAccount,phone);
int count = sysUserService.count(wrapper); Long count = sysUserService.count(wrapper);
if(count<1){ if(count<1L){
return R.error("无效手机号,请重新输入"); return R.error("无效手机号,请重新输入");
} }
String key = RedisCacheKeys.PHONE_KEY+phone; String key = RedisCacheKeys.PHONE_KEY+phone;

16
src/main/java/com/qs/serve/modules/qms/controller/QmsGroupController.java

@ -144,8 +144,16 @@ public class QmsGroupController {
} }
qmsGroup.setPublishState(1); qmsGroup.setPublishState(1);
qmsGroup.setPublishTime(LocalDateTime.now()); qmsGroup.setPublishTime(LocalDateTime.now());
try {
qmsGroupService.updateById(qmsGroup); qmsGroupService.updateById(qmsGroup);
} catch (Exception e) {
e.printStackTrace();
}
try {
this.qmsGroupScopeService.publish(groupId); this.qmsGroupScopeService.publish(groupId);
} catch (Exception e) {
e.printStackTrace();
}
return R.ok(); return R.ok();
} }
@ -234,8 +242,16 @@ public class QmsGroupController {
qmsGroup.setFormContext(qmsForm.getFormContext()); qmsGroup.setFormContext(qmsForm.getFormContext());
qmsGroup.setVersion(qmsForm.getVersion()); qmsGroup.setVersion(qmsForm.getVersion());
qmsGroup.setPublishState(0); qmsGroup.setPublishState(0);
try {
qmsGroupService.save(qmsGroup); qmsGroupService.save(qmsGroup);
} catch (Exception e) {
e.printStackTrace();
}
try {
qmsGroupScopeService.saveByBo(qmsGroup.getId(),param); qmsGroupScopeService.saveByBo(qmsGroup.getId(),param);
} catch (Exception e) {
e.printStackTrace();
}
return R.ok(); return R.ok();
} }

2
src/main/java/com/qs/serve/modules/qms/entity/QmsGroup.java

@ -12,6 +12,7 @@ import com.qs.serve.common.model.dto.SimpleKeyValue;
import com.qs.serve.modules.sys.entity.SysDept; import com.qs.serve.modules.sys.entity.SysDept;
import com.qs.serve.modules.sys.entity.dto.SysUserSimpleVo; import com.qs.serve.modules.sys.entity.dto.SysUserSimpleVo;
import lombok.Data; import lombok.Data;
import org.apache.ibatis.annotations.Options;
import org.apache.ibatis.type.JdbcType; import org.apache.ibatis.type.JdbcType;
import org.hibernate.validator.constraints.Length; import org.hibernate.validator.constraints.Length;
import org.springframework.format.annotation.DateTimeFormat; import org.springframework.format.annotation.DateTimeFormat;
@ -49,7 +50,6 @@ public class QmsGroup implements Serializable {
/** 表单json */ /** 表单json */
@NotBlank(message = "表单json不能为空") @NotBlank(message = "表单json不能为空")
@Length(max = 0,message = "表单json长度不能超过0字")
private String formContext; private String formContext;
/** 发布状态 */ /** 发布状态 */

8
src/main/java/com/qs/serve/modules/sys/controller/SysUserController.java

@ -82,8 +82,6 @@ public class SysUserController {
sysUser.setAuthorList(loginUser.getAuthorList()); sysUser.setAuthorList(loginUser.getAuthorList());
sysUserService.relateInfo(sysUser); sysUserService.relateInfo(sysUser);
sysUser.setPassword(null); sysUser.setPassword(null);
List<WxUser> wxUserList = wxUserService.getBySysUserId(sysUser.getId());
sysUser.setWxUserInfoList(wxUserList);
return R.ok(sysUser); return R.ok(sysUser);
} }
@ -247,6 +245,8 @@ public class SysUserController {
} }
sysUser.setPassword(null); sysUser.setPassword(null);
sysUserService.relateInfo(sysUser); sysUserService.relateInfo(sysUser);
List<WxUser> wxUserList = wxUserService.getBySysUserId(sysUser.getId());
sysUser.setWxUserInfoList(wxUserList);
return R.ok(sysUser); return R.ok(sysUser);
} }
@ -266,8 +266,8 @@ public class SysUserController {
//检查手机号是否已用 //检查手机号是否已用
LambdaQueryWrapper<SysUser> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<SysUser> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(SysUser::getMobile,param.getMobile()); wrapper.eq(SysUser::getMobile,param.getMobile());
int count = sysUserService.count(wrapper); Long count = sysUserService.count(wrapper);
if(count>0){ if(count>0L){
return R.error("手机号已被注册"); return R.error("手机号已被注册");
} }
param.setAccount(param.getMobile()); param.setAccount(param.getMobile());

2
src/main/java/com/qs/serve/modules/sys/service/impl/SysRoleServiceImpl.java

@ -71,7 +71,7 @@ public class SysRoleServiceImpl extends ServiceImpl<SysRoleMapper, SysRole> impl
roleWrap.in(SysRole::getId,roleIds); roleWrap.in(SysRole::getId,roleIds);
roleWrap.eq(SysRole::getEnable,1); roleWrap.eq(SysRole::getEnable,1);
roleWrap.eq(SysRole::getUserVisible,1); roleWrap.eq(SysRole::getUserVisible,1);
int count = baseMapper.selectCount(roleWrap); int count = baseMapper.selectCount(roleWrap).intValue();
if(count!=roleIds.size()){ if(count!=roleIds.size()){
Assert.throwEx("数据不配"); Assert.throwEx("数据不配");
} }

4
src/main/java/com/qs/serve/modules/wx/api/WxSvcUserApi.java

@ -57,8 +57,8 @@ public class WxSvcUserApi {
//拦截未注册的手机号 //拦截未注册的手机号
LambdaQueryWrapper<SysUser> lqw = new LambdaQueryWrapper<>(); LambdaQueryWrapper<SysUser> lqw = new LambdaQueryWrapper<>();
lqw.eq(SysUser::getMobile,phone); lqw.eq(SysUser::getMobile,phone);
int count = sysUserService.count(lqw); Long count = sysUserService.count(lqw);
if(count<1){ if(count<1L){
return R.error("手机号未被收录"); return R.error("手机号未被收录");
} }
String key = RedisCacheKeys.PHONE_KEY+phone; String key = RedisCacheKeys.PHONE_KEY+phone;

3
src/main/java/com/qs/serve/modules/wx/controller/WxUserController.java

@ -45,6 +45,9 @@ public class WxUserController {
LambdaQueryWrapper<WxUser> lqw = new LambdaQueryWrapper<>(param); LambdaQueryWrapper<WxUser> lqw = new LambdaQueryWrapper<>(param);
if(param.getNotBindFlag()!=null&&param.getNotBindFlag().equals(1)){ if(param.getNotBindFlag()!=null&&param.getNotBindFlag().equals(1)){
lqw.isNull(WxUser::getPhone).or().eq(WxUser::getPhone,""); lqw.isNull(WxUser::getPhone).or().eq(WxUser::getPhone,"");
}else if (param.getNotBindFlag()!=null&&param.getNotBindFlag().equals(0)){
lqw.isNotNull(WxUser::getPhone);
lqw.ne(WxUser::getPhone,"");
} }
List<WxUser> list = wxUserService.list(lqw); List<WxUser> list = wxUserService.list(lqw);
return R.byPageHelperList(list); return R.byPageHelperList(list);

Loading…
Cancel
Save