## 直推升级撤单处理等级；

bd-api/bd-api-member/src/main/java/com/hzs/member/base/IMemberServiceApi.java

@@ -296,9 +296,9 @@ public interface IMemberServiceApi {
      * 用户降级 -- 来源于活动
      *
      * @param cuMember 用户信息
-     * @param saOrder  订单信息
+     * @param pkOrder  订单ID
      */
-    R<?> reduceMemberLevel(CuMember cuMember, SaOrder saOrder);
+    R<?> reduceMemberLevel(CuMember cuMember, Long pkOrder);
 
     /**
      * 更新升级记录 -- 来源于活动

bd-business/bd-business-member/src/main/java/com/hzs/member/base/provider/MemberServiceProvider.java

@@ -352,9 +352,9 @@ public class MemberServiceProvider implements IMemberServiceApi {
     }
 
     @Override
-    public R<?> reduceMemberLevel(CuMember cuMember, SaOrder saOrder) {
+    public R<?> reduceMemberLevel(CuMember cuMember, Long pkOrder) {
         try {
-            iCuMemberBusinessService.reduceMemberLevel(cuMember, saOrder);
+            iCuMemberBusinessService.reduceMemberLevel(cuMember, pkOrder);
             return R.ok();
         } catch (Exception e) {
             return R.fail(e.getMessage());

bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/ICuMemberBusinessService.java

@@ -180,9 +180,9 @@ public interface ICuMemberBusinessService {
      * 用户降级 -- 来源于活动
      *
      * @param cuMember 用户信息
-     * @param saOrder  订单信息
+     * @param pkOrder  订单ID
      */
-    void reduceMemberLevel(CuMember cuMember, SaOrder saOrder);
+    void reduceMemberLevel(CuMember cuMember, Long pkOrder);
 
     /**
      * 更新升级记录 -- 来源于活动

bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberBusinessServiceImpl.java

@@ -1207,12 +1207,12 @@ public class CuMemberBusinessServiceImpl implements ICuMemberBusinessService {
 
     @Transactional(rollbackFor = Exception.class)
     @Override
-    public void reduceMemberLevel(CuMember cuMember, SaOrder saOrder) {
+    public void reduceMemberLevel(CuMember cuMember, Long pkOrder) {
         updateCuMember(cuMember);
         iCuMemberLevelService.update(Wrappers.<CuMemberLevel>lambdaUpdate()
                 .eq(CuMemberLevel::getPkMember, cuMember.getPkId())
                 .eq(CuMemberLevel::getUpType, EUpgradeType.ACTIVITY_UPGRADE.getValue())
-                .eq(CuMemberLevel::getPkOrder, saOrder.getPkId())
+                .eq(CuMemberLevel::getPkOrder, pkOrder)
                 .set(CuMemberLevel::getDelFlag, EDelFlag.DELETE.getValue())
                 .set(CuMemberLevel::getUpgradeTime, new Date())
         );

bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/service/impl/AcRepurCouponsRuleConfigServiceImpl.java

@@ -707,10 +707,12 @@ public class AcRepurCouponsRuleConfigServiceImpl extends ServiceImpl<AcRepurCoup
         Long pkOrderId = saOrderExt.getPkId();
         // 推荐人
         Long pkMember = saOrderExt.getPkReference();
+        // 订单年月
+        String upgradeTime = DateUtils.parseDateToFormat(DateUtils.YYYYMM, saOrderExt.getPayTime());
 
         List<AcRecomUpgradeRecord> upgradeRecordList = iAcRecomUpgradeRecordService.list(Wrappers.<AcRecomUpgradeRecord>lambdaQuery()
                 .eq(AcRecomUpgradeRecord::getPkMember, pkMember)
-                .eq(AcRecomUpgradeRecord::getPkOrderId, pkOrderId)
+                .eq(AcRecomUpgradeRecord::getUpgradeTime, upgradeTime)
                 .orderByDesc(AcRecomUpgradeRecord::getUpgradeTime)
         );
         if (CollectionUtil.isNotEmpty(upgradeRecordList)) {
@@ -732,10 +734,10 @@ public class AcRepurCouponsRuleConfigServiceImpl extends ServiceImpl<AcRepurCoup
                         .pkId(pkMember)
                         .pkSettleGrade(referenceMember.getPkSettleGrade())
                         .build();
-                iMemberServiceApi.reduceMemberLevel(cuMember, saOrderExt);
+                iMemberServiceApi.reduceMemberLevel(cuMember, recomUpgradeRecord.getPkOrderId());
             } else {
                 // 活动基础配置
-                AcBaseConfig baseConfig = iAcBaseConfigService.getById(recomUpgradeRecord.getPkId());
+                AcBaseConfig baseConfig = iAcBaseConfigService.getById(recomUpgradeRecord.getPkBaseId());
                 // 活动基础配置
                 AcRecomUpgradeRuleConfig upgradeRuleConfig = iAcRecomUpgradeRuleConfigService.getById(recomUpgradeRecord.getPkRuleId());
                 // 查询订单时间范围
@@ -762,7 +764,7 @@ public class AcRepurCouponsRuleConfigServiceImpl extends ServiceImpl<AcRepurCoup
                             .pkId(pkMember)
                             .pkSettleGrade(recomUpgradeRecord.getPkSettleGrade())
                             .build();
-                    iMemberServiceApi.reduceMemberLevel(cuMember, saOrderExt);
+                    iMemberServiceApi.reduceMemberLevel(cuMember, recomUpgradeRecord.getPkOrderId());
                     return;
                 }
                 // 足够升级，更新升级记录时间

bd-third/src/main/java/com/hzs/third/mqcall/listener/ActivityBackListener.java

@@ -51,9 +51,9 @@ public class ActivityBackListener {
                 if (EOrderType.REGISTER_ORDER.getValue() == saOrderExt.getOrderType()
                         || EOrderType.UPGRADE_ORDER.getValue() == saOrderExt.getOrderType()) {
                     // 处理直推升级
-                    iActivityServiceApi.invokeRecommendUpgrade(AcRecommendUpgradeDTO.builder().
+                    iActivityServiceApi.invokeRecommendUpgrade(AcRecommendUpgradeDTO.builder()
-                            saOrderExt(saOrderExt).
+                            .saOrderExt(saOrderExt)
-                            orderOperateStatus(EOrderOperateStatus.CANCEL)
+                            .orderOperateStatus(EOrderOperateStatus.CANCEL)
                             .build());
                 }
             }