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("项目实时统计消息发送失败");
+		}
+
 	}
 
 	/**