refactor(vip): 优化积分和返佣计算逻辑

Administrator

2025-05-19 9b51a95fa8bc9b3a86108c6900e17fc55f8db467

 src/main/java/cc/mrbird/febs/mall/service/impl/AdminMallMemberServiceImpl.java

@@ -2,15 +2,13 @@

import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.entity.QueryRequest;
import cc.mrbird.febs.common.enumerates.AgentLevelEnum;
import cc.mrbird.febs.common.enumerates.FlowTypeEnum;
import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum;
import cc.mrbird.febs.common.enumerates.*;
import cc.mrbird.febs.common.exception.FebsException;
import cc.mrbird.febs.common.utils.LoginUserUtil;
import cc.mrbird.febs.common.utils.AppContants;
import cc.mrbird.febs.common.utils.MallUtils;
import cc.mrbird.febs.common.utils.RedisUtils;
import cc.mrbird.febs.mall.dto.*;
import cc.mrbird.febs.mall.entity.*;
import cc.mrbird.febs.mall.entity.MallNewsInfo;
import cc.mrbird.febs.mall.mapper.*;
import cc.mrbird.febs.mall.service.IAdminMallMemberService;
import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
@@ -19,17 +17,19 @@
import cc.mrbird.febs.pay.model.MemberWithdrawalDto;
import cc.mrbird.febs.pay.service.IXcxPayService;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.crypto.SecureUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.xmlbeans.impl.store.Query;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@@ -46,6 +46,8 @@
@RequiredArgsConstructor
@Transactional
public class AdminMallMemberServiceImpl extends ServiceImpl<MallMemberMapper, MallMember> implements IAdminMallMemberService {

    private final RedisUtils redisUtils;

    private final MallMemberMapper mallMemberMapper;

@@ -70,25 +72,18 @@

    private final MallAgentRecordMapper mallAgentRecordMapper;
    private final MallSalesmanMapper mallSalesmanMapper;
    private final SalemanCouponMapper salemanCouponMapper;
    private final MallMemberCouponMapper mallMemberCouponMapper;
    private final MallGoodsCouponMapper mallGoodsCouponMapper;
    private final HappySaleLevelMapper  happySaleLevelMapper;
    private final HappyMemberLevelMapper happyMemberLevelMapper;


