From b2b2544a0c02f4e476fb7e2261eb65dedf6f0d60 Mon Sep 17 00:00:00 2001 From: xhxu Date: Wed, 11 Nov 2020 10:59:16 +0800 Subject: [PATCH] bug --- .../src/main/java/com/iformall/mapper/WxCUserMapper.java | 2 +- .../main/java/com/iformall/service/impl/WxMsgServiceImpl.java | 3 +++ .../iformall/service/msg/impl/SendSmartAppMsgServiceImpl.java | 3 ++- mallinkService/src/main/resources/mapper/WxCUserMapper.xml | 2 +- 4 files changed, 7 insertions(+), 3 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java b/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java index 954d407cd..8df7c87a2 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/WxCUserMapper.java @@ -39,5 +39,5 @@ public interface WxCUserMapper extends CommonMapper { void updateMsgCount(WxCUser user); - void updateMsgCountDown(@Param("tenantId")String tenantId, String[] array); + void updateMsgCountDown(@Param("tenantId")String tenantId, @Param("openIds")List list); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java index b0421dc1b..21ea3a9c5 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java @@ -441,6 +441,9 @@ public class WxMsgServiceImpl implements WxMsgService { wxCUserQ.updateTenantInfo(tenantEntity); PageInfo openIdPage = wxCUserService.listOpenIdAsPage(wxCUserQ, 1, 1000); wxMsg.setExpectSendNumber((int) openIdPage.getTotal()); + if(openIdPage.getTotal() == 0){ + return; + } String phones = StringUtils.join(openIdPage.getList(), ","); smartAppMsg.setTo(phones); mqBaseProducer.sendMessage(smartAppMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); diff --git a/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmartAppMsgServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmartAppMsgServiceImpl.java index fce0ad070..1062303eb 100644 --- a/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmartAppMsgServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/msg/impl/SendSmartAppMsgServiceImpl.java @@ -24,6 +24,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.ArrayList; +import java.util.Arrays; import java.util.List; /** @@ -115,7 +116,7 @@ public class SendSmartAppMsgServiceImpl implements MsgSendService { // wxMaService.getMsgService().sendTemplateMsg(templateMessage); String[] split = smartAppMsg.getTo().split(","); - wxCUserMapper.updateMsgCountDown(tenantEntity.getTenantId(),split); + wxCUserMapper.updateMsgCountDown(tenantEntity.getTenantId(),Arrays.asList(split)); for (String to:split) { subscribeMessage = WxMaSubscribeMessage.builder() diff --git a/mallinkService/src/main/resources/mapper/WxCUserMapper.xml b/mallinkService/src/main/resources/mapper/WxCUserMapper.xml index 7f6c081c1..aacc8adf2 100644 --- a/mallinkService/src/main/resources/mapper/WxCUserMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxCUserMapper.xml @@ -265,7 +265,7 @@ and `tenant_id` = #{tenantId} and `open_id` in - + #{openId}