| | |
| | | /** |
| | | * 文件默认保存小时数 |
| | | */ |
| | | private static final int DEFAULT_HOUR = 8; |
| | | private static final int DEFAULT_HOUR = 0; |
| | | // 每5秒执行一次 |
| | | //@Scheduled(fixedRate = 1000000) |
| | | //@Scheduled(cron = "0 1 0 * * ?") // 每天上午0点1分执行 |
| | |
| | | LocalDateTime now = LocalDateTime.now(); |
| | | for (Machine machine : machines) { |
| | | int remainHours = machine.getReceiveDirExpiryHours() != null ?machine.getSendDirExpiryHours():DEFAULT_HOUR; |
| | | if(remainHours == 0){ |
| | | continue; |
| | | } |
| | | LocalDateTime earlyTime = now.minusHours(remainHours); |
| | | List<MachineFile> overTimeFiles = this.machineFileService.lambdaQuery().lt(MachineFile::getFileCreateTime,earlyTime) |
| | | .eq(MachineFile::getDirType,MachineFile.DIR_TYPE_SEND) |