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 a6b006058..829e15d70 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java @@ -746,12 +746,18 @@ public class WxCUserBasicInfoServiceImpl implements WxCUserBasicInfoService,IExc @Override public void updateTenantIdMsg(TenantEntity tenantInfo, TenantEntity mallTenant, Long userId) { - FmInsideBasicUserPushMsg basicUserPushMsg = new FmInsideBasicUserPushMsg(); - basicUserPushMsg.setMsgType(EnumMsgRecordType.MEMBER_UPDATE_TENANT.getCode()); - basicUserPushMsg.updateTenantInfo(tenantInfo); - basicUserPushMsg.setMallTenantEntity(mallTenant); - basicUserPushMsg.setBasicUserId(userId); - mqBaseProducer.sendMessage(basicUserPushMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); + try{ + FmInsideBasicUserPushMsg basicUserPushMsg = new FmInsideBasicUserPushMsg(); + basicUserPushMsg.setMsgType(EnumMsgRecordType.MEMBER_UPDATE_TENANT.getCode()); + basicUserPushMsg.updateTenantInfo(tenantInfo); + basicUserPushMsg.setMallTenantEntity(mallTenant); + basicUserPushMsg.setBasicUserId(userId); + mqBaseProducer.sendMessage(basicUserPushMsg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); + logger.info(">>>>>>>>>>>send updateTenantIdMsg :"+basicUserPushMsg); + }catch(Exception e){ + logger.info(">>>>>>>>>>>send updateTenantIdMsg : error"+e.getMessage()); + } + } @Override diff --git a/mallinkService/src/main/java/com/iformall/service/msg/impl/FmInsideCouponVerifyMsgServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/msg/impl/FmInsideCouponVerifyMsgServiceImpl.java index 69c1548d8..7ed33028c 100644 --- a/mallinkService/src/main/java/com/iformall/service/msg/impl/FmInsideCouponVerifyMsgServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/msg/impl/FmInsideCouponVerifyMsgServiceImpl.java @@ -32,6 +32,9 @@ public class FmInsideCouponVerifyMsgServiceImpl implements MsgSendService { @Autowired private WxMerchantBUserService merchantBUserService; + @Autowired + private WxCUserBasicInfoService wxCUserBasicInfoService; + @Autowired private WxMerchantService merchantService; @@ -58,6 +61,8 @@ public class FmInsideCouponVerifyMsgServiceImpl implements MsgSendService { orderService.sendInsideOrderPushDeliveryMsg(couponOrder,null,couponOrder.getId()); // orderService.sendInsideOrderPushMsg(couponOrder,couponOrder.getComposeOrderId()); + wxCUserBasicInfoService.updateTenantIdMsg(couponOrder,merchant,couponOrder.getCUserId()); + couponOrderService.actionAfterVerify(couponOrder, merchant); } }