package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.whyc.dto.AlarmDaoFactory;
|
import com.whyc.dto.BattMaintDealarm;
|
import com.whyc.dto.Response;
|
import com.whyc.dto.paramter.BattinfPar;
|
import com.whyc.dto.result.ReportBattBadDTO;
|
import com.whyc.mapper.AlarmParamMapper;
|
import com.whyc.mapper.BadbattMonMapper;
|
import com.whyc.mapper.BattInfMapper;
|
import com.whyc.pojo.AlarmParam;
|
import com.whyc.pojo.BadbattMon;
|
import com.whyc.pojo.BattMapInformation;
|
import com.whyc.pojo.UserInf;
|
import com.whyc.util.ActionUtil;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
@Service
|
public class BadBattMonService {
|
|
@Resource
|
BadbattMonMapper badbattMonMapper;
|
@Resource
|
AlarmParamMapper alarmParamMapper;
|
@Resource
|
BattInfMapper binfMapper;
|
|
public Response<List<BattMaintDealarm>> searchByInfo(int pageNum, int pageSize, BattinfPar battinfPar) {
|
//分页信息
|
PageHelper.startPage(pageNum, pageSize);
|
UserInf userInf = ActionUtil.getUser();
|
float capAlarm = 0.8f;
|
float capChange = 0.6f;
|
//1.查询劣化(告警)和损坏(更换)的阈值
|
QueryWrapper<AlarmParam> alarmWrapper = new QueryWrapper();
|
alarmWrapper.and(wrapper -> {
|
return wrapper.eq("alm_name", "Batt_Alarm_Type_CapAlarm").or().eq("alm_name", "Batt_Alarm_Type_CapChange");
|
});
|
alarmWrapper.orderByAsc("alm_id");
|
List<AlarmParam> paramList = alarmParamMapper.selectList(alarmWrapper);
|
if (paramList.size() > 0) {
|
capAlarm = paramList.get(0).getAlmLowCoe();//劣化参数0.8
|
capChange = paramList.get(1).getAlmLowCoe();//损坏参数0.6
|
}
|
battinfPar.setCapAlarm(capAlarm);
|
battinfPar.setCapChange(capChange);
|
List<ReportBattBadDTO> list = badbattMonMapper.searchByInfo(battinfPar, userInf.getUId().intValue());
|
for (ReportBattBadDTO dto : list) {
|
if (Integer.parseInt(dto.getBdmon().getNote()) == AlarmDaoFactory.Alarm_CapAlarm) {
|
dto.getBdmon().setNote("告警");
|
} else if (Integer.parseInt(dto.getBdmon().getNote()) == AlarmDaoFactory.Alarm_CapChange) {
|
dto.getBdmon().setNote("更换");
|
} else {
|
dto.getBdmon().setNote("--");
|
}
|
}
|
PageInfo<ReportBattBadDTO> pinfo = new PageInfo(list);
|
|
return new Response().set(1, pinfo, "查询成功");
|
}
|
//落后单体数量查询
|
public Response searchNums() {
|
UserInf uinf= ActionUtil.getUser();
|
int badMonNum=badbattMonMapper.searchNums(uinf.getUId().intValue());
|
return new Response().set(1, badMonNum);
|
}
|
|
public int getBadCountByStationId(String stationId) {
|
return badbattMonMapper.getBadCountByStationId(stationId);
|
}
|
|
public List<BattMapInformation> findBehind() {
|
return badbattMonMapper.findBehind();
|
}
|
|
//管理员首页:蓄电池优劣分析
|
@Transactional
|
public Response getQualityAnalysis(int userId) {
|
try {
|
//1.查询劣化(告警)和损坏(更换)的阈值
|
QueryWrapper<AlarmParam> alarmWrapper = new QueryWrapper();
|
alarmWrapper.and(wrapper -> {
|
return wrapper.eq("alm_name", "Batt_Alarm_Type_CapAlarm").or().eq("alm_name", "Batt_Alarm_Type_CapChange");
|
});
|
alarmWrapper.orderByAsc("alm_id");
|
List<AlarmParam> paramList = alarmParamMapper.selectList(alarmWrapper);
|
float capAlarm = 0f;
|
float capChange = 0f;
|
if (paramList != null && paramList.size() > 0) {
|
capAlarm = paramList.get(0).getAlmLowCoe();//劣化参数0.8
|
capChange = paramList.get(1).getAlmLowCoe();//损坏参数0.6
|
} else {
|
capAlarm = 0.8f;
|
capChange = 0.6f;
|
}
|
Map<String, Integer> map = new HashMap<>();
|
//劣化数量(包含损坏)
|
int alarmNum = badbattMonMapper.getQualityAnalysis(userId, capAlarm);
|
//损坏数量
|
int changeNum = badbattMonMapper.getQualityAnalysis(userId, capChange);
|
map.put("alarmNum", (alarmNum - changeNum));
|
map.put("changeNum", changeNum);
|
//总单体数(分类)
|
int monNum = binfMapper.getMonCount(userId);
|
map.put("monNum", monNum);
|
//蓄电池优良
|
map.put("goodSum", (monNum - alarmNum));
|
return new Response().setII(1, true, map, "蓄电池优劣分析");
|
} catch (Exception e) {
|
return new Response<>().set(1, false, "发生异常:" + e.getCause());
|
}
|
}
|
|
//管理员首页:蓄电池组优劣分析
|
@Transactional
|
public Response getGroupAnalysis(int userId) {
|
try {
|
//1.查询劣化(告警)和损坏(更换)的阈值
|
QueryWrapper<AlarmParam> alarmWrapper = new QueryWrapper();
|
alarmWrapper.and(wrapper -> {
|
return wrapper.eq("alm_name", "Batt_Alarm_Type_CapAlarm").or().eq("alm_name", "Batt_Alarm_Type_CapChange");
|
});
|
alarmWrapper.orderByAsc("alm_id");
|
List<AlarmParam> paramList = alarmParamMapper.selectList(alarmWrapper);
|
float capAlarm = 0f;
|
float capChange = 0f;
|
if (paramList != null && paramList.size() > 0) {
|
capAlarm = paramList.get(0).getAlmLowCoe();//劣化参数0.8
|
capChange = paramList.get(1).getAlmLowCoe();//损坏参数0.6
|
} else {
|
capAlarm = 0.8f;
|
capChange = 0.6f;
|
}
|
Map<String, Integer> map = new HashMap<>();
|
//站点劣化数量(包含损坏)
|
int alarmNum = badbattMonMapper.getGroupAnalysis(userId, capAlarm);
|
//站点损坏数量
|
int changeNum = badbattMonMapper.getGroupAnalysis(userId, capChange);
|
map.put("alarmNum", (alarmNum - changeNum));
|
map.put("changeNum", changeNum);
|
//总电池组数(分类)
|
int groupNum = binfMapper.geGroupCount(userId);
|
map.put("groupNum", groupNum);
|
//蓄电池优良
|
map.put("goodSum", (groupNum - alarmNum));
|
return new Response().setII(1, true, map, "蓄电池组优劣分析");
|
} catch (Exception e) {
|
return new Response<>().set(1, false, "发生异常:" + e.getCause());
|
}
|
}
|
|
//管理员首页:不同品牌同一时间品质
|
public Response getProductQuaAnalysis(int userId) {
|
Map<String, Map<String, Map<String, Integer>>> responseMap = new HashMap<>();
|
float capAlarm = 0.8f;
|
float capChange = 0.6f;
|
try {
|
//1.查询劣化(告警)和损坏(更换)的阈值
|
QueryWrapper<AlarmParam> alarmWrapper = new QueryWrapper();
|
alarmWrapper.and(wrapper -> {
|
return wrapper.eq("alm_name", "Batt_Alarm_Type_CapAlarm").or().eq("alm_name", "Batt_Alarm_Type_CapChange");
|
});
|
alarmWrapper.orderByAsc("alm_id");
|
List<AlarmParam> paramList = alarmParamMapper.selectList(alarmWrapper);
|
if (paramList.size() > 0) {
|
capAlarm = paramList.get(0).getAlmLowCoe();//劣化参数0.8
|
capChange = paramList.get(1).getAlmLowCoe();//损坏参数0.6
|
}
|
//1~7年内数据
|
for (int i = 1; i <= 8; i++) {
|
List<BadbattMon> list = new ArrayList<>();
|
String yeari = "year" + i;
|
if (i == 8) {//8的时候超过7年
|
yeari = "yearOther";
|
list = badbattMonMapper.getProductQuaAnalysis(userId, 7, capAlarm, capChange, 0);
|
} else {
|
list = badbattMonMapper.getProductQuaAnalysis(userId, i, capAlarm, capChange, 1);
|
}
|
Map<String, List<BadbattMon>> listMap = list.stream().collect(Collectors.groupingBy(BadbattMon::getBattProducer));
|
Map<String, Map<String, Integer>> producerMap = new HashMap<>();
|
for (String producer : listMap.keySet()) {
|
List<BadbattMon> badList = listMap.get(producer);
|
Map<String, List<BadbattMon>> badListMap = badList.stream().collect(Collectors.groupingBy(BadbattMon::getNote));
|
Map<String, Integer> badMap = new HashMap<>();
|
badMap.put("change", 0);
|
badMap.put("alarm", 0);
|
badMap.put("good", 0);
|
for (String note : badListMap.keySet()) {
|
badMap.put(note, badListMap.get(note).size());
|
}
|
producerMap.put(producer, badMap);
|
}
|
responseMap.put(yeari, producerMap);
|
}
|
return new Response().set(1, responseMap, "不同品牌同一时间品质和同品牌同时间品质");
|
} catch (Exception e) {
|
return new Response().set(1, responseMap, e.getCause().toString());
|
}
|
}
|
|
|
}
|
