package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.whyc.dto.BattTestData;
|
import com.whyc.dto.Response;
|
import com.whyc.mapper.BattInfMapper;
|
import com.whyc.mapper.BattRtstateMapper;
|
import com.whyc.mapper.BattdischargePlanMapper;
|
import com.whyc.pojo.*;
|
import com.whyc.util.ActionUtil;
|
import com.whyc.util.DateUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Service
|
public class BattdischargePlanService {
|
@Resource
|
private BattdischargePlanMapper mapper;
|
|
@Resource
|
private BattInfMapper battInfMapper;
|
|
@Resource
|
private BattRtstateMapper rtstateMapper;
|
|
@Resource
|
private BatttestdataInfService testInfService;
|
|
@Autowired
|
private BattDischargePlanLogService planLogService;
|
|
//查询
|
public Response serchByCondition(BattdischargePlan battdischargePlan) {
|
PageHelper.startPage(battdischargePlan.getPage().getPageCurr(), battdischargePlan.getPage().getPageSize());
|
UserInf uinf = ActionUtil.getUser();
|
battdischargePlan.setUId(uinf.getUId().intValue());
|
List list = mapper.serchByCondition(battdischargePlan);
|
PageInfo pageInfo = new PageInfo(list);
|
return new Response().set(1, pageInfo);
|
}
|
//websocket查询，uId通过前端传递
|
public Response searchByConditionOfWebSocket(BattdischargePlan battdischargePlan){
|
PageHelper.startPage(battdischargePlan.getPage().getPageCurr(),battdischargePlan.getPage().getPageSize());
|
List list=mapper.serchByCondition(battdischargePlan);
|
PageInfo pageInfo=new PageInfo(list);
|
return new Response().set(1,pageInfo);
|
}
|
|
//删除
|
public Response delete(int num) {
|
int flag=mapper.deleteById(num);
|
return new Response().set(flag>0?1:0);
|
}
|
//创建计划-查询
|
public Response serchBattPlan(String stationName1,String stationName2,String stationName5,String stationId) {
|
UserInf uinf=ActionUtil.getUser();
|
List list=battInfMapper.serchBattPlan(stationName1,stationName2,stationName5,stationId,uinf.getUId().intValue());
|
PageInfo pageInfo=new PageInfo(list);
|
return new Response().set(1,pageInfo);
|
}
|
//创建计划-创建计划
|
public Response getBattSate(int battGroupId) {
|
BattRtstate brt=rtstateMapper.getCurrentSate(battGroupId);
|
Response response=new Response();
|
if(brt != null){
|
response.setCode(1);
|
Calendar instance = Calendar.getInstance();
|
instance.add(Calendar.MINUTE,-1);
|
Date time = instance.getTime();
|
if(time.compareTo(brt.getRecDatetime())>0){
|
response.setMsg("通讯故障");
|
}else{
|
/**
|
* 0 未知
|
* 1 浮充
|
* 2 充电
|
* 3 放电
|
* 4 均充
|
*/
|
switch (brt.getBattState()){
|
case 0 : response.setMsg("未进行充放电操作"); break;
|
case 1 : response.setMsg("浮充"); break;
|
case 2 : response.setMsg("充电"); break;
|
case 3 : response.setMsg("放电"); break;
|
case 4 : response.setMsg("均充"); break;
|
}
|
|
}
|
}else{
|
response.setMsg("无法查询到该电池当前状态");
|
}
|
return response;
|
}
|
//启用/延时/取消放电计划/修改放电参数
|
public Response updatePro(List<BattdischargePlan> list) {
|
//记录修改日志,根据note来区分是什么类型及变更原因
|
List<BattDischargePlanLog> logList = new LinkedList<>();
|
int userId = ActionUtil.getUser().getUId().intValue();
|
Date date = new Date();
|
String note = list.get(0).getNote();
|
Integer type = Integer.parseInt(note.substring(0, 1));
|
String reason = note.substring(2);
|
for (BattdischargePlan plan : list) {
|
BattDischargePlanLog log = new BattDischargePlanLog();
|
Integer id = plan.getNum();
|
log.setPlanId(id);
|
log.setType(type);
|
log.setReason(reason);
|
log.setUserId(userId);
|
log.setCreateTime(date);
|
//msg
|
String msg;
|
switch (type){
|
case 1:{msg="取消计划";}break;
|
case 2:{msg="启用计划";}break;
|
case 3:{
|
//修改放电参数,参数值:
|
StringBuilder msgBuilder = new StringBuilder();
|
BattdischargePlan planDB = getPlanByNum(id);
|
msgBuilder.append("放电参数变更:");
|
if(plan.getDischargeState()!=null &&!plan.getDischargeState().equals(planDB.getDischargeState())){
|
msgBuilder.append("放电状态值由"+planDB.getDischargeState()+"变更为"+plan.getDischargeState()+",");
|
}
|
if(plan.getPresetTime()!=null &&!plan.getPresetTime().equals(planDB.getPresetTime())){
|
msgBuilder.append("预设放电时长由"+planDB.getPresetTime()+"变更为"+plan.getPresetTime()+",");
|
}
|
if(plan.getPresetCap()!=null &&!plan.getPresetCap().equals(planDB.getPresetCap())){
|
msgBuilder.append("预设放电容量由"+planDB.getPresetCap()+"变更为"+plan.getPresetCap()+",");
|
}
|
if(plan.getPresetMonvol()!=null &&!plan.getPresetMonvol().equals(planDB.getPresetMonvol())){
|
msgBuilder.append("预设单体电压由"+planDB.getPresetMonvol()+"变更为"+plan.getPresetMonvol()+",");
|
}
|
if(plan.getPresetGroupvol()!=null &&!plan.getPresetGroupvol().equals(planDB.getPresetGroupvol())){
|
msgBuilder.append("预设组端电压由"+planDB.getPresetGroupvol()+"变更为"+plan.getPresetGroupvol()+",");
|
}
|
if(plan.getPresetCurr()!=null &&!plan.getPresetCurr().equals(planDB.getPresetCurr())){
|
msgBuilder.append("预设放电电流由"+planDB.getPresetCurr()+"变更为"+plan.getPresetCurr()+",");
|
}
|
if(plan.getPresetMon()!=null &&!plan.getPresetMon().equals(planDB.getPresetMon())){
|
msgBuilder.append("预设单体由"+planDB.getPresetMon()+"变更为"+plan.getPresetMon()+",");
|
}
|
if(plan.getDcvolhighlimit()!=null &&!plan.getDcvolhighlimit().equals(planDB.getDcvolhighlimit())){
|
msgBuilder.append("升压上限由"+planDB.getDcvolhighlimit()+"变更为"+plan.getDcvolhighlimit()+",");
|
}
|
if(plan.getChargecurrset()!=null &&!plan.getChargecurrset().equals(planDB.getChargecurrset())){
|
msgBuilder.append("充电电流由"+planDB.getChargecurrset()+"变更为"+plan.getChargecurrset()+",");
|
}
|
if(plan.getPlanCircle()!=null &&!plan.getPlanCircle().equals(planDB.getPlanCircle())){
|
msgBuilder.append("单次周期由"+planDB.getPlanCircle()+"变更为"+plan.getPlanCircle()+",");
|
}
|
if(plan.getPlanRate()!=null &&!plan.getPlanRate().equals(planDB.getPlanRate())){
|
msgBuilder.append("执行次数由"+planDB.getPlanRate()+"变更为"+plan.getPlanRate()+",");
|
}
|
msg = msgBuilder.toString();
|
}break;
|
case 4:{ //修改放电开始时间
|
BattdischargePlan planDB = getPlanByNum(id);
|
msg = "放电开始时间变更:由"+DateUtil.YYYY_MM_DD_HH_MM_SS.format(planDB.getDischargeStarttime())+"变更为"+plan.getDischargeStarttime();
|
}break;
|
default:
|
throw new IllegalStateException("Unexpected value: " + type);
|
}
|
log.setMsg(msg);
|
|
logList.add(log);
|
}
|
planLogService.addList(logList);
|
|
int flag=mapper.updatePro(list);
|
return new Response().set(flag>0?1:0);
|
}
|
|
private BattdischargePlan getPlanByNum(Integer id) {
|
return mapper.selectById(id);
|
}
|
|
//校验需要添加的计划参数 放电计划处于等待启动0，放电延时1，放电计划进行中3，充电进行中5
|
public Response judgePlan(List<BattdischargePlan> bplans) {
|
List<BattdischargePlan> list = new ArrayList();//存放满足计划设定条件的可行计划
|
if(bplans!=null&&bplans.size()>0){
|
for(int i=0;i<bplans.size();i++){
|
List flag=mapper.judgePlan(bplans.get(i));
|
if(flag!=null&&flag.size()>0){//判断通过是否数据库存在同机房放电计划，满足条件
|
if(list.size()>0){
|
int judge=judgeList(bplans.get(i), list);
|
if(judge==1){////判断通过时间相隔3天，满足条件
|
list.add(bplans.get(i));
|
}else{
|
continue;
|
}
|
}else{
|
list.add(bplans.get(i));
|
}
|
|
}
|
}
|
}
|
PageInfo pageInfo = new PageInfo(list);
|
return new Response().set(1,pageInfo);
|
}
|
//放电计划中添加计划时，有没有出现同机房存在电池组有计划
|
public int judgeList(Object obj1,Object obj2){
|
BattdischargePlan bplan=(BattdischargePlan) obj1;
|
List<BattdischargePlan> list=(List<BattdischargePlan>) obj2;
|
int flag=1;
|
if(list!=null&&list.size()>0){
|
for(int i=0;i<list.size();i++){
|
|
if(bplan.getNote().equals(list.get(i).getNote())){
|
int hours=ActionUtil.HoursBetween(bplan.getDischargeStarttime(), list.get(i).getDischargeStarttime1());
|
if(hours< BattTestData.hoursBetween){
|
flag=0;
|
break;
|
}
|
}
|
}
|
}
|
return flag;
|
}
|
|
//创建计划-创建计划
|
public Response addPro(List<BattdischargePlan> list) {
|
int flag = mapper.addPro(list);
|
return new Response().set(flag > 0 ? 1 : 0);
|
}
|
|
public List<BattMapInformation> findTimeoutStation() {
|
return mapper.findTimeoutStation();
|
}
|
|
//监控层首页:今日放电任务统计
|
public Response getPlanStaticToday(int userId) {
|
Response planRes = new Response<>();
|
try {
|
Map<String, Object> map = new HashMap<>();
|
//查询今天所有正在放电的机房总数
|
int disNumAll = testInfService.getPlanStaticToday(userId);
|
|
//Map<String, Integer> stateNumMap = new HashMap<>();
|
Map<String, Object> stateMap = new HashMap<>();
|
List<BattdischargePlan> stateList = mapper.getPlanStaticToday(userId);
|
Map<Integer, List<BattdischargePlan>> stateDisMap = stateList.stream().collect(Collectors.groupingBy(BattdischargePlan::getDischargeState));
|
/* stateNumMap.put("state0", 0);
|
stateNumMap.put("state1", 0);
|
stateNumMap.put("state3", 0);*/
|
stateMap.put("state0", new ArrayList<>());
|
stateMap.put("state1", new ArrayList<>());
|
stateMap.put("state3", new ArrayList<>());
|
for (Integer dischargeState : stateDisMap.keySet()) {
|
//stateNumMap.put("state" + String.valueOf(dischargeState), stateDisMap.get(dischargeState).size());
|
stateMap.put("state" + String.valueOf(dischargeState), stateDisMap.get(dischargeState));
|
}
|
/* Map<String, Integer> nodeNumMap = new HashMap<>();
|
nodeNumMap.put("node0", 0);
|
nodeNumMap.put("node1", 0);*/
|
Map<String, Object> nodeMap = new HashMap<>();
|
nodeMap.put("node0", new ArrayList<>());
|
nodeMap.put("node1", new ArrayList<>());
|
Map<Integer, List<BattdischargePlan>> nodeDisMap = stateList.stream().collect(Collectors.groupingBy(BattdischargePlan::getNodeStation));
|
for (Integer node : nodeDisMap.keySet()) {
|
//nodeNumMap.put("node" + String.valueOf(node), nodeDisMap.get(node).size());
|
nodeMap.put("node" + String.valueOf(node), nodeDisMap.get(node));
|
}
|
//stateNumMap.put("sumNum", stateList.size());
|
//map.put("stateNumMap", stateNumMap);
|
map.put("stateMap", stateMap);
|
// map.put("nodeNumMap", nodeNumMap);
|
map.put("nodeMap", nodeMap);
|
map.put("disNumAll", disNumAll);
|
map.put("nowTime", ActionUtil.sdf.format(new Date()));
|
planRes.setII(1, stateList.size() > 0, map, "今日放电任务统计");
|
} catch (Exception e) {
|
planRes.set(1, false, "出现异常" + e.getMessage());
|
}
|
return planRes;
|
}
|
|
/**
|
* 审核通过,将临时表的放电计划转移到正式表
|
* @param tempList
|
*/
|
public void insertConfirmDischargePlan(List<BattDischargePlanTemp> tempList) {
|
List<BattdischargePlan> planList = new LinkedList<>();
|
Date date = new Date();
|
for (BattDischargePlanTemp temp : tempList) {
|
//计算预计停止放电时间
|
Date dischargeStartTime = temp.getDischargeStartTime();
|
Calendar stopTime = Calendar.getInstance();
|
stopTime.setTime(dischargeStartTime);
|
stopTime.add(Calendar.MINUTE,600);
|
Date dischargeStopTime = stopTime.getTime();
|
|
BattdischargePlan plan = new BattdischargePlan();
|
plan.setBattgroupid(temp.getBattGroupId());
|
plan.setDischargeStarttime(dischargeStartTime);
|
plan.setDischargeStoptime(dischargeStopTime);
|
plan.setDischargeState(0);
|
plan.setDischargeCleartype(1);
|
plan.setBattIndexInFbs(0);
|
plan.setPresetTime(600);
|
plan.setPresetCap(temp.getMonCapStd()*temp.getCapPercent());
|
plan.setPresetMonvol(temp.getMonVolStd()*0.9f);
|
plan.setPresetGroupvol(43f);
|
plan.setPresetMon(1);
|
plan.setPresetCurr(temp.getMonCapStd()/10);
|
plan.setDcvolhighlimit(56.4f);
|
plan.setChargecurrset(20f);
|
plan.setPlanCircle(30);
|
plan.setPlanRate(1);
|
plan.setAlreadyCount(0);
|
plan.setDischargeReason("");
|
plan.setNote("");
|
plan.setNodeStation(temp.getNodeStation());
|
plan.setBaojiGroupId(temp.getGroupId().intValue());
|
plan.setCreateTime(date);
|
|
planList.add(plan);
|
}
|
mapper.insertBatchSomeColumn(planList);
|
}
|
|
public Response getReplaceBattGroupList(int num) {
|
QueryWrapper<BattdischargePlan> query = Wrappers.query();
|
query.eq("discharge_state",0);
|
List<BattdischargePlan> tempList = mapper.selectList(query);
|
List<BattdischargePlan> recommendList = new LinkedList<>();
|
List<BattdischargePlan> list = new LinkedList<>();
|
BattdischargePlan currentTemp = null;
|
for (BattdischargePlan temp : tempList) {
|
if(temp.getNum()==num){
|
currentTemp = temp;
|
break;
|
}
|
}
|
//同类型替换,并且不能是同一天的
|
for (BattdischargePlan temp : tempList) {
|
assert currentTemp != null;
|
if(temp.getNum()!=num &&temp.getDischargeStarttime().compareTo(currentTemp.getDischargeStarttime())!=0 && temp.getNodeStation()==(currentTemp.getNodeStation())){
|
if(temp.getBaojiGroupId().equals(currentTemp.getBaojiGroupId())){ //同班组,推荐
|
recommendList.add(temp);
|
}else{
|
list.add(temp);
|
}
|
}
|
}
|
return new Response().setII(1,recommendList,list,null);
|
}
|
|
public Response getDisabledDischargeTime(int num) {
|
QueryWrapper<BattdischargePlan> query = Wrappers.query();
|
query.eq("discharge_state",0);
|
List<BattdischargePlan> tempList = mapper.selectList(query);
|
BattdischargePlan currentTemp = null;
|
for (BattdischargePlan temp : tempList) {
|
if(temp.getNum()==num){
|
currentTemp = temp;
|
break;
|
}
|
}
|
//不可用的时间,三种方式,层层筛选:1.当前电池组时间 2.其他 满足每天3个站点的时间 3.如果当前为节点站,再其他,存在节点站的时间
|
List<Date> disabledDischargeTimeList = new LinkedList<>();
|
Date dischargeStartTime = currentTemp.getDischargeStarttime();
|
disabledDischargeTimeList.add(dischargeStartTime);
|
Integer nodeStation = currentTemp.getNodeStation();
|
Map<Date, List<BattdischargePlan>> dischargeMap = tempList.stream().collect(Collectors.groupingBy(BattdischargePlan::getDischargeStarttime));
|
Set<Date> dates = dischargeMap.keySet();
|
for (Date date : dates) {
|
if(dischargeStartTime.compareTo(date)==0){
|
continue;
|
}
|
List<BattdischargePlan> dailyTempList = dischargeMap.get(date);
|
if (dailyTempList.size()==3){
|
disabledDischargeTimeList.add(date);
|
}else{ //当天不足3个站点
|
if(nodeStation == 1){ //如果需要插入的站点是节点站,当天存在节点站,也不可用
|
for (BattdischargePlan temp : dailyTempList) {
|
if(temp.getNodeStation()==1){
|
disabledDischargeTimeList.add(date);
|
break;
|
}
|
}
|
}
|
}
|
}
|
disabledDischargeTimeList = disabledDischargeTimeList.stream().sorted().collect(Collectors.toList());
|
return new Response().set(1,disabledDischargeTimeList);
|
}
|
|
public Response exchangeDischargeTime(int numOriginal, int numReplaced) {
|
BattdischargePlan original = mapper.selectById(numOriginal);
|
BattdischargePlan replaced = mapper.selectById(numReplaced);
|
|
UpdateWrapper<BattdischargePlan> update = Wrappers.update();
|
update.set("discharge_starttime",replaced.getDischargeStarttime()).eq("num",numOriginal);
|
mapper.update(null,update);
|
|
UpdateWrapper<BattdischargePlan> update2 = Wrappers.update();
|
update2.set("discharge_starttime",original.getDischargeStarttime()).eq("num",numReplaced);
|
mapper.update(null,update2);
|
return new Response().setII(1,"放电时间互换");
|
}
|
|
public Response getDischargePlanFinishTime() {
|
List<BattdischargePlan> baojiGroupPlanFinishTimeList = new LinkedList<>();
|
List<BattdischargePlan> planList = mapper.getListWithBaojiGroupName();
|
Map<Integer, List<BattdischargePlan>> baojiGroupPlanMap = planList.stream().collect(Collectors.groupingBy(BattdischargePlan::getBaojiGroupId));
|
Set<Integer> baojiGroupSet = baojiGroupPlanMap.keySet();
|
for (Integer baojiGroupId : baojiGroupSet) {
|
List<BattdischargePlan> planListByBaojiGroupId = baojiGroupPlanMap.get(baojiGroupId);
|
baojiGroupPlanFinishTimeList.add(planListByBaojiGroupId.get(planListByBaojiGroupId.size()-1));
|
}
|
return new Response().set(1,baojiGroupPlanFinishTimeList);
|
|
}
|
|
public Response getMyPlanCount(int userId) {
|
Map<String,Integer> map = new HashMap<>();
|
int year = Calendar.getInstance().get(Calendar.YEAR);
|
List<BattdischargePlan> planList = mapper.getPlanCount(userId, year);
|
//总数,已完成数量
|
int total = planList.size();
|
int finishNum = planList.stream().filter(plan -> plan.getDischargeState() == 2).collect(Collectors.toList()).size();
|
map.put("total", total);
|
map.put("finishNum", finishNum);
|
return new Response().set(1, map);
|
}
|
|
public Map<String, Map<String, Integer>> getPlanCount(int userId) {
|
//int userId = ActionUtil.getUser().getUId().intValue();
|
Map<String, Map<String, Integer>> resMap = new HashMap<>();
|
Map<String, Integer> map = new HashMap<>();
|
int year = Calendar.getInstance().get(Calendar.YEAR);
|
List<BattdischargePlan> planList = mapper.getPlanCount(userId, year);
|
//班组,总数,已完成数量
|
Map<String, List<BattdischargePlan>> groupNameListMap = planList.stream().collect(Collectors.groupingBy(BattdischargePlan::getBaojiGroupName));
|
Set<String> groupNameSet = groupNameListMap.keySet();
|
for (String groupName : groupNameSet) {
|
List<BattdischargePlan> plans = groupNameListMap.get(groupName);
|
int total = plans.size();
|
int finishNum = plans.stream().filter(plan -> plan.getDischargeState() == 2).collect(Collectors.toList()).size();
|
map.put("total", total);
|
map.put("finishNum", finishNum);
|
|
resMap.put(groupName, map);
|
}
|
return resMap;
|
|
}
|
|
public Response getPlanCountWithTotal(int userId) {
|
Map<String, Integer> resMap = new HashMap<>();
|
resMap.put("放电任务总数", 0);
|
int total = 0;
|
Map<String, Map<String, Integer>> planCount = getPlanCount(userId);
|
Set<String> groupNameSet = planCount.keySet();
|
for (String groupName : groupNameSet) {
|
//resMap.put(groupName,planCount.get(groupName).get("finishNum"));
|
total = total + planCount.get(groupName).get("total");
|
}
|
resMap.put("放电任务总数", total);
|
return new Response().setII(1, resMap, planCount, null);
|
|
}
|
}
|
