bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/achieve/mapper/CuMemberRetailRangeMapper.java

@@ -133,16 +133,7 @@ public interface CuMemberRetailRangeMapper extends BaseMapper<CuMemberRetailRang
      */
     List<CuMemberRetailRangeExt> queryEnoughAwardMember(@Param("rangeTableName") String rangeTableName,
                                                         @Param("totalCheck") BigDecimal totalCheck,
-                                                        @Param("awardsValue") Integer awardsValue);
+                                                        @Param("pkAwards") Integer pkAwards);
-
-    /**
-     * 查询符合奖衔业绩、安置条件会员
-     */
-    List<CuMemberRetailRangeExt> queryEnoughAwardPlaceMember(@Param("rangeTableName") String rangeTableName,
-                                                             @Param("awardsValue") Integer awardsValue,
-                                                             @Param("totalCheck") BigDecimal totalCheck,
-                                                             @Param("placeDeptNum") Integer placeDeptNum,
-                                                             @Param("checkAwardsValue") Integer checkAwardsValue);
 
     /**
      * 查询会员血缘下达标奖衔会员

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/achieve/service/ICuMemberRetailRangeService.java

@@ -91,13 +91,7 @@ public interface ICuMemberRetailRangeService extends IService<CuMemberRetailRang
     /**
      * 查询符合奖衔业绩条件会员
      */
-    List<CuMemberRetailRangeExt> queryEnoughAwardMember(String rangeTableName, BigDecimal totalCheck, Integer awardsValue);
+    List<CuMemberRetailRangeExt> queryEnoughAwardMember(String settleTableName, BigDecimal totalCheck, Integer pkAwards);
-
-    /**
-     * 查询符合奖衔业绩、安置条件会员
-     */
-    List<CuMemberRetailRangeExt> queryEnoughAwardPlaceMember(String rangeTableName, Integer awardsValue, BigDecimal totalCheck, Integer placeDeptNum,
-                                                             Integer checkAwardsValue);
 
     /**
      * 查询会员血缘下达标奖衔会员

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/achieve/service/impl/CuMemberRetailRangeServiceImpl.java

@@ -187,14 +187,8 @@ public class CuMemberRetailRangeServiceImpl extends ServiceImpl<CuMemberRetailRa
     }
 
     @Override
-    public List<CuMemberRetailRangeExt> queryEnoughAwardMember(String rangeTableName, BigDecimal totalCheck, Integer awardsValue) {
+    public List<CuMemberRetailRangeExt> queryEnoughAwardMember(String settleTableName, BigDecimal totalCheck, Integer pkAwards) {
-        return baseMapper.queryEnoughAwardMember(rangeTableName, totalCheck, awardsValue);
+        return baseMapper.queryEnoughAwardMember(settleTableName, totalCheck, pkAwards);
-    }
-
-    @Override
-    public List<CuMemberRetailRangeExt> queryEnoughAwardPlaceMember(String rangeTableName, Integer awardsValue, BigDecimal totalCheck, Integer placeDeptNum,
-                                                                    Integer checkAwardsValue) {
-        return baseMapper.queryEnoughAwardPlaceMember(rangeTableName, awardsValue, totalCheck, placeDeptNum, checkAwardsValue);
     }
 
     @Override

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/service/impl/BonusSettleRangeHandle.java

@@ -290,6 +290,8 @@ public class BonusSettleRangeHandle extends BonusSettleHandle {
             List<BdAwards> awardsList = bonusConfigDTO.getAwardsList();
             awardsList.forEach(bdAwards -> awardsMap.put(bdAwards.getAwardsValue(), bdAwards));
 
+            // 会员奖衔升级记录
+            List<CuMemberAwards> cuMemberAwardsList = new ArrayList<>();
             // 直推收益、见点收益
             List<CuMemberBonusPush> cuMemberBonusPushList = new ArrayList<>();
             // 领导奖收益、平级奖收益
@@ -304,7 +306,7 @@ public class BonusSettleRangeHandle extends BonusSettleHandle {
             // 更新血缘上业绩、金额
             iCuMemberRetailRangeService.updateMemberParentDate(rangeTableName, memberAchieveHashMap);
             // 处理奖衔
-            iCuMemberAwardsService.calculateCuMemberAwards(rangeTableName, awardsList, settleStartDate, period);
+            iCuMemberAwardsService.calculateCuMemberAwards(rangeTableName, awardsList, awardsMap, settleStartDate, period);
 
             // 按照血缘，查询该会员所有伞上会员
             List<CuMemberRetailRangeExt> memberRetailRangeExtList = iCuMemberRetailRangeService.queryCuMemberRetailRangeParent(rangeTableName, orderList);
@@ -335,8 +337,8 @@ public class BonusSettleRangeHandle extends BonusSettleHandle {
                 sourceMember.setMonthConsumeAmount(sourceMember.getMonthConsumeAmount().add(orderAmount));
 //                // 自己计算奖衔，目前业绩都只往下传，所以此处暂时不需要处理订单会员的奖衔
 //                this.calculateAwards(period, memberRangeExtMap, rangeTableName, saOrderExt, retailAwardsMap, cuMemberAwardsList, sourceMember);
-                // 累计团队业绩、金额
+                // 累计团队业绩、金额 + 计算奖衔
-                this.calculateParentDate(memberRangeExtMap, sourceMember, saOrderExt);
+                cuMemberAwardsList.addAll(this.calculateParentAwards(period, memberRangeExtMap, rangeTableName, sourceMember, saOrderExt, awardsMap));
 
                 if (EOrderType.RETAIL_REGISTER.getValue() == saOrderExt.getOrderType()
                         || EOrderType.RETAIL_UPGRADE.getValue() == saOrderExt.getOrderType()) {
@@ -411,6 +413,12 @@ public class BonusSettleRangeHandle extends BonusSettleHandle {
             if (cuMemberBonusStageList.size() > 0) {
                 bonusRecordDetailVO.setCuMemberBonusStageList(cuMemberBonusStageList);
             }
+//            if (cuMemberAwardsList.size() > 0) {
+//                // 批量插入会员奖衔记录
+//                iCuMemberAwardsService.saveBatchCuMemberAwards(cuMemberAwardsList);
+//                // 更新会员表奖衔数据
+//                iCuMemberService.updateCuMemberAwardsByPeriod(period);
+//            }
             // 更新日结数据
             iCuMemberRetailRangeService.updateCuMemberRetailRange(rangeTableName, memberRangeExtMap);
             // 更新日结明细数据
@@ -1086,10 +1094,12 @@ public class BonusSettleRangeHandle extends BonusSettleHandle {
 //    }
 
     /**
-     * 计算团队数据
+     * 计算团队奖衔
      */
