From e2d62d40f05d844c73d91fe4cee413a35be5f94b Mon Sep 17 00:00:00 2001 From: liyj <1617420630@qq.com> Date: Wed, 24 Sep 2025 14:42:12 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E4=BF=A1=E6=B6=88=E6=81=AF=E8=AE=A2?= =?UTF-8?q?=E9=98=85job=E9=97=AE=E9=A2=98=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/AccountUserBindConnectServiceImpl.java | 2 +- .../mall/shop/components/quartz/job/XcxSubSendMessageJob.java | 4 ++-- .../message/service/impl/ShopMessageTemplateServiceImpl.java | 4 ++-- 3 files changed, 5 insertions(+), 5 deletions(-) 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();