## 日结前初始化见点考核数据;

This commit is contained in:
cabbage 2025-07-24 15:37:20 +08:00
parent 5c0af7ac32
commit a99830aff8
9 changed files with 67 additions and 163 deletions

View File

@ -17,9 +17,6 @@ import java.util.List;
/** /**
* 会员业绩记录 Mapper 接口 * 会员业绩记录 Mapper 接口
*
* @author hzs
* @since 2022-10-26
*/ */
public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> { public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
@ -27,9 +24,6 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
* 创建会员网体记录表 * 创建会员网体记录表
* *
* @param tableName 日期 * @param tableName 日期
* @return: void
* @Author: sui q
* @Date: 2022/10/31 11:44
*/ */
void createCuMemberAchieveTable(String tableName); void createCuMemberAchieveTable(String tableName);
@ -37,25 +31,16 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
* 创建每年的会员考核表 * 创建每年的会员考核表
* *
* @param tableName 表名 * @param tableName 表名
* @return: void
* @Author: sui q
* @Date: 2022/11/7 14:10
*/ */
void createCuMemberMonthTable(String tableName); void createCuMemberMonthTable(String tableName);
/* /*
* @description:更新会员业绩表 每月月统计报表 * 更新会员业绩表 每月月统计报表
* @author: sui q
* @date: 2023/8/29 10:57
* @param: null null
**/ **/
void mergeCuMemberMonth(@Param("date") String date, @Param("period") Integer period); void mergeCuMemberMonth(@Param("date") String date, @Param("period") Integer period);
/* /*
* @description: 查询每月月业绩获得血缘业绩 首购复购 * 查询每月月业绩获得血缘业绩 首购复购
* @author: sui q
* @date: 2023/12/11 15:36
* @param: null null
**/ **/
List<CuMemberAchieveExt> queryCuMemberMonthAchieveByMemberIdList(@Param("settleTableName") String settleTableName, @Param("memberSwingNetExtList") List<CuMemberSwingNetExt> memberSwingNetExtList); List<CuMemberAchieveExt> queryCuMemberMonthAchieveByMemberIdList(@Param("settleTableName") String settleTableName, @Param("memberSwingNetExtList") List<CuMemberSwingNetExt> memberSwingNetExtList);
@ -65,9 +50,6 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
* @param targetTableName 目标表 网体月表 * @param targetTableName 目标表 网体月表
* @param sourceTableName 来源表 结算日表 * @param sourceTableName 来源表 结算日表
* @param period 期间 * @param period 期间
* @return: void
* @Author: sui q
* @Date: 2023/2/16 11:35
*/ */
void mergeCuMemberAchieveBySettleDate(@Param("targetTableName") String targetTableName, void mergeCuMemberAchieveBySettleDate(@Param("targetTableName") String targetTableName,
@Param("sourceTableName") String sourceTableName, @Param("period") Integer period); @Param("sourceTableName") String sourceTableName, @Param("period") Integer period);
@ -78,9 +60,6 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
* *
* @param sourceTable 来源表记录10天跟月表一摸一样的滚动表数据 * @param sourceTable 来源表记录10天跟月表一摸一样的滚动表数据
* @param targetTable 目标表 记录10天跟月表一摸一样的滚动表数据 * @param targetTable 目标表 记录10天跟月表一摸一样的滚动表数据
* @return: void
* @Author: sui q
* @Date: 2022/10/31 16:26
*/ */
void updateCuMemberSettleAchieveByBeforeDay(@Param("sourceTable") String sourceTable, @Param("targetTable") String targetTable); void updateCuMemberSettleAchieveByBeforeDay(@Param("sourceTable") String sourceTable, @Param("targetTable") String targetTable);
@ -90,17 +69,11 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
* *
* @param sourceTable 来源表记录10天跟月表一摸一样的滚动表数据 * @param sourceTable 来源表记录10天跟月表一摸一样的滚动表数据
* @param targetTable 目标表 记录10天跟月表一摸一样的滚动表数据 * @param targetTable 目标表 记录10天跟月表一摸一样的滚动表数据
* @return: void
* @Author: sui q
* @Date: 2022/10/31 16:26
*/ */
void updateCuMemberExpandSettleAchieveByBeforeDay(@Param("sourceTable") String sourceTable, @Param("targetTable") String targetTable); void updateCuMemberExpandSettleAchieveByBeforeDay(@Param("sourceTable") String sourceTable, @Param("targetTable") String targetTable);
/* /*
* @description: 更新为最初始的数据新增的为0历史的通过昨天进行更新 * 更新为最初始的数据新增的为0历史的通过昨天进行更新
* @author: sui q
* @date: 2023/8/11 14:57
* @param: null null
**/ **/
void updateCuMemberSettleInitAchieve(String targetTable); void updateCuMemberSettleInitAchieve(String targetTable);
@ -110,26 +83,17 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
* @param targetTable 结算表 * @param targetTable 结算表
* @param period 期间 * @param period 期间
* @param pkId 主键 * @param pkId 主键
* @return: void
* @Author: sui q
* @Date: 2023/3/11 13:42
*/ */
void updateCuMemberSettleAchieveBySpecialBus(@Param("targetTable") String targetTable, @Param("period") Integer period, void updateCuMemberSettleAchieveBySpecialBus(@Param("targetTable") String targetTable, @Param("period") Integer period,
@Param("pkId") Long pkId); @Param("pkId") Long pkId);
/* /*
* @description: 注水到期更新业绩 * 注水到期更新业绩
* @author: sui q
* @date: 2024/5/23 11:37
* @param: null null
**/ **/
void mergeCuMemberSettleByAchieveLogByDate(@Param("targetTable") String targetTable, @Param("settleDate") Date settleDate); void mergeCuMemberSettleByAchieveLogByDate(@Param("targetTable") String targetTable, @Param("settleDate") Date settleDate);
/* /*
* @description: 根据到期日期更新业绩到期后需要还原到实际累计金额 * 根据到期日期更新业绩到期后需要还原到实际累计金额
* @author: sui q
* @date: 2023/4/8 15:32
* @param: null null
**/ **/
void updateCuMemberSettleAchieveByDueDate(@Param("currentTableName") String currentTableName, @Param("yesTableName") String yesTableName, void updateCuMemberSettleAchieveByDueDate(@Param("currentTableName") String currentTableName, @Param("yesTableName") String yesTableName,
@Param("currentDate") Date currentDate); @Param("currentDate") Date currentDate);
@ -140,18 +104,12 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
* *
* @param memberAchieveParamList 会员业绩 * @param memberAchieveParamList 会员业绩
* @param tableName 更新的表结算日的日表 * @param tableName 更新的表结算日的日表
* @return: Boolean
* @Author: sui q
* @Date: 2022/11/2 11:30
*/ */
Boolean updateCuMemberBackOldAchieveEveryDay(@Param("memberAchieveParamList") List<?> memberAchieveParamList, Boolean updateCuMemberBackOldAchieveEveryDay(@Param("memberAchieveParamList") List<?> memberAchieveParamList,
@Param("tableName") String tableName); @Param("tableName") String tableName);
/* /*
* @description: 退单回退业绩 * 退单回退业绩
* @author: sui q
* @date: 2023/9/22 9:27
* @param: null null
**/ **/
void chargeBackSaOrder(@Param("targetTable") String targetTable, @Param("sourceTable") String sourceTable, void chargeBackSaOrder(@Param("targetTable") String targetTable, @Param("sourceTable") String sourceTable,
@Param("period") Integer period, @Param("achieve") MemberAchieveParam memberAchieveParam); @Param("period") Integer period, @Param("achieve") MemberAchieveParam memberAchieveParam);
@ -161,9 +119,6 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
* *
* @param memberAchieveParamList 会员业绩 * @param memberAchieveParamList 会员业绩
* @param tableName 更新的表结算日的日表 * @param tableName 更新的表结算日的日表
* @return: Boolean
* @Author: sui q
* @Date: 2022/11/2 11:30
*/ */
Boolean updateCuMemberBackAchieveEveryDay(@Param("memberAchieveParamList") List<?> memberAchieveParamList, Boolean updateCuMemberBackAchieveEveryDay(@Param("memberAchieveParamList") List<?> memberAchieveParamList,
@Param("tableName") String tableName); @Param("tableName") String tableName);
@ -172,9 +127,6 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
* 重新结算会员网体业绩 * 重新结算会员网体业绩
* *
* @param currentSettleTableName 更新甩网业绩 * @param currentSettleTableName 更新甩网业绩
* @return: void
* @Author: sui q
* @Date: 2022/11/3 13:56
*/ */
void updateCuMemberNetAchieve(@Param("updMemberAchieveExtList") List<CuMemberAchieveExt> updMemberAchieveExtList, @Param("tableName") String currentSettleTableName); void updateCuMemberNetAchieve(@Param("updMemberAchieveExtList") List<CuMemberAchieveExt> updMemberAchieveExtList, @Param("tableName") String currentSettleTableName);
@ -184,22 +136,15 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
* @param pkMember 会员主键 * @param pkMember 会员主键
* @param pkCountry 公司 * @param pkCountry 公司
* @param tableName 结算表 * @param tableName 结算表
* @return: CuMemberAchieve
* @Author: sui q
* @Date: 2022/10/26 15:04
*/ */
CuMemberAchieve queryCuMemberAchieveByPkMember(@Param("pkMember") Long pkMember, @Param("pkCountry") Integer pkCountry, @Param("tableName") String tableName); CuMemberAchieve queryCuMemberAchieveByPkMember(@Param("pkMember") Long pkMember, @Param("pkCountry") Integer pkCountry, @Param("tableName") String tableName);
/* /*
* description: 查询会员伞下血缘业绩 * 查询会员伞下血缘业绩
* @author: sui q
* @date: 2023/4/7 15:13
* @param: null null
**/ **/
BigDecimal queryCuMemberUnderBloodAchieveByPkMember(@Param("treeTable") String treeTable, @Param("achieveTable") String achieveTable, BigDecimal queryCuMemberUnderBloodAchieveByPkMember(@Param("treeTable") String treeTable, @Param("achieveTable") String achieveTable,
@Param("pkMember") Long pkMember, @Param("period") Integer period); @Param("pkMember") Long pkMember, @Param("period") Integer period);
/** /**
* 会员端新增业绩 * 会员端新增业绩
* *
@ -224,7 +169,6 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
*/ */
List<CuMemberAwardsUnderVO> selectUnderMemberAwards(CuMemberAwardsUnderVO memberAwardsUnderVO); List<CuMemberAwardsUnderVO> selectUnderMemberAwards(CuMemberAwardsUnderVO memberAwardsUnderVO);
/** /**
* 月度新增业绩对比 * 月度新增业绩对比
* *
@ -252,51 +196,33 @@ public interface CuMemberAchieveMapper extends BaseMapper<CuMemberAchieve> {
List<BigDecimal> selectByParent(@Param("memberIds") List<Long> memberIds, @Param("pkCountry") Integer pkCountry, @Param("achieveTable") String achieveTable); List<BigDecimal> selectByParent(@Param("memberIds") List<Long> memberIds, @Param("pkCountry") Integer pkCountry, @Param("achieveTable") String achieveTable);
/* /*
* @description: 更新会员的业绩 * 更新会员的业绩
* @author: sui q
* @date: 2023/8/12 15:46
* @param: null null
**/ **/
void updateCuMemberAchieve(@Param("tableName") String tableName, @Param("period") Integer period); void updateCuMemberAchieve(@Param("tableName") String tableName, @Param("period") Integer period);
/* /*
* @description: 查询月统计数据按照月倒叙 * 查询月统计数据按照月倒叙
* @author: sui q
* @date: 2023/8/29 16:10
* @param: null null
**/ **/
List<CuMemberAchieveExt> queryMemberMonthAchieve(@Param("pkMember") Long pkMember, @Param("monthList") List<String> monthList); List<CuMemberAchieveExt> queryMemberMonthAchieve(@Param("pkMember") Long pkMember, @Param("monthList") List<String> monthList);
/* /*
* @description: 查询会员一代伞下 * 查询会员一代伞下
* @author: sui q
* @date: 2023/8/29 18:07
* @param: null null
**/ **/
List<Long> queryPkMemberMonthAchieve(@Param("month") String month, @Param("pkMember") Long pkMember); List<Long> queryPkMemberMonthAchieve(@Param("month") String month, @Param("pkMember") Long pkMember);
/* /*
* @description: 查询月统计数据查询明细 * 查询月统计数据查询明细
* @author: sui q
* @date: 2023/8/29 17:43
* @param: null null
**/ **/
List<CuMemberAchieveExt> queryMemberMonthAchieveDetail(@Param("monthAchieveParam") MonthAchieveParam monthAchieveParam, List<CuMemberAchieveExt> queryMemberMonthAchieveDetail(@Param("monthAchieveParam") MonthAchieveParam monthAchieveParam,
@Param("memberList") List<Long> memberList); @Param("memberList") List<Long> memberList);
/* /*
* @description: 查询月统计数据查询明细安置伞下 * 查询月统计数据查询明细安置伞下
* @author: sui q
* @date: 2023/9/6 21:12
* @param: null null
**/ **/
List<CuMemberAchieveExt> queryPlaceParentMemberMonthAchieve(MonthAchieveParam monthAchieveParam); List<CuMemberAchieveExt> queryPlaceParentMemberMonthAchieve(MonthAchieveParam monthAchieveParam);
/* /*
* @description: 查询月统计数据查询明细安置伞下 * 查询月统计数据查询明细安置伞下
* @author: sui q
* @date: 2023/9/6 21:12
* @param: null null
**/ **/
List<CuMemberAchieveExt> queryParentMemberMonthAchieve(MonthAchieveParam monthAchieveParam); List<CuMemberAchieveExt> queryParentMemberMonthAchieve(MonthAchieveParam monthAchieveParam);
} }

