feat(RetailMemberVO): 会员信息页导出移除收益区域字段，注册业绩移除货币符号

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

@@ -133,7 +133,16 @@ public interface CuMemberRetailRangeMapper extends BaseMapper<CuMemberRetailRang
      */
     List<CuMemberRetailRangeExt> queryEnoughAwardMember(@Param("rangeTableName") String rangeTableName,
                                                         @Param("totalCheck") BigDecimal totalCheck,
-                                                        @Param("pkAwards") Integer pkAwards);
+                                                        @Param("awardsValue") Integer awardsValue);
+
+    /**
+     * 查询符合奖衔业绩、安置条件会员
+     */
+    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,7 +91,13 @@ public interface ICuMemberRetailRangeService extends IService<CuMemberRetailRang
     /**
      * 查询符合奖衔业绩条件会员
      */
-    List<CuMemberRetailRangeExt> queryEnoughAwardMember(String settleTableName, BigDecimal totalCheck, Integer pkAwards);
+    List<CuMemberRetailRangeExt> queryEnoughAwardMember(String rangeTableName, BigDecimal totalCheck, Integer awardsValue);
+
+    /**
+     * 查询符合奖衔业绩、安置条件会员
+     */
+    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,8 +187,14 @@ public class CuMemberRetailRangeServiceImpl extends ServiceImpl<CuMemberRetailRa
     }
 
     @Override
