## 会员实时奖金返回培育津贴字段；

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/account/mapper/CuMemberAccountMapper.java

@@ -2,113 +2,17 @@ package com.hzs.bonus.account.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.hzs.common.domain.member.account.CuMemberAccount;
-import com.hzs.common.domain.member.ext.CuMemberAccountExt;
 import org.apache.ibatis.annotations.Param;
 
-import java.math.BigDecimal;
-import java.util.List;
-
 /**
  * 会员账户信息 Mapper 接口
- *
- * @author hzs
- * @since 2022-08-11
  */
 public interface CuMemberAccountMapper extends BaseMapper<CuMemberAccount> {
 
-    /**
-     * 查询会员账户状态，账户信息
-     *
-     * @param cuMemberAccount 会员账户条件信息
-     * @return: List<CuMemberAccountExt>
-     * @Author: sui q
-     * @Date: 2022/9/5 11:57
-     */
-    List<CuMemberAccountExt> queryMemberAccountByCondition(CuMemberAccount cuMemberAccount);
-
-
-    /**
-     * 根据会员编码获取余额
-     *
-     * @param pkMember    会员编号
-     * @param accountType 账户类型
-     * @return BigDecimal
-     */
-    BigDecimal selectBalanceByMemberCode(@Param("pkMember") Long pkMember, @Param("accountType") Integer accountType);
-
-    /**
-     * 更新账户余额
-     *
-     * @param cuMemberAccount 会员账户表
-     * @return: Integer
-     * @Author: sui q
-     * @Date: 2022/9/21 21:42
-     */
-    Integer updateMemberAccount(CuMemberAccount cuMemberAccount);
-
-    /**
-     * 根据用户ID集合查询用户余额
-     *
-     * @param pkMembers 用户ID集合
-     * @return List<CuMemberAccount>
-     */
-    List<CuMemberAccount> selectMemberAccountByPkMember(@Param(value = "pkMembers") List<Long> pkMembers);
-
-
-    /**
-     * 根据国家查询余额与银行卡信息
-     *
-     * @param pkCountry 国家ID
-     * @return List<CuMemberAccountExt>
-     */
-    List<CuMemberAccountExt> queryMemberAccountByPkCountry(@Param("pkCountry") Integer pkCountry);
-
-    /**
-     * 获得更新账户余额 奖金账户、可提现账户、可消费账户
-     * 奖金账户 = 可提现账户+可消费账户
-     * 奖金账户操作时 ：入的金额 进可消费账户  出的金额 进可提现账户
-     * <p>
-     * 根据用户batch 批量更新余额
-     *
-     * @param batch 批次号
-     * @param type  操作类型（1：转入、2：转出）
-     * @return Boolean
-     */
-    Boolean updateBatchMemberAccountByPkmember(@Param("batch") String batch, @Param("pkModified") Long pkModified, @Param("type") int type);
-
-
-    /**
-     * 根据用户编号集查询用户账户的全部字段信息
-     *
-     * @param memberCodes 用户编号
-     * @return List<CuMemberAccountExt>
-     */
-    List<CuMemberAccountExt> queryMemberAccountAllByMemberCodes(@Param(value = "memberCodes") List<String> memberCodes);
-
-    /**
-     * 根据用户编号查询用户ID
-     *
-     * @param memberCodes 用户编号
-     * @param pkCountry   国家
-     * @return List<Long>
-     */
-    List<Long> selectPkMembersByMemberCode(@Param("memberCodes") List<String> memberCodes, @Param("pkCountry") Integer pkCountry);
-
-    /**
-     * 更新冻结账户信息
-     *
-     * @param cuMemberAccount
-     * @return Integer
-     */
-    Integer updateFrozenAmountInfo(CuMemberAccountExt cuMemberAccount);
-
     /**
      * 奖金发放，根据期间发放奖金，更新奖金余额
      *
      * @param startPeriod 期间
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/21 14:12
      */
     void updateMemberAccountGrantByPeriod(@Param("pkCountry") Integer pkCountry, @Param("startPeriod") Integer startPeriod,
                                           @Param("endPeriod") Integer endPeriod);
@@ -117,18 +21,7 @@ public interface CuMemberAccountMapper extends BaseMapper<CuMemberAccount> {
      * 奖金可提现，根据期间更新可提现金额，减少可消费金额
      *
      * @param startPeriod 期间
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/21 14:12
      */
     void updateMemberAccountWithdrawalByPeriod(@Param("startPeriod") Integer startPeriod, @Param("endPeriod") Integer endPeriod, @Param("pkCountry") Integer pkCountry);
 
-    /**
-     * 根据来源单号查询奖金账号信息
-     *
-     * @param sourceCode 来源单号
-     * @return List<CuMemberAccount>
-     */
-    List<CuMemberAccount> selectMemberBonusAccountBySourceCode(String sourceCode);
-
 }

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/account/mapper/CuMemberTradeBonusMapper.java

@@ -4,12 +4,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.hzs.common.domain.member.account.CuMemberTradeBonus;
 
 /**
- * <p>
  * 会员已发放奖金交易明细表 Mapper 接口
- * </p>
- *
- * @author hzs
- * @since 2023-03-24
  */
 public interface CuMemberTradeBonusMapper extends BaseMapper<CuMemberTradeBonus> {
 

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/account/mapper/CuMemberTradeDetailMapper.java

@@ -1,19 +1,13 @@
 package com.hzs.bonus.account.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.hzs.common.domain.member.account.CuMemberTradeBonus;
 import com.hzs.common.domain.member.account.CuMemberTradeDetail;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
 /**
- * <p>
  * Mapper 接口
- * </p>
- *
- * @author hzs
- * @since 2023-03-21
  */
 public interface CuMemberTradeDetailMapper extends BaseMapper<CuMemberTradeDetail> {
 
@@ -21,9 +15,6 @@ public interface CuMemberTradeDetailMapper extends BaseMapper<CuMemberTradeDetai
      * 批量插入会员交易流水，用于奖金发放插入流水
      *
      * @param cuMemberTradeDetailList 交易流水
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/21 11:45
      */
     void batchInsertCuMemberTradeDetail(@Param("cuMemberTradeDetailList") List<?> cuMemberTradeDetailList);
 
@@ -31,55 +22,7 @@ public interface CuMemberTradeDetailMapper extends BaseMapper<CuMemberTradeDetai
      * 奖金可提现 根据期间发放奖金
      *
      * @param startPeriod 期间
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/21 15:30
      */
     void updateCuMemberTradeDetailByPeriod(@Param("startPeriod") Integer startPeriod, @Param("endPeriod") Integer endPeriod, @Param("pkCountry") Integer pkCountry);
 
-    /**
-     * 根据会员编号查询会员奖金的发放明细
-     *
-     * @param pkMember 会员编号
-     * @return: List<CuMemberTradeDetail>
-     * @Author: sui q
-     * @Date: 2023/3/24 16:05
-     */
-    List<CuMemberTradeDetail> queryCuMemberTradeDetail(Long pkMember);
-
-    /**
-     * 批量更新会员奖金发放明细
-     *
-     * @param cuMemberTradeDetailList 会员奖金发放明细
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/24 17:41
-     */
-    void updateCuMemberTradeDetail(@Param("cuMemberTradeDetailList") List<?> cuMemberTradeDetailList);
-
-    /**
-     * 批量更新会员奖金发放明细
-     *
-     * @param cuMemberTradeDetailList 会员奖金发放明细
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/24 17:41
-     */
-    void updateAddCuMemberTradeDetail(@Param("cuMemberTradeDetailList") List<?> cuMemberTradeDetailList);
-
-    /**
-     * 根据交易流水信息 批量插入会员奖金发放
-     *
-     * @param sourceCode 单号
-     * @return Integer
-     */
-    Integer batchInsertMemberTradeDetailFromTrade(@Param("sourceCode") String sourceCode, @Param("period") Integer period);
-
-    /**
-     * 根据用户ID查询用户扣款金额
-     *
-     * @param pkMember 用户ID
-     * @return List<CuMemberTradeDetail>
-     */
-    List<CuMemberTradeDetail> selectMemberTradeDetailByPkMember(@Param("pkMember") Long pkMember);
 }

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/account/mapper/CuMemberTradeMapper.java

@@ -7,12 +7,7 @@ import org.apache.ibatis.annotations.Param;
 import java.util.List;
 
 /**
- * <p>
  * 会员交易明细 Mapper 接口
- * </p>
- *
- * @author hzs
- * @since 2022-09-06
  */
 public interface CuMemberTradeMapper extends BaseMapper<CuMemberTrade> {
 
@@ -20,9 +15,6 @@ public interface CuMemberTradeMapper extends BaseMapper<CuMemberTrade> {
      * 批量获取cuMemberBonus主键
      *
      * @param rowNum 数量
-     * @return: List<Integer>
-     * @Author: sui q
-     * @Date: 2022/12/13 13:47
      */
     List<Long> batchQueryCuMemberTradeSeq(Integer rowNum);
 
@@ -30,9 +22,6 @@ public interface CuMemberTradeMapper extends BaseMapper<CuMemberTrade> {
      * 批量插入会员交易流水，用于奖金发放插入流水
      *
      * @param cuMemberTradeList 交易流水
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/21 11:45
      */
     void batchInsertCuMemberTrade(@Param("cuMemberTradeList") List<?> cuMemberTradeList);
 

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/account/service/ICuMemberAccountService.java

@@ -3,42 +3,15 @@ package com.hzs.bonus.account.service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.hzs.common.domain.member.account.CuMemberAccount;
 
-import java.util.List;
-
 /**
  * 会员账户信息 服务类
- *
- * @author hzs
- * @since 2022-08-11
  */
 public interface ICuMemberAccountService extends IService<CuMemberAccount> {
 
-    /**
-     * 更新账户余额
-     *
-     * @param cuMemberAccount 会员账户表
-     * @param pkModified      修改人
-     * @return: Boolean
-     * @Author: sui q
-     * @Date: 2022/9/21 21:42
-     */
-    Boolean updateMemberAccount(CuMemberAccount cuMemberAccount, Long pkModified);
-
-    /**
-     * 根据用户ID集合查询用户余额
-     *
-     * @param pkMembers 用户ID集合
-     * @return List<CuMemberAccount>
-     */
-    List<CuMemberAccount> selectMemberAccountByPkMember(List<Long> pkMembers);
-
     /**
      * 奖金发放，根据期间发放奖金，更新奖金余额
      *
      * @param startPeriod 期间
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/21 14:12
      */
     void updateMemberAccountGrantByPeriod(Integer pkCountry, Integer startPeriod, Integer endPeriod);
 
@@ -46,9 +19,6 @@ public interface ICuMemberAccountService extends IService<CuMemberAccount> {
      * 奖金可提现，根据期间更新可提现金额，减少可消费金额
      *
      * @param startPeriod 期间
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/21 14:12
      */
     void updateMemberAccountWithdrawalByPeriod(Integer startPeriod, Integer endPeriod, Integer pkCountry);
 

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/account/service/ICuMemberTradeBonusService.java

@@ -4,12 +4,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
 import com.hzs.common.domain.member.account.CuMemberTradeBonus;
 
 /**
- * <p>
  * 会员已发放奖金交易明细表 服务类
- * </p>
- *
- * @author hzs
- * @since 2023-03-24
  */
 public interface ICuMemberTradeBonusService extends IService<CuMemberTradeBonus> {
 

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/account/service/ICuMemberTradeDetailService.java

@@ -1,18 +1,12 @@
 package com.hzs.bonus.account.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.hzs.common.domain.member.account.CuMemberTradeBonus;
 import com.hzs.common.domain.member.account.CuMemberTradeDetail;
 
 import java.util.List;
 
 /**
- * <p>
  * 服务类
- * </p>
- *
- * @author hzs
- * @since 2023-03-21
  */
 public interface ICuMemberTradeDetailService extends IService<CuMemberTradeDetail> {
 
@@ -20,9 +14,6 @@ public interface ICuMemberTradeDetailService extends IService<CuMemberTradeDetai
      * 批量插入会员交易流水，用于奖金发放插入流水
      *
      * @param cuMemberTradeDetailList 交易流水
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/21 11:45
      */
     void batchInsertCuMemberTradeDetail(List<CuMemberTradeDetail> cuMemberTradeDetailList);
 
@@ -30,57 +21,7 @@ public interface ICuMemberTradeDetailService extends IService<CuMemberTradeDetai
      * 奖金可提现 根据期间发放奖金
      *
      * @param startPeriod 期间
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/21 15:30
      */
     void updateCuMemberTradeDetailByPeriod(Integer startPeriod, Integer endPeriod, Integer pkCountry);
 
-    /**
-     * 根据会员编号查询会员奖金的发放明细
-     *
-     * @param pkMember 会员编号
-     * @return: List<CuMemberTradeDetail>
-     * @Author: sui q
-     * @Date: 2023/3/24 16:05
-     */
-    List<CuMemberTradeDetail> queryCuMemberTradeDetail(Long pkMember);
-
-    /**
-     * 批量更新会员奖金发放明细
-     *
-     * @param cuMemberTradeDetailList 会员奖金发放明细
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/24 17:41
-     */
-    void updateCuMemberTradeDetail(List<CuMemberTradeDetail> cuMemberTradeDetailList);
-
-    /**
-     * 批量更新会员奖金发放明细
-     *
-     * @param cuMemberTradeDetailList 会员奖金发放明细
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/24 17:41
-     */
-    void updateAddCuMemberTradeDetail(List<CuMemberTradeDetail> cuMemberTradeDetailList);
-
-    /**
-     * 根据交易流水信息 批量插入会员奖金发放
-     *
-     * @param sourceCode 单号
-     * @param period 期间
-     * @return Integer
-     */
-    Integer batchInsertMemberTradeDetailFromTrade(String sourceCode, Integer period);
-
-    /**
-     * 根据用户ID查询用户扣款金额
-     *
-     * @param pkMember 用户ID
-     * @return List<CuMemberTradeDetail>
-     */
-    List<CuMemberTradeDetail> selectMemberTradeDetailByPkMember(Long pkMember);
-
 }

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/account/service/ICuMemberTradeService.java

@@ -7,12 +7,7 @@ import org.apache.ibatis.annotations.Param;
 import java.util.List;
 
 /**
- * <p>
  * 会员交易明细 服务类
- * </p>
- *
- * @author hzs
- * @since 2022-09-06
  */
 public interface ICuMemberTradeService extends IService<CuMemberTrade> {
 
@@ -20,9 +15,6 @@ public interface ICuMemberTradeService extends IService<CuMemberTrade> {
      * 批量获取cuMemberBonus主键
      *
      * @param rowNum 数量
-     * @return: List<Integer>
-     * @Author: sui q
-     * @Date: 2022/12/13 13:47
      */
     List<Long> batchQueryCuMemberTradeSeq(Integer rowNum);
 
@@ -30,9 +22,6 @@ public interface ICuMemberTradeService extends IService<CuMemberTrade> {
      * 批量插入会员交易流水，用于奖金发放插入流水
      *
      * @param cuMemberTradeList 交易流水
-     * @return: void
-     * @Author: sui q
-     * @Date: 2023/3/21 11:45
      */
     void batchInsertCuMemberTrade(@Param("cuMemberTradeList") List<CuMemberTrade> cuMemberTradeList);
 

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

@@ -7,29 +7,13 @@ import com.hzs.bonus.account.mapper.CuMemberAccountMapper;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
-import java.util.List;
-
 /**
  * 会员账户信息 服务实现类
- *
- * @author hzs
- * @since 2022-08-11
  */
 @Service
 @Slf4j
 public class CuMemberAccountServiceImpl extends ServiceImpl<CuMemberAccountMapper, CuMemberAccount> implements ICuMemberAccountService {
 
-    @Override
-    public Boolean updateMemberAccount(CuMemberAccount cuMemberAccount, Long pkModified) {
-        cuMemberAccount.setPkModified(pkModified);
-        return baseMapper.updateMemberAccount(cuMemberAccount) > 0;
-    }
-
-    @Override
-    public List<CuMemberAccount> selectMemberAccountByPkMember(List<Long> pkMembers) {
-        return baseMapper.selectMemberAccountByPkMember(pkMembers);
-    }
-
     @Override
     public void updateMemberAccountGrantByPeriod(Integer pkCountry, Integer startPeriod, Integer endPeriod) {
         baseMapper.updateMemberAccountGrantByPeriod(pkCountry, startPeriod, endPeriod);

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

@@ -7,12 +7,7 @@ import com.hzs.common.domain.member.account.CuMemberTradeBonus;
 import org.springframework.stereotype.Service;
 
 /**
- * <p>
  * 会员已发放奖金交易明细表 服务实现类
- * </p>
- *
- * @author hzs
- * @since 2023-03-24
  */
 @Service
 public class CuMemberTradeBonusServiceImpl extends ServiceImpl<CuMemberTradeBonusMapper, CuMemberTradeBonus> implements ICuMemberTradeBonusService {

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

@@ -11,22 +11,13 @@ import org.springframework.stereotype.Service;
 import java.util.List;
 
 /**
- * <p>
  * 服务实现类
- * </p>
- *
- * @author hzs
- * @since 2023-03-21
  */
 @Service
 public class CuMemberTradeDetailServiceImpl extends ServiceImpl<CuMemberTradeDetailMapper, CuMemberTradeDetail> implements ICuMemberTradeDetailService {
 
-    private CuMemberBonusSettle cuMemberBonusSettle;
-
     @Autowired
-    public void setCuMemberBonusSettle(CuMemberBonusSettle cuMemberBonusSettle) {
+    private CuMemberBonusSettle cuMemberBonusSettle;
-        this.cuMemberBonusSettle = cuMemberBonusSettle;
-    }
 
     @Override
     public void batchInsertCuMemberTradeDetail(List<CuMemberTradeDetail> cuMemberTradeDetailList) {
@@ -40,41 +31,4 @@ public class CuMemberTradeDetailServiceImpl extends ServiceImpl<CuMemberTradeDet
         baseMapper.updateCuMemberTradeDetailByPeriod(startPeriod, endPeriod, pkCountry);
     }
 
-    @Override
-    public List<CuMemberTradeDetail> queryCuMemberTradeDetail(Long pkMember) {
-//        QueryWrapper<CuMemberTradeDetail> queryWrapper = new QueryWrapper<>();
-//        queryWrapper.eq(MemberFieldConstants.PK_MEMBER, pkMember)
-//                    .gt(MemberFieldConstants.CONSUME_MONEY, 0);
-//        queryWrapper.orderByAsc(MemberFieldConstants.PERIOD);
-//        return baseMapper.selectList(queryWrapper);
-        return baseMapper.queryCuMemberTradeDetail(pkMember);
-    }
-
-    @Override
-    public void updateCuMemberTradeDetail(List<CuMemberTradeDetail> cuMemberTradeDetailList) {
-        if (cuMemberTradeDetailList.size() > 0) {
-            List<List<?>> cutList = cuMemberBonusSettle.handleCutList(cuMemberTradeDetailList);
-            cutList.forEach(memberTradeDetailList ->
-                    baseMapper.updateCuMemberTradeDetail(memberTradeDetailList));
-        }
-    }
-
-    @Override
-    public void updateAddCuMemberTradeDetail(List<CuMemberTradeDetail> cuMemberTradeDetailList) {
-        if (cuMemberTradeDetailList.size() > 0) {
-            List<List<?>> cutList = cuMemberBonusSettle.handleCutList(cuMemberTradeDetailList);
-            cutList.forEach(memberTradeDetailList ->
-                    baseMapper.updateAddCuMemberTradeDetail(memberTradeDetailList));
-        }
-    }
-
-    @Override
-    public Integer batchInsertMemberTradeDetailFromTrade(String sourceCode, Integer period){
-        return baseMapper.batchInsertMemberTradeDetailFromTrade(sourceCode,period);
-    }
-
-    @Override
-    public List<CuMemberTradeDetail> selectMemberTradeDetailByPkMember(Long pkMember){
-        return baseMapper.selectMemberTradeDetailByPkMember(pkMember);
-    }
 }

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

@@ -1,11 +1,9 @@
 package com.hzs.bonus.account.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.hzs.bonus.account.service.ICuMemberAccountService;
 import com.hzs.bonus.account.service.ICuMemberTradeService;
 import com.hzs.bonus.achieve.service.impl.CuMemberBonusSettle;
 import com.hzs.common.domain.member.account.CuMemberTrade;
-import com.hzs.common.service.ITransactionCommonService;
 import com.hzs.bonus.account.mapper.CuMemberTradeMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -13,29 +11,14 @@ import org.springframework.stereotype.Service;
 import java.util.*;
 
 /**
- * <p>
  * 会员交易明细 服务实现类
- * </p>
- *
- * @author hzs
- * @since 2022-09-06
  */
 @Service
 public class CuMemberTradeServiceImpl extends ServiceImpl<CuMemberTradeMapper, CuMemberTrade> implements ICuMemberTradeService {
 
     @Autowired
-    ICuMemberAccountService cuMemberAccountService;
-
-    @Autowired
-    ITransactionCommonService iTransactionCommonService;
-
     private CuMemberBonusSettle cuMemberBonusSettle;
 
-    @Autowired
-    public void setCuMemberBonusSettle(CuMemberBonusSettle cuMemberBonusSettle) {
-        this.cuMemberBonusSettle = cuMemberBonusSettle;
-    }
-
     @Override
     public List<Long> batchQueryCuMemberTradeSeq(Integer rowNum) {
         return baseMapper.batchQueryCuMemberTradeSeq(rowNum);

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

@@ -5,20 +5,12 @@ import com.hzs.common.domain.member.achieve.CuMemberSettlePeriodDetail;
 import com.hzs.common.domain.member.achieve.ext.CuMemberSettlePeriodExt;
 
 /**
- * <p>
  * 会员结算期间明细 服务类
- * </p>
- *
- * @author hzs
- * @since 2023-07-27
  */
 public interface ICuMemberSettlePeriodDetailService extends IService<CuMemberSettlePeriodDetail> {
 
-    /*
+    /**
-     * @description: 更新明细表
+     * 更新明细表
-     * @author: sui q
+     */
-     * @date: 2023/7/28 17:43
-     * @param: null null
-     **/
     boolean updateCuMemberSettlePeriodDetailByPeriod(CuMemberSettlePeriodExt cuMemberSettlePeriodExt);
 }

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

@@ -2,11 +2,8 @@ package com.hzs.bonus.achieve.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.hzs.common.domain.member.achieve.CuMemberTree;
-import com.hzs.common.domain.member.ext.CuMemberSettleExt;
 
 import java.util.Date;
-import java.util.List;
-import java.util.Set;
 
 /**
  * 会员网体历史记录 服务类
@@ -57,30 +54,6 @@ public interface ICuMemberTreeService extends IService<CuMemberTree> {
      */
     void updateCuMemberRetailRangeInitAward(String rangeTableName);
 
-    /**
-     * 根据订单，查询出网体中记录的会员数据，推荐人、安置人
-     *
-     * @param settleTableName  结算表
-     * @param serviceMemberSet 会员编号
-     */
-    List<CuMemberSettleExt> batchQueryMemberSettleByMemberPk(String settleTableName, Set<Long> serviceMemberSet);
-
-    /**
-     * 根据订单，查询出网体中记录的会员数据及推荐人
-     *
-     * @param settleTableName  结算表
-     * @param serviceMemberSet 会员编号
-     */
-    List<CuMemberSettleExt> batchQueryMemberSettleParentByMemberPk(String settleTableName, Set<Long> serviceMemberSet);
-
-    /**
-     * 批量根据量奖信息查询会员结算表中的父级血缘数据
-     *
-     * @param settleTableName 结算表
-     * @param expandMemberSet 有量奖的会员
-     */
-    List<CuMemberSettleExt> batchQueryCuMemberSettleParent(String settleTableName, Set<Long> expandMemberSet);
-
     /**
      * 删除日表数据
      *

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

@@ -4,12 +4,10 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.hzs.bonus.achieve.service.ICuMemberAchieveService;
 import com.hzs.bonus.achieve.service.ICuMemberSettlePeriodService;
 import com.hzs.bonus.achieve.service.ICuMemberTreeService;
-import com.hzs.common.core.constant.MagicNumberConstants;
 import com.hzs.common.core.constant.TableNameConstants;
 import com.hzs.common.core.enums.EAwardsType;
 import com.hzs.common.core.utils.DateUtils;
 import com.hzs.common.domain.member.achieve.CuMemberTree;
-import com.hzs.common.domain.member.ext.CuMemberSettleExt;
 import com.hzs.bonus.achieve.mapper.CuMemberTreeMapper;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -30,8 +28,6 @@ public class CuMemberTreeServiceImpl extends ServiceImpl<CuMemberTreeMapper, CuM
     private ICuMemberAchieveService iCuMemberAchieveService;
     @Autowired
     private ICuMemberSettlePeriodService iCuMemberSettlePeriodService;
-    @Autowired
-    private CuMemberBonusSettle cuMemberBonusSettle;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -124,53 +120,6 @@ public class CuMemberTreeServiceImpl extends ServiceImpl<CuMemberTreeMapper, CuM
         baseMapper.updateCuMemberRetailRangeInitV5Award(rangeTableName);
     }
 
-    private List<CuMemberSettleExt> getCuMemberSettleExtList(String settleTableName, Set<Long> serviceMemberSet) {
-        List<CuMemberSettleExt> cuMemberSettleExtList = new ArrayList<>();
-        if (serviceMemberSet.size() > 0) {
-            List<Long> memberPkList = Arrays.asList(serviceMemberSet.toArray(new Long[]{}));
-            List<List<?>> listList = cuMemberBonusSettle.handleCutList(memberPkList);
-            listList.forEach(list ->
-                    cuMemberSettleExtList.addAll(baseMapper.queryMemberSettleBySaOrder(settleTableName, list)));
-        }
-        return cuMemberSettleExtList;
-    }
-
-    @Override
-    public List<CuMemberSettleExt> batchQueryMemberSettleByMemberPk(String settleTableName, Set<Long> serviceMemberSet) {
-        return getCuMemberSettleExtList(settleTableName, serviceMemberSet);
-    }
-
-    @Override
-    public List<CuMemberSettleExt> batchQueryMemberSettleParentByMemberPk(String settleTableName, Set<Long> serviceMemberSet) {
-        List<CuMemberSettleExt> cuMemberSettleExtList = new ArrayList<>();
-        if (serviceMemberSet.size() > 0) {
-            List<Long> memberPkList = Arrays.asList(serviceMemberSet.toArray(new Long[]{}));
-            List<List<?>> listList = cuMemberBonusSettle.handleCutList(memberPkList);
-            listList.forEach(list ->
-                    cuMemberSettleExtList.addAll(baseMapper.batchQueryMemberSettleParentByMemberPk(settleTableName, list)));
-        }
-        return cuMemberSettleExtList;
-    }
-
-    @Override
-    public List<CuMemberSettleExt> batchQueryCuMemberSettleParent(String settleTableName, Set<Long> expandMemberSet) {
-        List<CuMemberSettleExt> cuMemberSettleExtList = new ArrayList<>();
-        if (expandMemberSet == null || expandMemberSet.size() == 0) {
-            return cuMemberSettleExtList;
-        }
-        List<Long> memberPkList = Arrays.asList(expandMemberSet.toArray(new Long[]{}));
-        List<List<?>> listList = cuMemberBonusSettle.handleCutList(memberPkList, MagicNumberConstants.DELETE_DATA_BATCH_UPDATE_NUM);
-        listList.forEach(list ->
-                cuMemberSettleExtList.addAll(baseMapper.batchQueryCuMemberSettleParent(settleTableName, list)));
-        return cuMemberSettleExtList;
-    }
-
-    private List<List<?>> setUpdCuMemberTreeLists(Map<Long, CuMemberSettleExt> cuMemberTreeMap) {
-        List<CuMemberSettleExt> cuMemberTreeList = new ArrayList<>();
-        cuMemberTreeMap.forEach((key, value) -> cuMemberTreeList.add(value));
-        return cuMemberBonusSettle.handleCutList(cuMemberTreeList);
-    }
-
     @Override
     public void truncateCuMemberTreeTable(String tableName) {
         baseMapper.truncateCuMemberTreeTable(tableName);

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/base/mapper/CuMemberMapper.java

@@ -27,14 +27,23 @@ public interface CuMemberMapper extends BaseMapper<CuMember> {
     /**
      * 更新会员奖衔根据临时表
      */
-    Integer updateCuMemberRetailAwardsByPeriod(@Param("period") Integer period, @Param("awardType") Integer awardType);
+    int updateCuMemberRetailAwardsByPeriod(@Param("period") Integer period, @Param("awardType") Integer awardType);
+
+    /**
+     * 更新会员最高奖衔
+     *
+     * @param period
+     * @param awardType
+     * @return
+     */
+    int updateCuMemberMaxAwardsByPeriod(@Param("period") Integer period, @Param("awardType") Integer awardType);
 
     /**
      * 更新会员奖衔根据临时表
      *
      * @param cuMemberAwardsList 修改奖衔的会员
      */
-    Integer updateCuMemberRetailRangeByList(@Param("cuMemberAwardsList") List<CuMemberAwards> cuMemberAwardsList,
+    int updateCuMemberRetailRangeByList(@Param("cuMemberAwardsList") List<CuMemberAwards> cuMemberAwardsList,
                                             @Param("period") Integer period,
                                             @Param("awardType") Integer awardType);
 
@@ -43,7 +52,7 @@ public interface CuMemberMapper extends BaseMapper<CuMember> {
      *
      * @param cuMemberGradeList 修改奖衔的会员
      */
-    Integer updateCuMemberMinGradeByList(@Param("cuMemberGradeList") List<CuMemberGrade> cuMemberGradeList, @Param("period") Integer period);
+    int updateCuMemberMinGradeByList(@Param("cuMemberGradeList") List<CuMemberGrade> cuMemberGradeList, @Param("period") Integer period);
 
     /**
      * 更新会员的等级

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/base/service/ICuMemberService.java

@@ -23,11 +23,9 @@ public interface ICuMemberService extends IService<CuMember> {
     CuMemberExt getMemberByCode(String memberCode);
 
     /**
-     * 更新会员奖衔根据临时表
+     * 更新会员奖衔根据临时表 -- 日结
-     *
-     * @param cuMemberAwardsList 修改奖衔的会员
      */
-    void updateCuMemberRetailRangeByPeriod(List<CuMemberAwards> cuMemberAwardsList, Integer period);
+    void updateCuMemberRetailRangeByPeriod(Integer period);
 
     /**
      * 更新会员奖衔根据临时表

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

@@ -25,9 +25,11 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
     }
 
     @Override
-    public void updateCuMemberRetailRangeByPeriod(List<CuMemberAwards> cuMemberAwardsList, Integer period) {
+    public void updateCuMemberRetailRangeByPeriod(Integer period) {
         baseMapper.updateCuMemberRetailAwardsByPeriod(period, EAwardsType.RANGE_TYPE.getValue());
         baseMapper.updateCuMemberRetailAwardsByPeriod(period, EAwardsType.SHARE_TYPE.getValue());
+        // 更新会员最高奖衔
+        baseMapper.updateCuMemberMaxAwardsByPeriod(period, EAwardsType.RANGE_TYPE.getValue());
     }
 
     @Override

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/component/BonusSettleTimer.java

@@ -1,61 +0,0 @@
-package com.hzs.bonus.bonus.component;
-
-import lombok.extern.slf4j.Slf4j;
-
-/**
- * @Description: 奖金结算发放定时任务
- * @Author: sui q
- * @Time: 2023/3/4 13:47
- * @Classname: BonusSettleTimer
- * @PackageName: com.hzs.member.bonus.component
- */
-//@Component
-@Slf4j
-public class BonusSettleTimer {
-
-//    @DubboReference
-//    private ISystemConfigServiceApi systemConfigServiceApi;
-//
-//    @DubboReference
-//    private ISaOrderServiceApi saOrderServiceApi;
-//
-//    @DubboReference
-//    private IRangeServiceApi rangeServiceApi;
-//
-//    private IBonusSettleService bonusSettleService;
-//
-//    private ICuMemberTreeService cuMemberTreeService;
-//
-//    @Autowired
-//    public void setBonusSettleService(IBonusSettleService bonusSettleService) {
-//        this.bonusSettleService = bonusSettleService;
-//    }
-//
-//    @Autowired
-//    public void setCuMemberTreeService(ICuMemberTreeService cuMemberTreeService) {
-//        this.cuMemberTreeService = cuMemberTreeService;
-//    }
-//
-//    /**
-//     * 奖金每天自动结算,计算前一天奖金
-//    * @return: void
-//    * @Author: sui q
-//    * @Date: 2023/3/4 13:48
-//    */
-////    @Scheduled(cron = "0 0 0 * * ?")
-////    @Scheduled(cron = "* */1 * * * ?")
-//    public void autoSettleBonusEveryday(){
-//        log.info("开始进行奖金结算");
-//        Date currentDate = DateUtils.currentDate();
-//        Date startDate = DateUtils.beforeDate(1, ChronoUnit.DAYS, currentDate);
-//        String settleDate = DateUtils.parseDateTimeToStr(DateUtils.YYYY_MM_DD, startDate);
-//        // 自动初始化表
-//        cuMemberTreeService.createCuMemberTree(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, startDate));
-//        log.info("初始化表完成");
-//        // 奖金结算
-//        List<SaOrderExt> saOrderExtList = saOrderServiceApi.querySaOrderByDay(startDate, currentDate).getData();
-//        Map<String, String> systemConfigMap = systemConfigServiceApi.getBonusSystemConfig().getData();
-//        Map<String, RangeDTO> rangeDtoMap = rangeServiceApi.queryRangeDto().getData();
-//        bonusSettleService.calculateCuMemberBonus(systemConfigMap, rangeDtoMap, settleDate, saOrderExtList);
-//    }
-}

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/controller/manage/BdWaresBonusController.java

@@ -19,9 +19,6 @@ import java.math.BigDecimal;
 
 /**
  * 特殊商品分配奖金 前端控制器
- *
- * @author hzs
- * @since 2024-10-30
  */
 @RestController
 @RequestMapping("/wares-bonus/special")

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

@@ -8,28 +8,17 @@ import com.hzs.common.domain.member.ext.BdWaresBonusExt;
 import java.util.List;
 
 /**
- * <p>
  * 特殊商品分配奖金 Mapper 接口
- * </p>
- *
- * @author hzs
- * @since 2024-10-30
  */
 public interface BdWaresBonusMapper extends BaseMapper<BdWaresBonus> {
 
     /*
-     * @description: 查询特殊品奖金配置
+     *  查询特殊品奖金配置
-     * @author: sui q
-     * @date: 2024/10/30 10:55
-     * @param: null null
      **/
     List<BdWaresBonusExt> querySpecialWaresBonus(BdWaresBonusParam waresBonusParam);
 
     /*
-     * @description: 查询能设置奖金的特殊品
+     *  查询能设置奖金的特殊品
-     * @author: sui q
-     * @date: 2024/11/8 10:19
-     * @param: null null
      **/
     List<BdWaresBonusExt> queryAllSpecialWaresBonus();
 }

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

@@ -8,52 +8,32 @@ import com.hzs.common.domain.member.ext.BdWaresBonusExt;
 import java.util.List;
 
 /**
- * <p>
  * 特殊商品分配奖金 服务类
- * </p>
- *
- * @author hzs
- * @since 2024-10-30
  */
 public interface IBdWaresBonusService extends IService<BdWaresBonus> {
 
     /*
-     * @description: 查询特殊品奖金配置
+     *  查询特殊品奖金配置
-     * @author: sui q 
-     * @date: 2024/10/30 10:55
-     * @param: null null
      **/
     List<BdWaresBonusExt> querySpecialWaresBonus(BdWaresBonusParam waresBonusParam);
 
     /*
-     * @description: 根据主键删除特殊商品奖金配置
+     *  根据主键删除特殊商品奖金配置
-     * @author: sui q
-     * @date: 2024/11/8 9:58
-     * @param: null null
      **/
     void deleteSpecialWaresBonus(Long pkId, Long userId);
 
     /*
-     * @description: 根据商品id查询是否已经存在数据
+     *  根据商品id查询是否已经存在数据
-     * @author: sui q
-     * @date: 2024/11/7 15:51
-     * @param: null null
      **/
     BdWaresBonus queryWaresBonusById(BdWaresBonusParam waresBonusParam);
 
     /*
-     * @description: 插入商品奖金根据参数
+     *  插入商品奖金根据参数
-     * @author: sui q
-     * @date: 2024/11/7 13:47
-     * @param: null null
      **/
     void insertOrUpdateBdWaresBonusByParam(BdWaresBonusParam bdWaresBonusParam, Long userId);
 
     /*
-     * @description: 查询能设置奖金的特殊品
+     *  查询能设置奖金的特殊品
-     * @author: sui q
-     * @date: 2024/11/8 10:19
-     * @param: null null
      **/
     List<BdWaresBonusExt> querySpecialWaresBonus();
 }

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

@@ -23,12 +23,7 @@ import java.util.Date;
 import java.util.List;
 
 /**
- * <p>
  * 特殊商品分配奖金 服务实现类
- * </p>
- *
- * @author hzs
- * @since 2024-10-30
  */
 @Service
 public class BdWaresBonusServiceImpl extends ServiceImpl<BdWaresBonusMapper, BdWaresBonus> implements IBdWaresBonusService {
@@ -58,7 +53,7 @@ public class BdWaresBonusServiceImpl extends ServiceImpl<BdWaresBonusMapper, BdW
     public BdWaresBonus queryWaresBonusById(BdWaresBonusParam waresBonusParam) {
         QueryWrapper<BdWaresBonus> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq(SystemFieldConstants.PK_WARES, waresBonusParam.getPkWares());
-        if(waresBonusParam.getPkId() != null){
+        if (waresBonusParam.getPkId() != null) {
             queryWrapper.ne(SystemFieldConstants.PK_ID, waresBonusParam.getPkId());
         }
         return baseMapper.selectOne(queryWrapper);

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

@@ -585,7 +585,7 @@ public class BonusSettleRangeHandle extends BonusSettleHandle {
                 // 批量插入会员奖衔记录
                 iCuMemberAwardsService.saveBatchCuMemberAwards(cuMemberAwardsList);
                 // 更新会员表奖衔数据
-                iCuMemberService.updateCuMemberRetailRangeByPeriod(cuMemberAwardsList, period);
+                iCuMemberService.updateCuMemberRetailRangeByPeriod(period);
             }
             if (cuMemberGradeList.size() > 0) {
                 // 批量插入会员等级记录
@@ -1777,7 +1777,9 @@ public class BonusSettleRangeHandle extends BonusSettleHandle {
                         }
                     }
                     if (secondAwardsRetailRangeList.size() > 0) {
+                        // 月度分红平均收益 = 订单总业绩 乘 分红平均比例 除 奖衔人数
                         BigDecimal benefitAvgIncome = ComputeUtil.computeDivide(ComputeUtil.computeBonusMultiply(totalMonthConsumePv, secondBenefitAvgRatio), BigDecimal.valueOf(secondAwardsRetailRangeList.size()));
+                        // 月度分红加权总收益 = 订单总业绩 乘 分红加权比例
                         BigDecimal benefitShareIncome = ComputeUtil.computeBonusMultiply(totalMonthConsumePv, secondBenefitShareRatio);
                         for (CuMemberRetailRangeExt cuMemberRetailRangeExt : secondAwardsRetailRangeList) {
                             if (ECategory.NORMAL.getValue() != cuMemberRetailRangeExt.getCategory()

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

@@ -241,7 +241,6 @@ public class CuMemberBonusServiceImpl extends ServiceImpl<CuMemberBonusMapper, C
     public void calculateBonusTotal(CuMemberBonusExt cuMemberBonusExt, CuMemberBonusExt memberBonusExt) {
         cuMemberBonusExt.setDirectIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getDirectIncome(), memberBonusExt.getDirectIncome()));
         cuMemberBonusExt.setExpandIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getExpandIncome(), memberBonusExt.getExpandIncome()));
-        cuMemberBonusExt.setCoachIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getCoachIncome(), memberBonusExt.getCoachIncome()));
         cuMemberBonusExt.setShareIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getShareIncome(), memberBonusExt.getShareIncome()));
         cuMemberBonusExt.setServiceIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getServiceIncome(), memberBonusExt.getServiceIncome()));
         cuMemberBonusExt.setBackPoints(ComputeUtil.computeAdd(cuMemberBonusExt.getBackPoints(), memberBonusExt.getBackPoints()));
@@ -258,6 +257,16 @@ public class CuMemberBonusServiceImpl extends ServiceImpl<CuMemberBonusMapper, C
         cuMemberBonusExt.setCarAwardPoints(ComputeUtil.computeAdd(cuMemberBonusExt.getCarAwardPoints(), memberBonusExt.getCarAwardPoints()));
         cuMemberBonusExt.setRealIncomeTotal(ComputeUtil.computeAdd(cuMemberBonusExt.getRealIncomeTotal(), memberBonusExt.getRealIncomeTotal()));
         cuMemberBonusExt.setStoreIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getStoreIncome(), memberBonusExt.getStoreIncome()));
+
+        cuMemberBonusExt.setRetailRangeIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getRetailRangeIncome(), memberBonusExt.getRetailRangeIncome()));
+        cuMemberBonusExt.setRetailSameLevelIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getRetailSameLevelIncome(), memberBonusExt.getRetailSameLevelIncome()));
+        cuMemberBonusExt.setRetailAreaIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getRetailAreaIncome(), memberBonusExt.getRetailAreaIncome()));
+        cuMemberBonusExt.setRetailBenefitRangeIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getRetailBenefitRangeIncome(), memberBonusExt.getRetailBenefitRangeIncome()));
+        cuMemberBonusExt.setRetailMonthRepurchaseIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getRetailMonthRepurchaseIncome(), memberBonusExt.getRetailMonthRepurchaseIncome()));
+        cuMemberBonusExt.setCoachIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getCoachIncome(), memberBonusExt.getCoachIncome()));
+        cuMemberBonusExt.setRetailBenefitAvgIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getRetailBenefitAvgIncome(), memberBonusExt.getRetailBenefitAvgIncome()));
+        cuMemberBonusExt.setRetailBenefitIncome(ComputeUtil.computeAdd(cuMemberBonusExt.getRetailBenefitIncome(), memberBonusExt.getRetailBenefitIncome()));
+        cuMemberBonusExt.setRetailRealSubtotal(ComputeUtil.computeAdd(cuMemberBonusExt.getRetailRealSubtotal(), memberBonusExt.getRetailRealSubtotal()));
     }
 
     @Override
