From bff81db1b64c8f34c9880b228bdbff343fb387c2 Mon Sep 17 00:00:00 2001 From: zhaokai Date: Fri, 20 Mar 2026 14:22:55 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=8F=90=E9=86=92?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/zcloud/fire/check/command/FireCheckListAddExe.java | 4 +++- .../zcloud/fire/check/command/FireCheckListUpdateExe.java | 4 +++- .../zcloud/fire/check/command/FireCheckRecordAddExe.java | 4 +++- .../fire/check/command/query/FireCheckListQueryExe.java | 6 ++++-- 4 files changed, 13 insertions(+), 5 deletions(-) diff --git a/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListAddExe.java b/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListAddExe.java index 33fd62e..837b988 100644 --- a/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListAddExe.java +++ b/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListAddExe.java @@ -119,7 +119,9 @@ public class FireCheckListAddExe { TodoListAddBatchEvent event3 = new TodoListAddBatchEvent(); 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){ log.error("发送消息异常",e); } diff --git a/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListUpdateExe.java b/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListUpdateExe.java index f5761e4..ddf859a 100644 --- a/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListUpdateExe.java +++ b/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckListUpdateExe.java @@ -103,7 +103,9 @@ public class FireCheckListUpdateExe { //删除清单 TodoListDeleteEvent event2 = new TodoListDeleteEvent(); 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){ diff --git a/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckRecordAddExe.java b/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckRecordAddExe.java index a8779cc..b84ed06 100644 --- a/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckRecordAddExe.java +++ b/web-app/src/main/java/com/zcloud/fire/check/command/FireCheckRecordAddExe.java @@ -129,7 +129,9 @@ public class FireCheckRecordAddExe { FireCheckListDO fireCheckListDO = fireCheckListRepository.getInfoByUUId(fireCheckRecordDO.getFireCheckId()); TodoListCompleteEvent event1 = new TodoListCompleteEvent(); event1.setForeignSubsidiaryKey(fireCheckListDO.getId());// 业务附表ID 没有附表时为foreignKey的值 - todoListEventPusherUtil.sendMessageCompleteEvent(event1); + log.info("完成待办,请求：{}",fireCheckListDO.getId()); + boolean b = todoListEventPusherUtil.sendMessageCompleteEvent(event1); + log.info("完成待办,结果：{}",b); }catch (Exception e){ log.error("发送待办消息失败",e); } diff --git a/web-app/src/main/java/com/zcloud/fire/check/command/query/FireCheckListQueryExe.java b/web-app/src/main/java/com/zcloud/fire/check/command/query/FireCheckListQueryExe.java index 879a3c4..d0cd23c 100644 --- a/web-app/src/main/java/com/zcloud/fire/check/command/query/FireCheckListQueryExe.java +++ b/web-app/src/main/java/com/zcloud/fire/check/command/query/FireCheckListQueryExe.java @@ -651,8 +651,10 @@ public class FireCheckListQueryExe { } TodoListAddBatchEvent event3 = new TodoListAddBatchEvent(); - event3.setTodoListAddEventList(new ArrayList<>()); - todoListEventPusherUtil.sendMessageAddBatchEvent(event3); + event3.setTodoListAddEventList(todoListAddEventList); + log.info("待排查待办,请求：{}",JSONUtil.toJsonStr(event3)); + boolean b = todoListEventPusherUtil.sendMessageAddBatchEvent(event3); + log.info("待排查待办,结果：{}",b); } catch (Exception e) { log.error("发送消息异常", e); }