From 7844d16cf8c17856dee037756d5b9a1da87b3d54 Mon Sep 17 00:00:00 2001 From: yangzhe123 <2824096059@qq.com> Date: Fri, 21 Nov 2025 15:52:34 +0800 Subject: [PATCH] =?UTF-8?q?=E9=A2=84=E8=AD=A6-=E5=AE=9A=E6=97=B6=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/gunshi/project/hsz/service/WarningRuleService.java | 7 ++++++- .../com/gunshi/project/hsz/timetask/WarningRuleTask.java | 4 ++++ 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/gunshi/project/hsz/service/WarningRuleService.java b/src/main/java/com/gunshi/project/hsz/service/WarningRuleService.java index 22c0adf..393d6b9 100644 --- a/src/main/java/com/gunshi/project/hsz/service/WarningRuleService.java +++ b/src/main/java/com/gunshi/project/hsz/service/WarningRuleService.java @@ -2,6 +2,7 @@ package com.gunshi.project.hsz.service; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gunshi.project.hsz.entity.so.WarningRulePageSo; @@ -87,7 +88,11 @@ public class WarningRuleService extends ServiceImpl eq = warningConditionService.lambdaQuery().eq(WarningCondition::getRuleId, dto.getId()); + boolean remove = warningConditionService.remove(eq); + if(remove){ + warningConditionService.updateBatchById(conditions); + } return true; } diff --git a/src/main/java/com/gunshi/project/hsz/timetask/WarningRuleTask.java b/src/main/java/com/gunshi/project/hsz/timetask/WarningRuleTask.java index 008c7e6..6f13bf4 100644 --- a/src/main/java/com/gunshi/project/hsz/timetask/WarningRuleTask.java +++ b/src/main/java/com/gunshi/project/hsz/timetask/WarningRuleTask.java @@ -12,7 +12,9 @@ import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Profile; +import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.EnableScheduling; +import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import java.math.BigDecimal; @@ -64,6 +66,8 @@ public class WarningRuleTask { @Autowired private RainBasinDivisionService rainBasinDivisionService; + @Scheduled(fixedDelay = 60 * 60 * 1000) // 75分钟，单位毫秒 + @Async public void warningRuleExecute(){ //获取配置的预警规则 List warningRules = warningRuleService.listData();