Просмотр исходного кода

//tenant msg

release_toaliyun_real
xhxu 3 лет назад
Родитель
Сommit
4c6d26993a
2 измененных файлов: 17 добавлений и 6 удалений
  1. +12
    -6
      mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java
  2. +5
    -0
      mallinkService/src/main/java/com/iformall/service/msg/impl/FmInsideCouponVerifyMsgServiceImpl.java

+ 12
- 6
mallinkService/src/main/java/com/iformall/service/impl/WxCUserBasicInfoServiceImpl.java Просмотреть файл

@@ -746,12 +746,18 @@ public class WxCUserBasicInfoServiceImpl implements WxCUserBasicInfoService,IExc


@Override @Override
public void updateTenantIdMsg(TenantEntity tenantInfo, TenantEntity mallTenant, Long userId) { 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 @Override


+ 5
- 0
mallinkService/src/main/java/com/iformall/service/msg/impl/FmInsideCouponVerifyMsgServiceImpl.java Просмотреть файл

@@ -32,6 +32,9 @@ public class FmInsideCouponVerifyMsgServiceImpl implements MsgSendService {
@Autowired @Autowired
private WxMerchantBUserService merchantBUserService; private WxMerchantBUserService merchantBUserService;


@Autowired
private WxCUserBasicInfoService wxCUserBasicInfoService;

@Autowired @Autowired
private WxMerchantService merchantService; private WxMerchantService merchantService;


@@ -58,6 +61,8 @@ public class FmInsideCouponVerifyMsgServiceImpl implements MsgSendService {
orderService.sendInsideOrderPushDeliveryMsg(couponOrder,null,couponOrder.getId()); orderService.sendInsideOrderPushDeliveryMsg(couponOrder,null,couponOrder.getId());
// orderService.sendInsideOrderPushMsg(couponOrder,couponOrder.getComposeOrderId()); // orderService.sendInsideOrderPushMsg(couponOrder,couponOrder.getComposeOrderId());


wxCUserBasicInfoService.updateTenantIdMsg(couponOrder,merchant,couponOrder.getCUserId());

couponOrderService.actionAfterVerify(couponOrder, merchant); couponOrderService.actionAfterVerify(couponOrder, merchant);
} }
} }

Загрузка…
Отмена
Сохранить