From 792c0f6a5745c0ea636deee73d6b9c461fa2e809 Mon Sep 17 00:00:00 2001
From: yinzuomei <576302893@qq.com>
Date: Mon, 30 Jan 2023 13:54:21 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BA=8B=E4=BB=B6=E8=BD=AC=E8=AE=AE=E9=A2=98?=
 =?UTF-8?q?=E5=8F=91=E9=80=81=E7=AB=99=E5=86=85=E4=BF=A1=E3=80=82=E9=80=9A?=
 =?UTF-8?q?=E7=9F=A5=E5=B1=85=E6=B0=91=E7=AB=AF=E7=94=A8=E6=88=B7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/IcEventServiceImpl.java      | 22 +++++++++++++++++++
 1 file changed, 22 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 d40ff78a46..e5bf477bc6 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
@@ -1870,6 +1870,28 @@ public class IcEventServiceImpl extends BaseServiceImpl<IcEventDao, IcEventEntit
         logEntity.setActionDesc("转议题");
         logEntity.setOperateTime(nowTime);
         icEventOperationLogService.insert(logEntity);
+        // 来源于随手拍，随时讲发送站内信消息
+        if ("0".equals(icEventEntity.getSourceType())) {
+            // 通知
+            List<UserMessageFormDTO> msgList = new ArrayList<>();
+            UserMessageFormDTO messageFormDTO = new UserMessageFormDTO();
+            messageFormDTO.setCustomerId(formDTO.getCustomerId());
+            messageFormDTO.setApp(ProjectConstant.RESI);
+            messageFormDTO.setGridId(icEventEntity.getGridId());
+            messageFormDTO.setUserId(icEventEntity.getCreatedBy());
+            messageFormDTO.setTitle(UserMessageConstant.EVENT_TITILE);
+            // 获取当前工作人员缓存信息
+            CustomerStaffInfoCacheResult staffInfo = getStaffInfo(formDTO.getCustomerId(), formDTO.getCurrentUserId());
+            messageFormDTO.setMessageContent(String.format("%s将您上报的事件转为议题，请查看。", staffInfo.getAgencyName()));
+            messageFormDTO.setReadFlag(Constant.UNREAD);
+            messageFormDTO.setMessageType(UserMessageTypeConstant.IC_EVENT);
+            messageFormDTO.setTargetId(icEventEntity.getId());
+            msgList.add(messageFormDTO);
+            Result sendMessageRes = messageOpenFeignClient.saveUserMessageList(msgList);
+            if (!sendMessageRes.success()) {
+                log.warn(String.format("事件转议题,给居民端用户发送站内信异常,事件Id->%s", icEventEntity.getId()));
+            }
+        }
     }
 
     /**