|
@@ -29,10 +29,21 @@ public class TaskTraceCleanTask extends AbstractTask {
|
|
|
|
|
|
@Override
|
|
|
public void run(ScheduleJob scheduleJob) throws Exception {
|
|
|
- // 清理过去7天前的数据
|
|
|
+ int amount = 2;
|
|
|
+ try {
|
|
|
+ amount = Integer.parseInt(scheduleJob.getExt1());
|
|
|
+ } catch (Exception e) {
|
|
|
+ // ignore
|
|
|
+ }
|
|
|
+
|
|
|
+ if (1 > amount || amount > 10) {
|
|
|
+ amount = 2;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 清理过去amount天前的数据
|
|
|
Calendar c = Calendar.getInstance();
|
|
|
c.setTime(new Date());
|
|
|
- c.add(Calendar.DATE, -7);
|
|
|
+ c.add(Calendar.DATE, 0 - amount);
|
|
|
Date d = c.getTime();
|
|
|
taskTraceRepo.deleteByCreationTimeLessThan(d);
|
|
|
}
|