监盘概览部分API提交

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/controller/SupervisionConfigureController.java

@@ -7,11 +7,16 @@ import com.yeejoin.equipmanage.common.utils.CommonPageable;
 import com.yeejoin.equipmanage.common.utils.CommonResponseUtil;
 import com.yeejoin.equipmanage.common.utils.StringUtil;
 import com.yeejoin.equipmanage.config.PersonIdentify;
+import com.yeejoin.equipmanage.mapper.FireFightingSystemMapper;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.MediaType;
+import org.springframework.util.ObjectUtils;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 import org.typroject.tyboot.core.foundation.enumeration.UserType;
 import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
@@ -23,4 +28,89 @@ import org.typroject.tyboot.core.restful.utils.ResponseModel;
 @RequestMapping(value = "/supervisionConfigure", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
 public class SupervisionConfigureController extends AbstractBaseController {
 
+    @Autowired
+    private FireFightingSystemMapper fireFightingSystemMapper;
+
+    @PersonIdentify
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "监盘概览水源信息")
+    @GetMapping("/getWaterInfo")
+    public ResponseModel getWaterInfo(CommonPageable commonPageable, @RequestParam(required = false) String bizOrgCode) {
+        if (commonPageable.getPageNumber() == 0) {
+            commonPageable.setPageNumber(1);
+        }
+        if (StringUtils.isEmpty(bizOrgCode)) {
+            ReginParams reginParams = getSelectedOrgInfo();
+            bizOrgCode = !ValidationUtil.isEmpty(reginParams.getPersonIdentity()) && StringUtil.isNotEmpty(reginParams.getPersonIdentity().getBizOrgCode()) ? reginParams.getPersonIdentity().getBizOrgCode() : null;
+        }
+        Page page = new Page<>(commonPageable.getPageNumber(), commonPageable.getPageSize());
+        return CommonResponseUtil.success(fireFightingSystemMapper.getWaterInfoBySuper(page, bizOrgCode));
+    }
+
+    @PersonIdentify
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "监盘概览泡沫罐和水箱信息（监盘概览）")
+    @GetMapping("/getFoamTankBySuper")
+    public ResponseModel getFoamTankBySuper(CommonPageable commonPageable, @RequestParam(required = false) String bizOrgCode) {
+        if (commonPageable.getPageNumber() == 0) {
+            commonPageable.setPageNumber(1);
+        }
+        if (StringUtils.isEmpty(bizOrgCode)) {
+            ReginParams reginParams = getSelectedOrgInfo();
+            bizOrgCode = !ValidationUtil.isEmpty(reginParams.getPersonIdentity()) && StringUtil.isNotEmpty(reginParams.getPersonIdentity().getBizOrgCode()) ? reginParams.getPersonIdentity().getBizOrgCode() : null;
+        }
+        Page page = new Page<>(commonPageable.getPageNumber(), commonPageable.getPageSize());
+        return CommonResponseUtil.success(fireFightingSystemMapper.getFoamTankBySuper(page, bizOrgCode));
+    }
+
+    @PersonIdentify
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "监盘概览管网压力信息（监盘概览）")
+    @GetMapping("/getPipeNetworkBySuper")
+    public ResponseModel getPipeNetworkBySuper(CommonPageable commonPageable, @RequestParam(required = false) String bizOrgCode) {
+        if (commonPageable.getPageNumber() == 0) {
+            commonPageable.setPageNumber(1);
+        }
+        if (StringUtils.isEmpty(bizOrgCode)) {
+            ReginParams reginParams = getSelectedOrgInfo();
+            bizOrgCode = !ValidationUtil.isEmpty(reginParams.getPersonIdentity()) && StringUtil.isNotEmpty(reginParams.getPersonIdentity().getBizOrgCode()) ? reginParams.getPersonIdentity().getBizOrgCode() : null;
+        }
+        Page page = new Page<>(commonPageable.getPageNumber(), commonPageable.getPageSize());
+        return CommonResponseUtil.success(fireFightingSystemMapper.getPipeNetworkBySuper(page, bizOrgCode));
+    }
+
+    @PersonIdentify
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "监盘概览水池装置进水流量信息（监盘概览）")
+    @GetMapping("/getInfluentFlowBySuper")
+    public ResponseModel getInfluentFlowBySuper(CommonPageable commonPageable, @RequestParam(required = false) String bizOrgCode) {
+        if (commonPageable.getPageNumber() == 0) {
+            commonPageable.setPageNumber(1);
+        }
+        if (StringUtils.isEmpty(bizOrgCode)) {
+            ReginParams reginParams = getSelectedOrgInfo();
+            bizOrgCode = !ValidationUtil.isEmpty(reginParams.getPersonIdentity()) && StringUtil.isNotEmpty(reginParams.getPersonIdentity().getBizOrgCode()) ? reginParams.getPersonIdentity().getBizOrgCode() : null;
+        }
+        Page page = new Page<>(commonPageable.getPageNumber(), commonPageable.getPageSize());
+        return CommonResponseUtil.success(fireFightingSystemMapper.getInfluentFlowBySuper(page, bizOrgCode));
+    }
+
+    @PersonIdentify
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "获取某站下装备数量、摄像头数量（监盘概览）")
+    @GetMapping("/statisticsBySuper")
+    public ResponseModel statisticsByStation(@RequestParam(required = false) String bizOrgCode) {
+
+        if (ObjectUtils.isEmpty(bizOrgCode)) {
+            ReginParams reginParams = getSelectedOrgInfo();
+            ReginParams.PersonIdentity personIdentity = reginParams.getPersonIdentity();
+            if (!ValidationUtil.isEmpty(personIdentity)) {
+                bizOrgCode = personIdentity.getBizOrgCode();
+            }
+        }
+        if (ObjectUtils.isEmpty(bizOrgCode)){
+            return CommonResponseUtil.success(null);
+        }
+        return CommonResponseUtil.success(fireFightingSystemMapper.statisticsByStation(bizOrgCode));
+    }
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/mapper/FireFightingSystemMapper.java

