优化

gongzuming

2024-11-12 8f725f326e3243220027424bb0599d0ebb9e4bec

 src/main/java/com/mzl/flower/service/point/CustomerPointService.java

@@ -1,9 +1,229 @@
package com.mzl.flower.service.point;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.mzl.flower.config.exception.ValidationException;
import com.mzl.flower.config.security.SecurityUtils;
import com.mzl.flower.dto.request.point.ChangePointDTO;
import com.mzl.flower.dto.request.point.QueryCustomerPointDTO;
import com.mzl.flower.dto.request.point.QueryPointDetailDTO;
import com.mzl.flower.dto.response.point.CustomerPointDTO;
import com.mzl.flower.dto.response.point.CustomerPointDetailDTO;
import com.mzl.flower.entity.customer.Customer;
import com.mzl.flower.entity.point.CustomerPoint;
import com.mzl.flower.entity.point.CustomerPointDetail;
import com.mzl.flower.mapper.point.CustomerPointDetailMapper;
import com.mzl.flower.mapper.point.CustomerPointMapper;
import com.mzl.flower.service.BaseService;
import com.mzl.flower.service.payment.RedisLockService;
import com.mzl.flower.utils.DateUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.time.LocalDate;
import java.util.ArrayList;
import java.util.List;

import com.mzl.flower.constant.Constants.*;

@Service
@Transactional
public class CustomerPointService {
public class CustomerPointService extends BaseService {

    private final CustomerPointMapper customerPointMapper;

    private final CustomerPointDetailMapper customerPointDetailMapper;

    private final  RedisLockService redisLockService;


    public CustomerPointService(CustomerPointMapper customerPointMapper, CustomerPointDetailMapper customerPointDetailMapper, RedisLockService redisLockService) {
        this.customerPointMapper = customerPointMapper;
        this.customerPointDetailMapper = customerPointDetailMapper;
        this.redisLockService = redisLockService;
    }

    public Page<CustomerPointDTO> queryPage(QueryCustomerPointDTO dto, Page page) {
        List<CustomerPointDTO> list = customerPointMapper.queryPage(dto, page);
        page.setRecords(list);
        return page;
    }

    public  Page<CustomerPointDetailDTO> queryCustomerDetails(QueryPointDetailDTO dto, Page page) {
        if(StringUtils.isNotBlank(dto.getCreateTimeStartStr())){
            dto.setCreateTimeStart(DateUtils.dateTimeStringToLocalDateTime(dto.getCreateTimeStartStr()));
        }
        if(StringUtils.isNotBlank(dto.getCreateTimeEndStr())){
            dto.setCreateTimeEnd(DateUtils.dateTimeStringToLocalDateTime(dto.getCreateTimeEndStr()));
        }
        List<CustomerPointDetailDTO> list = customerPointMapper.queryCustomerDetails(dto, page);
        page.setRecords(list);

        return page;
    }

    public void giveawayPoint(ChangePointDTO dto) {
        CustomerPointDetail detail = new CustomerPointDetail();
        Customer customer = getCustomer(dto.getCustomerId());
        detail.setCustomerId(customer.getId());
        detail.setUserId(customer.getUserId());
        detail.setPoint(dto.getPoint());
        detail.setRemarks(dto.getRemarks());
        detail.setRecordDate(LocalDate.now());
        detail.setChangeType(POINT_CHANGE_TYPE.add.name());
        detail.setType(POINT_TYPE.giveaway.name());
        detail.create(SecurityUtils.getUserId());
        customerPointDetailMapper.insert(detail);

        //更新汇总表
        updateCustomerPoint(detail);
    }

    public void updateCustomerPoint(CustomerPointDetail detail) {
        boolean lock = redisLockService.getObjectLock("LOCK_KEY_CUSTOMER_POINT_", detail.getUserId());
        if(!lock){
            return;
        }
        try {
            CustomerPoint point = customerPointMapper.selectOne(new LambdaQueryWrapper<CustomerPoint>()
                    .eq(CustomerPoint::getCustomerId, detail.getCustomerId()));
            boolean isAdd = false;
            if(point == null){
                isAdd = true;
                point = new CustomerPoint();
                point.setCustomerId(detail.getCustomerId());
                point.setUserId(detail.getUserId());
                point.setTotalPoint(0);
                point.setUsedPoint(0);
                point.setExpiredPoint(0);
                point.setDeductionPoint(0);
                point.create(SecurityUtils.getUserId());
            }

            if(POINT_CHANGE_TYPE.add.name().equals(detail.getChangeType())){
                point.setTotalPoint(point.getTotalPoint() + detail.getPoint());
            }else if(POINT_CHANGE_TYPE.reduce.name().equals(detail.getChangeType())){
                Integer detailPoint = detail.getPoint();
                if(POINT_TYPE.deduction.name().equals(detail.getType())){ //积分扣减
                    Integer balancePoint = point.getTotalPoint() - point.getUsedPoint()-point.getExpiredPoint()-point.getDeductionPoint();//可用积分
                    balancePoint = balancePoint.intValue()>0?balancePoint.intValue():0;
                    if(balancePoint.intValue() >= detail.getPoint().intValue()){
                        point.setDeductionPoint(point.getDeductionPoint() + detail.getPoint());
                    }else{
                        //积分不足，直接清0
                        point.setDeductionPoint(point.getDeductionPoint() + balancePoint);
                        detail.setPoint(balancePoint);
                        detail.setRemarks(detail.getRemarks()+",当前积分不足"+detailPoint+"，实际扣除积分"+balancePoint);
                    }
                }
            }
            if(isAdd){
                customerPointMapper.insert(point);
            }else{
                customerPointMapper.updateById(point);
            }
        }finally {
            redisLockService.releaseObjectLock("LOCK_KEY_CUSTOMER_POINT_", detail.getUserId());
        }
    }

