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

hotfix: push查询新模版

Browse Source
This commit is contained in:
yanglin 2024-11-18 15:17:05 +08:00
parent f46bfe65fd
commit 91e52e462b
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
inside-notices/src/main/java/cn/axzo/msg/center/message/service/youmeng/YoumengTemplateClient.java
View File

@ -2,9 +2,9 @@ package cn.axzo.msg.center.message.service.youmeng;
import cn.axzo.msg.center.api.request.MsgBody4Guest; import cn.axzo.msg.center.api.request.MsgBody4Guest;
import cn.axzo.msg.center.common.utils.BizAssertions; import cn.axzo.msg.center.common.utils.BizAssertions;
import cn.axzo.msg.center.dal.mapper.MessageBaseTemplateMapper; import cn.axzo.msg.center.dal.mapper.MessageTemplateV3Mapper;
import cn.axzo.msg.center.domain.entity.MessageBaseTemplate;
import cn.axzo.msg.center.domain.entity.MessageBaseTemplate.PushData; import cn.axzo.msg.center.domain.entity.MessageBaseTemplate.PushData;
import cn.axzo.msg.center.domain.entity.MessageTemplateV3;
import cn.axzo.msg.center.event.outer.PushYouMengMessageHandler; import cn.axzo.msg.center.event.outer.PushYouMengMessageHandler;
import cn.axzo.msg.center.inside.notices.service.IYouMengMessageService; import cn.axzo.msg.center.inside.notices.service.IYouMengMessageService;
import cn.axzo.msg.center.message.service.impl.v3.AppLink; import cn.axzo.msg.center.message.service.impl.v3.AppLink;
@ -37,7 +37,7 @@ public class YoumengTemplateClient {
private final IYouMengMessageService youMengMessageService; private final IYouMengMessageService youMengMessageService;
private final PushYouMengMessageHandler pushYouMengMessageHandler; private final PushYouMengMessageHandler pushYouMengMessageHandler;
private final MessageBaseTemplateMapper messageBaseTemplateMapper; private final MessageTemplateV3Mapper messageTemplateV3Mapper;
private final ExecutorService executor = new ThreadPoolExecutor( private final ExecutorService executor = new ThreadPoolExecutor(
30, 50, 30, 50,
@ -62,7 +62,7 @@ public class YoumengTemplateClient {
public void syncSend(Long templateId, List<YoumengPush> pushes) { public void syncSend(Long templateId, List<YoumengPush> pushes) {
BizAssertions.assertNotNull(templateId, "模版id不能为空"); BizAssertions.assertNotNull(templateId, "模版id不能为空");
BizAssertions.assertNotEmpty(pushes, "pushes不能为空"); BizAssertions.assertNotEmpty(pushes, "pushes不能为空");
MessageBaseTemplate template = messageBaseTemplateMapper.selectById(templateId); MessageTemplateV3 template = messageTemplateV3Mapper.selectById(templateId);
if (template == null) { if (template == null) {
log.warn("Can't find template, templateId={}", templateId); log.warn("Can't find template, templateId={}", templateId);
return; return;