| | |
|---|
| | | 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); |
|---|
| | | } |
|---|
| | | } |
|---|
