yangzhe
/
gunshi-project-ss
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

预警-定时任务

master
yangzhe123 2025-11-21 15:52:34 +08:00
parent be92973276
commit 7844d16cf8
2 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/com/gunshi/project/hsz/service/WarningRuleService.java
View File

@ -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<WarningRuleMapper, WarningRu
}
condition.setRuleId(dto.getId());
}
warningConditionService.updateBatchById(conditions);
LambdaQueryChainWrapper<WarningCondition> eq = warningConditionService.lambdaQuery().eq(WarningCondition::getRuleId, dto.getId());
boolean remove = warningConditionService.remove(eq);
if(remove){
warningConditionService.updateBatchById(conditions);
}
return true;
}

4
src/main/java/com/gunshi/project/hsz/timetask/WarningRuleTask.java
View File

@ -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<WarningRule> warningRules = warningRuleService.listData();