backend/java-mall
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

微信消息订阅job问题修复

Browse Source
This commit is contained in:
liyj 2025-09-24 14:42:12 +08:00
parent 53aca6ede9
commit e2d62d40f0
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBindConnectServiceImpl.java
View File

@ -518,7 +518,7 @@ public class AccountUserBindConnectServiceImpl extends BaseServiceImpl<AccountUs
@Override
public long getAllBindCount(String bindTmpl) {
QueryWrapper<AccountUserBindConnect> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("bind_type", Arrays.asList(BindCode.MOBILE,BindCode.WEIXIN_XCX))
queryWrapper.in("bind_type", Arrays.asList(BindCode.MOBILE,BindCode.WEIXIN_XCX))
.eq("user_type", CommonConstant.USER_TYPE_NORMAL)
.eq("bind_active", CommonConstant.Enable)
.eq("bind_tmpl",bindTmpl)

4
mall-shop/src/main/java/com/suisung/mall/shop/components/quartz/job/XcxSubSendMessageJob.java
View File

@ -16,9 +16,9 @@ public class XcxSubSendMessageJob extends QuartzJobBean {
@Override
protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
Logger logger = LoggerFactory.getLogger(UpdateVoucherStatusJob.class);
ShopMessageTemplateService shopMessageTemplateService = SpringUtil.getBean(ShopMessageTemplateService.class);
Logger logger = LoggerFactory.getLogger(XcxSubSendMessageJob.class);
logger.info("小程序订阅号消息发送消息开始--------start");
ShopMessageTemplateService shopMessageTemplateService = SpringUtil.getBean(ShopMessageTemplateService.class);
shopMessageTemplateService.sendToXcxAllUserMessage();
logger.info("小程序订阅号消息发送消息结束-------end");
}

4
mall-shop/src/main/java/com/suisung/mall/shop/message/service/impl/ShopMessageTemplateServiceImpl.java
View File

@ -779,9 +779,9 @@ public class ShopMessageTemplateServiceImpl extends BaseServiceImpl<ShopMessageT
// 等待所有任务完成
for (Future<?> future : futures) {
try {
log.info("规格任务结果: {}", future.get());
log.info("推送任务结果: {}", future.get());
} catch (Exception e) {
log.info("规格任务执行异常: {}", e.getMessage());
log.info("推送任务执行异常: {}", e.getMessage());
}
}
executor.shutdown();