add:新增定时清理设备故障表任务
This commit is contained in:
@@ -0,0 +1,36 @@
|
|||||||
|
package org.nl.acs.autotask;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @Author : TuQiang
|
||||||
|
* @create 2024/5/27 9:45
|
||||||
|
*/
|
||||||
|
|
||||||
|
import lombok.RequiredArgsConstructor;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.nl.acs.AcsConfig;
|
||||||
|
import org.nl.modules.system.service.ParamService;
|
||||||
|
import org.nl.modules.wql.core.bean.WQLObject;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 自动清除日志(设备故障)数据
|
||||||
|
*/
|
||||||
|
@Slf4j
|
||||||
|
@Component
|
||||||
|
@RequiredArgsConstructor
|
||||||
|
public class CleanDeviceErrorLog {
|
||||||
|
|
||||||
|
private final ParamService paramService;
|
||||||
|
|
||||||
|
public void run() {
|
||||||
|
//delete from acs_log where DATE(create_time) <= DATE(DATE_SUB(NOW(),INTERVAL 30 day)) limit 10;
|
||||||
|
log.info("开始打印日志");
|
||||||
|
int days = Integer.parseInt(paramService.findByCode(AcsConfig.AutoCleanDays).getValue());
|
||||||
|
WQLObject logTab = WQLObject.getWQLObject("acs_device_error_log");
|
||||||
|
logTab.delete("DATE(error_time) <= DATE(DATE_SUB(NOW(),INTERVAL " + days + " day))");
|
||||||
|
log.info("自动清理日志执行成功...!");
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user