    @Override
    public IPage<MallMember> getMallMemberList(MallMember mallMember, QueryRequest request) {
        Page<MallMember> page = new Page<>(request.getPageNum(), request.getPageSize());
        IPage<MallMember> mallMembers = this.baseMapper.selectMallMemberListInPage(page, mallMember);
        if(CollUtil.isNotEmpty(mallMembers.getRecords())){
            for(MallMember mallMemberTeam : mallMembers.getRecords()){
                Long salesmansId = mallMemberTeam.getSalesmansId();
                MallSalesman mallSalesman = mallSalesmanMapper.selectById(salesmansId);
                if(ObjectUtil.isNotEmpty(mallSalesman)){
                    StringBuffer salesmanName = new StringBuffer();
                    salesmanName.append(mallSalesman.getName());
                    if(2 == mallSalesman.getState()){
                        salesmanName.append("（禁用）");
                    }
                    mallMemberTeam.setSalesmansName(salesmanName.toString());
                }
            }
        }
//        IPage<MallMember> mallMembers = this.baseMapper.selectMallMemberListInPage(page, mallMember);
        IPage<MallMember> mallMembers = this.baseMapper.selectHappyMemberListInPage(page, mallMember);
        return mallMembers;
    }

@@ -285,6 +280,126 @@
        return dataDictionaryCustomMapper.getAgentLevelOption();
    }


    @Override
    public List<AdminAgentLevelOptionTreeVo> agentLevelOption() {
        return dataDictionaryCustomMapper.agentLevelOption();
    }

    @Override
    public FebsResponse agentVerifyUpdate(AdminAgentVerifyVo adminAgentVerifyVo) {
        MallAgentRecord mallAgentRecord = mallAgentRecordMapper.selectById(adminAgentVerifyVo.getId());
        if(ObjectUtil.isEmpty(mallAgentRecord)){
            throw new FebsException("记录不存在");
        }
        BigDecimal amount = adminAgentVerifyVo.getAmount();
        if(BigDecimal.ZERO.compareTo(amount) >= 0){
            throw new FebsException("请输入正确的金额");
        }
//        if(StrUtil.isEmpty(adminAgentVerifyVo.getLevelCode())){
//            throw new FebsException("请选择代理级别");
//        }
//        mallAgentRecord.setAgentLevel(adminAgentVerifyVo.getLevelCode());
        mallAgentRecord.setAmount(adminAgentVerifyVo.getAmount());
        mallAgentRecordMapper.updateById(mallAgentRecord);
        return new FebsResponse().success().message("操作成功");
    }

    @Override
    public FebsResponse doctorStateChange(Long id) {
        MallMember mallMember = this.baseMapper.selectById(id);
        if(ObjectUtil.isEmpty(mallMember)){
            throw new FebsException("请刷新页面");
        }
        mallMember.setDoctorState(mallMember.getDoctorState() == 1 ? 0 : 1);
        this.baseMapper.updateById(mallMember);
        return new FebsResponse().success().message("操作成功");
    }

    @Override
    public FebsResponse upCoupon(Long id) {
        MallMember mallMember = this.baseMapper.selectById(id);
        if(ObjectUtil.isEmpty(mallMember)){
            throw new FebsException("请刷新页面");
        }
        mallMember.setIsSale(1);
        this.baseMapper.updateById(mallMember);
        return new FebsResponse().success().message("操作成功");
    }

    @Override
    public FebsResponse downCoupon(Long id) {
        MallMember mallMember = this.baseMapper.selectById(id);
        if(ObjectUtil.isEmpty(mallMember)){
            throw new FebsException("请刷新页面");
        }
        mallMember.setIsSale(2);
        this.baseMapper.updateById(mallMember);

        QueryWrapper<SalemanCoupon> objectQueryWrapper = new QueryWrapper<>();
        objectQueryWrapper.eq("member_id",mallMember.getId());
        List<SalemanCoupon> salemanCouponList = salemanCouponMapper.selectList(objectQueryWrapper);
        if(CollUtil.isNotEmpty(salemanCouponList)){
            for(SalemanCoupon salemanCoupon : salemanCouponList){
                salemanCouponMapper.deleteById(salemanCoupon);
            }
        }

        return new FebsResponse().success().message("操作成功");
    }

    @Override
    public FebsResponse memberOut(Long id) {

        MallMember mallMember = this.baseMapper.selectById(id);
        if(ObjectUtil.isEmpty(mallMember)){
            throw new FebsException("请刷新页面");
        }
        String redisKey = AppContants.XCX_LOGIN_PREFIX + mallMember.getId();
        String existToken = redisUtils.getString(redisKey);
        if (StrUtil.isNotBlank(existToken)) {
            Object o = redisUtils.get(existToken);
            if (ObjectUtil.isNotEmpty(o)) {
                redisUtils.del(existToken);
            }
        }
        redisUtils.del(AppContants.XCX_LOGIN_PREFIX + id);
        redisUtils.del(AppContants.XCX_LOGIN_PHONE_PREFIX + id);
        this.baseMapper.deleteById(mallMember);
        return new FebsResponse().success().message("操作成功");
    }

    @Override
    public IPage<MallMember> getsalemanRuleList(MallMember mallMember, QueryRequest request) {
        Page<MallMember> page = new Page<>(request.getPageNum(), request.getPageSize());
        IPage<MallMember> mallMembers = this.baseMapper.getsalemanRuleList(page, mallMember);
        return mallMembers;
    }

    @Override
    public FebsResponse salemanCoupon(MallMember mallmember) {
        MallMember member = this.baseMapper.selectById(mallmember.getId());
        if(ObjectUtil.isEmpty(member)){
            throw new FebsException("请刷新页面");
        }
        Long couponId = mallmember.getCouponId();

        QueryWrapper<SalemanCoupon> objectQueryWrapper = new QueryWrapper<>();
        objectQueryWrapper.eq("member_id",member.getId());
        List<SalemanCoupon> salemanCouponList = salemanCouponMapper.selectList(objectQueryWrapper);
        if(CollUtil.isNotEmpty(salemanCouponList)){
            SalemanCoupon salemanCoupon = salemanCouponList.get(0);
            salemanCoupon.setCouponId(couponId);
            salemanCouponMapper.updateById(salemanCoupon);
            return new FebsResponse().success().message("操作成功");
        }
        SalemanCoupon salemanCoupon = new SalemanCoupon();
        salemanCoupon.setMemberId(member.getId());
        salemanCoupon.setCouponId(couponId);
        salemanCouponMapper.insert(salemanCoupon);
        return new FebsResponse().success().message("操作成功");
    }

    @Override
    public IPage<AdminAgentMemberVo> agentChild(QueryRequest request, MallMember mallMember) {
        Long memberId = mallMember.getId();
@@ -396,12 +511,16 @@

        Integer type = mallSystemPayDto.getType();
        String filedType = "";
        Integer flowType = 0;
        if (type == 1) {
            filedType = "balance";
            flowType = FlowTypeEnum.BALANCE.getValue();
        } else if (type == 2) {
            filedType = "score";
        } else if (type == 3) {
            filedType = "prizeScore";
            flowType = FlowTypeEnum.PRIZE_SCORE.getValue();
        } else if (type == 3) {
            filedType = "commission";
            flowType = FlowTypeEnum.COMMISSION.getValue();
        } else {
            throw new FebsException("参数错误");
        }
@@ -415,7 +534,15 @@
        } else {
            iApiMallMemberWalletService.add(mallSystemPayDto.getAddBalance(), mallSystemPayDto.getId(), filedType);
        }
        mallMoneyFlowService.addMoneyFlow(memberId, bigDecimal, MoneyFlowTypeEnum.SYSTEM.getValue(), null, type);
        mallMoneyFlowService.addMoneyFlow(
                memberId,
                bigDecimal,
                ScoreFlowTypeEnum.SYSTEM.getValue(),
                MallUtils.getOrderNum(),
                flowType,
                StrUtil.format(ScoreFlowTypeEnum.SYSTEM.getDesc(),bigDecimal),
                2
        );
        return new FebsResponse().success();
    }

