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

REQ-2135: update sharding key

Browse Source
This commit is contained in:
yanglin 2024-04-01 18:20:19 +08:00
parent 585fcd414f
commit 2fac4bd592
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -406,12 +406,14 @@ public class TodoManager {
message.setExecutorOuId(todo.getOuId());
message.setExecutorWorkspaceId(todo.getOrgId());
message.setExecutorWorkspaceName(todo.getOrgName());
String shardingKey = String.format("%s:%s", todo.getTemplateCode(), todo.getBizCode());
ctx.addLogContent("shardingKey", shardingKey);
try {
mqProducer.send(MqMessageRecord
.builder(MqMessageType.TODO_PRESET_BUTTON_PRESSED, message)
.targetId(todo.getId())
.operatorId(request.getOperatorId())
.shardingKey(todo.getTemplateCode())
.shardingKey(shardingKey)
.build());
ctx.addLogContent("mqMessage", ImmutableMap.of("isSuccess", "true"));
} catch (Exception e) {
@ -419,7 +421,7 @@ public class TodoManager {
log.warn("预设按钮点击发送事件失败. requestNo={}, request={}", ctx.getRequestNo(), request, e);
// 表记录中的字段也会记录requestNo, 这里重复记录requestNo, 这样能更快的找到
String errorMessage = Throwables.getStackTraceAsString(e);
ctx.addLogContent("mqMessage", ImmutableMap.of(
ctx.addLogContent("sendMqMessage", ImmutableMap.of(
"traceId", TraceUtils.getOrCreateTraceId(),
"isSuccess", "false",
"request", request,