From 2cd8f35436fd324431f1ae78196f8140ecb3d8b0 Mon Sep 17 00:00:00 2001
From: zhanghua <314079846@qq.com>
Date: 星期四, 14 十一月 2024 11:25:11 +0800
Subject: [PATCH] Merge branch '视频专网' of http://42.193.1.25:9521/r/~qirong/qyspzw into 视频专网

---
 ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/sync/deleteSync.java |   25 +++++++++++++++++++------
 1 files changed, 19 insertions(+), 6 deletions(-)

diff --git a/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/sync/deleteSync.java b/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/sync/deleteSync.java
index 7a3a047..98334b1 100644
--- a/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/sync/deleteSync.java
+++ b/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/sync/deleteSync.java
@@ -28,16 +28,29 @@
     @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);
+    }
 }

--
Gitblit v1.8.0