| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | @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) { |
|---|
| | | baseMapper.deleteById(ossId); |
|---|
| | | HttpUtils.sendDeleteRequest(boundary.getVideo() + "/resource/synchronization/delete", |
|---|
| | | String.valueOf(vo.getOssId())); |
|---|
| | | String.valueOf(ossId)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
