wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

待办发送MQ治理

Browse Source
This commit is contained in:
yanglin 2024-12-30 19:39:02 +08:00
parent 6d151429af
commit 87f43e84f1
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/manage/TodoManager.java
View File

@ -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())