From a8fa8c5473d8bd4dc509d9f4b0bb370f443d15ad Mon Sep 17 00:00:00 2001
From: aijinhui <aijinhui>
Date: 星期二, 07 十一月 2023 16:23:03 +0800
Subject: [PATCH] 清淤

---
 ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java |   43 +++++++++++++++++++++----------------------
 1 files changed, 21 insertions(+), 22 deletions(-)

diff --git a/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java b/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java
index f5b13e3..24b034c 100644
--- a/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java
@@ -1,7 +1,6 @@
 package com.ruoyi.statistical.service.impl;
 
 import com.alibaba.fastjson.JSONObject;
-import com.alibaba.fastjson2.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.ruoyi.alarm.access.mapper.ArdAlarmAccessMapper;
 import com.ruoyi.alarm.apponekey.mapper.ArdAlarmApponekeyMapper;
@@ -22,8 +21,8 @@
 import com.ruoyi.device.camera.mapper.ArdCamerasMapper;
 import com.ruoyi.device.radar.domain.ArdEquipRadar;
 import com.ruoyi.device.radar.mapper.ArdEquipRadarMapper;
-import com.ruoyi.statistical.domain.PumpStatus;
-import com.ruoyi.statistical.mapper.PumpStatusMapper;
+import com.ruoyi.statistical.domain.ArdPumpStatus;
+import com.ruoyi.statistical.mapper.ArdPumpStatusMapper;
 import com.ruoyi.statistical.param.ESParam;
 import com.ruoyi.statistical.param.Para;
 import com.ruoyi.statistical.service.StatisticalService;
@@ -75,7 +74,7 @@
     @Autowired
     private ArdCamerasMapper camerasMapper;
     @Autowired
-    private PumpStatusMapper pumpStatusMapper;
+    private ArdPumpStatusMapper ardPumpStatusMapper;
 
 
     @Override
@@ -381,16 +380,16 @@
     @Override
     public List<TenVo> pump() {
         List<TenVo> list = new ArrayList<>();
-        QueryWrapper<PumpStatus> queryWrapper = new QueryWrapper<>();
+        QueryWrapper<ArdPumpStatus> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("alarm_type","杩愯");
-        int y = pumpStatusMapper.selectCount(queryWrapper);
+        int y = ardPumpStatusMapper.selectCount(queryWrapper);
         TenVo tenVo = new TenVo();
         tenVo.setName("杩愯");
         tenVo.setValue(y);
         list.add(tenVo);
-        QueryWrapper<PumpStatus> queryWrapper1 = new QueryWrapper<>();
+        QueryWrapper<ArdPumpStatus> queryWrapper1 = new QueryWrapper<>();
         queryWrapper1.eq("alarm_type","鍋滄満");
-        int t = pumpStatusMapper.selectCount(queryWrapper1);
+        int t = ardPumpStatusMapper.selectCount(queryWrapper1);
         TenVo tenVo1 = new TenVo();
         tenVo1.setName("鍋滄満");
         tenVo1.setValue(t);
@@ -406,22 +405,22 @@
         if(list.size()>0){
             for (int i = 0; i < list.size(); i++) {
                 JSONObject j = list.get(i);
-                QueryWrapper<PumpStatus> queryWrapper = new QueryWrapper<>();
+                QueryWrapper<ArdPumpStatus> queryWrapper = new QueryWrapper<>();
                 queryWrapper.eq("target_id",j.getInteger("targetId")).eq("name",j.getString("name"));
-                PumpStatus pumpStatus1 = pumpStatusMapper.selectOne(queryWrapper);
-                if(pumpStatus1==null){
-                    PumpStatus pumpStatus = new PumpStatus();
-                    pumpStatus.setTargetId(j.getInteger("targetId"));
-                    pumpStatus.setName(j.getString("name"));
+                ArdPumpStatus ardPumpStatus1 = ardPumpStatusMapper.selectOne(queryWrapper);
+                if(ardPumpStatus1 ==null){
+                    ArdPumpStatus ardPumpStatus = new ArdPumpStatus();
+                    ardPumpStatus.setTargetId(j.getInteger("targetId"));
+                    ardPumpStatus.setName(j.getString("name"));
                     if(j.containsKey("alarmType")){
-                        pumpStatus.setAlarmType(j.getString("alarmType"));
+                        ardPumpStatus.setAlarmType(j.getString("alarmType"));
                     }else if(j.containsKey("alarm")){
-                        pumpStatus.setAlarmType(j.getString("alarm"));
+                        ardPumpStatus.setAlarmType(j.getString("alarm"));
                     }
-                    pumpStatus.setAlarmTime(alarmTime);
-                    pumpStatusMapper.insert(pumpStatus);
+                    ardPumpStatus.setAlarmTime(alarmTime);
+                    ardPumpStatusMapper.insert(ardPumpStatus);
                 }else {
-                    String alarmType = pumpStatus1.getAlarmType();
+                    String alarmType = ardPumpStatus1.getAlarmType();
                     Boolean bo = false;
                     if(j.containsKey("alarmType")){
                         if(alarmType.equals(j.getString("alarmType"))){
@@ -433,9 +432,9 @@
                         }
                     }
                     if(!bo){
-                        pumpStatus1.setAlarmType(j.getString("alarmType"));
-                        pumpStatus1.setAlarmTime(alarmTime);
-                        pumpStatusMapper.updateById(pumpStatus1);
+                        ardPumpStatus1.setAlarmType(j.getString("alarmType"));
+                        ardPumpStatus1.setAlarmTime(alarmTime);
+                        ardPumpStatusMapper.updateById(ardPumpStatus1);
                     }
                 }
             }

--
Gitblit v1.9.3