|
|
@ -130,10 +130,8 @@ public class TMotorvehicleTask {
|
|
|
|
TransitVehicleRecord one = vehicleRecordService.getOne(queryWrapper);
|
|
|
|
TransitVehicleRecord one = vehicleRecordService.getOne(queryWrapper);
|
|
|
|
Date partitionField = one.getPartitionField();
|
|
|
|
Date partitionField = one.getPartitionField();
|
|
|
|
maxTime = dateFormat.format(partitionField);
|
|
|
|
maxTime = dateFormat.format(partitionField);
|
|
|
|
|
|
|
|
|
|
|
|
//将maxTime转换为Date对象
|
|
|
|
//将maxTime转换为Date对象
|
|
|
|
Date maxDate = dateFormat.parse(maxTime);
|
|
|
|
Date maxDate = dateFormat.parse(maxTime);
|
|
|
|
|
|
|
|
|
|
|
|
//计算2天前的日期
|
|
|
|
//计算2天前的日期
|
|
|
|
Calendar calendar = Calendar.getInstance();
|
|
|
|
Calendar calendar = Calendar.getInstance();
|
|
|
|
calendar.setTime(maxDate);
|
|
|
|
calendar.setTime(maxDate);
|
|
|
@ -143,8 +141,7 @@ public class TMotorvehicleTask {
|
|
|
|
//构造删除条件
|
|
|
|
//构造删除条件
|
|
|
|
LambdaQueryWrapper<TransitVehicleRecord> deleteWrapper = Wrappers.lambdaQuery();
|
|
|
|
LambdaQueryWrapper<TransitVehicleRecord> deleteWrapper = Wrappers.lambdaQuery();
|
|
|
|
deleteWrapper.le(TransitVehicleRecord::getPartitionField, twoDaysAgo);
|
|
|
|
deleteWrapper.le(TransitVehicleRecord::getPartitionField, twoDaysAgo);
|
|
|
|
// int countTM = vehicleRecordService.count(deleteWrapper);
|
|
|
|
// int countTM = vehicleRecordervice.count(deleteWrapper);
|
|
|
|
deleteWrapper.last("LIMIT 1000");
|
|
|
|
|
|
|
|
boolean result = vehicleRecordService.remove(deleteWrapper);
|
|
|
|
boolean result = vehicleRecordService.remove(deleteWrapper);
|
|
|
|
|
|
|
|
|
|
|
|
if (result) {
|
|
|
|
if (result) {
|
|
|
|