From 5d1e05579c22c05da877af7910ffe5154cf712b4 Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Mon, 13 Jun 2022 14:37:59 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B1=85=E6=B0=91=E5=9B=9E=E5=A4=8D=E4=BA=8B?=
 =?UTF-8?q?=E4=BB=B6=E7=BB=99=E5=B7=A5=E4=BD=9C=E7=AB=AF=E7=A4=BE=E5=8C=BA?=
 =?UTF-8?q?=E7=9A=84=E4=BA=BA=E5=8F=91=E9=80=81=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/IcEventServiceImpl.java      | 29 +++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/IcEventServiceImpl.java b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/IcEventServiceImpl.java
index 438cbc54ae..86a3a7a1b7 100644
--- a/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/IcEventServiceImpl.java
+++ b/epmet-module/gov-project/gov-project-server/src/main/java/com/epmet/service/impl/IcEventServiceImpl.java
@@ -1458,6 +1458,35 @@ public class IcEventServiceImpl extends BaseServiceImpl<IcEventDao, IcEventEntit
         logEntity.setActionDesc(ResiEventAction.REPLY.getDesc());
         logEntity.setOperateTime(new Date());
         icEventOperationLogService.insert(logEntity);
+        // 4.给工作端社区的人发送消息:山东路168号-张先生对事件进行了新的回复，请查看
+        noticeStaffResiReply(entity.getAgencyId(),entity.getCustomerId(),replyEntity.getUserShowName(),entity.getId());
+    }
+
+    public void noticeStaffResiReply(String agencyId,String customerId,String showName,String icEventId){
+        // 查询组织下的所有工作人员
+        AgencyIdFormDTO formDTO = new AgencyIdFormDTO();
+        formDTO.setAgencyId(agencyId);
+        Result<List<String>> agencyStaffsResult = govOrgOpenFeignClient.getAgencyStaffs(formDTO);
+        if (!agencyStaffsResult.success()){
+            throw new EpmetException("查询组织下工作人员失败...");
+        }
+        if (!CollectionUtils.isEmpty(agencyStaffsResult.getData())){
+            List<UserMessageFormDTO> msgList = new ArrayList<>();
+            agencyStaffsResult.getData().forEach(u -> {
+                UserMessageFormDTO msg = new UserMessageFormDTO();
+                msg.setUserId(u);
+                msg.setCustomerId(customerId);
+                msg.setTargetId(icEventId);
+                msg.setGridId("*");
+                msg.setApp(AppClientConstant.APP_GOV);
+                msg.setMessageType(UserMessageTypeConstant.IC_EVENT);
+                msg.setReadFlag(ReadFlagConstant.UN_READ);
+                msg.setTitle("您有一条事件消息");
+                msg.setMessageContent(showName+"对事件进行了新的回复，请查看。");
+                msgList.add(msg);
+            });
+            messageOpenFeignClient.saveUserMessageList(msgList);
+        }
     }
 
     /**