-    private void calculateParentDate(Map<Long, CuMemberRetailRangeExt> memberRangeExtMap, CuMemberRetailRangeExt sourceMember,
+    private List<CuMemberAwards> calculateParentAwards(Integer period, Map<Long, CuMemberRetailRangeExt> memberRangeExtMap, String rangeTableName,
-                                     SaOrderExt saOrderExt) {
+                                                       CuMemberRetailRangeExt sourceMember, SaOrderExt saOrderExt, Map<Integer, BdAwards> retailAwardsMap) {
+        // 会员奖衔升级列表
+        List<CuMemberAwards> cuMemberAwardsList = new ArrayList<>();
         // 订单会员的推荐人
         CuMemberRetailRangeExt targetMember = memberRangeExtMap.get(sourceMember.getPkParent());
 
@@ -1114,8 +1124,12 @@ public class BonusSettleRangeHandle extends BonusSettleHandle {
                 targetMember.setRepTeamNewPv(targetMember.getRepTeamNewPv().add(orderAchieve));
                 targetMember.setRepTeamNewAmount(targetMember.getRepTeamNewAmount().add(orderAmount));
             }
+//            // 计算奖衔
+//            calculateAwards(period, memberRangeExtMap, rangeTableName, saOrderExt, retailAwardsMap, cuMemberAwardsList, targetMember);
+
             targetMember = memberRangeExtMap.get(targetMember.getPkParent());
         }
+        return cuMemberAwardsList;
     }
 
 

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/detail/service/ICuMemberAwardsService.java

