新增 手动处理水质报警-新的逻辑 并且需要传入起止时间 接口

slibra-admin/src/main/java/com/slibra/web/controller/business/HandleDataController.java

@@ -2210,5 +2210,29 @@ public class HandleDataController extends BaseController
         }else
             xinyiForecastComparisonService.insertTXinyiForecastComparison(tXinyiForecastComparison);
     }
+
+
+    //2025年05月08日10:02:48  下面是新的手动操作数据的接口
+
+    /**
+     *手动处理水质报警-新的逻辑 并且需要传入起止时间
+     */
+    @GetMapping("/waterWarningNewByDate")
+    public String waterWarningNewByDate(@RequestParam String dateBegin, @RequestParam String dateEnd){
+        log.info("进入了 手动处理水质报警-新的逻辑 并且需要传入起止时间 操作");
+        //获取配置表
+        List<TXinyiNormConfig> tXinyiNormConfigs = this.xinyiNormConfigMapper.selectTXinyiNormConfigList(null);
+        if(CollectionUtils.isEmpty(tXinyiNormConfigs))
+            throw new RuntimeException("未查询到配置信息");
+        TXinyiNormConfig normConfig = tXinyiNormConfigs.get(0);
+        //查询最近N天的数据，遍历，处理报警信息
+        List<TXinyiIndustry> tXinyiIndustries = this.xinyiIndustryMapper.selectTXinyiIndustryList(TXinyiIndustry.builder().timeBegin(dateBegin).timeEnd(dateEnd).build());
+        if(!CollectionUtils.isEmpty(tXinyiIndustries)){
+            for (TXinyiIndustry tXinyiIndustry : tXinyiIndustries) {
+                asyncTask.handleSZWarningNew(tXinyiIndustry, normConfig);
+            }
+        }
+        return "success";
+    }
 }