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

REQ-3201: 用枚举替换字符串

Browse Source
This commit is contained in:
yanglin 2024-12-17 09:19:49 +08:00
parent 4471a6f23a
commit 3219108fc5
5 changed files with 15 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
inside-notices/src/main/java/cn/axzo/msg/center/message/service/card/CardManager.java
View File

@ -168,8 +168,7 @@ public class CardManager {
cardLogger.reloadAndLogCards("presetButtonPressed:enqueue");
});
if (updateMessages("presetButtonPressed", cardLogger, cards)) {
cardBroadcaster.firePresetButtonPressed(
cards, request.getOperatorId(), request.getPresetButtonType());
cardBroadcaster.firePresetButtonPressed(cards, request);
cardLogger.reloadAndLogCards("presetButtonPressed:mq:success");
}
}

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

@ -8,7 +8,7 @@ import cn.axzo.msg.center.domain.entity.Card;
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.enums.PresetButtonType;
import cn.axzo.msg.center.service.pending.request.CardPresetButtonRequest;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component;
@ -24,16 +24,17 @@ public class CardBroadcaster {
private final CardDao cardDao;
private final MqProducer mqProducer;
public void firePresetButtonPressed(
List<Card> cards, Long operatorId, PresetButtonType presetButtonType) {
public void firePresetButtonPressed(List<Card> cards, CardPresetButtonRequest request) {
for (Card card : cardDao.reloadCards(cards)) {
CardPresetButtonPressedMessage message = new CardPresetButtonPressedMessage();
message.setPresetButtonType(presetButtonType);
message.setPresetButtonType(request.getPresetButtonType());
message.setOperatorId(request.getOperatorId());
message.setOperatorName(request.getOperatorName());
message.setCardInfo(BeanMapper.copyBean(card, CardInfo.class));
mqProducer.send(MqMessageRecord
.builder(MqMessageType.CARD_PRESET_BUTTON_PRESSED, message)
.messageKey(card.getId())
.operatorId(operatorId)
.operatorId(request.getOperatorId())
.shardingKey(card.getTemplateCode())
.build());
}

4
msg-center-api/src/main/java/cn/axzo/msg/center/api/mq/CardPresetButtonPressedMessage.java
View File

@ -13,6 +13,10 @@ import java.io.Serializable;
@EqualsAndHashCode(callSuper = true)
public class CardPresetButtonPressedMessage extends MqMessage implements Serializable {
private Long operatorId;
private String operatorName;
/**
* 预设按钮类型
* AGREE: 同意

2
msg-center-api/src/main/java/cn/axzo/msg/center/service/pending/request/CardPresetButtonRequest.java
View File

@ -11,4 +11,6 @@ public interface CardPresetButtonRequest {
Long getOperatorId();
String getOperatorName();
}

2
msg-center-api/src/main/java/cn/axzo/msg/center/service/pending/request/CardUpdatePresetButtonRequest.java
View File

@ -24,4 +24,6 @@ public class CardUpdatePresetButtonRequest extends CardUpdateRequest implements
private Long operatorId;
private String operatorName;
}