需求、项目结案时来源居民端的事件需要为居民端推送站内信

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()));
+            }
+        }
+
     }
 
     /**