From 87f43e84f11e246b11770e056081cbbd90164deb Mon Sep 17 00:00:00 2001 From: yanglin Date: Mon, 30 Dec 2024 19:39:02 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=85=E5=8A=9E=E5=8F=91=E9=80=81MQ=E6=B2=BB?= =?UTF-8?q?=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../message/service/todo/manage/TodoManager.java | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/manage/TodoManager.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/manage/TodoManager.java index 26db620d..73527b8d 100644 --- a/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/manage/TodoManager.java +++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/manage/TodoManager.java @@ -306,8 +306,11 @@ public class TodoManager { } if (advanceResult.isAdvanced()) { todoLogger.logTodoCompleted(ctx, advanceResult.getAdvancedTodos()); - todoBroadcaster.fireTodoUpdates("completeById", advanceResult.getBusinessId(), true); } + if (businessUpdated) + todoBroadcaster.fireTodoUpdates("completeById", advanceResult.getBusinessId(), true); + else + advanceResult.broadcast(); return advanceResult.isAdvanced() || businessUpdated; } @@ -334,10 +337,12 @@ public class TodoManager { "businessUpdated", businessUpdated); todoLogger.logBusinessUpdated(ctx, advanceResult.getBusiness()); } - if (advanceResult.isAdvanced()) { - todoBroadcaster.fireTodoUpdates("completeByBizCode", advanceResult.getBusinessId(), true); + if (advanceResult.isAdvanced()) todoLogger.logTodoCompleted(ctx, advanceResult.getAdvancedTodos()); - } + if (businessUpdated) + todoBroadcaster.fireTodoUpdates("completeByBizCode", advanceResult.getBusinessId(), true); + else + advanceResult.broadcast(); return advanceResult.isAdvanced() || businessUpdated; } @@ -554,6 +559,7 @@ public class TodoManager { .addLogContent("updatedRouterParam", routerParam) .addLogContent("updatedTemplateCode", request.getTemplateCode()); todoLogger.logBusinessUpdated(ctx, business); + todoBroadcaster.fireTodoUpdates("updateBusinessById", business.getId(), true); } return updated; } @@ -580,7 +586,6 @@ public class TodoManager { // 支持重复发mq消息 if (isAdvancedOrCompleted) { sendMqMessageOnPresetButtonPressed(ctx, request, todo); - todoBroadcaster.fireTodoUpdates("presetButtonPressed", todo, syncCardState); // 如果不是重复发送, 就只记一条日志. 如果是重复发送, 就单独记录一条日志 if (!advanceResult.isAdvanced())