View File

@ -325,4 +325,12 @@ public interface CuMemberTreeMapper extends BaseMapper<CuMemberTree> {
*/ */
int updateCuMemberSettlePointAssess(@Param("settleTableName") String settleTableName, @Param("assessTableName") String assessTableName); int updateCuMemberSettlePointAssess(@Param("settleTableName") String settleTableName, @Param("assessTableName") String assessTableName);
/**
* 初始化考核数据
*
* @param settleTableName
* @return
*/
int initAssessDate(@Param("settleTableName") String settleTableName);
} }

View File

@ -13,9 +13,6 @@ import java.util.Map;
/** /**
* 会员业绩记录 服务类 * 会员业绩记录 服务类
*
* @author hzs
* @since 2022-10-26
*/ */
public interface ICuMemberAchieveService extends IService<CuMemberAchieve> { public interface ICuMemberAchieveService extends IService<CuMemberAchieve> {
@ -23,9 +20,6 @@ public interface ICuMemberAchieveService extends IService<CuMemberAchieve> {
* 创建每月的会员业绩记录表 * 创建每月的会员业绩记录表
* *
* @param date 日期 * @param date 日期
* @return: void
* @Author: sui q
* @Date: 2022/10/31 15:17
*/ */
String createCuMemberAchieve(String date); String createCuMemberAchieve(String date);
@ -33,17 +27,11 @@ public interface ICuMemberAchieveService extends IService<CuMemberAchieve> {
* 创建每年的业绩统计年表用于放月表 * 创建每年的业绩统计年表用于放月表
* *
* @param tableName 表名 * @param tableName 表名
* @return: void
* @Author: sui q
* @Date: 2022/11/7 14:10
*/ */
void createCuMemberMonthTable(String tableName); void createCuMemberMonthTable(String tableName);
/* /*
* @description:更新会员业绩表 每月月统计报表 * 更新会员业绩表 每月月统计报表
* @author: sui q
* @date: 2023/8/29 10:57
* @param: null null
**/ **/
void mergeCuMemberMonth(Integer day, String date); void mergeCuMemberMonth(Integer day, String date);
@ -53,9 +41,6 @@ public interface ICuMemberAchieveService extends IService<CuMemberAchieve> {
* @param targetTableName 目标表 网体月表 * @param targetTableName 目标表 网体月表
* @param sourceTableName 来源表 结算日表 * @param sourceTableName 来源表 结算日表
* @param period 期间 * @param period 期间
* @return: void
* @Author: sui q
* @Date: 2023/2/16 11:35
*/ */
void mergeCuMemberAchieveBySettleDate(String targetTableName, String sourceTableName, Integer period); void mergeCuMemberAchieveBySettleDate(String targetTableName, String sourceTableName, Integer period);
@ -64,9 +49,6 @@ public interface ICuMemberAchieveService extends IService<CuMemberAchieve> {
* *
* @param memberAchieveParamMap 修改的结算 * @param memberAchieveParamMap 修改的结算
* @param tablaName 修改的结算期间表 * @param tablaName 修改的结算期间表
* @return: Boolean
* @Author: sui q
* @Date: 2022/11/2 11:30
*/ */
void updateCuMemberAchieveEveryDay(Map<Long, MemberAchieveParam> memberAchieveParamMap, String tablaName); void updateCuMemberAchieveEveryDay(Map<Long, MemberAchieveParam> memberAchieveParamMap, String tablaName);
@ -74,9 +56,6 @@ public interface ICuMemberAchieveService extends IService<CuMemberAchieve> {
* 重新结算会员网体业绩 * 重新结算会员网体业绩
* *
* @param currentSettleTableName 更新甩网业绩 * @param currentSettleTableName 更新甩网业绩
* @return: void
* @Author: sui q
* @Date: 2022/11/3 13:56
*/ */
void updateCuMemberNetAchieve(List<CuMemberAchieveExt> updMemberAchieveExtList, String currentSettleTableName); void updateCuMemberNetAchieve(List<CuMemberAchieveExt> updMemberAchieveExtList, String currentSettleTableName);
@ -85,9 +64,6 @@ public interface ICuMemberAchieveService extends IService<CuMemberAchieve> {
* *
* @param memberAchieveParamMap 修改的结算 * @param memberAchieveParamMap 修改的结算
* @param tablaName 修改的结算期间表 * @param tablaName 修改的结算期间表
* @return: Boolean
* @Author: sui q
* @Date: 2022/11/2 11:30
*/ */
void updateCuMemberBackOldAchieveEveryDay(Map<Long, MemberAchieveParam> memberAchieveParamMap, String tablaName); void updateCuMemberBackOldAchieveEveryDay(Map<Long, MemberAchieveParam> memberAchieveParamMap, String tablaName);
@ -96,9 +72,6 @@ public interface ICuMemberAchieveService extends IService<CuMemberAchieve> {
* 根据昨天结算表数据更新今天结算表的业绩数据 * 根据昨天结算表数据更新今天结算表的业绩数据
* *
* @param targetTable 目标表 记录10天跟月表一摸一样的滚动表数据 * @param targetTable 目标表 记录10天跟月表一摸一样的滚动表数据
* @return: void
* @Author: sui q
* @Date: 2022/10/31 16:26
*/ */
void updateCuMemberSettleInitAchieve(String targetTable); void updateCuMemberSettleInitAchieve(String targetTable);
@ -108,9 +81,6 @@ public interface ICuMemberAchieveService extends IService<CuMemberAchieve> {
* *
* @param sourceTable 来源表记录10天跟月表一摸一样的滚动表数据 * @param sourceTable 来源表记录10天跟月表一摸一样的滚动表数据
* @param targetTable 目标表 记录10天跟月表一摸一样的滚动表数据 * @param targetTable 目标表 记录10天跟月表一摸一样的滚动表数据
* @return: void
* @Author: sui q
* @Date: 2022/10/31 16:26
*/ */
void updateCuMemberSettleAchieveByBeforeDay(String sourceTable, String targetTable); void updateCuMemberSettleAchieveByBeforeDay(String sourceTable, String targetTable);
@ -120,9 +90,6 @@ public interface ICuMemberAchieveService extends IService<CuMemberAchieve> {
* *
* @param sourceTable 来源表记录10天跟月表一摸一样的滚动表数据 * @param sourceTable 来源表记录10天跟月表一摸一样的滚动表数据
* @param targetTable 目标表 记录10天跟月表一摸一样的滚动表数据 * @param targetTable 目标表 记录10天跟月表一摸一样的滚动表数据
* @return: void
* @Author: sui q
* @Date: 2022/10/31 16:26
*/ */
void updateCuMemberExpandSettleAchieveByBeforeDay(String sourceTable, String targetTable); void updateCuMemberExpandSettleAchieveByBeforeDay(String sourceTable, String targetTable);
@ -132,41 +99,26 @@ public interface ICuMemberAchieveService extends IService<CuMemberAchieve> {
* @param targetTable 结算表 * @param targetTable 结算表
* @param period 期间 * @param period 期间
* @param pkId 主键 * @param pkId 主键
* @return: void
* @Author: sui q
* @Date: 2023/3/11 13:42
*/ */
void updateCuMemberSettleAchieveBySpecialBus(String targetTable, Integer period, Long pkId); void updateCuMemberSettleAchieveBySpecialBus(String targetTable, Integer period, Long pkId);
/* /*
* @description: 注水到期更新业绩 * 注水到期更新业绩
* @author: sui q
* @date: 2024/5/23 11:37
* @param: null null
**/ **/
void mergeCuMemberSettleByAchieveLogByDate(String targetTable, Date settleDate); void mergeCuMemberSettleByAchieveLogByDate(String targetTable, Date settleDate);
/* /*
* @description: 根据到期日期更新业绩到期后需要还原到实际累计金额 * 根据到期日期更新业绩到期后需要还原到实际累计金额
* @author: sui q
* @date: 2023/4/8 15:32
* @param: null null
**/ **/
void updateCuMemberSettleAchieveByDueDate(String currentTableName, String yesTableName, Date currentDate); void updateCuMemberSettleAchieveByDueDate(String currentTableName, String yesTableName, Date currentDate);
/* /*
* @description: 退单回退业绩 * 退单回退业绩
* @author: sui q
* @date: 2023/9/22 9:27
* @param: null null
**/ **/
Boolean chargeBackSaOrder(SaOrder saOrder); Boolean chargeBackSaOrder(SaOrder saOrder);
/* /*
* @description: 查询每月月业绩获得血缘业绩 首购复购 * 查询每月月业绩获得血缘业绩 首购复购
* @author: sui q
* @date: 2023/12/11 15:36
* @param: null null
**/ **/
List<CuMemberAchieveExt> queryCuMemberMonthAchieveByMemberIdList(String settleTableName, List<CuMemberSwingNetExt> memberSwingNetExtList); List<CuMemberAchieveExt> queryCuMemberMonthAchieveByMemberIdList(String settleTableName, List<CuMemberSwingNetExt> memberSwingNetExtList);
} }

View File

@ -6,7 +6,6 @@ import com.hzs.common.domain.member.achieve.ext.CuMemberAchieveExt;
import com.hzs.common.domain.member.ext.CuMemberSettleExt; import com.hzs.common.domain.member.ext.CuMemberSettleExt;
import com.hzs.common.domain.sale.ext.SaOrderExt; import com.hzs.common.domain.sale.ext.SaOrderExt;
import com.hzs.bonus.achieve.param.MemberAchieveParam; import com.hzs.bonus.achieve.param.MemberAchieveParam;
import org.apache.ibatis.annotations.Param;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -267,7 +266,7 @@ public interface ICuMemberTreeService extends IService<CuMemberTree> {
* @param cuMemberTreeList 推荐人 * @param cuMemberTreeList 推荐人
* @return: List<CuMemberSettleExt> * @return: List<CuMemberSettleExt>
*/ */
List<CuMemberSettleExt> queryCuMemberSecondParent(@Param("secondTableName") String secondTableName, @Param("cuMemberTreeList") List<?> cuMemberTreeList); List<CuMemberSettleExt> queryCuMemberSecondParent(String secondTableName, List<?> cuMemberTreeList);
/** /**
* 删除日表数据 * 删除日表数据
@ -333,4 +332,12 @@ public interface ICuMemberTreeService extends IService<CuMemberTree> {
*/ */
void updateCuMemberSettlePointAssess(String settleTableName, String assessTableName); void updateCuMemberSettlePointAssess(String settleTableName, String assessTableName);
/**
* 初始化考核数据
*
* @param settleTableName
* @return
*/
int initAssessDate(String settleTableName);
} }

View File

@ -25,30 +25,27 @@ import java.util.*;
/** /**
* 会员业绩记录 服务实现类 * 会员业绩记录 服务实现类
*
* @author hzs
* @since 2022-10-26
*/ */
@Slf4j @Slf4j
@Service @Service
public class CuMemberAchieveServiceImpl extends ServiceImpl<CuMemberAchieveMapper, CuMemberAchieve> implements ICuMemberAchieveService { public class CuMemberAchieveServiceImpl extends ServiceImpl<CuMemberAchieveMapper, CuMemberAchieve> implements ICuMemberAchieveService {
@Autowired @Autowired
private ICuMemberTreeService cuMemberTreeService; private ICuMemberTreeService iCuMemberTreeService;
@Autowired @Autowired
private CuMemberBonusSettle cuMemberBonusSettle; private CuMemberBonusSettle cuMemberBonusSettle;
@Autowired @Autowired
private ICuMemberSettlePeriodService cuMemberSettlePeriodService; private ICuMemberSettlePeriodService iCuMemberSettlePeriodService;
@Override @Override
public String createCuMemberAchieve(String date) { public String createCuMemberAchieve(String date) {
// 创建业绩月表记录表 // 创建业绩月表记录表
String tableName = TableNameConstants.CU_MEMBER_ACHIEVE + DateUtils.getMonth(date); String tableName = TableNameConstants.CU_MEMBER_ACHIEVE + DateUtils.getMonth(date);
Integer num = cuMemberTreeService.queryExistOracleTable(tableName); Integer num = iCuMemberTreeService.queryExistOracleTable(tableName);
if (num == null || num <= 0) { if (num == null || num <= 0) {
baseMapper.createCuMemberAchieveTable(tableName); baseMapper.createCuMemberAchieveTable(tableName);
cuMemberTreeService.createCuMemberTableUniqueIndex(tableName); iCuMemberTreeService.createCuMemberTableUniqueIndex(tableName);
cuMemberTreeService.createCuMemberTableSequence(tableName, TableNameConstants.CU_MEMBER_ACHIEVE_SEQ); iCuMemberTreeService.createCuMemberTableSequence(tableName, TableNameConstants.CU_MEMBER_ACHIEVE_SEQ);
} }
return tableName; return tableName;
} }
@ -61,12 +58,12 @@ public class CuMemberAchieveServiceImpl extends ServiceImpl<CuMemberAchieveMappe
@Override @Override
public void mergeCuMemberMonth(Integer day, String date) { public void mergeCuMemberMonth(Integer day, String date) {
String tableName = TableNameConstants.CU_MEMBER_MONTH + DateUtils.getMonth(date); String tableName = TableNameConstants.CU_MEMBER_MONTH + DateUtils.getMonth(date);
CuMemberSettlePeriod cuMemberSettlePeriod = cuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(date); CuMemberSettlePeriod cuMemberSettlePeriod = iCuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(date);
// 每月6号删除上月数据,重新生成 // 每月6号删除上月数据,重新生成
// if (day == 6) { // if (day == 6) {
Integer number = cuMemberTreeService.queryExistOracleTable(tableName); Integer number = iCuMemberTreeService.queryExistOracleTable(tableName);
if (number != null && number > 0) { if (number != null && number > 0) {
cuMemberTreeService.truncateCuMemberTreeTable(tableName); iCuMemberTreeService.truncateCuMemberTreeTable(tableName);
} }
// } // }
baseMapper.mergeCuMemberMonth(DateUtils.getMonth(date), cuMemberSettlePeriod.getPkId()); baseMapper.mergeCuMemberMonth(DateUtils.getMonth(date), cuMemberSettlePeriod.getPkId());
@ -172,11 +169,11 @@ public class CuMemberAchieveServiceImpl extends ServiceImpl<CuMemberAchieveMappe
cuMemberAchieve.setRepNewPv(saOrder.getOrderAchieve()); cuMemberAchieve.setRepNewPv(saOrder.getOrderAchieve());
} }
String payTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, saOrder.getPayTime()); String payTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, saOrder.getPayTime());
int period = cuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(payTime).getPkId(); int period = iCuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(payTime).getPkId();
String sourceTable = TableNameConstants.CU_MEMBER_TREE + DateUtils.getMonth(payTime); String sourceTable = TableNameConstants.CU_MEMBER_TREE + DateUtils.getMonth(payTime);
for (int i = 7; i > 0; i--) { for (int i = 7; i > 0; i--) {
String settleDate = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, DateUtils.beforeDate(i, ChronoUnit.DAYS)); String settleDate = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, DateUtils.beforeDate(i, ChronoUnit.DAYS));
int settlePeriod = cuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(settleDate).getPkId(); int settlePeriod = iCuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(settleDate).getPkId();
String targetTable = TableNameConstants.CU_MEMBER_SETTLE + settlePeriod; String targetTable = TableNameConstants.CU_MEMBER_SETTLE + settlePeriod;
baseMapper.chargeBackSaOrder(targetTable, sourceTable, period, cuMemberAchieve); baseMapper.chargeBackSaOrder(targetTable, sourceTable, period, cuMemberAchieve);
} }

View File

@ -430,4 +430,9 @@ public class CuMemberTreeServiceImpl extends ServiceImpl<CuMemberTreeMapper, CuM
baseMapper.updateCuMemberSettlePointAssess(settleTableName, assessTableName); baseMapper.updateCuMemberSettlePointAssess(settleTableName, assessTableName);
} }
@Override
public int initAssessDate(String settleTableName) {
return baseMapper.initAssessDate(settleTableName);
}
} }

View File

@ -1180,9 +1180,9 @@ public class BonusSettleServiceImpl implements IBonusSettleService {
} }
//****************************复购级差*****************************/ //****************************复购级差*****************************/
List<CuMemberBonusRange> cuMemberBonusRangeList = bonusSettlePurchaseHandle.calculateRepurchaseRangeBonus(cuMemberSettleExtMap, settleTableName, settleDate, rangeDtoMap, awardsMap, // List<CuMemberBonusRange> cuMemberBonusRangeList = bonusSettlePurchaseHandle.calculateRepurchaseRangeBonus(cuMemberSettleExtMap, settleTableName, settleDate, rangeDtoMap, awardsMap,
bonusConfigDTO, purchaseOrderList, period, cuMemberBonusMap, cuAwardsControlMap); // bonusConfigDTO, purchaseOrderList, period, cuMemberBonusMap, cuAwardsControlMap);
bonusRecordDetailVO.setCuMemberBonusRangeList(cuMemberBonusRangeList); // bonusRecordDetailVO.setCuMemberBonusRangeList(cuMemberBonusRangeList);
//****************************见点收益*****************************/ //****************************见点收益*****************************/
List<CuMemberBonusCoach> cuMemberPointBonusList = bonusSettlePurchaseHandle.calculateRepurchasePointBonus(cuMemberSettleExtMap, settleTableName, period, List<CuMemberBonusCoach> cuMemberPointBonusList = bonusSettlePurchaseHandle.calculateRepurchasePointBonus(cuMemberSettleExtMap, settleTableName, period,
@ -1193,8 +1193,8 @@ public class BonusSettleServiceImpl implements IBonusSettleService {
bonusRecordDetailVO.setCuMemberBonusCoachList(cuMemberPointBonusList); bonusRecordDetailVO.setCuMemberBonusCoachList(cuMemberPointBonusList);
} }
// TODO
//****************************区域收益*****************************/ //****************************区域收益*****************************/
// TODO
Map<Long, MemberBonusDetailCalVO> memberBonusDetailCalVoMap = new HashMap<>(ComputeUtil.mapInitCapacity(purchaseOrderList.size())); Map<Long, MemberBonusDetailCalVO> memberBonusDetailCalVoMap = new HashMap<>(ComputeUtil.mapInitCapacity(purchaseOrderList.size()));
if (null != cuMemberBonusExpandList) { if (null != cuMemberBonusExpandList) {
@ -1211,10 +1211,11 @@ public class BonusSettleServiceImpl implements IBonusSettleService {
memberBonusDetailCalVO.setRepCoachIncome(ComputeUtil.computeAdd(memberBonusDetailCalVO.getRepCoachIncome(), cuMemberBonusCoach.getRealIncome())); memberBonusDetailCalVO.setRepCoachIncome(ComputeUtil.computeAdd(memberBonusDetailCalVO.getRepCoachIncome(), cuMemberBonusCoach.getRealIncome()));
}); });
} }
cuMemberBonusRangeList.forEach(cuMemberBonusRange -> { // cuMemberBonusRangeList.forEach(cuMemberBonusRange -> {
MemberBonusDetailCalVO memberBonusDetailCalVO = calculateOrderRatio(memberBonusDetailCalVoMap, cuMemberBonusRange); // MemberBonusDetailCalVO memberBonusDetailCalVO = calculateOrderRatio(memberBonusDetailCalVoMap, cuMemberBonusRange);
memberBonusDetailCalVO.setRepRangeIncome(ComputeUtil.computeAdd(memberBonusDetailCalVO.getRepRangeIncome(), cuMemberBonusRange.getRealIncome())); // memberBonusDetailCalVO.setRepRangeIncome(ComputeUtil.computeAdd(memberBonusDetailCalVO.getRepRangeIncome(), cuMemberBonusRange.getRealIncome()));
}); // });
// 见点收益
cuMemberPointBonusList.forEach(cuMemberPointBonus -> { cuMemberPointBonusList.forEach(cuMemberPointBonus -> {
MemberBonusDetailCalVO memberBonusDetailCalVO = calculateOrderRatio(memberBonusDetailCalVoMap, cuMemberPointBonus); MemberBonusDetailCalVO memberBonusDetailCalVO = calculateOrderRatio(memberBonusDetailCalVoMap, cuMemberPointBonus);
memberBonusDetailCalVO.setGlobalPoints(ComputeUtil.computeAdd(memberBonusDetailCalVO.getGlobalPoints(), cuMemberPointBonus.getRealIncome())); memberBonusDetailCalVO.setGlobalPoints(ComputeUtil.computeAdd(memberBonusDetailCalVO.getGlobalPoints(), cuMemberPointBonus.getRealIncome()));

View File

@ -420,6 +420,8 @@ public class CuMemberAssessServiceImpl extends ServiceImpl<CuMemberAssessMapper,
// 当月会员复购考核 // 当月会员复购考核
baseMapper.updatePassMemberAssess(assessTableName, startDate, endDate); baseMapper.updatePassMemberAssess(assessTableName, startDate, endDate);
// 初始化考核数据
iCuMemberTreeService.initAssessDate(currentSettleTableName);
// 更新日结表会员免考信息 // 更新日结表会员免考信息
iCuMemberTreeService.updateCuMemberSettlePointAssess(currentSettleTableName, assessTableName); iCuMemberTreeService.updateCuMemberSettlePointAssess(currentSettleTableName, assessTableName);
} }

View File

@ -1172,4 +1172,10 @@
update set cms.is_maker_space = 0 update set cms.is_maker_space = 0
</update> </update>
<!-- 初始化考核数据 -->
<update id="initAssessDate">
update ${settleTableName} cms
set cms.is_maker_space = 1
</update>
</mapper> </mapper>