修改代码

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/IdxBizPvHealthIndexController.java

@@ -192,4 +192,21 @@ public class IdxBizPvHealthIndexController extends BaseController {
 
 		return ResponseHelper.buildResponse(list);
 	}
-}
+	@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
+	@ApiOperation(httpMethod = "GET",value = "预警监测设备级统计",   notes = "预警监测设备级统计")
+	@GetMapping(value = "/queryForPointNum")
+	public ResponseModel<Map<String,Object>> selectPointByANALYSISTYPE(@RequestParam(required = false) String STATION, @RequestParam(required = false)String HEALTHLEVEL,@RequestParam(required = false) String EQUIPMENTNAME,@RequestParam(required = false)String POINTNAME,@RequestParam(required = false)String SUBARRAY,@RequestParam(required = false)String startTime,@RequestParam(required = false) String endTime) {
+
+		List<Map<String, Object>> maps = idxBizPvHealthIndexServiceImpl.selectPointByANALYSISTYPE(STATION, HEALTHLEVEL, EQUIPMENTNAME, POINTNAME,SUBARRAY,startTime,endTime);
+		Map<String,Object> result = new HashMap<>();
+		List<Object> seriesData = new ArrayList<>();
+		List<Object> axisData = new ArrayList<>();
+		for (Map<String, Object> map : maps) {
+			seriesData.add(map.get("value"));
+			axisData.add(map.get("REC_DATE"));
+		}
+
+		result.put("seriesData",seriesData);
+		result.put("axisData",axisData);
+		return ResponseHelper.buildResponse(result);}
+	}

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/mapper2/IdxBizPvHealthIndexMapper.java

@@ -30,6 +30,7 @@ public interface IdxBizPvHealthIndexMapper extends BaseMapper<IdxBizPvHealthInde
 
     List<IdxBizPvWarningRecord> warningData(String STATION, String SUBARRAY, String EQUIPMENTNAME);
     Integer pointNum(String STATION, String SUBARRAY, String EQUIPMENTNAME);
+    List<Map<String,Object>>  selectPointByANALYSISTYPE(String STATION, String HEALTHLEVEL,String EQUIPMENTNAME,String POINTNAME,String SUBARRAY,String startTime,String endTime);
 
 
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/IdxBizPvHealthIndexServiceImpl.java

@@ -66,5 +66,10 @@ public class IdxBizPvHealthIndexServiceImpl extends BaseService<IdxBizPvHealthIn
         return this.getBaseMapper().warningData(STATION, SUBARRAY, EQUIPMENTNAME);
     }
 
+    public List<Map<String,Object>>  selectPointByANALYSISTYPE(String STATION, String HEALTHLEVEL, String EQUIPMENTNAME, String POINTNAME, String SUBARRAY, String startTime, String endTime){
+
+        return this.getBaseMapper().selectPointByANALYSISTYPE(STATION,HEALTHLEVEL,EQUIPMENTNAME,POINTNAME,SUBARRAY,startTime,endTime);
+    };
+
 
 }
\ No newline at end of file

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/mapper/cluster/IdxBizPvHealthIndexMapper.xml

@@ -275,4 +275,62 @@
         </if>
     </select>
 
+
+    <select id="selectPointByANALYSISTYPE" resultType="map">
+        SELECT
+        b.*
+        FROM
+        (
+        SELECT
+        POINT_NAME,
+        STATION,
+        HEALTH_INDEX,
+        HEALTH_INDEX AS VALUE,
+        HEALTH_LEVEL,
+        ( CASE HEALTH_LEVEL WHEN '危险' THEN 3 WHEN '警告' THEN 2 WHEN '注意' THEN 1 ELSE 0 END ) AS STATUS,
+        SUBARRAY,
+        REC_DATE,
+        EQUIPMENT_NAME,
+        INDEX_ADDRESS,
+        ANALYSIS_OBJ_SEQ,
+        ANALYSIS_TYPE
+        FROM
+        `idx_biz_pv_health_index`
+        WHERE
+        ANALYSIS_OBJ_TYPE = '测点'
+        <if test="(startTime == null or startTime == '' ) and (endTime == null or endTime =='')  ">
+            AND ( ANALYSIS_TYPE = '按小时' AND REC_DATE >= DATE_SUB( NOW( ), INTERVAL 15 HOUR ) )
+            OR ( REC_DATE >=DATE_SUB( NOW(), INTERVAL 15 DAY ) AND ANALYSIS_TYPE = '按天' )
+            OR ( ANALYSIS_TYPE = '按时刻' AND REC_DATE >= DATE_SUB( NOW( ), INTERVAL 150 MINUTE ) )
+        </if>
+        <if test="startTime != null and startTime != '' or endTime != null and endTime != '' ">
+            AND REC_DATE >= #{startTime}
+        </if>
+        <if test="endTime != null and endTime != ''">
+            <![CDATA[ AND REC_DATE  <= #{endTime}]]>
+        </if>
+        ) b
+        INNER JOIN idx_biz_pv_warning_rule_set rule ON rule.ANALYSIS_POINT_ID = b.ANALYSIS_OBJ_SEQ
+        AND rule.WARNING_NAME = '注意'
+        AND rule.ANALYSIS_TYPE = b.ANALYSIS_TYPE
+        <where>
+            <if test="STATION != null and  STATION != '' ">
+                b.STATION = #{STATION}
+            </if>
+            <if test="SUBARRAY != null and  SUBARRAY != '' ">
+                AND b.SUBARRAY = #{SUBARRAY}
+            </if>
+            <if test="EQUIPMENTNAME != null and  EQUIPMENTNAME != '' ">
+                AND b.EQUIPMENT_NAME = #{EQUIPMENTNAME}
+            </if>
+            <if test="HEALTHLEVEL != null and  HEALTHLEVEL != '' ">
+                AND b.HEALTH_LEVEL = #{HEALTHLEVEL}
+            </if>
+            <if test="POINTNAME != null and  POINTNAME != '' ">
+                AND b.POINT_NAME = #{POINTNAME}
+            </if>
+        </where>
+
+    </select>
+
 </mapper>