任务 13500

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

@@ -490,6 +490,16 @@ public class EquipmentAlarmController extends AbstractBaseController {
         return CommonResponseUtil.success(map);
     }
 
+    @RequestMapping(value = "/pressureMessage", method = RequestMethod.GET)
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(httpMethod = "GET", value = "站端双月报稳压泵打压频次信息", produces = "application/json;charset=UTF-8", notes = "数字换流站根据id获取装备详情")
+    public ResponseModel pressureMessage(@RequestParam(value = "startTime") String startTime,
+                                           @RequestParam(value = "orgCode") String orgCode,
+                                           @RequestParam(value = "endTime") String endTime) {
+        Map<String, Object> map = iEquipmentSpecificAlarmService.pressureMessage(orgCode, startTime, endTime);
+        return CommonResponseUtil.success(map);
+    }
+
     @RequestMapping(value = "/getAllEquipNum", method = RequestMethod.GET)
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @ApiOperation(httpMethod = "GET", value = "查装备数量", produces = "application/json;charset=UTF-8", notes = "查装备数量")

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

@@ -221,6 +221,9 @@ public interface EquipmentSpecificAlarmMapper extends BaseMapper<EquipmentSpecif
     Map<String, Object> inspectionMessage(@Param("orgCode") String orgCode
             , @Param("startTime") String startTime
             , @Param("endTime") String endTime);
+    Map<String, Object> pressureMessage(@Param("orgCode") String orgCode
+            , @Param("startTime") String startTime
+            , @Param("endTime") String endTime);
 
     Page<Map<String, Object>> fireAlarmLogPage(Page page, @Param("param") CommonPageInfoParam param);
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/IEquipmentSpecificAlarmService.java

@@ -93,6 +93,7 @@ public interface IEquipmentSpecificAlarmService extends IService<EquipmentSpecif
     List<Map<String, Object>> fireFacilitiesList(String bizOrgCode, String startTime, String endTime);
     Map<String, Object> dailyMaintenance(String bizOrgCode,String orgCode, String startTime, String endTime);
     Map<String, Object> inspectionMessage(String orgCode, String startTime, String endTime);
+    Map<String, Object> pressureMessage(String orgCode, String startTime, String endTime);
 
     Page<Map<String, Object>> fireAlarmLogPage(CommonPageInfoParam param);
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/EquipmentSpecificAlarmServiceImpl.java

@@ -760,6 +760,38 @@ public class EquipmentSpecificAlarmServiceImpl extends ServiceImpl<EquipmentSpec
     }
 
     @Override
+    public Map<String, Object> pressureMessage(String orgCode, String startTime, String endTime) {
+        Map<String, Object> stringObjectMap = equipmentSpecificAlarmMapper.pressureMessage(orgCode, startTime, endTime);
+        Map<String, Object> retMap = new HashMap<>();
+        int allNum = Integer.parseInt(stringObjectMap.get("allNum").toString());
+        int startNum = Integer.parseInt(stringObjectMap.get("startNum").toString());
+        // 计算平均每小时打压频率
+        try {
+            int hour = DateUtils.dateBetweenNew(DateUtils.dateParse(startTime, null),DateUtils.dateParse(endTime, null));
+
+            int hafHour = DateUtils.dateBetweenNew1(DateUtils.dateParse(startTime, null),DateUtils.dateParse(endTime, null));
+
+            int twoHour = DateUtils.dateBetweenNew2(DateUtils.dateParse(startTime, null),DateUtils.dateParse(endTime, null));
+
+            int fourHour = DateUtils.dateBetweenNew3(DateUtils.dateParse(startTime, null),DateUtils.dateParse(endTime, null));
+
+            if(allNum/hour > 15) {
+                retMap.put("status","异常");
+            } else  {
+                retMap.put("status","正常");
+            }
+            retMap.put("name", stringObjectMap.get("name").toString());
+            String frequency = "稳压泵总数"+stringObjectMap.get("allEqu").toString()+"台,平均近半小时启动"+startNum/hafHour+"次,"+
+                    "平均2小时启动"+startNum/twoHour+"次，"+"平均4小时启动"+startNum/fourHour+"次";
+            retMap.put("frequency",frequency);
+
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+        return retMap;
+    }
+
+    @Override
     public Page<Map<String, Object>> fireAlarmLogPage(CommonPageInfoParam param) {
         Page result = new Page<>(param.getPageNumber(), param.getPageSize());
         return this.baseMapper.fireAlarmLogPage(result, param);

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

@@ -1476,4 +1476,41 @@
         ORDER BY
             `result`.`click_date`
     </select>
+    <select id="pressureMessage" resultType="java.util.Map">
+        select
+            (
+                select
+                    count(1)
+                from
+                    wl_equipment_specific_index
+                where
+                        equipment_index_key in ('FHS_PressurePump_Start', 'FHS_PressurePump_Stop')
+                  and update_date >=
+                      #{startTime} and  #{endTime} >=  update_date
+            ) as allNum,
+            (
+                select
+                    (
+                        select
+                            count(1)
+                        from
+                            wl_equipment_detail wed
+                        where
+                            wed.code like '92010800%' ) as allEqu) as allEqu,
+            (
+                select
+                    '稳压泵平均打压频次' as name) as name,
+            (
+                select
+                    (
+                        select
+                            count(1)
+                        from
+                            wl_equipment_specific_index
+                        where
+                            equipment_index_key in ('FHS_PressurePump_Start')
+                          and update_date >=
+                              #{startTime} and  #{endTime} >=  update_date
+                    ) as startNum) as startNum
+    </select>
 </mapper>
\ No newline at end of file