From 3783546f3a825f403cdda7879b198c54277fa7ff Mon Sep 17 00:00:00 2001
From: sunyuchao <syc_ls@163.com>
Date: Mon, 13 Jun 2022 14:35:43 +0800
Subject: [PATCH] =?UTF-8?q?=E9=9C=80=E6=B1=82=E3=80=81=E9=A1=B9=E7=9B=AE?=
 =?UTF-8?q?=E7=BB=93=E6=A1=88=E6=97=B6=E6=9D=A5=E6=BA=90=E5=B1=85=E6=B0=91?=
 =?UTF-8?q?=E7=AB=AF=E7=9A=84=E4=BA=8B=E4=BB=B6=E9=9C=80=E8=A6=81=E4=B8=BA?=
 =?UTF-8?q?=E5=B1=85=E6=B0=91=E7=AB=AF=E6=8E=A8=E9=80=81=E7=AB=99=E5=86=85?=
 =?UTF-8?q?=E4=BF=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/IcEventServiceImpl.java      | 21 +++++++++++++++++++
 1 file changed, 21 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..f1f10b52c5 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
@@ -1212,6 +1212,27 @@ public class IcEventServiceImpl extends BaseServiceImpl<IcEventDao, IcEventEntit
             logEntity.setActualServiceTime(formDTO.getActualServiceTime());
             icEventOperationLogService.insert(logEntity);
         }
+
+        //4.判断来源居民端的事件，需求、项目结案时给居民推送站内信
+        if("0".equals(entity.getSourceType())){
+            List<UserMessageFormDTO> msgList = new ArrayList<>();
+            UserMessageFormDTO messageFormDTO = new UserMessageFormDTO();
+            messageFormDTO.setCustomerId(formDTO.getCustomerId());
+            messageFormDTO.setApp(ProjectConstant.RESI);
+            messageFormDTO.setGridId(entity.getGridId());
+            messageFormDTO.setUserId(entity.getCreatedBy());
+            messageFormDTO.setTitle(UserMessageConstant.EVENT_TITILE);
+            messageFormDTO.setMessageContent(String.format("您上报的事件已完成，请查看。"));
+            messageFormDTO.setReadFlag(Constant.UNREAD);
+            messageFormDTO.setMessageType(UserMessageTypeConstant.IC_EVENT);
+            messageFormDTO.setTargetId(entity.getId());
+            msgList.add(messageFormDTO);
+            Result sendMessageRes = messageOpenFeignClient.saveUserMessageList(msgList);
+            if (!sendMessageRes.success()) {
+                log.warn(String.format("事件回复,给居民端用户发送站内信异常,事件Id->%s", entity.getId()));
+            }
+        }
+
     }
 
     /**