From 8f2ef22a58f01033b018caec82b97d6dd867f871 Mon Sep 17 00:00:00 2001
From: zhaoqifeng <cpyxrt@163.com>
Date: Tue, 12 Jan 2021 18:00:58 +0800
Subject: [PATCH] =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E6=B5=81=E8=BD=AC=E7=9F=AD?=
 =?UTF-8?q?=E4=BF=A1=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/ProjectProcessServiceImpl.java       | 19 +++++++++++++++++++
 .../service/impl/ProjectServiceImpl.java      | 17 +++++++++++++++++
 2 files changed, 36 insertions(+)

diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectProcessServiceImpl.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectProcessServiceImpl.java
index bc78b8b46c..26a9fe3de3 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectProcessServiceImpl.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectProcessServiceImpl.java
@@ -707,6 +707,25 @@ public class ProjectProcessServiceImpl extends BaseServiceImpl<ProjectProcessDao
             logger.error("项目流转，推送微信订阅消息失败");
             //throw new RenException(ProjectConstant.SAVE_WXMP_MSG_EXCEPTION);
         }
+
+        //短信消息
+        List<ProjectSendMsgFormDTO> smsList = new ArrayList<>();
+        staffList.forEach(staff -> {
+            CustomerStaffDTO staffDTO = new CustomerStaffDTO();
+            staffDTO.setUserId(staff.getStaffId());
+            Result<CustomerStaffDTO> staffResult = epmetUserFeignClient.getCustomerStaffInfoByUserId(staffDTO);
+            if (staffResult.success() && null != staffResult.getData()) {
+                ProjectSendMsgFormDTO sms = new ProjectSendMsgFormDTO();
+                sms.setCustomerId(staffResult.getData().getCustomerId());
+                sms.setMobile(staffResult.getData().getMobile());
+                sms.setAliyunTemplateCode(SmsTemplateConstant.PROJECT_TRANSFER);
+                smsList.add(sms);
+            }
+        });
+        Result result = epmetMessageOpenFeignClient.projectSendMsg(smsList);
+        if (!result.success()) {
+            logger.error("项目流转，发送手机短信失败" + JSON.toJSONString(result));
+        }
     }
 
 }
\ No newline at end of file
diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
index cc7973f318..ca29e4b937 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/ProjectServiceImpl.java
@@ -1813,6 +1813,23 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit
 		if (!result.success()) {
 			logger.error("项目退回成功，发送微信订阅消息失败" + JSON.toJSONString(result));
 		}
+
+		//短信消息
+		List<ProjectSendMsgFormDTO> smsList = new ArrayList<>();
+		CustomerStaffDTO staffDTO = new CustomerStaffDTO();
+		staffDTO.setUserId(projectStaffDTO.getStaffId());
+		Result<CustomerStaffDTO> staffResult = epmetUserFeignClient.getCustomerStaffInfoByUserId(staffDTO);
+		if (staffResult.success() && null != staffResult.getData()) {
+			ProjectSendMsgFormDTO sms = new ProjectSendMsgFormDTO();
+			sms.setCustomerId(staffResult.getData().getCustomerId());
+			sms.setMobile(staffResult.getData().getMobile());
+			sms.setAliyunTemplateCode(SmsTemplateConstant.PROJECT_TRANSFER);
+			smsList.add(sms);
+		}
+		result = epmetMessageOpenFeignClient.projectSendMsg(smsList);
+		if (!result.success()) {
+			logger.error("项目退回，发送手机短信失败" + JSON.toJSONString(result));
+		}
 	}
 
 	/**