diff --git a/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBindConnectServiceImpl.java b/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBindConnectServiceImpl.java index 54fa1f54..70c8f690 100644 --- a/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBindConnectServiceImpl.java +++ b/mall-account/src/main/java/com/suisung/mall/account/service/impl/AccountUserBindConnectServiceImpl.java @@ -518,7 +518,7 @@ public class AccountUserBindConnectServiceImpl extends BaseServiceImpl 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) diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/components/quartz/job/XcxSubSendMessageJob.java b/mall-shop/src/main/java/com/suisung/mall/shop/components/quartz/job/XcxSubSendMessageJob.java index 9c3c2f3d..2296f3d9 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/components/quartz/job/XcxSubSendMessageJob.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/components/quartz/job/XcxSubSendMessageJob.java @@ -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"); } diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/message/service/impl/ShopMessageTemplateServiceImpl.java b/mall-shop/src/main/java/com/suisung/mall/shop/message/service/impl/ShopMessageTemplateServiceImpl.java index e165fc95..760fd763 100644 --- a/mall-shop/src/main/java/com/suisung/mall/shop/message/service/impl/ShopMessageTemplateServiceImpl.java +++ b/mall-shop/src/main/java/com/suisung/mall/shop/message/service/impl/ShopMessageTemplateServiceImpl.java @@ -779,9 +779,9 @@ public class ShopMessageTemplateServiceImpl extends BaseServiceImpl future : futures) { try { - log.info("规格任务结果: {}", future.get()); + log.info("推送任务结果: {}", future.get()); } catch (Exception e) { - log.info("规格任务执行异常: {}", e.getMessage()); + log.info("推送任务执行异常: {}", e.getMessage()); } } executor.shutdown();