diff --git a/mallinkService/src/main/java/com/iformall/service/impl/MallCooUserInfoServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/MallCooUserInfoServiceImpl.java index 96fc112cf..89b7c96df 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/MallCooUserInfoServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/MallCooUserInfoServiceImpl.java @@ -251,6 +251,7 @@ public class MallCooUserInfoServiceImpl implements MallCooUserInfoService { basicUserPushMsg.setMsgType(EnumMsgRecordType.MALL_COO_USER_PUSH.getCode()); basicUserPushMsg.updateTenantInfo(tenantEntity); basicUserPushMsg.setBasicUserId(basicUserId); + basicUserPushMsg.setIsFirst(false); logger.info(">>>>>>>>>>>send pullByMobileMsg :"+basicUserPushMsg); mqBaseProducer.sendMessage(basicUserPushMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); }catch(Exception e){ diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java index 48859b536..a71ced749 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java @@ -751,6 +751,7 @@ public class WxCUserBasicInfoServiceImpl implements WxCUserBasicInfoService,IExc basicUserPushMsg.updateTenantInfo(tenantInfo); basicUserPushMsg.setMallTenantEntity(mallTenant); basicUserPushMsg.setBasicUserId(userId); + basicUserPushMsg.setIsFirst(false); mqBaseProducer.sendMessage(basicUserPushMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); logger.info(">>>>>>>>>>>send updateTenantIdMsg :"+basicUserPushMsg); }catch(Exception e){