| | |
| | | } |
| | | |
| | | |
| | | @Scheduled(cron = "0 */10 * * * ?") |
| | | // @Scheduled(cron = "0 */10 * * * ?") |
| | | public void remove() throws IOException { |
| | | System.out.println("同步删除......"); |
| | | List<SysOssVo> list = baseMapper.selectVoList(new LambdaQueryWrapper<SysOss>() |
| | | .le(SysOss::getCreateTime, LocalDateTime.now().minusDays(1))); |
| | | List<Long> ids = baseMapper.getWillDeleted(LocalDateTime.now().minusDays(1)); |
| | | |
| | | if (list.size() == 0) { |
| | | if (ids.size() == 0) { |
| | | return; |
| | | } |
| | | for (SysOssVo vo : list) { |
| | | baseMapper.deleteById(vo.getOssId()); |
| | | for (Long ossId : ids) { |
| | | HttpUtils.sendDeleteRequest(boundary.getVideo() + "/resource/synchronization/delete", |
| | | String.valueOf(vo.getOssId())); |
| | | 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); |
| | | } |
| | | } |