事件转议题发送站内信。通知居民端用户

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