package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.whyc.dto.Response;
|
import com.whyc.mapper.BattMapInformationMapper;
|
import com.whyc.pojo.BattMapInformation;
|
import com.whyc.pojo.BattalarmData;
|
import com.whyc.pojo.Battinf;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
|
@Service
|
public class BattMapInformationService {
|
|
@Resource
|
private BattMapInformationMapper mapper;
|
|
@Resource
|
private BadBattMonService badBattMonService;
|
@Resource
|
private BattalarmDataService battalarmDataService;
|
|
public Response add(BattMapInformation entity){
|
mapper.insert(entity);
|
return new Response().set(1,true,"添加成功");
|
}
|
|
public Response update(BattMapInformation entity){
|
mapper.updateById(entity);
|
return new Response().set(1,true,"更新成功");
|
}
|
|
|
public Response searchNotInBattMapByUid(int uId){
|
List<Battinf> list = mapper.searchNotInBattMapByUid(uId);
|
return new Response().set(1,list,"查询成功");
|
}
|
|
|
//首页上查询用户管理的已经设置过位置的机房信息
|
public Response searchUserManageStation(int uId){
|
List<BattMapInformation> list = mapper.searchInBattMapByUid(uId);
|
return new Response().set(1,list,"查询成功");
|
}
|
|
|
public Response searchAddressByStationId(String stationId){
|
QueryWrapper<BattMapInformation> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("stationId",stationId);
|
List<BattMapInformation> list = mapper.selectList(queryWrapper);
|
for (BattMapInformation battMapInformation:list) {
|
String address = battMapInformation.getAddress();
|
String[] split = address.split("-");
|
battMapInformation.setStationName1(split[0]);
|
battMapInformation.setStationName2(split[1]);
|
battMapInformation.setStationName5(split[2]);
|
}
|
return new Response().set(1,list,"查询成功");
|
}
|
|
|
public Response delete(BattMapInformation battMapInformation){
|
QueryWrapper<BattMapInformation> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq(battMapInformation.getStationName3()!=null,"stationName3",battMapInformation.getStationName3());
|
queryWrapper.eq(battMapInformation.getLongitude()!=null,"longitude",battMapInformation.getLongitude());
|
queryWrapper.eq(battMapInformation.getLatitude()!=null,"latitude",battMapInformation.getLatitude());
|
mapper.delete(queryWrapper);
|
return new Response().set(1,true,"删除成功");
|
}
|
|
|
|
public Response multiAmount(String stationId){
|
Response model = new Response();
|
String state="";
|
int numBadBatt=0;//落后总数
|
int numAlarm=0;//告警总数
|
int numPlan=0;//延迟总数
|
|
state="item-normal";
|
numBadBatt=badBattMonService.getBadCountByStationId(stationId); //落后总数
|
//numAlarm=(new Battalarm_dataDAOImpl()).serchByStationId(binformation); //告警总数
|
List<BattalarmData> alarmDataList = battalarmDataService.getCountByStationId(stationId); //告警确认和未确认总数
|
int battAlarmConfirmed = 0;
|
int battAlarmNoConfirmed = 0;
|
for (int i = 0; i < alarmDataList.size(); i++) {
|
if(alarmDataList.get(i).getAlmIsConfirmed()==0){
|
battAlarmNoConfirmed = alarmDataList.get(i).getNum().intValue();
|
}else{
|
battAlarmConfirmed = alarmDataList.get(i).getNum().intValue();
|
}
|
}
|
|
String battAlarmStr = battAlarmConfirmed+","+battAlarmNoConfirmed;
|
//todo 延迟总数
|
// numPlan=(new BattDischarge_planImpl()).serchByStationId(binformation); //延迟总数
|
// if(numBadBatt>0){
|
// state="item-behind"; //落后机房
|
// }else{
|
// if(numAlarm > 0){
|
// state="item-warn"; //告警机房
|
// }else{
|
// if(numPlan > 0){
|
// state="item-timeout"; //延迟机房
|
// }
|
// }
|
// }
|
//}
|
//model.setCode(numAlarm); //告警总数
|
model.setMsg(battAlarmStr); //告警总数
|
// model.setSum(numBadBatt); //落后总数
|
// model.setNewsum(numPlan); //延时总数
|
// model.setMsg(state); //61850状态
|
// model.setMsgN(binformation.getFBSDeviceId().toString());
|
return model;
|
|
}
|
|
|
|
|
|
|
}
|
