| | |
| | | import com.ycl.platform.domain.entity.MonitorConstruction; |
| | | import com.ycl.platform.domain.entity.Report; |
| | | import com.ycl.platform.domain.result.UY.RecordMetaDSumResult; |
| | | import com.ycl.platform.mapper.DailyMonitorDemeritRecordMapper; |
| | | import com.ycl.platform.mapper.DemeritRecordMapper; |
| | | import com.ycl.platform.mapper.IMonitorConstructionMapper; |
| | | import com.ycl.platform.mapper.ReportMapper; |
| | |
| | | |
| | | private final IMonitorConstructionMapper monitorConstructionMapper; |
| | | |
| | | private final IDailyMonitorDemeritRecordService dailyMonitorDemeritRecordService; |
| | | private final DailyMonitorDemeritRecordMapper dailyMonitorDemeritRecordMapper; |
| | | |
| | | private final DemeritRecordMapper demeritRecordMapper; |
| | | |
| | | |
| | | |
| | | private static final ExecutorService executorService = new ThreadPoolExecutor(16, |
| | | 128, |
| | |
| | | } |
| | | |
| | | //处理完数据插入数据库中 |
| | | //先删除需要插入时间是否存在数据 |
| | | |
| | | LambdaQueryWrapper<DemeritRecord> demeritRecordLambdaQueryWrapper = new LambdaQueryWrapper<>(); |
| | | demeritRecordLambdaQueryWrapper.ge(DemeritRecord::getCreateTime,DateUtils.getDayStart(today)) |
| | | .le(DemeritRecord::getCreateTime,DateUtils.getDayEnd(today)); |
| | | demeritRecordService.remove(demeritRecordLambdaQueryWrapper); |
| | | demeritRecordMapper.deleteByTimeRange(DateUtils.getDayStart(today),DateUtils.getDayEnd(today)); |
| | | // 物理删除 |
| | | |
| | | demeritRecordService.saveBatch(demeritRecords); |
| | | log.info("结束计算每日扣分记录情况:插入数据量{},数据信息:{}",demeritRecords.size(),demeritRecords); |
| | | //填充设备录像情况扣分详情结果 |
| | | LambdaQueryWrapper<DailyMonitorDemeritRecord> dailyMonitorDemeritRecordLambdaQueryWrapper = new LambdaQueryWrapper<>(); |
| | | dailyMonitorDemeritRecordLambdaQueryWrapper.ge(DailyMonitorDemeritRecord::getCreateTime,DateUtils.getDayStart(today)) |
| | | .le(DailyMonitorDemeritRecord::getCreateTime,DateUtils.getDayEnd(today)); |
| | | iDailyMonitorDemeritRecordService.remove(dailyMonitorDemeritRecordLambdaQueryWrapper); |
| | | |
| | | dailyMonitorDemeritRecordMapper.deleteByDailyRecord(DateUtils.getDayStart(today),DateUtils.getDayEnd(today)); |
| | | // 物理删除 |
| | | |
| | | iDailyMonitorDemeritRecordService.saveBatch(dailyMonitorDemeritRecords); |
| | | log.info("结束计算每日扣分记录详情情况:插入数据量{},数据信息:{}",dailyMonitorDemeritRecords.size(),dailyMonitorDemeritRecords); |
| | | |