@@ -272,7 +281,6 @@ public class CuMemberBonusServiceImpl extends ServiceImpl<CuMemberBonusMapper, C
         cuMemberBonusExt.setExpandIncome(BigDecimal.ZERO);
         cuMemberBonusExt.setExpandNoCapping(BigDecimal.ZERO);
         cuMemberBonusExt.setExpandCapping(BigDecimal.ZERO);
-        cuMemberBonusExt.setCoachIncome(BigDecimal.ZERO);
         cuMemberBonusExt.setShareIncome(BigDecimal.ZERO);
         cuMemberBonusExt.setServiceIncome(BigDecimal.ZERO);
         cuMemberBonusExt.setBackPoints(BigDecimal.ZERO);
@@ -282,22 +290,23 @@ public class CuMemberBonusServiceImpl extends ServiceImpl<CuMemberBonusMapper, C
         cuMemberBonusExt.setRepurRangeIncome(BigDecimal.ZERO);
         cuMemberBonusExt.setRepurExpandIncome(BigDecimal.ZERO);
         cuMemberBonusExt.setRepurRealSubtotal(BigDecimal.ZERO);
-        cuMemberBonusExt.setCloudDirectIncome(BigDecimal.ZERO);
-        cuMemberBonusExt.setCloudPurIncome(BigDecimal.ZERO);
-        cuMemberBonusExt.setCloudRepurIncome(BigDecimal.ZERO);
-        cuMemberBonusExt.setCloudRealSubtotal(BigDecimal.ZERO);
         cuMemberBonusExt.setRepurCoupon(BigDecimal.ZERO);
         cuMemberBonusExt.setRepurCouponShare(BigDecimal.ZERO);
         cuMemberBonusExt.setRepurCouponSubtotal(BigDecimal.ZERO);
