数据清理任务Job优化

neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/dal/DataCleanMapper.java

@@ -26,6 +26,8 @@ import fun.asgc.neutrino.core.aop.Intercept;
 import fun.asgc.neutrino.core.db.annotation.Delete;
 import fun.asgc.neutrino.core.db.mapper.SqlMapper;
 
+import java.util.Date;
+
 /**
  * @author: aoshiguchen
  * @date: 2022/9/17
@@ -35,21 +37,21 @@ import fun.asgc.neutrino.core.db.mapper.SqlMapper;
 public interface DataCleanMapper extends SqlMapper {
 
     @Delete("delete from `job_log` where create_time < ?")
-    void cleanJobLog(long date);
+    void cleanJobLog(Date date);
 
     @Delete("delete from `user_login_record` where create_time < ?")
-    void cleanUserLoginRecord(long date);
+    void cleanUserLoginRecord(Date date);
 
     @Delete("delete from `client_connect_record` where create_time < ?")
-    void cleanClientConnectRecord(long date);
+    void cleanClientConnectRecord(Date date);
 
     @Delete("delete from `flow_report_minute` where create_time < ?")
-    void cleanFlowMinuteReport(long date);
+    void cleanFlowMinuteReport(Date date);
 
     @Delete("delete from `flow_report_hour` where create_time < ?")
-    void cleanFlowHourReport(long date);
+    void cleanFlowHourReport(Date date);
 
     @Delete("delete from `flow_report_day` where create_time < ?")
-    void cleanFlowDayReport(long date);
+    void cleanFlowDayReport(Date date);
 
 }

neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/job/DataCleanJob.java

@@ -84,37 +84,37 @@ public class DataCleanJob implements IJobHandler {
         {
             Date date = DateUtil.addDate(new Date(), Calendar.DATE, -1 * jobParams.getJobLogKeepDays());
             log.info("清理调度管理日志 date:{}", sdf.format(date));
-            dataCleanMapper.cleanJobLog(date.getTime());
+            dataCleanMapper.cleanJobLog(date);
         }
 
         {
             Date date = DateUtil.addDate(new Date(), Calendar.DATE, -1 * jobParams.getUserLoginRecordKeepDays());
             log.info("清理用户登录日志 date:{}", sdf.format(date));
-            dataCleanMapper.cleanUserLoginRecord(date.getTime());
+            dataCleanMapper.cleanUserLoginRecord(date);
         }
 
         {
             Date date = DateUtil.addDate(new Date(), Calendar.DATE, -1 * jobParams.getClientConnectRecordKeepDays());
             log.info("清理客户端连接日志 date:{}", sdf.format(date));
-            dataCleanMapper.cleanClientConnectRecord(date.getTime());
+            dataCleanMapper.cleanClientConnectRecord(date);
         }
 
         {
             Date date = DateUtil.addDate(new Date(), Calendar.DATE, -1 * jobParams.getFlowMinuteReportKeepDays());
             log.info("清理流通统计分钟报表日志 date:{}", sdf.format(date));
-            dataCleanMapper.cleanFlowMinuteReport(date.getTime());
+            dataCleanMapper.cleanFlowMinuteReport(date);
         }
 
         {
             Date date = DateUtil.addDate(new Date(), Calendar.DATE, -1 * jobParams.getFlowHourReportKeepDays());
             log.info("清理流通统计小时报表日志 date:{}", sdf.format(date));
-            dataCleanMapper.cleanFlowHourReport(date.getTime());
+            dataCleanMapper.cleanFlowHourReport(date);
         }
 
         {
             Date date = DateUtil.addDate(new Date(), Calendar.DATE, -1 * jobParams.getFlowDayReportKeepDays());
             log.info("清理流通统计日报表日志 date:{}", sdf.format(date));
-            dataCleanMapper.cleanFlowDayReport(date.getTime());
+            dataCleanMapper.cleanFlowDayReport(date);
         }
     }