Prechádzať zdrojové kódy

添加定时清理预警记录任务

zhaoxian 4 rokov pred
rodič
commit
b34f367052

+ 1 - 0
module-alarm/src/main/java/cn/com/ctop/alarm/modules/mapper/AlarmRuleRecordMapper.java

@@ -12,4 +12,5 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  */
 public interface AlarmRuleRecordMapper extends BaseMapper<AlarmRuleRecord> {
 
+    void deleteByTime();
 }

+ 6 - 0
module-alarm/src/main/java/cn/com/ctop/alarm/modules/mapper/xml/AlarmRuleRecordMapper.xml

@@ -2,4 +2,10 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="cn.com.ctop.alarm.modules.mapper.AlarmRuleRecordMapper">
 
+    <delete id="deleteByTime">
+        delete
+        from ctop_alarm_rule_record
+        where create_time &lt;= DATE_SUB(NOW(), INTERVAL 10 DAY)
+    </delete>
+
 </mapper>

+ 8 - 0
module-alarm/src/main/java/cn/com/ctop/alarm/modules/mapper/xml/AlarmRuleRecordServiceImpl.java

@@ -4,6 +4,7 @@ import cn.com.ctop.alarm.modules.entity.AlarmRuleRecord;
 import cn.com.ctop.alarm.modules.mapper.AlarmRuleRecordMapper;
 import cn.com.ctop.alarm.modules.service.IAlarmRuleRecordService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 /**
@@ -16,4 +17,11 @@ import org.springframework.stereotype.Service;
 @Service
 public class AlarmRuleRecordServiceImpl extends ServiceImpl<AlarmRuleRecordMapper, AlarmRuleRecord> implements IAlarmRuleRecordService {
 
+    @Autowired
+    private AlarmRuleRecordMapper alarmRuleRecordMapper;
+
+    @Override
+    public void deleteByTime() {
+        alarmRuleRecordMapper.deleteByTime();
+    }
 }

+ 1 - 0
module-alarm/src/main/java/cn/com/ctop/alarm/modules/service/IAlarmRuleRecordService.java

@@ -11,4 +11,5 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface IAlarmRuleRecordService extends IService<AlarmRuleRecord> {
 
+    void deleteByTime();
 }

+ 21 - 0
module-job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/handler/KuaishouAlarmRuleRecordJob.java

@@ -0,0 +1,21 @@
+package cn.com.ctop.job.kuaishou.handler;
+
+import cn.com.ctop.alarm.modules.service.IAlarmRuleRecordService;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import org.quartz.JobExecutionException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class KuaishouAlarmRuleRecordJob {
+    @Autowired
+    private IAlarmRuleRecordService alarmRuleRecordService;
+
+    /**
+     * 预警规则记录表 定期删除,只保留10天数据
+     */
+    @XxlJob("cleanAlarmRuleRecordJob")
+    public void execute() throws Exception {
+        alarmRuleRecordService.deleteByTime();
+    }
+}