-    public List<CuMemberRetailRangeExt> queryEnoughAwardMember(String settleTableName, BigDecimal totalCheck, Integer pkAwards) {
-        return baseMapper.queryEnoughAwardMember(settleTableName, totalCheck, pkAwards);
+    public List<CuMemberRetailRangeExt> queryEnoughAwardMember(String rangeTableName, BigDecimal totalCheck, Integer awardsValue) {
+        return baseMapper.queryEnoughAwardMember(rangeTableName, totalCheck, awardsValue);
+    }
+
+    @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,8 +290,6 @@ 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<>();
             // 领导奖收益、平级奖收益
@@ -306,7 +304,7 @@ public class BonusSettleRangeHandle extends BonusSettleHandle {
             // 更新血缘上业绩、金额
             iCuMemberRetailRangeService.updateMemberParentDate(rangeTableName, memberAchieveHashMap);
             // 处理奖衔
-            iCuMemberAwardsService.calculateCuMemberAwards(rangeTableName, awardsList, awardsMap, settleStartDate, period);
+            iCuMemberAwardsService.calculateCuMemberAwards(rangeTableName, awardsList, settleStartDate, period);
 
             // 按照血缘，查询该会员所有伞上会员
             List<CuMemberRetailRangeExt> memberRetailRangeExtList = iCuMemberRetailRangeService.queryCuMemberRetailRangeParent(rangeTableName, orderList);
@@ -337,8 +335,8 @@ public class BonusSettleRangeHandle extends BonusSettleHandle {
                 sourceMember.setMonthConsumeAmount(sourceMember.getMonthConsumeAmount().add(orderAmount));
 //                // 自己计算奖衔，目前业绩都只往下传，所以此处暂时不需要处理订单会员的奖衔
 //                this.calculateAwards(period, memberRangeExtMap, rangeTableName, saOrderExt, retailAwardsMap, cuMemberAwardsList, sourceMember);
-                // 累计团队业绩、金额 + 计算奖衔
-                cuMemberAwardsList.addAll(this.calculateParentAwards(period, memberRangeExtMap, rangeTableName, sourceMember, saOrderExt, awardsMap));
+                // 累计团队业绩、金额
+                this.calculateParentDate(memberRangeExtMap, sourceMember, saOrderExt);
 
                 if (EOrderType.RETAIL_REGISTER.getValue() == saOrderExt.getOrderType()
                         || EOrderType.RETAIL_UPGRADE.getValue() == saOrderExt.getOrderType()) {
@@ -413,12 +411,6 @@ 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);
             // 更新日结明细数据
@@ -1094,12 +1086,10 @@ public class BonusSettleRangeHandle extends BonusSettleHandle {
 //    }
 
     /**
-     * 计算团队奖衔
+     * 计算团队数据
      */
-    private List<CuMemberAwards> calculateParentAwards(Integer period, Map<Long, CuMemberRetailRangeExt> memberRangeExtMap, String rangeTableName,
-                                                       CuMemberRetailRangeExt sourceMember, SaOrderExt saOrderExt, Map<Integer, BdAwards> retailAwardsMap) {
-        // 会员奖衔升级列表
-        List<CuMemberAwards> cuMemberAwardsList = new ArrayList<>();
+    private void calculateParentDate(Map<Long, CuMemberRetailRangeExt> memberRangeExtMap, CuMemberRetailRangeExt sourceMember,
+                                     SaOrderExt saOrderExt) {
         // 订单会员的推荐人
         CuMemberRetailRangeExt targetMember = memberRangeExtMap.get(sourceMember.getPkParent());
 
@@ -1124,12 +1114,8 @@ 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,7 +7,6 @@ import com.hzs.common.domain.system.config.BdAwards;
 
 import java.util.Date;
 import java.util.List;
-import java.util.Map;
 
 /**
  * 会员信息-奖衔升级记录 服务类
@@ -17,7 +16,7 @@ public interface ICuMemberAwardsService extends IService<CuMemberAwards> {
     /**
      * 计算奖衔
      */
-    void calculateCuMemberAwards(String rangeTableName, List<BdAwards> awardsList, Map<Integer, BdAwards> awardsMap, Date settleDate, Integer period);
+    void calculateCuMemberAwards(String rangeTableName, List<BdAwards> awardsList, Date settleDate, Integer period);
 
     /**
      * 批量插入奖衔记录

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

@@ -19,7 +19,6 @@ import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
 import java.util.*;
-import java.util.stream.Collectors;
 
 /**
  * 会员信息-奖衔升级记录 服务实现类
@@ -37,7 +36,7 @@ public class CuMemberAwardsServiceImpl extends ServiceImpl<CuMemberAwardsMapper,
     private ICuMemberRetailRangeService iCuMemberRetailRangeService;
 
     @Override
-    public void calculateCuMemberAwards(String rangeTableName, List<BdAwards> awardsList, Map<Integer, BdAwards> awardsMap, Date settleDate, Integer period) {
+    public void calculateCuMemberAwards(String rangeTableName, List<BdAwards> awardsList, Date settleDate, Integer period) {
         // 回退结算表奖衔
         iCuMemberTreeService.updateBackCuMemberRetailRangeAward(rangeTableName, period);
         // 回退会员表奖衔
@@ -56,7 +55,14 @@ public class CuMemberAwardsServiceImpl extends ServiceImpl<CuMemberAwardsMapper,
         Map<Long, List<CuMemberRetailRangeExt>> cuMemberRangeExtMap = new HashMap<>();
 
         for (BdAwards bdAwards : awardsList) {
-            List<CuMemberRetailRangeExt> cuMemberRetailRangeExtList = iCuMemberRetailRangeService.queryEnoughAwardMember(rangeTableName, bdAwards.getTotalCheck(), bdAwards.getPkId());
+            List<CuMemberRetailRangeExt> cuMemberRetailRangeExtList;
+            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) {
@@ -78,6 +84,12 @@ public class CuMemberAwardsServiceImpl extends ServiceImpl<CuMemberAwardsMapper,
             Date nowDate = new Date();
 
             cuMemberRetailRangeExtList.forEach(targetMember -> {
+                if (bdAwards.getPlaceDeptNum() > 0 && bdAwards.getCommunityCheck().compareTo(BigDecimal.ZERO) == 0) {
+                    // 需要校验部门奖衔并且小区业绩为0的
+                    cuMemberAwardsList.add(getCuMemberRetailAwards(targetMember, period, bdAwards, EAwardsType.RANGE_TYPE.getValue(), targetMember.getPkAwards(), nowDate));
+                    targetMember.setPkAwards(bdAwards.getPkId());
+                    targetMember.setAwardsValue(bdAwards.getAwardsValue());
+                } else {
                     List<CuMemberRetailRangeExt> cuMemberRangeExtList = cuMemberRangeExtMap.get(targetMember.getPkMember());
                     if (null == cuMemberRangeExtList) {
                         cuMemberRangeExtList = iCuMemberRetailRangeService.queryCuMemberRetailRangeExtByParent(rangeTableName, targetMember.getPkMember());
@@ -101,7 +113,7 @@ public class CuMemberAwardsServiceImpl extends ServiceImpl<CuMemberAwardsMapper,
                             if (CollectionUtil.isNotEmpty(cuMemberRangeExtList)) {
                                 // 验证每条血缘下，满足达标数量
                                 List<Integer> checkList = iCuMemberRetailRangeService.listChildAwards(rangeTableName, bdAwards.getPkCheckAwardsLeft(),
-                                    cuMemberRangeExtList.stream().map(CuMemberRetailRangeExt::getPkMember).collect(Collectors.toList()));
+                                        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());
@@ -115,6 +127,7 @@ public class CuMemberAwardsServiceImpl extends ServiceImpl<CuMemberAwardsMapper,
                             targetMember.setAwardsValue(bdAwards.getAwardsValue());
                         }
                     }
+                }
             });
         }
         return cuMemberAwardsList;

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

@@ -980,9 +980,36 @@
     <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 #{pkAwards} > cmr.pk_awards
+          and #{awardsValue} > ba.awards_value
+    </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>
 
     <!-- 查询会员血缘下达标奖衔会员 -->

bd-business/bd-business-member/src/main/java/com/hzs/member/base/vo/RetailMemberVO.java

@@ -118,7 +118,7 @@ public class RetailMemberVO implements Serializable {
     /**
      * 消费业绩 注册业绩
      */
-    @Excel(name = "注册业绩($)")
+    @Excel(name = "注册业绩")
     private BigDecimal consumeAchieve;
     /**
      * 隶属体系
@@ -161,26 +161,7 @@ public class RetailMemberVO implements Serializable {
     private String memberAccountVal;
     @Excel(name = "收益状态")
     private String incomeStatusVal;
-    /**
-     * 省
-     */
-    @Excel(name = "收益区省")
-    private String giftProvince;
 
-    private Integer province;
-
-    /**
-     * 市
-     */
-    @Excel(name = "收益区市")
-    private String giftCity;
-    private Integer city;
-    /**
-     * 县（区）
-     */
-    @Excel(name = "收益区县(区)")
-    private String giftCounty;
-    private Integer county;
     /**
      * 创建时间
      */

bd-business/bd-business-member/src/main/resources/mapper/member/base/CuMemberMapper.xml

@@ -1993,10 +1993,7 @@
         awar.awards_name as pkRangeAwardsVal,
         awm.awards_name as pkMaxAwardsVal,
         par.member_code parMemberCode,
-        par.member_name parMemberName,
-        pr.NAME giftProvince,
-        cty.NAME giftCity,
-        con.NAME giftCounty
+        par.member_name parMemberName
         FROM cu_member cm
         inner join CU_MEMBER_ACCOUNT cma
         on cm.pk_id = cma.PK_MEMBER
@@ -2018,12 +2015,6 @@
         on cmt.pk_id = cm.pk_team_code
         left join CU_MEMBER_RETAIL_REGION cmrr
         on cm.pk_id = cmrr.PK_MEMBER and cmrr.effective = 0 and cmrr.del_flag = 0
-        left join BD_AREA pr
-        on pr.pk_id = cmrr.PROVINCE
-        left join BD_AREA cty
-        on cty.pk_id = cmrr.CITY
-        left join BD_AREA con
-        on con.pk_id = cmrr.COUNTY
         WHERE cm.del_flag = 0 and cm.pk_id in
         (
         SELECT cm.PK_ID
@@ -2146,15 +2137,6 @@
         <if test="isConsume != null ">
             and cma.IS_CONSUME=#{isConsume}
         </if>
-        <if test="province != null">
-            and cmrr.PROVINCE=#{province}
-        </if>
-        <if test="city != null">
-            and cmrr.CITY=#{city}
-        </if>
-        <if test="county != null">
-            and cmrr.COUNTY=#{county}
-        </if>
         <!-- 体系权限处理 -->
         <if test="vertexList != null and vertexList.size > 0">
             and ver.pk_member in