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

update message

Browse Source
This commit is contained in:
yanglin 2025-01-07 14:50:59 +08:00
parent 62a8f333da
commit 288771e861
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
inside-notices/src/main/java/cn/axzo/msg/center/message/service/todo/card/TodoSyncCardService.java
View File

@ -58,36 +58,36 @@ public class TodoSyncCardService {
try {
sync(event, message);
} catch (Exception e) {
log.warn("TodoSyncStateToCardService.onMessage: error, message={}", message, e);
log.warn("onMessage error, message={}", message, e);
throw new RuntimeException(e);
}
}
private void sync(Event event, TodoUpdateMessage message) {
if (!message.isUpdateCard()) {
log.warn("TodoSyncStateToCardService.onMessage: not update card, message={}", message);
log.warn("not update card, message={}", message);
return;
}
Todo todo = todoDao.findTodoByCode(message.getUpdatedTodo().getIdentityCode())
.orElse(null);
if (todo == null) {
log.warn("TodoSyncStateToCardService.onMessage: todo not found, message={}", message);
log.warn("todo not found, message={}", message);
return;
}
MessageTemplateV3 template = messageTemplateV3Dao
.findByCode(todo.getTemplateCode())
.orElse(null);
if (template == null) {
log.warn("TodoSyncStateToCardService.onMessage: template not found, message={}", message);
log.warn("template not found, message={}", message);
return;
}
if (!template.determineChannels().contains(MessageChannel.IM)) {
log.warn("TodoSyncStateToCardService.onMessage: template not support IM, message={}", message);
log.warn("template not support IM, message={}", message);
return;
}
TodoBusiness business = todoBusinessDao.getBusinesses(todo).findBusiness(todo).orElse(null);
if (business == null) {
log.warn("TodoSyncStateToCardService.sendCard: business not found, message={}", message);
log.warn("business not found, message={}", message);
return;
}
if (todo.getState() == PendingMessageStateEnum.HAS_BEEN_SENT
@ -118,14 +118,14 @@ public class TodoSyncCardService {
.create("sendCard", event)
.addLogContent("sendCardRequest", request);
try {
log.info("TodoSyncStateToCardService.sendCard: todo={}", todo);
log.info("sendCard: todo={}", todo);
cardManager.send(request);
todoLogger.logTodoUpdated(ctx, todo);
log.info("TodoSyncStateToCardService.sendCard: success, todo={}", todo);
log.info("sendCard: success, todo={}", todo);
} catch (CardIdempotentException ignored) {
log.warn("TodoSyncStateToCardService.sendCard: idempotent, todo={}", todo);
log.warn("sendCard: idempotent, todo={}", todo);
} catch (Exception e) {
log.warn("TodoSyncStateToCardService.sendCard: error, todo={}", todo, e);
log.warn("sendCard: error, todo={}", todo, e);
todoLogger.logTodoUpdated(ctx.copy().addLogContent("exception", e), todo);
}
}
@ -151,30 +151,30 @@ public class TodoSyncCardService {
cardManager.updateState(request);
todoLogger.logTodoUpdated(ctx.copy().addLogContent("updateCardStateResult", "success"), todo);
} catch (Exception e) {
log.warn("TodoSyncStateToCardService.updateCardState: error, todo={}", todo, e);
log.warn("updateCardState: error, todo={}", todo, e);
todoLogger.logTodoUpdated(ctx.copy().addLogContent("exception", e), todo);
}
} else {
log.info("TodoSyncStateToCardService.updateCardState: invalid request, todo={}", todo);
log.info("updateCardState: invalid request, todo={}", todo);
todoLogger.logTodoUpdated(ctx.copy().addLogContent("updateCardStateResult", "invalid update card state request"), todo);
}
}
void syncCardPresetButtonPressed(CardPresetButtonPressedMessage message) {
log.info("TodoSyncStateToCardService.onCardPresetButtonPressed: {}", message);
log.info("onCardPresetButtonPressed: {}", message);
if (!APP_CODE.equals(message.getCardInfo().getAppCode())) {
log.info("TodoSyncStateToCardService.onCardPresetButtonPressed: not msg-center:todo, message={}", message);
log.info("onCardPresetButtonPressed: not msg-center:todo, message={}", message);
return;
}
String identityCode = message.getCardInfo()
.determineBizParam().getString(TODO_IDENTITY_CODE_BIZ_PARAM_KEY);
if (StringUtils.isBlank(identityCode)) {
log.warn("TodoSyncStateToCardService.onCardPresetButtonPressed: identityCode is blank, message={}", message);
log.warn("onCardPresetButtonPressed: identityCode is blank, message={}", message);
return;
}
Todo todo = todoDao.findTodoByCode(identityCode).orElse(null);
if (todo == null) {
log.info("TodoSyncStateToCardService.onCardPresetButtonPressed: todo not found, message={}", message);
log.info("onCardPresetButtonPressed: todo not found, message={}", message);
return;
}
PresetButtonPressedRequest request = new PresetButtonPressedRequest();