## 去掉不需要的方法;调整代码写法;

This commit is contained in:
cabbage 2025-05-12 11:22:10 +08:00
parent 84567784b7
commit 4076c71e17
1 changed files with 0 additions and 423 deletions

View File

@ -2,24 +2,19 @@ package com.hzs.member.base.service.impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.lang.tree.Tree;
import cn.hutool.core.lang.tree.TreeNodeConfig;
import cn.hutool.core.lang.tree.TreeUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hzs.activity.base.IActivityServiceApi;
import com.hzs.common.core.constant.*;
import com.hzs.common.core.constant.msg.ConfigMsgConstants;
import com.hzs.common.core.domain.R;
import com.hzs.common.core.enums.*;
import com.hzs.common.core.exception.ServiceException;
import com.hzs.common.core.service.RedisService;
import com.hzs.common.core.utils.*;
import com.hzs.common.domain.member.account.CuMemberAccount;
import com.hzs.common.domain.member.achieve.CuMemberTree;
@ -28,7 +23,6 @@ import com.hzs.common.domain.member.detail.CuMemberServiceLog;
import com.hzs.common.domain.member.empty.CuMemberEmptyCode;
import com.hzs.common.domain.member.ext.CuMemberExt;
import com.hzs.common.domain.member.ext.CuMemberSettleExt;
import com.hzs.common.domain.member.ext.CuMemberTeamExt;
import com.hzs.common.domain.sale.wares.BdWaresAuthority;
import com.hzs.common.domain.system.base.BdCountry;
import com.hzs.common.domain.system.config.BdAwards;
@ -54,7 +48,6 @@ import com.hzs.member.handlebusiness.vo.BusinessMemberVO;
import com.hzs.member.handlebusiness.vo.HandleBusinessVO;
import com.hzs.member.marketnews.param.MarketNewsParam;
import com.hzs.member.marketnews.vo.UserInvestmentVo;
import com.hzs.member.param.MemberParam;
import com.hzs.system.base.ICountryServiceApi;
import com.hzs.system.base.ICurrencyServiceApi;
import com.hzs.system.base.ISystemConfigServiceApi;
@ -122,13 +115,7 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
private ICuAwardsControlService iCuAwardsControlService;
@Autowired
private ICuSettleCountryDetailedService iCuSettleCountryDetailedService;
@Autowired
private ICuMemberTeamService iCuMemberTeamService;
@Autowired
private ICuMemberBusinessService iCuMemberBusinessService;
@Autowired
private RedisService redisService;
@Autowired
private RabbitTemplate rabbitTemplate;
@ -322,9 +309,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return cuMember;
}
/**
* @description: 会员信息
**/
@Override
public List<CuMemberVO> queryCuMemberByCondition(CuMemberVO memberParam) {
return baseMapper.queryCuMemberByCondition(memberParam);
@ -340,20 +324,11 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return baseMapper.queryCuMemberByMemberListExcel(memberParam);
}
/**
* @description: 真实信息
**/
@Override
public List<CuMemberVO> realCuMemberByCondition(CuMemberVO memberParam) {
return baseMapper.realCuMemberByCondition(memberParam);
}
/**
* 创建空单注册会员
*
* @param member
* @return
*/
@Override
public CuMember createEmptyOrderMember(CuMemberExt member) {
try {
@ -397,25 +372,16 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
iCuMemberRegisterService.save(cuMemberRegister);
}
/**
* @description: 特殊业务-修改会员编号列表
**/
@Override
public List<UpdateCodeVO> puCodeList(UpdateCodeVO updateCodeVO) {
return baseMapper.puCodeList(updateCodeVO);
}
/**
* @description: 查询会员续约
**/
@Override
public List<UpdateExpireStopVO> getMemberExpireStopList(UpdateExpireStopVO updateExpireStopVO) {
return baseMapper.getMemberExpireStopList(updateExpireStopVO);
}
/**
* @description: 零元撤单列表
**/
@Override
public List<ZeroElementRevokeVO> zeroList(ZeroElementRevokeVO zeroElementRevokeVO) {
return baseMapper.zeroList(zeroElementRevokeVO);
@ -439,17 +405,11 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return zeoList;
}
/**
* @description: 查询会员变更前信息
**/
@Override
public UpdateCodeVO specialBusinessQuery(UpdateCodeVO updateCodeVO) {
return baseMapper.specialBusinessQuery(updateCodeVO);
}
/**
* @description: 批量修改会员编号
**/
@Override
@Transactional(rollbackFor = Exception.class)
public UpdateCodeVO updateCode(UpdateCodeVO updateCode) {
@ -514,9 +474,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return updateCode;
}
/**
* @description: 修改会员续约发起签呈
**/
@Override
@Transactional(rollbackFor = Exception.class)
public UpdateExpireStopVO upExpireStop(UpdateExpireStopVO upESVO) {
@ -607,9 +564,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return upESVO;
}
/**
* @description: 修改会员续约-审核通过驳回
**/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean upExpireStopProcess(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
@ -648,9 +602,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return true;
}
/**
* @description: 零元撤单
**/
@Override
@Transactional(rollbackFor = Exception.class)
public ZeroElementRevokeVO zeroRevokeBusiness(ZeroElementRevokeVO zero) {
@ -728,9 +679,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return zero;
}
/**
* @description: 发起签呈-零元撤单
**/
@Override
@Transactional(rollbackFor = Exception.class)
public ZeroElementRevokeVO zeroPetition(ZeroElementRevokeVO zeroElementRevokeVO) {
@ -876,9 +824,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return updateCodeVO;
}
/**
* @description: 发起签呈-修改结算国
**/
@Override
@Transactional(rollbackFor = Exception.class)
public UpdateSettleCountryVO petition(UpdateSettleCountryVO upseCountryVO) {
@ -953,9 +898,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return upseCountryVO;
}
/**
* @description: 特殊业务-修改政策币发起签呈
**/
@Override
@Transactional(rollbackFor = Exception.class)
public UpPolicyCurrencyVO petition(UpPolicyCurrencyVO policyCurrencyVO) {
@ -1031,9 +973,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return policyCurrencyVO;
}
/**
* @description: 特殊业务-零元撤单-审核通过/驳回
**/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean zeroByBusinessNo(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
@ -1120,11 +1059,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return true;
}
/**
* @description: 特殊业务-修改会员编号-审核通过
* @param: [updateCodeVO]
* @return: boolean
**/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean updateCodeByBusinessNo(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
@ -1156,11 +1090,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return true;
}
/**
* @description: 政策币签呈-审核通过-驳回
* @param: [approvalBusinessResultDTO]
* @return: boolean
**/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean upPolicyCurrencyProcess(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
@ -1218,11 +1147,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return true;
}
/**
* @description: 删除政策币业务审核
* @param: [approvalBusinessResultDTO]
* @return: boolean
**/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean delPolicyCurrencyProcess(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
@ -1293,11 +1217,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return true;
}
/**
* @description: 特殊业务-修改会员编号-审核驳回
* @param: [updateCodeVO]
* @return: boolean
**/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean updateCodeReject(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
@ -1353,11 +1272,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return true;
}
/**
* @description: 特殊业务-真实奖衔控制-审核通过或驳回
* @param: [updateCodeVO]
* @return: boolean
**/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean awardsControlPetition(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
@ -1706,11 +1620,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return businessNo;
}
/**
* @param pkCountry 国家
* @Description: 生成会员编号
* @return: String
*/
@Override
public String createUserNameByPremix(Integer pkCountry, Boolean isHaiFun, Integer digit) {
String prefix;
@ -2091,13 +2000,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return num;
}
/**
* 后台安置列表
*
* @param list
* @param memberSettleExt
* @return
*/
@Override
public List<Tree<String>> systemAzSetListTree(List<CuMemberSettleExt> list, CuMemberSettleExt memberSettleExt) {
R<Map<Integer, BdCountry>> allCountryMap = iCountryServiceApi.getAllCountryMap();
@ -2110,7 +2012,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
memberSettleExt.setColor(date.getColor());
}
}
// TODO 关联网体查询等级颜色值
Map<String, GradeDTO> gradeDtoMap = queryGradeDTOMap(list);
Map<Integer, BdCountry> allCountryData = allCountryMap.getData();
TreeNodeConfig treeNodeConfig = new TreeNodeConfig();
@ -2202,13 +2103,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return build;
}
/**
* 安置架构五
*
* @param list
* @param memberSettleExt
* @return
*/
@Override
public List<Tree<String>> systemAzSetListTreeFive(List<CuMemberSettleExt> list, CuMemberSettleExt memberSettleExt) {
TreeNodeConfig treeNodeConfig = new TreeNodeConfig();
@ -2243,31 +2137,16 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return num;
}
/**
* @description: 特殊配置 修改结算国列表
* @param: [upseCountryVO]
* @return: java.util.List<com.hzs.member.base.vo.UpdateSettleCountryVO>
**/
@Override
public List<UpdateSettleCountryVO> upsettleCountryList(UpdateSettleCountryVO upseCountryVO) {
return baseMapper.upsettleCountryList(upseCountryVO);
}
/**
* @description: 查询修改政策币列表
* @param: [upVO]
* @return: java.util.List<com.hzs.member.base.vo.UpPolicyCurrencyVO>
**/
@Override
public List<UpPolicyCurrencyVO> upPolicyCurrencyList(UpPolicyCurrencyVO upVO) {
return baseMapper.upPolicyCurrencyList(upVO);
}
/**
* @description: 特殊业务-批量修改结算国
* @param: [upseCountryVO]
* @return: com.hzs.member.base.vo.UpdateSettleCountryVO
**/
@Override
@Transactional(rollbackFor = Exception.class)
public UpdateSettleCountryVO updateSettleCountry(UpdateSettleCountryVO upseCountryVO) {
@ -2391,11 +2270,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return upseCountryVO;
}
/**
* @description: 特殊业务-修改政策币
* @param: [upseCountryVO]
* @return: com.hzs.member.base.vo.UpdateSettleCountryVO
**/
@Override
@Transactional(rollbackFor = Exception.class)
public UpPolicyCurrencyVO upPolicyCurrency(UpPolicyCurrencyVO policyCurrencyVO) {
@ -2462,11 +2336,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return policyCurrencyVO;
}
/**
* @description: 特殊业务-删除政策币业务
* @param: [policyCurrencyVO]
* @return: com.hzs.member.base.vo.UpPolicyCurrencyVO
**/
@Override
@Transactional(rollbackFor = Exception.class)
public UpPolicyCurrencyVO delPolicyCurrency(UpPolicyCurrencyVO policyCurrencyVO) {
@ -2565,12 +2434,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return policyCurrencyVO;
}
/**
* @description: 特殊业务-修改结算国-审核通过
* @param: [approvalBusinessResultDTO]
* @return: boolean
**/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean updateSettleCountryAdopt(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
@ -2653,11 +2516,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return true;
}
/**
* @description: 特殊业务-修改结算国-审核驳回
* @param: [approvalBusinessResultDTO]
* @return: boolean
**/
@Transactional(rollbackFor = Exception.class)
@Override
public boolean updateSettleCountryReject(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
@ -2713,62 +2571,31 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return true;
}
/**
* @description: 校验会员是否有充值审核
* @param: [pkMember]
* @return: java.lang.Integer
**/
@Override
public Integer checkCecharge(Long pkMember) {
return baseMapper.checkCecharge(pkMember);
}
/**
* @description: 校验会员是否有提现审核
* @param: [pkMember]
* @return: java.lang.Integer
**/
@Override
public Integer checkWithdraw(Long pkMember) {
return baseMapper.checkWithdraw(pkMember);
}
/**
* @description: 校验会员所有账户是否有余额
* @param: [pkMember]
* @return: java.lang.Integer
**/
@Override
public Integer checkAccount(Long pkMember) {
return baseMapper.checkAccount(pkMember);
}
/**
* @description: 查询会员是否存在未完成基础业务办理
* @param: [pkMember]
* @return: java.lang.Integer
**/
@Override
public Integer checkmsLogCount(Long pkMember, Integer editType) {
return baseMapper.checkmsLogCount(pkMember, editType);
}
/**
* @description: 查询会员是否存在未完成注水业绩业务
* @param: [pkMember]
* @return: java.lang.Integer
**/
@Override
public Integer checkMemberAchieveCount(Long pkMember) {
return baseMapper.checkMemberAchieveCount(pkMember);
}
/**
* 查询汇总
*
* @param censusSummaryParam 表格名称
* @return
*/
@Override
public List<CensusSummaryVo> selectCensusSummary(CensusSummaryParam censusSummaryParam, List<String> days) {
Integer loginUserCountry = SecurityUtils.getPkCountry();
@ -2992,26 +2819,12 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return censusSummaryList;
}
/**
* 获取等级的翻译KEY值
*
* @param pkId ID
* @return Integer
*/
@Override
public Integer getGradeTranslateValue(Integer pkId) {
R<GradeDTO> grade = iGradeServiceApi.getGrade(pkId);
return grade.getData().getPkTransaction();
}
/**
* 获取奖衔的翻译KEY值
*
* @param pkCountry 国家
* @param pkId ID
* @return Integer
*/
@Override
public Integer getAwardsTranslateValue(Integer pkCountry, Integer pkId) {
R<BdAwards> awards = iAwardsServiceApi.getAwardsOne(pkId);
@ -3040,102 +2853,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return baseMapper.queryMemberSelect(param, pkCountry);
}
@Override
public CuMember confirmShareMemberByMemberParam(MemberParam memberParam) {
CuMember parentMember = getMember(memberParam.getPkParent());
CuMember cuMember = packageSaveUser(memberParam, parentMember);
String memberCode = memberParam.getMemberCode();
if (StringUtils.isEmpty(memberCode)) {
memberCode = createUserNameByPremix(parentMember.getPkSettleCountry(), Boolean.TRUE, MagicNumberConstants.DIGIT);
}
cuMember.setPkId(baseMapper.createMemberId());
memberParam.setMemberCode(memberCode);
// 处理等级
GradeDTO gradeDTO = iGradeServiceApi.getGradeByGradeValue(EGrade.START_UP.getValue(), parentMember.getPkSettleCountry()).getData();
if (gradeDTO == null) {
return null;
}
cuMember.setPkRegisterGrade(gradeDTO.getPkId());
cuMember.setPkSettleGrade(gradeDTO.getPkId());
cuMember.setPkAwards(gradeDTO.getPkAwards());
// 等级对应的结算值
cuMember.setConsumeMoney(BigDecimal.ZERO);
cuMember.setConsumeAchieve(BigDecimal.ZERO);
cuMember.setRegisterAuthority(gradeDTO.getRegisterAuthority());
iCuMemberBusinessService.saveShareMember(cuMember);
return cuMember;
}
/**
* @param memberParam 参数
* @Description: 生成用户
* @return: void
*/
CuMember packageSaveUser(MemberParam memberParam, CuMember parentMember) {
// 获取新的订单编号
CuMember cuMember = CuMember.builder()
.memberCode(memberParam.getMemberCode())
.memberName(memberParam.getMemberName())
.pkSettleCountry(parentMember.getPkSettleCountry())
.phone(memberParam.getPhone())
.loginPwd(SecurityUtils.encryptPassword(memberParam.getLoginPassword()))
.loginPassword(memberParam.getLoginPassword())
.payPwd(SecurityUtils.encryptPassword(memberParam.getPayPassword()))
.payPassword(memberParam.getPayPassword())
.source(EDataSource.APP.getValue())
.pkParent(parentMember.getPkId())
.accountStatus(EAccountStatus.NORMAL.getValue())
// 这个时候是待支付等支付的时候变为支付可以跟待支付公用
.payStatus(EPayStatus.PAID.getValue())
.category(ECategory.NORMAL.getValue())
.orderSource(EOrderSource.SOLID.getValue())
.consumeMoney(BigDecimal.ZERO)
.consumeAchieve(BigDecimal.ZERO)
.customerType(ECustomerType.HAI_FANS.getValue())
.registerAuthority(ERegistrationAuthority.ORDINARY.getValue())
.build();
// 自动上树验证推荐人等级推荐人是海粉验证左右区人数否则验证业绩
CuMember placeCuMember = repeatTryTree(cuMember);
cuMember.setPkPlaceParent(placeCuMember.getPkPlaceParent());
cuMember.setPlaceDept(placeCuMember.getPlaceDept());
cuMember.setPkCountry(parentMember.getPkCountry());
Date currentTime = DateUtils.currentDateTime();
cuMember.setCreationTime(currentTime);
cuMember.setPayStatus(EPayStatus.PAID.getValue());
cuMember.setPayTime(currentTime);
// 2024.05.29 会员续约需求有效期为购买时间次年的上月最后一天
cuMember.setExpireDate(DateUtils.beforeMonthLastDate(DateUtils.addYears(currentTime, 1)));
// 休止期普通会员6个月奖衔会员12个月 -- 分享自注册肯定是普通会员直接给6个月
cuMember.setStopDate(DateUtils.addMonths(cuMember.getExpireDate(), 6));
cuMember.setPkCreator(parentMember.getPkId());
if (parentMember.getPkTeamCode() == null) {
// 验证父级是不是团队
CuMemberTeamExt memberTeamExt = iCuMemberTeamService.getCuMemberTeamById(parentMember.getPkId());
if (memberTeamExt != null) {
cuMember.setPkTeamCode(memberTeamExt.getPkId());
}
} else {
cuMember.setPkTeamCode(parentMember.getPkTeamCode());
}
cuMember.setPkVertex(parentMember.getPkVertex());
return cuMember;
}
private CuMember repeatTryTree(CuMember cuMember) {
CuMember placeCuMember = iCuMemberBusinessService.queryCuMemberPlaceDept(cuMember, false, false);
if (!redisService.lockKeyOnce(CacheConstants.POSITION + placeCuMember.getPkPlaceParent() + placeCuMember.getPlaceDept(), Constants.FIVE_TIMEOUT_SECOND)) {
try {
Thread.sleep(300);
repeatTryTree(cuMember);
} catch (Exception e) {
e.printStackTrace();
}
}
return placeCuMember;
}
@Override
public void deleteCuMemberByPkMember(Long pkMember, Long pkApprove, Date currentDateTime) {
LambdaUpdateWrapper<CuMember> updateWrapper = new LambdaUpdateWrapper<>();
@ -3146,7 +2863,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
update(updateWrapper);
}
@Override
public boolean updateMemberNameAndPhone(Long pkMember, String memberName, String phone, Long pkModified) {
LambdaUpdateWrapper<CuMember> updateWrapper = new LambdaUpdateWrapper<>();
@ -3163,38 +2879,16 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return baseMapper.queryCuMemberLastPlaceParent(pkMember);
}
/**
* 查询会员真实信息
*
* @return
*/
@Override
public List<MemberRealInfoVO> selectByMemberRealInfo(MemberRealInfoParam memberRealInfoParam) {
return baseMapper.selectByMemberRealInfo(memberRealInfoParam);
}
/**
* 查询推荐列表
*
* @param pkParent 会员主键
* @param memberCode 会员编号
* @param memberName 会员名称
* @param startCreateTime 开始时间
* @param endCreateTime 结束时间
* @param memberInfo 会员信息
* @return
*/
@Override
public List<ParentMemberVo> parentList(Long pkParent, String memberCode, String memberName, Date startCreateTime, Date endCreateTime, String memberInfo) {
return baseMapper.parentList(pkParent, memberCode, memberName, startCreateTime, endCreateTime, memberInfo);
}
/**
* 查询注册列表
*
* @param marketNewsParam
* @return
*/
@Override
public List<UserInvestmentVo> selectRegList(MarketNewsParam marketNewsParam) {
return baseMapper.selectRegList(marketNewsParam);
@ -3205,13 +2899,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return baseMapper.findNoPayMember(memberCodes, pkCountry);
}
/**
* 计算明星用时
*/
public String getStarTime() {
return RandomUtil.randomDouble(5, 10) + "";
}
@Override
public int checkParent(String topCode, Long pkMember) {
return baseMapper.checkParent(topCode, pkMember);
@ -3235,23 +2922,11 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return resultMap;
}
/**
* 查询全部用户
*
* @return
*/
@Override
public List<CuMemberExt> findAll() {
return baseMapper.findAll();
}
/**
* 查询左右区人数统计
*
* @param pkMember
* @param placeDept
* @return
*/
@Override
public Long selectByDeptNumberCount(Long pkMember, Integer placeDept) {
return baseMapper.selectByDeptNumberCount(pkMember, placeDept);
@ -3262,20 +2937,11 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return baseMapper.selectMemberByMemberCode(memberCode, memberName, pkCountry);
}
/**
* @description: 查询表是否存在
**/
@Override
public Integer selectExistTable(String tableName) {
return baseMapper.selectExistTable(tableName);
}
/**
* 校验商品团队信息是否可见
*
* @param showWaresDTOS
* @return
*/
@Override
public Map<Integer, Boolean> checkIsShowWares(List<ShowWaresDTO> showWaresDTOS) {
Map<Integer, Boolean> resultMap = new HashMap<>();
@ -3358,13 +3024,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return baseMapper.queryPlaceSponsorUnderUmbrella(waresAuthorityParentParamList);
}
/**
* 查询编号是否在登录用户伞下
*
* @param pkMember
* @param memberCode
* @return
*/
@Override
public Long checkPlaceSponsorUnderUmbrella(Long pkMember, String memberCode) {
return baseMapper.checkPlaceSponsorUnderUmbrella(pkMember, memberCode);
@ -3395,11 +3054,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return baseMapper.insertBatchCuMember(memberList);
}
/**
* 修改直推审批
*
* @param updateParentPetitionParam
*/
@Override
public UpdateParentPetitionParam petitionUpdateParent(UpdateParentPetitionParam updateParentPetitionParam) {
Integer pkCountry = SecurityUtils.getPkCountry();
@ -3476,11 +3130,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return updateParentPetitionParam;
}
/**
* 修改安置审批
*
* @param updatePlaceParentPetitionParam
*/
@Override
public UpdatePlaceParentPetitionParam petitionUpdatePlaceParent(UpdatePlaceParentPetitionParam updatePlaceParentPetitionParam) {
Integer pkCountry = SecurityUtils.getPkCountry();
@ -3569,11 +3218,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return updatePlaceParentPetitionParam;
}
/**
* 修改直推通过
*
* @param approvalBusinessResultDTO
*/
@Override
public void updateParentByBusinessNo(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
//修改直推
@ -3596,11 +3240,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
}
}
/**
* 修改直推驳回
*
* @param approvalBusinessResultDTO
*/
@Override
public void updateParentByBusinessNoReject(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
//修改直推
@ -3646,11 +3285,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
}
}
/**
* 修改安置通过
*
* @param approvalBusinessResultDTO
*/
@Override
public void updatePlaceParentByBusinessNo(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
//修改安置
@ -3670,14 +3304,8 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
iCuMemberServiceLogService.updateById(memberServiceLog);
}
}
}
/**
* 修改安置驳回
*
* @param approvalBusinessResultDTO
*/
@Override
public void updatePlaceParentByBusinessNoReject(ApprovalBusinessResultDTO approvalBusinessResultDTO) {
String businessCode = approvalBusinessResultDTO.getBusinessCode();
@ -3751,7 +3379,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return this.update(updateWrapper);
}
@Override
public List<CuMemberExt> selectPlaceErrorCode() {
return baseMapper.selectPlaceErrorCode();
@ -3763,45 +3390,21 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return cuMemberList != null && cuMemberList.size() > 0;
}
/**
* @description: 校验会员是否存在三方订单
**/
@Override
public Integer checkThreeOrder(Long pkMember) {
return baseMapper.checkThreeOrder(pkMember);
}
/**
* 校验新安置部门和安置编号下是否已存在节点
*
* @param placeDeptMemberCode
* @param placeDept
* @return
*/
@Override
public Long checkPlaceDeptAndMemberCode(String placeDeptMemberCode, Integer placeDept) {
return baseMapper.checkPlaceDeptAndMemberCode(placeDeptMemberCode, placeDept);
}
/**
* 校验会员体系伞下
*
* @param vertexIdList
* @param memberCode
* @return
*/
@Override
public List<CuMemberExt> checkMemberVertex(List<Integer> vertexIdList, String memberCode) {
return baseMapper.checkMemberVertex(vertexIdList, memberCode);
}
/**
* 校验修改直推 memberCode 是否在自己血缘伞下
*
* @param pkMember
* @param memberCode
* @return
*/
@Override
public Long checkMemberParent(Long pkMember, String memberCode) {
return baseMapper.checkMemberParent(pkMember, memberCode);
@ -3813,23 +3416,11 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return baseMapper.updateMemberEditNumber(pkMemberList, updatePkMember);
}
/**
* 查询会员安置伞上
*
* @param pkMember
* @param editNewPlaceMemberCode
* @return
*/
@Override
public List<CuMember> checkMemberPlaceParent(Long pkMember, String editNewPlaceMemberCode) {
return baseMapper.checkMemberPlaceParent(pkMember, editNewPlaceMemberCode);
}
/**
* @param pkMember 推荐人
* @param editNewPlaceMemberCode 安置后会员编号
* @return
*/
@Override
public Long checkPlaceMemberList(Long pkMember, String editNewPlaceMemberCode) {
return baseMapper.checkPlaceMemberList(pkMember, editNewPlaceMemberCode);
@ -3850,11 +3441,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return baseMapper.updateMemberExpireDate();
}
/**
* 用户消费统计
*
* @return
*/
@Override
public List<MemberConsumptionStatVo> getMemberConsumptionStat(MemberConsumptionStatParam memberConsumptionStatParam) {
return baseMapper.getMemberConsumptionStat(memberConsumptionStatParam);
@ -3940,15 +3526,6 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return baseMapper.countGradeMemberPoint(memberName, phone, pkGrade, pkCountry);
}
private boolean validateFirstOrder(Long pkParent, Integer pkCountry) {
String validateFirstOrder = querySystemConfigByKey(pkCountry, ESystemConfig.FIRST_ORDER.getKey());
if (EYesNo.YES.getIntValue() == Integer.parseInt(validateFirstOrder)) {
Integer count = queryCuMemberByPkMember(pkParent);
return count == 0;
}
return false;
}
private String querySystemConfigByKey(Integer pkCountry, String key) {
return iSystemConfigServiceApi.getBonusSystemConfig(pkCountry, key).getData();
}