From fb766b5ff9f913561f76aa747c76eae5c3678589 Mon Sep 17 00:00:00 2001
From: qirong <2032486488@qq.com>
Date: 星期五, 08 十二月 2023 14:08:54 +0800
Subject: [PATCH] 三方同步
---
ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/runner/SystemApplicationRunner.java | 24 ++++++++++++------------
1 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/runner/SystemApplicationRunner.java b/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/runner/SystemApplicationRunner.java
index cbb70db..d5ee534 100644
--- a/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/runner/SystemApplicationRunner.java
+++ b/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/runner/SystemApplicationRunner.java
@@ -52,18 +52,18 @@
log.info("鍒濆鍖朞SS閰嶇疆鎴愬姛");
log.info("閫氶亾: {} 鐩戝惉涓�......", "OSS");
// 椤圭洰鍒濆鍖栬缃竴娆″嵆鍙�
-// QueueUtils.subscribeBlockingQueue("OSS", (String ossId) -> {
-// // 瑙傚療鎺ユ敹鏃堕棿
-// log.info("閫氶亾: {}, 鏀跺埌鏁版嵁: {}", "OSS", ossId);
-// SysOssVo vo = ossMapper.selectVoById(ossId);
-// client.delete( vo.getUrl());
-// ossMapper.deleteById(Long.valueOf(ossId));
-// try {
-// HttpUtils.sendDeleteRequest(boundary.getVideo() + "/resource/synchronization/delete",ossId);
-// } catch (IOException e) {
-// throw new RuntimeException(e);
-// }
-// });
+ QueueUtils.subscribeBlockingQueue("OSS", (String ossId) -> {
+ // 瑙傚療鎺ユ敹鏃堕棿
+ log.info("閫氶亾: {}, 鏀跺埌鏁版嵁: {}", "OSS", ossId);
+ SysOssVo vo = ossMapper.selectVoById(ossId);
+ client.delete( vo.getUrl());
+ ossMapper.deleteById(Long.valueOf(ossId));
+ try {
+ HttpUtils.sendDeleteRequest(boundary.getVideo() + "/resource/synchronization/delete",ossId);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+ });
}
}
--
Gitblit v1.8.0