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-15 14:42:15 +08:00
parent 347dde83e2
commit 034cbf6163
2 changed files with 19 additions and 3 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/inside/notices/config/PendingMessageBizConfig.java
View File

@ -176,6 +176,12 @@ public class PendingMessageBizConfig {
@Getter
private boolean enableTodoLog = true;
@Getter
private String workflowIMChannelAppMinVersionCmp = "";
@Getter
private String workflowIMChannelAppMinVersionCm = "";
public boolean determineOldMsgStatCacheOn() {
return isOldMsgStatCacheOn();
}

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

@ -10,6 +10,7 @@ import cn.axzo.msg.center.common.utils.BizAssertions;
import cn.axzo.msg.center.dal.CardIdempotentDao;
import cn.axzo.msg.center.domain.entity.Card;
import cn.axzo.msg.center.domain.entity.CardIdempotent;
import cn.axzo.msg.center.inside.notices.config.PendingMessageBizConfig;
import cn.axzo.msg.center.message.domain.dto.TemplateModelV3;
import cn.axzo.msg.center.message.domain.vo.GeneralMessagePushVO;
import cn.axzo.msg.center.message.service.card.domain.CardGroup;
@ -23,6 +24,7 @@ import cn.axzo.msg.center.nimpush.device.PushDeviceSnapshots;
import cn.axzo.msg.center.push.PushData;
import cn.axzo.msg.center.service.domain.card.AppVersionConfig;
import cn.axzo.msg.center.service.dto.PeerPerson;
import cn.axzo.msg.center.service.enums.MessageCategoryEnum;
import cn.axzo.msg.center.service.enums.MessageChannel;
import cn.axzo.msg.center.service.pending.request.CardContent;
import cn.axzo.msg.center.service.pending.request.CardSendRequest;
@ -60,6 +62,7 @@ public class CardSupport {
private final NimPushService nimPushService;
private final CardIdempotentDao cardIdempotentDao;
private final CardProps cardProps;
private final PendingMessageBizConfig cfg;
public static String getBizIdPrefix(String templateCode) {
return IdBuilder.builder()
@ -178,15 +181,22 @@ public class CardSupport {
private String determineMinAppVersion(ParsedModelV3 model,
AppTypeEnum appType) {
Ref<String> minVersion = Ref.create("");
Ref<String> ref = Ref.create("");
ParsedModelV3Walker.walkDown(model, new ParsedModel3Visitor() {
@Override
public void visitAppVersionConfig(AppVersionConfig cfg) {
if (cfg.getAppType() == appType)
minVersion.set(cfg.getMinVersion());
ref.set(cfg.getMinVersion());
}
});
return minVersion.get();
String minVersion = ref.get();
if (StringUtils.isBlank(minVersion)
&& model.getTemplate().getMsgCategory() == MessageCategoryEnum.APPROVAL_PENDING_MESSAGE) {
return appType == AppTypeEnum.CMP
? cfg.getWorkflowIMChannelAppMinVersionCmp()
: cfg.getWorkflowIMChannelAppMinVersionCm();
}
return minVersion;
}
TemplateModelV3 ensureImChannelPresent(String templateCode) {