-        cuMemberBonusExt.setMakerDirectIncome(BigDecimal.ZERO);
-        cuMemberBonusExt.setMakerShareIncome(BigDecimal.ZERO);
-        cuMemberBonusExt.setMakerRealSubtotal(BigDecimal.ZERO);
         cuMemberBonusExt.setStoreIncome(BigDecimal.ZERO);
         cuMemberBonusExt.setGlobalPoints(BigDecimal.ZERO);
         cuMemberBonusExt.setCarAwardPoints(BigDecimal.ZERO);
-        cuMemberBonusExt.setHiFunIncome(BigDecimal.ZERO);
-        cuMemberBonusExt.setHaiFunIncome(BigDecimal.ZERO);
         cuMemberBonusExt.setRealIncomeTotal(BigDecimal.ZERO);
+
+        cuMemberBonusExt.setRetailRangeIncome(BigDecimal.ZERO);
+        cuMemberBonusExt.setRetailSameLevelIncome(BigDecimal.ZERO);
+        cuMemberBonusExt.setRetailAreaIncome(BigDecimal.ZERO);
+        cuMemberBonusExt.setRetailBenefitRangeIncome(BigDecimal.ZERO);
+        cuMemberBonusExt.setRetailMonthRepurchaseIncome(BigDecimal.ZERO);
+        cuMemberBonusExt.setCoachIncome(BigDecimal.ZERO);
+        cuMemberBonusExt.setRetailBenefitAvgIncome(BigDecimal.ZERO);
+        cuMemberBonusExt.setRetailBenefitIncome(BigDecimal.ZERO);
+        cuMemberBonusExt.setRetailRealSubtotal(BigDecimal.ZERO);
         return cuMemberBonusExt;
     }
 
