From 08c121c0801ea15d762c0ea45c9e71144579528f Mon Sep 17 00:00:00 2001
From: zhaoqifeng <cpyxrt@163.com>
Date: Wed, 28 Apr 2021 09:57:19 +0800
Subject: [PATCH] =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E5=AE=9E=E6=97=B6=E7=BB=9F?=
 =?UTF-8?q?=E8=AE=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       | 16 ++++++
 .../service/impl/ProjectServiceImpl.java      | 52 +++++++++++++++++++
 2 files changed, 68 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 455e085999..2046de6106 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
@@ -21,6 +21,7 @@ import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
+import com.epmet.commons.rocketmq.messages.ProjectChangedMQMsg;
 import com.epmet.commons.tools.constant.AppClientConstant;
 import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.constant.NumConstant;
@@ -57,6 +58,7 @@ import com.epmet.feign.EpmetUserFeignClient;
 import com.epmet.feign.EpmetUserOpenFeignClient;
 import com.epmet.feign.GovOrgFeignClient;
 import com.epmet.redis.ProjectProcessRedis;
+import com.epmet.send.SendMqMsgUtil;
 import com.epmet.service.ProjectProcessService;
 import com.epmet.service.ProjectService;
 import com.epmet.service.ProjectStaffService;
@@ -384,6 +386,13 @@ public class ProjectProcessServiceImpl extends BaseServiceImpl<ProjectProcessDao
             logger.error("项目流转，发送手机短信失败" + JSON.toJSONString(result));
         }
 
+        //项目实时统计消息
+        ProjectChangedMQMsg msg = new ProjectChangedMQMsg(staffEntity.getCustomerId());
+        boolean msgResult = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient).sendProjectChangedMqMsg(msg);
+        if (!msgResult) {
+            log.error("项目实时统计消息发送失败");
+        }
+
     }
 
     /**
@@ -730,6 +739,13 @@ public class ProjectProcessServiceImpl extends BaseServiceImpl<ProjectProcessDao
         if (!result.success()) {
             logger.error("项目流转，发送手机短信失败" + JSON.toJSONString(result));
         }
+
+        //项目实时统计消息
+        ProjectChangedMQMsg msg = new ProjectChangedMQMsg(staffEntity.getCustomerId());
+        boolean msgResult = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient).sendProjectChangedMqMsg(msg);
+        if (!msgResult) {
+            log.error("项目实时统计消息发送失败");
+        }
     }
 
     /**
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 e97a697dc5..bee3979312 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
@@ -21,6 +21,7 @@ import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
+import com.epmet.commons.rocketmq.messages.ProjectChangedMQMsg;
 import com.epmet.commons.tools.constant.*;
 import com.epmet.commons.tools.exception.EpmetErrorCode;
 import com.epmet.commons.tools.exception.RenException;
@@ -48,6 +49,7 @@ import com.epmet.resi.group.dto.topic.result.TopicAttachmentResultDTO;
 import com.epmet.resi.group.dto.topic.result.TopicFileResultDTO;
 import com.epmet.resi.group.feign.ResiGroupOpenFeignClient;
 import com.epmet.resi.mine.dto.from.MyPartProjectsFormDTO;
+import com.epmet.send.SendMqMsgUtil;
 import com.epmet.service.*;
 import com.github.pagehelper.PageHelper;
 import com.google.common.base.Joiner;
@@ -543,6 +545,13 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit
 		if (!result.success()) {
 			logger.error("项目结案成功，发送微信订阅消息失败" + JSON.toJSONString(result));
 		}
+
+		//项目实时统计消息
+		ProjectChangedMQMsg msg = new ProjectChangedMQMsg(projectEntity.getCustomerId());
+		boolean msgResult = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient).sendProjectChangedMqMsg(msg);
+		if (!msgResult) {
+			log.error("项目实时统计消息发送失败");
+		}
 	}
 
 	/**
@@ -696,6 +705,13 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit
 		if (!result.success()) {
 			logger.error("项目结案成功，发送微信订阅消息失败" + JSON.toJSONString(result));
 		}
+
+		//项目实时统计消息
+		ProjectChangedMQMsg msg = new ProjectChangedMQMsg(projectEntity.getCustomerId());
+		boolean msgResult = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient).sendProjectChangedMqMsg(msg);
+		if (!msgResult) {
+			log.error("项目实时统计消息发送失败");
+		}
 	}
 
 	@Override
@@ -842,6 +858,13 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit
 		if (!result.success()) {
 			logger.error("项目退回，发送手机短信失败" + JSON.toJSONString(result));
 		}
+
+		//项目实时统计消息
+		ProjectChangedMQMsg mqMsg = new ProjectChangedMQMsg(projectStaff.getCustomerId());
+		boolean msgResult = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient).sendProjectChangedMqMsg(mqMsg);
+		if (!msgResult) {
+			log.error("项目实时统计消息发送失败");
+		}
 	}
 
 	@Override
@@ -1119,6 +1142,13 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit
 			logger.error("项目吹哨，发送手机短信失败" + JSON.toJSONString(result));
 		}
 
+		//项目实时统计消息
+		ProjectChangedMQMsg msg = new ProjectChangedMQMsg(issueDTO.getCustomerId());
+		boolean msgResult = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient).sendProjectChangedMqMsg(msg);
+		if (!msgResult) {
+			log.error("项目实时统计消息发送失败");
+		}
+
 		return issueProjectResultDTO;
 	}
 
@@ -1191,6 +1221,14 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit
 		    throw new RenException("没有找到相关的节点耗时记录");
         }
 
+		//项目实时统计消息
+		ProjectChangedMQMsg msg = new ProjectChangedMQMsg(projectStaff.getCustomerId());
+		boolean msgResult = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient).sendProjectChangedMqMsg(msg);
+		if (!msgResult) {
+			log.error("项目实时统计消息发送失败");
+		}
+
+
 	}
 
 	/**
@@ -1950,6 +1988,13 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit
 		if (!result.success()) {
 			logger.error("项目退回，发送手机短信失败" + JSON.toJSONString(result));
 		}
+
+		//项目实时统计消息
+		ProjectChangedMQMsg mqMsg = new ProjectChangedMQMsg(projectEntity.getCustomerId());
+		boolean msgResult = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient).sendProjectChangedMqMsg(mqMsg);
+		if (!msgResult) {
+			log.error("项目实时统计消息发送失败");
+		}
 	}
 
 	/**
@@ -2031,6 +2076,13 @@ public class ProjectServiceImpl extends BaseServiceImpl<ProjectDao, ProjectEntit
 			throw new RenException("没有找到相关的节点耗时记录");
 		}
 
+		//项目实时统计消息
+		ProjectChangedMQMsg msg = new ProjectChangedMQMsg(projectStaff.getCustomerId());
+		boolean msgResult = SendMqMsgUtil.build().openFeignClient(epmetMessageOpenFeignClient).sendProjectChangedMqMsg(msg);
+		if (!msgResult) {
+			log.error("项目实时统计消息发送失败");
+		}
+
 	}
 
 	/**