    public void deductionPoint(ChangePointDTO dto) {
        CustomerPointDetail detail = new CustomerPointDetail();
        Customer customer = getCustomer(dto.getCustomerId());
        detail.setCustomerId(customer.getId());
        detail.setUserId(customer.getUserId());
        detail.setPoint(dto.getPoint());
        detail.setRemarks(dto.getRemarks());
        detail.setRecordDate(LocalDate.now());
        detail.setChangeType(POINT_CHANGE_TYPE.reduce.name());
        detail.setType(POINT_TYPE.deduction.name());
        detail.create(SecurityUtils.getUserId());
        //更新汇总表
        updateCustomerPoint(detail);

        customerPointDetailMapper.insert(detail);
    }

    public void consumptionPoint(BigDecimal orderAmount, String orderNo,String userId)  {
        CustomerPointDetail detail = new CustomerPointDetail();
        Customer customer = getCustomerByUserId(userId);
        detail.setCustomerId(customer.getId());
        detail.setUserId(customer.getUserId());
        BigDecimal point = orderAmount.setScale(0, BigDecimal.ROUND_HALF_UP);
        detail.setPoint(point.intValue());
        detail.setRemarks(orderNo);
        detail.setRecordDate(LocalDate.now());
        detail.setChangeType(POINT_CHANGE_TYPE.add.name());
        detail.setType(POINT_TYPE.consume.name());
        detail.create(SecurityUtils.getUserId());
        customerPointDetailMapper.insert(detail);

        //更新汇总表
        updateCustomerPoint(detail);
    }

    public void signIn() {
        if(signToday()){
            throw new ValidationException("今天已经签到过了");
        }
        int signNum = customerPointDetailMapper
                .selectCount(new LambdaQueryWrapper<CustomerPointDetail>()
                        .eq(CustomerPointDetail::getUserId, SecurityUtils.getUserId())
                        .ge(CustomerPointDetail::getRecordDate,LocalDate.now().minusDays(9))
                        .eq(CustomerPointDetail::getChangeType,POINT_CHANGE_TYPE.add.name())
                        .eq(CustomerPointDetail::getType,POINT_TYPE.sign.name())
                );
        int point = 1;
        if(signNum==9){
            point = 3;
        }
        CustomerPointDetail detail = new CustomerPointDetail();
        Customer customer = getCurrentCustomer();
        detail.setCustomerId(customer.getId());
        detail.setUserId(customer.getUserId());
        detail.setPoint(point);
        detail.setRemarks("签到");
        detail.setRecordDate(LocalDate.now());
        detail.setChangeType(POINT_CHANGE_TYPE.add.name());
        detail.setType(POINT_TYPE.sign.name());
        detail.create(SecurityUtils.getUserId());
        customerPointDetailMapper.insert(detail);

        //更新汇总表
        updateCustomerPoint(detail);
    }

    public List<CustomerPointDetailDTO> signList(LocalDate startDate, LocalDate endDate) {
        LambdaQueryWrapper<CustomerPointDetail> lambdaQueryWrapper = new LambdaQueryWrapper<CustomerPointDetail>()
                .eq(CustomerPointDetail::getUserId, SecurityUtils.getUserId())
                .eq(CustomerPointDetail::getChangeType, POINT_CHANGE_TYPE.add.name())
                .eq(CustomerPointDetail::getType, POINT_TYPE.sign.name());
        lambdaQueryWrapper.orderByDesc(CustomerPointDetail::getRecordDate);
        if(startDate!=null){
            lambdaQueryWrapper.ge(CustomerPointDetail::getRecordDate,startDate);
        }
        if (endDate != null) {
            lambdaQueryWrapper.le(CustomerPointDetail::getRecordDate, endDate);
        }

        List<CustomerPointDetail> details = customerPointDetailMapper.selectList(lambdaQueryWrapper);
        List<CustomerPointDetailDTO> dtos = new ArrayList<>();
        for (CustomerPointDetail detail : details) {
            CustomerPointDetailDTO dto = new CustomerPointDetailDTO();
            BeanUtils.copyProperties(detail, dto);
            dtos.add(dto);
        }
        return dtos;
    }

    public Boolean signToday() {
        return customerPointDetailMapper.selectCount(new LambdaQueryWrapper<CustomerPointDetail>()
                        .eq(CustomerPointDetail::getUserId, SecurityUtils.getUserId())
                        .eq(CustomerPointDetail::getRecordDate,LocalDate.now())
                        .eq(CustomerPointDetail::getChangeType,POINT_CHANGE_TYPE.add.name())
                        .eq(CustomerPointDetail::getType,POINT_TYPE.sign.name()))>0;
    }
}