From 001882d13a85bc11541f241b0ce0f18a82eb248e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=A2=81=E7=90=A6=E6=B6=9B?= <18222067976@163.com>
Date: Thu, 18 Nov 2021 11:42:38 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E5=87=BA=E5=90=88=E5=90=8C=E6=B7=BB?=
 =?UTF-8?q?=E5=8A=A0=E5=8F=91=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../common/PayIncomeContractCommon.java       |   5 +
 .../impl/PaySpendingContractServiceImpl.java  | 117 ++++++++++++++++++
 2 files changed, 122 insertions(+)

diff --git a/jero-boot-incoming-payment/src/main/java/com/jero/contract/common/PayIncomeContractCommon.java b/jero-boot-incoming-payment/src/main/java/com/jero/contract/common/PayIncomeContractCommon.java
index ec954d33..cbe373b7 100644
--- a/jero-boot-incoming-payment/src/main/java/com/jero/contract/common/PayIncomeContractCommon.java
+++ b/jero-boot-incoming-payment/src/main/java/com/jero/contract/common/PayIncomeContractCommon.java
@@ -119,4 +119,9 @@ public class PayIncomeContractCommon {
      */
     public final static Integer CHARGE_WAY2 = 2;
 
+    /**
+     * 合同类型（1为支出合同，否侧为收入合同）
+     */
+    public final static Integer CONTRACT_TYPE = 2;
+
 }
diff --git a/jero-boot-incoming-payment/src/main/java/com/jero/contract/service/impl/PaySpendingContractServiceImpl.java b/jero-boot-incoming-payment/src/main/java/com/jero/contract/service/impl/PaySpendingContractServiceImpl.java
index 92ce4ebb..a7bdf1f9 100644
--- a/jero-boot-incoming-payment/src/main/java/com/jero/contract/service/impl/PaySpendingContractServiceImpl.java
+++ b/jero-boot-incoming-payment/src/main/java/com/jero/contract/service/impl/PaySpendingContractServiceImpl.java
@@ -153,6 +153,34 @@ public class PaySpendingContractServiceImpl extends ServiceImpl<PaySpendingContr
             throw new JeroBootException(msgPaySpendingContractInstallment.toString());
         }
         LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
+        // 获取项目负责人，发送消息
+        List<SysUser> list = sysUserService.getRolesUser(Arrays.asList(RoleCommon.CWRY));
+        if(!CollectionUtils.isEmpty(list)){
+            list.forEach(p->{
+                // 发送消息
+                SendMessageDTO sendMessageDTO = new SendMessageDTO();
+                if(!StringUtils.isBlank(p.getEmail())){
+                    sendMessageDTO.setEmail(PasswordUtil.decrypt(p.getEmail()));
+                }
+                if(!StringUtils.isEmpty(p.getPhone())){
+                    sendMessageDTO.setPhone(PasswordUtil.decrypt(p.getPhone()));
+                }
+                HashMap<String,String> map = new HashMap<>();
+                map.put("contractNum",paySpendingContract.getContractNum());
+                map.put("contractName",paySpendingContract.getContractName());
+                sendMessageDTO.setFromUser(sysUser.getUsername());
+                sendMessageDTO.setToUser(p.getUsername());
+                sendMessageDTO.setTemplateCode(ManagementMessageEnums.MSG2.getCode());
+                sendMessageDTO.setTemplateParam(map);
+                sendMessageDTO.setBusType("M_OPEN_TYPE2");
+                JSONObject json = new JSONObject();
+                json.put("revenueId",paySpendingContract.getId());
+                json.put("contractNum",paySpendingContract.getContractNum());
+                json.put("contractType",PayIncomeContractCommon.CONTRACT_TYPE);
+                sendMessageDTO.setBusId(json.toJSONString());
+                sendMessageService.SendMessageService(sendMessageDTO);
+            });
+        }
         return paySpendingContract;
     }
 
@@ -238,6 +266,35 @@ public class PaySpendingContractServiceImpl extends ServiceImpl<PaySpendingContr
         paySpendingContract.setPrincipalId(principalName.getId());
         paySpendingContract.setPrincipalName(principalName.getRealname());
         paySpendingContractService.updateById(paySpendingContract);
