zcloud_gbs
/
zcloud_gbs_fire_check_gwj
15
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

消息提醒

main
zhaokai 2026-03-20 14:22:55 +08:00
parent f903d54b5a
commit bff81db1b6
4 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListAddExe.java
View File

@ -119,7 +119,9 @@ public class FireCheckListAddExe {
TodoListAddBatchEvent event3 = new TodoListAddBatchEvent(); TodoListAddBatchEvent event3 = new TodoListAddBatchEvent();
event3.setTodoListAddEventList(todoListAddEventList); event3.setTodoListAddEventList(todoListAddEventList);
todoListEventPusherUtil.sendMessageAddBatchEvent(event3); log.info("创建清单,待排查待办参数:event3: {}", JSONUtil.toJsonStr(event3));
boolean b = todoListEventPusherUtil.sendMessageAddBatchEvent(event3);
log.info("创建清单,待排查待办结果:{}", JSONUtil.toJsonStr(b));
}catch (Exception e){ }catch (Exception e){
log.error("发送消息异常",e); log.error("发送消息异常",e);
} }

4
web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListUpdateExe.java
View File

@ -103,7 +103,9 @@ public class FireCheckListUpdateExe {
//删除清单 //删除清单
TodoListDeleteEvent event2 = new TodoListDeleteEvent(); TodoListDeleteEvent event2 = new TodoListDeleteEvent();
event2.setForeignSubsidiaryKey(fireCheckListUpdateStateCmd.getId());// 业务附表ID 没有附表时为foreignKey的值 event2.setForeignSubsidiaryKey(fireCheckListUpdateStateCmd.getId());// 业务附表ID 没有附表时为foreignKey的值
todoListEventPusherUtil.sendMessageDeleteEvent(event2); log.info("删除待办,请求：{}",fireCheckListUpdateStateCmd.getId());
boolean b = todoListEventPusherUtil.sendMessageDeleteEvent(event2);
log.info("删除待办,结果：{}",b);
} }
if(fireCheckListUpdateStateCmd.getState() == 0){ if(fireCheckListUpdateStateCmd.getState() == 0){

4
web-app/src/main/java/com/zcloud/fire/check/command/FireCheckRecordAddExe.java
View File

@ -129,7 +129,9 @@ public class FireCheckRecordAddExe {
FireCheckListDO fireCheckListDO = fireCheckListRepository.getInfoByUUId(fireCheckRecordDO.getFireCheckId()); FireCheckListDO fireCheckListDO = fireCheckListRepository.getInfoByUUId(fireCheckRecordDO.getFireCheckId());
TodoListCompleteEvent event1 = new TodoListCompleteEvent(); TodoListCompleteEvent event1 = new TodoListCompleteEvent();
event1.setForeignSubsidiaryKey(fireCheckListDO.getId());// 业务附表ID 没有附表时为foreignKey的值 event1.setForeignSubsidiaryKey(fireCheckListDO.getId());// 业务附表ID 没有附表时为foreignKey的值
todoListEventPusherUtil.sendMessageCompleteEvent(event1); log.info("完成待办,请求：{}",fireCheckListDO.getId());
boolean b = todoListEventPusherUtil.sendMessageCompleteEvent(event1);
log.info("完成待办,结果：{}",b);
}catch (Exception e){ }catch (Exception e){
log.error("发送待办消息失败",e); log.error("发送待办消息失败",e);
} }

6
web-app/src/main/java/com/zcloud/fire/check/command/query/FireCheckListQueryExe.java
View File

@ -651,8 +651,10 @@ public class FireCheckListQueryExe {
} }
TodoListAddBatchEvent event3 = new TodoListAddBatchEvent(); TodoListAddBatchEvent event3 = new TodoListAddBatchEvent();
event3.setTodoListAddEventList(new ArrayList<>()); event3.setTodoListAddEventList(todoListAddEventList);
todoListEventPusherUtil.sendMessageAddBatchEvent(event3); log.info("待排查待办,请求：{}",JSONUtil.toJsonStr(event3));
boolean b = todoListEventPusherUtil.sendMessageAddBatchEvent(event3);
log.info("待排查待办,结果：{}",b);
} catch (Exception e) { } catch (Exception e) {
log.error("发送消息异常", e); log.error("发送消息异常", e);
} }