|
|
package com.huatek.busi.service.impl.arrester;
|
|
|
|
|
|
import java.time.LocalDate;
|
|
|
import java.time.LocalDateTime;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.Arrays;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
import org.springframework.util.CollectionUtils;
|
|
|
|
|
|
import com.alibaba.dubbo.config.annotation.Reference;
|
|
|
import com.alibaba.dubbo.config.annotation.Service;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.github.pagehelper.Page;
|
|
|
import com.github.pagehelper.PageHelper;
|
|
|
import com.google.common.collect.Maps;
|
|
|
import com.huatek.busi.common.BusiConstant.EqType;
|
|
|
import com.huatek.busi.common.BusiConstant.GzType;
|
|
|
import com.huatek.busi.common.SiteConstants.ArresterTreeEnum;
|
|
|
import com.huatek.busi.common.SiteConstants.ExternalTypeEnum;
|
|
|
import com.huatek.busi.common.SiteConstants.SiteTreeEnum;
|
|
|
import com.huatek.busi.common.util.DecimalUtil;
|
|
|
import com.huatek.busi.common.util.FieldUtil;
|
|
|
import com.huatek.busi.common.util.TimeUtil;
|
|
|
import com.huatek.busi.common.util.Tools;
|
|
|
import com.huatek.busi.dto.EquipmentInfoDto;
|
|
|
import com.huatek.busi.dto.LightningrodImStatisticsDto;
|
|
|
import com.huatek.busi.dto.curve.BaseCurveQueryDto;
|
|
|
import com.huatek.busi.dto.curve.PointItemDto;
|
|
|
import com.huatek.busi.entity.ArresterInsulationMonitorThreshold;
|
|
|
import com.huatek.busi.entity.BusiEqmWarning;
|
|
|
import com.huatek.busi.entity.BusiOnlineMonitorData;
|
|
|
import com.huatek.busi.entity.BusiSiteTree;
|
|
|
import com.huatek.busi.entity.LightningrodIm;
|
|
|
import com.huatek.busi.entity.RptAretMonitor;
|
|
|
import com.huatek.busi.mapper.LightningrodImMapper;
|
|
|
import com.huatek.busi.mapper.RptAretMonitorMapper;
|
|
|
import com.huatek.busi.service.BusiSiteTreeService;
|
|
|
import com.huatek.busi.service.IecBydworkParamService;
|
|
|
import com.huatek.busi.service.arrester.LightningrodImService;
|
|
|
import com.huatek.busi.service.arrester.RptAretMonitorService;
|
|
|
import com.huatek.busi.service.impl.cac.AbstractCacEtlService;
|
|
|
import com.huatek.busi.service.threshold.ArresterInsulationMonitorThresholdService;
|
|
|
import com.huatek.busi.vo.LightningrodImStatisticsVo;
|
|
|
import com.huatek.busi.vo.LightningrodImVo;
|
|
|
import com.huatek.busi.vo.curve.PointItemVo;
|
|
|
import com.huatek.busi.vo.monitor.BusiOnlineMonitorDataVo;
|
|
|
import com.huatek.busi.vo.stability.LightningrodImStabilityVo;
|
|
|
import com.huatek.busi.vo.warning.BusiArresterItemVo;
|
|
|
import com.huatek.busi.vo.warning.BusiArresterItemVo.BusiArresterItemVoBuilder;
|
|
|
import com.huatek.busi.vo.warning.BusiArresterVo;
|
|
|
import com.huatek.busi.vo.warning.BusiGisSf6Vo;
|
|
|
import com.huatek.torch.frame.tools.ConstantUtil;
|
|
|
import com.huatek.torch.frame.tools.ResultUtil;
|
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
|
/**
|
|
|
* 金属氧化物避雷器——绝缘监测：023001 ServiceImpl
|
|
|
*
|
|
|
* @author anker_cheng
|
|
|
* @date Jun 26, 2019 1:11:48 PM
|
|
|
*/
|
|
|
@Slf4j
|
|
|
@Component
|
|
|
@Service(interfaceClass = LightningrodImService.class)
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public class LightningrodImServiceImpl extends AbstractCacEtlService<LightningrodIm> implements LightningrodImService {
|
|
|
|
|
|
@Autowired
|
|
|
private LightningrodImMapper lightningrodImMapper;
|
|
|
@Autowired
|
|
|
private RptAretMonitorMapper rptAretMonitorMapper;
|
|
|
|
|
|
@Reference(check = false)
|
|
|
private RptAretMonitorService rptAretMonitorService;
|
|
|
@Reference(check = false)
|
|
|
private IecBydworkParamService iecBydworkParamService;
|
|
|
|
|
|
@Reference(check = false)
|
|
|
private BusiSiteTreeService busiSiteTreeService;
|
|
|
|
|
|
@Reference(check = false)
|
|
|
private ArresterInsulationMonitorThresholdService arresterInsulationMonitorThresholdService;
|
|
|
|
|
|
@Override
|
|
|
public void saveHistoryData(LightningrodIm cacEntity, EquipmentInfoDto equipmentInfo) {
|
|
|
// 设备状态
|
|
|
String state = iecBydworkParamService.getIecType(cacEntity.getMainTreeId(), cacEntity.getTimeStamp());
|
|
|
if (StringUtils.isEmpty(state)) {
|
|
|
log.info("无法获取设备状态");
|
|
|
}
|
|
|
cacEntity.setRunState(state);
|
|
|
//设置rowkey，导入hbase使用
|
|
|
cacEntity.setHbaseRowkey(Tools.strReverse(TimeUtil.getTimeStr(cacEntity.getTimeStamp())) + "_"
|
|
|
+ cacEntity.getSensorId() + "_" + TimeUtil.getTimeStr(cacEntity.getTimeStamp()) + "_"
|
|
|
+ cacEntity.getCacMonitorTypeCode() + "_" + cacEntity.getMainTreeId());
|
|
|
|
|
|
super.saveHistoryData(cacEntity, equipmentInfo);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public void saveBusiWarning(LightningrodIm cacEntity, String cacMonitorTypeCode, String sensorId,
|
|
|
EquipmentInfoDto equipmentInfo) {
|
|
|
// 阈值
|
|
|
ArresterInsulationMonitorThreshold arresterThreshold =
|
|
|
arresterInsulationMonitorThresholdService.getArresterInsulationMonitorThreshold(cacEntity.getMainTreeId(),
|
|
|
cacEntity.getRunState(), cacEntity.getSensorId());
|
|
|
if (arresterThreshold == null) {
|
|
|
log.warn("ArresterInsulationMonitorThreshold not exists! mainTreeId: {}, runState: {}, sensorCode: {}",
|
|
|
cacEntity.getMainTreeId(), cacEntity.getRunState(), cacEntity.getSensorId());
|
|
|
return;
|
|
|
}
|
|
|
final StringBuilder warningMsg = new StringBuilder();
|
|
|
|
|
|
// 全电流、阻性电流的预警值、阈值
|
|
|
String fullCurrentWarning = getWarningVal(arresterThreshold, cacEntity.getPhase(), "FullCurrent");
|
|
|
String fullCurrentThreshold = getThresholdVal(arresterThreshold, cacEntity.getPhase(), "FullCurrent");
|
|
|
String resistiveCurrentWarning = getWarningVal(arresterThreshold, cacEntity.getPhase(), "ResistiveCurrent");
|
|
|
String resistiveCurrentThreshold = getThresholdVal(arresterThreshold, cacEntity.getPhase(), "ResistiveCurrent");
|
|
|
|
|
|
Map<String, Object> stabilityMap= busiStabilityService.getStabilityBySensorCodeAndStatus(sensorId, cacEntity.getRunState());
|
|
|
|
|
|
// 全电流
|
|
|
BusiArresterItemVoBuilder builder1 = BusiArresterItemVo.builder().phase(cacEntity.getPhase()).name("全电流（mA）")
|
|
|
.collectValue(cacEntity.getTotalCurrent()).thresholdValue(fullCurrentThreshold)
|
|
|
.equipmentStatus(cacEntity.getRunState()).warningValue(fullCurrentWarning);
|
|
|
//数据稳定性
|
|
|
builder1.stabilityIndex(getString(stabilityMap, "totalCurrent", "--"));
|
|
|
// if (gt(cacEntity.getTotalCurrent(), arresterThreshold.getAFullCurrentThreshold(),arresterThreshold.getAFullCurrentWarning())) {
|
|
|
// append(warningMsg, format("{}全电流超标为：{}", cacEntity.getPhase(), cacEntity.getTotalCurrent()));
|
|
|
// builder1.alarmValue(cacEntity.getTotalCurrent());
|
|
|
// }
|
|
|
|
|
|
String fFullCurrent = gt(cacEntity.getTotalCurrent(), arresterThreshold.getAFullCurrentThreshold(),arresterThreshold.getAFullCurrentWarning());
|
|
|
if("1".equals(fFullCurrent))
|
|
|
{
|
|
|
append(warningMsg, format("{}全电流超标为：{}", cacEntity.getPhase(), cacEntity.getTotalCurrent()));
|
|
|
builder1.alarmValue(cacEntity.getTotalCurrent());
|
|
|
// 保存告警
|
|
|
BusiEqmWarning busiEqmWarning = newEw(EqType.EQ_TYPE3, GzType.GZ_TYPE6, warningMsg.toString(), cacMonitorTypeCode,"1");
|
|
|
busiEqmWarning.setWarningTime(cacEntity.getTimeStamp());
|
|
|
busiEqmWarning.setRunState(cacEntity.getRunState());
|
|
|
busiEqmWarning.setWarningFlag("1");
|
|
|
busiEqmWarning = this.buildWarning(busiEqmWarning, equipmentInfo);
|
|
|
// 保存告警详情
|
|
|
BusiArresterVo busiArresterVo = new BusiArresterVo();
|
|
|
busiArresterVo.setEquipmentName(equipmentInfo.getSubEquipmentName());
|
|
|
busiArresterVo.setList(Arrays.asList(builder1.build()));
|
|
|
busiArresterVo.setCollectDate(cacEntity.getTimeStamp());
|
|
|
this.buildWarningInfo(busiEqmWarning, JSON.toJSONString(busiArresterVo));
|
|
|
}else if("2".equals(fFullCurrent)) //预警
|
|
|
{
|
|
|
append(warningMsg, format("{}全电流超标为：{}", cacEntity.getPhase(), cacEntity.getTotalCurrent()));
|
|
|
builder1.alarmValue(cacEntity.getTotalCurrent());
|
|
|
// 保存告警
|
|
|
BusiEqmWarning busiEqmWarning = newEw(EqType.EQ_TYPE3, GzType.GZ_TYPE6, warningMsg.toString(), cacMonitorTypeCode,"2");
|
|
|
busiEqmWarning.setWarningTime(cacEntity.getTimeStamp());
|
|
|
busiEqmWarning.setRunState(cacEntity.getRunState());
|
|
|
busiEqmWarning.setWarningFlag("2");
|
|
|
busiEqmWarning = this.buildWarning(busiEqmWarning, equipmentInfo);
|
|
|
// 保存告警详情
|
|
|
BusiArresterVo busiArresterVo = new BusiArresterVo();
|
|
|
busiArresterVo.setEquipmentName(equipmentInfo.getSubEquipmentName());
|
|
|
busiArresterVo.setList(Arrays.asList(builder1.build()));
|
|
|
busiArresterVo.setCollectDate(cacEntity.getTimeStamp());
|
|
|
this.buildWarningInfo(busiEqmWarning, JSON.toJSONString(busiArresterVo));
|
|
|
}
|
|
|
|
|
|
|
|
|
// 阻性电流
|
|
|
BusiArresterItemVoBuilder builder2 = BusiArresterItemVo.builder().phase(cacEntity.getPhase()).name("阻性电流（mA）")
|
|
|
.collectValue(cacEntity.getResistiveCurrent()).thresholdValue(resistiveCurrentThreshold)
|
|
|
.equipmentStatus(cacEntity.getRunState()).warningValue(resistiveCurrentWarning);
|
|
|
//数据稳定性
|
|
|
builder2.stabilityIndex(getString(stabilityMap, "resistiveCurrent", "--"));
|
|
|
// if (gt(cacEntity.getResistiveCurrent(), arresterThreshold.getAResistiveCurrentThreshold(),arresterThreshold.getAResistiveCurrentWarning())) {
|
|
|
// append(warningMsg, format("{}阻性电流超标为：{}", cacEntity.getPhase(), cacEntity.getResistiveCurrent()));
|
|
|
// builder2.alarmValue(cacEntity.getResistiveCurrent());
|
|
|
// }
|
|
|
|
|
|
String aResistiveCurrent = gt(cacEntity.getResistiveCurrent(), arresterThreshold.getAResistiveCurrentThreshold(),arresterThreshold.getAResistiveCurrentWarning());
|
|
|
|
|
|
if("1".equals(aResistiveCurrent))
|
|
|
{
|
|
|
append(warningMsg, format("{}阻性电流超标为：{}", cacEntity.getPhase(), cacEntity.getResistiveCurrent()));
|
|
|
builder2.alarmValue(cacEntity.getResistiveCurrent());
|
|
|
|
|
|
// 保存告警
|
|
|
BusiEqmWarning busiEqmWarning = newEw(EqType.EQ_TYPE3, GzType.GZ_TYPE6, warningMsg.toString(), cacMonitorTypeCode,"1");
|
|
|
busiEqmWarning.setWarningTime(cacEntity.getTimeStamp());
|
|
|
busiEqmWarning.setRunState(cacEntity.getRunState());
|
|
|
busiEqmWarning.setWarningFlag("1");
|
|
|
busiEqmWarning = this.buildWarning(busiEqmWarning, equipmentInfo);
|
|
|
// 保存告警详情
|
|
|
BusiArresterVo busiArresterVo = new BusiArresterVo();
|
|
|
busiArresterVo.setEquipmentName(equipmentInfo.getSubEquipmentName());
|
|
|
busiArresterVo.setList(Arrays.asList(builder2.build()));
|
|
|
busiArresterVo.setCollectDate(cacEntity.getTimeStamp());
|
|
|
this.buildWarningInfo(busiEqmWarning, JSON.toJSONString(busiArresterVo));
|
|
|
|
|
|
}else if("2".equals(aResistiveCurrent)) //预警
|
|
|
{
|
|
|
append(warningMsg, format("{}阻性电流超标为：{}", cacEntity.getPhase(), cacEntity.getResistiveCurrent()));
|
|
|
builder2.alarmValue(cacEntity.getResistiveCurrent());
|
|
|
|
|
|
// 保存告警
|
|
|
BusiEqmWarning busiEqmWarning = newEw(EqType.EQ_TYPE3, GzType.GZ_TYPE6, warningMsg.toString(), cacMonitorTypeCode,"2");
|
|
|
busiEqmWarning.setWarningTime(cacEntity.getTimeStamp());
|
|
|
busiEqmWarning.setRunState(cacEntity.getRunState());
|
|
|
busiEqmWarning.setWarningFlag("2");
|
|
|
busiEqmWarning = this.buildWarning(busiEqmWarning, equipmentInfo);
|
|
|
// 保存告警详情
|
|
|
BusiArresterVo busiArresterVo = new BusiArresterVo();
|
|
|
busiArresterVo.setEquipmentName(equipmentInfo.getSubEquipmentName());
|
|
|
busiArresterVo.setList(Arrays.asList(builder2.build()));
|
|
|
busiArresterVo.setCollectDate(cacEntity.getTimeStamp());
|
|
|
this.buildWarningInfo(busiEqmWarning, JSON.toJSONString(busiArresterVo));
|
|
|
}
|
|
|
// 累计落雷次数
|
|
|
RptAretMonitor rptAretMonitor = rptAretMonitorMapper.getRptAretMonitor(cacEntity.getSubTreeId());
|
|
|
if (rptAretMonitor != null) {
|
|
|
int totalActionCount = DecimalUtil.getVal(rptAretMonitor.getArresterCount())
|
|
|
.add(DecimalUtil.getVal(cacEntity.getActionCount())).intValue();
|
|
|
builder1.totalActionCount(String.valueOf(totalActionCount));
|
|
|
builder2.totalActionCount(String.valueOf(totalActionCount));
|
|
|
} else {
|
|
|
builder1.totalActionCount("-");
|
|
|
builder2.totalActionCount("-");
|
|
|
}
|
|
|
|
|
|
if (warningMsg.length() == 0) {
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public void updateCurrentData(LightningrodIm cacEntity) {
|
|
|
rptAretMonitorService.saveRptAretMonitor(cacEntity);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 返回 aVal.compareTo(bVal)>0的结果，判断aVal是否大于bVal
|
|
|
*
|
|
|
* @param aVal 报文数据
|
|
|
* @param bVal 阈值
|
|
|
* @param cVal 预警值
|
|
|
* @return 0,正常；1预警；2告警
|
|
|
*/
|
|
|
private static String gt(String aVal, String bVal,String cVal) {
|
|
|
//return DecimalUtil.getVal(aVal).compareTo(DecimalUtil.getVal(bVal)) > 0;
|
|
|
String flag = "0";
|
|
|
|
|
|
if (StringUtils.isEmpty(bVal)) {
|
|
|
return "0";
|
|
|
}
|
|
|
//预警
|
|
|
if( DecimalUtil.getVal(aVal).compareTo(DecimalUtil.getVal(bVal)) > 0)
|
|
|
{
|
|
|
if( DecimalUtil.getVal(aVal).compareTo(DecimalUtil.getVal(cVal)) < 0)
|
|
|
{
|
|
|
flag = "2";
|
|
|
}
|
|
|
}
|
|
|
//告警
|
|
|
if(DecimalUtil.getVal(aVal).compareTo(DecimalUtil.getVal(cVal)) > 0)
|
|
|
{
|
|
|
flag = "1";
|
|
|
}
|
|
|
return flag;
|
|
|
}
|
|
|
|
|
|
private String getWarningVal(ArresterInsulationMonitorThreshold threshold, String phase, String name) {
|
|
|
return (String)FieldUtil.getFieldValue(threshold, phase(phase) + name + "Warning");
|
|
|
}
|
|
|
|
|
|
private String getThresholdVal(ArresterInsulationMonitorThreshold threshold, String phase, String name) {
|
|
|
return (String)FieldUtil.getFieldValue(threshold, phase(phase) + name + "Threshold");
|
|
|
}
|
|
|
|
|
|
private static String phase(String phase) {
|
|
|
if (phase == null) {
|
|
|
return "";
|
|
|
}
|
|
|
return phase.replace("相", "").toLowerCase();
|
|
|
}
|
|
|
/**
|
|
|
* 数据输入-绝缘监测原始数据查询
|
|
|
*/
|
|
|
@Override
|
|
|
public Map<String, Object> findCACPageData(Map<String, Object> params) {
|
|
|
if (params.get("page") != null && params.get("limit") != null) {
|
|
|
PageHelper.startPage(page(params), limit(params));
|
|
|
}
|
|
|
Page<Map<String, Object>> page = lightningrodImMapper.findCACPageData(params);
|
|
|
return ResultUtil.put(ConstantUtil.REQUEST_SUCCESS, page.getTotal(), "", page.getResult());
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public Map<String, Object> exportCacMonitorData(Map<String, Object> mapParams) {
|
|
|
Map<String, Object> returnMap = new HashMap<>();
|
|
|
if (mapParams.containsKey("mainTreeId") && StringUtils.isNotEmpty(mapParams.get("mainTreeId")+"")) {
|
|
|
BusiSiteTree busiSiteTree = busiSiteTreeService.findByPK(mapParams.get("mainTreeId")+"");
|
|
|
List<LightningrodImVo> lightningrodImList = lightningrodImMapper.exportCacMonitorData(mapParams);
|
|
|
String replaceRegex = "[\\\\n`~!@#$%^&*()+=|{}':;',\\\\\\\\[\\\\\\\\].<>/?~！@#￥%……&*（）——+|{}【】‘；：”“’。， 、？]";
|
|
|
String treeName = busiSiteTree.getName().replaceAll(replaceRegex, "-");
|
|
|
returnMap.put("fileName", String.format("%s%s", treeName,"落雷监测数据"));
|
|
|
returnMap.put("title", String.format("%s%s", treeName,"落雷监测数据"));
|
|
|
if (lightningrodImList.isEmpty()) {
|
|
|
lightningrodImList = new ArrayList<>();
|
|
|
lightningrodImList.add(new LightningrodImVo());
|
|
|
}
|
|
|
returnMap.put("data", lightningrodImList);
|
|
|
} else {
|
|
|
throw new RuntimeException("主设备编码不正确");
|
|
|
}
|
|
|
return returnMap;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public List<LightningrodImStabilityVo> getByStatus(String sensorCode, String status, LocalDateTime begin, LocalDateTime end) {
|
|
|
return lightningrodImMapper.selectByStatus( sensorCode, status, begin, end);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
protected List<Map<String, Object>> queryMonitorDataList(LocalDateTime startTime, LocalDateTime endTime) {
|
|
|
return lightningrodImMapper.queryMonitorDataList(startTime, endTime);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
protected void saveBusiOnlineMonitorData(BusiOnlineMonitorData busiOnlineMonitorData, Map<String, Object> item) {
|
|
|
busiOnlineMonitorData.setSubEquipmentType(ArresterTreeEnum.JY_EQM.getValue());
|
|
|
busiOnlineMonitorData.setExtType(ExternalTypeEnum.BLQ.getValue());
|
|
|
busiOnlineMonitorData.setEquipmentType(SiteTreeEnum.BLQ_HL_EQM.getValue());
|
|
|
// 这里将保存的任务交给父类方法完成，子类只需要修改指定几个字段就可以了
|
|
|
super.saveBusiOnlineMonitorData(busiOnlineMonitorData, item);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
protected Map<String, Object> thresholdDataMap(BusiOnlineMonitorDataVo vo) {
|
|
|
Map<String, Object> tMap = Maps.newLinkedHashMapWithExpectedSize(10);
|
|
|
ArresterInsulationMonitorThreshold thresholdVo = arresterInsulationMonitorThresholdService
|
|
|
.getArresterInsulationMonitorThreshold(vo.getMainTreeId(), vo.getRunState(), vo.getSensorCode());
|
|
|
if(thresholdVo == null) {
|
|
|
return tMap;
|
|
|
}
|
|
|
String phase = phase(vo.getPhase());
|
|
|
if("A".equalsIgnoreCase(phase)) {
|
|
|
tMap.put("totalCurrentWarning", thresholdVo.getAFullCurrentWarning());
|
|
|
tMap.put("totalCurrentThreshold", thresholdVo.getAFullCurrentThreshold());
|
|
|
tMap.put("resistiveCurrentWarning", thresholdVo.getAResistiveCurrentWarning());
|
|
|
tMap.put("resistiveCurrentThreshold", thresholdVo.getAResistiveCurrentThreshold());
|
|
|
tMap.put("capacitanceCurrentWarning", thresholdVo.getACapacitanceCurrentWarning());
|
|
|
tMap.put("capacitanceCurrentThreshold", thresholdVo.getACapacitanceCurrentThreshold());
|
|
|
}else if("B".equals(phase)) {
|
|
|
tMap.put("totalCurrentWarning", thresholdVo.getBFullCurrentWarning());
|
|
|
tMap.put("totalCurrentThreshold", thresholdVo.getBFullCurrentThreshold());
|
|
|
tMap.put("resistiveCurrentWarning", thresholdVo.getBResistiveCurrentWarning());
|
|
|
tMap.put("resistiveCurrentThreshold", thresholdVo.getBResistiveCurrentThreshold());
|
|
|
tMap.put("capacitanceCurrentWarning", thresholdVo.getBCapacitanceCurrentWarning());
|
|
|
tMap.put("capacitanceCurrentThreshold", thresholdVo.getBCapacitanceCurrentThreshold());
|
|
|
}else if("C".equals(phase)) {
|
|
|
tMap.put("totalCurrentWarning", thresholdVo.getCFullCurrentWarning());
|
|
|
tMap.put("totalCurrentThreshold", thresholdVo.getCFullCurrentThreshold());
|
|
|
tMap.put("resistiveCurrentWarning", thresholdVo.getCResistiveCurrentWarning());
|
|
|
tMap.put("resistiveCurrentThreshold", thresholdVo.getCResistiveCurrentThreshold());
|
|
|
tMap.put("capacitanceCurrentWarning", thresholdVo.getCCapacitanceCurrentWarning());
|
|
|
tMap.put("capacitanceCurrentThreshold", thresholdVo.getCCapacitanceCurrentThreshold());
|
|
|
}
|
|
|
return tMap;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public LightningrodImStatisticsVo getListEquInfo(String cacMonitorTypeCode, LocalDate day, String sensorCode) {
|
|
|
LightningrodImStatisticsDto param = new LightningrodImStatisticsDto();
|
|
|
param.setCacMonitorTypeCode(cacMonitorTypeCode);
|
|
|
param.setStartTime(day.atStartOfDay());
|
|
|
param.setEndTime(day.plusDays(1).atStartOfDay());
|
|
|
param.setSensorCode(sensorCode);
|
|
|
List<LightningrodImStatisticsVo> list = lightningrodImMapper.getListEquInfo(param);
|
|
|
return CollectionUtils.isEmpty(list) ? null : list.get(0);
|
|
|
}
|
|
|
|
|
|
// *****************************趋势图部分********************************\\
|
|
|
@Override
|
|
|
public List<BaseCurveQueryDto> findSensorCodeList(LocalDate day) {
|
|
|
return lightningrodImMapper.findSensorCodeList(day.atStartOfDay(), day.plusDays(1).atStartOfDay());
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public List<PointItemVo> findDaylyPointList(BaseCurveQueryDto sensorCode, LocalDate day, String subType) {
|
|
|
return lightningrodImMapper.findDaylyPointList(sensorCode, subType, day.atStartOfDay(),
|
|
|
day.plusDays(1).atStartOfDay());
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public PointItemDto getDaylyPointStatistics(BaseCurveQueryDto param) {
|
|
|
return lightningrodImMapper.getDaylyPointStatistics(param);
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 获取避雷器最近半年类落雷监测次数
|
|
|
*/
|
|
|
@Override
|
|
|
public String getSensorActionCount(String sensorCode, LocalDateTime startTime, LocalDateTime endTime) {
|
|
|
// TODO Auto-generated method stub
|
|
|
Map<String, Object> param = Maps.newLinkedHashMapWithExpectedSize(3);
|
|
|
param.put("sensorCode", sensorCode);
|
|
|
param.put("startTime", startTime);
|
|
|
param.put("endTime", endTime);
|
|
|
String actionCount = lightningrodImMapper.getActionCount(param);
|
|
|
return actionCount;
|
|
|
}
|
|
|
} |