bonus
/
Bonus-Cloud-SafetyWarning
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

边代数据异常同步WARN报警状态

This commit is contained in:
syruan 2024-11-23 17:51:51 +08:00
parent 89e196b712
commit 57a1355a8e
1 changed files with 36 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
bonus-modules/data/src/main/java/com/bonus/data/service/DataCenterServiceImpl.java
View File

@ -120,6 +120,15 @@ public class DataCenterServiceImpl implements DataCenterService{
attributeVos.clear();
DevAttributeVo devAttributeVo=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"电池电量",vo.getCapacity(),"%","capacity","0",vo.getDataTime(),mergerId);
attributeVos.add(devAttributeVo);
if ("1".equals(isWarn(config,vo.getAngleX(),1,deviceVo,"角度X"))) {
mapper.updateDeviceIsWarn(devId);
}
if ("1".equals(isWarn(config,vo.getAngleY(),1,deviceVo,"角度Y"))) {
mapper.updateDeviceIsWarn(devId);
}
if ("1".equals(isWarn(config,vo.getAngleZ(),1,deviceVo,"角度Z"))) {
mapper.updateDeviceIsWarn(devId);
}
DevAttributeVo devAttributeVo2=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"角度X",vo.getAngleX(),"°","angle_x",isWarn(config,vo.getAngleX(),1,deviceVo,"角度X"),vo.getDataTime(),mergerId);
attributeVos.add(devAttributeVo2);
DevAttributeVo devAttributeVo3=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"角度Y",vo.getAngleY(),"°","angle_y",isWarn(config,vo.getAngleY(),1,deviceVo,"角度Y"),vo.getDataTime(),mergerId);
@ -299,18 +308,33 @@ public class DataCenterServiceImpl implements DataCenterService{
DevAttributeVo devAttributeVo3=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"5.0µm粒子数",vo.getGrain50(),"m³","grain_50","0",vo.getDataTime(),mergerId);
attributeVos.add(devAttributeVo3);
DevAttributeVo devAttributeVo4=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"pm25",vo.getPm25(),"μg/m3","pm25",isWarn(config,vo.getPm25(),2,deviceVo,"pm25"),vo.getDataTime(),mergerId);
if ("1".equals(isWarn(config,vo.getPm25(),2,deviceVo,"pm25"))) {
mapper.updateDeviceIsWarn(devId);
}
attributeVos.add(devAttributeVo4);
DevAttributeVo devAttributeVo5=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"pm10",vo.getPm10(),"μg/m3","pm10",isWarn(config,vo.getPm10(),3,deviceVo,"pm10"),vo.getDataTime(),mergerId);
if ("1".equals(isWarn(config,vo.getPm10(),3,deviceVo,"pm10"))) {
mapper.updateDeviceIsWarn(devId);
}
attributeVos.add(devAttributeVo5);
DevAttributeVo devAttributeVo6=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"噪声",vo.getNoise(),"db","noise",isWarn(config,vo.getNoise(),4,deviceVo,"噪声"),vo.getDataTime(),mergerId);
if ("1".equals(isWarn(config,vo.getNoise(),4,deviceVo,"噪声"))) {
mapper.updateDeviceIsWarn(devId);
}
attributeVos.add(devAttributeVo6);
DevAttributeVo devAttributeVo7=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"风向",vo.getWindDirection(),"","wind_direction","0",vo.getDataTime(),mergerId);
attributeVos.add(devAttributeVo7);
DevAttributeVo devAttributeVo8=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"风速",vo.getWindForce(),"m/s","wind_force","0",vo.getDataTime(),mergerId);
attributeVos.add(devAttributeVo8);
DevAttributeVo devAttributeVo9=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"温度",vo.getAirTemperature(),"°C","air_Temperature",isWarn(config,vo.getAirTemperature(),5,deviceVo,"温度"),vo.getDataTime(),mergerId);
if ("1".equals(isWarn(config,vo.getAirTemperature(),5,deviceVo,"温度"))) {
mapper.updateDeviceIsWarn(devId);
}
attributeVos.add(devAttributeVo9);
DevAttributeVo devAttributeVo10=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"湿度",vo.getHumidity(),"%rh","humidity",isWarn(config,vo.getHumidity(),6,deviceVo,"湿度"),vo.getDataTime(),mergerId);
if ("1".equals(isWarn(config,vo.getHumidity(),6,deviceVo,"湿度"))) {
mapper.updateDeviceIsWarn(devId);
}
attributeVos.add(devAttributeVo10);
DevAttributeVo devAttributeVo11=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"微正压",vo.getPositivePressure(),"Pa","positive_pressure","0",vo.getDataTime(),mergerId);
attributeVos.add(devAttributeVo11);
@ -366,12 +390,24 @@ public class DataCenterServiceImpl implements DataCenterService{
String mergerId= UuidUtils.generateUuid().toUpperCase().replaceAll("-","");
attributeVos.clear();
DevAttributeVo devAttributeVo=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"含氧量",vo.getOxygen(),"%VOL","oxygen",isWarn(config,vo.getOxygen(),7,deviceVo,"含氧量"),vo.getDataTime(),mergerId);
if ("1".equals(isWarn(config,vo.getOxygen(),7,deviceVo,"含氧量"))) {
mapper.updateDeviceIsWarn(devId);
}
attributeVos.add(devAttributeVo);
DevAttributeVo devAttributeVo2=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"一氧化碳",vo.getCarbonMonoxide(),"ppm","carbon_monoxide",isWarn(config,vo.getCarbonMonoxide(),8,deviceVo,"一氧化碳"),vo.getDataTime(),mergerId);
if ("1".equals(isWarn(config,vo.getCarbonMonoxide(),8,deviceVo,"一氧化碳"))) {
mapper.updateDeviceIsWarn(devId);
}
attributeVos.add(devAttributeVo2);
DevAttributeVo devAttributeVo3=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"可燃气体",vo.getCombustible(),"%LEL","combustible",isWarn(config,vo.getCombustible(),9,deviceVo,"可燃气体"),vo.getDataTime(),mergerId);
if ("1".equals(isWarn(config,vo.getCombustible(),9,deviceVo,"可燃气体"))) {
mapper.updateDeviceIsWarn(devId);
}
attributeVos.add(devAttributeVo3);
DevAttributeVo devAttributeVo4=new DevAttributeVo(devId,json,deviceVo.getDevName(),deviceVo.getDevType(),"硫化氢",vo.getHydrothion(),"ppm","hydrothion",isWarn(config,vo.getHydrothion(),10,deviceVo,"硫化氢"),vo.getDataTime(),mergerId);
if ("1".equals(isWarn(config,vo.getHydrothion(),10,deviceVo,"硫化氢"))) {
mapper.updateDeviceIsWarn(devId);
}
attributeVos.add(devAttributeVo4);
//更新/新增设备检测信息及记录
insertOrAddDevAttribute(attributeVos);