From 73e313096a6a181feb34e7c4c272525ca5a4ebe7 Mon Sep 17 00:00:00 2001 From: zhaoqifeng Date: Tue, 7 Apr 2020 17:42:47 +0800 Subject: [PATCH 01/13] =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=9F=A5=E8=AF=A2?= =?UTF-8?q?=E5=92=8C=E5=B7=B2=E8=AF=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../commons/tools/constant/FieldConstant.java | 3 ++ .../epmet/dto/result/MymessageResultDTO.java | 6 +-- .../epmet/constant/UserMessageConstans.java | 11 ++++ .../controller/UserMessageController.java | 28 +++++++++-- .../com/epmet/service/UserMessageService.java | 12 ++++- .../service/impl/UserMessageServiceImpl.java | 46 ++++++++++++++--- .../feign/EpmetMessageFeignClient.java | 50 +++++++++++++++++++ .../EpmetMessageFeignClientFallBack.java | 34 +++++++++++++ .../controller/UserMessageController.java | 15 +++--- .../message/service/UserMessageService.java | 32 ++++++++++++ .../service/impl/UserMessageServiceImpl.java | 38 ++++++++++++++ 11 files changed, 253 insertions(+), 22 deletions(-) create mode 100644 epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/constant/UserMessageConstans.java create mode 100644 epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/EpmetMessageFeignClient.java create mode 100644 epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/fallback/EpmetMessageFeignClientFallBack.java diff --git a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/FieldConstant.java b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/FieldConstant.java index d99374d1b0..a3bed53c8f 100644 --- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/FieldConstant.java +++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/FieldConstant.java @@ -46,6 +46,9 @@ public interface FieldConstant { String COMMUNITY_ID = "COMMUNITY_ID"; String COMMUNITY_ID_HUMP = "communityId"; + String CUSTOMER_ID = "CUSTOMER_ID"; + String CUSTOMER_ID_HUMP = "customerId"; + String GRID_ID = "GRID_ID"; String GRID_ID_HUMP = "gridId"; diff --git a/epmet-module/epmet-message/epmet-message-client/src/main/java/com/epmet/dto/result/MymessageResultDTO.java b/epmet-module/epmet-message/epmet-message-client/src/main/java/com/epmet/dto/result/MymessageResultDTO.java index 6e0d415251..693524057e 100644 --- a/epmet-module/epmet-message/epmet-message-client/src/main/java/com/epmet/dto/result/MymessageResultDTO.java +++ b/epmet-module/epmet-message/epmet-message-client/src/main/java/com/epmet/dto/result/MymessageResultDTO.java @@ -17,12 +17,12 @@ public class MymessageResultDTO implements Serializable { /** * 消息主键 */ - private String messageId; + private String id; /** * 消息标题 */ - private String messageTitle; + private String title; /** * 消息内容 @@ -32,5 +32,5 @@ public class MymessageResultDTO implements Serializable { /** * 发布消息时间 */ - private Date noticeTime; + private Date createdTime; } diff --git a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/constant/UserMessageConstans.java b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/constant/UserMessageConstans.java new file mode 100644 index 0000000000..b67f9251df --- /dev/null +++ b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/constant/UserMessageConstans.java @@ -0,0 +1,11 @@ +package com.epmet.constant; + +/** + * @author zhaoqifeng + * @dscription + * @date 2020/4/7 14:40 + */ +public interface UserMessageConstans { + String READ = "read"; + String UNREAD = "unread"; +} diff --git a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/controller/UserMessageController.java b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/controller/UserMessageController.java index cfe7302a4f..5a56dab9ae 100644 --- a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/controller/UserMessageController.java +++ b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/controller/UserMessageController.java @@ -47,8 +47,8 @@ import java.util.Map; @RequestMapping("usermessage") public class UserMessageController { - @Autowired - private UserMessageService userMessageService; + @Autowired + private UserMessageService userMessageService; @GetMapping("page") public Result> page(@RequestParam Map params){ @@ -92,6 +92,28 @@ public class UserMessageController { ExcelUtils.exportExcelToTarget(response, null, list, UserMessageExcel.class); } + /** + * 单条消息标记为已读 + * + * @param messageDTO 参数 + * @return Result + */ + @PostMapping("readmsg") + public Result readMessage(@RequestBody UserMessageDTO messageDTO) { + return userMessageService.readMessage(messageDTO); + } + + /** + * 消息全部已读 + * + * @param messageDTO 参数 + * @return Result + */ + @PostMapping("readall") + public Result readAllMessage(@RequestBody UserMessageDTO messageDTO) { + return userMessageService.readAllMessage(messageDTO); + } + /** * @param formDto * @return com.epmet.commons.tools.utils.Result @@ -104,4 +126,4 @@ public class UserMessageController { ValidatorUtils.validateEntity(formDto); return userMessageService.saveUserMessage(formDto); } -} +} \ No newline at end of file diff --git a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/UserMessageService.java b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/UserMessageService.java index 1e036405bb..e4a76b9b0b 100644 --- a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/UserMessageService.java +++ b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/UserMessageService.java @@ -95,13 +95,21 @@ public interface UserMessageService extends BaseService { */ void delete(String[] ids); + /** + * 单条消息标记为已读 + * + * @param messageDTO 参数 + * @return Result + */ + Result readMessage(UserMessageDTO messageDTO); + /** * 全部已读 * * @param messageDTO 参数 * @return Result */ - Result allRead(UserMessageDTO messageDTO); + Result readAllMessage(UserMessageDTO messageDTO); /** * @param formDto @@ -111,4 +119,4 @@ public interface UserMessageService extends BaseService { * @Date 2020/4/7 15:34 **/ Result saveUserMessage(UserMessageFormDTO formDto); -} +} \ No newline at end of file diff --git a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/UserMessageServiceImpl.java b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/UserMessageServiceImpl.java index 953595c3bf..f343684809 100644 --- a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/UserMessageServiceImpl.java +++ b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/UserMessageServiceImpl.java @@ -24,6 +24,7 @@ import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.utils.ConvertUtils; import com.epmet.commons.tools.constant.FieldConstant; import com.epmet.commons.tools.utils.Result; +import com.epmet.constant.UserMessageConstans; import com.epmet.dao.UserMessageDao; import com.epmet.dto.UserMessageDTO; import com.epmet.dto.form.UserMessageFormDTO; @@ -69,13 +70,13 @@ public class UserMessageServiceImpl extends BaseServiceImpl getWrapper(Map params) { String id = (String) params.get(FieldConstant.ID_HUMP); - String communityId = (String) params.get(FieldConstant.COMMUNITY_ID_HUMP); + String customerId = (String) params.get(FieldConstant.CUSTOMER_ID_HUMP); String gridId = (String) params.get(FieldConstant.GRID_ID_HUMP); String userId = (String) params.get(FieldConstant.USER_ID_HUMP); QueryWrapper wrapper = new QueryWrapper<>(); wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id) - .eq(StringUtils.isNotBlank(communityId), FieldConstant.COMMUNITY_ID, communityId) + .eq(StringUtils.isNotBlank(customerId), FieldConstant.CUSTOMER_ID, customerId) .eq(StringUtils.isNotBlank(gridId), FieldConstant.GRID_ID, gridId) .eq(StringUtils.isNotBlank(userId), FieldConstant.USER_ID, userId); @@ -109,11 +110,44 @@ public class UserMessageServiceImpl extends BaseServiceImpl getWrapper(UserMessageDTO messageDTO) { + String id = messageDTO.getId(); + String customerId = messageDTO.getCustomerId(); + String gridId = messageDTO.getGridId(); + String userId = messageDTO.getUserId(); + String readFlag = messageDTO.getReadFlag(); + String deFlag = messageDTO.getDelFlag(); + + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id) + .eq(StringUtils.isNotBlank(customerId), FieldConstant.CUSTOMER_ID, customerId) + .eq(StringUtils.isNotBlank(gridId), FieldConstant.GRID_ID, gridId) + .eq(StringUtils.isNotBlank(userId), FieldConstant.USER_ID, userId) + .eq(StringUtils.isNotBlank(deFlag), FieldConstant.DEL_FLAG, deFlag) + .eq(StringUtils.isNotBlank(readFlag),"read_flag", readFlag); + + return wrapper; + } + @Override public Result saveUserMessage(UserMessageFormDTO formDto) { UserMessageEntity entity = ConvertUtils.sourceToTarget(formDto, UserMessageEntity.class); @@ -121,4 +155,4 @@ public class UserMessageServiceImpl extends BaseServiceImpl> + */ + @GetMapping("/message/usermessage/page") + Result> page(@RequestParam Map params); + + /** + * 单条消息已读 + * + * @param messageDTO 参数 + * @return Result + */ + @PostMapping("/message/usermessage/readmsg") + Result readMessage(@RequestBody UserMessageDTO messageDTO); + + /** + * 消息全部已读 + * + * @param messageDTO 参数 + * @return Result + */ + @PostMapping("/message/usermessage/readall") + Result readAllMessage(@RequestBody UserMessageDTO messageDTO); +} diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/fallback/EpmetMessageFeignClientFallBack.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/fallback/EpmetMessageFeignClientFallBack.java new file mode 100644 index 0000000000..43635879e7 --- /dev/null +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/fallback/EpmetMessageFeignClientFallBack.java @@ -0,0 +1,34 @@ +package com.epmet.modules.feign.fallback; + +import com.epmet.commons.tools.constant.ServiceConstant; +import com.epmet.commons.tools.page.PageData; +import com.epmet.commons.tools.utils.ModuleUtils; +import com.epmet.commons.tools.utils.Result; +import com.epmet.dto.UserMessageDTO; +import com.epmet.modules.feign.EpmetMessageFeignClient; +import org.springframework.stereotype.Component; + +import java.util.Map; + +/** + * @author zhaoqifeng + * @dscription + * @date 2020/4/7 14:58 + */ +@Component +public class EpmetMessageFeignClientFallBack implements EpmetMessageFeignClient { + @Override + public Result> page(Map params) { + return ModuleUtils.feignConError(ServiceConstant.EPMET_MESSAGE_SERVER, "page", params); + } + + @Override + public Result readMessage(UserMessageDTO messageDTO) { + return ModuleUtils.feignConError(ServiceConstant.EPMET_MESSAGE_SERVER, "readMessage", messageDTO); + } + + @Override + public Result readAllMessage(UserMessageDTO messageDTO) { + return ModuleUtils.feignConError(ServiceConstant.EPMET_MESSAGE_SERVER, "allRead", messageDTO); + } +} diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/controller/UserMessageController.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/controller/UserMessageController.java index fa626f84ba..48479bc44c 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/controller/UserMessageController.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/controller/UserMessageController.java @@ -1,17 +1,16 @@ package com.epmet.modules.message.controller; import com.epmet.commons.tools.annotation.LoginUser; +import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.security.dto.TokenDto; import com.epmet.commons.tools.utils.Result; import com.epmet.commons.tools.validator.ValidatorUtils; +import com.epmet.dto.UserMessageDTO; import com.epmet.dto.form.MymessageFormDTO; -import com.epmet.dto.result.MymessageResultDTO; import com.epmet.modules.message.service.UserMessageService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; -import java.util.List; - /** * @Description 我的消息 * @Author yinzuomei @@ -31,12 +30,12 @@ public class UserMessageController { * @Date 2020/3/29 20:53 **/ @PostMapping("getmymessage") - public Result> getMyMessage(@LoginUser TokenDto tokenDto, + public Result> getMyMessage(@LoginUser TokenDto tokenDto, @RequestBody MymessageFormDTO mymessageFormDTO) { mymessageFormDTO.setUserId(tokenDto.getUserId()); ValidatorUtils.validateEntity(mymessageFormDTO); //逻辑待实现 - return new Result(); + return userMessageService.getMessageList(tokenDto, mymessageFormDTO); } /** @@ -51,7 +50,7 @@ public class UserMessageController { public Result readMessage(@LoginUser TokenDto tokenDto, @RequestParam("messageId") String messageId) { //逻辑待实现 - return new Result(); + return userMessageService.readMessage(messageId); } /** @@ -62,8 +61,8 @@ public class UserMessageController { * @Date 2020/3/29 21:06 **/ @PostMapping("readallmsg") - public Result readAllMessage(@LoginUser TokenDto tokenDto) { + public Result readAllMessage(@LoginUser TokenDto tokenDto, @RequestBody UserMessageDTO userMessageDTO) { //逻辑待实现 - return new Result(); + return userMessageService.readAllMessage(tokenDto, userMessageDTO); } } diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/UserMessageService.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/UserMessageService.java index 165d9f3650..de27818e3f 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/UserMessageService.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/UserMessageService.java @@ -1,9 +1,41 @@ package com.epmet.modules.message.service; +import com.epmet.commons.tools.page.PageData; +import com.epmet.commons.tools.security.dto.TokenDto; +import com.epmet.commons.tools.utils.Result; +import com.epmet.dto.UserMessageDTO; +import com.epmet.dto.form.MymessageFormDTO; + /** * @Description 我的消息 * @Author yinzuomei * @Date 2020/3/29 20:50 */ public interface UserMessageService { + + /** + * 获取消息列表 + * + * @param tokenDto token + * @param messageFromDTO 参数 + * @return Result> + */ + Result> getMessageList(TokenDto tokenDto, MymessageFormDTO messageFromDTO); + + /** + * 单条消息标记为已读 + * + * @param messageId 参数 + * @return Result + */ + Result readMessage(String messageId); + + /** + * 消息全部已读 + * + * @param tokenDto token + * @param messageDTO 参数 + * @return Result + */ + Result readAllMessage(TokenDto tokenDto, UserMessageDTO messageDTO); } diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/impl/UserMessageServiceImpl.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/impl/UserMessageServiceImpl.java index dee56e413e..efb914a94e 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/impl/UserMessageServiceImpl.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/impl/UserMessageServiceImpl.java @@ -1,8 +1,18 @@ package com.epmet.modules.message.service.impl; +import com.epmet.commons.tools.page.PageData; +import com.epmet.commons.tools.security.dto.TokenDto; +import com.epmet.commons.tools.utils.Result; +import com.epmet.dto.UserMessageDTO; +import com.epmet.dto.form.MymessageFormDTO; +import com.epmet.modules.feign.EpmetMessageFeignClient; import com.epmet.modules.message.service.UserMessageService; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.util.HashMap; +import java.util.Map; + /** * @Description 我的消息 * @Author yinzuomei @@ -10,4 +20,32 @@ import org.springframework.stereotype.Service; */ @Service public class UserMessageServiceImpl implements UserMessageService { + @Autowired + private EpmetMessageFeignClient messageFeignClient; + + @Override + public Result> getMessageList(TokenDto tokenDto, MymessageFormDTO messageFromDTO) { + Map param = new HashMap(); + param.put("customerId", messageFromDTO.getCustomerId()); + param.put("gridId", messageFromDTO.getGridId()); + param.put("userId", tokenDto.getUserId()); + param.put("pageNo", messageFromDTO.getPageNo()); + param.put("pageSize", messageFromDTO.getPageSize()); + Result> result = messageFeignClient.page(param); + return result; + } + + @Override + public Result readMessage(String messageId) { + UserMessageDTO messageDTO = new UserMessageDTO(); + messageDTO.setId(messageId); + return messageFeignClient.readMessage(messageDTO); + } + + @Override + public Result readAllMessage(TokenDto tokenDto, UserMessageDTO messageDTO) { + messageDTO.setUserId(tokenDto.getUserId()); + messageDTO.setDelFlag("0"); + return messageFeignClient.readAllMessage(messageDTO); + } } From 4e999e2e0f16f54cb1e9e2de585873401ceefae1 Mon Sep 17 00:00:00 2001 From: yinzuomei <57602893@qq.com> Date: Tue, 7 Apr 2020 17:43:33 +0800 Subject: [PATCH 02/13] =?UTF-8?q?=E6=A0=B9=E6=8D=AE=E9=93=BE=E6=8E=A5?= =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E7=BE=A4=E7=BB=84=E4=BF=A1=E6=81=AF=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../invitation/service/impl/GroupInvitationServiceImpl.java | 2 +- .../resi-group-server/src/main/resources/logback-spring.xml | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java index dbd4e47f6e..8b95c2fae8 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java @@ -209,7 +209,7 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl().error(EpmetErrorCode.LOSE_EFFICACY.getValue(),EpmetErrorCode.LOSE_EFFICACY.getName()); } - if (null != groupInvitationDTO && groupInvitationDTO.getValidEndTime().after(new Date())) { + if (null != groupInvitationDTO && !groupInvitationDTO.getValidEndTime().after(new Date())) { return new Result().error(EpmetErrorCode.LOSE_EFFICACY.getValue(),EpmetErrorCode.LOSE_EFFICACY.getName()); } return new Result().ok(groupInvitationDTO); diff --git a/epmet-module/resi-group/resi-group-server/src/main/resources/logback-spring.xml b/epmet-module/resi-group/resi-group-server/src/main/resources/logback-spring.xml index 2fae9b3cd9..e994fde077 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/resources/logback-spring.xml +++ b/epmet-module/resi-group/resi-group-server/src/main/resources/logback-spring.xml @@ -136,6 +136,7 @@ + @@ -152,6 +153,7 @@ + From b9c1a74aa07f0a6aa31de1e1fd4897b364ef10c5 Mon Sep 17 00:00:00 2001 From: yinzuomei <57602893@qq.com> Date: Tue, 7 Apr 2020 18:01:51 +0800 Subject: [PATCH 03/13] =?UTF-8?q?=E6=A0=B9=E6=8D=AE=E9=93=BE=E6=8E=A5?= =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E7=BE=A4=E7=BB=84=E4=BF=A1=E6=81=AF=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/GroupInvitationServiceImpl.java | 35 ++++++++++++++++++- 1 file changed, 34 insertions(+), 1 deletion(-) diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java index 8b95c2fae8..81928c869a 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java @@ -35,6 +35,7 @@ import com.epmet.feign.MessageFeignClient; import com.epmet.modules.constant.UserMessageConstant; import com.epmet.modules.feign.EpmetUserFeignClient; import com.epmet.modules.group.dao.ResiGroupDao; +import com.epmet.modules.group.entity.ResiGroupEntity; import com.epmet.modules.group.service.ResiGroupService; import com.epmet.modules.invitation.dao.GroupInvitationDao; import com.epmet.modules.invitation.entity.GroupInvitationEntity; @@ -58,6 +59,8 @@ import com.epmet.resi.group.dto.invitation.result.LinkGroupInfoResultDTO; import com.epmet.resi.group.dto.member.GroupMemeberOperationDTO; import com.epmet.resi.group.dto.member.ResiGroupMemberDTO; import org.apache.commons.lang3.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -72,7 +75,7 @@ import java.util.*; */ @Service public class GroupInvitationServiceImpl extends BaseServiceImpl implements GroupInvitationService { - + private Logger logger = LoggerFactory.getLogger(getClass()); @Autowired private ResiGroupMemberDao resiGroupMemberDao; @@ -199,9 +202,39 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl().error(validResult.getCode(),validResult.getMsg()); } LinkGroupInfoResultDTO linkGroupInfoResultDTO = baseDao.selectLinkGroupInfo(validResult.getData().getResiGroupId()); + //获取组长信息 + Result groupLeaderUserInfo = this.getGroupLeaderUserInfo(linkGroupInfoResultDTO.getGroupId()); + if (groupLeaderUserInfo.success() && null != groupLeaderUserInfo.getData()) { + linkGroupInfoResultDTO.setLeaderName(groupLeaderUserInfo.getData().getShowName()); + } else { + logger.info("组长注册信息查询失败" + groupLeaderUserInfo.getMsg()); + } return new Result().ok(linkGroupInfoResultDTO); } + /** + * @param groupId + * @return com.epmet.commons.tools.utils.Result + * @Author yinzuomei + * @Description 根据组id查询组长信息 + * @Date 2020/3/30 15:07 + **/ + private Result getGroupLeaderUserInfo(String groupId) { + //群主名称需要调用feign查询 + ResiGroupEntity resiGroupEntity = resiGroupDao.selectById(groupId); + if (null == resiGroupEntity) { + return new Result<>(); + } + ResiGroupMemberDTO groupMemberDTO = resiGroupDao.selectGroupLeader(groupId); + if (null == groupMemberDTO) { + return new Result<>(); + } + UserResiInfoFormDTO resiUserInfoFormDTO = new UserResiInfoFormDTO(); + resiUserInfoFormDTO.setCustomerId(resiGroupEntity.getCustomerId()); + resiUserInfoFormDTO.setUserId(groupMemberDTO.getCustomerUserId()); + return epmetUserFeignClient.getUserResiInfoDTO(resiUserInfoFormDTO); + } + private Result checkLinkValid(String invitationId){ //校验是否存在该邀请连接 GroupInvitationDTO groupInvitationDTO = this.get(invitationId); From 79d768375cb4e178b6f6a024c9dc847aa26fb140 Mon Sep 17 00:00:00 2001 From: yinzuomei <57602893@qq.com> Date: Tue, 7 Apr 2020 22:16:19 +0800 Subject: [PATCH 04/13] =?UTF-8?q?=E6=9F=A5=E7=9C=8B=E7=BE=A4=E6=88=90?= =?UTF-8?q?=E5=91=98=E5=88=97=E8=A1=A8=E6=B7=BB=E5=8A=A0=E5=A4=B4=E5=83=8F?= =?UTF-8?q?=E3=80=81=E7=94=A8=E6=88=B7=E6=98=BE=E7=A4=BA=E5=90=8D=E7=A7=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../modules/feign/EpmetUserFeignClient.java | 18 ++++- .../EpmetUserFeignClientFallback.java | 10 ++- .../service/impl/ResiGroupServiceImpl.java | 7 +- .../impl/GroupInvitationServiceImpl.java | 7 +- .../impl/ResiGroupMemberServiceImpl.java | 45 +++++++++++-- .../service/impl/ResiTopicServiceImpl.java | 7 +- .../dto/form/UserResiInfoListFormDTO.java | 18 +++++ .../dto/result/UserResiInfoResultDTO.java | 65 +++++++++++++++++++ .../controller/UserResiInfoController.java | 18 ++++- .../java/com/epmet/dao/UserResiInfoDao.java | 12 +++- .../epmet/service/UserResiInfoService.java | 13 +++- .../impl/RegisterRelationServiceImpl.java | 5 +- .../service/impl/UserResiInfoServiceImpl.java | 34 ++++++---- .../main/resources/mapper/UserResiInfoDao.xml | 35 +++++++++- 14 files changed, 254 insertions(+), 40 deletions(-) create mode 100644 epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/UserResiInfoListFormDTO.java create mode 100644 epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/UserResiInfoResultDTO.java diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/feign/EpmetUserFeignClient.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/feign/EpmetUserFeignClient.java index 4ae87fce2f..3c620c3c72 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/feign/EpmetUserFeignClient.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/feign/EpmetUserFeignClient.java @@ -2,14 +2,16 @@ package com.epmet.modules.feign; import com.epmet.commons.tools.constant.ServiceConstant; import com.epmet.commons.tools.utils.Result; -import com.epmet.dto.UserResiInfoDTO; import com.epmet.dto.form.UserResiInfoFormDTO; +import com.epmet.dto.form.UserResiInfoListFormDTO; import com.epmet.dto.form.UserRoleFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.dto.result.UserRoleResultDTO; import com.epmet.modules.feign.fallback.EpmetUserFeignClientFallback; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.http.MediaType; import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; import java.util.List; @@ -28,8 +30,8 @@ public interface EpmetUserFeignClient { * @Description 查询用户注册信息 * @Date 2020/3/30 10:45 **/ - @PostMapping(value = "epmetuser/userresiinfo/getUserResiInfoDTO", consumes = MediaType.APPLICATION_JSON_VALUE) - Result getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO); + @PostMapping(value = "epmetuser/userresiinfo/getuserresiinfo", consumes = MediaType.APPLICATION_JSON_VALUE) + Result getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO); /** * @param userRoleFormDTO @@ -40,4 +42,14 @@ public interface EpmetUserFeignClient { **/ @PostMapping(value = "epmetuser/userrole/getuserroleinfo", consumes = MediaType.APPLICATION_JSON_VALUE) Result> getUserRoleInfo(UserRoleFormDTO userRoleFormDTO); + + /** + * @param userResiInfoListFormDTO + * @return com.epmet.commons.tools.utils.Result> + * @Author yinzuomei + * @Description 根据userId集合，查询用户注册信息 + * @Date 2020/4/7 22:14 + **/ + @PostMapping(value = "epmetuser/userresiinfo/getuserresiinfolist", consumes = MediaType.APPLICATION_JSON_VALUE) + Result> getUserResiInfoList(@RequestBody UserResiInfoListFormDTO userResiInfoListFormDTO); } diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/feign/fallback/EpmetUserFeignClientFallback.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/feign/fallback/EpmetUserFeignClientFallback.java index cd650df6ff..6519d76517 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/feign/fallback/EpmetUserFeignClientFallback.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/feign/fallback/EpmetUserFeignClientFallback.java @@ -3,9 +3,10 @@ package com.epmet.modules.feign.fallback; import com.epmet.commons.tools.constant.ServiceConstant; import com.epmet.commons.tools.utils.ModuleUtils; import com.epmet.commons.tools.utils.Result; -import com.epmet.dto.UserResiInfoDTO; import com.epmet.dto.form.UserResiInfoFormDTO; +import com.epmet.dto.form.UserResiInfoListFormDTO; import com.epmet.dto.form.UserRoleFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.dto.result.UserRoleResultDTO; import com.epmet.modules.feign.EpmetUserFeignClient; import org.springframework.stereotype.Component; @@ -21,7 +22,7 @@ import java.util.List; public class EpmetUserFeignClientFallback implements EpmetUserFeignClient { @Override - public Result getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO) { + public Result getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO) { return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "getUserResiInfoDTO", userResiInfoFormDTO); } @@ -29,4 +30,9 @@ public class EpmetUserFeignClientFallback implements EpmetUserFeignClient { public Result> getUserRoleInfo(UserRoleFormDTO userRoleFormDTO) { return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "getUserRoleInfo", userRoleFormDTO); } + + @Override + public Result> getUserResiInfoList(UserResiInfoListFormDTO userResiInfoListFormDTO) { + return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "getUserResiInfoList", userResiInfoListFormDTO); + } } diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupServiceImpl.java index 92fe240414..a37bf1aa7a 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupServiceImpl.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupServiceImpl.java @@ -30,6 +30,7 @@ import com.epmet.commons.tools.utils.Result; import com.epmet.dto.UserResiInfoDTO; import com.epmet.dto.form.UserResiInfoFormDTO; import com.epmet.dto.form.UserRoleFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.dto.result.UserRoleResultDTO; import com.epmet.modules.feign.EpmetUserFeignClient; import com.epmet.modules.group.dao.ResiGroupDao; @@ -244,7 +245,7 @@ public class ResiGroupServiceImpl extends BaseServiceImpl().error(ModuleConstant.GETGROUPSUMMARIZE_FAILED); } //获取组长信息 - Result groupLeaderUserInfo = this.getGroupLeaderUserInfo(groupSummarizeFormDTO.getGroupId()); + Result groupLeaderUserInfo = this.getGroupLeaderUserInfo(groupSummarizeFormDTO.getGroupId()); if (groupLeaderUserInfo.success() && null != groupLeaderUserInfo.getData()) { groupSummarizeResultDTO.setLeaderName(groupLeaderUserInfo.getData().getShowName()); } else { @@ -260,7 +261,7 @@ public class ResiGroupServiceImpl extends BaseServiceImpl getGroupLeaderUserInfo(String groupId) { + private Result getGroupLeaderUserInfo(String groupId) { //群主名称需要调用feign查询 ResiGroupEntity resiGroupEntity = baseDao.selectById(groupId); if (null == resiGroupEntity) { @@ -370,7 +371,7 @@ public class ResiGroupServiceImpl extends BaseServiceImpl result = epmetUserFeignClient.getUserResiInfoDTO(resiUserInfoFormDTO); + Result result = epmetUserFeignClient.getUserResiInfoDTO(resiUserInfoFormDTO); if (!result.success() || null == result.getData() || StringUtils.isBlank(result.getData().getRegMobile())) { logger.info("居民注册信息查询失败"); return new Result().error(EpmetErrorCode.CANNOT_JOIN_GROUP.getValue(),EpmetErrorCode.CANNOT_JOIN_GROUP.getName()); diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java index 81928c869a..1746b9b648 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java @@ -31,6 +31,7 @@ import com.epmet.constant.ReadFlagConstant; import com.epmet.dto.UserResiInfoDTO; import com.epmet.dto.form.UserMessageFormDTO; import com.epmet.dto.form.UserResiInfoFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.feign.MessageFeignClient; import com.epmet.modules.constant.UserMessageConstant; import com.epmet.modules.feign.EpmetUserFeignClient; @@ -203,7 +204,7 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl groupLeaderUserInfo = this.getGroupLeaderUserInfo(linkGroupInfoResultDTO.getGroupId()); + Result groupLeaderUserInfo = this.getGroupLeaderUserInfo(linkGroupInfoResultDTO.getGroupId()); if (groupLeaderUserInfo.success() && null != groupLeaderUserInfo.getData()) { linkGroupInfoResultDTO.setLeaderName(groupLeaderUserInfo.getData().getShowName()); } else { @@ -219,7 +220,7 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl getGroupLeaderUserInfo(String groupId) { + private Result getGroupLeaderUserInfo(String groupId) { //群主名称需要调用feign查询 ResiGroupEntity resiGroupEntity = resiGroupDao.selectById(groupId); if (null == resiGroupEntity) { @@ -319,7 +320,7 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl userResiInfoDTOResult=epmetUserFeignClient.getUserResiInfoDTO(userResiInfoFormDTO); + Result userResiInfoDTOResult=epmetUserFeignClient.getUserResiInfoDTO(userResiInfoFormDTO); if(!userResiInfoDTOResult.success()||null==userResiInfoDTOResult.getData()){ return ; } diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java index 56740b7cc4..b46c945e56 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java @@ -29,6 +29,8 @@ import com.epmet.commons.tools.utils.ConvertUtils; import com.epmet.commons.tools.utils.Result; import com.epmet.constant.ReadFlagConstant; import com.epmet.dto.form.UserMessageFormDTO; +import com.epmet.dto.form.UserResiInfoListFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.feign.MessageFeignClient; import com.epmet.modules.constant.UserMessageConstant; import com.epmet.modules.feign.EpmetUserFeignClient; @@ -55,6 +57,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.Map; @@ -210,10 +213,25 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl list = baseDao.selectListGroupMember(groupMemberListFormDTO); if (null != list && list.size() > 0) { + List userIdList=new ArrayList<>(); for (GroupMemberListResultDTO groupMemberListResultDTO : list) { - groupMemberListResultDTO.setUserShowName("测试昵称"); - groupMemberListResultDTO.setHeadPhoto("https://wx.qlogo.cn/mmopen/vi_32/PiajxSqBRaEIXGqhj0JakGnhk0L4x31XuWyQM4OxnriaKD4GuAgr8GdLpwu8jphH0oQPbPy0pepWU5iciaIeQwUJPg/132"); - +// groupMemberListResultDTO.setUserShowName("测试昵称"); +// groupMemberListResultDTO.setHeadPhoto("https://wx.qlogo.cn/mmopen/vi_32/PiajxSqBRaEIXGqhj0JakGnhk0L4x31XuWyQM4OxnriaKD4GuAgr8GdLpwu8jphH0oQPbPy0pepWU5iciaIeQwUJPg/132"); + userIdList.add(groupMemberListResultDTO.getUserId()); + } + UserResiInfoListFormDTO formDTO=new UserResiInfoListFormDTO(); + formDTO.setUserIdList(userIdList); + Result> userResiInfoDTOListResult=epmetUserFeignClient.getUserResiInfoList(formDTO); + if(userResiInfoDTOListResult.success()){ + for(UserResiInfoResultDTO userResiInfo:userResiInfoDTOListResult.getData()){ + for (GroupMemberListResultDTO groupMember : list) { + if(groupMember.getUserId().equals(userResiInfo.getUserId())){ + groupMember.setUserShowName(userResiInfo.getShowName()); + groupMember.setHeadPhoto(userResiInfo.getHeadPhoto()); + break; + } + } + } } } return new Result>().ok(list); @@ -232,10 +250,27 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl list = baseDao.selectListApplyingMember(applyingMemberFormDTO); if (null != list && list.size() > 0) { + List userIdList=new ArrayList<>(); for (ApplyingMemberResultDTO applyingMemberResultDTO : list) { - applyingMemberResultDTO.setApplyUserName("测试昵称"); - applyingMemberResultDTO.setApplyUserHeadPhoto("https://wx.qlogo.cn/mmopen/vi_32/PiajxSqBRaEIXGqhj0JakGnhk0L4x31XuWyQM4OxnriaKD4GuAgr8GdLpwu8jphH0oQPbPy0pepWU5iciaIeQwUJPg/132"); +// applyingMemberResultDTO.setApplyUserName("测试昵称"); +// applyingMemberResultDTO.setApplyUserHeadPhoto("https://wx.qlogo.cn/mmopen/vi_32/PiajxSqBRaEIXGqhj0JakGnhk0L4x31XuWyQM4OxnriaKD4GuAgr8GdLpwu8jphH0oQPbPy0pepWU5iciaIeQwUJPg/132"); + userIdList.add(applyingMemberResultDTO.getApplyUserId()); } + UserResiInfoListFormDTO formDTO=new UserResiInfoListFormDTO(); + formDTO.setUserIdList(userIdList); + Result> userResiInfoDTOListResult=epmetUserFeignClient.getUserResiInfoList(formDTO); + if(userResiInfoDTOListResult.success()){ + for(UserResiInfoResultDTO userResiInfo:userResiInfoDTOListResult.getData()){ + for (ApplyingMemberResultDTO memberInfo : list) { + if(memberInfo.getApplyUserId().equals(userResiInfo.getUserId())){ + memberInfo.setApplyUserName(userResiInfo.getShowName()); + memberInfo.setApplyUserHeadPhoto(userResiInfo.getHeadPhoto()); + break; + } + } + } + } + } return new Result>().ok(list); } diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java index 3c54ebb021..1e76513c50 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/service/impl/ResiTopicServiceImpl.java @@ -26,8 +26,8 @@ import com.epmet.commons.tools.security.dto.TokenDto; import com.epmet.commons.tools.utils.ConvertUtils; import com.epmet.commons.tools.constant.FieldConstant; import com.epmet.commons.tools.utils.Result; -import com.epmet.dto.UserResiInfoDTO; import com.epmet.dto.form.UserResiInfoFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.modules.feign.EpmetUserFeignClient; import com.epmet.modules.group.dao.ResiGroupDao; import com.epmet.modules.group.entity.ResiGroupEntity; @@ -424,8 +424,7 @@ public class ResiTopicServiceImpl extends BaseServiceImpl userInfo = - epmetUserFeignClient.getUserResiInfoDTO(userParam); + Result userInfo = epmetUserFeignClient.getUserResiInfoDTO(userParam); if(userInfo.success()){ resultDTO.setReleaseUserName(userInfo.getData().getSurname() + userInfo.getData().getName()); @@ -515,4 +514,4 @@ public class ResiTopicServiceImpl extends BaseServiceImpl userIdList; +} diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/UserResiInfoResultDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/UserResiInfoResultDTO.java new file mode 100644 index 0000000000..8c846a621a --- /dev/null +++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/UserResiInfoResultDTO.java @@ -0,0 +1,65 @@ +package com.epmet.dto.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * @Description + * @Author yinzuomei + * @Date 2020/4/7 18:45 + */ +@Data +public class UserResiInfoResultDTO implements Serializable { + + /** + * 唯一标识 + */ + private String id; + + /** + * 用户Id(主键) user.id + */ + private String userId; + + /** + * 手机号(注册手机号) + */ + private String regMobile; + + /** + * 姓氏 + */ + private String surname; + + /** + * 名称 + */ + private String name; + + /** + * 街道 + */ + private String street; + + /** + * 小区名称 + */ + private String district; + + /** + * 楼栋单元 + */ + private String buildingAddress; + + /** + * 用户显示名称 + */ + private String showName; + + /** + * 用户头像 + */ + private String headPhoto; + +} diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserResiInfoController.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserResiInfoController.java index 862d296a49..825cc6e78b 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserResiInfoController.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserResiInfoController.java @@ -27,7 +27,9 @@ import com.epmet.commons.tools.validator.group.DefaultGroup; import com.epmet.commons.tools.validator.group.UpdateGroup; import com.epmet.dto.UserResiInfoDTO; import com.epmet.dto.form.UserResiInfoFormDTO; +import com.epmet.dto.form.UserResiInfoListFormDTO; import com.epmet.dto.form.VerificationCodeFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.excel.UserResiInfoExcel; import com.epmet.service.UserResiInfoService; import org.springframework.beans.factory.annotation.Autowired; @@ -100,12 +102,24 @@ public class UserResiInfoController { * @Description 查询用户注册信息 * @Date 2020/3/30 10:49 **/ - @PostMapping("getUserResiInfoDTO") - public Result getUserResiInfoDTO(@RequestBody UserResiInfoFormDTO userResiInfoFormDTO) { + @PostMapping("getuserresiinfo") + public Result getUserResiInfoDTO(@RequestBody UserResiInfoFormDTO userResiInfoFormDTO) { ValidatorUtils.validateEntity(userResiInfoFormDTO); return userResiInfoService.getUserResiInfoDTO(userResiInfoFormDTO); } + /** + * @return com.epmet.commons.tools.utils.Result> + * @param userResiInfoListFormDTO + * @Author yinzuomei + * @Description 根据userId集合查询用户注册信息 + * @Date 2020/4/7 18:24 + **/ + @PostMapping("getuserresiinfolist") + public Result> getUserResiInfoList(@RequestBody UserResiInfoListFormDTO userResiInfoListFormDTO){ + return userResiInfoService.getUserResiInfoList(userResiInfoListFormDTO); + } + /** * @param userResiInfoDTO * @Author sun diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserResiInfoDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserResiInfoDao.java index 45e96e78f6..e14b927f1b 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserResiInfoDao.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserResiInfoDao.java @@ -20,8 +20,10 @@ package com.epmet.dao; import com.epmet.commons.mybatis.dao.BaseDao; import com.epmet.dto.UserResiInfoDTO; import com.epmet.dto.form.UserResiInfoFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.entity.UserResiInfoEntity; import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; import java.util.List; @@ -41,7 +43,7 @@ public interface UserResiInfoDao extends BaseDao { * @Description 查询用户注册信息 * @Date 2020/3/30 11:10 **/ - UserResiInfoDTO selectUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO); + UserResiInfoResultDTO selectUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO); /** * @Author sun @@ -49,4 +51,12 @@ public interface UserResiInfoDao extends BaseDao { **/ List selectResiInfoByMobile(String regMobile); + /** + * @return java.util.List + * @param userIdList + * @Author yinzuomei + * @Description 根据userId集合查询用户注册信息 + * @Date 2020/4/7 18:26 + **/ + List selectListUserResiInfoDTO(@Param("userIdList") List userIdList); } diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserResiInfoService.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserResiInfoService.java index 2ea687b27a..5f0817a62e 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserResiInfoService.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserResiInfoService.java @@ -22,7 +22,9 @@ import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.utils.Result; import com.epmet.dto.UserResiInfoDTO; import com.epmet.dto.form.UserResiInfoFormDTO; +import com.epmet.dto.form.UserResiInfoListFormDTO; import com.epmet.dto.form.VerificationCodeFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.entity.UserResiInfoEntity; import java.util.List; @@ -103,7 +105,7 @@ public interface UserResiInfoService extends BaseService { * @Description 查询用户注册信息 * @Date 2020/3/30 11:07 **/ - Result getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO); + Result getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO); /** * 居民端-居民注册信息提交 @@ -130,4 +132,13 @@ public interface UserResiInfoService extends BaseService { * @author zhaoqifeng */ Result saveResiInfo(UserResiInfoDTO userResiInfoDTO); + + /** + * @return com.epmet.commons.tools.utils.Result> + * @param userResiInfoListFormDTO + * @Author yinzuomei + * @Description 根据userId集合查询用户注册信息 + * @Date 2020/4/7 18:21 + **/ + Result> getUserResiInfoList(UserResiInfoListFormDTO userResiInfoListFormDTO); } diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/RegisterRelationServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/RegisterRelationServiceImpl.java index a78af90ba4..986ba1a93c 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/RegisterRelationServiceImpl.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/RegisterRelationServiceImpl.java @@ -37,6 +37,7 @@ import com.epmet.dto.form.EnterGridFormDTO; import com.epmet.dto.form.UserResiInfoFormDTO; import com.epmet.dto.form.UserRoleFormDTO; import com.epmet.dto.result.UserInfoOnEnterGridResultDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.dto.result.UserRoleResultDTO; import com.epmet.entity.RegisterRelationEntity; import com.epmet.entity.UserCustomerEntity; @@ -232,7 +233,7 @@ public class RegisterRelationServiceImpl extends BaseServiceImpl getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO) { - UserResiInfoDTO userResiInfoDTO = baseDao.selectUserResiInfoDTO(userResiInfoFormDTO); - if (null != userResiInfoDTO) { - String showName = userResiInfoDTO.getStreet() + "-" + userResiInfoDTO.getSurname() + userResiInfoDTO.getName(); - userResiInfoDTO.setShowName(showName); - } - return new Result().ok(userResiInfoDTO); + public Result getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO) { + UserResiInfoResultDTO userResiInfoDTO = baseDao.selectUserResiInfoDTO(userResiInfoFormDTO); + return new Result().ok(userResiInfoDTO); } /** @@ -244,6 +239,23 @@ public class UserResiInfoServiceImpl extends BaseServiceImpl> + * @Author yinzuomei + * @Description 根据userId集合查询用户注册信息 + * @Date 2020/4/7 18:21 + **/ + @Override + public Result> getUserResiInfoList(UserResiInfoListFormDTO userResiInfoListFormDTO) { + List list=new ArrayList<>(); + if(null==userResiInfoListFormDTO.getUserIdList()){ + return new Result>().ok(list); + } + list= baseDao.selectListUserResiInfoDTO(userResiInfoListFormDTO.getUserIdList()); + return new Result>().ok(list); + } + /** * 判断手机号是否可用-根据手机号查询居民注册信息(user_resi_info)表数据 * diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/UserResiInfoDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/UserResiInfoDao.xml index 5d68dcef31..acc2efacfa 100644 --- a/epmet-user/epmet-user-server/src/main/resources/mapper/UserResiInfoDao.xml +++ b/epmet-user/epmet-user-server/src/main/resources/mapper/UserResiInfoDao.xml @@ -40,7 +40,7 @@ + + From a227181a24114eeb058f315819ddb9a0d9323f60 Mon Sep 17 00:00:00 2001 From: yinzuomei <57602893@qq.com> Date: Tue, 7 Apr 2020 22:19:49 +0800 Subject: [PATCH 05/13] =?UTF-8?q?=E6=9F=A5=E7=9C=8B=E7=BE=A4=E6=88=90?= =?UTF-8?q?=E5=91=98=E5=88=97=E8=A1=A8=E6=B7=BB=E5=8A=A0=E5=A4=B4=E5=83=8F?= =?UTF-8?q?=E3=80=81=E7=94=A8=E6=88=B7=E6=98=BE=E7=A4=BA=E5=90=8D=E7=A7=B0?= =?UTF-8?q?=EF=BC=8C=E6=B7=BB=E5=8A=A0=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/epmet/dto/form/UserResiInfoListFormDTO.java | 2 +- .../main/java/com/epmet/dto/result/UserResiInfoResultDTO.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/UserResiInfoListFormDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/UserResiInfoListFormDTO.java index 1fbf0eb3dc..b5a34ed278 100644 --- a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/UserResiInfoListFormDTO.java +++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/UserResiInfoListFormDTO.java @@ -6,7 +6,7 @@ import java.io.Serializable; import java.util.List; /** - * @Description + * @Description userId集合 * @Author yinzuomei * @Date 2020/4/7 18:20 */ diff --git a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/UserResiInfoResultDTO.java b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/UserResiInfoResultDTO.java index 8c846a621a..abb0fbe90a 100644 --- a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/UserResiInfoResultDTO.java +++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/UserResiInfoResultDTO.java @@ -5,7 +5,7 @@ import lombok.Data; import java.io.Serializable; /** - * @Description + * @Description 用户注册信息返参DTO * @Author yinzuomei * @Date 2020/4/7 18:45 */ From 439b54a3d2b563ea992a1e0bc3ec867f09bf8705 Mon Sep 17 00:00:00 2001 From: yinzuomei <57602893@qq.com> Date: Tue, 7 Apr 2020 22:21:06 +0800 Subject: [PATCH 06/13] =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=B5=8B=E8=AF=95?= =?UTF-8?q?=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../member/service/impl/ResiGroupMemberServiceImpl.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java index b46c945e56..8ea821ad49 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/impl/ResiGroupMemberServiceImpl.java @@ -215,8 +215,6 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl 0) { List userIdList=new ArrayList<>(); for (GroupMemberListResultDTO groupMemberListResultDTO : list) { -// groupMemberListResultDTO.setUserShowName("测试昵称"); -// groupMemberListResultDTO.setHeadPhoto("https://wx.qlogo.cn/mmopen/vi_32/PiajxSqBRaEIXGqhj0JakGnhk0L4x31XuWyQM4OxnriaKD4GuAgr8GdLpwu8jphH0oQPbPy0pepWU5iciaIeQwUJPg/132"); userIdList.add(groupMemberListResultDTO.getUserId()); } UserResiInfoListFormDTO formDTO=new UserResiInfoListFormDTO(); @@ -252,8 +250,6 @@ public class ResiGroupMemberServiceImpl extends BaseServiceImpl 0) { List userIdList=new ArrayList<>(); for (ApplyingMemberResultDTO applyingMemberResultDTO : list) { -// applyingMemberResultDTO.setApplyUserName("测试昵称"); -// applyingMemberResultDTO.setApplyUserHeadPhoto("https://wx.qlogo.cn/mmopen/vi_32/PiajxSqBRaEIXGqhj0JakGnhk0L4x31XuWyQM4OxnriaKD4GuAgr8GdLpwu8jphH0oQPbPy0pepWU5iciaIeQwUJPg/132"); userIdList.add(applyingMemberResultDTO.getApplyUserId()); } UserResiInfoListFormDTO formDTO=new UserResiInfoListFormDTO(); From 46ff54203aacdbd2ae62f3dfff2be0af28c37d6d Mon Sep 17 00:00:00 2001 From: sunyuchao Date: Wed, 8 Apr 2020 10:13:24 +0800 Subject: [PATCH 07/13] =?UTF-8?q?=E7=83=AD=E5=BF=83=E5=B1=85=E6=B0=91?= =?UTF-8?q?=E7=94=B3=E8=AF=B7=E4=BA=BA=E5=B7=A5=E5=AE=A1=E6=A0=B8=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E7=A7=BB=E8=87=B3=E6=94=BF=E5=BA=9C=E7=AB=AF=E6=9C=8D?= =?UTF-8?q?=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- epmet-module/gov-org/gov-org-server/pom.xml | 6 +++ .../CustomerStaffGridController.java | 13 +++++++ .../feign/ResiPartymemberFeignClient.java | 25 ++++++++++++ .../ResiPartymemberFeignClientFallBack.java | 21 ++++++++++ .../service/CustomerStaffGridService.java | 13 +++++++ .../impl/CustomerStaffGridServiceImpl.java | 38 +++++++++++++++++-- .../java/com/epmet/util/ModuleConstant.java | 5 +++ .../feign/ResiPartymemberFeignClient.java | 9 ----- .../ResiPartymemberFeignClientFallBack.java | 6 --- .../controller/ResiWarmheartedController.java | 12 ------ .../service/ResiWarmheartedService.java | 10 ----- .../impl/ResiWarmheartedServiceImpl.java | 22 ----------- .../impl/ResiWarmheartedApplyServiceImpl.java | 4 +- 13 files changed, 120 insertions(+), 64 deletions(-) create mode 100644 epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/feign/ResiPartymemberFeignClient.java create mode 100644 epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/feign/fallback/ResiPartymemberFeignClientFallBack.java diff --git a/epmet-module/gov-org/gov-org-server/pom.xml b/epmet-module/gov-org/gov-org-server/pom.xml index 1ab1be15fe..54875bf0ce 100644 --- a/epmet-module/gov-org/gov-org-server/pom.xml +++ b/epmet-module/gov-org/gov-org-server/pom.xml @@ -61,6 +61,12 @@ gov-org-client 2.0.0 + + com.epmet + resi-partymember-client + 2.0.0 + compile + diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerStaffGridController.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerStaffGridController.java index 38d23d2962..29058e3247 100644 --- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerStaffGridController.java +++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/CustomerStaffGridController.java @@ -17,7 +17,9 @@ package com.epmet.controller; +import com.epmet.commons.tools.annotation.LoginUser; import com.epmet.commons.tools.page.PageData; +import com.epmet.commons.tools.security.dto.TokenDto; import com.epmet.commons.tools.utils.ExcelUtils; import com.epmet.commons.tools.utils.Result; import com.epmet.commons.tools.validator.AssertUtils; @@ -27,6 +29,7 @@ import com.epmet.commons.tools.validator.group.UpdateGroup; import com.epmet.commons.tools.validator.group.DefaultGroup; import com.epmet.dto.CustomerStaffGridDTO; import com.epmet.excel.CustomerStaffGridExcel; +import com.epmet.resi.partymember.dto.warmhearted.form.ResiWarmheartedAuditFormDTO; import com.epmet.service.CustomerStaffGridService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -91,4 +94,14 @@ public class CustomerStaffGridController { ExcelUtils.exportExcelToTarget(response, null, list, CustomerStaffGridExcel.class); } + /** + * @param + * @Author sun + * @Description 政府端-热心居民申请人工审核 + **/ + @PostMapping("manageaudit") + public Result manageAudit(@LoginUser TokenDto tokenDTO, @RequestBody ResiWarmheartedAuditFormDTO formDTO) { + return customerStaffGridService.manageAudit(tokenDTO, formDTO); + } + } \ No newline at end of file diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/feign/ResiPartymemberFeignClient.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/feign/ResiPartymemberFeignClient.java new file mode 100644 index 0000000000..f1e7ef4c9e --- /dev/null +++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/feign/ResiPartymemberFeignClient.java @@ -0,0 +1,25 @@ +package com.epmet.feign; + +import com.epmet.commons.tools.constant.ServiceConstant; +import com.epmet.commons.tools.utils.Result; +import com.epmet.feign.fallback.ResiPartymemberFeignClientFallBack; +import com.epmet.resi.partymember.dto.warmhearted.form.ResiWarmheartedAuditFormDTO; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.PostMapping; + +/** + * @Description 政府端工作人员审核 + * @Author sun + */ +@FeignClient(name = ServiceConstant.RESI_PARTYMEMBER_SERVER, fallback = ResiPartymemberFeignClientFallBack.class) +public interface ResiPartymemberFeignClient { + + /** + * @Author sun + * @Description 政府端-热心居民申请人工审核 + **/ + @PostMapping(value = "resi/partymember/resiwarmheartedapply/manageaudit") + Result manageAudit(ResiWarmheartedAuditFormDTO formDTO); + + +} diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/feign/fallback/ResiPartymemberFeignClientFallBack.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/feign/fallback/ResiPartymemberFeignClientFallBack.java new file mode 100644 index 0000000000..90ddb00086 --- /dev/null +++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/feign/fallback/ResiPartymemberFeignClientFallBack.java @@ -0,0 +1,21 @@ +package com.epmet.feign.fallback; + +import com.epmet.commons.tools.constant.ServiceConstant; +import com.epmet.commons.tools.utils.ModuleUtils; +import com.epmet.commons.tools.utils.Result; +import com.epmet.feign.ResiPartymemberFeignClient; +import com.epmet.resi.partymember.dto.warmhearted.form.ResiWarmheartedAuditFormDTO; +import org.springframework.stereotype.Component; + +/** + * @Description 政府端工作人员审核 + * @Author sun + */ +@Component +public class ResiPartymemberFeignClientFallBack implements ResiPartymemberFeignClient { + + @Override + public Result manageAudit(ResiWarmheartedAuditFormDTO formDTO) { + return ModuleUtils.feignConError(ServiceConstant.RESI_PARTYMEMBER_SERVER, "manageAudit", formDTO); + } +} diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerStaffGridService.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerStaffGridService.java index 9ebc45c530..8ddb524092 100644 --- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerStaffGridService.java +++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/CustomerStaffGridService.java @@ -19,8 +19,11 @@ package com.epmet.service; import com.epmet.commons.mybatis.service.BaseService; import com.epmet.commons.tools.page.PageData; +import com.epmet.commons.tools.security.dto.TokenDto; +import com.epmet.commons.tools.utils.Result; import com.epmet.dto.CustomerStaffGridDTO; import com.epmet.entity.CustomerStaffGridEntity; +import com.epmet.resi.partymember.dto.warmhearted.form.ResiWarmheartedAuditFormDTO; import java.util.List; import java.util.Map; @@ -92,4 +95,14 @@ public interface CustomerStaffGridService extends BaseService page(Map params) { @@ -65,8 +74,8 @@ public class CustomerStaffGridServiceImpl extends BaseServiceImpl getWrapper(Map params){ - String id = (String)params.get(FieldConstant.ID_HUMP); + private QueryWrapper getWrapper(Map params) { + String id = (String) params.get(FieldConstant.ID_HUMP); QueryWrapper wrapper = new QueryWrapper<>(); wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id); @@ -101,4 +110,25 @@ public class CustomerStaffGridServiceImpl extends BaseServiceImpl Date: Wed, 8 Apr 2020 12:42:33 +0800 Subject: [PATCH 08/13] =?UTF-8?q?=E6=A0=B9=E6=8D=AE=E9=93=BE=E6=8E=A5?= =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E7=BE=A4=E7=BB=84=E4=BF=A1=E6=81=AF=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E4=BF=AE=E6=94=B9=E6=B7=BB=E5=8A=A0inGroup=E8=BF=94?= =?UTF-8?q?=E5=8F=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../commons/tools/constant/Constant.java | 10 +++ .../invitation/result/LinkGroupInfoDTO.java | 50 ++++++++++++++ .../result/LinkGroupInfoResultDTO.java | 33 ++------- .../invitation/dao/GroupInvitationDao.java | 5 +- .../impl/GroupInvitationServiceImpl.java | 67 ++++++++++++------- .../service/ResiGroupMemberService.java | 9 +++ .../impl/ResiGroupMemberServiceImpl.java | 37 +++++++--- .../mapper/invitation/GroupInvitationDao.xml | 2 +- 8 files changed, 144 insertions(+), 69 deletions(-) create mode 100644 epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/invitation/result/LinkGroupInfoDTO.java diff --git a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/Constant.java b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/Constant.java index e62ed4b7ce..256113a848 100644 --- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/Constant.java +++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/constant/Constant.java @@ -108,4 +108,14 @@ public interface Constant { * 版本控制用 */ String VERSION_CONTROL = "/{version}"; + + /** + * 是 + */ + String YES="yes"; + + /** + * 否 + */ + String NO="no"; } diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/invitation/result/LinkGroupInfoDTO.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/invitation/result/LinkGroupInfoDTO.java new file mode 100644 index 0000000000..240901878d --- /dev/null +++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/invitation/result/LinkGroupInfoDTO.java @@ -0,0 +1,50 @@ +package com.epmet.resi.group.dto.invitation.result; + +import lombok.Data; + +import java.io.Serializable; + +/** + * @Description 点击链接，查看组信息返参DTO + * @Author yinzuomei + * @Date 2020/4/8 11:22 + */ +@Data +public class LinkGroupInfoDTO implements Serializable { + private static final long serialVersionUID = 6136787210623326830L; + /** + * 群组id + */ + private String groupId; + + /** + * 群组头像 + */ + private String groupHeadPhoto; + + /** + * 组长名称！！！！！！！！ + * 暂定街道-姓名 + */ + private String leaderName; + + /** + * 群组名称 + */ + private String groupName; + + /** + * 组介绍 + */ + private String groupIntroduction; + + /** + * 成员总数 + */ + private Integer totalMember; + + /** + * 党员总数 + */ + private Integer totalPartyMember; +} diff --git a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/invitation/result/LinkGroupInfoResultDTO.java b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/invitation/result/LinkGroupInfoResultDTO.java index b856309601..fbbc9214ff 100644 --- a/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/invitation/result/LinkGroupInfoResultDTO.java +++ b/epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/invitation/result/LinkGroupInfoResultDTO.java @@ -14,38 +14,13 @@ public class LinkGroupInfoResultDTO implements Serializable { private static final long serialVersionUID = 8860336693592035343L; /** - * 群组id + * 是否在群内标志，已经在群内yes 不在群内no */ - private String groupId; + private String inGroup; /** - * 群组头像 + * 小组相关信息 */ - private String groupHeadPhoto; + private LinkGroupInfoDTO groupInfo; - /** - * 组长名称！！！！！！！！ - * 暂定街道-姓名 - */ - private String leaderName; - - /** - * 群组名称 - */ - private String groupName; - - /** - * 组介绍 - */ - private String groupIntroduction; - - /** - * 成员总数 - */ - private Integer totalMember; - - /** - * 党员总数 - */ - private Integer totalPartyMember; } diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/dao/GroupInvitationDao.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/dao/GroupInvitationDao.java index c521956b8b..0e3d4ce0f3 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/dao/GroupInvitationDao.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/dao/GroupInvitationDao.java @@ -19,8 +19,7 @@ package com.epmet.modules.invitation.dao; import com.epmet.commons.mybatis.dao.BaseDao; import com.epmet.modules.invitation.entity.GroupInvitationEntity; -import com.epmet.resi.group.dto.invitation.form.LinkGroupInfoFormDTO; -import com.epmet.resi.group.dto.invitation.result.LinkGroupInfoResultDTO; +import com.epmet.resi.group.dto.invitation.result.LinkGroupInfoDTO; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; @@ -40,5 +39,5 @@ public interface GroupInvitationDao extends BaseDao { * @Description 根据群邀请连接查询群基本信息 * @Date 2020/3/31 23:22 **/ - LinkGroupInfoResultDTO selectLinkGroupInfo(@Param("groupId") String groupId); + LinkGroupInfoDTO selectLinkGroupInfo(@Param("groupId") String groupId); } diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java index 1746b9b648..3b9d3d1059 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/invitation/service/impl/GroupInvitationServiceImpl.java @@ -21,6 +21,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; import com.epmet.commons.tools.constant.AppClientConstant; +import com.epmet.commons.tools.constant.Constant; import com.epmet.commons.tools.constant.FieldConstant; import com.epmet.commons.tools.constant.NumConstant; import com.epmet.commons.tools.exception.EpmetErrorCode; @@ -56,6 +57,7 @@ import com.epmet.resi.group.dto.invitation.form.AccetInvitationFormDTO; import com.epmet.resi.group.dto.invitation.form.CreateGroupInvitationFormDTO; import com.epmet.resi.group.dto.invitation.form.LinkGroupInfoFormDTO; import com.epmet.resi.group.dto.invitation.result.CreateGroupInvitationResultDTO; +import com.epmet.resi.group.dto.invitation.result.LinkGroupInfoDTO; import com.epmet.resi.group.dto.invitation.result.LinkGroupInfoResultDTO; import com.epmet.resi.group.dto.member.GroupMemeberOperationDTO; import com.epmet.resi.group.dto.member.ResiGroupMemberDTO; @@ -169,7 +171,7 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl().error(ModuleConstant.CANNOT_SHARED); } //3、插入一条邀请记录 @@ -199,17 +201,28 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl getLinkGroupInfo(LinkGroupInfoFormDTO formDTO) { //校验是否存在该邀请连接 Result validResult = this.checkLinkValid(formDTO.getInvitationId()); - if(!validResult.success()){ - return new Result().error(validResult.getCode(),validResult.getMsg()); + if (!validResult.success()) { + return new Result().error(validResult.getCode(), validResult.getMsg()); } - LinkGroupInfoResultDTO linkGroupInfoResultDTO = baseDao.selectLinkGroupInfo(validResult.getData().getResiGroupId()); - //获取组长信息 - Result groupLeaderUserInfo = this.getGroupLeaderUserInfo(linkGroupInfoResultDTO.getGroupId()); + LinkGroupInfoResultDTO linkGroupInfoResultDTO = new LinkGroupInfoResultDTO(); + //1、查询是否在群内 + ResiGroupMemberDTO resiGroupMemberDTO = resiGroupMemberDao.selectGroupMemberInfo(validResult.getData().getResiGroupId(), formDTO.getUserId()); + if (null != resiGroupMemberDTO && !MemberStateConstant.REMOVED.equals(resiGroupMemberDTO.getStatus())) { + linkGroupInfoResultDTO.setInGroup(Constant.YES); + return new Result().ok(linkGroupInfoResultDTO); + } else { + linkGroupInfoResultDTO.setInGroup(Constant.NO); + } + //2、查询组信息 + LinkGroupInfoDTO groupInfo = baseDao.selectLinkGroupInfo(validResult.getData().getResiGroupId()); + //3、获取组长信息 + Result groupLeaderUserInfo = this.getGroupLeaderUserInfo(groupInfo.getGroupId()); if (groupLeaderUserInfo.success() && null != groupLeaderUserInfo.getData()) { - linkGroupInfoResultDTO.setLeaderName(groupLeaderUserInfo.getData().getShowName()); + groupInfo.setLeaderName(groupLeaderUserInfo.getData().getShowName()); } else { logger.info("组长注册信息查询失败" + groupLeaderUserInfo.getMsg()); } + linkGroupInfoResultDTO.setGroupInfo(groupInfo); return new Result().ok(linkGroupInfoResultDTO); } @@ -236,15 +249,15 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl checkLinkValid(String invitationId){ + private Result checkLinkValid(String invitationId) { //校验是否存在该邀请连接 GroupInvitationDTO groupInvitationDTO = this.get(invitationId); //Date1.after(Date2),当Date1大于Date2时，返回TRUE，当小于等于时，返回false； if (null == groupInvitationDTO) { - return new Result().error(EpmetErrorCode.LOSE_EFFICACY.getValue(),EpmetErrorCode.LOSE_EFFICACY.getName()); + return new Result().error(EpmetErrorCode.LOSE_EFFICACY.getValue(), EpmetErrorCode.LOSE_EFFICACY.getName()); } if (null != groupInvitationDTO && !groupInvitationDTO.getValidEndTime().after(new Date())) { - return new Result().error(EpmetErrorCode.LOSE_EFFICACY.getValue(),EpmetErrorCode.LOSE_EFFICACY.getName()); + return new Result().error(EpmetErrorCode.LOSE_EFFICACY.getValue(), EpmetErrorCode.LOSE_EFFICACY.getName()); } return new Result().ok(groupInvitationDTO); } @@ -260,8 +273,8 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl validResult = this.checkLinkValid(formDTO.getInvitationId()); - if(!validResult.success()){ - return new Result().error(validResult.getCode(),validResult.getMsg()); + if (!validResult.success()) { + return new Result().error(validResult.getCode(), validResult.getMsg()); } //2、校验是否已经注册居民 ResiGroupDTO resiGroupDTO = resiGroupService.get(validResult.getData().getResiGroupId()); @@ -270,65 +283,69 @@ public class GroupInvitationServiceImpl extends BaseServiceImpl userResiInfoDTOResult=epmetUserFeignClient.getUserResiInfoDTO(userResiInfoFormDTO); - if(!userResiInfoDTOResult.success()||null==userResiInfoDTOResult.getData()){ - return ; + Result userResiInfoDTOResult = epmetUserFeignClient.getUserResiInfoDTO(userResiInfoFormDTO); + if (!userResiInfoDTOResult.success() || null == userResiInfoDTOResult.getData()) { + return; } - UserMessageFormDTO userMessage=new UserMessageFormDTO(); + UserMessageFormDTO userMessage = new UserMessageFormDTO(); userMessage.setApp(AppClientConstant.APP_RESI); userMessage.setCustomerId(resiGroupDTO.getCustomerId()); userMessage.setGridId(resiGroupDTO.getGridId()); - String messageContent=String.format(UserMessageConstant.INVITED_JOIN_GROUP,userResiInfoDTOResult.getData().getShowName(),resiGroupDTO.getGroupName()); + String messageContent = String.format(UserMessageConstant.INVITED_JOIN_GROUP, userResiInfoDTOResult.getData().getShowName(), resiGroupDTO.getGroupName()); userMessage.setMessageContent(messageContent); userMessage.setReadFlag(ReadFlagConstant.UN_READ); userMessage.setTitle(UserMessageConstant.GROUP_TITLE); diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/ResiGroupMemberService.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/ResiGroupMemberService.java index 0744a4c689..0daad30427 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/ResiGroupMemberService.java +++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/member/service/ResiGroupMemberService.java @@ -151,4 +151,13 @@ public interface ResiGroupMemberService extends BaseService - SELECT rg.id AS groupId, rg.GROUP_HEAD_PHOTO AS groupHeadPhoto, From 2c0f15869bb49590e22d69e740e925b496bfe337 Mon Sep 17 00:00:00 2001 From: sunyuchao Date: Wed, 8 Apr 2020 13:27:24 +0800 Subject: [PATCH 09/13] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E8=BF=94=E5=9B=9E=E7=9A=84=E6=8F=90=E7=A4=BA=E8=AF=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../resiregister/service/impl/ResiRegisterServiceImpl.java | 2 +- .../warmhearted/service/impl/ResiWarmheartedServiceImpl.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/resiregister/service/impl/ResiRegisterServiceImpl.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/resiregister/service/impl/ResiRegisterServiceImpl.java index 98ac4d9249..33922268a6 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/resiregister/service/impl/ResiRegisterServiceImpl.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/resiregister/service/impl/ResiRegisterServiceImpl.java @@ -41,7 +41,7 @@ public class ResiRegisterServiceImpl implements ResiRegisterService { if (null == formDTO || StringUtils.isBlank(formDTO.getCustomerId()) || StringUtils.isBlank(formDTO.getGridId()) || StringUtils.isBlank(formDTO.getVisitFrom())) { - return new Result().error(EpmetErrorCode.PARAMETER_EXCEPTION.getName()); + return new Result().error(EpmetErrorCode.PARTICIPATION_EXCEPTION.getName()); } formDTO.setUserId(tokenDTO.getUserId()); return epmetUserFeignClient.init(formDTO); diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedServiceImpl.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedServiceImpl.java index 49eec6960f..c8054780a1 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedServiceImpl.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedServiceImpl.java @@ -37,7 +37,7 @@ public class ResiWarmheartedServiceImpl implements ResiWarmheartedService { if (null == formDTO || StringUtils.isBlank(formDTO.getCustomerId()) || StringUtils.isBlank(formDTO.getGridId()) || StringUtils.isBlank(formDTO.getVisitFrom())) { - return new Result().error(EpmetErrorCode.PARAMETER_EXCEPTION.getName()); + return new Result().error(EpmetErrorCode.PARTICIPATION_EXCEPTION.getName()); } formDTO.setUserId(tokenDTO.getUserId()); return resiPartymemberFeignClient.init(formDTO); @@ -57,7 +57,7 @@ public class ResiWarmheartedServiceImpl implements ResiWarmheartedService { || StringUtils.isBlank(formDTO.getGridId()) || StringUtils.isBlank(formDTO.getResiWarmVisitId()) || StringUtils.isBlank(formDTO.getReason())) { - return new Result().error(EpmetErrorCode.PARAMETER_EXCEPTION.getName()); + return new Result().error(EpmetErrorCode.PARTICIPATION_EXCEPTION.getName()); } formDTO.setUserId(tokenDTO.getUserId()); return resiPartymemberFeignClient.submit(formDTO); From baeac394f3d8a84471b95e1760fb0cdee603752d Mon Sep 17 00:00:00 2001 From: yinzuomei <57602893@qq.com> Date: Wed, 8 Apr 2020 13:32:20 +0800 Subject: [PATCH 10/13] =?UTF-8?q?getUserResiInfoDTO=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E5=BA=9F=E5=BC=83=E6=94=B9=E4=B8=BAgetuserresiinfo?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/epmet/modules/feign/EpmetUserFeignClient.java | 5 +++-- .../modules/feign/fallback/EpmetUserFeignClientFallBack.java | 3 ++- .../service/impl/PartyMemberConfirmServiceImpl.java | 5 +++-- 3 files changed, 8 insertions(+), 5 deletions(-) diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/feign/EpmetUserFeignClient.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/feign/EpmetUserFeignClient.java index 69c93422a7..30cb07eb4b 100644 --- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/feign/EpmetUserFeignClient.java +++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/feign/EpmetUserFeignClient.java @@ -5,6 +5,7 @@ import com.epmet.commons.tools.utils.Result; import com.epmet.dto.UserResiInfoDTO; import com.epmet.dto.UserRoleDTO; import com.epmet.dto.form.UserResiInfoFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.modules.feign.fallback.EpmetUserFeignClientFallBack; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.PostMapping; @@ -23,8 +24,8 @@ public interface EpmetUserFeignClient { * @param userResiInfoFormDTO 参数 * @return Result */ - @PostMapping("/epmetuser/userresiinfo/getUserResiInfoDTO") - Result getUserResiInfoDTO(@RequestBody UserResiInfoFormDTO userResiInfoFormDTO); + @PostMapping("/epmetuser/userresiinfo/getuserresiinfo") + Result getUserResiInfoDTO(@RequestBody UserResiInfoFormDTO userResiInfoFormDTO); /** * 党员认证时，如果没有注册居民，则注册居民信息 diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/feign/fallback/EpmetUserFeignClientFallBack.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/feign/fallback/EpmetUserFeignClientFallBack.java index 257bbb295e..93e9d3cf20 100644 --- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/feign/fallback/EpmetUserFeignClientFallBack.java +++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/feign/fallback/EpmetUserFeignClientFallBack.java @@ -6,6 +6,7 @@ import com.epmet.commons.tools.utils.Result; import com.epmet.dto.UserResiInfoDTO; import com.epmet.dto.UserRoleDTO; import com.epmet.dto.form.UserResiInfoFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.modules.feign.EpmetUserFeignClient; import org.springframework.stereotype.Component; @@ -17,7 +18,7 @@ import org.springframework.stereotype.Component; @Component public class EpmetUserFeignClientFallBack implements EpmetUserFeignClient { @Override - public Result getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO) { + public Result getUserResiInfoDTO(UserResiInfoFormDTO userResiInfoFormDTO) { return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "getUserResiInfoDTO", userResiInfoFormDTO); } diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/PartyMemberConfirmServiceImpl.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/PartyMemberConfirmServiceImpl.java index 9ba74dda60..d6ea5ad2db 100644 --- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/PartyMemberConfirmServiceImpl.java +++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/PartyMemberConfirmServiceImpl.java @@ -8,6 +8,7 @@ import com.epmet.constant.PartyMemberConstant; import com.epmet.dto.UserResiInfoDTO; import com.epmet.dto.UserRoleDTO; import com.epmet.dto.form.UserResiInfoFormDTO; +import com.epmet.dto.result.UserResiInfoResultDTO; import com.epmet.modules.feign.EpmetMessageFeignClient; import com.epmet.modules.feign.EpmetUserFeignClient; import com.epmet.modules.partymember.entity.*; @@ -78,7 +79,7 @@ public class PartyMemberConfirmServiceImpl implements PartyMemberConfirmService UserResiInfoFormDTO userResiInfoFormDTO = new UserResiInfoFormDTO(); userResiInfoFormDTO.setCustomerId(fromDto.getCustomerId()); userResiInfoFormDTO.setUserId(fromDto.getUserId()); - UserResiInfoDTO userResiInfoResult = epmetUserFeignClient.getUserResiInfoDTO(userResiInfoFormDTO).getData(); + UserResiInfoResultDTO userResiInfoResult = epmetUserFeignClient.getUserResiInfoDTO(userResiInfoFormDTO).getData(); PartymemberInfoDTO partyMemberInfo = ConvertUtils.sourceToTarget(userResiInfoResult, PartymemberInfoDTO.class); partyMemberInfo.setMobile(userResiInfoResult.getRegMobile()); @@ -228,7 +229,7 @@ public class PartyMemberConfirmServiceImpl implements PartyMemberConfirmService UserResiInfoFormDTO userResiInfoFormDTO = new UserResiInfoFormDTO(); userResiInfoFormDTO.setCustomerId(partyMemberInfoDTO.getCustomerId()); userResiInfoFormDTO.setUserId(partyMemberInfoDTO.getUserId()); - Result userResiInfoResult = epmetUserFeignClient.getUserResiInfoDTO(userResiInfoFormDTO); + Result userResiInfoResult = epmetUserFeignClient.getUserResiInfoDTO(userResiInfoFormDTO); if (null == userResiInfoResult.getData()) { UserResiInfoDTO userResiInfoDTO = ConvertUtils.sourceToTarget(partyMemberInfoDTO, UserResiInfoDTO.class); userResiInfoDTO.setRegMobile(partyMemberInfoDTO.getMobile()); From f8e576d365269b5ceb967b26a9246e615841aae2 Mon Sep 17 00:00:00 2001 From: zhaoqifeng Date: Wed, 8 Apr 2020 14:08:37 +0800 Subject: [PATCH 11/13] =?UTF-8?q?=E5=85=9A=E5=91=98=E8=AE=A4=E8=AF=81?= =?UTF-8?q?=E5=88=9D=E5=A7=8B=E5=8C=96bug=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/PartyMemberConfirmServiceImpl.java | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/PartyMemberConfirmServiceImpl.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/PartyMemberConfirmServiceImpl.java index d6ea5ad2db..c52a1baae0 100644 --- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/PartyMemberConfirmServiceImpl.java +++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/partymember/service/impl/PartyMemberConfirmServiceImpl.java @@ -80,14 +80,16 @@ public class PartyMemberConfirmServiceImpl implements PartyMemberConfirmService userResiInfoFormDTO.setCustomerId(fromDto.getCustomerId()); userResiInfoFormDTO.setUserId(fromDto.getUserId()); UserResiInfoResultDTO userResiInfoResult = epmetUserFeignClient.getUserResiInfoDTO(userResiInfoFormDTO).getData(); - PartymemberInfoDTO partyMemberInfo = ConvertUtils.sourceToTarget(userResiInfoResult, - PartymemberInfoDTO.class); - partyMemberInfo.setMobile(userResiInfoResult.getRegMobile()); - partyMemberInfo.setEstate(userResiInfoResult.getDistrict()); - partyMemberInfo.setBuilding(userResiInfoResult.getBuildingAddress()); - result.setPartyMemberInfo(partyMemberInfo); - } + if (null != userResiInfoResult) { + PartymemberInfoDTO partyMemberInfo = ConvertUtils.sourceToTarget(userResiInfoResult, + PartymemberInfoDTO.class); + partyMemberInfo.setMobile(userResiInfoResult.getRegMobile()); + partyMemberInfo.setEstate(userResiInfoResult.getDistrict()); + partyMemberInfo.setBuilding(userResiInfoResult.getBuildingAddress()); + result.setPartyMemberInfo(partyMemberInfo); + } + } // 将访问行为存入热心居民申请行为记录表 String visitId = saveOrUpdateVisit(null, fromDto, PartyMemberConstant.OPERATE_INITIALIZE); From 72ee2e5ff4fb3d10c9cf715f300cedf4ffb5ed63 Mon Sep 17 00:00:00 2001 From: sunyuchao Date: Wed, 8 Apr 2020 14:18:22 +0800 Subject: [PATCH 12/13] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E5=85=A5=E5=8F=82=E5=8F=8A=E6=8F=90=E7=A4=BA=E8=AF=AD=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../commons/tools/exception/EpmetErrorCode.java | 11 +---------- .../impl/CustomerStaffGridServiceImpl.java | 4 ++-- .../modules/exception/ModuleErrorCode.java | 6 ++++-- .../service/impl/ResiRegisterServiceImpl.java | 17 ++++++++++------- .../impl/ResiWarmheartedServiceImpl.java | 8 ++++---- .../impl/ResiWarmheartedApplyServiceImpl.java | 1 - .../epmet/dto/form/ResiInfoSubmitFormDTO.java | 5 +++++ .../epmet/dto/form/VerificationCodeFormDTO.java | 3 +++ .../constant/UserResiRegisterConstant.java | 6 +++++- .../service/impl/UserResiInfoServiceImpl.java | 3 +-- .../impl/UserResiRegisterVisitServiceImpl.java | 4 ++-- 11 files changed, 37 insertions(+), 31 deletions(-) diff --git a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java index c659d19404..f2f209ea6e 100644 --- a/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java +++ b/epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/exception/EpmetErrorCode.java @@ -17,16 +17,7 @@ public enum EpmetErrorCode { MOBILE_CODE_ERROR(8102, "手机验证码错误"), AUTO_CONFIRM_FAILED(8103, "自动认证失败"), MOBILE_GET_CODE_ERROR(8104,"获取手机验证码失败"), - MESSAGE_SMS_SEND_ERROR(8105, "短信发送失败"), - - - /** - * 手机号已存在 - */ - MOBILE_EXIST(8201, "该手机号已注册居民，请使用其他手机号注册！"), - PARAMETER_EXCEPTION(8202, "必要参数存在空值或手机号输入不合规，请检查参数赋值情况！！"), - UPDATE_EXCEPTION(8203, "用户居民注册访问记录表更新数据失败！"), - PARTICIPATION_EXCEPTION(8204, "参数异常，请检查所传参数是否合规！"); + MESSAGE_SMS_SEND_ERROR(8105, "短信发送失败"); private int value; diff --git a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerStaffGridServiceImpl.java b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerStaffGridServiceImpl.java index 11b01de27b..6bb2f7243f 100644 --- a/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerStaffGridServiceImpl.java +++ b/epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/CustomerStaffGridServiceImpl.java @@ -120,12 +120,12 @@ public class CustomerStaffGridServiceImpl extends BaseServiceImpl * https://www.renren.io - * + *

* 版权所有，侵权必究！ */ @@ -22,4 +22,6 @@ import com.epmet.commons.tools.exception.ErrorCode; */ public interface ModuleErrorCode extends ErrorCode { + String PARTICIPATION_EXCEPTION = "参数异常,请检查所传参数是否符合规范以及是否存在空值"; + String MOBILE_EXCEPTION = "手机号输入不符合规范，请重新输入"; } diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/resiregister/service/impl/ResiRegisterServiceImpl.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/resiregister/service/impl/ResiRegisterServiceImpl.java index 33922268a6..1def10010d 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/resiregister/service/impl/ResiRegisterServiceImpl.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/resiregister/service/impl/ResiRegisterServiceImpl.java @@ -1,6 +1,5 @@ package com.epmet.modules.resiregister.service.impl; -import com.epmet.commons.tools.exception.EpmetErrorCode; import com.epmet.commons.tools.security.dto.TokenDto; import com.epmet.commons.tools.utils.Result; import com.epmet.dto.UserResiInfoDTO; @@ -8,6 +7,7 @@ import com.epmet.dto.form.ResiInfoSubmitFormDTO; import com.epmet.dto.form.ResiRegisterFormDTO; import com.epmet.dto.form.VerificationCodeFormDTO; import com.epmet.dto.result.ResiRegisterResultDTO; +import com.epmet.modules.exception.ModuleErrorCode; import com.epmet.modules.feign.EpmetUserFeignClient; import com.epmet.modules.resiregister.service.ResiRegisterService; import com.epmet.modules.utils.ModuleConstant; @@ -38,11 +38,11 @@ public class ResiRegisterServiceImpl implements ResiRegisterService { if (null == tokenDTO || StringUtils.isBlank(tokenDTO.getUserId())) { return new Result().error(ModuleConstant.USER_NOT_NULL); } - if (null == formDTO || StringUtils.isBlank(formDTO.getCustomerId()) + /*if (null == formDTO || StringUtils.isBlank(formDTO.getCustomerId()) || StringUtils.isBlank(formDTO.getGridId()) || StringUtils.isBlank(formDTO.getVisitFrom())) { - return new Result().error(EpmetErrorCode.PARTICIPATION_EXCEPTION.getName()); - } + return new Result().error(ModuleErrorCode.PARTICIPATION_EXCEPTION); + }*/ formDTO.setUserId(tokenDTO.getUserId()); return epmetUserFeignClient.init(formDTO); } @@ -57,11 +57,11 @@ public class ResiRegisterServiceImpl implements ResiRegisterService { if (null == tokenDTO || StringUtils.isBlank(tokenDTO.getUserId())) { return new Result().error(ModuleConstant.USER_NOT_NULL); } - if (null == resiInfoSubmitFormDTO || StringUtils.isBlank(resiInfoSubmitFormDTO.getCustomerId()) + /*if (null == resiInfoSubmitFormDTO || StringUtils.isBlank(resiInfoSubmitFormDTO.getCustomerId()) || StringUtils.isBlank(resiInfoSubmitFormDTO.getGridId()) || StringUtils.isBlank(resiInfoSubmitFormDTO.getResiVisitId())) { return new Result().error(EpmetErrorCode.PARAMETER_EXCEPTION.getName()); - } + }*/ UserResiInfoDTO userResiInfoDTO = resiInfoSubmitFormDTO.getResiInfo(); userResiInfoDTO.setUserId(tokenDTO.getUserId()); userResiInfoDTO.setApp(tokenDTO.getApp()); @@ -81,10 +81,13 @@ public class ResiRegisterServiceImpl implements ResiRegisterService { if (null == tokenDTO || StringUtils.isBlank(tokenDTO.getUserId())) { return new Result().error(ModuleConstant.USER_NOT_NULL); } - if (null == formDTO || StringUtils.isBlank(formDTO.getMobile()) + /*if (null == formDTO || StringUtils.isBlank(formDTO.getMobile()) || StringUtils.isBlank(formDTO.getResiVisitId()) || !validateMobile(formDTO.getMobile())) { return new Result().error(EpmetErrorCode.PARAMETER_EXCEPTION.getName()); + }*/ + if (!validateMobile(formDTO.getMobile())) { + return new Result().error(ModuleErrorCode.MOBILE_EXCEPTION); } formDTO.setUserId(tokenDTO.getUserId()); return epmetUserFeignClient.getVerificationCode(formDTO); diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedServiceImpl.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedServiceImpl.java index c8054780a1..0448f99547 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedServiceImpl.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedServiceImpl.java @@ -34,11 +34,11 @@ public class ResiWarmheartedServiceImpl implements ResiWarmheartedService { if (null == tokenDTO || StringUtils.isBlank(tokenDTO.getUserId())) { return new Result().error(ModuleConstant.USER_NOT_NULL); } - if (null == formDTO || StringUtils.isBlank(formDTO.getCustomerId()) + /* if (null == formDTO || StringUtils.isBlank(formDTO.getCustomerId()) || StringUtils.isBlank(formDTO.getGridId()) || StringUtils.isBlank(formDTO.getVisitFrom())) { return new Result().error(EpmetErrorCode.PARTICIPATION_EXCEPTION.getName()); - } + }*/ formDTO.setUserId(tokenDTO.getUserId()); return resiPartymemberFeignClient.init(formDTO); } @@ -53,12 +53,12 @@ public class ResiWarmheartedServiceImpl implements ResiWarmheartedService { if (null == tokenDTO || StringUtils.isBlank(tokenDTO.getUserId())) { return new Result().error(ModuleConstant.USER_NOT_NULL); } - if (null == formDTO || StringUtils.isBlank(formDTO.getCustomerId()) + /*if (null == formDTO || StringUtils.isBlank(formDTO.getCustomerId()) || StringUtils.isBlank(formDTO.getGridId()) || StringUtils.isBlank(formDTO.getResiWarmVisitId()) || StringUtils.isBlank(formDTO.getReason())) { return new Result().error(EpmetErrorCode.PARTICIPATION_EXCEPTION.getName()); - } + }*/ formDTO.setUserId(tokenDTO.getUserId()); return resiPartymemberFeignClient.submit(formDTO); } diff --git a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedApplyServiceImpl.java b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedApplyServiceImpl.java index 221a90fc4b..a5765fa744 100644 --- a/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedApplyServiceImpl.java +++ b/epmet-module/resi-partymember/resi-partymember-server/src/main/java/com/epmet/modules/warmhearted/service/impl/ResiWarmheartedApplyServiceImpl.java @@ -163,7 +163,6 @@ public class ResiWarmheartedApplyServiceImpl extends BaseServiceImpl Date: Wed, 8 Apr 2020 14:43:27 +0800 Subject: [PATCH 13/13] =?UTF-8?q?=E8=8E=B7=E5=8F=96=E6=88=91=E7=9A=84?= =?UTF-8?q?=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/UserMessageController.java | 12 +++++-- .../java/com/epmet/dao/UserMessageDao.java | 12 ++++--- .../com/epmet/service/UserMessageService.java | 8 +++++ .../service/impl/UserMessageServiceImpl.java | 28 ++++++++++------ .../main/resources/mapper/UserMessageDao.xml | 32 +++++++++++++++++-- .../feign/EpmetMessageFeignClient.java | 10 +++--- .../EpmetMessageFeignClientFallBack.java | 8 ++--- .../controller/UserMessageController.java | 7 ++-- .../message/service/UserMessageService.java | 5 +-- .../service/impl/UserMessageServiceImpl.java | 15 +++------ 10 files changed, 92 insertions(+), 45 deletions(-) diff --git a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/controller/UserMessageController.java b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/controller/UserMessageController.java index 5a56dab9ae..3c9a2ba01a 100644 --- a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/controller/UserMessageController.java +++ b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/controller/UserMessageController.java @@ -23,9 +23,10 @@ import com.epmet.commons.tools.utils.Result; import com.epmet.commons.tools.validator.AssertUtils; import com.epmet.commons.tools.validator.ValidatorUtils; import com.epmet.commons.tools.validator.group.AddGroup; -import com.epmet.commons.tools.validator.group.UpdateGroup; import com.epmet.commons.tools.validator.group.DefaultGroup; +import com.epmet.commons.tools.validator.group.UpdateGroup; import com.epmet.dto.UserMessageDTO; +import com.epmet.dto.form.MymessageFormDTO; import com.epmet.dto.form.UserMessageFormDTO; import com.epmet.excel.UserMessageExcel; import com.epmet.service.UserMessageService; @@ -50,8 +51,8 @@ public class UserMessageController { @Autowired private UserMessageService userMessageService; - @GetMapping("page") - public Result> page(@RequestParam Map params){ + @PostMapping("page") + public Result> page(@RequestBody Map params){ PageData page = userMessageService.page(params); return new Result>().ok(page); } @@ -126,4 +127,9 @@ public class UserMessageController { ValidatorUtils.validateEntity(formDto); return userMessageService.saveUserMessage(formDto); } + + @PostMapping("mymsg") + public Result> getMyMessageList(@RequestBody MymessageFormDTO params){ + return userMessageService.getMyMessageList(params); + } } \ No newline at end of file diff --git a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/dao/UserMessageDao.java b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/dao/UserMessageDao.java index 01c3898318..db8cc78e3c 100644 --- a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/dao/UserMessageDao.java +++ b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/dao/UserMessageDao.java @@ -18,9 +18,12 @@ package com.epmet.dao; import com.epmet.commons.mybatis.dao.BaseDao; +import com.epmet.dto.form.MymessageFormDTO; import com.epmet.entity.UserMessageEntity; import org.apache.ibatis.annotations.Mapper; +import java.util.List; + /** * 用户消息表 * @@ -29,11 +32,12 @@ import org.apache.ibatis.annotations.Mapper; */ @Mapper public interface UserMessageDao extends BaseDao { + /** - * 更新阅读状态为已读 - * - * @param entity 参数 + * 获取消息分页 + * @param messageFromDTO + * @return */ - void updateReadFlag(UserMessageEntity entity); + List selectMyMessageList(MymessageFormDTO messageFromDTO); } \ No newline at end of file diff --git a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/UserMessageService.java b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/UserMessageService.java index e4a76b9b0b..1555f73aed 100644 --- a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/UserMessageService.java +++ b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/UserMessageService.java @@ -21,6 +21,7 @@ import com.epmet.commons.mybatis.service.BaseService; import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.utils.Result; import com.epmet.dto.UserMessageDTO; +import com.epmet.dto.form.MymessageFormDTO; import com.epmet.dto.form.UserMessageFormDTO; import com.epmet.entity.UserMessageEntity; @@ -119,4 +120,11 @@ public interface UserMessageService extends BaseService { * @Date 2020/4/7 15:34 **/ Result saveUserMessage(UserMessageFormDTO formDto); + + /** + * 获取我的消息列表 + * @param param 参数 + * @return + */ + Result> getMyMessageList(MymessageFormDTO param); } \ No newline at end of file diff --git a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/UserMessageServiceImpl.java b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/UserMessageServiceImpl.java index f343684809..8354b9166c 100644 --- a/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/UserMessageServiceImpl.java +++ b/epmet-module/epmet-message/epmet-message-server/src/main/java/com/epmet/service/impl/UserMessageServiceImpl.java @@ -20,13 +20,15 @@ package com.epmet.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; +import com.epmet.commons.tools.constant.FieldConstant; +import com.epmet.commons.tools.constant.NumConstant; import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.utils.ConvertUtils; -import com.epmet.commons.tools.constant.FieldConstant; import com.epmet.commons.tools.utils.Result; import com.epmet.constant.UserMessageConstans; import com.epmet.dao.UserMessageDao; import com.epmet.dto.UserMessageDTO; +import com.epmet.dto.form.MymessageFormDTO; import com.epmet.dto.form.UserMessageFormDTO; import com.epmet.entity.UserMessageEntity; import com.epmet.redis.UserMessageRedis; @@ -72,13 +74,13 @@ public class UserMessageServiceImpl extends BaseServiceImpl wrapper = new QueryWrapper<>(); wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id) - .eq(StringUtils.isNotBlank(customerId), FieldConstant.CUSTOMER_ID, customerId) - .eq(StringUtils.isNotBlank(gridId), FieldConstant.GRID_ID, gridId) - .eq(StringUtils.isNotBlank(userId), FieldConstant.USER_ID, userId); + .eq(StringUtils.isNotBlank(customerId), FieldConstant.CUSTOMER_ID, customerId) + .eq(StringUtils.isNotBlank(gridId), FieldConstant.GRID_ID, gridId) + .eq(StringUtils.isNotBlank(userId), FieldConstant.USER_ID, userId); return wrapper; } @@ -121,13 +123,13 @@ public class UserMessageServiceImpl extends BaseServiceImpl getWrapper(UserMessageDTO messageDTO) { String id = messageDTO.getId(); @@ -143,7 +145,7 @@ public class UserMessageServiceImpl extends BaseServiceImpl> getMyMessageList(MymessageFormDTO params) { + int pageIndex = (params.getPageNo() - NumConstant.ONE) * params.getPageSize(); + params.setPageNo(pageIndex); + List myMessageList = baseDao.selectMyMessageList(params); + return new Result>().ok(ConvertUtils.sourceToTarget(myMessageList, UserMessageDTO.class)); + } + } \ No newline at end of file diff --git a/epmet-module/epmet-message/epmet-message-server/src/main/resources/mapper/UserMessageDao.xml b/epmet-module/epmet-message/epmet-message-server/src/main/resources/mapper/UserMessageDao.xml index 381f748093..e00cc96051 100644 --- a/epmet-module/epmet-message/epmet-message-server/src/main/resources/mapper/UserMessageDao.xml +++ b/epmet-module/epmet-message/epmet-message-server/src/main/resources/mapper/UserMessageDao.xml @@ -3,7 +3,7 @@ - + @@ -19,9 +19,35 @@ - - + \ No newline at end of file diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/EpmetMessageFeignClient.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/EpmetMessageFeignClient.java index 0fed7222eb..15426bb538 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/EpmetMessageFeignClient.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/EpmetMessageFeignClient.java @@ -1,17 +1,15 @@ package com.epmet.modules.feign; import com.epmet.commons.tools.constant.ServiceConstant; -import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.utils.Result; import com.epmet.dto.UserMessageDTO; +import com.epmet.dto.form.MymessageFormDTO; import com.epmet.modules.feign.fallback.EpmetMessageFeignClientFallBack; import org.springframework.cloud.openfeign.FeignClient; -import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestParam; -import java.util.Map; +import java.util.List; /** * @author zhaoqifeng @@ -27,8 +25,8 @@ public interface EpmetMessageFeignClient { * @param params 参数 * @return Result> */ - @GetMapping("/message/usermessage/page") - Result> page(@RequestParam Map params); + @PostMapping("/message/usermessage/mymsg") + Result> getMyMessageList(@RequestBody MymessageFormDTO params); /** * 单条消息已读 diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/fallback/EpmetMessageFeignClientFallBack.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/fallback/EpmetMessageFeignClientFallBack.java index 43635879e7..72758c4a8e 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/fallback/EpmetMessageFeignClientFallBack.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/feign/fallback/EpmetMessageFeignClientFallBack.java @@ -1,14 +1,14 @@ package com.epmet.modules.feign.fallback; import com.epmet.commons.tools.constant.ServiceConstant; -import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.utils.ModuleUtils; import com.epmet.commons.tools.utils.Result; import com.epmet.dto.UserMessageDTO; +import com.epmet.dto.form.MymessageFormDTO; import com.epmet.modules.feign.EpmetMessageFeignClient; import org.springframework.stereotype.Component; -import java.util.Map; +import java.util.List; /** * @author zhaoqifeng @@ -18,8 +18,8 @@ import java.util.Map; @Component public class EpmetMessageFeignClientFallBack implements EpmetMessageFeignClient { @Override - public Result> page(Map params) { - return ModuleUtils.feignConError(ServiceConstant.EPMET_MESSAGE_SERVER, "page", params); + public Result> getMyMessageList(MymessageFormDTO params) { + return ModuleUtils.feignConError(ServiceConstant.EPMET_MESSAGE_SERVER, "getMyMessageList", params); } @Override diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/controller/UserMessageController.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/controller/UserMessageController.java index 48479bc44c..d0c75c990c 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/controller/UserMessageController.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/controller/UserMessageController.java @@ -1,7 +1,6 @@ package com.epmet.modules.message.controller; import com.epmet.commons.tools.annotation.LoginUser; -import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.security.dto.TokenDto; import com.epmet.commons.tools.utils.Result; import com.epmet.commons.tools.validator.ValidatorUtils; @@ -11,6 +10,8 @@ import com.epmet.modules.message.service.UserMessageService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; +import java.util.List; + /** * @Description 我的消息 * @Author yinzuomei @@ -30,8 +31,8 @@ public class UserMessageController { * @Date 2020/3/29 20:53 **/ @PostMapping("getmymessage") - public Result> getMyMessage(@LoginUser TokenDto tokenDto, - @RequestBody MymessageFormDTO mymessageFormDTO) { + public Result> getMyMessage(@LoginUser TokenDto tokenDto, + @RequestBody MymessageFormDTO mymessageFormDTO) { mymessageFormDTO.setUserId(tokenDto.getUserId()); ValidatorUtils.validateEntity(mymessageFormDTO); //逻辑待实现 diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/UserMessageService.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/UserMessageService.java index de27818e3f..af96e93389 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/UserMessageService.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/UserMessageService.java @@ -1,11 +1,12 @@ package com.epmet.modules.message.service; -import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.security.dto.TokenDto; import com.epmet.commons.tools.utils.Result; import com.epmet.dto.UserMessageDTO; import com.epmet.dto.form.MymessageFormDTO; +import java.util.List; + /** * @Description 我的消息 * @Author yinzuomei @@ -20,7 +21,7 @@ public interface UserMessageService { * @param messageFromDTO 参数 * @return Result> */ - Result> getMessageList(TokenDto tokenDto, MymessageFormDTO messageFromDTO); + Result> getMessageList(TokenDto tokenDto, MymessageFormDTO messageFromDTO); /** * 单条消息标记为已读 diff --git a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/impl/UserMessageServiceImpl.java b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/impl/UserMessageServiceImpl.java index efb914a94e..4743602217 100644 --- a/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/impl/UserMessageServiceImpl.java +++ b/epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/message/service/impl/UserMessageServiceImpl.java @@ -1,6 +1,5 @@ package com.epmet.modules.message.service.impl; -import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.security.dto.TokenDto; import com.epmet.commons.tools.utils.Result; import com.epmet.dto.UserMessageDTO; @@ -10,8 +9,7 @@ import com.epmet.modules.message.service.UserMessageService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; -import java.util.HashMap; -import java.util.Map; +import java.util.List; /** * @Description 我的消息 @@ -24,14 +22,9 @@ public class UserMessageServiceImpl implements UserMessageService { private EpmetMessageFeignClient messageFeignClient; @Override - public Result> getMessageList(TokenDto tokenDto, MymessageFormDTO messageFromDTO) { - Map param = new HashMap(); - param.put("customerId", messageFromDTO.getCustomerId()); - param.put("gridId", messageFromDTO.getGridId()); - param.put("userId", tokenDto.getUserId()); - param.put("pageNo", messageFromDTO.getPageNo()); - param.put("pageSize", messageFromDTO.getPageSize()); - Result> result = messageFeignClient.page(param); + public Result> getMessageList(TokenDto tokenDto, MymessageFormDTO messageFromDTO) { + messageFromDTO.setUserId(tokenDto.getUserId()); + Result> result = messageFeignClient.getMyMessageList(messageFromDTO); return result; }