package com.dingzhuo.energy.project.electricityTypeSetting.service.impl;
|
|
import com.dingzhuo.energy.project.electricityTypeSetting.domain.dto.ElectricityTypeSettingAddVO;
|
import com.dingzhuo.energy.project.electricityTypeSetting.domain.dto.ElectricityTypeSettingItemAddVO;
|
import com.dingzhuo.energy.project.electricityTypeSetting.domain.dto.ElectricityTypeSettingItemUpdateVO;
|
import com.dingzhuo.energy.project.electricityTypeSetting.domain.dto.ElectricityTypeSettingUpdateVO;
|
import com.dingzhuo.energy.project.electricityTypeSetting.domain.entity.ElectricityTypeSetting;
|
import com.dingzhuo.energy.project.electricityTypeSetting.domain.entity.ElectricityTypeSettingItem;
|
import com.dingzhuo.energy.project.electricityTypeSetting.domain.enums.ElectricityTypeEnum;
|
import com.dingzhuo.energy.project.electricityTypeSetting.domain.vo.ElectricityTypeSettingItemQueryVO;
|
import com.dingzhuo.energy.project.electricityTypeSetting.domain.vo.ElectricityTypeSettingItemVO;
|
import com.dingzhuo.energy.project.electricityTypeSetting.domain.vo.ElectricityTypeSettingPageListVO;
|
import com.dingzhuo.energy.project.electricityTypeSetting.mapper.ElectricityTypeSettingItemMapper;
|
import com.dingzhuo.energy.project.electricityTypeSetting.mapper.ElectricityTypeSettingMapper;
|
import com.dingzhuo.energy.project.electricityTypeSetting.service.IElectricityTypeSettingService;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.UUID;
|
import java.util.stream.Collectors;
|
|
/**
|
* 计费规则Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2024-06-14
|
*/
|
@Service
|
public class ElectricityTypeSettingServiceImpl implements IElectricityTypeSettingService {
|
|
@Resource
|
private ElectricityTypeSettingMapper rulesMapper;
|
@Resource
|
private ElectricityTypeSettingItemMapper ruleDetailsMapper;
|
|
|
/**
|
* 查询计费规则列表
|
*/
|
@Override
|
public List<ElectricityTypeSettingPageListVO> selectPageList(String name) {
|
List<ElectricityTypeSettingPageListVO> rulesPageListVOList = rulesMapper.selectList(name);
|
if (CollectionUtils.isEmpty(rulesPageListVOList)) {
|
return rulesPageListVOList;
|
}
|
Date maxEffectiveDate = new Date();
|
Date date = new Date();
|
|
for (ElectricityTypeSettingPageListVO vo : rulesPageListVOList) {
|
Date effectiveDate = vo.getEffectiveDate();
|
// 判断并设置 effective 属性
|
if (effectiveDate.before(date) && effectiveDate.after(maxEffectiveDate)) {
|
maxEffectiveDate = effectiveDate;
|
vo.setEffective(true);
|
}
|
}
|
return rulesPageListVOList;
|
}
|
|
/**
|
* 获取计费规则详情
|
*/
|
@Override
|
public ElectricityTypeSettingItemQueryVO getRuleDetail(String id) {
|
ElectricityTypeSettingItemQueryVO rulesDetailQueryResponse = new ElectricityTypeSettingItemQueryVO();
|
|
ElectricityTypeSetting rules = rulesMapper.selectById(id);
|
if (ObjectUtils.isEmpty(rules)) {
|
return rulesDetailQueryResponse;
|
}
|
BeanUtils.copyProperties(rules, rulesDetailQueryResponse);
|
|
List<ElectricityTypeSettingItem> detailsList = ruleDetailsMapper.selectListByRuleId(id);
|
if (ObjectUtils.isNotEmpty(detailsList)) {
|
List<ElectricityTypeSettingItemVO> ruleDetailList = new ArrayList<>();
|
for (ElectricityTypeSettingItem ruleDetails : detailsList) {
|
ElectricityTypeSettingItemVO ruleDetailsResponse = new ElectricityTypeSettingItemVO();
|
BeanUtils.copyProperties(ruleDetails, ruleDetailsResponse);
|
ruleDetailsResponse.setTypeDesc(ElectricityTypeEnum.getNameByType(ruleDetails.getType()));
|
ruleDetailList.add(ruleDetailsResponse);
|
}
|
rulesDetailQueryResponse.setRuleDetailList(ruleDetailList);
|
}
|
return rulesDetailQueryResponse;
|
}
|
|
/**
|
* 修改计费策略
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void updateRule(ElectricityTypeSettingUpdateVO request) {
|
ElectricityTypeSetting rules = rulesMapper.selectById(request.getId());
|
if (ObjectUtils.isEmpty(rules)) {
|
throw new RuntimeException("计费规则不存在");
|
}
|
|
// 判断当前生效时间不能小于当前日期
|
Date now = new Date();
|
Date inputDate = request.getEffectiveDate();
|
if (inputDate.before(now) || inputDate.equals(now)) {
|
throw new RuntimeException("传入时间早于或等于当前时间: " + inputDate);
|
}
|
|
List<ElectricityTypeSettingItemUpdateVO> ruleDetailList = request.getRuleDetailList();
|
|
if (ruleDetailList.size() != 48) {
|
throw new RuntimeException("收费时间段必须是48条");
|
}
|
|
BeanUtils.copyProperties(request, rules);
|
rulesMapper.updateRules(rules);
|
|
for (ElectricityTypeSettingItemUpdateVO ruleDetailsRequest : ruleDetailList) {
|
ElectricityTypeSettingItem ruleDetails = new ElectricityTypeSettingItem();
|
|
ruleDetails.setId(ruleDetailsRequest.getId());
|
ruleDetails.setType(ruleDetailsRequest.getType());
|
if (ObjectUtils.isNotEmpty(ruleDetailsRequest.getRemark())) {
|
ruleDetails.setRemark(ruleDetailsRequest.getRemark());
|
}
|
ruleDetailsMapper.updateRuleDetails(ruleDetails);
|
}
|
}
|
|
/**
|
* 新增计费策略
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void addRule(ElectricityTypeSettingAddVO request) {
|
Date effectiveDate = request.getEffectiveDate();
|
Date now = new Date();
|
if (effectiveDate.before(now) || effectiveDate.equals(now)) {
|
throw new RuntimeException("传入时间早于或等于当前时间");
|
}
|
|
List<ElectricityTypeSettingItemAddVO> ruleDetailList = request.getRuleDetailList();
|
|
if (ruleDetailList.size() != 48) {
|
throw new RuntimeException("收费时间段必须是48条!");
|
}
|
List<Integer> timePeriodList = ruleDetailList.stream().distinct().map(ElectricityTypeSettingItemAddVO::getTimePeriod).collect(Collectors.toList());
|
if (timePeriodList.size() != ruleDetailList.size()) {
|
throw new RuntimeException("收费时间段不能重复!");
|
}
|
Date createTime = new Date();
|
|
ElectricityTypeSetting rules = new ElectricityTypeSetting();
|
BeanUtils.copyProperties(request, rules);
|
rules.setId(UUID.randomUUID().toString());
|
rules.setCreateTime(createTime);
|
rulesMapper.insertRules(rules);
|
|
for (ElectricityTypeSettingItemAddVO ruleDetailsAddRequest : ruleDetailList) {
|
ElectricityTypeSettingItem ruleDetails = new ElectricityTypeSettingItem();
|
ruleDetails.setRuleId(rules.getId());
|
BeanUtils.copyProperties(ruleDetailsAddRequest, ruleDetails);
|
ruleDetails.setId(UUID.randomUUID().toString());
|
ruleDetails.setCreateTime(createTime);
|
ruleDetailsMapper.insertRuleDetails(ruleDetails);
|
}
|
}
|
|
/**
|
* 删除计费策略
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void delRule(String id) {
|
ElectricityTypeSetting rules = rulesMapper.selectById(id);
|
if (ObjectUtils.isEmpty(rules)) {
|
throw new RuntimeException("计费规则不存在");
|
}
|
|
rulesMapper.deleteRulesById(id);
|
ruleDetailsMapper.deleteRulesByRuleId(id);
|
}
|
}
|
