From 1bf8463b8579317aa6f767202ab793c292deaadc Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 9 Nov 2020 16:51:49 +0800 Subject: [PATCH] bug --- .../service/impl/WxMsgServiceImpl.java | 25 ++++++++++++++++--- 1 file changed, 21 insertions(+), 4 deletions(-) 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 c70d836e5..1fb470929 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java @@ -75,6 +75,9 @@ public class WxMsgServiceImpl implements WxMsgService { @Autowired WxAppinfoService wxAppinfoService; + @Autowired + WxCUserService wxCUserService; + @Override public PageInfo listAsPage(WxMsg record, Integer pageIndex, Integer pageSize) { PageHelper.startPage(pageIndex, pageSize); @@ -371,6 +374,10 @@ public class WxMsgServiceImpl implements WxMsgService { smartAppMsg.setAppId(cAppInfo.getAppId()); WxTemplateMsg wxTemplateMsg = wxTemplateMsgMapper.selectById(wxMsg.getModelId()); +// if(1 == wxTemplateMsg.getOnOff().intValue()){ +// logger.error("订阅消息模板关闭。"); +// return; +// } smartAppMsg.setTemplateType(wxTemplateMsg.getType()); JSONObject customParam = JSON.parseObject(wxMsg.getMsg()); @@ -415,13 +422,23 @@ public class WxMsgServiceImpl implements WxMsgService { }else{ WxCUser wxCUserQ = new WxCUser(); wxCUserQ.updateTenantInfo(tenantEntity); - - List list = wxCUserMapper.findList(wxCUserQ); - wxMsg.setExpectSendNumber(list.size()); - for (WxCUser u:list) { + PageInfo wxCUserPageInfo = wxCUserService.listAsPage(wxCUserQ, 1, 1000); +// List list = wxCUserService.findList(wxCUserQ); + wxMsg.setExpectSendNumber((int) wxCUserPageInfo.getTotal()); + for (WxCUser u:wxCUserPageInfo.getList()) { smartAppMsg.setTo(u.getOpenId()); mqBaseProducer.sendMessage(smartAppMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); } + if(wxCUserPageInfo.getPages() > 1){ + for(int i=2;i<=wxCUserPageInfo.getPages();i++){ + wxCUserPageInfo = wxCUserService.listAsPage(wxCUserQ, i, 1000); + for (WxCUser u:wxCUserPageInfo.getList()) { + smartAppMsg.setTo(u.getOpenId()); + mqBaseProducer.sendMessage(smartAppMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); + } + } + } + } }