diff --git a/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/dal/DataCleanMapper.java b/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/dal/DataCleanMapper.java index 998ef2d2..70694712 100644 --- a/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/dal/DataCleanMapper.java +++ b/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); } diff --git a/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/job/DataCleanJob.java b/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/job/DataCleanJob.java index 6bcc2b22..44f43a0b 100644 --- a/neutrino-proxy-server/src/main/java/fun/asgc/neutrino/proxy/server/job/DataCleanJob.java +++ b/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); } }