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

REQ-3502: 添加日志

Browse Source
This commit is contained in:
yanglin 2025-01-16 13:28:09 +08:00
parent 33dc7dfa93
commit fcc98a2ea7
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
inside-notices/src/main/java/cn/axzo/msg/center/message/service/card/broadcast/CardBroadcaster.java
View File

@ -9,6 +9,7 @@ import cn.axzo.msg.center.mq.MqMessageRecord;
import cn.axzo.msg.center.mq.MqProducer;
import cn.axzo.msg.center.service.enums.MqMessageType;
import cn.axzo.msg.center.service.pending.request.CardPresetButtonRequest;
import cn.axzo.msg.center.service.util.IdBuilder;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component;
@ -33,9 +34,13 @@ public class CardBroadcaster {
message.setCardInfo(BeanMapper.copyBean(card, CardInfo.class));
mqProducer.send(MqMessageRecord
.builder(MqMessageType.CARD_PRESET_BUTTON_PRESSED, message)
.messageKey(card.getId())
.messageKey(card.getIdentityCode())
.operatorId(request.getOperatorId())
.shardingKey(card.getTemplateCode())
.shardingKey(IdBuilder.builder()
.append(card.getTemplateCode())
.append(card.getBizCode())
.append(card.getSubBizCode())
.build())
.build());
}
}