@@ -583,16 +710,29 @@
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void modifyReferer(MallMember member) {
        MallMember referer = this.baseMapper.selectInfoByInviteId(member.getReferrerId());
        if(StrUtil.isEmpty(member.getReferrerId())){
            this.baseMapper.updateReferrerId(member.getId());
            return;
        }
        String referrerId = member.getReferrerId();//新的推荐人邀请码
        //获取新推荐人信息
        MallMember referer = this.baseMapper.selectInfoByInviteId(referrerId);
        if (referer == null) {
            throw new FebsException("推荐人不存在");
        }
        String refererId = member.getReferrerId();
        member = this.baseMapper.selectById(member.getId());//修改的用户

        member = this.baseMapper.selectById(member.getId());

        String beforeReferer = member.getReferrerId();
        member.setReferrerId(refererId);
        if(member.getInviteId().equals(referrerId)){
            throw new FebsException("自己不能推荐自己");
        }
        String refererId = referer.getInviteId();//新推荐人的邀请码
        if(StrUtil.isNotEmpty(referer.getReferrerIds())){
            if (referer.getReferrerIds().contains(member.getInviteId())) {
                throw new FebsException("修改的推荐关系不符合规则");
            }
        }
//        String beforeReferer = member.getReferrerId();
        member.setReferrerId(refererId);//更新用户的上级推荐人为新推荐人的邀请码refererId
        String refererIds = refererIds(refererId);
        member.setReferrerIds(refererIds);
        this.baseMapper.updateById(member);
@@ -797,4 +937,35 @@

        return ids;
    }

    @Override
    public FebsResponse addMemberCoupon(MallMember member) {
        MallGoodsCoupon existCoupon = mallGoodsCouponMapper.selectById(member.getCouponId());
        if(existCoupon == null) {
            return new FebsResponse().fail().message("优惠券不存在");
        }

        MallMemberCoupon memberCoupon = new MallMemberCoupon();
        memberCoupon.setCouponId(existCoupon.getId());
        memberCoupon.setCouponName(existCoupon.getName());
        memberCoupon.setInviteId(member.getInviteId());
        memberCoupon.setCouponUuid(IdUtil.simpleUUID());
        memberCoupon.setState(1);
        memberCoupon.setFromType(4);
        memberCoupon.setExpireTime(DateUtil.offsetDay(DateUtil.date(), existCoupon.getExpireDay()));
        memberCoupon.setMemberId(member.getId());
        mallMemberCouponMapper.insert(memberCoupon);

        return new FebsResponse().success().message("操作成功");
    }

    @Override
    public FebsResponse checkOrder(Long id) {

        MallMember mallMember = this.baseMapper.selectById(id);
        mallMember.setCheckOrder(StateUpDownEnum.DOWN.getCode() == mallMember.getCheckOrder() ? StateUpDownEnum.UP.getCode() : StateUpDownEnum.DOWN.getCode());
        this.baseMapper.updateById(mallMember);

        return new FebsResponse().success().message("操作成功");
    }
}