@@ -306,6 +306,40 @@ public interface FireFightingSystemMapper extends BaseMapper<FireFightingSystemE
      * @return
      */
     Page<Map<String, Object>> getWaterInfo(Page page, @Param("bizOrgCode") String bizOrgCode, @Param("systemCode") String systemCode);
+
+    /**
+     * 获取水源信息(监盘概览)
+     *
+     * @param bizOrgCode
+     * @return
+     */
+    Page<Map<String, Object>> getWaterInfoBySuper(Page page, @Param("bizOrgCode") String bizOrgCode);
+
+    /**
+     * 监盘概览泡沫罐和水箱信息（监盘概览）
+     * @param page
+     * @param bizOrgCode
+     * @return
+     */
+    Page<Map<String, Object>> getFoamTankBySuper(Page page, @Param("bizOrgCode") String bizOrgCode);
+
+    /**
+     * 监盘概览管网压力信息（监盘概览）
+     * @param page
+     * @param bizOrgCode
+     * @return
+     */
+    Page<Map<String, Object>> getPipeNetworkBySuper(Page page, @Param("bizOrgCode") String bizOrgCode);
+
+    /**
+     * 监盘概览水池装置进水流量信息（监盘概览）
+     * @param page
+     * @param bizOrgCode
+     * @return
+     */
+    Page<Map<String, Object>> getInfluentFlowBySuper(Page page, @Param("bizOrgCode") String bizOrgCode);
+
+
     /**
      * 获取系统今日告警信息
      *

amos-boot-system-equip/src/main/resources/mapper/FireFightingSystemMapper.xml

@@ -4356,4 +4356,298 @@
         temp.notReturnd DESC
 
     </select>
+
+    <select id="getWaterInfoBySuper" resultType="java.util.Map">
+        SELECT
+        r.`name`,
+        ou.`code`,
+        IFNULL( rp.min_water_level, 0 ) AS minLevel,
+        IFNULL( rp.max_water_level, 0 ) AS maxLevel,
+        (
+        CASE
+
+        WHEN max( CASE WHEN ei.equipment_index_key = 'FHS_FirePoolDevice_WaterLevel' THEN ei.`value` END ) IS NULL THEN
+        '--'
+        WHEN max( CASE WHEN ei.equipment_index_key = 'FHS_FirePoolDevice_WaterLevel' THEN ei.`value` END ) >= IFNULL( rp.min_water_level, 0 )
+        AND rp.max_water_level IS NULL THEN
+        '100'
+        WHEN max( CASE WHEN ei.equipment_index_key = 'FHS_FirePoolDevice_WaterLevel' THEN ei.`value` END ) &lt; IFNULL( rp.min_water_level, 0 )
+        AND rp.max_water_level IS NULL THEN
+        '--' ELSE IFNULL((
+        FORMAT(
+        abs(
+        IFNULL(
+        max( CASE WHEN ei.equipment_index_key = 'FHS_FirePoolDevice_WaterLevel' THEN ei.`value` END ),
+        IFNULL( rp.min_water_level, 0 )) /
+        IF
+        (
+        IFNULL( rp.max_water_level, 0 ) = 0,
+        1,
+        IFNULL( rp.max_water_level, 0 ))) * 100,
+        2
+        )
+        ),
+        0
+        )
+        END
+        ) AS levelAbs,
+        IFNULL(max( CASE WHEN ei.equipment_index_key = 'FHS_FirePoolDevice_WaterLevel' THEN ei.`value` END ),'--')  AS nowLevel,
+        (
+        CASE
+
+        WHEN max( CASE WHEN ei.equipment_index_key = 'FHS_FirePoolDevice_WaterLevel' THEN ei.`value` END ) IS NULL
+        OR rp.min_water_level IS NULL THEN
+        '--'
+        WHEN IFNULL(
+        max( CASE WHEN ei.equipment_index_key = 'FHS_FirePoolDevice_WaterLevel' THEN ei.`value` END ),
+        IFNULL( rp.min_water_level, 0 )) &lt; IFNULL( rp.min_water_level, 0 ) THEN
+        '缺水' ELSE '正常'
+        END
+        ) AS levelStatus,
+        IFNULL( rp.volume, 0 ) AS volume,
+        ec.image,
+        r.resource_type,
+        r.sequence_nbr,
+        fs.`code` AS systemCode
+        FROM
+        cb_water_resource r
+        LEFT JOIN cb_org_usr ou ON ou.biz_org_code = r.biz_org_code
+        AND ou.is_delete = 0
+        LEFT JOIN cb_water_resource_pool rp ON rp.resource_id = r.sequence_nbr
+        LEFT JOIN wl_equipment_specific es ON es.id = rp.level_device_id
+        LEFT JOIN wl_equipment_detail ed ON ed.id = es.equipment_detail_id
+        LEFT JOIN wl_equipment_specific_index ei ON ei.equipment_specific_id = rp.level_device_id
+        LEFT JOIN wl_equipment_category ec ON ec.id = r.equip_category_id
+        LEFT JOIN f_fire_fighting_system fs ON fs.id = r.belong_fighting_system_id
+        WHERE
+        r.resource_type IN ( 'pool', 'industryPool' )
+        AND r.is_delete = 1
+        AND ou.`code` IS NOT NULL
+        <if test="bizOrgCode!=null and bizOrgCode!=''">
+            AND r.biz_org_code like concat(#{bizOrgCode}, '%')
+        </if>
+        GROUP BY
+        r.sequence_nbr
+        ORDER BY
+        levelStatus DESC
+    </select>
+
+    <select id="getFoamTankBySuper" resultType="java.util.Map">
+        SELECT
+            a.`name`,
+            IFNULL(a.nowLevel, '--') AS nowLevel,
+            a.id,
+            IFNULL(a.image, '') AS image,
+            (
+                CASE
+
+                    WHEN a.nowLevel IS NULL THEN
+                        '--'
+                    WHEN a.nowLevel >= IFNULL( a.minLevel, 0 )
+                        AND a.maxLevel IS NULL THEN
+                        '100'
+                    WHEN IFNULL( a.minLevel, 0 ) > a.nowLevel
+                        AND a.maxLevel IS NULL THEN
+                        '--' ELSE IFNULL((
+                                             FORMAT(
+                                                         abs(
+                                                                     IFNULL(
+                                                                             a.nowLevel,
+                                                                             IFNULL( a.minLevel, 0 )) /
+                                                                     IF
+                                                                         (
+                                                                             IFNULL( a.maxLevel, 0 ) = 0,
+                                                                             1,
+                                                                             IFNULL( a.maxLevel, 0 ))) * 100,
+                                                         2
+                                                 )
+                                             ),
+                                         0
+                    )
+                    END
+                ) AS levelAbs,
+            (
+                CASE
+
+                    WHEN a.nowLevel IS NULL
+                        OR a.minLevel IS NULL THEN
+                        '--'
+                    WHEN IFNULL( a.minLevel, 0 ) > IFNULL(
+                            a.nowLevel,
+                            IFNULL( a.minLevel, 0 ))   THEN
+                        '缺水' ELSE '正常'
+                    END
+                ) AS levelStatus,
+            'foamTank' AS type
+        FROM
+            (
+                SELECT
+                    ed.`name`,
+                    es.iot_code,
+                    es.id,
+                    ec.image,
+                    max( CASE WHEN ei.equipment_index_key = 'CAFS_FoamTank_FoamTankLevel' THEN ei.`value` END ) AS nowLevel,
+                    max( CASE WHEN fi.field_name = 'minLevel' THEN fi.field_value END ) AS minLevel,
+                    max( CASE WHEN fi.field_name = 'maxLevel' THEN fi.field_value END ) AS maxLevel
+                FROM
+                    wl_equipment_specific es
+                        LEFT JOIN wl_equipment_detail ed ON es.equipment_detail_id = ed.id
+                        LEFT JOIN wl_equipment_specific_index ei ON es.id = ei.equipment_specific_id
+                        LEFT JOIN wl_equipment e ON e.id = ed.equipment_id
+                        LEFT JOIN wl_equipment_category ec ON e.category_id = ec.id
+                        LEFT JOIN wl_form_instance fi ON fi.instance_id = es.id
+                WHERE
+                    ed.`code` LIKE '92031900%'
+                  AND es.biz_org_code LIKE concat(#{bizOrgCode}, '%')
+                  AND es.iot_code IS NOT NULL
+                GROUP BY
+                    es.id
+            ) a UNION ALL
+        SELECT
+            a.`name`,
+            IFNULL(a.nowLevel, '--') as nowLevel,
+            a.id,
+            IFNULL(a.image, '') AS image,
+            (
+                CASE
+
+                    WHEN a.nowLevel IS NULL THEN
+                        '--'
+                    WHEN a.nowLevel >= IFNULL( a.minLevel, 0 )
+                        AND a.maxLevel IS NULL THEN
+                        '100'
+                    WHEN IFNULL( a.minLevel, 0 ) > a.nowLevel
+                        AND a.maxLevel IS NULL THEN
+                        '--' ELSE IFNULL((
+                                             FORMAT(
+                                                         abs(
+                                                                     IFNULL(
+                                                                             a.nowLevel,
+                                                                             IFNULL( a.minLevel, 0 )) /
+                                                                     IF
+                                                                         (
+                                                                             IFNULL( a.maxLevel, 0 ) = 0,
+                                                                             1,
+                                                                             IFNULL( a.maxLevel, 0 ))) * 100,
+                                                         2
+                                                 )
+                                             ),
+                                         0
+                    )
+                    END
+                ) AS levelAbs,
+            (
+                CASE
+
+                    WHEN a.nowLevel IS NULL
+                        OR a.minLevel IS NULL THEN
+                        '--'
+                    WHEN IFNULL( a.minLevel, 0 ) > IFNULL(
+                            a.nowLevel,
+                            IFNULL( a.minLevel, 0 ))  THEN
+                        '缺水' ELSE '正常'
+                    END
+                ) AS levelStatus,
+            a.type AS type
+        FROM
+            (
+                SELECT
+                    r.`name`,
+                    IFNULL( rp.min_water_level, 0 ) AS minLevel,
+                    IFNULL( rp.max_water_level, 0 ) AS maxLevel,
+                    max( CASE WHEN ei.equipment_index_key = 'FHS_FirePoolDevice_WaterLevel' THEN ei.`value` END ) AS nowLevel,
+                    ec.image,
+                    r.resource_type AS type,
+                    r.sequence_nbr AS id
+                FROM
+                    cb_water_resource r
+                        LEFT JOIN cb_water_resource_pool rp ON rp.resource_id = r.sequence_nbr
+                        LEFT JOIN wl_equipment_specific_index ei ON ei.equipment_specific_id = rp.level_device_id
+                        LEFT JOIN wl_equipment_category ec ON ec.id = r.equip_category_id
+                WHERE
+                    r.resource_type = 'waterTank'
+                  AND r.biz_org_code LIKE concat(#{bizOrgCode}, '%')
+                  AND r.is_delete = 1
+                GROUP BY
+                    r.sequence_nbr
+            ) a
+    </select>
+
+    <select id="getPipeNetworkBySuper" resultType="java.util.Map">
+        SELECT
+            a.`name`,
+            IFNULL(a.area, '') AS area,
+            a.id,
+            IFNULL(a.nowPressure, '--') AS nowPressure,
+            a.nowPressureDate,
+            (
+                CASE
+
+                    WHEN nowPressure IS NOT NULL
+                        AND minLevel IS NOT NULL
+                        AND nowPressure >= minLevel THEN
+                        '正常'
+                    WHEN nowPressure IS NOT NULL
+                        AND minLevel IS NOT NULL
+                        AND minLevel > nowPressure THEN
+                        '压力低' ELSE '--'
+                    END
+                ) AS `status`
+        FROM
+            (
+                SELECT
+                    ed.`name`,
+                    concat_ws( '-', ws.full_name, ed.area ) area,
+                    es.id,
+                    max( CASE WHEN ei.equipment_index_key = 'FHS_PipePressureDetector_PipePressure' THEN ei.`value` END ) AS nowPressure,
+                    IF
+                        ((
+                             max( CASE WHEN ei.equipment_index_key = 'FHS_PipePressureDetector_PipePressure' THEN ei.`value` END ) IS NOT NULL
+                             ),
+                         max( CASE WHEN ei.equipment_index_key = 'FHS_PipePressureDetector_PipePressure' THEN DATE_FORMAT( ei.`update_date`, '%m-%d %H:%i:%S' ) END ),
+                         '--'
+                        ) AS nowPressureDate,
+                    max( CASE WHEN fi.field_name = 'lowLevel' THEN fi.field_value END ) AS minLevel,
+                    max( CASE WHEN fi.field_name = 'highLevel' THEN fi.field_value END ) AS maxLevel
+                FROM
+                    wl_equipment_specific es
+                        LEFT JOIN wl_equipment_detail ed ON es.equipment_detail_id = ed.id
+                        LEFT JOIN wl_warehouse_structure ws ON ws.id = es.warehouse_structure_id
+                        LEFT JOIN wl_equipment_specific_index ei ON es.id = ei.equipment_specific_id
+                        LEFT JOIN wl_form_instance fi ON fi.instance_id = es.id
+                WHERE
+                    ed.`code` LIKE '92011000%'
+                  AND es.iot_code IS NOT NULL
+                  AND es.biz_org_code like concat(#{bizOrgCode}, '%')
+                GROUP BY
+                    es.id
+            ) a
+    </select>
+
+    <select id="getInfluentFlowBySuper" resultType="java.util.Map">
+        SELECT
+            ed.`name`,
+            IFNULL(concat_ws( '-', ws.full_name, ed.area ), '') AS area,
+            es.id,
+            IFNULL( max( CASE WHEN ei.equipment_index_key = 'FHS_FirePoolDevice_InfluentFlow' THEN ei.`value` END ), '--' ) AS nowInfluentFlow,
+            IF
+                ((
+                     max( CASE WHEN ei.equipment_index_key = 'FHS_FirePoolDevice_InfluentFlow' THEN ei.`value` END ) IS NOT NULL
+                     ),
+                 max( CASE WHEN ei.equipment_index_key = 'FHS_FirePoolDevice_InfluentFlow' THEN DATE_FORMAT( ei.`update_date`, '%m-%d %H:%i:%S' ) END ),
+                 '--'
+                ) AS nowInfluentFlowDate
+        FROM
+            wl_equipment_specific es
+                LEFT JOIN wl_equipment_detail ed ON es.equipment_detail_id = ed.id
+                LEFT JOIN wl_warehouse_structure ws ON ws.id = es.warehouse_structure_id
+                LEFT JOIN wl_equipment_specific_index ei ON es.id = ei.equipment_specific_id
+                LEFT JOIN wl_form_instance fi ON fi.instance_id = es.id
+        WHERE
+            ed.`code` LIKE '92010700%'
+          AND es.iot_code IS NOT NULL
+          AND es.biz_org_code LIKE concat(#{bizOrgCode}, '%')
+        GROUP BY
+            es.id
+    </select>
 </mapper>