修改代码

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/MonitorFanIdxController.java

@@ -17,6 +17,7 @@ import com.yeejoin.amos.boot.module.jxiop.biz.constants.CommonConstans;
 import com.yeejoin.amos.boot.module.jxiop.biz.dto.DeaviationRateDto;
 import com.yeejoin.amos.boot.module.jxiop.biz.dto.ResultsData;
 import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.CommonServiceImpl;
+import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.EquipAlarmEventServiceImpl;
 import com.yeejoin.amos.boot.module.jxiop.biz.service.impl.MonitorFanIndicatorImpl;
 import com.yeejoin.amos.component.influxdb.InfluxdbUtil;
 import io.swagger.annotations.Api;
@@ -48,6 +49,9 @@ public class MonitorFanIdxController extends BaseController {
     @Autowired
     MonitorFanIndicatorImpl monitorFanIndicator;
 
+    @Autowired
+    EquipAlarmEventServiceImpl equipAlarmEventService;
+
 
     @Autowired
     StationBasicMapper stationBasicMapper;
@@ -792,7 +796,9 @@ public class MonitorFanIdxController extends BaseController {
         for (StationBasic stationBasic : stationBasics) {
             String gatewayId = stationBasic.getFanGatewayId();
             String werks = stationBasic.getStationNumber();
-            monitorFanIndicator.getListByNbq(gatewayId,werks,stationBasic.getSequenceNbr().toString());
+            if (!stationBasic.getStationType() .equals("FDZ")){
+                monitorFanIndicator.getListByNbq(gatewayId,werks,stationBasic.getSequenceNbr().toString());
+            }
         }
 
 
@@ -864,4 +870,18 @@ public class MonitorFanIdxController extends BaseController {
         return CommonResponseUtil.success();
     }
 
+
+    @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+    @ApiOperation(value = "实时告警")
+    @GetMapping("/getEventByEquipIndex")
+    public ResponseModel<ResultsData> getEventByEquipIndex(@RequestParam(value = "current") int current,
+                                                           @RequestParam(value = "size") int size,
+                                                           @RequestParam(value = "stationId") String stationId,
+                                                           @RequestParam(value = "equipIndex") String equipIndex) {
+        StationBasic stationBasic = stationBasicMapper.selectById(stationId);
+        String gatewayId = stationBasic.getFanGatewayId();
+        ResultsData resultsData = equipAlarmEventService.getEventByEquipIndex(gatewayId, current, size, equipIndex);
+        return ResponseHelper.buildResponse(resultsData);
+    }
+
 }