Commit 73e272b0 authored by maoying's avatar maoying

修改消防水源接口及预案添加参数

parent b1f2804f
...@@ -21,6 +21,9 @@ public class ContingencyRo implements Serializable { ...@@ -21,6 +21,9 @@ public class ContingencyRo implements Serializable {
private String fireEquipmentName;//消防设备名称 private String fireEquipmentName;//消防设备名称
@Label("消防设备id") @Label("消防设备id")
private String fireEquipmentId;//消防设备id private String fireEquipmentId;//消防设备id
@Label("消防设备code")
private String fireEquipmentCode;//消防设备code
private Integer layer=0;//显示图层 private Integer layer=0;//显示图层
......
...@@ -9,6 +9,7 @@ import org.apache.ibatis.annotations.Param; ...@@ -9,6 +9,7 @@ import org.apache.ibatis.annotations.Param;
import com.yeejoin.amos.fas.business.bo.BindRegionBo; import com.yeejoin.amos.fas.business.bo.BindRegionBo;
import com.yeejoin.amos.fas.business.param.CommonPageInfoParam; import com.yeejoin.amos.fas.business.param.CommonPageInfoParam;
import com.yeejoin.amos.fas.business.vo.FormInstanceVo;
import com.yeejoin.amos.fas.core.common.response.RegionTreeResponse; import com.yeejoin.amos.fas.core.common.response.RegionTreeResponse;
import com.yeejoin.amos.fas.core.common.response.RiskSourceTreeResponse; import com.yeejoin.amos.fas.core.common.response.RiskSourceTreeResponse;
import com.yeejoin.amos.fas.dao.entity.RiskSource; import com.yeejoin.amos.fas.dao.entity.RiskSource;
...@@ -93,7 +94,7 @@ public interface RiskSourceMapper extends BaseMapper { ...@@ -93,7 +94,7 @@ public interface RiskSourceMapper extends BaseMapper {
List<RiskSourceTreeResponse> getCheckPointRiskSource(); List<RiskSourceTreeResponse> getCheckPointRiskSource();
List<Map> queryContingencyWater(); List<FormInstanceVo> queryContingencyWater();
List<Map> queryFmeaByPointId(@Param("pointId") Long pointId); List<Map> queryFmeaByPointId(@Param("pointId") Long pointId);
......
...@@ -550,6 +550,7 @@ public class RiskSourceServiceImpl implements IRiskSourceService { ...@@ -550,6 +550,7 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
contingencyRo.setEquipmentName(equipment.getName()); contingencyRo.setEquipmentName(equipment.getName());
contingencyRo.setFireEquipmentId(String.valueOf(fireEquipment.getId())); contingencyRo.setFireEquipmentId(String.valueOf(fireEquipment.getId()));
contingencyRo.setFireEquipmentName(fireEquipment.getName()); contingencyRo.setFireEquipmentName(fireEquipment.getName());
contingencyRo.setFireEquipmentCode(fireEquipment.getCode());
contingencyRo.setStep("0"); contingencyRo.setStep("0");
contingencyRo.setConfirm("NONE"); contingencyRo.setConfirm("NONE");
contingencyRo.setFireTruckRoute(equipment.getFireTruckRoute()); contingencyRo.setFireTruckRoute(equipment.getFireTruckRoute());
...@@ -1392,29 +1393,29 @@ public class RiskSourceServiceImpl implements IRiskSourceService { ...@@ -1392,29 +1393,29 @@ public class RiskSourceServiceImpl implements IRiskSourceService {
// } // }
@Override @Override
public List<Map> queryContingencyWater() { public List<FormInstanceVo> queryContingencyWater() {
List<Map> list = riskSourceMapper.queryContingencyWater(); List<FormInstanceVo> list = riskSourceMapper.queryContingencyWater();
for (Map map : list) { for (FormInstanceVo map : list) {
String iotCode = ""; String iotCode = "";
String maxlevel = ""; String maxlevel = "";
String volume = ""; String volume = "";
double area = 0; double area = 0;
if (!ObjectUtils.isEmpty(map.get("area"))) { if (!ObjectUtils.isEmpty(map.getArea())) {
area = Double.valueOf(map.get("area").toString()); area = Double.valueOf(map.getArea());
} }
if (!ObjectUtils.isEmpty(map.get("iot_code"))) { if (!ObjectUtils.isEmpty(map.getIotCode())) {
iotCode = map.get("iot_code").toString(); iotCode = map.getIotCode();
} }
Object value = redisTemplate.opsForValue().get("WaterLevel:Value:" + iotCode); Object value = redisTemplate.opsForValue().get("WaterLevel:Value:" + iotCode);
if (StringUtil.isNotEmpty(value)) { if (StringUtil.isNotEmpty(value)) {
maxlevel = map.get("max_level") != null ? map.get("max_level").toString() : value.toString(); maxlevel = map.getMaxLevel() != null ? map.getMaxLevel() : value.toString();
volume = map.get("volume") != null && StringUtil.isNumeric(map.get("volume").toString()) ? String.format("%.2f", (Double.valueOf(map.get("volume").toString()))) : String.format("%.2f", Double.valueOf(value.toString()) * area); volume = map.getVolume() != null && StringUtil.isNumeric(map.getVolume()) ? String.format("%.2f", (Double.valueOf(map.getVolume()))) : String.format("%.2f", Double.valueOf(value.toString()) * area);
} else { } else {
maxlevel = map.get("max_level") != null ? map.get("max_level").toString() : "0.0"; maxlevel = map.getMaxLevel() != null ? map.getMaxLevel() : "0.0";
volume = map.get("volume") != null && StringUtil.isNumeric(map.get("volume").toString()) ? String.format("%.2f", (Double.valueOf(map.get("volume").toString()))) : String.format("%.2f", Double.valueOf(maxlevel) * area); volume = map.getVolume() != null && StringUtil.isNumeric(map.getVolume()) ? String.format("%.2f", (Double.valueOf(map.getVolume()))) : String.format("%.2f", Double.valueOf(maxlevel) * area);
} }
map.put("level", maxlevel); map.setLevel(maxlevel);
map.put("volume", volume); map.setVolume(volume);
} }
return list; return list;
} }
......
...@@ -11,6 +11,7 @@ import com.yeejoin.amos.fas.business.param.AlarmParam; ...@@ -11,6 +11,7 @@ import com.yeejoin.amos.fas.business.param.AlarmParam;
import com.yeejoin.amos.fas.business.param.CommonPageInfoParam; import com.yeejoin.amos.fas.business.param.CommonPageInfoParam;
import com.yeejoin.amos.fas.business.param.FmeaBindParam; import com.yeejoin.amos.fas.business.param.FmeaBindParam;
import com.yeejoin.amos.fas.business.service.model.ContingencyDeviceStatus; import com.yeejoin.amos.fas.business.service.model.ContingencyDeviceStatus;
import com.yeejoin.amos.fas.business.vo.FormInstanceVo;
import com.yeejoin.amos.fas.core.common.request.CommonPageable; import com.yeejoin.amos.fas.core.common.request.CommonPageable;
import com.yeejoin.amos.fas.core.common.response.RegionTreeResponse; import com.yeejoin.amos.fas.core.common.response.RegionTreeResponse;
import com.yeejoin.amos.fas.core.common.response.RiskSourceTreeResponse; import com.yeejoin.amos.fas.core.common.response.RiskSourceTreeResponse;
...@@ -150,7 +151,7 @@ public interface IRiskSourceService { ...@@ -150,7 +151,7 @@ public interface IRiskSourceService {
void queryContingencyDeviceStatus(ContingencyDeviceStatus contingencyDeviceStatus); void queryContingencyDeviceStatus(ContingencyDeviceStatus contingencyDeviceStatus);
List<Map> queryContingencyWater(); List<FormInstanceVo> queryContingencyWater();
List<Map> queryFmeaByPointId(Long pointId); List<Map> queryFmeaByPointId(Long pointId);
......
...@@ -52,3 +52,6 @@ emqx.password=public ...@@ -52,3 +52,6 @@ emqx.password=public
#文件服务器地址 #文件服务器地址
file.downLoad.url=http://39.98.246.31:8888/ file.downLoad.url=http://39.98.246.31:8888/
#规则ip配置,用于多网卡及docker镜像启动时添加
rule.definition.local-ip=172.16.11.201
...@@ -6,8 +6,8 @@ ...@@ -6,8 +6,8 @@
SELECT SELECT
MAX( CASE WHEN a.field_name = 'name' THEN a.field_value END ) AS `name`, MAX( CASE WHEN a.field_name = 'name' THEN a.field_value END ) AS `name`,
MAX( CASE WHEN a.field_name = 'code' THEN a.field_value END ) AS `code`, MAX( CASE WHEN a.field_name = 'code' THEN a.field_value END ) AS `code`,
MAX( CASE WHEN a.field_name = 'height' THEN a.field_value END ) AS max_level, MAX( CASE WHEN a.field_name = 'height' THEN a.field_value END ) AS maxLevel,
MAX( CASE WHEN a.field_name = 'lowWaterHeight' THEN a.field_value END ) AS alarm_level, MAX( CASE WHEN a.field_name = 'lowWaterHeight' THEN a.field_value END ) AS alarmLevel,
MAX( CASE WHEN a.field_name = 'bottomArea' THEN a.field_value END ) AS area, MAX( CASE WHEN a.field_name = 'bottomArea' THEN a.field_value END ) AS area,
MAX( CASE WHEN a.field_name = 'volume' THEN a.field_value END ) AS volume, MAX( CASE WHEN a.field_name = 'volume' THEN a.field_value END ) AS volume,
es.iot_code es.iot_code
......
...@@ -641,7 +641,7 @@ ...@@ -641,7 +641,7 @@
rf.id = ${factorId} rf.id = ${factorId}
) )
</select> </select>
<select id="queryContingencyWater" resultType="java.util.HashMap"> <select id="queryContingencyWater" resultType="com.yeejoin.amos.fas.business.vo.FormInstanceVo">
SELECT SELECT
* *
FROM FROM
...@@ -649,8 +649,8 @@ ...@@ -649,8 +649,8 @@
SELECT SELECT
MAX( CASE WHEN a.field_name = 'name' THEN a.field_value END ) AS `name`, MAX( CASE WHEN a.field_name = 'name' THEN a.field_value END ) AS `name`,
MAX( CASE WHEN a.field_name = 'code' THEN a.field_value END ) AS `code`, MAX( CASE WHEN a.field_name = 'code' THEN a.field_value END ) AS `code`,
MAX( CASE WHEN a.field_name = 'height' THEN a.field_value END ) AS max_level, MAX( CASE WHEN a.field_name = 'height' THEN a.field_value END ) AS maxLevel,
MAX( CASE WHEN a.field_name = 'lowWaterHeight' THEN a.field_value END ) AS alarm_level, MAX( CASE WHEN a.field_name = 'lowWaterHeight' THEN a.field_value END ) AS alarmLevel,
MAX( CASE WHEN a.field_name = 'bottomArea' THEN a.field_value END ) AS area, MAX( CASE WHEN a.field_name = 'bottomArea' THEN a.field_value END ) AS area,
MAX( CASE WHEN a.field_name = 'volume' THEN a.field_value END ) AS volume, MAX( CASE WHEN a.field_name = 'volume' THEN a.field_value END ) AS volume,
es.iot_code es.iot_code
...@@ -663,8 +663,8 @@ ...@@ -663,8 +663,8 @@
a.instance_id a.instance_id
) s ) s
GROUP BY GROUP BY
s.alarm_level, s.alarmLevel,
s.max_level, s.maxLevel,
s.area, s.area,
s.`name` s.`name`
</select> </select>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment