明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2024-08-19 5a22de857470ed18e993260e2cf3a38a1a43de7e 
 ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TAccountingStrategyDetailServiceImpl.java


@@ -2,6 +2,8 @@




import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ruoyi.account.api.feignClient.AppUserClient;


import com.ruoyi.account.api.model.TAppUser;


import com.ruoyi.chargingPile.api.model.TAccountingStrategy;


import com.ruoyi.chargingPile.api.model.TAccountingStrategyDetail;


import com.ruoyi.chargingPile.api.vo.StrategyPriceVO;


@@ -10,11 +12,13 @@


import com.ruoyi.chargingPile.mapper.TAccountingStrategyMapper;


import com.ruoyi.chargingPile.service.TAccountingStrategyDetailService;


import com.ruoyi.common.core.exception.ServiceException;


import com.ruoyi.common.security.service.TokenService;


import com.ruoyi.other.api.domain.TVip;


import com.ruoyi.other.api.feignClient.VipClient;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;




import javax.annotation.Resource;


import java.math.BigDecimal;


import java.time.LocalTime;


import java.util.ArrayList;


@@ -36,7 +40,10 @@


    private TAccountingStrategyMapper accountingStrategyMapper;


    @Autowired


    private VipClient vipClient;




    @Autowired


    private TokenService tokenService;


    @Autowired


    private AppUserClient appUserClient;


    @Override


    public List<TAccountingStrategyDetailVO> queryAccountingStrategyDetailByStrategyId(Integer strategyId) {


        return this.baseMapper.queryAccountingStrategyDetailByStrategyId(strategyId);


@@ -51,18 +58,40 @@


            throw new ServiceException("未查询到计费策略");


        }


        List<TAccountingStrategyDetailVO> list = this.queryAccountingStrategyDetailByStrategyId(accountingStrategy.getId());


        // 获取当前时间段的计费策略明细


        TAccountingStrategyDetailVO accountingStrategyDetailVO = list.stream().filter(detail -> detail.getStartTime().compareTo(LocalTime.now().toString()) <= 0 && detail.getEndTime().compareTo(LocalTime.now().toString()) >= 0)


                .findFirst().orElseThrow(() -> new ServiceException("当前时间段未查询到计费策略明细"));


        accountingStrategyDetailVO.setDiscount(accountingStrategy.getDiscount());


        // 获取后一次的计费策略明细


        TAccountingStrategyDetailVO accountingStrategyDetailNext = list.stream().filter(detail -> detail.getStartTime().compareTo(accountingStrategyDetailVO.getEndTime()) == 0)


                .findFirst().orElseThrow(() -> new ServiceException("未查询到下一时间段的计费策略明细"));


        accountingStrategyDetailNext.setDiscount(accountingStrategy.getDiscount());


        list = new ArrayList<>();


        list.add(accountingStrategyDetailVO);


        list.add(accountingStrategyDetailNext);


        return list;


        // 获取当前登录用户id


        Long userId = tokenService.getLoginUserApplet().getUserId();


        // 根据id查询用户信息


        TAppUser appUser = appUserClient.getUserById(userId).getData();


        if(Objects.nonNull(appUser) && Objects.nonNull(appUser.getVipId())){


            // 查询会员信息


            TVip vip = vipClient.getInfo1(appUser.getVipId()).getData();


            TAccountingStrategyDetailVO accountingStrategyDetailVO;


            TAccountingStrategyDetailVO accountingStrategyDetailNext;


            if(Objects.nonNull(vip) && vip.getType() == 2){


                // 获取当前时间段的计费策略明细


                accountingStrategyDetailVO = list.stream().filter(detail -> detail.getStartTime().compareTo(LocalTime.now().toString()) <= 0 && detail.getEndTime().compareTo(LocalTime.now().toString()) >= 0)


                        .findFirst().orElseThrow(() -> new ServiceException("当前时间段未查询到计费策略明细"));


                accountingStrategyDetailVO.setDiscount(accountingStrategyDetailVO.getElectrovalence().add(accountingStrategyDetailVO.getServiceCharge()).multiply(vip.getDiscount()));


                // 获取后一次的计费策略明细


                accountingStrategyDetailNext = list.stream().filter(detail -> detail.getStartTime().compareTo(accountingStrategyDetailVO.getEndTime()) == 0)


                        .findFirst().orElseThrow(() -> new ServiceException("未查询到下一时间段的计费策略明细"));


                accountingStrategyDetailNext.setDiscount(accountingStrategyDetailNext.getElectrovalence().add(accountingStrategyDetailNext.getServiceCharge()).multiply(vip.getDiscount()));


            }else {


                // 获取当前时间段的计费策略明细


                accountingStrategyDetailVO = list.stream().filter(detail -> detail.getStartTime().compareTo(LocalTime.now().toString()) <= 0 && detail.getEndTime().compareTo(LocalTime.now().toString()) >= 0)


                        .findFirst().orElseThrow(() -> new ServiceException("当前时间段未查询到计费策略明细"));


                accountingStrategyDetailVO.setDiscount(accountingStrategyDetailVO.getElectrovalence().add(accountingStrategyDetailVO.getServiceCharge()).multiply(accountingStrategy.getDiscount()));


                // 获取后一次的计费策略明细


                accountingStrategyDetailNext = list.stream().filter(detail -> detail.getStartTime().compareTo(accountingStrategyDetailVO.getEndTime()) == 0)


                        .findFirst().orElseThrow(() -> new ServiceException("未查询到下一时间段的计费策略明细"));


                accountingStrategyDetailNext.setDiscount(accountingStrategyDetailNext.getElectrovalence().add(accountingStrategyDetailNext.getServiceCharge()).multiply(accountingStrategy.getDiscount()));


            }


            list = new ArrayList<>();


            list.add(accountingStrategyDetailVO);


            list.add(accountingStrategyDetailNext);


            return list;


        }


        return new ArrayList<>();


    }




    @Override