@@ -456,8 +465,8 @@ public class CuMemberBonusServiceImpl extends ServiceImpl<CuMemberBonusMapper, C
                 MemberBonusDetailSerVO memberBonusDetailVO = BeanUtil.copyProperties(cuMemberBonusExpand, MemberBonusDetailSerVO.class);
                 memberBonusDetailSerVoS.add(memberBonusDetailVO);
             });
-        } else if (EBonusItems.COACHING_INCOME.getValue() == bonusItemsValue) {
+        } else if (EBonusItems.RETAIL_COACHING_INCOME.getValue() == bonusItemsValue) {
-            // 辅导收益
+            // 培育津贴
             List<CuMemberBonusCoachExt> cuMemberBonusCoachList = cuMemberBonusCoachMapper.queryMemberBonusCoachByBonusItemsForServer(bonusParam);
             dataTable = getDataTable(cuMemberBonusCoachList);
             cuMemberBonusCoachList.forEach(cuMemberBonusCoach -> {

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/vo/BonusTotalVO.java

@@ -69,6 +69,12 @@ public class BonusTotalVO implements Serializable {
     @Excel(name = "复购级差收益", scale = 2)
     private BigDecimal retailMonthRepurchaseIncome;
 
+    /**
+     * 培育津贴
+     */
+    @Excel(name = "培育津贴", scale = 2)
+    private BigDecimal coachIncome;
+
     /**
      * 福利分红平均收益
      */
@@ -233,10 +239,6 @@ public class BonusTotalVO implements Serializable {
      */
     private BigDecimal expandCapping;
 
-    /**
-     * 辅导收益
-     */
-    private BigDecimal coachIncome;
 
     /**
      * 分红收益

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/vo/CuMemberBonusVO.java

@@ -91,7 +91,7 @@ public class CuMemberBonusVO implements Serializable {
      */
     public static final String[] INCOME_ARRAY = new String[]{
             "backPoints", "retailRangeIncome", "retailSameLevelIncome", "retailAreaIncome",
-            "retailBenefitRangeIncome", "retailMonthRepurchaseIncome", "retailBenefitAvgIncome",
+            "retailBenefitRangeIncome", "retailMonthRepurchaseIncome", "coachIncome", "retailBenefitAvgIncome",
             "retailBenefitIncome", "retailRealSubtotal", "realIncomeTotal"};
 
 
@@ -130,6 +130,13 @@ public class CuMemberBonusVO implements Serializable {
     @Excel(name = "复购级差收益", scale = 2)
     private BigDecimal retailMonthRepurchaseIncomeOri;
 
+    /**
+     * 培育津贴
+     */
+    private BigDecimal coachIncome;
+    @Excel(name = "培育津贴", scale = 2)
+    private BigDecimal coachIncomeOri;
+
     /**
      * 新零售福利平均收益
      */
@@ -160,7 +167,7 @@ public class CuMemberBonusVO implements Serializable {
      */
     private BigDecimal retailRealSubtotal;
 
-    @Excel(name = "收益小计", scale = 2)
+//    @Excel(name = "收益小计", scale = 2)
     private BigDecimal retailRealSubtotalOri;
 
     /**

bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/vo/MemberBonusFirstPurchaseVO.java

@@ -26,11 +26,6 @@ public class MemberBonusFirstPurchaseVO extends PubMemberBonusVO {
 //    private BigDecimal expandIncome;
 //
 //    /**
-//     * 辅导收益
-//     */
-//    private BigDecimal coachIncome;
-//
-//    /**
 //     * 分红收益
 //     */
 //    private BigDecimal shareIncome;
@@ -107,6 +102,12 @@ public class MemberBonusFirstPurchaseVO extends PubMemberBonusVO {
     @BigDecimalFormat
     private BigDecimal retailMonthRepurchaseIncome;
 
+    /**
+     * 培育津贴
+     */
+    @BigDecimalFormat
+    private BigDecimal coachIncome;
+
     /**
      * 福利分红收益总计
      */

bd-business/bd-business-bonus/src/main/resources/mapper/bonus/account/CuMemberAccountMapper.xml

@@ -69,564 +69,6 @@
         <result column="PK_COUNTRY" property="pkCountry"/>
     </resultMap>
 
-    <select id="queryMemberAccountByCondition" resultMap="AccountExResultMap">
-        select cm.pay_pwd,
-        cm.account_status,
-        ca.pk_member,
-        ca.account1,
-        ca.lock_account1,
-        ca.account2,
-        ca.lock_account2,
-        ca.lock_account3,
-        ca.account3,
-        ca.lock_account4,
-        ca.account4,
-        ca.consume_account4,
-        ca.withdraw_account4,
-        ca.lock_account4,
-        ca.account5,
-        ca.lock_account5,
-        ca.account6,
-        ca.lock_account6,
-        ca.account7,
-        ca.lock_account7,
-        ca.account8,
-        ca.lock_account8,
-        ca.account9,
-        ca.account10,
-        ca.account11,
-        ca.account12,
-        ca.account13,
-        ca.lock_account13,
-        ca.is_transfer,
-        ca.is_withdraw,
-        ca.is_consume,
-        cm.pk_settle_country pk_country
-        from cu_member cm
-        inner join cu_member_account ca
-        on cm.pk_id = ca.pk_member
-        where cm.del_flag=0 and ca.del_flag=0
-        and cm.category =0
-        and cm.pk_settle_country=#{pkCountry}
-        <if test="pkMember != null and pkMember != ''">
-            and ca.pk_member = #{pkMember}
-        </if>
-    </select>
-
-
-    <!-- 根据会员编码获取会员账户余额 -->
-    <select id="selectBalanceByMemberCode" resultType="decimal">
-        SELECT CASE
-                   WHEN 1 = #{accountType} then account1
-                   WHEN 2 = #{accountType} then account2
-                   WHEN 3 = #{accountType} then account3
-                   WHEN 4 = #{accountType} then account4
-                   WHEN 5 = #{accountType} then account5
-                   WHEN 6 = #{accountType} then account6
-                   WHEN 7 = #{accountType} then account7
-                   WHEN 8 = #{accountType} then account8
-                   WHEN 9 = #{accountType} then account9
-                   WHEN 10 = #{accountType} then account10
-                   WHEN 11 = #{accountType} then account11
-                   WHEN 12 = #{accountType} then account12
-                   WHEN 13 = #{accountType} then account13
-                   WHEN 14 = #{accountType} then account14
-                   WHEN 15 = #{accountType} then account15
-                   WHEN 16 = #{accountType} then account16
-                   WHEN 17 = #{accountType} then account17
-                   WHEN 18 = #{accountType} then account18
-                   WHEN 19 = #{accountType} then account19
-                   WHEN 20 = #{accountType} then account20
-                   END balance
-        FROM CU_MEMBER_ACCOUNT
-        WHERE pk_member = #{pkMember}
-    </select>
-
-
-    <update id="updateMemberAccount">
-        UPDATE CU_MEMBER_ACCOUNT
-        SET
-        <if test="account1 != null">
-            account1 = account1 + #{account1},
-        </if>
-        <if test="account2 != null">
-            account2 = account2 + #{account2},
-        </if>
-        <if test="account3 != null">
-            account3 = account3 + #{account3},
-        </if>
-        <if test="account4 != null">
-            account4 = account4 + #{account4},
-        </if>
-        <if test="account5 != null">
-            account5 = account5 + #{account5},
-        </if>
-        <if test="account6 != null">
-            account6 = account6 + #{account6},
-        </if>
-        <if test="account7 != null">
-            account7 = account7 + #{account7},
-        </if>
-        <if test="account8 != null">
-            account8 = account8 + #{account8},
-        </if>
-        <if test="account9 != null">
-            account9 = account9 + #{account9},
-        </if>
-        <if test="account10 != null">
-            account10 = account10 + #{account10},
-        </if>
-        <if test="account11 != null">
-            account11 = account11 + #{account11},
-        </if>
-        <if test="account12 != null">
-            account12 = account12 + #{account12},
-        </if>
-        <if test="account13 != null">
-            account13 = account13 + #{account13},
-        </if>
-        <if test="account14 != null">
-            account14 = account14 + #{account14},
-        </if>
-        <if test="account15 != null">
-            account15 = account15 + #{account15},
-        </if>
-        <if test="account16 != null">
-            account16 = account16 + #{account16},
-        </if>
-        <if test="account17 != null">
-            account17 = account17 + #{account17},
-        </if>
-        <if test="account18 != null">
-            account18 = account18 + #{account18},
-        </if>
-        <if test="account19 != null">
-            account19 = account19 + #{account19},
-        </if>
-        <if test="account20 != null">
-            account20 = account20 + #{account20},
-        </if>
-        <if test="lockAccount1 != null">
-            lock_account1 = #{lockAccount1},
-        </if>
-        <if test="lockAccount2 != null">
-            lock_account2 = #{lockAccount2},
-        </if>
-        <if test="lockAccount4 != null">
-            lock_account4 = #{lockAccount4},
-        </if>
-        <if test="withdrawAccount4 != null">
-            withdraw_account4 = withdraw_account4 + #{withdrawAccount4},
-        </if>
-        <if test="consumeAccount4 != null">
-            consume_account4 = consume_account4 + #{consumeAccount4},
-        </if>
-        <if test="lockAccount13 != null">
-            lock_account13 = #{lockAccount13},
-        </if>
-        pk_modified = #{pkModified},
-        modified_time = sysdate
-        WHERE pk_member = #{pkMember} and pk_country = #{pkCountry} and del_flag=0
-    </update>
-
-    <select id="queryMemberAccountByPkCountry" resultType="com.hzs.common.domain.member.ext.CuMemberAccountExt">
-        select a.*, b.pk_id pkBank
-        from cu_member_account a,
-             cu_member_bank b
-        where a.pk_member = b.pk_member
-          and a.del_flag = 0
-          and b.del_flag = 0
-          and b.default_card = 1
-          and a.is_withdraw = 0
-          and a.pk_country = #{pkCountry}
-    </select>
-
-    <update id="updateBatchMemberAccountByPkmember">
-        MERGE INTO cu_member_account m
-            USING (select *
-                   from (select a.field_value,
-                                r.recharge_amount,
-                                pk_member,
-                                r.recharge_method
-                         from cu_member_recharge r
-                                  left join bd_account a
-                                            on r.pk_account = a.pk_id
-                         where r.del_flag = 0
-                           and r.batch = #{batch}) tt pivot(sum(recharge_amount)
-        for field_value in('1' as account1,
-        '2' as account2,
-        '3' as account3,
-        '4' as account4,
-        '5' as account5,
-        '6' as account6,
-        '7' as account7,
-        '8' as account8,
-        '9' as account9,
-        '10' as account10,
-        '12' as account12,
-        '13' as account13))) t
-            ON (m.pk_member = t.pk_member)
-            WHEN MATCHED THEN
-                update
-                    set m.account1 = NVL(t.account1, 0) + m.account1,
-                        m.account2 = NVL(t.account2, 0) + m.account2,
-                        m.account3 = NVL(t.account3, 0) + m.account3,
-                        m.account4 = NVL(t.account4, 0) + m.account4,
-                        m.WITHDRAW_ACCOUNT4 = case
-                                                  when NVL(t.account4, 0) &lt; 0 and m.WITHDRAW_ACCOUNT4 + NVL(t.account4, 0) >= 0 then
-                                                      NVL(t.account4, 0) + m.WITHDRAW_ACCOUNT4
-                                                  when NVL(t.account4, 0) &lt; 0 and m.WITHDRAW_ACCOUNT4 + NVL(t.account4, 0) &lt; 0 then
-                                                      0
-                                                  else
-                                                      m.WITHDRAW_ACCOUNT4
-                            end,
-                        m.CONSUME_ACCOUNT4 = case
-                                                 when NVL(t.account4, 0) &lt; 0 and m.WITHDRAW_ACCOUNT4 + NVL(t.account4, 0) &lt; 0 then
-                                                     m.WITHDRAW_ACCOUNT4 + t.account4 + m.CONSUME_ACCOUNT4
-                                                 else
-                                                     NVL(t.account4, 0) + m.CONSUME_ACCOUNT4
-                            end,
-                        m.account5 = NVL(t.account5, 0) + m.account5,
-                        m.account6 = NVL(t.account6, 0) + m.account6,
-                        m.account7 = NVL(t.account7, 0) + m.account7,
-                        m.account8 = NVL(t.account8, 0) + m.account8,
-                        m.account9 = NVL(t.account9, 0) + m.account9,
-                        m.account10 = NVL(t.account10, 0) + m.account10,
-                        m.account12 = NVL(t.account12, 0) + m.account12,
-                        m.account13 = NVL(t.account13, 0) + m.account13,
-                        m.MODIFIED_TIME = sysdate,
-                        m.PK_MODIFIED = #{pkModified}
-    </update>
-
-
-    <select id="queryMemberAccountAllByMemberCodes" resultType="com.hzs.common.domain.member.ext.CuMemberAccountExt">
-        select m.member_code memberCode,
-        m.member_name memberName,
-        a.*
-        from cu_member_account a, cu_member m
-        where a.pk_member = m.pk_id
-        and a.del_flag = 0
-        and m.del_flag = 0
-        <if test="memberCodes != null and memberCodes.size >0">
-            and m.member_code in
-            <foreach collection="memberCodes" item="item" open="(" close=")" separator=",">
-                #{item}
-            </foreach>
-        </if>
-    </select>
-
-    <sql id="select_base">
-        with t1 as
-        (select u.member_code,
-        u.member_name,
-        u.pk_id,
-        u.pk_vertex vertex_id,
-        u.pk_team_code team_id,
-        v.vertex_name,
-        v.pk_member,
-        u.pk_place_parent,
-        u.pk_parent,
-        t.team_name
-        from cu_member u
-        left join bd_vertex v
-        on u.pk_vertex = v.pk_id
-        and v.del_flag = 0
-        left join cu_member_team t
-        on u.pk_team_code = t.pk_id
-        and t.del_flag = 0
-        where u.del_flag = 0
-        and u.pk_settle_country = #{pkCountry})
-        select ss.memberCode,
-        ss.memberName,
-        ss.pk_id pkId,
-        ss.vertexId,
-        ss.teamId,
-        ss.vertexName,
-        ss.pk_member,
-        ss.pk_place_parent,
-        ss.pk_parent,
-        ss.teamName,
-        ss.slevel,
-        pp.plevel,
-        account1,
-        lock_account1,
-        lock_transfer_account1,
-        account2,
-        lock_account2,
-        lock_transfer_account2,
-        account3,
-        lock_account3,
-        lock_transfer_account3,
-        account4,
-        lock_account4,
-        lock_transfer_account4,
-        lock_withdraw_account4,
-        withdraw_account4,
-        consume_account4,
-        account5,
-        lock_account5,
-        lock_transfer_account5,
-        account6,
-        lock_account6,
-        lock_transfer_account6,
-        account7,
-        lock_account7,
-        lock_transfer_account7,
-        account8,
-        lock_account8,
-        lock_transfer_account8,
-        account9,
-        lock_account9,
-        lock_transfer_account9,
-        account10,
-        lock_account10,
-        account11,
-        lock_transfer_account10,
-        account12,
-        account13,
-        lock_account13
-        from (select member_code memberCode,
-        member_name memberName,
-        pk_id,
-        vertex_id vertexId,
-        team_id teamId,
-        vertex_name vertexName,
-        pk_member,
-        pk_place_parent,
-        pk_parent,
-        team_name teamName,
-        level slevel
-        from t1
-        <include refid="list_place_where"></include>
-        start with pk_id =
-        <if test="memberCode != null and memberCode != ''">
-            (select cm.pk_id
-            from cu_member cm
-            where cm.member_code = #{memberCode})
-        </if>
-        <if test="memberCode == null or memberCode == ''">
-            pk_member
-        </if>
-        connect by prior pk_id = pk_place_parent) ss,
-        (select pk_id, level plevel
-        from t1
-        <include refid="list_rem_where"></include>
-        start with pk_id =
-        <if test="memberCode != null and memberCode != ''">
-            (select cm.pk_id
-            from cu_member cm
-            where cm.member_code = #{memberCode})
-        </if>
-        <if test="memberCode == null or memberCode == ''">
-            pk_member
-        </if>
-        connect by prior pk_id = pk_parent) pp,
-        cu_member_account a
-    </sql>
-
-    <!--  安置条件  -->
-    <sql id="list_place_where">
-        <where>
-            1=1
-            <if test="memberName != null and memberName != ''">
-                and member_name like #{memberName} || '%'
-            </if>
-            <if test="vertexName != null and vertexName != ''">
-                and vertex_name like #{memberName} || '%'
-            </if>
-            <if test="teamName != null and teamName != ''">
-                and team_name like #{teamName} || '%'
-            </if>
-            <if test="teamId != null">
-                and team_id = #{teamId}
-            </if>
-            <if test="vertexId != null">
-                and vertex_id = #{vertexId}
-            </if>
-            <if test="slevel != null">
-                and level &lt;= #{slevel}
-            </if>
-        </where>
-    </sql>
-
-    <!--  推荐条件  -->
-    <sql id="list_rem_where">
-        <where>
-            1=1
-            <if test="memberName != null and memberName != ''">
-                and member_name like #{memberName} || '%'
-            </if>
-            <if test="vertexName != null and vertexName != ''">
-                and vertex_name like #{memberName} || '%'
-            </if>
-            <if test="teamName != null and teamName != ''">
-                and team_name like #{teamName} || '%'
-            </if>
-            <if test="teamId != null">
-                and team_id = #{teamId}
-            </if>
-            <if test="vertexId != null">
-                and vertex_id = #{vertexId}
-            </if>
-
-            <if test="plevel != null">
-                and level &lt;= #{plevel}
-            </if>
-        </where>
-    </sql>
-
-    <sql id="list_where">
-        <where>
-            ss.pk_id = pp.pk_id
-            and ss.pk_id = a.pk_member
-            and a.del_flag = 0
-            and a.pk_country = #{pkCountry}
-        </where>
-    </sql>
-
-
-    <sql id="ids_where">
-        <where>
-            ss.pk_id = pp.pk_id
-            and ss.pk_id = a.pk_member
-            and a.del_flag = 0
-            and a.pk_country = #{pkCountry}
-            and ss.pk_id in
-            <foreach collection="pkIds" item="item" open="(" close=")" separator=",">
-                #{item}
-            </foreach>
-        </where>
-    </sql>
-
-
-    <select id="selectPkMembersByMemberCode" resultType="java.lang.Long">
-        select a.pk_member
-        from cu_member_account a, cu_member c
-        where a.pk_member = c.pk_id
-        and c.del_flag = 0
-        and c.account_status = 0
-        and a.del_flag = 0
-        and c.pk_settle_country= #{pkCountry}
-        and c.member_code in
-        <foreach collection="memberCodes" item="item" open="(" close=")" separator=",">
-            #{item}
-        </foreach>
-    </select>
-
-
-    <update id="updateFrozenAmountInfo">
-        update cu_member_account a
-        set
-        <if test="lockAccount1 != null">
-            a.lock_account1 = #{lockAccount1},
-        </if>
-        <if test="lockTransferAccount1 != null">
-            a.lock_transfer_account1 = #{lockTransferAccount1},
-        </if>
-        <if test="account1Remarks != null and account1Remarks != ''">
-            a.account1_remarks = #{account1Remarks},
-        </if>
-
-        <if test="lockAccount2 != null">
-            a.lock_account2 = #{lockAccount2},
-        </if>
-        <if test="lockTransferAccount2 != null">
-            a.lock_transfer_account2 = #{lockTransferAccount2},
-        </if>
-        <if test="account2Remarks != null and account2Remarks != ''">
-            a.account2_remarks = #{account2Remarks},
-        </if>
-
-        <if test="lockAccount3 != null">
-            a.lock_account3 = #{lockAccount3},
-        </if>
-        <if test="lockTransferAccount3 != null">
-            a.lock_transfer_account3 = #{lockTransferAccount3},
-        </if>
-        <if test="account3Remarks != null and account3Remarks != ''">
-            a.account3_remarks = #{account3Remarks},
-        </if>
-
-        <if test="lockAccount4 != null">
-            a.lock_account4 = #{lockAccount4},
-        </if>
-        <if test="lockTransferAccount4 != null">
-            a.lock_transfer_account4 = #{lockTransferAccount4},
-        </if>
-        <if test="lockWithdrawAccount4 != null">
-            a.lock_withdraw_account4 = #{lockWithdrawAccount4},
-        </if>
-        <if test="account4Remarks != null and account4Remarks != ''">
-            a.account4_remarks = #{account4Remarks},
-        </if>
-
-        <if test="lockAccount5 != null">
-            a.lock_account5 = #{lockAccount5},
-        </if>
-        <if test="lockTransferAccount5 != null">
-            a.lock_transfer_account5 = #{lockTransferAccount5},
-        </if>
-        <if test="account5Remarks != null and account5Remarks != ''">
-            a.account5_remarks = #{account5Remarks},
-        </if>
-
-        <if test="lockAccount6 != null">
-            a.lock_account6 = #{lockAccount6},
-        </if>
-        <if test="lockTransferAccount6 != null">
-            a.lock_transfer_account6 = #{lockTransferAccount6},
-        </if>
-        <if test="account6Remarks != null and account6Remarks != ''">
-            a.account6_remarks = #{account6Remarks},
-        </if>
-
-        <if test="lockAccount7 != null">
-            a.lock_account7 = #{lockAccount7},
-        </if>
-        <if test="lockTransferAccount7 != null">
-            a.lock_transfer_account7 = #{lockTransferAccount7},
-        </if>
-        <if test="account7Remarks != null and account7Remarks != ''">
-            a.account7_remarks = #{account7Remarks},
-        </if>
-
-        <if test="lockAccount8 != null">
-            a.lock_account8 = #{lockAccount8},
-        </if>
-        <if test="lockTransferAccount8 != null">
-            a.lock_transfer_account8 = #{lockTransferAccount8},
-        </if>
-        <if test="account8Remarks != null and account8Remarks != ''">
-            a.account8_remarks = #{account8Remarks},
-        </if>
-
-        <if test="lockAccount9 != null">
-            a.lock_account9 = #{lockAccount9},
-        </if>
-        <if test="lockTransferAccount9 != null">
-            a.lock_transfer_account9 = #{lockTransferAccount9},
-        </if>
-        <if test="account9Remarks != null and account9Remarks != ''">
-            a.account9_remarks = #{account9Remarks},
-        </if>
-
-        <if test="lockAccount10 != null">
-            a.lock_account10 = #{lockAccount10},
-        </if>
-        <if test="lockTransferAccount10 != null">
-            a.lock_transfer_account10 = #{lockTransferAccount10},
-        </if>
-        <if test="account10Remarks != null and account10Remarks != ''">
-            a.account10_remarks = #{account10Remarks},
-        </if>
-        a.pk_modified = #{pkModified},
-        a.modified_time = sysdate
-        WHERE a.pk_member in
-        <foreach collection="pkMembers" item="item" open="(" close=")" separator=",">
-            #{item}
-        </foreach>
-    </update>
-
     <update id="updateMemberAccountGrantByPeriod">
         merge into cu_member_account a
             using (select pk_member,
@@ -651,6 +93,7 @@
                     a.account5 = a.account5 + b.account5,
                     a.account8 = a.account8 + b.account8
     </update>
+
     <update id="updateMemberAccountWithdrawalByPeriod">
         merge into cu_member_account a
             using (
@@ -675,44 +118,4 @@
                     a.consume_account4 = a.consume_account4 - b.consume_money
     </update>
 
-    <select id="selectMemberBonusAccountBySourceCode" resultMap="AccountExResultMap">
-        select r.pk_member, ma.account4, ma.withdraw_account4, ma.consume_account4, ma.pk_modified, ma.pk_country
-        from cu_member_recharge r
-                 left join cu_member_account ma
-                           on r.pk_member = ma.pk_member
-                               and ma.del_flag = 0
-                 left join bd_account a
-                           on r.pk_account = a.pk_id
-                               and a.del_flag = 0
-        where r.del_flag = 0
-          and a.field_value = 4
-          and r.batch = #{sourceCode}
-    </select>
-    <select id="selectMemberAccountByPkMember" resultType="com.hzs.common.domain.member.account.CuMemberAccount">
-        select a.pk_member,
-        a.account1,
-        a.account2,
-        a.account3,
-        a.account4,
-        a.account5,
-        a.account6,
-        a.account7,
-        a.account8,
-        a.account9,
-        a.account10,
-        a.account11,
-        a.account12,
-        a.account13,
-        a.account14,
-        a.account15
-        from cu_member_account a
-        where a.del_flag = 0
-        <if test="pkMembers != null and pkMembers.size >0">
-            and a.pk_member in
-            <foreach collection="pkMembers" item="item" open="(" close=")" separator=",">
-                #{item}
-            </foreach>
-        </if>
-    </select>
-
 </mapper>

bd-business/bd-business-bonus/src/main/resources/mapper/bonus/account/CuMemberTradeDetailMapper.xml

@@ -4,21 +4,22 @@
 
     <!-- 通用查询映射结果 -->
     <resultMap id="CuMemberTradeDetail" type="com.hzs.common.domain.member.account.CuMemberTradeDetail">
-        <id column="PK_ID" property="pkId" />
+        <id column="PK_ID" property="pkId"/>
-        <result column="DEL_FLAG" property="delFlag" />
+        <result column="DEL_FLAG" property="delFlag"/>
-        <result column="PK_COUNTRY" property="pkCountry" />
+        <result column="PK_COUNTRY" property="pkCountry"/>
-        <result column="CREATION_TIME" property="creationTime" />
+        <result column="CREATION_TIME" property="creationTime"/>
-        <result column="MODIFIED_TIME" property="modifiedTime" />
+        <result column="MODIFIED_TIME" property="modifiedTime"/>
-        <result column="PK_CREATOR" property="pkCreator" />
+        <result column="PK_CREATOR" property="pkCreator"/>
-        <result column="PK_MODIFIED" property="pkModified" />
+        <result column="PK_MODIFIED" property="pkModified"/>
-        <result column="PERIOD" property="period" />
+        <result column="PERIOD" property="period"/>
-        <result column="PK_MEMBER_TRADE" property="pkMemberTrade" />
+        <result column="PK_MEMBER_TRADE" property="pkMemberTrade"/>
-        <result column="GRANT_MONEY" property="grantMoney" />
+        <result column="GRANT_MONEY" property="grantMoney"/>
-        <result column="CONSUME_MONEY" property="consumeMoney" />
+        <result column="CONSUME_MONEY" property="consumeMoney"/>
     </resultMap>
+
     <insert id="batchInsertCuMemberTradeDetail">
         insert ALL
-        <foreach item="item" index="index" collection="cuMemberTradeDetailList" separator=" " >
+        <foreach item="item" index="index" collection="cuMemberTradeDetailList" separator=" ">
             into CU_MEMBER_TRADE_DETAIL(period,pk_member_trade,consume_money,pk_country,creation_time,pk_creator) values
             (
             #{item.period},#{item.pkMemberTrade},#{item.consumeMoney,jdbcType=NUMERIC},#{item.pkCountry},
@@ -27,89 +28,23 @@
         </foreach>
         SELECT 1 FROM dual
     </insert>
+
     <update id="updateCuMemberTradeDetailByPeriod">
         merge into cu_member_trade_detail a
             using (
-        select cd.pk_id,cd.consume_money from cu_member_trade ct
+                select cd.pk_id, cd.consume_money
+                from cu_member_trade ct
                          inner join cu_member_trade_detail cd
                                     on cd.pk_member_trade = ct.pk_id
-        where cd.del_flag=0 and ct.del_flag=0 and cd.trade_statue=1
+                where cd.del_flag = 0
-        and cd.period between #{startPeriod} and #{endPeriod} and ct.pk_country = #{pkCountry}
+                  and ct.del_flag = 0
-        )b
+                  and cd.trade_statue = 1
-        on (a.pk_id = b.pk_id)
+                  and cd.period between #{startPeriod} and #{endPeriod}
-        when matched then
+                  and ct.pk_country = #{pkCountry}
-        update set a.consume_money = 0,modified_time=sysdate
-    </update>
-    <update id="updateCuMemberTradeDetail">
-        merge into cu_member_trade_detail a
-        using (
-        <foreach collection="cuMemberTradeDetailList" item="item" open=" " separator=" union all " close=" ">
-            select #{item.pkId} pk_id,#{item.grantMoney,jdbcType=NUMERIC} grant_money,#{item.consumeMoney,jdbcType=NUMERIC} consume_money from dual
-        </foreach>
             ) b
             on (a.pk_id = b.pk_id)
             when matched then
-        update set a.grant_money = b.grant_money,
+                update set a.consume_money = 0,modified_time = sysdate
-            a.consume_money = b.consume_money
     </update>
 
-    <update id="updateAddCuMemberTradeDetail">
-        merge into cu_member_trade_detail a
-        using (
-        <foreach collection="cuMemberTradeDetailList" item="item" open=" " separator=" union all " close=" ">
-            select #{item.pkId} pk_id,#{item.grantMoney,jdbcType=NUMERIC} grant_money,#{item.consumeMoney,jdbcType=NUMERIC} consume_money from dual
-        </foreach>
-        ) b
-        on (a.pk_id = b.pk_id)
-        when matched then
-        update set a.grant_money = a.grant_money + b.grant_money,
-        a.consume_money = a.consume_money + b.consume_money
-    </update>
-
-
-
-    <update id="batchInsertMemberTradeDetailFromTrade">
-        merge into cu_member_trade_detail d
-        using (select t.pk_id, t.trade_amount, t.pk_country, t.pk_creator
-                 from cu_member_trade t
-                 left join bd_account a
-                   on t.pk_account = a.pk_id
-                  and a.del_flag = 0
-                where t.del_flag = 0
-                  and a.field_value = 4
-                  and t.trade_amount > 0
-                  and t.source_code = #{sourceCode}) tt
-        on (1 = 0)
-        when not matched then
-          insert
-            (d.period,
-             d.pk_member_trade,
-             d.consume_money,
-             d.pk_country,
-             d.pk_creator)
-          values
-            (#{period},tt.pk_id, tt.trade_amount, tt.pk_country, tt.pk_creator)
-    </update>
-
-    <select id="selectMemberTradeDetailByPkMember" resultMap="CuMemberTradeDetail">
-        select d.pk_id, d.period, d.consume_money,d.pk_country
-          from cu_member_trade t
-         inner join cu_member_trade_detail d
-            on t.pk_id = d.pk_member_trade
-           and d.del_flag = 0
-         where t.del_flag = 0
-           and t.pk_member = #{pkMember}
-           and d.consume_money > 0
-         order by d.creation_time
-    </select>
-    <select id="queryCuMemberTradeDetail" resultMap="CuMemberTradeDetail">
-        SELECT cd.* FROM CU_MEMBER_TRADE_DETAIL cd
-        inner join CU_MEMBER_TRADE cb
-        on cd.pk_member_trade = cb.pk_id
-        WHERE  cb.DEL_FLAG=0 and cb.del_flag=0
-        and cb.pk_member=#{pkMember}
-        and CONSUME_MONEY >0
-        order by period
-    </select>
-
 </mapper>

bd-business/bd-business-bonus/src/main/resources/mapper/bonus/account/CuMemberTradeMapper.xml

@@ -25,62 +25,6 @@
         <result column="REMARKS" property="remarks"/>
     </resultMap>
 
-    <sql id="select_base">
-        select t.*, m.member_code as memberCode, m.member_name as memberName
-        from cu_member_trade t
-                 left join cu_member m
-                           on t.pk_member = m.pk_id
-    </sql>
-
-    <sql id="ids_where">
-        <where>
-            t.del_flag='0'
-            and t.pk_id in
-            <foreach collection="pkIds" item="item" open="(" close=")" separator=",">
-                #{item}
-            </foreach>
-        </where>
-    </sql>
-
-    <sql id="list_where">
-        <where>
-            t.del_flag='0'
-            <if test="memberName != null and memberName != ''">
-                and m.member_name like #{memberName} || '%'
-            </if>
-            <if test="memberCode != null and memberCode != ''">
-                and m.member_code like #{memberCode} || '%'
-            </if>
-            <if test="tradeAmount != null">
-                and t.TRADE_AMOUNT = #{tradeAmount}
-            </if>
-            <if test="remarks != null and remarks != ''">
-                and m.REMARKS like #{remarks} || '%'
-            </if>
-            <if test="pkAccount != null">
-                and t.PK_ACCOUNT = #{pkAccount}
-            </if>
-            <if test="tradeType != null">
-                and t.TRADE_TYPE = #{tradeType}
-            </if>
-            <if test="sourceCode != null and sourceCode != ''">
-                and t.SOURCE_CODE = #{sourceCode}
-            </if>
-            <if test="pkCountry != null">
-                and t.pk_country = #{pkCountry}
-            </if>
-            <if test="tradeClassify != null">
-                and t.TRADE_CLASSIFY = #{tradeClassify}
-            </if>
-            <if test="startDate != null and startDate != ''">
-                and t.CREATION_TIME >= to_date(#{startDate}, 'yyyy-mm-dd')
-            </if>
-            <if test="endDate != null and endDate != ''">
-                and t.CREATION_TIME &lt;= to_date(#{endDate} || ' 23:59:59', 'yyyy-mm-dd hh24:mi:ss')
-            </if>
-        </where>
-    </sql>
-
     <update id="batchInsertCuMemberTrade">
         merge into cu_member_trade a
         using (

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

@@ -106,6 +106,23 @@
         a.modified_time = sysdate
     </update>
 
+    <update id="updateCuMemberMaxAwardsByPeriod">
+        merge into cu_member a
+            using (select c1.*
+                   from (select pk_member, max(new_level) pk_awards
+                         from cu_member_awards
+                         where period = #{period}
+                           and award_type = #{awardType}
+                           and del_flag = 0
+                         group by pk_member) c1
+                            inner join cu_member c2
+                                       on c1.pk_member = c2.pk_id
+                                           and c1.pk_awards > c2.pk_max_awards) b
+            on (a.pk_id = b.pk_member)
+            when matched then
+                update set a.pk_max_awards = b.pk_awards, a.modified_time = sysdate
+    </update>
+
     <update id="updateCuMemberGrade">
         merge into cu_member a
             using (

bd-business/bd-business-bonus/src/main/resources/mapper/bonus/bonus/BdWaresBonusMapper.xml

@@ -4,22 +4,23 @@
 
     <!-- 通用查询映射结果 -->
     <resultMap id="BdWaresBonusExt" type="com.hzs.common.domain.member.ext.BdWaresBonusExt">
-        <id column="PK_ID" property="pkId" />
+        <id column="PK_ID" property="pkId"/>
-        <result column="DEL_FLAG" property="delFlag" />
+        <result column="DEL_FLAG" property="delFlag"/>
-        <result column="PK_COUNTRY" property="pkCountry" />
+        <result column="PK_COUNTRY" property="pkCountry"/>
-        <result column="CREATION_TIME" property="creationTime" />
+        <result column="CREATION_TIME" property="creationTime"/>
-        <result column="MODIFIED_TIME" property="modifiedTime" />
+        <result column="MODIFIED_TIME" property="modifiedTime"/>
-        <result column="PK_CREATOR" property="pkCreator" />
+        <result column="PK_CREATOR" property="pkCreator"/>
-        <result column="PK_MODIFIED" property="pkModified" />
+        <result column="PK_MODIFIED" property="pkModified"/>
-        <result column="PK_WARES" property="pkWares" />
+        <result column="PK_WARES" property="pkWares"/>
-        <result column="ORDER_ASS_ACHIEVE" property="orderAssAchieve" />
+        <result column="ORDER_ASS_ACHIEVE" property="orderAssAchieve"/>
-        <result column="TOTAL_ALGEBRA" property="totalAlgebra" />
+        <result column="TOTAL_ALGEBRA" property="totalAlgebra"/>
         <collection property="bdWaresBonusItemsList" ofType="com.hzs.common.domain.member.bonus.BdWaresBonusItems">
-            <result column="PK_ID_ITEM" property="pkId" />
+            <result column="PK_ID_ITEM" property="pkId"/>
-            <result column="ASS_ACHIEVE" property="assAchieve" />
+            <result column="ASS_ACHIEVE" property="assAchieve"/>
-            <result column="ALGEBRA" property="algebra" />
+            <result column="ALGEBRA" property="algebra"/>
         </collection>
     </resultMap>
+
     <select id="querySpecialWaresBonus" resultMap="BdWaresBonusExt">
         select bw.*,ba.wares_code,ba.wares_name,bt.pk_id pk_id_item,bt.ass_achieve,bt.algebra from bd_wares_bonus bw
         inner join bd_wares_bonus_items bt
@@ -35,8 +36,9 @@
         </if>
         order by bw.pk_wares,bt.algebra
     </select>
+
     <select id="queryAllSpecialWaresBonus" resultMap="BdWaresBonusExt">
-        select bw.pk_id,bw.wares_code, bw.wares_name
+        select bw.pk_id, bw.wares_code, bw.wares_name
         from bd_wares bw
                  inner join bd_wares_extend be on bw.pk_id = be.pk_wares
                  left join bd_wares_bonus bwb on bw.pk_id = bwb.pk_wares and bwb.del_flag = 0

bd-business/bd-business-bonus/src/main/resources/mapper/bonus/bonus/CuMemberBonusCoachMapper.xml

@@ -153,20 +153,22 @@
         </where>
         order by b.period,b.pk_bonus_items,b.real_income desc
     </select>
+
     <select id="queryMemberBonusCoachByBonusItemsForServer" resultMap="CuMemberBonusCoach">
         select b.period,cp.settle_date,so.order_code,so.order_type,bt.short_name source_country_name,
         cu.member_code source_member_code,cu.member_name source_member_name,so.pk_rate,bc.out_exchange_rate,so.order_amount,
         so.order_achieve,b.pk_country,b.pk_bonus_items,b.pretax_income,b.income_tax,b.real_income,b.income_status,
         tar.member_code,tar.member_name,bg.pk_transaction pk_settle_grade,ba.pk_transaction pk_awards,bv.vertex_name,ct.team_name,
         b.remark,b.income_ratio,b.income_dial_ratio,b.order_dial_ratio,b.current_generation,b.coach_generation,
-        b.coach_no_capping,b.coach_capping,b.coach_normal_half,b.coach_normal_real,bct.short_name settle_country from sa_order so
+        b.coach_no_capping,b.coach_capping,b.coach_normal_half,b.coach_normal_real,bct.short_name settle_country
+        from sa_order so
         inner join (
         select cb.pk_member,cc.pk_order,cb.period,cb.pk_country,cc.pk_bonus_items,cc.income_status,cc.CAL_ACHIEVE,cc.pretax_income,cc.income_tax,cc.real_income,
         cc.remark,cc.income_ratio,cc.income_dial_ratio,cc.order_dial_ratio,cc.current_generation,cc.coach_generation,
         cc.coach_no_capping,cc.coach_capping,cc.coach_normal_half,cc.coach_normal_real from cu_member_bonus cb
         inner join cu_member_bonus_coach cc
         on cb.pk_id = cc.pk_bonus
-        where 1=1
+        where 1 = 1
         <if test="bonusParam.period != null">
             and cb.period =#{bonusParam.period}
         </if>
@@ -205,15 +207,15 @@
         left join cu_member_team ct
         on ct.pk_id = tar.pk_team_code
         left join bd_currency bc
-        on bc.pk_id=so.pk_rate
+        on bc.pk_id = so.pk_rate
         left join bd_grade bg
-        on bg.pk_id=tar.pk_settle_grade
+        on bg.pk_id = tar.pk_settle_grade
         left join bd_awards ba
-        on ba.pk_id=tar.pk_awards
+        on ba.pk_id = tar.pk_awards
         left join bd_country bt
-        on bt.pk_id=so.pk_country
+        on bt.pk_id = so.pk_country
         left join bd_country bct
-        on bct.pk_id=tar.pk_settle_country
+        on bct.pk_id = tar.pk_settle_country
         <where>
             1=1
             <if test="bonusParam.pkCountry != null">

bd-business/bd-business-bonus/src/main/resources/mapper/bonus/bonus/CuMemberBonusMapper.xml

@@ -328,10 +328,11 @@
         cm.pk_settle_grade, cm.pk_awards,
         bv.vertex_name, ct.team_name,
         cb.period,cp.settle_date,cb.direct_income,cb.expand_income,cb.expand_no_capping,
-        cb.expand_capping,cb.coach_income,cb.share_income,cb.service_income,cb.back_points,cb.service_spend,
+        cb.expand_capping,cb.share_income,cb.service_income,cb.back_points,cb.service_spend,
         cb.pur_real_subtotal,cb.repur_push_income,cb.repur_range_income,cb.repur_expand_income,cb.repur_real_subtotal,
         cb.repur_coupon,cb.repur_coupon_share,cb.repur_coupon_subtotal,cb.store_income,
         cb.global_points,cb.car_award_points,cb.pk_rate,bc.out_exchange_rate,
+        cb.coach_income,
         cb.retail_range_income, cb.retail_same_level_income, cb.retail_area_income,
         cb.retail_benefit_range_income, cb.retail_month_repurchase_income,
         cb.retail_benefit_avg_income, cb.retail_benefit_income,cb.retail_real_subtotal,

bd-business/bd-business-member/src/main/java/com/hzs/member/account/provider/IMemberJobServiceProvider.java

@@ -6,6 +6,7 @@ import com.hzs.member.account.IMemberJobServiceApi;
 import com.hzs.member.account.service.ICuMemberAccountDetailService;
 import com.hzs.member.account.service.ICuMemberRechargeService;
 import com.hzs.member.account.service.ICuMemberWithdrawService;
+import com.hzs.member.base.mapper.DeleteGarbageDataMapper;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.config.annotation.DubboService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -35,6 +36,10 @@ public class IMemberJobServiceProvider implements IMemberJobServiceApi {
     @Autowired
     private ICuMemberRechargeService memberRechargeService;
 
+    @Autowired
+    private DeleteGarbageDataMapper deleteGarbageDataMapper;
+
+
     @Override
     public R insertAccountDetail() {
         try {
@@ -64,4 +69,12 @@ public class IMemberJobServiceProvider implements IMemberJobServiceApi {
        return R.ok(memberRechargeService.selectRechargeTotalAmount(startDate, endDate));
     }
 
+    @Override
+    public R autoDeleteGarbageData() {
+        deleteGarbageDataMapper.deleteMemberAwards(30);
+        deleteGarbageDataMapper.deleteMemberLevel(30);
+        deleteGarbageDataMapper.deleteMemberGrade(30);
+        return R.ok();
+    }
+
 }

bd-business/bd-business-member/src/main/java/com/hzs/member/base/mapper/DeleteGarbageDataMapper.java

@@ -0,0 +1,22 @@
+package com.hzs.member.base.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.hzs.common.domain.member.base.CuMemberAgent;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Date;
+
+/**
+ * <p>
+ * 会员信息-代理商信息 Mapper 接口
+ * </p>
+ *
+ * @author hzs
+ * @since 2022-08-31
+ */
+public interface DeleteGarbageDataMapper extends BaseMapper {
+
+    void deleteMemberAwards(@Param("days") Integer days);
+    void deleteMemberLevel(@Param("days") Integer days);
+    void deleteMemberGrade(@Param("days") Integer days);
+}

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

@@ -0,0 +1,23 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.hzs.member.base.mapper.DeleteGarbageDataMapper">
+
+    <delete id="deleteMemberAwards" parameterType="java.lang.Integer">
+        delete from CU_MEMBER_AWARDS
+        where
+            CREATION_TIME <![CDATA[ < ]]> (SYSDATE - #{days})
+            and DEL_FLAG = 1
+    </delete>
+    <delete id="deleteMemberLevel" parameterType="java.lang.Integer">
+        delete from CU_MEMBER_LEVEL
+        where
+            CREATION_TIME <![CDATA[ < ]]> (SYSDATE - #{days})
+            and DEL_FLAG = 1
+    </delete>
+    <delete id="deleteMemberGrade" parameterType="java.lang.Integer">
+        delete from CU_MEMBER_GRADE
+        where
+            CREATION_TIME <![CDATA[ < ]]> (SYSDATE - #{days})
+            and DEL_FLAG = 1
+    </delete>
+</mapper>

bd-common/bd-common-domain/src/main/java/com/hzs/common/domain/member/account/CuMemberTrade.java

@@ -14,12 +14,7 @@ import lombok.NoArgsConstructor;
 import lombok.experimental.Accessors;
 
 /**
- * <p>
  * 会员交易明细
- * </p>
- *
- * @author hzs
- * @since 2022-09-06
  */
 @Data
 @EqualsAndHashCode(callSuper = true)

bd-common/bd-common-domain/src/main/java/com/hzs/common/domain/member/account/CuMemberTradeBonus.java

@@ -11,12 +11,7 @@ import lombok.*;
 import lombok.experimental.Accessors;
 
 /**
- * <p>
  * 会员已发放奖金交易明细表
- * </p>
- *
- * @author hzs
- * @since 2023-03-24
  */
 @Data
 @EqualsAndHashCode(callSuper = true)

bd-common/bd-common-domain/src/main/java/com/hzs/common/domain/member/account/CuMemberTradeDetail.java

@@ -11,12 +11,7 @@ import lombok.*;
 import lombok.experimental.Accessors;
 
 /**
- * <p>
+ * 奖金发放明细表
- *
- * </p> 奖金发放明细表
- *
- * @author hzs
- * @since 2023-03-21
  */
 @Data
 @EqualsAndHashCode(callSuper = true)

bd-common/bd-common-domain/src/main/java/com/hzs/common/domain/member/bonus/BdWaresBonus.java

@@ -12,12 +12,7 @@ import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
 
 /**
- * <p>
  * 特殊商品分配奖金
- * </p>
- *
- * @author hzs
- * @since 2024-10-30
  */
 @Data
 @EqualsAndHashCode(callSuper = true)

bd-common/bd-common-domain/src/main/java/com/hzs/common/domain/member/bonus/CuMemberBonus.java

@@ -74,7 +74,7 @@ public class CuMemberBonus extends BaseEntity {
     private BigDecimal expandCapping;
 
     /**
-     * 辅导收益
+     * 培育津贴
      */
     @TableField("COACH_INCOME")
     private BigDecimal coachIncome;

bd-third/src/main/java/com/hzs/third/job/CuMemberJob.java

@@ -34,4 +34,9 @@ public class CuMemberJob {
         iMemberJobServiceApi.automaticWithdrawal();
     }
 
+    @XxlJob("autoDeleteGarbageData")
+    public void autoDeleteGarbageData(){
+        iMemberJobServiceApi.autoDeleteGarbageData();
+    }
+
 }

bd-third/src/main/java/com/hzs/third/job/controller/JobTestController.java

@@ -6,6 +6,7 @@ import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
 import com.hzs.common.core.domain.R;
 import com.hzs.common.core.web.domain.AjaxResult;
+import com.hzs.member.account.IMemberJobServiceApi;
 import com.hzs.system.base.IAreaServiceApi;
 import com.hzs.system.base.dto.AreaDTO;
 import com.hzs.third.job.OrderJob;
@@ -29,6 +30,9 @@ public class JobTestController {
     @DubboReference
     IAreaServiceApi iAreaServiceApi;
 
+    @DubboReference
+    IMemberJobServiceApi iMemberJobServiceApi;
+
     /**
      * 测试行政区划更新
      *
@@ -124,4 +128,10 @@ public class JobTestController {
         return AjaxResult.error("处理失败：" + resultR.getMsg());
     }
 
+
+    @GetMapping("/autoDeleteGarbageData")
+    public AjaxResult autoDeleteGarbageData() {
+        iMemberJobServiceApi.autoDeleteGarbageData();
+        return AjaxResult.success();
+    }
 }