From 243e226df477748581a3315e7c27d673f7c4f0da Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=83=AD=E6=89=BF?= <guocheng@xinyingpower.com>
Date: Thu, 13 Mar 2025 13:12:32 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E6=94=B9=E4=B8=80=E9=94=AE?=
 =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=A4=84=E7=90=86=E7=8A=B6=E6=80=81=E7=9A=84?=
 =?UTF-8?q?=E5=A4=84=E7=90=86=E6=96=B9=E5=BC=8F=E5=B9=B6=E4=B8=8D=E8=83=BD?=
 =?UTF-8?q?=E9=87=8D=E5=A4=8D=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cac/controller/WarningController.java     | 21 ++++++++++++++-----
 .../com/xydl/cac/service/DataService.java     |  2 ++
 .../cac/service/impl/DataServiceImpl.java     |  6 ++++++
 3 files changed, 24 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/xydl/cac/controller/WarningController.java b/src/main/java/com/xydl/cac/controller/WarningController.java
index a823667..d56afb6 100644
--- a/src/main/java/com/xydl/cac/controller/WarningController.java
+++ b/src/main/java/com/xydl/cac/controller/WarningController.java
@@ -5,6 +5,7 @@ import com.xydl.cac.entity.Warning;
 import com.xydl.cac.exception.BusinessException;
 import com.xydl.cac.model.ConditionModel;
 import com.xydl.cac.model.Response;
+import com.xydl.cac.service.DataService;
 import com.xydl.cac.service.ReportService;
 import com.xydl.cac.service.WarningService;
 import io.swagger.annotations.Api;
@@ -28,6 +29,9 @@ public class WarningController extends BasicController {
     @Resource
     WarningService service;
 
+    @Resource
+    DataService dataService;
+
     @GetMapping("list")
     @ApiOperation("查询列表")
     public Response<Page<Warning>> list(@Validated ConditionModel condition) throws Exception {
@@ -65,13 +69,20 @@ public class WarningController extends BasicController {
 
     }
 
+    Boolean isFlat = false;
+
     @PostMapping("oneKeyUpdateState")
     @ApiOperation("一键修改处理状态")
     public Response<String> oneKeyUpdateState() throws Exception {
-        ConditionModel condition = new ConditionModel();
-        condition.setState("1");
-        List<Warning> warnings = service.listAll(condition);
-        service.oneKeyUpdateState(warnings);
-        return Response.success("OK");
+        try {
+            if (isFlat) {
+                throw new BusinessException("相同请求正在处理中, 请勿重复处理");
+            }
+            isFlat = true;
+            dataService.updateWarningState("warning" , "0" , "1");
+            return Response.success("OK");
+        } finally {
+            isFlat = false;
+        }
     }
 }
diff --git a/src/main/java/com/xydl/cac/service/DataService.java b/src/main/java/com/xydl/cac/service/DataService.java
index 0965e83..c9b1e05 100644
--- a/src/main/java/com/xydl/cac/service/DataService.java
+++ b/src/main/java/com/xydl/cac/service/DataService.java
@@ -23,4 +23,6 @@ public interface DataService {
     Map<String, Object> getLastOneData(String tableName, Integer devId, ModevTypePoint point) throws Exception;
 
     void insertData(String tableName, Integer devId, String time, String colname, String value);
+
+    void updateWarningState(String tableName, String frontState , String afterState);
 }
diff --git a/src/main/java/com/xydl/cac/service/impl/DataServiceImpl.java b/src/main/java/com/xydl/cac/service/impl/DataServiceImpl.java
index 7a24e89..95ebe5b 100644
--- a/src/main/java/com/xydl/cac/service/impl/DataServiceImpl.java
+++ b/src/main/java/com/xydl/cac/service/impl/DataServiceImpl.java
@@ -322,4 +322,10 @@ public class DataServiceImpl implements DataService {
         }
     }
 
+    @Override
+    public void updateWarningState(String tableName, String frontState, String afterState) {
+        String sql = "UPDATE " + tableName + " set state = " + frontState + " where state = " + afterState;
+        jdbcTemplate.execute(sql);
+    }
+
 }