From 9de0bc4690f05f5aab5b084bb5bc7d549731704d Mon Sep 17 00:00:00 2001
From: cabbage <281119120@qq.com>
Date: Thu, 26 Jun 2025 13:56:47 +0800
Subject: [PATCH] =?UTF-8?q?##=20=E6=B3=A8=E6=B0=B4=E5=A4=84=E7=90=86?=
=?UTF-8?q?=E5=8F=AA=E4=BF=9D=E7=95=99=E5=B7=A6=E5=8F=B3=E5=8C=BA=E4=B8=9A?=
=?UTF-8?q?=E7=BB=A9=E5=92=8C=E7=BB=93=E4=BD=99=E5=A4=84=E7=90=86=EF=BC=9B?=
=?UTF-8?q?=E9=83=A8=E5=88=86=E6=9E=9A=E4=B8=BE=E5=8E=BB=E6=8E=89=E5=9B=BD?=
=?UTF-8?q?=E9=99=85=E5=8C=96=EF=BC=9B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../bonus/base/vo/CuMemberAchieveLogVO.java | 34 +--
.../manage/CuMemberAchieveLogController.java | 210 ++-------------
.../impl/CuMemberAchieveLogServiceImpl.java | 240 +++++++-----------
.../base/vo/CuMemberAchieveLogImportVO.java | 35 ++-
.../member/base/vo/CuMemberAchieveLogVO.java | 80 +++---
.../member/base/CuMemberAchieveLogMapper.xml | 15 +-
.../enums/controller/EnumsController.java | 55 +---
.../enums/controller/EnumsInitController.java | 18 +-
.../core/constant/EnumsPrefixConstants.java | 78 ------
.../common/core/enums/EActivityStatus.java | 21 +-
.../com/hzs/common/core/enums/EBatchType.java | 9 +-
.../common/core/enums/EInfusingWaterType.java | 33 ++-
.../hzs/common/core/enums/EMemberAchieve.java | 51 ++--
.../hzs/common/core/enums/EProcessType.java | 6 +-
14 files changed, 253 insertions(+), 632 deletions(-)
diff --git a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/base/vo/CuMemberAchieveLogVO.java b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/base/vo/CuMemberAchieveLogVO.java
index 5509455b..a7b99e5b 100644
--- a/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/base/vo/CuMemberAchieveLogVO.java
+++ b/bd-business/bd-business-bonus/src/main/java/com/hzs/bonus/base/vo/CuMemberAchieveLogVO.java
@@ -7,6 +7,7 @@ import com.hzs.common.core.constant.EnumsPrefixConstants;
import com.hzs.common.core.web.domain.BaseApprovalEntity;
import com.hzs.member.account.dto.MemberAmountDTO;
import lombok.Data;
+import lombok.EqualsAndHashCode;
import java.math.BigDecimal;
import java.util.Date;
@@ -14,13 +15,9 @@ import java.util.List;
import java.util.Set;
/**
- *
* 注水业绩记录表VO
- *
- *
- * @author hzs
- * @since 2022-08-22
*/
+@EqualsAndHashCode(callSuper = true)
@Data
public class CuMemberAchieveLogVO extends BaseApprovalEntity {
@@ -56,7 +53,6 @@ public class CuMemberAchieveLogVO extends BaseApprovalEntity {
/**
* 注水方式 EInfusingWaterType 1 增加 2减少 3 最终
*/
- @Transaction(transactionKey = EnumsPrefixConstants.INFUSING_WATER_TYPE)
private Integer infusingWaterType;
@Excel(name = "注水方式")
private String infusingWaterTypeVal;
@@ -64,52 +60,52 @@ public class CuMemberAchieveLogVO extends BaseApprovalEntity {
* 变更后A左区累计 变更后左区真实业绩
*/
@Excel(name = "变更后左区真实业绩(PV)")
- private BigDecimal asumRealModifyPv=BigDecimal.ZERO;
+ private BigDecimal asumRealModifyPv = BigDecimal.ZERO;
/**
* 变更后B右区累计 更后右区真实业绩
*/
@Excel(name = "变更后右区真实业绩(PV)")
- private BigDecimal bsumRealModifyPv=BigDecimal.ZERO;
+ private BigDecimal bsumRealModifyPv = BigDecimal.ZERO;
/**
* 变更后A左区 变更后左区首购业绩
*/
@Excel(name = "变更后左区首购业绩(PV)")
- private BigDecimal afirstModifyPv=BigDecimal.ZERO;
+ private BigDecimal afirstModifyPv = BigDecimal.ZERO;
/**
* 变更后B右区 变更后右区首购业绩
*/
@Excel(name = "变更后右区首购业绩(PV)")
- private BigDecimal bfirstModifyPv=BigDecimal.ZERO;
+ private BigDecimal bfirstModifyPv = BigDecimal.ZERO;
/**
* 变更后A左区首购结余
*/
@Excel(name = "变更后左区首购结余")
- private BigDecimal repAFirstModifyBalance=BigDecimal.ZERO;
+ private BigDecimal repAFirstModifyBalance = BigDecimal.ZERO;
/**
* 变更后B右区首购结余
*/
@Excel(name = "变更后右区首购结余")
- private BigDecimal repBFirstModifyBalance=BigDecimal.ZERO;
+ private BigDecimal repBFirstModifyBalance = BigDecimal.ZERO;
/**
* 变更后A左区复购业绩累计业绩
*/
@Excel(name = "变更后左区复购业绩(PV)")
- private BigDecimal repAModifySumPv=BigDecimal.ZERO;
+ private BigDecimal repAModifySumPv = BigDecimal.ZERO;
/**
* 变更后B右区复购业绩累计业绩
*/
@Excel(name = "变更后右区复购业绩(PV)")
- private BigDecimal repBModifySumPv=BigDecimal.ZERO;
+ private BigDecimal repBModifySumPv = BigDecimal.ZERO;
/**
* 变更后A左区复购结余
*/
@Excel(name = "变更后左区复购结余")
- private BigDecimal repAModifyBalance=BigDecimal.ZERO;
+ private BigDecimal repAModifyBalance = BigDecimal.ZERO;
/**
* 变更后B右区复购结余
*/
@Excel(name = "变更后右区复购结余")
- private BigDecimal repBModifyBalance=BigDecimal.ZERO;
+ private BigDecimal repBModifyBalance = BigDecimal.ZERO;
/**
* A左区累计 左区真实业绩
*/
@@ -190,7 +186,6 @@ public class CuMemberAchieveLogVO extends BaseApprovalEntity {
/**
* 注水状态 EActivityStatus 0 未开始 1 进行中 2 已结束
*/
- @Transaction(transactionKey = EnumsPrefixConstants.ACTIVITY_STATUS)
private Integer waterStatus;
@Excel(name = "注水状态")
private String waterStatusVal;
@@ -324,7 +319,6 @@ public class CuMemberAchieveLogVO extends BaseApprovalEntity {
private Date endDueDate;
-
/**
* 修改时间
*/
@@ -347,8 +341,4 @@ public class CuMemberAchieveLogVO extends BaseApprovalEntity {
private String tableName;
-
-
-
-
}
diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/controller/manage/CuMemberAchieveLogController.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/controller/manage/CuMemberAchieveLogController.java
index d235ead3..10a345c9 100644
--- a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/controller/manage/CuMemberAchieveLogController.java
+++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/controller/manage/CuMemberAchieveLogController.java
@@ -4,7 +4,6 @@ import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import com.hzs.common.core.annotation.AccessPermissions;
import com.hzs.common.core.annotation.Log;
-import com.hzs.common.core.constant.CountryConstants;
import com.hzs.common.core.constant.EnumsPrefixConstants;
import com.hzs.common.core.constant.TableNameConstants;
import com.hzs.common.core.constant.msg.ConfigMsgConstants;
@@ -31,8 +30,6 @@ import com.hzs.member.base.service.ICuMemberService;
import com.hzs.member.base.vo.CuMemberAchieveLogImportVO;
import com.hzs.member.base.vo.CuMemberAchieveLogVO;
import com.hzs.member.base.vo.UpdateCodeVO;
-import com.hzs.system.base.ICurrencyServiceApi;
-import com.hzs.system.base.dto.CurrencyDTO;
import com.hzs.system.config.IServiceChargeServiceApi;
import com.hzs.system.config.dto.ServiceChargeDTO;
import org.apache.dubbo.config.annotation.DubboReference;
@@ -67,8 +64,6 @@ public class CuMemberAchieveLogController extends BaseController {
@DubboReference
IServiceChargeServiceApi iServiceChargeServiceApi;
- @DubboReference
- ICurrencyServiceApi iCurrencyServiceApi;
/**
* 特殊业务-注水业绩记录查询
@@ -77,74 +72,12 @@ public class CuMemberAchieveLogController extends BaseController {
@Log(module = EOperationModule.SPECIAL_BUSINESS, business = EOperationBusiness.MODIFY_ACHIEVEMENT, method = EOperationMethod.SELECT)
@GetMapping("/list")
public TableDataInfo achieveLogList(CuMemberAchieveLogVO cuMemberAchieveLogVO) {
- startPage();
cuMemberAchieveLogVO.setPkCountry(SecurityUtils.getPkCountry());
- R currency = iCurrencyServiceApi.getCurrency(SecurityUtils.getPkCountry());
+ startPage();
List list = iCuMemberAchieveLogService.queryMemberAchieveLogList(cuMemberAchieveLogVO);
if (CollectionUtil.isNotEmpty(list)) {
for (CuMemberAchieveLogVO cma : list) {
- if (SecurityUtils.getPkCountry().equals(CountryConstants.CHINA_COUNTRY)) {
- if (cma.getAsumRealModifyPv() != null) {
- cma.setAsumRealModifyPv(cma.getAsumRealModifyPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getBsumRealModifyPv() != null) {
- cma.setBsumRealModifyPv(cma.getBsumRealModifyPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getAfirstModifyPv() != null) {
- cma.setAfirstModifyPv(cma.getAfirstModifyPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getBfirstModifyPv() != null) {
- cma.setBfirstModifyPv(cma.getBfirstModifyPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepAFirstModifyBalance() != null) {
- cma.setRepAFirstModifyBalance(cma.getRepAFirstModifyBalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepBFirstModifyBalance() != null) {
- cma.setRepBFirstModifyBalance(cma.getRepBFirstModifyBalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepAModifySumPv() != null) {
- cma.setRepAModifySumPv(cma.getRepAModifySumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepBModifySumPv() != null) {
- cma.setRepBModifySumPv(cma.getRepBModifySumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepAModifyBalance() != null) {
- cma.setRepAModifyBalance(cma.getRepAModifyBalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepBModifyBalance() != null) {
- cma.setRepBModifyBalance(cma.getRepBModifyBalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getAsumRealPv() != null) {
- cma.setAsumRealPv(cma.getAsumRealPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getBsumRealPv() != null) {
- cma.setBsumRealPv(cma.getBsumRealPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getAsumPv() != null) {
- cma.setAsumPv(cma.getAsumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getBsumPv() != null) {
- cma.setBsumPv(cma.getBsumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getAbalance() != null) {
- cma.setAbalance(cma.getAbalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getBbalance() != null) {
- cma.setBbalance(cma.getBbalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepASumPv() != null) {
- cma.setRepASumPv(cma.getRepASumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepBSumPv() != null) {
- cma.setRepBSumPv(cma.getRepBSumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepABalance() != null) {
- cma.setRepABalance(cma.getRepABalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepBBalance() != null) {
- cma.setRepBBalance(cma.getRepBBalance().multiply(currency.getData().getInExchangeRate()));
- }
- }
+ cma.setInfusingWaterTypeVal(EInfusingWaterType.getLabelByValue(cma.getInfusingWaterType()));
// 判断注水状态
// 开始时间
long startTime = cma.getSettleDate().getTime();
@@ -174,79 +107,14 @@ public class CuMemberAchieveLogController extends BaseController {
@PostMapping("/export")
public void export(HttpServletResponse response, CuMemberAchieveLogVO cuMemberAchieveLogVO) {
startPage();
- R currency = iCurrencyServiceApi.getCurrency(SecurityUtils.getPkCountry());
List list = iCuMemberAchieveLogService.queryMemberAchieveLogList(cuMemberAchieveLogVO);
if (CollectionUtil.isNotEmpty(list)) {
//枚举翻译
- Map transactionMap = iTransactionCommonService.exportEnumTransaction(EInfusingWaterType.values());
- Map transactionMap1 = iTransactionCommonService.exportEnumTransactionByDB(
- EnumsPrefixConstants.KEY_AWARD);
+ Map transactionMap1 = iTransactionCommonService.exportEnumTransactionByDB(EnumsPrefixConstants.KEY_AWARD);
for (CuMemberAchieveLogVO cma : list) {
- //中国把美元转成人民币
- if (SecurityUtils.getPkCountry().equals(CountryConstants.CHINA_COUNTRY)) {
- if (cma.getAsumRealModifyPv() != null) {
- cma.setAsumRealModifyPv(cma.getAsumRealModifyPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getBsumRealModifyPv() != null) {
- cma.setBsumRealModifyPv(cma.getBsumRealModifyPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getAfirstModifyPv() != null) {
- cma.setAfirstModifyPv(cma.getAfirstModifyPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getBfirstModifyPv() != null) {
- cma.setBfirstModifyPv(cma.getBfirstModifyPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepAFirstModifyBalance() != null) {
- cma.setRepAFirstModifyBalance(cma.getRepAFirstModifyBalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepBFirstModifyBalance() != null) {
- cma.setRepBFirstModifyBalance(cma.getRepBFirstModifyBalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepAModifySumPv() != null) {
- cma.setRepAModifySumPv(cma.getRepAModifySumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepBModifySumPv() != null) {
- cma.setRepBModifySumPv(cma.getRepBModifySumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepAModifyBalance() != null) {
- cma.setRepAModifyBalance(cma.getRepAModifyBalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepBModifyBalance() != null) {
- cma.setRepBModifyBalance(cma.getRepBModifyBalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getAsumRealPv() != null) {
- cma.setAsumRealPv(cma.getAsumRealPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getBsumRealPv() != null) {
- cma.setBsumRealPv(cma.getBsumRealPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getAsumPv() != null) {
- cma.setAsumPv(cma.getAsumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getBsumPv() != null) {
- cma.setBsumPv(cma.getBsumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getAbalance() != null) {
- cma.setAbalance(cma.getAbalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getBbalance() != null) {
- cma.setBbalance(cma.getBbalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepASumPv() != null) {
- cma.setRepASumPv(cma.getRepASumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepBSumPv() != null) {
- cma.setRepBSumPv(cma.getRepBSumPv().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepABalance() != null) {
- cma.setRepABalance(cma.getRepABalance().multiply(currency.getData().getInExchangeRate()));
- }
- if (cma.getRepBBalance() != null) {
- cma.setRepBBalance(cma.getRepBBalance().multiply(currency.getData().getInExchangeRate()));
- }
- }
- cma.setInfusingWaterTypeVal(transactionMap.get(EnumsPrefixConstants.INFUSING_WATER_TYPE + cma.getInfusingWaterType()));
+ cma.setInfusingWaterTypeVal(EInfusingWaterType.getLabelByValue(cma.getInfusingWaterType()));
cma.setAwardsVal(transactionMap1.get(cma.getAwards()));
+
// 判断注水状态
// 开始时间
long startTime = cma.getSettleDate().getTime();
@@ -268,7 +136,6 @@ public class CuMemberAchieveLogController extends BaseController {
}
ExcelUtil util = new ExcelUtil<>(CuMemberAchieveLogVO.class);
util.exportExcel(response, list, "注水业绩");
-
}
/**
@@ -280,13 +147,11 @@ public class CuMemberAchieveLogController extends BaseController {
List list = new ArrayList<>();
ExcelUtil util = new ExcelUtil<>(CuMemberAchieveLogImportVO.class);
util.exportExcel(response, list, "注水业绩");
-
}
/**
* 查询会员当期业绩
**/
- @Log(module = EOperationModule.SPECIAL_BUSINESS, business = EOperationBusiness.MODIFY_ACHIEVEMENT, method = EOperationMethod.SELECT)
@GetMapping("/searchList")
public AjaxResult searchList(CuMemberAchieveLogVO cuMemberAchieveLogVO) {
if (StringUtils.isEmpty(cuMemberAchieveLogVO.getMemberCode())) {
@@ -295,16 +160,18 @@ public class CuMemberAchieveLogController extends BaseController {
UpdateCodeVO updateCodeVO = BeanUtil.copyProperties(cuMemberAchieveLogVO, UpdateCodeVO.class);
updateCodeVO = iCuMemberService.specialBusinessQuery(updateCodeVO);
Integer pkCountry = SecurityUtils.getPkCountry();
- Integer maxSecond = iCuMemberAchieveLogService.selectByMaxApproveNumber(updateCodeVO.getPkId(), EApproveStatus.FINISH.getValue());
+
//查询扣费金额,账户信息
ServiceChargeDTO serviceChargeDTO = new ServiceChargeDTO();
serviceChargeDTO.setType(EApprovalBusiness.MEMBER_ACHIEVE.getValue());
- serviceChargeDTO.setQuantity(maxSecond + 1);
+ serviceChargeDTO.setQuantity(1);
serviceChargeDTO.setPkCountry(pkCountry);
R serviceChargeDTOR = iServiceChargeServiceApi.getServiceChargeByType(serviceChargeDTO);
+
updateCodeVO.setCost(serviceChargeDTOR.getData().getCost());
updateCodeVO.setPkAccount(serviceChargeDTOR.getData().getPkAccount());
updateCodeVO.setPkAccountKey(iCuMemberBaseService.translateAccountValue(serviceChargeDTOR.getData().getPkAccount()));
+
cuMemberAchieveLogVO = BeanUtil.copyProperties(updateCodeVO, CuMemberAchieveLogVO.class);
cuMemberAchieveLogVO.setPkMember(updateCodeVO.getPkId());
List list = new ArrayList<>();
@@ -331,8 +198,7 @@ public class CuMemberAchieveLogController extends BaseController {
tableName = TableNameConstants.CU_MEMBER_ACHIEVE + month;
}
//查询最新期数
- int period = iCuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(
- DateUtils.parseDateToStr(datestr)).getPkId();
+ int period = iCuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(DateUtils.parseDateToStr(datestr)).getPkId();
cuMemberAchieveLogVO.setTableName(tableName);
cuMemberAchieveLogVO.setPeriod(period);
List calList = new ArrayList<>();
@@ -414,16 +280,14 @@ public class CuMemberAchieveLogController extends BaseController {
if (StringUtils.isNull(cuMemberAchieveLogVO.getInfusingWaterType())) {
return AjaxResult.error(TransactionUtils.getContent(ConfigMsgConstants.INFUSING_WATER_TYPE_NOT_NULL));
}
- if (StringUtils.isNull(cuMemberAchieveLogVO.getProcessType())) {
- return AjaxResult.error(TransactionUtils.getContent(ConfigMsgConstants.PROCESS_TYPE_NOT_NULL));
- }
- List errorList = new ArrayList<>();
+
+ // 返回VO
CuMemberAchieveLogVO memberAchieveLogVONew;
- Integer pkCountry = SecurityUtils.getPkCountry();
- List memberAmountDTOList = new ArrayList<>();
+
+ List errorList = new ArrayList<>();
Set pkMemberList = new HashSet<>();
+
if (CollectionUtil.isNotEmpty(cuMemberAchieveLogVO.getCmalvList())) {
- BusinessCommissionDTO businessCommissionDTO = new BusinessCommissionDTO();
for (CuMemberAchieveLogVO cmal : cuMemberAchieveLogVO.getCmalvList()) {
if (StringUtils.isNull(cmal.getSettleDate())) {
cmal.setErrorMsg(TransactionUtils.getContent(ConfigMsgConstants.SETTLEDATE_NOT_VALID));
@@ -469,16 +333,12 @@ public class CuMemberAchieveLogController extends BaseController {
}
cmal.setSettleDateStr(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, cmal.getSettleDate()));
cmal.setDueDateStr(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, cmal.getDueDate()));
- if (StringUtils.isNull(cmal.getAsumRealModifyPv())
- && StringUtils.isNull(cmal.getBsumRealModifyPv())
- && StringUtils.isNull(cmal.getAfirstModifyPv())
+
+ if (StringUtils.isNull(cmal.getAfirstModifyPv())
&& StringUtils.isNull(cmal.getBfirstModifyPv())
&& StringUtils.isNull(cmal.getRepAFirstModifyBalance())
&& StringUtils.isNull(cmal.getRepBFirstModifyBalance())
- && StringUtils.isNull(cmal.getRepAModifyBalance())
- && StringUtils.isNull(cmal.getRepBModifyBalance())
- && StringUtils.isNull(cmal.getRepAModifySumPv())
- && StringUtils.isNull(cmal.getRepBModifySumPv())) {
+ ) {
return AjaxResult.error(TransactionUtils.getContent(ConfigMsgConstants.INFUSING_WATER_PV_NOT_NULL));
}
@@ -495,50 +355,18 @@ public class CuMemberAchieveLogController extends BaseController {
continue;
}
- Integer maxSecond = iCuMemberAchieveLogService.selectByMaxApproveNumber(cmal.getPkMember(), EApproveStatus.FINISH.getValue());
- cmal.setApproveNumber(maxSecond + 1);
- if (cuMemberAchieveLogVO.getProcessType() == EProcessType.AVOIDSIGNING.getValue() ||
- cuMemberAchieveLogVO.getProcessType() == EProcessType.DOUBLEPAY.getValue()) {
- //查询扣费金额,账户信息
- ServiceChargeDTO serviceChargeDTO = new ServiceChargeDTO();
- serviceChargeDTO.setType(EApprovalBusiness.MEMBER_ACHIEVE.getValue());
- serviceChargeDTO.setQuantity(maxSecond + 1);
- serviceChargeDTO.setPkCountry(pkCountry);
- R serviceChargeDTOR = iServiceChargeServiceApi.getServiceChargeByType(serviceChargeDTO);
- //接口查询金额是否足够
- businessCommissionDTO.setPkAccount(serviceChargeDTOR.getData().getPkAccount());
- businessCommissionDTO.setPkCountry(pkCountry);
- MemberAmountDTO memberAmountDTO = new MemberAmountDTO();
- memberAmountDTO.setPkMember(cmal.getPkMember());
- memberAmountDTO.setTradeAmount(serviceChargeDTOR.getData().getCost());
- cmal.setCost(serviceChargeDTOR.getData().getCost());
- cmal.setPkAccount(serviceChargeDTOR.getData().getPkAccount());
- cmal.setPkAccountKey(iCuMemberBaseService.translateAccountValue(serviceChargeDTOR.getData().getPkAccount()));
- memberAmountDTOList.add(memberAmountDTO);
- }
pkMemberList.add(cmal.getPkMember());
}
if (CollectionUtil.isNotEmpty(errorList)) {
return AjaxResult.error(504, ConfigMsgConstants.MEMBER_DATA_ERROR, errorList);
}
cuMemberAchieveLogVO.setPkMemberList(pkMemberList);
+
List achieveList = iCuMemberAchieveLogService.checkAchieveList(cuMemberAchieveLogVO);
if (CollectionUtil.isNotEmpty(achieveList)) {
achieveList.forEach(itm -> itm.setErrorMsg(TransactionUtils.getContent(ConfigMsgConstants.MEMBER_UPDATE_CODE_REPEAT)));
return AjaxResult.error(504, ConfigMsgConstants.MEMBER_DATA_ERROR, achieveList);
}
- if (CollectionUtil.isNotEmpty(memberAmountDTOList)) {
- businessCommissionDTO.setMemberAmountDTOList(memberAmountDTOList);
- cuMemberAchieveLogVO.setMemberAmountDTOList(memberAmountDTOList);
- cuMemberAchieveLogVO.setPkCountry(pkCountry);
- //接口查询金额是否足够
- List memberBalanceList = iCuMemberTradeService.selectBalanceNotEnoughMember(businessCommissionDTO);
- if (CollectionUtil.isNotEmpty(memberBalanceList)) {
- memberBalanceList.forEach(item -> errorList.add(BeanUtil.copyProperties(item, CuMemberAchieveLogVO.class)));
- errorList.forEach(itm2 -> itm2.setErrorMsg(TransactionUtils.getContent(ConfigMsgConstants.MEMBER_BALANCE_INSUFFICIENT)));
- return AjaxResult.error(504, ConfigMsgConstants.MEMBER_DATA_ERROR, errorList);
- }
- }
memberAchieveLogVONew = iCuMemberAchieveLogService.infusingWater(cuMemberAchieveLogVO);
} else {
return AjaxResult.error(TransactionUtils.getContent(ConfigMsgConstants.MEMBER_DATA_NOT_NULL));
diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberAchieveLogServiceImpl.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberAchieveLogServiceImpl.java
index 5d6d3f98..c900060c 100644
--- a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberAchieveLogServiceImpl.java
+++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberAchieveLogServiceImpl.java
@@ -47,20 +47,20 @@ import java.util.*;
public class CuMemberAchieveLogServiceImpl extends ServiceImpl implements ICuMemberAchieveLogService {
@Autowired
- private ICuMemberSettlePeriodService cuMemberSettlePeriodService;
+ private ICuMemberSettlePeriodService iCuMemberSettlePeriodService;
@Autowired
- private ICuMemberTradeService cuMemberTradeService;
+ private ICuMemberTradeService iCuMemberTradeService;
@Autowired
private UserTokenService userTokenService;
@Autowired
private RabbitTemplate rabbitTemplate;
@Autowired
- private ICuMemberAchieveLogService cuMemberAchieveLogService;
+ private ICuMemberAchieveLogService iCuMemberAchieveLogService;
@DubboReference
- IApprovalServiceApi approvalServiceApi;
+ IApprovalServiceApi iApprovalServiceApi;
@DubboReference
- ICurrencyServiceApi currencyServiceApi;
+ ICurrencyServiceApi iCurrencyServiceApi;
@Override
public List queryMemberAchieveLogList(CuMemberAchieveLogVO cuMemberAchieveLogVO) {
@@ -77,7 +77,7 @@ public class CuMemberAchieveLogServiceImpl extends ServiceImpl queryMemberAchieveHistoryList(List calList) {
List list = baseMapper.queryMemberAchieveHistoryList(calList);
- R currency = currencyServiceApi.getCurrency(SecurityUtils.getPkCountry());
+ R currency = iCurrencyServiceApi.getCurrency(SecurityUtils.getPkCountry());
BigDecimal exchangeRate = SecurityUtils.getPkCountry().equals(CountryConstants.CHINA_COUNTRY) ? currency.getData().getInExchangeRate() : BigDecimal.ONE;
List listnew = new ArrayList<>();
if (CollectionUtil.isNotEmpty(list)) {
@@ -114,168 +114,98 @@ public class CuMemberAchieveLogServiceImpl extends ServiceImpl dtoList = new ArrayList<>();
- R currency = currencyServiceApi.getCurrency(SecurityUtils.getPkCountry());
- //业务单号
+ // 业务单号
String code = CommonUtil.createSerialNumber(EOrderPrefix.MEMBER_ACHIEVE.getValue());
cuMemberAchieveLogVO.setPkAccount(cuMemberAchieveLogVO.getCmalvList().get(0).getPkAccount());
for (CuMemberAchieveLogVO cmal : cuMemberAchieveLogVO.getCmalvList()) {
- //中国区人民币转为美元
- if (pkCountry.equals(CountryConstants.CHINA_COUNTRY)) {
- if (cmal.getAsumRealModifyPv() != null && cmal.getAsumRealModifyPv().compareTo(BigDecimal.ZERO) > 0) {
- cmal.setAsumRealModifyPv(cmal.getAsumRealModifyPv().divide(currency.getData().getInExchangeRate(), 6, RoundingMode.HALF_UP));
- }
- if (cmal.getBsumRealModifyPv() != null && cmal.getBsumRealModifyPv().compareTo(BigDecimal.ZERO) > 0) {
- cmal.setBsumRealModifyPv(cmal.getBsumRealModifyPv().divide(currency.getData().getInExchangeRate(), 6, RoundingMode.HALF_UP));
- }
- if (cmal.getAfirstModifyPv() != null && cmal.getAfirstModifyPv().compareTo(BigDecimal.ZERO) > 0) {
- cmal.setAfirstModifyPv(cmal.getAfirstModifyPv().divide(currency.getData().getInExchangeRate(), 6, RoundingMode.HALF_UP));
- }
- if (cmal.getBfirstModifyPv() != null && cmal.getBfirstModifyPv().compareTo(BigDecimal.ZERO) > 0) {
- cmal.setBfirstModifyPv(cmal.getBfirstModifyPv().divide(currency.getData().getInExchangeRate(), 6, RoundingMode.HALF_UP));
- }
- if (cmal.getRepAFirstModifyBalance() != null && cmal.getRepAFirstModifyBalance().compareTo(BigDecimal.ZERO) > 0) {
- cmal.setRepAFirstModifyBalance(cmal.getRepAFirstModifyBalance().divide(currency.getData().getInExchangeRate(), 6, RoundingMode.HALF_UP));
- }
- if (cmal.getRepBFirstModifyBalance() != null && cmal.getRepBFirstModifyBalance().compareTo(BigDecimal.ZERO) > 0) {
- cmal.setRepBFirstModifyBalance(cmal.getRepBFirstModifyBalance().divide(currency.getData().getInExchangeRate(), 6, RoundingMode.HALF_UP));
- }
- if (cmal.getRepAModifySumPv() != null && cmal.getRepAModifySumPv().compareTo(BigDecimal.ZERO) > 0) {
- cmal.setRepAModifySumPv(cmal.getRepAModifySumPv().divide(currency.getData().getInExchangeRate(), 6, RoundingMode.HALF_UP));
- }
- if (cmal.getRepBModifySumPv() != null && cmal.getRepBModifySumPv().compareTo(BigDecimal.ZERO) > 0) {
- cmal.setRepBModifySumPv(cmal.getRepBModifySumPv().divide(currency.getData().getInExchangeRate(), 6, RoundingMode.HALF_UP));
- }
- if (cmal.getRepAModifyBalance() != null && cmal.getRepAModifyBalance().compareTo(BigDecimal.ZERO) > 0) {
- cmal.setRepAModifyBalance(cmal.getRepAModifyBalance().divide(currency.getData().getInExchangeRate(), 6, RoundingMode.HALF_UP));
- }
- if (cmal.getRepBModifyBalance() != null && cmal.getRepBModifyBalance().compareTo(BigDecimal.ZERO) > 0) {
- cmal.setRepBModifyBalance(cmal.getRepBModifyBalance().divide(currency.getData().getInExchangeRate(), 6, RoundingMode.HALF_UP));
- }
- }
-
- //历史期业绩
+ // 历史期业绩
String datestr = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD, cmal.getSettleDate());
String month = DateUtils.getMonth(datestr);
String tableName = TableNameConstants.CU_MEMBER_ACHIEVE + month;
//查询最新期数
- int period = cuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(
- DateUtils.parseDateToStr(datestr)).getPkId();
+ int period = iCuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(DateUtils.parseDateToStr(datestr)).getPkId();
cuMemberAchieveLogVO.setTableName(tableName);
cuMemberAchieveLogVO.setPeriod(period);
cuMemberAchieveLogVO.setPkMember(cmal.getPkMember());
- List calList = new ArrayList<>();
- calList.add(cuMemberAchieveLogVO);
- calList = cuMemberAchieveLogService.queryMemberAchieveHistoryList(calList);
+ List calList = iCuMemberAchieveLogService.queryMemberAchieveHistoryList(Collections.singletonList(cuMemberAchieveLogVO));
- //免签呈 或 免签呈+免支付
- if (cuMemberAchieveLogVO.getProcessType() == EProcessType.AVOIDSIGNING.getValue() ||
- cuMemberAchieveLogVO.getProcessType() == EProcessType.DOUBLEAVOID.getValue()) {
- CuMemberAchieveLog memberAchieveLog = BeanUtil.copyProperties(cmal, CuMemberAchieveLog.class);
- memberAchieveLog.setASumRealModifyPv(cmal.getAsumRealModifyPv());
- memberAchieveLog.setBSumRealModifyPv(cmal.getBsumRealModifyPv());
- memberAchieveLog.setAFirstModifyPv(cmal.getAfirstModifyPv());
- memberAchieveLog.setBFirstModifyPv(cmal.getBfirstModifyPv());
- memberAchieveLog.setRepAFirstModifyBalance(cmal.getRepAFirstModifyBalance());
- memberAchieveLog.setRepBFirstModifyBalance(cmal.getRepBFirstModifyBalance());
- memberAchieveLog.setRepAModifySumPv(cmal.getRepAModifySumPv());
- memberAchieveLog.setRepBModifySumPv(cmal.getRepBModifySumPv());
- memberAchieveLog.setRepAModifyBalance(cmal.getRepAModifyBalance());
- memberAchieveLog.setRepBModifyBalance(cmal.getRepBModifyBalance());
- memberAchieveLog.setPkCountry(pkCountry);
- memberAchieveLog.setInfusingWaterType(cuMemberAchieveLogVO.getInfusingWaterType());
- memberAchieveLog.setProcessType(cuMemberAchieveLogVO.getProcessType());
- memberAchieveLog.setApproveStatus(EApproveStatus.FINISH.getValue());
- memberAchieveLog.setEditType(EApprovalBusiness.MEMBER_ACHIEVE.getValue());
- memberAchieveLog.setBusinessNo(code);
- memberAchieveLog.setCost(cmal.getCost());
- memberAchieveLog.setPkAccount(cmal.getPkAccount());
- memberAchieveLog.setRemarks(cmal.getRemarks());
- memberAchieveLog.setDueDate(cmal.getDueDate());
- memberAchieveLog.setSettleDate(cmal.getSettleDate());
- memberAchieveLog.setCreationTime(date);
- memberAchieveLog.setPkCreator(userID);
- if (CollectionUtil.isNotEmpty(calList)) {
- memberAchieveLog.setAsumRealPv(calList.get(0).getAsumRealPv());
- memberAchieveLog.setBsumRealPv(calList.get(0).getBsumRealPv());
- memberAchieveLog.setAsumPv(calList.get(0).getAsumPv());
- memberAchieveLog.setBsumPv(calList.get(0).getBsumPv());
- memberAchieveLog.setAbalance(calList.get(0).getAbalance());
- memberAchieveLog.setBbalance(calList.get(0).getBbalance());
- memberAchieveLog.setRepASumPv(calList.get(0).getRepASumPv());
- memberAchieveLog.setRepBSumPv(calList.get(0).getRepBSumPv());
- memberAchieveLog.setRepABalance(calList.get(0).getRepABalance());
- memberAchieveLog.setRepBBalance(calList.get(0).getRepBBalance());
- }
- baseMapper.insert(memberAchieveLog);
- String content = EApprovalBusiness.MEMBER_ACHIEVE.getLabel();
- String waterType = "";
- if (cuMemberAchieveLogVO.getInfusingWaterType() == EInfusingWaterType.ADD.getValue()) {
- waterType = EInfusingWaterType.ADD.getLabel();
- } else if (cuMemberAchieveLogVO.getInfusingWaterType() == EInfusingWaterType.BANK_TRANSFER.getValue()) {
- waterType = EInfusingWaterType.BANK_TRANSFER.getLabel();
- } else if (cuMemberAchieveLogVO.getInfusingWaterType() == EInfusingWaterType.FULL_PV.getValue()) {
- waterType = EInfusingWaterType.FULL_PV.getLabel();
- }
- if (cmal.getAsumRealModifyPv().compareTo(BigDecimal.ZERO) > 0) {
- content = content + " 左区真实业绩" + waterType + ": " + cmal.getAsumRealModifyPv();
- }
- if (cmal.getBsumRealModifyPv().compareTo(BigDecimal.ZERO) > 0) {
- content = content + " 右区真实业绩" + waterType + ": " + cmal.getBsumRealModifyPv();
- }
- if (cmal.getAfirstModifyPv().compareTo(BigDecimal.ZERO) > 0) {
- content = content + " 左区首购业绩" + waterType + ": " + cmal.getAfirstModifyPv();
- }
- if (cmal.getBfirstModifyPv().compareTo(BigDecimal.ZERO) > 0) {
- content = content + " 右区首购业绩" + waterType + ": " + cmal.getBfirstModifyPv();
- }
- if (cmal.getRepAFirstModifyBalance().compareTo(BigDecimal.ZERO) > 0) {
- content = content + " 左区首购结余" + waterType + ": " + cmal.getRepAFirstModifyBalance();
- }
- if (cmal.getRepBFirstModifyBalance().compareTo(BigDecimal.ZERO) > 0) {
- content = content + " 右区首购结余" + waterType + ": " + cmal.getRepBFirstModifyBalance();
- }
- if (cmal.getRepAModifySumPv().compareTo(BigDecimal.ZERO) > 0) {
- content = content + " 左区复购业绩累计业绩" + waterType + ": " + cmal.getRepAModifySumPv();
- }
- if (cmal.getRepBModifySumPv().compareTo(BigDecimal.ZERO) > 0) {
- content = content + " 右区复购业绩累计业绩" + waterType + ": " + cmal.getRepBModifySumPv();
- }
- if (cmal.getRepAModifyBalance().compareTo(BigDecimal.ZERO) > 0) {
- content = content + " 左区复购结余" + waterType + ": " + cmal.getRepAModifyBalance();
- }
- if (cmal.getRepBModifyBalance().compareTo(BigDecimal.ZERO) > 0) {
- content = content + " 右区复购结余" + waterType + ": " + cmal.getRepBModifyBalance();
- }
+ CuMemberAchieveLog memberAchieveLog = BeanUtil.copyProperties(cmal, CuMemberAchieveLog.class);
+ // 2025.06.26 同步北大修改,不要复购业绩等
+ memberAchieveLog.setASumRealModifyPv(cmal.getAfirstModifyPv());
+ memberAchieveLog.setBSumRealModifyPv(cmal.getBfirstModifyPv());
+ memberAchieveLog.setAFirstModifyPv(cmal.getAfirstModifyPv());
+ memberAchieveLog.setBFirstModifyPv(cmal.getBfirstModifyPv());
+ memberAchieveLog.setRepAFirstModifyBalance(cmal.getRepAFirstModifyBalance());
+ memberAchieveLog.setRepBFirstModifyBalance(cmal.getRepBFirstModifyBalance());
+// memberAchieveLog.setRepAModifySumPv(cmal.getRepAModifySumPv());
+// memberAchieveLog.setRepBModifySumPv(cmal.getRepBModifySumPv());
+// memberAchieveLog.setRepAModifyBalance(cmal.getRepAModifyBalance());
+// memberAchieveLog.setRepBModifyBalance(cmal.getRepBModifyBalance());
+ memberAchieveLog.setPkCountry(pkCountry);
+ memberAchieveLog.setInfusingWaterType(cuMemberAchieveLogVO.getInfusingWaterType());
+ memberAchieveLog.setProcessType(cuMemberAchieveLogVO.getProcessType());
+ memberAchieveLog.setApproveStatus(EApproveStatus.FINISH.getValue());
+ memberAchieveLog.setEditType(EApprovalBusiness.MEMBER_ACHIEVE.getValue());
+ memberAchieveLog.setBusinessNo(code);
+ memberAchieveLog.setCost(cmal.getCost());
+ memberAchieveLog.setPkAccount(cmal.getPkAccount());
+ memberAchieveLog.setRemarks(cmal.getRemarks());
+ memberAchieveLog.setDueDate(cmal.getDueDate());
+ memberAchieveLog.setSettleDate(cmal.getSettleDate());
+ memberAchieveLog.setCreationTime(date);
+ memberAchieveLog.setPkCreator(userID);
+ if (CollectionUtil.isNotEmpty(calList)) {
+ memberAchieveLog.setAsumRealPv(calList.get(0).getAsumRealPv());
+ memberAchieveLog.setBsumRealPv(calList.get(0).getBsumRealPv());
+ memberAchieveLog.setAsumPv(calList.get(0).getAsumPv());
+ memberAchieveLog.setBsumPv(calList.get(0).getBsumPv());
+ memberAchieveLog.setAbalance(calList.get(0).getAbalance());
+ memberAchieveLog.setBbalance(calList.get(0).getBbalance());
+// memberAchieveLog.setRepASumPv(calList.get(0).getRepASumPv());
+// memberAchieveLog.setRepBSumPv(calList.get(0).getRepBSumPv());
+// memberAchieveLog.setRepABalance(calList.get(0).getRepABalance());
+// memberAchieveLog.setRepBBalance(calList.get(0).getRepBBalance());
+ }
+ baseMapper.insert(memberAchieveLog);
- //组装日志数据
- BusinessLogDTO businessLog = BusinessLogDTO.builder()
- .businessType(EApprovalBusiness.MEMBER_ACHIEVE.getValue())
- .businessCode(code)
- .pkMember(cmal.getPkMember())
- .content(content)
- .pkCreator(userID)
- .pkCountry(pkCountry)
- .freeSignFlag(true).build();
- dtoList.add(businessLog);
+ String content = EApprovalBusiness.MEMBER_ACHIEVE.getLabel();
+ String waterType = "";
+ if (cuMemberAchieveLogVO.getInfusingWaterType() == EInfusingWaterType.ADD.getValue()) {
+ waterType = EInfusingWaterType.ADD.getLabel();
+ } else if (cuMemberAchieveLogVO.getInfusingWaterType() == EInfusingWaterType.BANK_TRANSFER.getValue()) {
+ waterType = EInfusingWaterType.BANK_TRANSFER.getLabel();
+ } else if (cuMemberAchieveLogVO.getInfusingWaterType() == EInfusingWaterType.FULL_PV.getValue()) {
+ waterType = EInfusingWaterType.FULL_PV.getLabel();
}
- }
- //扣钱
- if (cuMemberAchieveLogVO.getProcessType() == EProcessType.AVOIDSIGNING.getValue()) {
- BusinessCommissionDTO businessCommissionDTO = new BusinessCommissionDTO();
- businessCommissionDTO.setPkCountry(pkCountry);
- businessCommissionDTO.setPkAccount(cuMemberAchieveLogVO.getPkAccount());
- businessCommissionDTO.setMemberAmountDTOList(cuMemberAchieveLogVO.getMemberAmountDTOList());
- businessCommissionDTO.setTradeType(EApprovalBusiness.MEMBER_ACHIEVE.getValue());
- Boolean b = cuMemberTradeService.businessCommissionSubmit(businessCommissionDTO);
- if (!b) {
- throw new ServiceException(ConfigMsgConstants.MEMBER_ACHIEVE_DEDUCT_MONEY);
+ if (cmal.getAfirstModifyPv().compareTo(BigDecimal.ZERO) > 0) {
+ content = content + " 左区业绩" + waterType + ": " + cmal.getAfirstModifyPv();
}
+ if (cmal.getBfirstModifyPv().compareTo(BigDecimal.ZERO) > 0) {
+ content = content + " 右区业绩" + waterType + ": " + cmal.getBfirstModifyPv();
+ }
+ if (cmal.getRepAFirstModifyBalance().compareTo(BigDecimal.ZERO) > 0) {
+ content = content + " 左区结余" + waterType + ": " + cmal.getRepAFirstModifyBalance();
+ }
+ if (cmal.getRepBFirstModifyBalance().compareTo(BigDecimal.ZERO) > 0) {
+ content = content + " 右区结余" + waterType + ": " + cmal.getRepBFirstModifyBalance();
+ }
+
+ //组装日志数据
+ BusinessLogDTO businessLog = BusinessLogDTO.builder()
+ .businessType(EApprovalBusiness.MEMBER_ACHIEVE.getValue())
+ .businessCode(code)
+ .pkMember(cmal.getPkMember())
+ .content(content)
+ .pkCreator(userID)
+ .pkCountry(pkCountry)
+ .freeSignFlag(true).build();
+ dtoList.add(businessLog);
}
//发送MQ到操作日志
- rabbitTemplate.convertAndSend(RabbitMqConstants.BUSINESS_LOG_EXCHANGE, RabbitMqConstants.BUSINESS_LOG_KEY,
- dtoList);
+ rabbitTemplate.convertAndSend(RabbitMqConstants.BUSINESS_LOG_EXCHANGE, RabbitMqConstants.BUSINESS_LOG_KEY, dtoList);
return cuMemberAchieveLogVO;
}
@@ -299,14 +229,14 @@ public class CuMemberAchieveLogServiceImpl extends ServiceImpl calList = new ArrayList<>();
calList.add(cuMemberAchieveLogVO);
- calList = cuMemberAchieveLogService.queryMemberAchieveHistoryList(calList);
+ calList = iCuMemberAchieveLogService.queryMemberAchieveHistoryList(calList);
//免支付 或 需签呈+支付
if (cuMemberAchieveLogVO.getProcessType() == EProcessType.AVOIDPAY.getValue() ||
@@ -413,7 +343,7 @@ public class CuMemberAchieveLogServiceImpl extends ServiceImpl submit = approvalServiceApi.submit(approvalSubmitDTO, loginUser);
+ R submit = iApprovalServiceApi.submit(approvalSubmitDTO, loginUser);
if (!submit.isSuccess()) {
log.error("====" + submit.getData());
throw new RuntimeException(ConfigMsgConstants.MEMBER_ACHIEVE_DEDUCT_PETITION);
@@ -427,7 +357,7 @@ public class CuMemberAchieveLogServiceImpl extends ServiceImpl
* 注水业绩记录表下载模板VO
- *
- *
- * @author hzs
- * @since 2022-08-22
*/
+@EqualsAndHashCode(callSuper = true)
@Data
public class CuMemberAchieveLogImportVO extends BaseApprovalEntity {
@@ -32,7 +29,7 @@ public class CuMemberAchieveLogImportVO extends BaseApprovalEntity {
/**
* 会员编号
*/
- @Excel(name = "会员编号" )
+ @Excel(name = "会员编号")
private String memberCode;
/**
@@ -43,73 +40,72 @@ public class CuMemberAchieveLogImportVO extends BaseApprovalEntity {
/**
* 变更后A左区累计 变更后左区真实业绩
*/
- @Excel(name = "变更后左区真实业绩(PV)" )
+// @Excel(name = "变更后左区真实业绩(PV)")
private BigDecimal asumRealModifyPv;
/**
* 变更后B右区累计 更后右区真实业绩
*/
- @Excel(name = "变更后右区真实业绩(PV)" )
+// @Excel(name = "变更后右区真实业绩(PV)")
private BigDecimal bsumRealModifyPv;
/**
* 变更后A左区 变更后左区首购业绩
*/
- @Excel(name = "变更后左区首购业绩(PV)" )
+ @Excel(name = "变更后左区业绩(PV)")
private BigDecimal afirstModifyPv;
/**
* 变更后B右区 变更后右区首购业绩
*/
- @Excel(name = "变更后右区首购业绩(PV)" )
+ @Excel(name = "变更后右区业绩(PV)")
private BigDecimal bfirstModifyPv;
/**
* 变更后A左区复购业绩累计业绩
*/
- @Excel(name = "变更后左区复购业绩(PV)" )
+// @Excel(name = "变更后左区复购业绩(PV)")
private BigDecimal repAModifySumPv;
/**
* 变更后B右区复购业绩累计业绩
*/
- @Excel(name = "变更后右区复购业绩(PV)" )
+// @Excel(name = "变更后右区复购业绩(PV)")
private BigDecimal repBModifySumPv;
/**
* 变更后A左区首购结余
*/
- @Excel(name = "变更后左区首购结余" )
+ @Excel(name = "变更后左区结余")
private BigDecimal repAFirstModifyBalance;
/**
* 变更后B右区首购结余
*/
- @Excel(name = "变更后右区首购结余" )
+ @Excel(name = "变更后右区结余")
private BigDecimal repBFirstModifyBalance;
-
/**
* 变更后A左区复购结余
*/
- @Excel(name = "变更后左区复购结余" )
+// @Excel(name = "变更后左区复购结余")
private BigDecimal repAModifyBalance;
/**
* 变更后B右区复购结余
*/
- @Excel(name = "变更后右区复购结余" )
+// @Excel(name = "变更后右区复购结余")
private BigDecimal repBModifyBalance;
/**
* 结算日期 注水日期(年-月-日)
*/
- @Excel(name = "注水日期",dateFormat = "yyyy-MM-dd" )
+ @Excel(name = "注水日期", dateFormat = "yyyy-MM-dd")
private Date settleDate;
/**
* 到期日期
*/
- @Excel(name = "到期日期",dateFormat = "yyyy-MM-dd" )
+ @Excel(name = "到期日期", dateFormat = "yyyy-MM-dd")
@JsonFormat(pattern = "yyyy-MM-dd")
private Date dueDate;
@@ -134,5 +130,4 @@ public class CuMemberAchieveLogImportVO extends BaseApprovalEntity {
private String pkAccountKeyVal;
-
}
diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/vo/CuMemberAchieveLogVO.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/vo/CuMemberAchieveLogVO.java
index 9a7f4bae..6cade58c 100644
--- a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/vo/CuMemberAchieveLogVO.java
+++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/vo/CuMemberAchieveLogVO.java
@@ -1,6 +1,7 @@
package com.hzs.member.base.vo;
import com.fasterxml.jackson.annotation.JsonFormat;
+import com.hzs.common.core.annotation.BigDecimalFormat;
import com.hzs.common.core.annotation.Excel;
import com.hzs.common.core.annotation.Transaction;
import com.hzs.common.core.constant.EnumsPrefixConstants;
@@ -69,125 +70,139 @@ public class CuMemberAchieveLogVO extends BaseApprovalEntity {
@Excel(name = "隶属团队")
private String teamName;
- /**
- * 注水方式 EInfusingWaterType 1 增加 2减少 3 最终
- */
- @Transaction(transactionKey = EnumsPrefixConstants.INFUSING_WATER_TYPE)
- private Integer infusingWaterType;
- @Excel(name = "注水方式")
- private String infusingWaterTypeVal;
/**
* 变更后左区真实业绩
*/
- @Excel(name = "变更后左区真实业绩(PV)")
+ @BigDecimalFormat
+// @Excel(name = "变更后左区真实业绩(PV)")
private BigDecimal asumRealModifyPv = BigDecimal.ZERO;
/**
* 变更后右区真实业绩
*/
- @Excel(name = "变更后右区真实业绩(PV)")
+ @BigDecimalFormat
+// @Excel(name = "变更后右区真实业绩(PV)")
private BigDecimal bsumRealModifyPv = BigDecimal.ZERO;
+
/**
* 变更后左区首购业绩
*/
- @Excel(name = "变更后左区首购业绩(PV)")
+ @BigDecimalFormat
+ @Excel(name = "变更后左区业绩(PV)")
private BigDecimal afirstModifyPv = BigDecimal.ZERO;
/**
* 变更后右区首购业绩
*/
- @Excel(name = "变更后右区首购业绩(PV)")
+ @BigDecimalFormat
+ @Excel(name = "变更后右区业绩(PV)")
private BigDecimal bfirstModifyPv = BigDecimal.ZERO;
+
/**
* 变更后左区首购结余
*/
- @Excel(name = "变更后左区首购结余")
+ @BigDecimalFormat
+ @Excel(name = "变更后左区结余")
private BigDecimal repAFirstModifyBalance = BigDecimal.ZERO;
/**
* 变更后右区首购结余
*/
- @Excel(name = "变更后右区首购结余")
+ @BigDecimalFormat
+ @Excel(name = "变更后右区结余")
private BigDecimal repBFirstModifyBalance = BigDecimal.ZERO;
+
/**
* 变更后左区复购业绩
*/
- @Excel(name = "变更后左区复购业绩(PV)")
+// @Excel(name = "变更后左区复购业绩(PV)")
private BigDecimal repAModifySumPv = BigDecimal.ZERO;
+
/**
* 变更后右区复购业绩
*/
- @Excel(name = "变更后右区复购业绩(PV)")
+// @Excel(name = "变更后右区复购业绩(PV)")
private BigDecimal repBModifySumPv = BigDecimal.ZERO;
/**
* 变更后左区复购结余
*/
- @Excel(name = "变更后左区复购结余")
+// @Excel(name = "变更后左区复购结余")
private BigDecimal repAModifyBalance = BigDecimal.ZERO;
/**
* 变更后右区复购结余
*/
- @Excel(name = "变更后右区复购结余")
+// @Excel(name = "变更后右区复购结余")
private BigDecimal repBModifyBalance = BigDecimal.ZERO;
/**
* 变更前左区真实业绩
*/
- @Excel(name = "变更前左区真实业绩(PV)")
+ @BigDecimalFormat
+// @Excel(name = "变更前左区真实业绩(PV)")
private BigDecimal asumRealPv;
-
/**
* 变更前右区真实业绩
*/
- @Excel(name = "变更前右区真实业绩(PV)")
+ @BigDecimalFormat
+// @Excel(name = "变更前右区真实业绩(PV)")
private BigDecimal bsumRealPv;
/**
* 变更前左区首购业绩
*/
- @Excel(name = "变更前左区首购业绩(PV)")
+ @BigDecimalFormat
+// @Excel(name = "变更前左区首购业绩(PV)")
private BigDecimal asumPv;
-
/**
* 变更前右区首购业绩
*/
- @Excel(name = "变更前右区首购业绩(PV)")
+ @BigDecimalFormat
+// @Excel(name = "变更前右区首购业绩(PV)")
private BigDecimal bsumPv;
/**
* 变更前左区首购结余
*/
- @Excel(name = "变更前左区首购结余")
+ @BigDecimalFormat
+// @Excel(name = "变更前左区首购结余")
private BigDecimal abalance;
/**
* 变更前右区首购结余
*/
- @Excel(name = "变更前右区首购结余")
+ @BigDecimalFormat
+// @Excel(name = "变更前右区首购结余")
private BigDecimal bbalance;
/**
* 变更前左区复购业绩
*/
- @Excel(name = "变更前左区复购业绩(PV)")
+// @Excel(name = "变更前左区复购业绩(PV)")
private BigDecimal repASumPv;
-
/**
* 变更前右区复购业绩
*/
- @Excel(name = "变更前右区复购业绩(PV)")
+// @Excel(name = "变更前右区复购业绩(PV)")
private BigDecimal repBSumPv;
/**
* 变更前左区复购结余
*/
- @Excel(name = "变更前左区复购结余")
+// @Excel(name = "变更前左区复购结余")
private BigDecimal repABalance;
/**
* 变更前右区复购结余
*/
- @Excel(name = "变更前右区复购结余")
+// @Excel(name = "变更前右区复购结余")
private BigDecimal repBBalance;
+
+ /**
+ * 注水方式 EInfusingWaterType 1 增加 2减少 3 最终
+ */
+ private Integer infusingWaterType;
+ @Excel(name = "注水方式")
+ private String infusingWaterTypeVal;
+
/**
* 结算日期 注水日期(年-月-日)
*/
@@ -203,10 +218,10 @@ public class CuMemberAchieveLogVO extends BaseApprovalEntity {
@JsonFormat(pattern = "yyyy-MM-dd")
private Date dueDate;
private String dueDateStr;
+
/**
* 注水状态 EActivityStatus 0 未开始 1 进行中 2 已结束
*/
- @Transaction(transactionKey = EnumsPrefixConstants.ACTIVITY_STATUS)
private Integer waterStatus;
@Excel(name = "注水状态")
private String waterStatusVal;
@@ -237,13 +252,11 @@ public class CuMemberAchieveLogVO extends BaseApprovalEntity {
*/
private Long pkCreator;
-
/**
* 注水业绩记录
*/
private List cmalvList;
-
/**
* 注水备注
*/
@@ -322,7 +335,6 @@ public class CuMemberAchieveLogVO extends BaseApprovalEntity {
@JsonFormat(pattern = "yyyy-MM-dd")
private Date endDueDate;
-
/**
* 修改时间
*/
diff --git a/bd-business/bd-business-member/src/main/resources/mapper/member/base/CuMemberAchieveLogMapper.xml b/bd-business/bd-business-member/src/main/resources/mapper/member/base/CuMemberAchieveLogMapper.xml
index f3e94220..d71f59f0 100644
--- a/bd-business/bd-business-member/src/main/resources/mapper/member/base/CuMemberAchieveLogMapper.xml
+++ b/bd-business/bd-business-member/src/main/resources/mapper/member/base/CuMemberAchieveLogMapper.xml
@@ -234,14 +234,16 @@
-