消息修改

jero-boot-incoming-payment/src/main/java/com/jero/payment/service/impl/PayPaymentCheckServiceImpl.java

@@ -15,13 +15,12 @@ import com.jero.common.service.SendMessageService;
 import com.jero.common.system.api.ISysBaseAPI;
 import com.jero.common.system.vo.LoginUser;
 import com.jero.common.util.PasswordUtil;
+import com.jero.company.entity.PayContactsManagement;
+import com.jero.company.service.IPayContactsManagementService;
 import com.jero.contract.common.PayIncomeContractCommon;
-import com.jero.meeting.entity.PayMeetingSituation;
 import com.jero.meeting.mapper.PayMeetingSituationMapper;
 import com.jero.member.entity.PayMemberProject;
 import com.jero.member.entity.PayMemberProjectSubitem;
-import com.jero.member.entity.TbCertificatePayment;
-import com.jero.member.entity.TbMemberProjectSubitem;
 import com.jero.member.mapper.PayMemberProjectSubitemMapper;
 import com.jero.member.mapper.TbCertificatePaymentMapper;
 import com.jero.member.mapper.TbMemberProjectSubitemMapper;
@@ -91,6 +90,8 @@ public class PayPaymentCheckServiceImpl extends ServiceImpl<PayPaymentCheckMappe
     private ISysBaseAPI sysBaseAPI;
     @Resource
     private IPayWorkingGroupService payWorkingGroupService;
+    @Resource
+    private IPayContactsManagementService payContactsManagementService;
 
     /**
      *  来款列表
@@ -358,24 +359,26 @@ public class PayPaymentCheckServiceImpl extends ServiceImpl<PayPaymentCheckMappe
     /**
     * @Description 汇款凭证审核不通过 审核人 给申请人发送消息
     * @Date 2021/12/16 11:34
-     * @param userId 申请人id
+     * @param phone 企业端用户手机号
      * @param projectId 项目id
      * @param projectName 项目名称
      * @param projectType 项目类型
     * @return void
     */
-    private void checkSendMessage(String userId,String projectId,String projectName,String projectType){
+    private void checkSendMessage(String phone,String projectId,String projectName,String projectType){
         LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
-        SysUser sysUserData = sysUserService.getById(userId);
+        LambdaQueryWrapper<PayContactsManagement> queryPayContactsManagement = new LambdaQueryWrapper<>();
-        if(!Objects.isNull(sysUserData)){
+        queryPayContactsManagement.eq(PayContactsManagement::getPhone,phone);
+        List<PayContactsManagement> payContactsManagement = payContactsManagementService.list(queryPayContactsManagement);
+        if(CollectionUtils.isEmpty(payContactsManagement)){
             // 发送消息
             SendMessageDTO sendMessageDTO = new SendMessageDTO();
-            if(!StringUtils.isBlank(sysUserData.getEmail())){
+            if(!StringUtils.isBlank(payContactsManagement.get(0).getEmail())){
-                sendMessageDTO.setEmail(PasswordUtil.decrypt(sysUserData.getEmail()));
+                sendMessageDTO.setEmail(PasswordUtil.decrypt(payContactsManagement.get(0).getEmail()));
             }
-            if(!StringUtils.isEmpty(sysUserData.getPhone())){
+            if(!StringUtils.isEmpty(payContactsManagement.get(0).getPhone())){
-                sendMessageDTO.setPhone(PasswordUtil.decrypt(sysUserData.getPhone()));
+                sendMessageDTO.setPhone(PasswordUtil.decrypt(payContactsManagement.get(0).getPhone()));
-                sendMessageDTO.setToUser(PasswordUtil.decrypt(sysUserData.getPhone()));
+                sendMessageDTO.setToUser(PasswordUtil.decrypt(payContactsManagement.get(0).getPhone()));
             }
             HashMap<String,String> map = new HashMap<>();
             map.put("projectName",projectName);