+
+        // 获取项目负责人，发送消息
+        List<SysUser> list = sysUserService.getRolesUser(Arrays.asList(RoleCommon.CWRY));
+        if(!CollectionUtils.isEmpty(list)){
+            list.forEach(p->{
+                // 发送消息
+                SendMessageDTO sendMessageDTO = new SendMessageDTO();
+                if(!StringUtils.isBlank(p.getEmail())){
+                    sendMessageDTO.setEmail(PasswordUtil.decrypt(p.getEmail()));
+                }
+                if(!StringUtils.isEmpty(p.getPhone())){
+                    sendMessageDTO.setPhone(PasswordUtil.decrypt(p.getPhone()));
+                }
+                HashMap<String,String> map = new HashMap<>();
+                map.put("contractNum",paySpendingContract.getContractNum());
+                map.put("contractName",paySpendingContract.getContractName());
+                sendMessageDTO.setFromUser(sysUser.getUsername());
+                sendMessageDTO.setToUser(p.getUsername());
+                sendMessageDTO.setTemplateCode(ManagementMessageEnums.MSG2.getCode());
+                sendMessageDTO.setTemplateParam(map);
+                sendMessageDTO.setBusType("M_OPEN_TYPE2");
+                JSONObject json = new JSONObject();
+                json.put("revenueId",paySpendingContract.getId());
+                json.put("contractNum",paySpendingContract.getContractNum());
+                json.put("contractType",PayIncomeContractCommon.CONTRACT_TYPE);
+                sendMessageDTO.setBusId(json.toJSONString());
+                sendMessageService.SendMessageService(sendMessageDTO);
+            });
+        }
     }
 
     @Override
@@ -576,6 +633,66 @@ public class PaySpendingContractServiceImpl extends ServiceImpl<PaySpendingContr
         paySpendingContractService.update(update);
         // 添加审核记录
         paySpendingContractAuditService.save(paySpendingContractAudit);
+
+        // 审核通过
+        if(Objects.equals(paySpendingContractAudit.getContractStatus(),PayIncomeContractCommon.STATUS3)){
+            // 获取项目负责人，发送消息
+            List<SysUser> list = sysUserService.getRolesUser(Arrays.asList(RoleCommon.CWRY));
+            if(!CollectionUtils.isEmpty(list)){
+                list.forEach(p->{
+                    // 发送消息
+                    SendMessageDTO sendMessageDTO = new SendMessageDTO();
+                    if(!StringUtils.isBlank(p.getEmail())){
+                        sendMessageDTO.setEmail(PasswordUtil.decrypt(p.getEmail()));
+                    }
+                    if(!StringUtils.isBlank(p.getPhone())){
+                        sendMessageDTO.setPhone(PasswordUtil.decrypt(p.getPhone()));
+                    }
+                    HashMap<String,String> map = new HashMap<>();
+                    map.put("contractNum",paySpendingContractStatus.getContractNum());
+                    map.put("contractName",paySpendingContractStatus.getContractName());
+                    sendMessageDTO.setFromUser(sysUser.getUsername());
+                    sendMessageDTO.setToUser(p.getUsername());
+                    sendMessageDTO.setTemplateCode(ManagementMessageEnums.MSG3.getCode());
+                    sendMessageDTO.setTemplateParam(map);
+                    sendMessageDTO.setBusType("M_OPEN_TYPE3");
+                    JSONObject json = new JSONObject();
+                    json.put("revenueId",paySpendingContractStatus.getId());
+                    json.put("contractNum",paySpendingContractStatus.getContractNum());
+                    json.put("contractType",PayIncomeContractCommon.CONTRACT_TYPE);
+                    sendMessageDTO.setBusId(json.toJSONString());
+                    sendMessageService.SendMessageService(sendMessageDTO);
+                });
+            }
+        }
+        // 审核未通过
+        if(Objects.equals(paySpendingContractAudit.getContractStatus(),PayIncomeContractCommon.STATUS4)){
+            SysUser sysUserData = sysUserService.getById(paySpendingContractStatus.getPrincipalId());
+            if(!Objects.isNull(sysUserData)){
+                // 发送消息
+                SendMessageDTO sendMessageDTO = new SendMessageDTO();
+                if(!StringUtils.isBlank(sysUserData.getEmail())){
+                    sendMessageDTO.setEmail(PasswordUtil.decrypt(sysUserData.getEmail()));
+                }
+                if(!StringUtils.isEmpty(sysUserData.getPhone())){
+                    sendMessageDTO.setPhone(PasswordUtil.decrypt(sysUserData.getPhone()));
+                }
+                HashMap<String,String> map = new HashMap<>();
+                map.put("contractNum",paySpendingContractStatus.getContractNum());
+                map.put("contractName",paySpendingContractStatus.getContractName());
+                sendMessageDTO.setFromUser(sysUser.getUsername());
+                sendMessageDTO.setToUser(sysUserData.getUsername());
+                sendMessageDTO.setTemplateCode(ManagementMessageEnums.MSG4.getCode());
+                sendMessageDTO.setTemplateParam(map);
+                sendMessageDTO.setBusType("M_OPEN_TYPE4");
+                JSONObject json = new JSONObject();
+                json.put("revenueId",paySpendingContractStatus.getId());
+                json.put("contractNum",paySpendingContractStatus.getContractNum());
+                json.put("contractType",PayIncomeContractCommon.CONTRACT_TYPE);
+                sendMessageDTO.setBusId(json.toJSONString());
+                sendMessageService.SendMessageService(sendMessageDTO);
+            }
+        }
     }
 
     @Override