diff --git a/bd-api/bd-api-member/src/main/java/com/hzs/member/base/IMemberServiceApi.java b/bd-api/bd-api-member/src/main/java/com/hzs/member/base/IMemberServiceApi.java index 64920a4f..2412885d 100644 --- a/bd-api/bd-api-member/src/main/java/com/hzs/member/base/IMemberServiceApi.java +++ b/bd-api/bd-api-member/src/main/java/com/hzs/member/base/IMemberServiceApi.java @@ -119,19 +119,6 @@ public interface IMemberServiceApi { */ R getMember(Long pkMember); - /** - * 获取会员缓存 - * - * @param memberCode 会员编号 - * @return CuMember - */ - R queryMember(String memberCode); - - /* - * 查询会员 - **/ - R queryMember(Long pkMember); - /** * 保存新会员信息,待支付订单 * @@ -366,4 +353,13 @@ public interface IMemberServiceApi { */ R getMemberPhoneCount(String phone); + /** + * 查询最新升级记录 + * + * @param pkMember 会员ID + * @param pkOrder 订单ID(可为null) + * @return + */ + R getLastUpgrade(Long pkMember, Long pkOrder); + } diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/api/ApiCuMemberRechargeController.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/api/ApiCuMemberRechargeController.java index 755e9796..5ca5977d 100644 --- a/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/api/ApiCuMemberRechargeController.java +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/api/ApiCuMemberRechargeController.java @@ -1,6 +1,5 @@ package com.hzs.member.account.controller.api; - import com.hzs.common.core.constant.msg.FinanceMsgConstants; import com.hzs.common.core.enums.EOrderPrefix; import com.hzs.common.core.utils.CommonUtil; @@ -20,14 +19,8 @@ import org.springframework.web.bind.annotation.RestController; import java.math.BigDecimal; - /** - *

* 会员充值表 前端控制器 - *

- * - * @author hzs - * @since 2022-09-08 */ @RestController @@ -81,7 +74,7 @@ public class ApiCuMemberRechargeController extends BaseController { } //充值单号 String rechargeCode = CommonUtil.createSerialNumber(EOrderPrefix.RECHARGE_CODE.getValue()); - boolean result = cuMemberRechargeService.preCharge(rechargeAmount, pkCountry, pkMember, rechargeCode,pkCreator); + boolean result = cuMemberRechargeService.preCharge(rechargeAmount, pkCountry, pkMember, rechargeCode, pkCreator); if (result) { ajaxResult.put("flag", "1"); ajaxResult.put("orderCode", rechargeCode); @@ -105,7 +98,7 @@ public class ApiCuMemberRechargeController extends BaseController { // 用户支付密不能为空 return AjaxResult.error(TransactionUtils.getContent(FinanceMsgConstants.PAYMENT_PASSWORD_NOT_EMPTY)); } - CuMember cuMember = cuMemberService.queryMember(SecurityUtils.getUserId()); + CuMember cuMember = cuMemberService.getMember(SecurityUtils.getUserId()); if (SecurityUtils.matchesPassword(pwd, cuMember.getPayPwd())) { return AjaxResult.success(); } diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/api/ApiCuMemberTransferController.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/api/ApiCuMemberTransferController.java index a8d56bcf..f0ff816c 100644 --- a/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/api/ApiCuMemberTransferController.java +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/api/ApiCuMemberTransferController.java @@ -21,7 +21,6 @@ import com.hzs.common.domain.member.detail.CuMemberServiceLogExt; import com.hzs.common.domain.member.ext.CuMemberExt; import com.hzs.common.domain.system.config.BdAccount; import com.hzs.common.domain.system.config.BdTransfer; -import com.hzs.common.domain.system.config.BdTransferSpecial; import com.hzs.common.security.utils.SecurityUtils; import com.hzs.common.util.TransactionUtils; import com.hzs.member.account.dto.CuMemberRechargeAccountParam; @@ -42,7 +41,7 @@ import org.springframework.util.Assert; import org.springframework.web.bind.annotation.*; import java.math.BigDecimal; -import java.util.Arrays; +import java.util.Collections; import java.util.List; import java.util.Map; import java.util.stream.Collectors; @@ -171,10 +170,10 @@ public class ApiCuMemberTransferController extends BaseController { private List getServiceLogValue(Integer pkCountry, Long pkMember) { //查询体系 - CuMember cuMember = cuMemberService.queryMember(pkMember); + CuMember cuMember = cuMemberService.getMember(pkMember); Long pkVertex = cuMember.getPkVertex(); - List editTypeList = Arrays.asList(EApprovalBusiness.POLICY_CURRENCY_YES_NO.getValue()); + List editTypeList = Collections.singletonList(EApprovalBusiness.POLICY_CURRENCY_YES_NO.getValue()); CuMemberServiceLogExt log = new CuMemberServiceLogExt(); log.setPkMember(pkMember); log.setPkVertex(pkVertex); diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/manage/CuMemberAccountSummaryController.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/manage/CuMemberAccountSummaryController.java index 9bffaab7..1db90a2b 100644 --- a/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/manage/CuMemberAccountSummaryController.java +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/account/controller/manage/CuMemberAccountSummaryController.java @@ -79,7 +79,7 @@ public class CuMemberAccountSummaryController { if (EStatisticsScope.TOP.getValue() == param.getType()) { // 按顶点统计 - CuMember cuMember = iCuMemberService.queryMember(param.getPkMember()); + CuMember cuMember = iCuMemberService.getMember(param.getPkMember()); if (cuMember != null) { cuMemberAccountExt = iCuMemberAccountService.queryAccountSummaryByMember(cuMember.getMemberCode(), pkCountry); code = cuMember.getMemberCode(); @@ -101,7 +101,7 @@ public class CuMemberAccountSummaryController { } } else if (EStatisticsScope.MEMBER.getValue() == param.getType()) { // 按会员统计 - CuMember cuMember = iCuMemberService.queryMember(param.getMemberCode()); + CuMember cuMember = iCuMemberService.getMember(param.getMemberCode()); if (cuMember != null) { cuMemberAccountExt = iCuMemberAccountService.queryAccountSummaryByMember(param.getMemberCode(), pkCountry); code = cuMember.getMemberCode(); @@ -143,7 +143,7 @@ public class CuMemberAccountSummaryController { if (EStatisticsScope.TOP.getValue() == param.getType()) { // 按顶点统计 - CuMember cuMember = iCuMemberService.queryMember(param.getPkMember()); + CuMember cuMember = iCuMemberService.getMember(param.getPkMember()); if (cuMember != null) { cuMemberAccountExt = iCuMemberAccountService.queryAccountSummaryByMember(cuMember.getMemberCode(), pkCountry); code = cuMember.getMemberCode(); @@ -159,7 +159,7 @@ public class CuMemberAccountSummaryController { } } else if (EStatisticsScope.MEMBER.getValue() == param.getType()) { // 按会员统计 - CuMember cuMember = iCuMemberService.queryMember(param.getMemberCode()); + CuMember cuMember = iCuMemberService.getMember(param.getMemberCode()); if (cuMember != null) { cuMemberAccountExt = iCuMemberAccountService.queryAccountSummaryByMember(param.getMemberCode(), pkCountry); code = cuMember.getMemberCode(); diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/account/service/impl/CuMemberTransferServiceImpl.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/account/service/impl/CuMemberTransferServiceImpl.java index 8bd8f3c6..295c320e 100644 --- a/bd-business/bd-business-member/src/main/java/com/hzs/member/account/service/impl/CuMemberTransferServiceImpl.java +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/account/service/impl/CuMemberTransferServiceImpl.java @@ -187,8 +187,8 @@ public class CuMemberTransferServiceImpl extends ServiceImpl getMemberInfo(String memberCode) { @@ -156,16 +159,6 @@ public class MemberServiceProvider implements IMemberServiceApi { return R.ok(iCuMemberService.getMember(pkMember)); } - @Override - public R queryMember(String memberCode) { - return R.ok(iCuMemberService.queryMember(memberCode)); - } - - @Override - public R queryMember(Long pkMember) { - return R.ok(iCuMemberService.queryMember(pkMember)); - } - @Override public R saveMember(CuMember cuMember) { try { @@ -357,4 +350,8 @@ public class MemberServiceProvider implements IMemberServiceApi { return R.ok(iCuMemberService.getMemberPhoneCount(phone)); } + @Override + public R getLastUpgrade(Long pkMember, Long pkOrder) { + return R.ok(iCuMemberLevelService.getLastUpgrade(pkMember, pkOrder)); + } } diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/ICuMemberService.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/ICuMemberService.java index 006bd679..4b85530d 100644 --- a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/ICuMemberService.java +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/ICuMemberService.java @@ -80,16 +80,6 @@ public interface ICuMemberService extends IService { */ CuMember getMember(Long pkId); - /* - * 查询会员 - **/ - CuMember queryMember(String memberCode); - - /* - * 查询会员 - **/ - CuMember queryMember(Long pkMember); - /** * 校验会员下的安置人、推荐人是否存在 * diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberBusinessServiceImpl.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberBusinessServiceImpl.java index 655c49ad..a2dc78c7 100644 --- a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberBusinessServiceImpl.java +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberBusinessServiceImpl.java @@ -587,7 +587,7 @@ public class CuMemberBusinessServiceImpl implements ICuMemberBusinessService { // 会员账号 验证会员账户是否存在金额 CuMember member = cuMemberService.getMemberById(saOrder.getPkMember()); if (EOrderType.RETAIL_REGISTER.getValue() == saOrder.getOrderType() - ||(ObjectUtil.isNotEmpty(member) && EOrderType.RETAIL_REPURCHASE.getValue() == saOrder.getOrderType() && saOrder.getPayTime().equals(member.getPayTime())) + || (ObjectUtil.isNotEmpty(member) && EOrderType.RETAIL_REPURCHASE.getValue() == saOrder.getOrderType() && saOrder.getPayTime().equals(member.getPayTime())) ) { // 会员变为死点 member.setCategory(ECategory.LOGGED_OUT.getValue()); @@ -623,7 +623,7 @@ public class CuMemberBusinessServiceImpl implements ICuMemberBusinessService { CuMemberAccount payMemberAccount = iCuMemberAccountService.queryCuMemberAccountByPkMember(saOrder.getPkCreator()); if ( EOrderType.RETAIL_REGISTER.getValue() == saOrder.getOrderType() - || (saOrder.getOrderType() == EOrderType.RETAIL_REPURCHASE.getValue() && saOrder.getPayTime().equals(member.getPayTime())) + || (saOrder.getOrderType() == EOrderType.RETAIL_REPURCHASE.getValue() && saOrder.getPayTime().equals(member.getPayTime())) ) { // 会员账号 验证会员账户是否存在金额 @@ -899,6 +899,11 @@ public class CuMemberBusinessServiceImpl implements ICuMemberBusinessService { public Boolean normalRevokeOrder(Long pkApprove, SaOrderExt saOrder, CuMember cuMember, BusinessCommissionDTO businessCommissionDTO) { deductCancelOrderCost(businessCommissionDTO); + if (EOrderType.RETAIL_UPGRADE.getValue() == saOrder.getOrderType()) { + // 处理等级 + iCuMemberLevelService.deleteCuMemberLevelRecord(saOrder.getPkId(), pkApprove, new Date()); + } + // 更新会员标记,如果是则更新会员信息 if (saOrder.getUpdateFlag() != null && EYesNo.YES.getIntValue() == saOrder.getUpdateFlag()) { if (null != cuMember) { diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberServiceImpl.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberServiceImpl.java index 8179290f..14850791 100644 --- a/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberServiceImpl.java +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberServiceImpl.java @@ -167,16 +167,6 @@ public class CuMemberServiceImpl extends ServiceImpl i return baseMapper.queryLoginMember(null, pkId); } - @Override - public CuMember queryMember(String memberCode) { - return baseMapper.queryLoginMember(memberCode, null); - } - - @Override - public CuMember queryMember(Long pkMember) { - return baseMapper.queryLoginMember(null, pkMember); - } - @Override public boolean checkLowerMember(Long pkMember) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/mapper/CuMemberLevelMapper.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/mapper/CuMemberLevelMapper.java index 3891743c..7b049498 100644 --- a/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/mapper/CuMemberLevelMapper.java +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/mapper/CuMemberLevelMapper.java @@ -28,4 +28,14 @@ public interface CuMemberLevelMapper extends BaseMapper { */ int insertGradeBatch(@Param("memberGradeList") List memberGradeList); + /** + * 查询最新升级记录 + * + * @param pkMember 会员ID + * @param pkOrder 订单ID(可为null) + * @return + */ + CuMemberLevel getLastUpgrade(@Param("pkMember") Long pkMember, + @Param("pkOrder") Long pkOrder); + } diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/service/ICuMemberLevelService.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/service/ICuMemberLevelService.java index 1261a153..918e4c3e 100644 --- a/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/service/ICuMemberLevelService.java +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/service/ICuMemberLevelService.java @@ -37,4 +37,13 @@ public interface ICuMemberLevelService extends IService { */ int insertGradeBatch(List memberGradeList); + /** + * 查询最新升级记录 + * + * @param pkMember 会员ID + * @param pkOrder 订单ID(可为null) + * @return + */ + CuMemberLevel getLastUpgrade(Long pkMember, Long pkOrder); + } diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/service/impl/CuMemberLevelServiceImpl.java b/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/service/impl/CuMemberLevelServiceImpl.java index 6ece88f0..9f14f3a7 100644 --- a/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/service/impl/CuMemberLevelServiceImpl.java +++ b/bd-business/bd-business-member/src/main/java/com/hzs/member/detail/service/impl/CuMemberLevelServiceImpl.java @@ -38,4 +38,10 @@ public class CuMemberLevelServiceImpl extends ServiceImpl pkMemberList = baseMapper.selectDirectPushByPkMember(pkMember, systemType); // pkMemberList.add(userId); - if(CollUtil.isEmpty(pkMemberList)){ + if (CollUtil.isEmpty(pkMemberList)) { return CuMemberRetailDataStatisticsResultVO.builder() .totalPv(BigDecimal.ZERO) .bigRangeTotalPv(BigDecimal.ZERO) @@ -361,7 +361,7 @@ public class CuMemberRetailAchieveServiceImpl extends ServiceImpl statisticsDetailVOList = baseMapper.getRetailDataStatisticsDetail(memberAchieveVO); - CuMember cuMember = iCuMemberService.queryMember(userId); + CuMember cuMember = iCuMemberService.getMember(userId); CuMemberRetailDataStatisticsResultVO result = DataStatisticsUtil.getCalcMap(statisticsDetailVOList, cuMember); log.info("statisticsDetailVOList: {}", JSONUtil.toJsonStr(statisticsDetailVOList)); log.info("calcMap -> {}", JSONUtil.toJsonStr(result)); diff --git a/bd-business/bd-business-member/src/main/resources/mapper/member/detail/CuMemberLevelMapper.xml b/bd-business/bd-business-member/src/main/resources/mapper/member/detail/CuMemberLevelMapper.xml index a7cc886e..aae859f3 100644 --- a/bd-business/bd-business-member/src/main/resources/mapper/member/detail/CuMemberLevelMapper.xml +++ b/bd-business/bd-business-member/src/main/resources/mapper/member/detail/CuMemberLevelMapper.xml @@ -101,4 +101,20 @@ ) + + + diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/service/impl/AcPickServiceImpl.java b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/service/impl/AcPickServiceImpl.java index bfb440f0..0b450423 100644 --- a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/service/impl/AcPickServiceImpl.java +++ b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/pick/service/impl/AcPickServiceImpl.java @@ -179,7 +179,7 @@ public class AcPickServiceImpl extends ServiceImpl impleme } // 会员信息 - CuMember cuMember = iMemberServiceApi.queryMember(detailParam.getMemberCode()).getData(); + CuMember cuMember = iMemberServiceApi.getMember(detailParam.getMemberCode()).getData(); // 封装业务操作日志 logDTOList.add(BusinessLogDTO.builder() .businessType(EApprovalBusiness.PICK_ADD.getValue()) @@ -283,7 +283,7 @@ public class AcPickServiceImpl extends ServiceImpl impleme } // 被操作会员 - CuMember cuMember = iMemberServiceApi.queryMember(detailParam.getMemberCode()).getData(); + CuMember cuMember = iMemberServiceApi.getMember(detailParam.getMemberCode()).getData(); // 封装业务操作日志 logDTOList.add(BusinessLogDTO.builder() .businessType(EApprovalBusiness.PICK_ADD_DEL.getValue()) diff --git a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/service/impl/AcRepurCouponsRuleConfigServiceImpl.java b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/service/impl/AcRepurCouponsRuleConfigServiceImpl.java index 9d844b08..a86abce3 100644 --- a/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/service/impl/AcRepurCouponsRuleConfigServiceImpl.java +++ b/bd-business/bd-business-sale/src/main/java/com/hzs/activity/recommend/service/impl/AcRepurCouponsRuleConfigServiceImpl.java @@ -619,11 +619,10 @@ public class AcRepurCouponsRuleConfigServiceImpl extends ServiceImpl implements ISaOrderService { @DubboReference - IMemberServiceApi memberServiceApi; + IMemberServiceApi iMemberServiceApi; @DubboReference IMemberBankServiceApi memberBankServiceApi; @DubboReference @@ -201,7 +202,7 @@ public class SaOrderServiceImpl extends ServiceImpl impl @Override public CuMember getCuMemberByKey(Long pkId) { - return memberServiceApi.getMemberById(pkId).getData(); + return iMemberServiceApi.getMemberById(pkId).getData(); } @Override @@ -478,7 +479,7 @@ public class SaOrderServiceImpl extends ServiceImpl impl //创建用户 CuMemberExt memberExt = createMember(orderBlankRegParams); - R member = memberServiceApi.createEmptyOrderMember(memberExt); + R member = iMemberServiceApi.createEmptyOrderMember(memberExt); if (member.getData() == null) { throw new ServiceException("保存会员失败"); } @@ -663,7 +664,7 @@ public class SaOrderServiceImpl extends ServiceImpl impl @Transactional(rollbackFor = Exception.class) public void revokeSaOrderByOrderCode(Long pkApprove, OrderCancelParam orderCancelParam, ValidateCancelOrderVO validateCancelOrderVO) { SaOrderExt saOrderExt = validateCancelOrderVO.getSaOrderExt(); - CuMemberExt memberExt = memberServiceApi.getMemberById(saOrderExt.getPkMember()).getData(); + CuMemberExt memberExt = iMemberServiceApi.getMemberById(saOrderExt.getPkMember()).getData(); BusinessCommissionDTO businessCommissionDTO = null; if (orderCancelParam.getCancelRoad() == 1) { EApprovalBusiness approveBusiness = EApprovalBusiness.ORDER_CANCEL; @@ -735,7 +736,7 @@ public class SaOrderServiceImpl extends ServiceImpl impl if (!saOrderItemsService.updateOrderItemsById(pkOrderItemList, pkApprove, currentDateTime)) { throw new ServiceException("更新订单失败"); } - if (!memberServiceApi.normalRevokeOrder(pkApprove, saOrderExt, null, businessCommissionDTO).getData()) { + if (!iMemberServiceApi.normalRevokeOrder(pkApprove, saOrderExt, null, businessCommissionDTO).getData()) { throw new ServiceException("撤单失败"); } } else { @@ -753,10 +754,10 @@ public class SaOrderServiceImpl extends ServiceImpl impl // 撤销注册订单 单点撤单 if (ECancelOrderType.SINGLE_CANCEL_ORDER.getValue() == orderCancelParam.getCancelType() - ||(ObjectUtil.isNotEmpty(memberExt) && ECancelOrderType.OTHER_CANCEL_ORDER.getValue() == orderCancelParam.getCancelType() && saOrderExt.getPayTime().equals(memberExt.getPayTime())) + || (ObjectUtil.isNotEmpty(memberExt) && ECancelOrderType.OTHER_CANCEL_ORDER.getValue() == orderCancelParam.getCancelType() && saOrderExt.getPayTime().equals(memberExt.getPayTime())) ) { // 单点撤单,变死点 - R tmpR = memberServiceApi.singleRevokeMemberByRegisterOrder(pkApprove, saOrderExt, businessCommissionDTO); + R tmpR = iMemberServiceApi.singleRevokeMemberByRegisterOrder(pkApprove, saOrderExt, businessCommissionDTO); if (!tmpR.isSuccess()) { throw new ServiceException("撤单失败 " + tmpR.getMsg()); } @@ -770,7 +771,7 @@ public class SaOrderServiceImpl extends ServiceImpl impl baseMapper.updateSaOrderByMember(memberList, pkApprove, currentDate); } - R tmpR = memberServiceApi.mergeRevokeMemberByRegisterOrder(pkApprove, memberList, validateCancelOrderVO.getSaOrderMap(), businessCommissionDTO); + R tmpR = iMemberServiceApi.mergeRevokeMemberByRegisterOrder(pkApprove, memberList, validateCancelOrderVO.getSaOrderMap(), businessCommissionDTO); if (!tmpR.isSuccess()) { throw new ServiceException("撤单失败 " + tmpR.getMsg()); } @@ -905,7 +906,7 @@ public class SaOrderServiceImpl extends ServiceImpl impl // 如果是注册订单,需要校验下面是否有会员 if (EOrderType.REGISTER_ORDER.getValue() == saOrder.getOrderType()) { // 注册类订单,需要校验是否推荐过人或者安置过人,如果有则不允许进行取消 - if (memberServiceApi.checkLowerMember(saOrder.getPkMember()).getData()) { + if (iMemberServiceApi.checkLowerMember(saOrder.getPkMember()).getData()) { // 订单所属会员下存在用户不能取消 return TransactionUtils.getContent(MemberMsgConstants.EXIST_MEMBER_NOT_CANCEL); } @@ -931,7 +932,7 @@ public class SaOrderServiceImpl extends ServiceImpl impl // 如果是注册订单,需要取消点位 if (EOrderType.REGISTER_ORDER.getValue() == saOrder.getOrderType()) { - if (!memberServiceApi.cancelMember(saOrder.getPkMember()).getData()) { + if (!iMemberServiceApi.cancelMember(saOrder.getPkMember()).getData()) { throw new ServiceException("取消订单失败"); } } @@ -1131,7 +1132,6 @@ public class SaOrderServiceImpl extends ServiceImpl impl @Transactional(rollbackFor = Exception.class) public void selfRevokeOrder(Long pkApprove, MyOrderVO myOrderVO) { SaOrderExt saOrderExt = myOrderVO.getSaOrderExt(); - BusinessCommissionDTO businessCommissionDTO = null; if (saOrderExt != null) { // 删除订单 saOrderExt.setDelFlag(EDelFlag.DELETE.getValue()); @@ -1158,17 +1158,19 @@ public class SaOrderServiceImpl extends ServiceImpl impl saOrderChargeLogService.save(saOrderChargeLog); // 撤销注册订单 - CuMember member = memberServiceApi.getMember(SecurityUtils.getUserId()).getData(); + CuMember member = iMemberServiceApi.getMember(SecurityUtils.getUserId()).getData(); if (myOrderVO.getOrderType() == EOrderType.RETAIL_REGISTER.getValue() - || (myOrderVO.getOrderType() == EOrderType.RETAIL_REPURCHASE.getValue() && myOrderVO.getPayTime().equals(member.getPayTime())) + || (myOrderVO.getOrderType() == EOrderType.RETAIL_REPURCHASE.getValue() + && myOrderVO.getPayTime().equals(member.getPayTime()) + && member.getCreationTime().equals(member.getPayTime())) ) { // 逻辑删除会员 - if (!memberServiceApi.singleRevokeMemberBySelfRevokeOrder(pkApprove, saOrderExt, businessCommissionDTO).getData()) { + if (!iMemberServiceApi.singleRevokeMemberBySelfRevokeOrder(pkApprove, saOrderExt, null).getData()) { throw new ServiceException("撤单失败"); } } else { // 其他撤单 - this.handleCancelUpgradeOrder(saOrderExt, myOrderVO.getUpdSaOrder(), pkApprove, businessCommissionDTO); + this.handleCancelUpgradeOrder(saOrderExt, myOrderVO.getUpdSaOrder(), pkApprove, null); } try { @@ -1384,14 +1386,29 @@ public class SaOrderServiceImpl extends ServiceImpl impl private void handleCancelUpgradeOrder(SaOrderExt saOrderExt, SaOrder updSaOrder, Long pkApprove, BusinessCommissionDTO businessCommissionDTO) { // 其他撤单 撤销升级订单 CuMember cuMember = getCuMemberByKey(saOrderExt.getPkMember()); - if (EOrderType.RETAIL_PICK.getValue() == saOrderExt.getOrderType()) { + if (EOrderType.RETAIL_UPGRADE.getValue() == saOrderExt.getOrderType()) { + // 处理等级 + // 获取最新的升级记录,如果没有则查询会员的注册信息 + // 查询会员升级记录表最终数据 + CuMemberLevel cuMemberLevel = iMemberServiceApi.getLastUpgrade(cuMember.getPkId(), saOrderExt.getPkId()).getData(); + if (null != cuMemberLevel) { + // 存在升级记录 + cuMember.setPkSettleGrade(cuMemberLevel.getNewLevel()); + } else { + // 没有升级记录,重置成会员 + cuMember.setPkSettleGrade(iGradeServiceApi.getGradeByGradeValue(EGrade.MEMBER.getValue(), saOrderExt.getPkCountry()).getData().getPkId()); + cuMember.setConsumeMoney(BigDecimal.ZERO); + cuMember.setConsumeAchieve(BigDecimal.ZERO); + } + saOrderExt.setUpdateFlag(EYesNo.YES.getIntValue()); + } else if (EOrderType.RETAIL_PICK.getValue() == saOrderExt.getOrderType()) { // 新提货订单 if (!iAcRetailPickService.cancelRetailPickOrder(saOrderExt.getPkId(), pkApprove)) { throw new ServiceException("撤销订单退还提货失败"); } } - if (!memberServiceApi.normalRevokeOrder(pkApprove, saOrderExt, cuMember, businessCommissionDTO).getData()) { + if (!iMemberServiceApi.normalRevokeOrder(pkApprove, saOrderExt, cuMember, businessCommissionDTO).getData()) { throw new ServiceException("撤单处理会员失败"); } } @@ -1427,7 +1444,7 @@ public class SaOrderServiceImpl extends ServiceImpl impl @Override public boolean showDiscountArea() { - if(ObjectUtil.isEmpty(SecurityUtils.getUserId())){ + if (ObjectUtil.isEmpty(SecurityUtils.getUserId())) { return false; } LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); diff --git a/bd-business/bd-business-system/src/main/java/com/hzs/system/config/controller/manage/CuMemberTransferWhiteController.java b/bd-business/bd-business-system/src/main/java/com/hzs/system/config/controller/manage/CuMemberTransferWhiteController.java index 97af7b47..150d7461 100644 --- a/bd-business/bd-business-system/src/main/java/com/hzs/system/config/controller/manage/CuMemberTransferWhiteController.java +++ b/bd-business/bd-business-system/src/main/java/com/hzs/system/config/controller/manage/CuMemberTransferWhiteController.java @@ -1,7 +1,5 @@ package com.hzs.system.config.controller.manage; - -import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.collection.CollUtil; import com.hzs.common.core.annotation.Log; import com.hzs.common.core.constant.EnumsPrefixConstants; @@ -30,24 +28,17 @@ import java.util.List; import java.util.Map; /** - *

