From 0b89850e8f0cf6722e17c959171aded3a0ad3784 Mon Sep 17 00:00:00 2001
From: sunyuchao <syc_ls@163.com>
Date: Thu, 29 Oct 2020 16:59:26 +0800
Subject: [PATCH] =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E6=BB=9E=E7=95=99=E6=8F=90?=
 =?UTF-8?q?=E9=86=92=E6=B7=BB=E5=8A=A0=E5=BE=AE=E4=BF=A1=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../epmet/service/impl/ProjectServiceImpl.java | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

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 112243cf0b..3617f467ad 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
@@ -1232,6 +1232,8 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit
 		}));
 		//通知
 		List<UserMessageFormDTO> msgList = new ArrayList<>();
+		//10.29 项目滞留提醒添加推送微信消息  sun
+		List<WxSubscribeMessageFormDTO> wxmpMsgList = new ArrayList<>();
 		list.forEach(dto -> {
 			String title;
 			String msg;
@@ -1270,8 +1272,24 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit
 			messageFormDTO.setMessageContent(msg);
 			messageFormDTO.setReadFlag(Constant.UNREAD);
 			msgList.add(messageFormDTO);
+
+			//10.29 项目滞留提醒添加推送微信消息  sun
+			WxSubscribeMessageFormDTO wxmp = new WxSubscribeMessageFormDTO();
+			wxmp.setCustomerId(customerId);
+			wxmp.setClientType(ProjectConstant.GOV);
+			wxmp.setUserId(dto.getStaffId());
+			wxmp.setBehaviorType("项目滞留提醒");
+			wxmp.setMessageContent(msg);
+			wxmp.setMessageTime(new Date());
+			wxmp.setGridId(StrConstant.STAR);
+			wxmpMsgList.add(wxmp);
 		});
 		messageFeignClient.saveUserMessageList(msgList);
+		logger.info("项目滞留提醒，开始推送微信订阅消息");
+		Result result = epmetMessageOpenFeignClient.sendWxSubscribeMessage(wxmpMsgList);
+		if (!result.success()) {
+			logger.error("项目滞留提醒，发送微信订阅消息失败" + JSON.toJSONString(result));
+		}
 	}