REQ-3201: 引入业务状态

This commit is contained in:
yanglin 2024-12-13 10:18:47 +08:00
parent 35e939aa20
commit e3363a0cc1

View File

@ -79,19 +79,19 @@ public class CardManager {
for (CardGroup group : sendModel.getCardGroups()) {
SendTemplateMessageParam imRequest = cardSupport.buildImSendRequest(
sendModel, group, deviceSnapshots, imSenderAccount);
CardLogger groupCardLogger = cardLoggers.createLogger(requestContext, group.getCards());
CardLogger groupLogger = cardLoggers.createLogger(requestContext, group.getCards());
try {
MessageTaskResp imResponse = BizAssertions.assertResponse(
messageApi.sendTemplateMessageAsync(imRequest));
execTransactional(() -> {
cardDao.setSendSuccess(group.getCards(), imResponse);
groupCardLogger.reloadAndLogCards("send:success");
groupLogger.reloadAndLogCards("send:success");
});
} catch (Exception e) {
log.warn("发送IM消息失败, request={}", request, e);
execTransactional(() -> {
cardDao.deleteCards(sendModel.getCards());
groupCardLogger.reloadAndLogCards("send:fail", e);
groupLogger.reloadAndLogCards("send:fail", e);
});
throw e;
}