Browse Source

Merge remote-tracking branch 'origin/dev_issue_project' into dev_issue_project

dev_shibei_match
wangchao 5 years ago
parent
commit
44972dad5a
  1. 2
      epmet-auth/deploy/docker-compose-dev.yml
  2. 2
      epmet-auth/deploy/docker-compose-test.yml
  3. 2
      epmet-auth/pom.xml
  4. 7
      epmet-auth/src/main/java/com/epmet/service/impl/LoginServiceImpl.java
  5. 10
      epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java
  6. 2
      epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/RenExceptionHandler.java
  7. 2
      epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/utils/Result.java
  8. 38
      epmet-gateway/src/main/java/com/epmet/util/UserTokenValidateUtil.java
  9. 2
      epmet-module/gov-issue/gov-issue-server/deploy/docker-compose-dev.yml
  10. 2
      epmet-module/gov-issue/gov-issue-server/deploy/docker-compose-test.yml
  11. 2
      epmet-module/gov-issue/gov-issue-server/pom.xml
  12. 4
      epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/group/result/RecommendedListResultDTO.java
  13. 2
      epmet-module/resi-group/resi-group-server/deploy/docker-compose-dev.yml
  14. 2
      epmet-module/resi-group/resi-group-server/deploy/docker-compose-test.yml
  15. 2
      epmet-module/resi-group/resi-group-server/pom.xml
  16. 5
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupServiceImpl.java
  17. 52
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java
  18. 2
      epmet-module/resi-home/resi-home-server/deploy/docker-compose-dev.yml
  19. 2
      epmet-module/resi-home/resi-home-server/deploy/docker-compose-test.yml
  20. 2
      epmet-module/resi-home/resi-home-server/pom.xml
  21. 2
      epmet-module/resi-mine/resi-mine-server/deploy/docker-compose-dev.yml
  22. 2
      epmet-module/resi-mine/resi-mine-server/deploy/docker-compose-test.yml
  23. 2
      epmet-module/resi-mine/resi-mine-server/pom.xml
  24. 2
      epmet-module/resi-partymember/resi-partymember-server/deploy/docker-compose-dev.yml
  25. 2
      epmet-module/resi-partymember/resi-partymember-server/deploy/docker-compose-test.yml
  26. 2
      epmet-module/resi-partymember/resi-partymember-server/pom.xml
  27. 11
      epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/PartyMemberConfirmServiceImpl.java
  28. 2
      epmet-user/epmet-user-server/deploy/docker-compose-dev.yml
  29. 2
      epmet-user/epmet-user-server/deploy/docker-compose-test.yml
  30. 2
      epmet-user/epmet-user-server/pom.xml
  31. 10
      epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserResiInfoServiceImpl.java

2
epmet-auth/deploy/docker-compose-dev.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
epmet-auth-server: epmet-auth-server:
container_name: epmet-auth-server-dev container_name: epmet-auth-server-dev
image: 192.168.1.130:10080/epmet-cloud-dev/epmet-auth:0.3.10 image: 192.168.1.130:10080/epmet-cloud-dev/epmet-auth:0.3.11
ports: ports:
- "8081:8081" - "8081:8081"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-auth/deploy/docker-compose-test.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
epmet-auth-server: epmet-auth-server:
container_name: epmet-auth-server-test container_name: epmet-auth-server-test
image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/epmet-auth:0.3.10 image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/epmet-auth:0.3.11
ports: ports:
- "8081:8081" - "8081:8081"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-auth/pom.xml

@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<version>0.3.10</version> <version>0.3.11</version>
<parent> <parent>
<groupId>com.epmet</groupId> <groupId>com.epmet</groupId>
<artifactId>epmet-cloud</artifactId> <artifactId>epmet-cloud</artifactId>

7
epmet-auth/src/main/java/com/epmet/service/impl/LoginServiceImpl.java

