| | |
| | | return; |
| | | } |
| | | for (Long ossId : ids) { |
| | | baseMapper.deleteById(ossId); |
| | | HttpUtils.sendDeleteRequest(boundary.getVideo() + "/resource/synchronization/delete", |
| | | String.valueOf(ossId)); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 每小时删除30天之前的文件信息,确保上面的定时任务不会因为停电关机等原因导致文件未被删除 |
| | | * |
| | | * @throws IOException |
| | | */ |
| | | @Scheduled(cron = "0 0 * * * ?") |
| | | public void removeOssTable() throws IOException { |
| | | System.out.println("每小时定时删除超过30天的数据库文件信息......"); |
| | | List<Long> ids = baseMapper.getWillDeleted(LocalDateTime.now().minusDays(30)); |
| | | if (ids.size() == 0) { |
| | | return; |
| | | } |
| | | baseMapper.deleteBatchIds(ids); |
| | | } |
| | | } |