* 会员转账币种白名单 前端控制器 - *

- * - * @author hzs - * @since 2024-07-03 */ @RestController @RequestMapping("/manage/transfer-white") public class CuMemberTransferWhiteController extends BaseController { - @DubboReference - private IMemberServiceApi iMemberServiceApi; + @DubboReference + IMemberServiceApi iMemberServiceApi; @Autowired private ICuMemberTransferWhiteService transferWhiteService; - - @Autowired private ITransactionCommonService iTransactionCommonService; @@ -127,7 +118,7 @@ public class CuMemberTransferWhiteController extends BaseController { @Log(module = EOperationModule.TRADE_CONFIG, business = EOperationBusiness.TRANSFER_ACCOUNT_WHITE, method = EOperationMethod.UPDATE) @PostMapping("/update") public AjaxResult updateTransferConfig(@RequestBody CuMemberTransferWhiteVO transferWhiteVO) { - CuMember cumember = iMemberServiceApi.queryMember(transferWhiteVO.getMemberCode()).getData(); + CuMember cumember = iMemberServiceApi.getMember(transferWhiteVO.getMemberCode()).getData(); AjaxResult ajaxResult = parametersVerify(transferWhiteVO, cumember); if ((Integer) ajaxResult.get(AjaxResult.CODE_TAG) == HttpStatus.ERROR) { return ajaxResult; diff --git a/bd-business/bd-business-system/src/main/java/com/hzs/system/config/service/impl/BdGradeServiceImpl.java b/bd-business/bd-business-system/src/main/java/com/hzs/system/config/service/impl/BdGradeServiceImpl.java index 0b48bb49..ce29b7f6 100644 --- a/bd-business/bd-business-system/src/main/java/com/hzs/system/config/service/impl/BdGradeServiceImpl.java +++ b/bd-business/bd-business-system/src/main/java/com/hzs/system/config/service/impl/BdGradeServiceImpl.java @@ -54,7 +54,9 @@ public class BdGradeServiceImpl extends ServiceImpl impl @Override public BdGrade getGradeByGradeValue(Integer gradeValue, Integer pkCountry) { LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(BdGrade::getPkCountry, pkCountry); + if (null != pkCountry) { + queryWrapper.eq(BdGrade::getPkCountry, pkCountry); + } queryWrapper.eq(BdGrade::getGradeValue, gradeValue); queryWrapper.orderByAsc(BdGrade::getStartValue); return baseMapper.selectOne(queryWrapper);