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.BattMapInformation;
|
import com.whyc.pojo.Battinf;
|
import com.whyc.pojo.UserInf;
|
import com.whyc.util.ActionUtil;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
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();
|
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();
|
}
|
|
//管理员首页:蓄电池优劣分析
|
public Response getQualityAnalysis(int userId) {
|
//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 = paramList.get(0).getAlmLowCoe();//劣化参数0.8
|
float capChange = paramList.get(1).getAlmLowCoe();//损坏参数0.6
|
Map<String, Integer> map = new HashMap<>();
|
//劣化数量(包含损坏)
|
int alarmNum = badbattMonMapper.getProductQuaAnalysis(userId, capAlarm);
|
//损坏数量
|
int changeNum = badbattMonMapper.getProductQuaAnalysis(userId, capChange);
|
map.put("alarmNum", (alarmNum - changeNum));
|
map.put("changeNum", changeNum);
|
//总单体数(分类)
|
List<Battinf> battinfList = binfMapper.getBattGroupList(userId);
|
Map<Float, List<Battinf>> battMonVolStdMap = battinfList.stream().collect(Collectors.groupingBy(Battinf::getMonVolStd));
|
int sunNum = 0;
|
for (Float monVolStd : battMonVolStdMap.keySet()) {
|
sunNum += battMonVolStdMap.get(monVolStd).size();
|
}
|
map.put("sunNum", sunNum);
|
//蓄电池优良
|
map.put("goodSum", (sunNum - alarmNum));
|
return new Response().set(1);
|
}
|
|
//管理员首页:不同品牌同一时间品质
|
public Response getProductQuaAnalysis(int userId) {
|
|
return new Response().set(1);
|
}
|
|
|
}
|
