package com.zhitan.peakvalley.service.impl;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.zhitan.common.utils.DateUtils;
|
import com.zhitan.common.utils.StringUtils;
|
import com.zhitan.common.utils.time.Time24HourUtil;
|
import com.zhitan.peakvalley.domain.ElectricityPrice;
|
import com.zhitan.peakvalley.mapper.ElectricityPriceMapper;
|
import com.zhitan.peakvalley.service.IElectricityPriceService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.Collection;
|
import java.util.HashMap;
|
import java.util.List;
|
|
/**
|
* 【尖峰平谷电价明细】Service业务层处理
|
*
|
* @author ZhiTan
|
* @date 2024-10-10
|
*/
|
@Service
|
public class ElectricityPriceServiceImpl extends ServiceImpl<ElectricityPriceMapper, ElectricityPrice> implements IElectricityPriceService {
|
@Autowired
|
private ElectricityPriceMapper electricityPriceMapper;
|
|
/**
|
* 查询【尖峰平谷电价明细】
|
*
|
* @param id 【尖峰平谷电价明细】主键
|
* @return 【尖峰平谷电价明细】
|
*/
|
@Override
|
public ElectricityPrice selectElectricityPriceById(String id) {
|
return electricityPriceMapper.selectElectricityPriceById(id);
|
}
|
|
/**
|
* 查询【尖峰平谷电价明细】列表
|
*
|
* @param electricityPrice 【尖峰平谷电价明细】
|
* @return 【尖峰平谷电价明细】
|
*/
|
@Override
|
public List<ElectricityPrice> selectElectricityPriceList(ElectricityPrice electricityPrice) {
|
if(StringUtils.isEmpty(electricityPrice.getParentId())){
|
throw new RuntimeException("父级id不能为空");
|
}
|
return electricityPriceMapper.selectElectricityPriceList(electricityPrice);
|
}
|
|
/**
|
* 新增【尖峰平谷电价明细】
|
*
|
* @param electricityPrice 【尖峰平谷电价明细】
|
* @return 结果
|
*/
|
@Override
|
public int insertElectricityPrice(ElectricityPrice electricityPrice) {
|
electricityPrice.setCreateTime(DateUtils.getNowDate());
|
return electricityPriceMapper.insertElectricityPrice(electricityPrice);
|
}
|
|
/**
|
* 修改【尖峰平谷电价明细】
|
*
|
* @param electricityPrice 【尖峰平谷电价明细】
|
* @return 结果
|
*/
|
@Override
|
public int updateElectricityPrice(ElectricityPrice electricityPrice) {
|
electricityPrice.setUpdateTime(DateUtils.getNowDate());
|
return electricityPriceMapper.updateElectricityPrice(electricityPrice);
|
}
|
|
/**
|
* 批量删除【尖峰平谷电价明细】
|
*
|
* @param ids 需要删除的【尖峰平谷电价明细】主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteElectricityPriceByIds(String[] ids) {
|
return electricityPriceMapper.deleteElectricityPriceByIds(ids);
|
}
|
|
/**
|
* 删除【尖峰平谷电价明细】信息
|
*
|
* @param id 【尖峰平谷电价明细】主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteElectricityPriceById(String id) {
|
return electricityPriceMapper.deleteElectricityPriceById(id);
|
}
|
|
@Override
|
public void saveList(List<ElectricityPrice> electricityPriceList) {
|
if(CollectionUtil.isEmpty(electricityPriceList)){
|
throw new RuntimeException("价格明细不能为空！");
|
}
|
|
//校验时间是否重叠
|
boolean isOverlap = checkIntersection(electricityPriceList);
|
if(isOverlap){
|
throw new RuntimeException("时间段存在重叠，请检查！");
|
}
|
|
HashMap<String,String> collect = new HashMap<>();
|
electricityPriceList.forEach(electricityPrice -> {
|
collect.put(DateUtils.getHhMmSs(electricityPrice.getStartTime()) + "-" + DateUtils.getHhMmSs(electricityPrice.getStopTime()),electricityPrice.getType());
|
});
|
boolean is24Hour = Time24HourUtil.checkTimeSpan(collect);
|
if(!is24Hour){
|
throw new RuntimeException("时间没有覆盖24小时");
|
}
|
|
String parentId = electricityPriceList.get(0).getParentId();
|
LambdaQueryWrapper<ElectricityPrice> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(ElectricityPrice::getParentId,parentId);
|
if(electricityPriceMapper.selectCount(queryWrapper)>0) {
|
electricityPriceMapper.delete(queryWrapper);
|
}
|
Collection<ElectricityPrice> collection = new ArrayList<>(electricityPriceList);
|
saveBatch(collection);
|
}
|
|
public static boolean checkIntersection(List<ElectricityPrice> dtoList) {
|
int length = dtoList.size();
|
for (int i = 0; i < length; i++) {
|
long startTimeI = dtoList.get(i).getStartTime().getTime();
|
long endTimeI = dtoList.get(i).getStopTime().getTime();
|
|
for (int j = i + 1; j < length; j++) {
|
long startTimeJ = dtoList.get(j).getStartTime().getTime();
|
long endTimeJ = dtoList.get(j).getStopTime().getTime();
|
|
if (startTimeI < endTimeJ && startTimeJ < endTimeI) {
|
return true; // 存在相交，返回true
|
}
|
}
|
}
|
return false; // 不存在相交，返回false
|
}
|
}
|
