From 64670dc728cf83a047e8773835937b842d5535ed Mon Sep 17 00:00:00 2001
From: cy <1664593601@qq.com>
Date: 星期二, 11 十月 2022 15:03:56 +0800
Subject: [PATCH] fix(schedule): ftp下载前判断文件是否存在

---
 recommend-video/src/main/java/com/iplatform/recvideo/util/SFTPUtil.java |   20 ++++++++++++++++++--
 1 files changed, 18 insertions(+), 2 deletions(-)

diff --git a/recommend-video/src/main/java/com/iplatform/recvideo/util/SFTPUtil.java b/recommend-video/src/main/java/com/iplatform/recvideo/util/SFTPUtil.java
index dd2b5da..88c25b0 100644
--- a/recommend-video/src/main/java/com/iplatform/recvideo/util/SFTPUtil.java
+++ b/recommend-video/src/main/java/com/iplatform/recvideo/util/SFTPUtil.java
@@ -221,10 +221,26 @@
         if (!parentFile.exists()) {
             parentFile.mkdirs();
         }
-        sftp.get(downloadFile, new FileOutputStream(file));
-        log.info("file:{} is download successful", downloadFile);
+        if (isExistSftp(downloadFile)) {
+            sftp.get(downloadFile, new FileOutputStream(file));
+            log.info("file:{} is download successful", downloadFile);
+        } else {
+            log.error("file:{} is not found", downloadFile);
+        }
     }
 
+    // 鍒ゆ柇鏂囦欢鏄惁瀛樺湪
+    public boolean isExistSftp(String filePach) {
+        try {
+            sftp.lstat(filePach);
+        } catch (SftpException e) {
+            log.info("isExistSftp()==> file:{} is not found", filePach);
+            return false;
+        }
+        return true;
+    }
+
+
     /**
      * 涓嬭浇鏂囦欢
      *

--
Gitblit v1.9.1