diff --git a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/controller/api/ApiCuMemberBonusController.java b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/controller/api/ApiCuMemberBonusController.java
index e7e4b8db..0577ad47 100644
--- a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/controller/api/ApiCuMemberBonusController.java
+++ b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/controller/api/ApiCuMemberBonusController.java
@@ -35,46 +35,7 @@ public class ApiCuMemberBonusController extends BaseController {
private ICuMemberBonusService cuMemberBonusService;
/**
- * 查询会员某个时间段内的奖金,默认查询15天内,查询直推
- */
- @PostMapping("/query-bonus-first")
- public TableDataInfo listFirstRepurchaseBonus(@RequestBody BonusParam bonusParam) {
- setBonusParam(bonusParam);
- List cuMemberBonusList = cuMemberBonusService.queryMemberBonusVoByCondition(bonusParam);
- List firstPurchaseVOList = new ArrayList<>();
- cuMemberBonusList.forEach(cuMemberBonus -> {
- MemberBonusFirstPurchaseVO memberBonusFirstPurchaseVO = BeanUtil.copyProperties(cuMemberBonus, MemberBonusFirstPurchaseVO.class, "settleDate");
- packageSettleDate(cuMemberBonus, memberBonusFirstPurchaseVO);
-// BigDecimal serviceSpend = ComputeUtil.computeSubtract(ComputeUtil.computeAddNum(memberBonusFirstPurchaseVO.getDirectIncome(), memberBonusFirstPurchaseVO.getExpandIncome(),
-// memberBonusFirstPurchaseVO.getCoachIncome(), memberBonusFirstPurchaseVO.getServiceIncome(), memberBonusFirstPurchaseVO.getShareIncome()),
-// memberBonusFirstPurchaseVO.getPurRealSubtotal());
-// memberBonusFirstPurchaseVO.setBackPoints(ComputeUtil.computeMultiplyHalf(serviceSpend));
-// memberBonusFirstPurchaseVO.setServiceSpend(ComputeUtil.computeMultiplyHalf(serviceSpend));
- // if(DateUtils.compareDate(cuMemberBonus.getSettleDate(), DateUtils.parseStringToDate("2024-09-09"))>0) {
- BigDecimal serviceSpend = ComputeUtil.computeSubtract(ComputeUtil.computeAddNum(memberBonusFirstPurchaseVO.getDirectIncome(), memberBonusFirstPurchaseVO.getExpandIncome(),
- memberBonusFirstPurchaseVO.getCoachIncome(), memberBonusFirstPurchaseVO.getServiceIncome(), memberBonusFirstPurchaseVO.getShareIncome(),
- memberBonusFirstPurchaseVO.getRepurExpandIncome(), memberBonusFirstPurchaseVO.getRepurRangeIncome(), memberBonusFirstPurchaseVO.getRepurPushIncome()),
- ComputeUtil.computeAdd(memberBonusFirstPurchaseVO.getPurRealSubtotal(), memberBonusFirstPurchaseVO.getRepurRealSubtotal()));
- memberBonusFirstPurchaseVO.setBackPoints(ComputeUtil.computeMultiplyHalf(serviceSpend));
- memberBonusFirstPurchaseVO.setServiceSpend(ComputeUtil.computeMultiplyHalf(serviceSpend));
- memberBonusFirstPurchaseVO.setExpandIncome(ComputeUtil.computeAddNum(memberBonusFirstPurchaseVO.getExpandIncome(), memberBonusFirstPurchaseVO.getRepurExpandIncome(), memberBonusFirstPurchaseVO.getRepurPushIncome()));
- memberBonusFirstPurchaseVO.setPurRealSubtotal(ComputeUtil.computeAdd(memberBonusFirstPurchaseVO.getPurRealSubtotal(), memberBonusFirstPurchaseVO.getRepurRealSubtotal()));
-// }else{
-// BigDecimal serviceSpend = ComputeUtil.computeSubtract(ComputeUtil.computeAddNum(memberBonusFirstPurchaseVO.getDirectIncome(), memberBonusFirstPurchaseVO.getExpandIncome(),
-// memberBonusFirstPurchaseVO.getCoachIncome(), memberBonusFirstPurchaseVO.getServiceIncome(), memberBonusFirstPurchaseVO.getShareIncome(),
-// memberBonusFirstPurchaseVO.getRepurExpandIncome(), memberBonusFirstPurchaseVO.getRepurExpandIncome()),
-// ComputeUtil.computeAdd(memberBonusFirstPurchaseVO.getPurRealSubtotal(), memberBonusFirstPurchaseVO.getRepurRealSubtotal()));
-// memberBonusFirstPurchaseVO.setBackPoints(ComputeUtil.computeMultiplyHalf(serviceSpend));
-// memberBonusFirstPurchaseVO.setServiceSpend(ComputeUtil.computeMultiplyHalf(serviceSpend));
-// }
- memberBonusFirstPurchaseVO.setPurRealSubtotal(ComputeUtil.computeAdd(memberBonusFirstPurchaseVO.getPurRealSubtotal(), memberBonusFirstPurchaseVO.getGlobalPoints()));
- firstPurchaseVOList.add(memberBonusFirstPurchaseVO);
- });
- return getDataTable(firstPurchaseVOList);
- }
-
- /**
- * 查询会员实时奖金,当日的奖金
+ * 新零售实时奖金:查询会员实时奖金,当日的奖金
*/
@PostMapping("/query-current-bonus")
public TableDataInfo listCurrentBonus(@RequestBody BonusParam bonusParam) {
@@ -102,17 +63,40 @@ public class ApiCuMemberBonusController extends BaseController {
}
/**
- * 查询会员昨天奖金的值
+ * 查询会员某个时间段内的奖金,默认查询15天内,查询直推
+ */
+ @PostMapping("/query-bonus-first")
+ public TableDataInfo listFirstRepurchaseBonus(@RequestBody BonusParam bonusParam) {
+ setBonusParam(bonusParam);
+ List cuMemberBonusList = cuMemberBonusService.queryMemberBonusVoByCondition(bonusParam);
+ List firstPurchaseVOList = new ArrayList<>();
+ cuMemberBonusList.forEach(cuMemberBonus -> {
+ MemberBonusFirstPurchaseVO memberBonusFirstPurchaseVO = BeanUtil.copyProperties(cuMemberBonus, MemberBonusFirstPurchaseVO.class, "settleDate");
+ packageSettleDate(cuMemberBonus, memberBonusFirstPurchaseVO);
+ BigDecimal serviceSpend = ComputeUtil.computeSubtract(ComputeUtil.computeAddNum(memberBonusFirstPurchaseVO.getDirectIncome(), memberBonusFirstPurchaseVO.getExpandIncome(),
+ memberBonusFirstPurchaseVO.getCoachIncome(), memberBonusFirstPurchaseVO.getServiceIncome(), memberBonusFirstPurchaseVO.getShareIncome(),
+ memberBonusFirstPurchaseVO.getRepurExpandIncome(), memberBonusFirstPurchaseVO.getRepurRangeIncome(), memberBonusFirstPurchaseVO.getRepurPushIncome()),
+ ComputeUtil.computeAdd(memberBonusFirstPurchaseVO.getPurRealSubtotal(), memberBonusFirstPurchaseVO.getRepurRealSubtotal()));
+ memberBonusFirstPurchaseVO.setBackPoints(ComputeUtil.computeMultiplyHalf(serviceSpend));
+ memberBonusFirstPurchaseVO.setServiceSpend(ComputeUtil.computeMultiplyHalf(serviceSpend));
+ memberBonusFirstPurchaseVO.setExpandIncome(ComputeUtil.computeAddNum(memberBonusFirstPurchaseVO.getExpandIncome(), memberBonusFirstPurchaseVO.getRepurExpandIncome(), memberBonusFirstPurchaseVO.getRepurPushIncome()));
+ memberBonusFirstPurchaseVO.setPurRealSubtotal(ComputeUtil.computeAdd(memberBonusFirstPurchaseVO.getPurRealSubtotal(), memberBonusFirstPurchaseVO.getRepurRealSubtotal()));
+ memberBonusFirstPurchaseVO.setPurRealSubtotal(ComputeUtil.computeAdd(memberBonusFirstPurchaseVO.getPurRealSubtotal(), memberBonusFirstPurchaseVO.getGlobalPoints()));
+ firstPurchaseVOList.add(memberBonusFirstPurchaseVO);
+ });
+ return getDataTable(firstPurchaseVOList);
+ }
+
+ /**
+ * 新零售实时奖金:查询会员昨日奖金汇总
*/
@PostMapping("/query-bonus-total")
public TableDataInfo lisBonusTotal(@RequestBody BonusParam bonusParam) {
bonusParam.setPkCountry(SecurityUtils.getPkCountry());
bonusParam.setPkMember(SecurityUtils.getUserId());
-// bonusParam.setStartDate(DateUtils.beforeDate(1, ChronoUnit.DAYS));
-// bonusParam.setEndDate(DateUtils.currentDate());
- bonusParam.setStartDate(DateUtils.currentDate());
- bonusParam.setGrantStatus(EGrantStatus.SETTLED.getValue());
- bonusParam.setEndDate(DateUtils.afterDate(1, ChronoUnit.DAYS));
+ bonusParam.setEndDate(DateUtils.currentDate());
+ bonusParam.setStartDate(DateUtils.beforeDate(1, ChronoUnit.DAYS, bonusParam.getEndDate()));
+
List cuMemberBonusList = cuMemberBonusService.queryMemberBonusTotalByCondition(bonusParam);
MemberRealIncomeVO memberRealIncomeVO = new MemberRealIncomeVO();
if (CollectionUtil.isEmpty(cuMemberBonusList)) {
@@ -141,7 +125,6 @@ public class ApiCuMemberBonusController extends BaseController {
memberBonusPurchaseVO.getRetailRealSubtotal());
memberBonusPurchaseVO.setBackPoints(serviceSpend);
memberBonusPurchaseVO.setRetailBenefitIncome(ComputeUtil.computeAdd(memberBonusPurchaseVO.getRetailBenefitIncome(), memberBonusPurchaseVO.getRetailBenefitAvgIncome()));
-// memberBonusPurchaseVO.setServiceSpend(ComputeUtil.computeMultiplyHalf(serviceSpend));
memberBonusPurchaseVoList.add(memberBonusPurchaseVO);
});
return getDataTable(memberBonusPurchaseVoList);
@@ -197,14 +180,7 @@ public class ApiCuMemberBonusController extends BaseController {
public TableDataInfo listBonusSource(@RequestBody BonusParam bonusParam) {
setBonusParam(bonusParam);
startPage();
-// List memberBonusVoList = new ArrayList<>();
TableDataInfo tableDataInfo = cuMemberBonusService.queryMemberBonusDetailVoByCondition(bonusParam);
-// cuMemberBonusList.forEach(cuMemberBonus -> {
-// MemberBonusVO memberBonusVO = BeanUtil.copyProperties(cuMemberBonus, MemberBonusVO.class);
-// memberBonusVoList.add(memberBonusVO);
-// });
-// TableDataInfo dataTable = getDataTable(cuMemberBonusList);
-// dataTable.setRows(memberBonusVoList);
return tableDataInfo;
}
diff --git a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/mapper/CuMemberBonusMapper.java b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/mapper/CuMemberBonusMapper.java
index 53ef4e5d..4b9fa3e5 100644
--- a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/mapper/CuMemberBonusMapper.java
+++ b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/mapper/CuMemberBonusMapper.java
@@ -9,12 +9,7 @@ import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
- *
* 会员奖金-会员奖金汇总表 Mapper 接口
- *
- *
- * @author hzs
- * @since 2022-11-11
*/
public interface CuMemberBonusMapper extends BaseMapper {
@@ -22,9 +17,6 @@ public interface CuMemberBonusMapper extends BaseMapper {
* 批量获取cuMemberBonus主键
*
* @param rowNum 数量
- * @return: List
- * @Author: sui q
- * @Date: 2022/12/13 13:47
*/
List batchQueryCuMemberBonusSeq(Integer rowNum);
@@ -32,9 +24,6 @@ public interface CuMemberBonusMapper extends BaseMapper {
* 根据查询条件查询会员奖金
*
* @param bonusParam 查询条件
- * @return: List
- * @Author: sui q
- * @Date: 2023/1/13 11:27
*/
List queryMemberBonusTotalByCondition(BonusParam bonusParam);
@@ -42,9 +31,6 @@ public interface CuMemberBonusMapper extends BaseMapper {
* 根据查询条件查询会员奖金
*
* @param bonusParam 查询条件
- * @return: List
- * @Author: sui q
- * @Date: 2023/1/13 11:27
*/
List queryMemberBonusByCondition(BonusParam bonusParam);
@@ -52,30 +38,19 @@ public interface CuMemberBonusMapper extends BaseMapper {
* 根据查询条件查询会员奖金
*
* @param bonusParam 查询条件
- * @return: List
- * @Author: sui q
- * @Date: 2023/1/13 11:27
*/
List queryMemberBonusByConditionForServer(@Param("bonusParam") BonusParam bonusParam);
/**
- * @description: 查询奖金明细合计(最后一行)
- * @author: zhang jing
- * @date: 2024/10/12 14:06
- * @param: [bonusParam]
- * @return: com.hzs.common.domain.member.ext.CuMemberBonusExt
+ * 查询奖金明细合计(最后一行)
**/
CuMemberBonusExt queryMemberBonusByConditionForServerSum(@Param("bonusParam") BonusParam bonusParam);
-
/**
* 根据查询条件查询会员奖金
*
* @param bonusParam 查询条件
- * @return: List
- * @Author: sui q
- * @Date: 2023/1/13 11:27
*/
List queryBonusTotalVoByConditionForServer(@Param("bonusParam") BonusParam bonusParam);
@@ -83,9 +58,6 @@ public interface CuMemberBonusMapper extends BaseMapper {
* 删除会员奖金汇总表
*
* @param period 结算期间
- * @return: void
- * @Author: sui q
- * @Date: 2022/12/13 11:54
*/
void deleteCuMemberBonus(Integer period);
@@ -93,9 +65,6 @@ public interface CuMemberBonusMapper extends BaseMapper {
* 批量插入会员奖金主表
*
* @param cuMemberBonusList 会员奖金
- * @return: void
- * @Author: sui q
- * @Date: 2022/12/13 13:56
*/
void batchInsertCuMemberBonus(@Param("cuMemberBonusList") List> cuMemberBonusList);
@@ -103,9 +72,6 @@ public interface CuMemberBonusMapper extends BaseMapper {
* 批量插入会员奖金主表
*
* @param cuMemberBonusList 会员奖金
- * @return: void
- * @Author: sui q
- * @Date: 2022/12/13 13:56
*/
void insertOrUpdateCuMemberBonus(@Param("cuMemberBonusList") List cuMemberBonusList);
@@ -114,28 +80,19 @@ public interface CuMemberBonusMapper extends BaseMapper {
*
* @param grantStatus 发放状态
* @param oldGrantStatus 原来的发放状态
- * @return: Boolean
- * @Author: sui q
- * @Date: 2023/3/20 17:21
*/
Integer updateCuMemberBonusStatus(@Param("pkCountry") Integer pkCountry, @Param("grantStatus") Integer grantStatus,
@Param("oldGrantStatus") Integer oldGrantStatus, @Param("startPeriod") Integer startPeriod,
@Param("endPeriod") Integer endPeriod);
- /*
- * @description: 回退极差奖金
- * @author: sui q
- * @date: 2024/12/25 17:06
- * @param: null null
- **/
+ /**
+ * 回退极差奖金
+ */
void mergeBackRangeBonusIncome(@Param("pkOrder") Long pkOrder, @Param("bonusValue") Integer bonusValue);
- /*
- * @description: 查询会员一周周期的拓展累计,复购拓展累计
- * @author: sui q
- * @date: 2023/7/15 14:26
- * @param: null null
- **/
+ /**
+ * 查询会员一周周期的拓展累计,复购拓展累计
+ */
List queryWeekMemberBonus(@Param("startPeriod") int startPeriod, @Param("endPeriod") int endPeriod);
void recalculateTeamNewBoxNum(@Param("pkId") Long pkId, @Param("retailsTableName") String retailsTableName);
diff --git a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/param/BonusParam.java b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/param/BonusParam.java
index 2239ad88..65fafe0f 100644
--- a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/param/BonusParam.java
+++ b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/param/BonusParam.java
@@ -2,17 +2,12 @@ package com.hzs.bonus.bonus.param;
import com.hzs.common.core.web.domain.BaseAuthorityEntity;
import lombok.Data;
+import lombok.EqualsAndHashCode;
import java.util.Date;
import java.util.List;
-/**
- * @Description:
- * @Author: sui q
- * @Time: 2023/1/13 9:44
- * @Classname: BonusParam
- * @PackageName: com.hzs.member.bonus.param
- */
+@EqualsAndHashCode(callSuper = true)
@Data
public class BonusParam extends BaseAuthorityEntity {
diff --git a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/service/impl/CuMemberBonusServiceImpl.java b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/service/impl/CuMemberBonusServiceImpl.java
index f7a3f627..9cc77e1e 100644
--- a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/service/impl/CuMemberBonusServiceImpl.java
+++ b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/bonus/service/impl/CuMemberBonusServiceImpl.java
@@ -56,10 +56,10 @@ public class CuMemberBonusServiceImpl extends ServiceImpl handleMemberBonusPurchase(List cuMemberBonusExtList, BonusParam bonusParam, String value) {
@@ -211,16 +211,10 @@ public class CuMemberBonusServiceImpl extends ServiceImpl queryMemberSecondBonusVoByCondition(BonusParam bonusParam) {
- String value = iSystemConfigServiceApi.getBonusSystemConfig(bonusParam.getPkCountry(), ESystemConfig.EXPAND_CAP_METHOD.getKey()).getData();
-// if (StringUtils.isNotEmpty(value) && Objects.equals(Integer.toString(EExpandCapMethod.WEEK_SETTLE.getValue()), value)) {
-// // 周结的话不能查询当前周的数据,只能查询上周的数据
-// bonusParam.setStartDate(DateUtils.parseStringToDate(DateUtils.getRecentlyTuesday(bonusParam.getStartDate())));
-// bonusParam.setEndDate(DateUtils.parseStringToDate(DateUtils.getRecentlyMonday(bonusParam.getStartDate())));
-// }
- return getCuMemberBonusExtList(bonusParam, value);
+ return getCuMemberBonusExtList(bonusParam);
}
- private List getCuMemberBonusExtList(BonusParam bonusParam, String value) {
+ private List getCuMemberBonusExtList(BonusParam bonusParam) {
if (bonusParam.getGrantStatus() == null) {
bonusParam.setGrantStatus(EGrantStatus.PUBLISHED.getValue());
}
@@ -241,20 +235,11 @@ public class CuMemberBonusServiceImpl extends ServiceImpl> weekDateMap = new TreeMap<>();
-// // 计算周开始和结束
-// for (CuMemberBonusExt cuMemberBonusExt : cuMemberBonusExtList) {
-// String startDateStr = DateUtils.getRecentlyTuesday(cuMemberBonusExt.getSettleDate());
-// if (weekDateMap.containsKey(startDateStr)) {
-// weekDateMap.get(startDateStr).add(cuMemberBonusExt);
-// } else {
-// List cuMemberBonusExtList1 = new ArrayList<>();
-// cuMemberBonusExtList1.add(cuMemberBonusExt);
-// weekDateMap.put(startDateStr, cuMemberBonusExtList1);
-// }
-// }
-// List cuMemberBonusExtList1 = new ArrayList<>();
-// for (String key : weekDateMap.keySet()) {
-// CuMemberBonusExt cuMemberBonusExt = initCuMemberBonus();
-// cuMemberBonusExt.setSettleDate(DateUtils.parseStringToDate(key));
-// cuMemberBonusExt.setEndSettleDate(DateUtils.afterDate(6, ChronoUnit.DAYS, cuMemberBonusExt.getSettleDate()));
-// for (CuMemberBonusExt memberBonusExt : weekDateMap.get(key)) {
-// calculateBonusTotal(cuMemberBonusExt, memberBonusExt);
-// }
-// cuMemberBonusExtList1.add(cuMemberBonusExt);
-// }
-// return cuMemberBonusExtList1;
-// }
return cuMemberBonusExtList;
}
@@ -327,13 +287,7 @@ public class CuMemberBonusServiceImpl extends ServiceImpl queryMemberBonusTotalByCondition(BonusParam bonusParam) {
- String value = iSystemConfigServiceApi.getBonusSystemConfig(bonusParam.getPkCountry(), ESystemConfig.EXPAND_CAP_METHOD.getKey()).getData();
- if (StringUtils.isNotEmpty(value) && Objects.equals(Integer.toString(EExpandCapMethod.WEEK_SETTLE.getValue()), value)) {
- // 周结的话不能查询当前周
- bonusParam.setEndDate(DateUtils.parseStringToDate(DateUtils.getRecentlyTuesday(bonusParam.getEndDate())));
- bonusParam.setStartDate(DateUtils.beforeDate(7, ChronoUnit.DAYS, bonusParam.getEndDate()));
- }
- return getCuMemberBonusExtList(bonusParam, value);
+ return getCuMemberBonusExtList(bonusParam);
}
@Override
@@ -706,6 +660,7 @@ public class CuMemberBonusServiceImpl extends ServiceImpl
* 新零售会员区域考核 前端控制器
- *
- *
- * @author hzs
- * @since 2025-01-13
*/
@RestController
@RequestMapping("/manage/region")
@@ -58,6 +40,7 @@ public class CuRegionAssessController extends BaseController {
/**
* 考核
* 考核默认考核当月
+ *
* @return AjaxResult
*/
@GetMapping("/examine")
@@ -72,7 +55,7 @@ public class CuRegionAssessController extends BaseController {
* 查询会员昨天奖金的值
*/
@PostMapping("/query")
- public TableDataInfo listRegionAssess(@RequestBody CuRegionAssessParam cuRegionAssessParam){
+ public TableDataInfo listRegionAssess(@RequestBody CuRegionAssessParam cuRegionAssessParam) {
startPage();
cuRegionAssessParam.setPkCountry(SecurityUtils.getPkCountry());
List cuRegionAssessExtList = regionAssessService.queryRegionAssessByCondition(cuRegionAssessParam);
@@ -86,7 +69,7 @@ public class CuRegionAssessController extends BaseController {
* 分页查询会员某个时间段内的奖金汇总
*/
@PostMapping("/export")
- public void exportRegionAssess(HttpServletResponse response, CuRegionAssessParam cuRegionAssessParam){
+ public void exportRegionAssess(HttpServletResponse response, CuRegionAssessParam cuRegionAssessParam) {
List cuRegionAssessExtList = regionAssessService.queryRegionAssessByCondition(cuRegionAssessParam);
List cuRegionAssessVoList = new ArrayList<>();
for (CuRegionAssessExt cuRegionAssessExt : cuRegionAssessExtList) {
diff --git a/bd-business/bd-business-bonus/src/main/resources/mapper/bonus/bonus/CuMemberBonusMapper.xml b/bd-business/bd-business-bonus/src/main/resources/mapper/bonus/bonus/CuMemberBonusMapper.xml
index a111573f..5e6ca989 100644
--- a/bd-business/bd-business-bonus/src/main/resources/mapper/bonus/bonus/CuMemberBonusMapper.xml
+++ b/bd-business/bd-business-bonus/src/main/resources/mapper/bonus/bonus/CuMemberBonusMapper.xml
@@ -272,21 +272,40 @@