diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/sale/order/service/impl/SaOrderServiceImpl.java b/bd-business/bd-business-sale/src/main/java/com/hzs/sale/order/service/impl/SaOrderServiceImpl.java index bb63c9d4..ee238cc1 100644 --- a/bd-business/bd-business-sale/src/main/java/com/hzs/sale/order/service/impl/SaOrderServiceImpl.java +++ b/bd-business/bd-business-sale/src/main/java/com/hzs/sale/order/service/impl/SaOrderServiceImpl.java @@ -73,6 +73,7 @@ import com.hzs.system.sys.IApprovalServiceApi; import com.hzs.system.sys.dto.ApprovalBusinessResultDTO; import com.hzs.system.sys.dto.ApprovalSubmitDTO; import com.hzs.system.sys.dto.LoginUser; +import com.hzs.third.sms.ISmsServiceApi; import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.config.annotation.DubboReference; import org.springframework.amqp.rabbit.core.RabbitTemplate; @@ -124,6 +125,8 @@ public class SaOrderServiceImpl extends ServiceImpl impl ICuMemberDetailServiceApi iCuMemberDetailServiceApi; @DubboReference ICuMemberAgreementWhiteApi cuMemberAgreementWhiteApi; + @DubboReference + ISmsServiceApi iSmsServiceApi; @Autowired private IBdWaresService iBdWaresService; @@ -759,6 +762,9 @@ public class SaOrderServiceImpl extends ServiceImpl impl // 推送秒结数据处理 -- 注册订单 rabbitTemplate.convertAndSend(RabbitMqConstants.ORDER_SECOND_EXCHANGE, RabbitMqConstants.ORDER_SECOND_KEY, saOrderExt); + + newCuMember.getMemberCode(); + // if (EOrderType.REGISTER_ORDER.getValue() == saOrderExt.getOrderType()) { // // 推送会员续约处理MQ // rabbitTemplate.convertAndSend(RabbitMqConstants.MEMBER_CONTINUE_EXCHANGE, RabbitMqConstants.MEMBER_CONTINUE_KEY, @@ -1884,7 +1890,7 @@ public class SaOrderServiceImpl extends ServiceImpl impl payUpgradeSaOrder(saOrderExt, null); } else { // 其他订单 - if (EOrderType.UPGRADE_ORDER.getValue() == saOrderExt.getOrderType() + if (EOrderType.REPURCHASE_ORDER.getValue() == saOrderExt.getOrderType() && EOrderTypeExtend.REG_REP.getValue() == saOrderExt.getOrderTypeExtend()) { // 188分享订单,复购订单 扩展类型为 注册转复购 OrderParam orderParam = redisService.getCacheObject(CacheConstants.TEMP_PARAM + pkMember + orderCode);