From 271163e17fe8276781c4f88b6b52b25869112c9d Mon Sep 17 00:00:00 2001 From: winter Date: Thu, 16 May 2024 12:05:44 +0800 Subject: [PATCH] fix --- .../com/iformall/service/impl/MallCooUserInfoServiceImpl.java | 1 + .../com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java | 1 + 2 files changed, 2 insertions(+) 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){