项目滞留提醒添加微信消息

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));
+		}
 	}