@ -264,13 +264,14 @@ public class LoginServiceImpl implements LoginService {
passwordLoginUserInfoFormDTO.setPhone(formDTO.getPhone()); passwordLoginUserInfoFormDTO.setPhone(formDTO.getPhone());
Result<PasswordLoginUserInfoResultDTO> userInfoResult = epmetUserFeignClient.selectLoginUserInfoByPassword(passwordLoginUserInfoFormDTO); Result<PasswordLoginUserInfoResultDTO> userInfoResult = epmetUserFeignClient.selectLoginUserInfoByPassword(passwordLoginUserInfoFormDTO);
if (!userInfoResult.success() || null == userInfoResult.getData()) { if (!userInfoResult.success() || null == userInfoResult.getData()) {
logger.error("根据手机号查询运营人员信息失败"); logger.error("根据手机号查询运营人员信息失败,返回10003账号不存在");
throw new RenException("账号不存在"); throw new RenException(EpmetErrorCode.ERR10003.getCode());
} }
//3、密码是否正确 //3、密码是否正确
//密码错误 //密码错误
if (!PasswordUtils.matches(formDTO.getPassword(), userInfoResult.getData().getPassWord())) { if (!PasswordUtils.matches(formDTO.getPassword(), userInfoResult.getData().getPassWord())) {
throw new RenException(ErrorCode.ACCOUNT_PASSWORD_ERROR); logger.error(String.format("手机号密码登陆失败,返回10004密码错误,用户输入密码%s,数据库密码%s",formDTO.getPassword(), userInfoResult.getData().getPassWord()));
throw new RenException(EpmetErrorCode.ERR10004.getCode());
} }
//4、生成token返回,且将TokenDto存到redis //4、生成token返回,且将TokenDto存到redis
UserTokenResultDTO userTokenResultDTO = new UserTokenResultDTO(); UserTokenResultDTO userTokenResultDTO = new UserTokenResultDTO();

10
epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java

@ -6,6 +6,14 @@ package com.epmet.commons.tools.exception;
* @Description: * @Description:
*/ */
public enum EpmetErrorCode { public enum EpmetErrorCode {
/**
* 账号或密码错误ACCOUNT_NOT_EXIST
*/
ERR10003( 10003,"账号不存在"),
/**
* 账号或密码错误ACCOUNT_PASSWORD_ERROR
*/
ERR10004( 10004,"密码错误"),
ERR10005(10005, "token不能为空"), ERR10005(10005, "token不能为空"),
ERR10006(10006, "登录超时,请重新登录"), ERR10006(10006, "登录超时,请重新登录"),
ERR10007(10007, "当前帐号已在别处登录"), ERR10007(10007, "当前帐号已在别处登录"),
@ -13,7 +21,7 @@ public enum EpmetErrorCode {
ERR401(401, "未授权"), ERR401(401, "未授权"),
VALIDATE_ERROR(7000, "数据校验异常"), VALIDATE_ERROR(7000, "数据校验异常"),
SERVER_ERROR(8000, "服务器开小差了..."), SERVER_ERROR(8000, "服务器开小差了..."),
CANNOT_JOIN_GROUP(8001, "只有认证党员和居民才可以加入小组,请选择您的身份"), CANNOT_JOIN_GROUP(8001, "只有注册居民才可以加入小组"),
CANNOT_CREATE_GROUP(8002, "只有党员和热心居民才能创建小组,请选择您的身份"), CANNOT_CREATE_GROUP(8002, "只有党员和热心居民才能创建小组,请选择您的身份"),
GROUP_ALREADY_EXISTED(8003,"组名已存在"), GROUP_ALREADY_EXISTED(8003,"组名已存在"),
GOV_STAFF_NOT_EXISTS(8004,"手机号未注册,请联系贵单位管理员,确认其录入手机与您所持手机号相同"), GOV_STAFF_NOT_EXISTS(8004,"手机号未注册,请联系贵单位管理员,确认其录入手机与您所持手机号相同"),

2
epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/RenExceptionHandler.java

@ -37,7 +37,7 @@ import java.util.Map;
* @author Mark sunlightcs@gmail.com * @author Mark sunlightcs@gmail.com
* @since 1.0.0 * @since 1.0.0
*/ */
//@RestControllerAdvice @RestControllerAdvice
public class RenExceptionHandler { public class RenExceptionHandler {
private static final Logger logger = LoggerFactory.getLogger(RenExceptionHandler.class); private static final Logger logger = LoggerFactory.getLogger(RenExceptionHandler.class);
@Autowired @Autowired

2
epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/utils/Result.java

@ -41,7 +41,7 @@ public class Result<T> implements Serializable {
/** /**
* 内部信息 * 内部信息
*/ */
private String internalMsg; private String internalMsg="";
/** /**
* 响应数据 * 响应数据

38
epmet-gateway/src/main/java/com/epmet/util/UserTokenValidateUtil.java

@ -1,38 +0,0 @@
package com.epmet.util;
import com.epmet.commons.tools.exception.EpmetErrorCode;
import com.epmet.commons.tools.exception.RenException;
import com.epmet.commons.tools.security.dto.BaseTokenDto;
import com.epmet.commons.tools.utils.CpUserDetailRedis;
import com.epmet.jwt.JwtTokenUtils;
import io.jsonwebtoken.Claims;
import org.springframework.stereotype.Component;
/**
* @Description
* @ClassName UserTokenValidateUtil
* @Auth wangc
* @Date 2020-05-21 17:47
*/
@Component
public class UserTokenValidateUtil {
public BaseTokenDto getBaseTokenDto(String token, JwtTokenUtils jwtTokenUtils) {
//是否过期
Claims claims = jwtTokenUtils.getClaimByToken(token);
if (claims == null || jwtTokenUtils.isTokenExpired(claims.getExpiration())) {
throw new RenException(EpmetErrorCode.ERR401.getCode());
}
//获取用户ID
String app = (String) claims.get("app");
String client = (String) claims.get("client");
String userId = (String) claims.get("userId");
return new BaseTokenDto(app, client, userId, token);
}
public <T> T getLoginUserInfoByToken(String token, JwtTokenUtils jwtTokenUtils, CpUserDetailRedis cpUserDetailRedis, Class<T> clz) {
BaseTokenDto baseTokenDto = getBaseTokenDto(token, jwtTokenUtils);
//查询Redis
return cpUserDetailRedis.get(baseTokenDto.getApp(), baseTokenDto.getClient(), baseTokenDto.getUserId(), clz);
}
}

2
epmet-module/gov-issue/gov-issue-server/deploy/docker-compose-dev.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
gov-issue-server: gov-issue-server:
container_name: gov-issue-server-dev container_name: gov-issue-server-dev
image: 192.168.1.130:10080/epmet-cloud-dev/gov-issue-server:0.3.22 image: 192.168.1.130:10080/epmet-cloud-dev/gov-issue-server:0.3.25
ports: ports:
- "8101:8101" - "8101:8101"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-module/gov-issue/gov-issue-server/deploy/docker-compose-test.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
gov-issue-server: gov-issue-server:
container_name: gov-issue-server-test container_name: gov-issue-server-test
image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/gov-issue-server:0.3.22 image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/gov-issue-server:0.3.25
ports: ports:
- "8101:8101" - "8101:8101"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-module/gov-issue/gov-issue-server/pom.xml

@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" <project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<version>0.3.22</version> <version>0.3.25</version>
<parent> <parent>
<artifactId>gov-issue</artifactId> <artifactId>gov-issue</artifactId>
<groupId>com.epmet</groupId> <groupId>com.epmet</groupId>

4
epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/group/result/RecommendedListResultDTO.java

@ -28,11 +28,11 @@ public class RecommendedListResultDTO implements Serializable {
/** /**
* 总成员数 * 总成员数
*/ */
private String totalMember; private Integer totalMember;
/** /**
* 党员总数 * 党员总数
*/ */
private String totalPartyMember; private Integer totalPartyMember;
/** /**
* 组长名 * 组长名
*/ */

2
epmet-module/resi-group/resi-group-server/deploy/docker-compose-dev.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
resi-group-server: resi-group-server:
container_name: resi-group-server-dev container_name: resi-group-server-dev
image: 192.168.1.130:10080/epmet-cloud-dev/resi-group-server:0.3.31 image: 192.168.1.130:10080/epmet-cloud-dev/resi-group-server:0.3.35
ports: ports:
- "8095:8095" - "8095:8095"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-module/resi-group/resi-group-server/deploy/docker-compose-test.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
resi-group-server: resi-group-server:
container_name: resi-group-server-test container_name: resi-group-server-test
image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-group-server:0.3.31 image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-group-server:0.3.35
ports: ports:
- "8095:8095" - "8095:8095"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-module/resi-group/resi-group-server/pom.xml

@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<version>0.3.31</version> <version>0.3.35</version>
<parent> <parent>
<groupId>com.epmet</groupId> <groupId>com.epmet</groupId>
<artifactId>resi-group</artifactId> <artifactId>resi-group</artifactId>

5
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupServiceImpl.java

@ -17,6 +17,7 @@
package com.epmet.modules.group.service.impl; package com.epmet.modules.group.service.impl;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
@ -621,9 +622,10 @@ public class ResiGroupServiceImpl extends BaseServiceImpl<ResiGroupDao, ResiGrou
userRoleFormDTO.setCustomerId(customerId); userRoleFormDTO.setCustomerId(customerId);
userRoleFormDTO.setUserId(userId); userRoleFormDTO.setUserId(userId);
userRoleFormDTO.setGridId(gridId); userRoleFormDTO.setGridId(gridId);
logger.info(String.format("用户同意邀请进组,获取当前用户所有角色入参:%s", JSON.toJSONString(userRoleFormDTO)));
Result<List<UserRoleResultDTO>> userRoleListResult = epmetUserFeignClient.getUserRoleInfo(userRoleFormDTO); Result<List<UserRoleResultDTO>> userRoleListResult = epmetUserFeignClient.getUserRoleInfo(userRoleFormDTO);
if (!userRoleListResult.success()) { if (!userRoleListResult.success()) {
logger.info("获取用户角色feign调用失败" + userRoleListResult.getMsg()); logger.error("获取用户角色feign调用失败" + userRoleListResult.getMsg());
return userRoleDTO; return userRoleDTO;
} }
List<UserRoleResultDTO> userRoleList = userRoleListResult.getData(); List<UserRoleResultDTO> userRoleList = userRoleListResult.getData();
@ -641,6 +643,7 @@ public class ResiGroupServiceImpl extends BaseServiceImpl<ResiGroupDao, ResiGrou
userRoleDTO.setRegisteredResiFlag(NumConstant.ONE_STR); userRoleDTO.setRegisteredResiFlag(NumConstant.ONE_STR);
} }
} }
logger.info(String.format("用户同意邀请进组,获取当前用户所有角色返参:%s",JSON.toJSONString(userRoleDTO)));
return userRoleDTO; return userRoleDTO;
} }

52
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java

@ -33,6 +33,7 @@ import com.epmet.dto.form.UserMessageFormDTO;
import com.epmet.dto.form.UserResiInfoFormDTO; import com.epmet.dto.form.UserResiInfoFormDTO;
import com.epmet.dto.result.UserInfoOnEnterGridResultDTO; import com.epmet.dto.result.UserInfoOnEnterGridResultDTO;
import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.dto.result.UserResiInfoResultDTO;
import com.epmet.dto.result.UserRoleResultDTO;
import com.epmet.feign.MessageFeignClient; import com.epmet.feign.MessageFeignClient;
import com.epmet.modules.constant.UserMessageConstant; import com.epmet.modules.constant.UserMessageConstant;
import com.epmet.modules.feign.EpmetUserFeignClient; import com.epmet.modules.feign.EpmetUserFeignClient;
@ -217,13 +218,6 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl<GroupInvitationD
linkGroupInfoResultDTO.setGroupInfo(groupInfo); linkGroupInfoResultDTO.setGroupInfo(groupInfo);
//4、记录用户邀请关系 //4、记录用户邀请关系
this.saveUserInvitation(groupInvitationDTO,formDTO); this.saveUserInvitation(groupInvitationDTO,formDTO);
UserEnterGridFormDTO userEnterGridFormDTO=new UserEnterGridFormDTO();
userEnterGridFormDTO.setCustomerId(groupInfo.getCustomerId());
userEnterGridFormDTO.setGridId(groupInfo.getGridId());
Result<UserInfoOnEnterGridResultDTO> result=resiGuideFeignClient.enterGrid(userEnterGridFormDTO);
if(!result.success()){
logger.error("进入网格失败"+result.getMsg());
}
return linkGroupInfoResultDTO; return linkGroupInfoResultDTO;
} }
@ -312,9 +306,31 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl<GroupInvitationD
public void accetInvitation(AccetInvitationFormDTO formDTO) { public void accetInvitation(AccetInvitationFormDTO formDTO) {
//1、申请是否有效 //1、申请是否有效
GroupInvitationDTO groupInvitationDTO=this.checkLinkValid(formDTO.getInvitationId()); GroupInvitationDTO groupInvitationDTO=this.checkLinkValid(formDTO.getInvitationId());
//2、校验是否已经注册居民 //2、进入小组所在的网格
ResiGroupDTO resiGroupDTO = resiGroupService.get(groupInvitationDTO.getResiGroupId()); ResiGroupDTO resiGroupDTO = resiGroupService.get(groupInvitationDTO.getResiGroupId());
UserRoleDTO userRoleDTO=new UserRoleDTO(); if(null==resiGroupDTO){
logger.error(String.format("用户同意邀请进组,查询组信息失败。入参:userId【%s】、invitationId【%s】、groupId【%s】。",formDTO.getUserId(),formDTO.getInvitationId(),groupInvitationDTO.getResiGroupId()));
throw new RenException(EpmetErrorCode.LOSE_EFFICACY.getCode());
}
UserEnterGridFormDTO userEnterGridFormDTO=new UserEnterGridFormDTO();
userEnterGridFormDTO.setCustomerId(resiGroupDTO.getCustomerId());
userEnterGridFormDTO.setGridId(resiGroupDTO.getGridId());
Result<UserInfoOnEnterGridResultDTO> result=resiGuideFeignClient.enterGrid(userEnterGridFormDTO);
if (!result.success() || null == result.getData()) {
logger.error(String.format("用户同意邀请进组,进入网格失败。入参:userId【%s】、invitationId【%s】、groupId【%s】、customerId【%s】、gridId【%s】",
formDTO.getUserId(), formDTO.getInvitationId(),
groupInvitationDTO.getResiGroupId()),
resiGroupDTO.getCustomerId(), resiGroupDTO.getGridId());
logger.error(String.format("用户同意邀请进组,进入网格失败。当前接口返回8000,调用enterGrid接口返回", result.toString()));
throw new RenException(EpmetErrorCode.SERVER_ERROR.getCode());
}
//3、校验是否已经注册居民
if(null==result.getData().getUserRoleList()||result.getData().getUserRoleList().size()==0){
logger.error(String.format("用户同意邀请进组失败,返回角色列表为空错误编码%s,错误提示%s",EpmetErrorCode.CANNOT_JOIN_GROUP.getCode(),EpmetErrorCode.CANNOT_JOIN_GROUP.getMsg()));
throw new RenException(EpmetErrorCode.CANNOT_JOIN_GROUP.getCode());
}
UserRoleDTO userRoleDTO=this.getUserRoleDTO(result.getData().getUserRoleList());
/*UserRoleDTO userRoleDTO=new UserRoleDTO();
if (null != resiGroupDTO) { if (null != resiGroupDTO) {
//获取当前用户所有角色 //获取当前用户所有角色
userRoleDTO = resiGroupService.checkPartyMemberOrWarmHeated(formDTO.getApp(), userRoleDTO = resiGroupService.checkPartyMemberOrWarmHeated(formDTO.getApp(),
@ -325,7 +341,7 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl<GroupInvitationD
logger.error(String.format("居民端用户【%s】同意邀请进组失败,错误码:%s,错误提示:%s",formDTO.getUserId(),EpmetErrorCode.CANNOT_JOIN_GROUP.getCode(),EpmetErrorCode.CANNOT_JOIN_GROUP.getMsg())); logger.error(String.format("居民端用户【%s】同意邀请进组失败,错误码:%s,错误提示:%s",formDTO.getUserId(),EpmetErrorCode.CANNOT_JOIN_GROUP.getCode(),EpmetErrorCode.CANNOT_JOIN_GROUP.getMsg()));
throw new RenException(EpmetErrorCode.CANNOT_JOIN_GROUP.getCode()); throw new RenException(EpmetErrorCode.CANNOT_JOIN_GROUP.getCode());
} }
} }*/
//3、新增一条邀请入群、直接审核通过的入群记录 //3、新增一条邀请入群、直接审核通过的入群记录
GroupMemeberOperationDTO groupMemeberOperation = new GroupMemeberOperationDTO(); GroupMemeberOperationDTO groupMemeberOperation = new GroupMemeberOperationDTO();
groupMemeberOperation.setGroupId(resiGroupDTO.getId()); groupMemeberOperation.setGroupId(resiGroupDTO.getId());
@ -354,6 +370,22 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl<GroupInvitationD
this.sendMessageToLeader(formDTO, resiGroupDTO,groupInvitationDTO); this.sendMessageToLeader(formDTO, resiGroupDTO,groupInvitationDTO);
} }
private UserRoleDTO getUserRoleDTO(List<String> userRoleList) {
UserRoleDTO userRoleDTO=new UserRoleDTO();
for (String roleKey : userRoleList) {
if (EpmetRoleKeyConstant.PARTYMEMBER.equals(roleKey)) {
userRoleDTO.setPartymemberFlag(NumConstant.ONE_STR);
}
if (EpmetRoleKeyConstant.WARMHEARTED.equals(roleKey)) {
userRoleDTO.setWarmHeartedFlag(NumConstant.ONE_STR);
}
if (EpmetRoleKeyConstant.REGISTERED_RESI.equals(roleKey)) {
userRoleDTO.setRegisteredResiFlag(NumConstant.ONE_STR);
}
}
return userRoleDTO;
}
/** /**
* @param formDTO 当前用户信息 * @param formDTO 当前用户信息
* @param resiGroupDTO 群组信息 * @param resiGroupDTO 群组信息

2
epmet-module/resi-home/resi-home-server/deploy/docker-compose-dev.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
resi-home-server: resi-home-server:
container_name: resi-home-server-dev container_name: resi-home-server-dev
image: 192.168.1.130:10080/epmet-cloud-dev/resi-home-server:0.3.3 image: 192.168.1.130:10080/epmet-cloud-dev/resi-home-server:0.3.4
ports: ports:
- "8104:8104" - "8104:8104"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-module/resi-home/resi-home-server/deploy/docker-compose-test.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
resi-home-server: resi-home-server:
container_name: resi-home-server-test container_name: resi-home-server-test
image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-home-server:0.3.3 image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-home-server:0.3.4
ports: ports:
- "8104:8104" - "8104:8104"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-module/resi-home/resi-home-server/pom.xml

@ -3,7 +3,7 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<version>0.3.3</version> <version>0.3.4</version>
<parent> <parent>
<artifactId>resi-home</artifactId> <artifactId>resi-home</artifactId>

2
epmet-module/resi-mine/resi-mine-server/deploy/docker-compose-dev.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
resi-mine-server: resi-mine-server:
container_name: resi-mine-server-dev container_name: resi-mine-server-dev
image: 192.168.1.130:10080/epmet-cloud-dev/resi-mine-server:0.3.13 image: 192.168.1.130:10080/epmet-cloud-dev/resi-mine-server:0.3.16
ports: ports:
- "8094:8094" - "8094:8094"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-module/resi-mine/resi-mine-server/deploy/docker-compose-test.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
resi-mine-server: resi-mine-server:
container_name: resi-mine-server-test container_name: resi-mine-server-test
image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-mine-server:0.3.13 image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-mine-server:0.3.16
ports: ports:
- "8094:8094" - "8094:8094"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-module/resi-mine/resi-mine-server/pom.xml

@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<version>0.3.13</version> <version>0.3.16</version>
<parent> <parent>
<groupId>com.epmet</groupId> <groupId>com.epmet</groupId>
<artifactId>resi-mine</artifactId> <artifactId>resi-mine</artifactId>

2
epmet-module/resi-partymember/resi-partymember-server/deploy/docker-compose-dev.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
resi-partymember-server: resi-partymember-server:
container_name: resi-partymember-server-dev container_name: resi-partymember-server-dev
image: 192.168.1.130:10080/epmet-cloud-dev/resi-partymember-server:0.3.32 image: 192.168.1.130:10080/epmet-cloud-dev/resi-partymember-server:0.3.34
ports: ports:
- "8096:8096" - "8096:8096"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-module/resi-partymember/resi-partymember-server/deploy/docker-compose-test.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
resi-partymember-server: resi-partymember-server:
container_name: resi-partymember-server-test container_name: resi-partymember-server-test
image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-partymember-server:0.3.32 image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/resi-partymember-server:0.3.34
ports: ports:
- "8096:8096" - "8096:8096"
network_mode: host # 使用现有网络 network_mode: host # 使用现有网络

2
epmet-module/resi-partymember/resi-partymember-server/pom.xml

@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<version>0.3.32</version> <version>0.3.34</version>
<parent> <parent>
<groupId>com.epmet</groupId> <groupId>com.epmet</groupId>
<artifactId>resi-partymember</artifactId> <artifactId>resi-partymember</artifactId>

11
epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/PartyMemberConfirmServiceImpl.java

@ -144,8 +144,8 @@ public class PartyMemberConfirmServiceImpl implements PartyMemberConfirmService
if (null != partyMemberInfoResult) { if (null != partyMemberInfoResult) {
return new Result().error(EpmetErrorCode.MOBILE_HAS_BEEN_USED.getCode()); return new Result().error(EpmetErrorCode.MOBILE_HAS_BEEN_USED.getCode());
} }
//TODO 方便测试屏蔽短信验证码
//生成短信验证码 /*//生成短信验证码
Map<String, String> message = (Map<String, String>) messageFeignClient.sendSmsCaptcha(fromDTO.getMobile()).getData(); Map<String, String> message = (Map<String, String>) messageFeignClient.sendSmsCaptcha(fromDTO.getMobile()).getData();
if (null == message) { if (null == message) {
return new Result().error(EpmetErrorCode.MOBILE_GET_CODE_ERROR.getCode()); return new Result().error(EpmetErrorCode.MOBILE_GET_CODE_ERROR.getCode());
@ -154,7 +154,7 @@ public class PartyMemberConfirmServiceImpl implements PartyMemberConfirmService
partyMemberInfoRedis.deleteUserMobileCodeByPattern(fromDTO.getUserId(), fromDTO.getMobile()); partyMemberInfoRedis.deleteUserMobileCodeByPattern(fromDTO.getUserId(), fromDTO.getMobile());
//将验证码存入Redis //将验证码存入Redis
partyMemberInfoRedis.setUserMobileCode(fromDTO.getUserId(), fromDTO.getMobile(), message.get("code")); partyMemberInfoRedis.setUserMobileCode(fromDTO.getUserId(), fromDTO.getMobile(), message.get("code"));*/
//将访问记录更新到热心居民申请行为记录表 //将访问记录更新到热心居民申请行为记录表
saveOrUpdateVisit(fromDTO.getVisitId(), null, PartyMemberConstant.OPERATE_OPERATE_SMS_CODE); saveOrUpdateVisit(fromDTO.getVisitId(), null, PartyMemberConstant.OPERATE_OPERATE_SMS_CODE);
@ -168,14 +168,15 @@ public class PartyMemberConfirmServiceImpl implements PartyMemberConfirmService
Result result = new Result(); Result result = new Result();
//校验手机验证码是否正常 //校验手机验证码是否正常
String code = partyMemberInfoRedis.getUserMobileCode(partyMemberInfoDTO.getUserId(), //TODO 党员认证信息提交暂时注释验证码校验
/*String code = partyMemberInfoRedis.getUserMobileCode(partyMemberInfoDTO.getUserId(),
partyMemberInfoDTO.getMobile(), partyMemberInfoDTO.getMobile(),
partyMemberInfoDTO.getCode()); partyMemberInfoDTO.getCode());
if (null == code) { if (null == code) {
saveOrUpdateVisit(partyMemberInfoDTO.getPartymemberVisitId(), null, saveOrUpdateVisit(partyMemberInfoDTO.getPartymemberVisitId(), null,
PartyMemberConstant.OPERATE_AUTO_FAILED); PartyMemberConstant.OPERATE_AUTO_FAILED);
return new Result().error(EpmetErrorCode.MOBILE_CODE_ERROR.getCode()); return new Result().error(EpmetErrorCode.MOBILE_CODE_ERROR.getCode());
} }*/
//获取党员基本信息 //获取党员基本信息
PartymemberConfirmAutoDTO confirmAutoDTO = PartymemberConfirmAutoDTO confirmAutoDTO =

2
epmet-user/epmet-user-server/deploy/docker-compose-dev.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
epmet-user-server: epmet-user-server:
container_name: epmet-user-server-dev container_name: epmet-user-server-dev
image: 192.168.1.130:10080/epmet-cloud-dev/epmet-user-server:0.3.34 image: 192.168.1.130:10080/epmet-cloud-dev/epmet-user-server:0.3.37
ports: ports:
- "8087:8087" - "8087:8087"
network_mode: host # 不会创建新的网络 network_mode: host # 不会创建新的网络

2
epmet-user/epmet-user-server/deploy/docker-compose-test.yml

@ -2,7 +2,7 @@ version: "3.7"
services: services:
epmet-user-server: epmet-user-server:
container_name: epmet-user-server-test container_name: epmet-user-server-test
image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/epmet-user-server:0.3.34 image: registry-vpc.cn-qingdao.aliyuncs.com/epmet-cloud-release/epmet-user-server:0.3.37
ports: ports:
- "8087:8087" - "8087:8087"
network_mode: host # 不会创建新的网络 network_mode: host # 不会创建新的网络

2
epmet-user/epmet-user-server/pom.xml

@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<version>0.3.34</version> <version>0.3.37</version>
<parent> <parent>
<groupId>com.epmet</groupId> <groupId>com.epmet</groupId>
<artifactId>epmet-user</artifactId> <artifactId>epmet-user</artifactId>

10
epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserResiInfoServiceImpl.java

@ -153,12 +153,13 @@ public class UserResiInfoServiceImpl extends BaseServiceImpl<UserResiInfoDao, Us
public Result submit(UserResiInfoDTO userResiInfoDTO) { public Result submit(UserResiInfoDTO userResiInfoDTO) {
Result result = new Result(); Result result = new Result();
//1:手机验证码数据校验 //1:手机验证码数据校验
String verificationCode = userResiInfoRedis.getUserResiMobileCode(userResiInfoDTO.getUserId(),userResiInfoDTO.getRegMobile(),userResiInfoDTO.getMobileCode()); //TODO 完善居民信息暂时注释验证码校验
/*String verificationCode = userResiInfoRedis.getUserResiMobileCode(userResiInfoDTO.getUserId(),userResiInfoDTO.getRegMobile(),userResiInfoDTO.getMobileCode());
if(null == verificationCode || StringUtils.isBlank(verificationCode)){ if(null == verificationCode || StringUtils.isBlank(verificationCode)){
//验证码校验失败则更新行为记录表数据 返回前台结果 //验证码校验失败则更新行为记录表数据 返回前台结果
userResiRegisterVisitService.updateResiRegisterVisit(false, userResiInfoDTO); userResiRegisterVisitService.updateResiRegisterVisit(false, userResiInfoDTO);
return new Result().error(EpmetErrorCode.MOBILE_CODE_ERROR.getCode()); return new Result().error(EpmetErrorCode.MOBILE_CODE_ERROR.getCode());
} }*/
//2:再次判断手机号是否可用 //2:再次判断手机号是否可用
if (!getResiInfoByMobile(userResiInfoDTO.getRegMobile())) { if (!getResiInfoByMobile(userResiInfoDTO.getRegMobile())) {
//手机号验证失败则更新行为记录表数据 返回前台结果 //手机号验证失败则更新行为记录表数据 返回前台结果
@ -208,7 +209,8 @@ public class UserResiInfoServiceImpl extends BaseServiceImpl<UserResiInfoDao, Us
if (!getResiInfoByMobile(verificationCodeFormDTO.getMobile())) { if (!getResiInfoByMobile(verificationCodeFormDTO.getMobile())) {
return new Result().error(EpmetErrorCode.MOBILE_HAS_BEEN_USED.getCode()); return new Result().error(EpmetErrorCode.MOBILE_HAS_BEEN_USED.getCode());
} }
//3:调用短信服务 生成验证码发送短信 //TODO 2020-05-23方便测试先屏蔽短信验证码发送
/*//3:调用短信服务 生成验证码发送短信
result = messageFeignClient.sendSmsCaptcha(verificationCodeFormDTO.getMobile()); result = messageFeignClient.sendSmsCaptcha(verificationCodeFormDTO.getMobile());
Map<String,Object> map = (Map<String, Object>) result.getData(); Map<String,Object> map = (Map<String, Object>) result.getData();
if (null == map || null == map.get("code")) { if (null == map || null == map.get("code")) {
@ -217,7 +219,7 @@ public class UserResiInfoServiceImpl extends BaseServiceImpl<UserResiInfoDao, Us
//4:删除缓存中可能存在的旧验证码 //4:删除缓存中可能存在的旧验证码
userResiInfoRedis.deleteOldUserMobileCode(verificationCodeFormDTO.getUserId(), verificationCodeFormDTO.getMobile()); userResiInfoRedis.deleteOldUserMobileCode(verificationCodeFormDTO.getUserId(), verificationCodeFormDTO.getMobile());
//5:将验证码存入redis //5:将验证码存入redis
userResiInfoRedis.setUserResiMobileCode(verificationCodeFormDTO.getUserId(),verificationCodeFormDTO.getMobile(),map.get("code").toString()); userResiInfoRedis.setUserResiMobileCode(verificationCodeFormDTO.getUserId(),verificationCodeFormDTO.getMobile(),map.get("code").toString());*/
return result; return result;
} }

Loading…
Cancel
Save