@@ -7,6 +7,7 @@ import com.hzs.common.domain.system.config.BdAwards;
 
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
 
 /**
  * 会员信息-奖衔升级记录 服务类
@@ -16,7 +17,7 @@ public interface ICuMemberAwardsService extends IService<CuMemberAwards> {
     /**
      * 计算奖衔
      */
-    void calculateCuMemberAwards(String rangeTableName, List<BdAwards> awardsList, Date settleDate, Integer period);
+    void calculateCuMemberAwards(String rangeTableName, List<BdAwards> awardsList, Map<Integer, BdAwards> awardsMap, Date settleDate, Integer period);
 
     /**
      * 批量插入奖衔记录

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/detail/service/impl/CuMemberAwardsServiceImpl.java

@@ -19,6 +19,7 @@ import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
 import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * 会员信息-奖衔升级记录 服务实现类
@@ -36,7 +37,7 @@ public class CuMemberAwardsServiceImpl extends ServiceImpl<CuMemberAwardsMapper,
     private ICuMemberRetailRangeService iCuMemberRetailRangeService;
 
     @Override
-    public void calculateCuMemberAwards(String rangeTableName, List<BdAwards> awardsList, Date settleDate, Integer period) {
+    public void calculateCuMemberAwards(String rangeTableName, List<BdAwards> awardsList, Map<Integer, BdAwards> awardsMap, Date settleDate, Integer period) {
         // 回退结算表奖衔
         iCuMemberTreeService.updateBackCuMemberRetailRangeAward(rangeTableName, period);
         // 回退会员表奖衔
@@ -55,14 +56,7 @@ public class CuMemberAwardsServiceImpl extends ServiceImpl<CuMemberAwardsMapper,
         Map<Long, List<CuMemberRetailRangeExt>> cuMemberRangeExtMap = new HashMap<>();
 
         for (BdAwards bdAwards : awardsList) {
-            List<CuMemberRetailRangeExt> cuMemberRetailRangeExtList;
+            List<CuMemberRetailRangeExt> cuMemberRetailRangeExtList = iCuMemberRetailRangeService.queryEnoughAwardMember(rangeTableName, bdAwards.getTotalCheck(), bdAwards.getPkId());
-            if (bdAwards.getPlaceDeptNum() > 0) {
-                BdAwards checkAwards = awardsList.stream().filter(tmpDate -> tmpDate.getPkId().equals(bdAwards.getPkCheckAwardsLeft())).findFirst().get();
-                cuMemberRetailRangeExtList = iCuMemberRetailRangeService.queryEnoughAwardPlaceMember(rangeTableName, bdAwards.getAwardsValue(),
-                        bdAwards.getTotalCheck(), bdAwards.getPlaceDeptNum(), checkAwards.getAwardsValue());
-            } else {
-                cuMemberRetailRangeExtList = iCuMemberRetailRangeService.queryEnoughAwardMember(rangeTableName, bdAwards.getTotalCheck(), bdAwards.getAwardsValue());
-            }
             cuMemberAwardsList.addAll(this.calculateAwards(rangeTableName, bdAwards, period, cuMemberRetailRangeExtList, cuMemberRangeExtMap));
         }
         if (cuMemberAwardsList.size() > 0) {
@@ -76,7 +70,7 @@ public class CuMemberAwardsServiceImpl extends ServiceImpl<CuMemberAwardsMapper,
     }
 
     private List<CuMemberAwards> calculateAwards(String rangeTableName, BdAwards bdAwards, Integer period,
-                                                 List<CuMemberRetailRangeExt> cuMemberRetailRangeExtList, Map<Long, List<CuMemberRetailRangeExt>> cuMemberRangeExtMap) {
+                                 List<CuMemberRetailRangeExt> cuMemberRetailRangeExtList, Map<Long, List<CuMemberRetailRangeExt>> cuMemberRangeExtMap) {
         // 只满足业绩的
         List<CuMemberAwards> cuMemberAwardsList = new ArrayList<>();
 
@@ -84,48 +78,41 @@ public class CuMemberAwardsServiceImpl extends ServiceImpl<CuMemberAwardsMapper,
             Date nowDate = new Date();
 
             cuMemberRetailRangeExtList.forEach(targetMember -> {
-                if (bdAwards.getPlaceDeptNum() > 0 && bdAwards.getCommunityCheck().compareTo(BigDecimal.ZERO) == 0) {
+                List<CuMemberRetailRangeExt> cuMemberRangeExtList = cuMemberRangeExtMap.get(targetMember.getPkMember());
-                    // 需要校验部门奖衔并且小区业绩为0的
+                if (null == cuMemberRangeExtList) {
-                    cuMemberAwardsList.add(getCuMemberRetailAwards(targetMember, period, bdAwards, EAwardsType.RANGE_TYPE.getValue(), targetMember.getPkAwards(), nowDate));
+                    cuMemberRangeExtList = iCuMemberRetailRangeService.queryCuMemberRetailRangeExtByParent(rangeTableName, targetMember.getPkMember());
-                    targetMember.setPkAwards(bdAwards.getPkId());
+                    cuMemberRangeExtMap.put(targetMember.getPkMember(), cuMemberRangeExtList);
-                    targetMember.setAwardsValue(bdAwards.getAwardsValue());
+                }
-                } else {
+                // 大区
-                    List<CuMemberRetailRangeExt> cuMemberRangeExtList = cuMemberRangeExtMap.get(targetMember.getPkMember());
+                BigDecimal consumeBigPv = BigDecimal.ZERO;
-                    if (null == cuMemberRangeExtList) {
+                for (CuMemberRetailRangeExt cuMemberRetailRangeExt : cuMemberRangeExtList) {
-                        cuMemberRangeExtList = iCuMemberRetailRangeService.queryCuMemberRetailRangeExtByParent(rangeTableName, targetMember.getPkMember());
+                    // 累计业绩 = 团队累计消费业绩 + 个人累计消费业绩
-                        cuMemberRangeExtMap.put(targetMember.getPkMember(), cuMemberRangeExtList);
+                    BigDecimal consumePv = cuMemberRetailRangeExt.getTeamConsumePv().add(cuMemberRetailRangeExt.getConsumePv());
+                    if (ComputeUtil.compareGreaterThan(consumePv, consumeBigPv)) {
+                        // 累计业绩 > 大区业绩，则累计就成为大区
+                        consumeBigPv = consumePv;
                     }
-                    // 大区
+                }
-                    BigDecimal consumeBigPv = BigDecimal.ZERO;
+                // 小区业绩 = 团队累计业绩 - 大区业绩
-                    for (CuMemberRetailRangeExt cuMemberRetailRangeExt : cuMemberRangeExtList) {
+                BigDecimal smallAreaPv = ComputeUtil.computeSubtract(targetMember.getTeamConsumePv(), consumeBigPv);
-                        // 累计业绩 = 团队累计消费业绩 + 个人累计消费业绩
+                if (smallAreaPv.compareTo(bdAwards.getCommunityCheck()) >= 0) {
-                        BigDecimal consumePv = cuMemberRetailRangeExt.getTeamConsumePv().add(cuMemberRetailRangeExt.getConsumePv());
+                    // 小区业绩 >= 考核小区业绩
-                        if (ComputeUtil.compareGreaterThan(consumePv, consumeBigPv)) {
+                    if (bdAwards.getPlaceDeptNum() > 0) {
-                            // 累计业绩 > 大区业绩，则累计就成为大区
+                        if (CollectionUtil.isNotEmpty(cuMemberRangeExtList)) {
-                            consumeBigPv = consumePv;
+                            // 验证每条血缘下，满足达标数量
-                        }
+                            List<Integer> checkList = iCuMemberRetailRangeService.listChildAwards(rangeTableName, bdAwards.getPkCheckAwardsLeft(),
-                    }
+                                    cuMemberRangeExtList.stream().map(CuMemberRetailRangeExt::getPkMember).collect(Collectors.toList()));
-                    // 小区业绩 = 团队累计业绩 - 大区业绩
+                            if (CollectionUtil.isNotEmpty(checkList) && checkList.size() >= bdAwards.getPlaceDeptNum()) {
-                    BigDecimal smallAreaPv = ComputeUtil.computeSubtract(targetMember.getTeamConsumePv(), consumeBigPv);
+                                cuMemberAwardsList.add(getCuMemberRetailAwards(targetMember, period, bdAwards, EAwardsType.RANGE_TYPE.getValue(), targetMember.getPkAwards(), nowDate));
-                    if (smallAreaPv.compareTo(bdAwards.getCommunityCheck()) >= 0) {
+                                targetMember.setPkAwards(bdAwards.getPkId());
-                        // 小区业绩 >= 考核小区业绩
+                                targetMember.setAwardsValue(bdAwards.getAwardsValue());
-                        if (bdAwards.getPlaceDeptNum() > 0) {
-                            if (CollectionUtil.isNotEmpty(cuMemberRangeExtList)) {
-                                // 验证每条血缘下，满足达标数量
-                                List<Integer> checkList = iCuMemberRetailRangeService.listChildAwards(rangeTableName, bdAwards.getPkCheckAwardsLeft(),
-                                        Collections.singletonList(targetMember.getPkMember()));
-                                if (CollectionUtil.isNotEmpty(checkList) && checkList.size() >= bdAwards.getPlaceDeptNum()) {
-                                    cuMemberAwardsList.add(getCuMemberRetailAwards(targetMember, period, bdAwards, EAwardsType.RANGE_TYPE.getValue(), targetMember.getPkAwards(), nowDate));
-                                    targetMember.setPkAwards(bdAwards.getPkId());
-                                    targetMember.setAwardsValue(bdAwards.getAwardsValue());
-                                }
                             }
-                        } else {
-                            // 不需要考核血缘达标，直接给奖衔
-                            cuMemberAwardsList.add(getCuMemberRetailAwards(targetMember, period, bdAwards, EAwardsType.RANGE_TYPE.getValue(), targetMember.getPkAwards(), nowDate));
-                            targetMember.setPkAwards(bdAwards.getPkId());
-                            targetMember.setAwardsValue(bdAwards.getAwardsValue());
                         }
+                    } else {
+                        // 不需要考核血缘达标，直接给奖衔
+                        cuMemberAwardsList.add(getCuMemberRetailAwards(targetMember, period, bdAwards, EAwardsType.RANGE_TYPE.getValue(), targetMember.getPkAwards(), nowDate));
+                        targetMember.setPkAwards(bdAwards.getPkId());
+                        targetMember.setAwardsValue(bdAwards.getAwardsValue());
                     }
                 }
             });

bd-business/bd-business-bonus/src/main/resources/mapper/bonus/achieve/CuMemberRetailRangeMapper.xml

@@ -980,36 +980,9 @@
     <select id="queryEnoughAwardMember" resultMap="CuMemberRetailRangeExt">
         select cmr.*
         from ${rangeTableName} cmr
-                 left join bd_awards ba
-                           on ba.pk_id = cmr.pk_awards
         where cmr.category = 0
           and cmr.team_consume_pv >= #{totalCheck}
-          and #{awardsValue} > ba.awards_value
+          and #{pkAwards} > cmr.pk_awards
-    </select>
-
-    <!-- 查询符合奖衔业绩、安置条件会员 -->
-    <select id="queryEnoughAwardPlaceMember" resultMap="CuMemberRetailRangeExt">
-        select cmr.*
-        from ${rangeTableName} cmr
-                 left join bd_awards ba
-                           on ba.pk_id = cmr.pk_awards
-        where cmr.pk_member in
-              (select cmr.pk_parent
-               from ${rangeTableName} cmr
-               where cmr.pk_parent != 0
-        start with cmr.pk_member in
-                 (select cmr.pk_member
-            from ${rangeTableName} cmr
-            left join bd_awards ba
-            on ba.pk_id = cmr.pk_awards
-               and ba.del_flag = 0
-            where cmr.category = 0
-               and ba.awards_value >= #{checkAwardsValue})
-        connect by cmr.pk_member = prior cmr.pk_parent
-        group by cmr.pk_parent
-        having count (distinct cmr.pk_member) >= #{placeDeptNum})
-           and #{awardsValue} > ba.awards_value
-           and cmr.team_consume_pv >= #{totalCheck}
     </select>
 
     <!-- 查询会员血缘下达标奖衔会员 -->