diff --git a/jero-boot-incoming-payment/src/main/java/com/jero/project/controller/PayWorkingGroupDistributionRecordController.java b/jero-boot-incoming-payment/src/main/java/com/jero/project/controller/PayWorkingGroupDistributionRecordController.java index 6dd66054..d9fa9536 100644 --- a/jero-boot-incoming-payment/src/main/java/com/jero/project/controller/PayWorkingGroupDistributionRecordController.java +++ b/jero-boot-incoming-payment/src/main/java/com/jero/project/controller/PayWorkingGroupDistributionRecordController.java @@ -133,7 +133,7 @@ public class PayWorkingGroupDistributionRecordController extends JeroController< @PostMapping(value = "/add") public Result add(@RequestBody PayWorkingGroupDistributionRecord payWorkingGroupDistributionRecord) { payWorkingGroupDistributionRecordService.add(payWorkingGroupDistributionRecord); - return Result.OK("添加成功!"); + return Result.OK("分发成功!"); } /** diff --git a/jero-boot-incoming-payment/src/main/java/com/jero/project/controller/PayWorkingGroupSubItemController.java b/jero-boot-incoming-payment/src/main/java/com/jero/project/controller/PayWorkingGroupSubItemController.java index f47a59fc..f490faf9 100644 --- a/jero-boot-incoming-payment/src/main/java/com/jero/project/controller/PayWorkingGroupSubItemController.java +++ b/jero-boot-incoming-payment/src/main/java/com/jero/project/controller/PayWorkingGroupSubItemController.java @@ -175,6 +175,7 @@ public class PayWorkingGroupSubItemController extends JeroController listFile = new ArrayList<>(); listFile.add(fileName); List list = new ArrayList<>(); - if(payWorkingGroupDistributionRecord.getProjectType() != PayProjectCommon.PROJECT_TYPE_FILE1){ + String msg = ""; + if(payWorkingGroupDistributionRecord.getProjectType() == PayProjectCommon.PROJECT_TYPE_FILE1){ LambdaQueryWrapper queryPayContactsManagementTemporary = new LambdaQueryWrapper<>(); queryPayContactsManagementTemporary.in(PayContactsManagementTemporary::getId, Arrays.asList(s)); List listContacts = payContactsManagementTemporaryService.list(queryPayContactsManagementTemporary); if(!CollectionUtils.isEmpty(listContacts)){ list = listContacts.stream().map(PayContactsManagementTemporary::getEmail).collect(Collectors.toList()); } - - }else if(payWorkingGroupDistributionRecord.getProjectType() != PayProjectCommon.PROJECT_TYPE_FILE2){ + PayWorkingGroup payWorkingGroup = payWorkingGroupService.getById(payWorkingGroupDistributionRecord.getProjectId()); + if(Objects.isNull(payWorkingGroup)){ + throw new JeroBootException("工作组不存在!"); + } + msg = payWorkingGroup.getWorkingGroupProject(); + }else if(payWorkingGroupDistributionRecord.getProjectType() == PayProjectCommon.PROJECT_TYPE_FILE2){ LambdaQueryWrapper queryPayContactsManagement = new LambdaQueryWrapper<>(); queryPayContactsManagement.in(PayContactsManagement::getId, Arrays.asList(payWorkingGroupDistributionRecord.getContactsIds().split(","))); List listContacts = payContactsManagementService.list(queryPayContactsManagement); if(!CollectionUtils.isEmpty(listContacts)){ list = listContacts.stream().map(PayContactsManagement::getEmail).collect(Collectors.toList()); } + PayCaseCommittee payCaseCommittee = payCaseCommitteeService.getById(payWorkingGroupDistributionRecord.getProjectId()); + if(Objects.isNull(payCaseCommittee)){ + throw new JeroBootException("分标委不存在!"); + } + msg = payCaseCommittee.getName(); }else{ throw new JeroBootException("项目状态不正确!"); } if(CollectionUtils.isEmpty(list) || CollectionUtils.isEmpty(listFile)){ throw new JeroBootException("分发失败!"); } + StringBuilder str = new StringBuilder(); + List finalList = list; list.forEach(p->{ if(StringUtils.isBlank(p)){ return; } - p = PasswordUtil.decrypt(p); + str.append(PasswordUtil.decrypt(p)); + if(finalList.indexOf(p) < finalList.size() - 1){ + str.append(","); + } }); - String str = JSON.toJSONString(list); + if(StringUtils.isBlank(str)){ + throw new JeroBootException("分发失败!"); + } + String content = msg + "文件已发送到您的账号和邮箱,可通过手机号登录系统XXX(点击链接可进入系统)或微信小程序搜素XXX进入查看"; EmailSendMsgHandle emailHandle = new EmailSendMsgHandle(); - emailHandle.SendMsgAndFile(str, "", "", listFile); + emailHandle.SendMsgAndFile(str.toString(), "", content, listFile); + // todo 缺少发送消息 } @Override @@ -138,22 +165,32 @@ public class PayWorkingGroupDistributionRecordServiceImpl extends ServiceImpl list = new ArrayList<>(); - if(payWorkingGroupDistributionRecord.getProjectType() != PayProjectCommon.PROJECT_TYPE_FILE1){ + if(payWorkingGroupDistributionRecord.getProjectType() == PayProjectCommon.PROJECT_TYPE_FILE1){ LambdaQueryWrapper queryPayContactsManagementTemporary = new LambdaQueryWrapper<>(); queryPayContactsManagementTemporary.in(PayContactsManagementTemporary::getId, Arrays.asList(s)); List listContacts = payContactsManagementTemporaryService.list(queryPayContactsManagementTemporary); if(!CollectionUtils.isEmpty(listContacts)){ list = listContacts.stream().map(PayContactsManagementTemporary::getEmail).collect(Collectors.toList()); } - - }else if(payWorkingGroupDistributionRecord.getProjectType() != PayProjectCommon.PROJECT_TYPE_FILE2){ + PayWorkingGroup payWorkingGroup = payWorkingGroupService.getById(payWorkingGroupDistributionRecord.getProjectId()); + if(Objects.isNull(payWorkingGroup)){ + throw new JeroBootException("工作组不存在!"); + } + msg = payWorkingGroup.getWorkingGroupProject(); + }else if(payWorkingGroupDistributionRecord.getProjectType() == PayProjectCommon.PROJECT_TYPE_FILE2){ LambdaQueryWrapper queryPayContactsManagement = new LambdaQueryWrapper<>(); queryPayContactsManagement.in(PayContactsManagement::getId, Arrays.asList(n)); List listContacts = payContactsManagementService.list(queryPayContactsManagement); if(!CollectionUtils.isEmpty(listContacts)){ list = listContacts.stream().map(PayContactsManagement::getEmail).collect(Collectors.toList()); } + PayCaseCommittee payCaseCommittee = payCaseCommitteeService.getById(payWorkingGroupDistributionRecord.getProjectId()); + if(Objects.isNull(payCaseCommittee)){ + throw new JeroBootException("分标委不存在!"); + } + msg = payCaseCommittee.getName(); }else{ throw new JeroBootException("项目状态不正确!"); } @@ -166,8 +203,23 @@ public class PayWorkingGroupDistributionRecordServiceImpl extends ServiceImpl finalList = list; + list.forEach(p->{ + if(StringUtils.isBlank(p)){ + return; + } + str.append(PasswordUtil.decrypt(p)); + if(finalList.indexOf(p) < finalList.size() - 1){ + str.append(","); + } + }); + if(StringUtils.isBlank(str)){ + throw new JeroBootException("分发失败!"); + } + String content = msg + "文件已发送到您的账号和邮箱,可通过手机号登录系统XXX(点击链接可进入系统)或微信小程序搜素XXX进入查看"; EmailSendMsgHandle emailHandle = new EmailSendMsgHandle(); - emailHandle.SendMsgAndFile(str, "", "", listFile); + emailHandle.SendMsgAndFile(str.toString(), "", content, listFile); + // todo 缺少发送消息 } }