Merge pull request #1 from syscc/release/v0.0.2

release: v0.0.2 ensure recursive dst path creation for manual sync

Author: syscc

service/syncJob/jobClient.py

@@ -430,6 +430,19 @@ def listDir(self, path, firstDst, spec, rootPath, isSrc=True):
                           isPath=1)
             raise e
 
+    def ensurePath(self, path):
+        if self.breakFlag:
+            return
+        scanInterval = self.job['scanIntervalT']
+        segs = [s for s in path.split('/') if s]
+        cur = '/'
+        for s in segs:
+            cur = cur + s + '/'
+            try:
+                self.alistClient.fileListApi(cur, 0, scanInterval, None, cur)
+            except Exception:
+                self.alistClient.mkdir(cur, scanInterval)
+
     def syncWithHave(self, srcPath, dstPath, spec, srcRootPath, dstRootPath, firstDst):
         """
         扫描并同步-目标目录存在目录（意味着要继续扫描目标目录）
@@ -445,9 +458,12 @@ def syncWithHave(self, srcPath, dstPath, spec, srcRootPath, dstRootPath, firstDs
             return
         try:
             srcFiles = self.listDir(srcPath, firstDst, spec, srcRootPath)
-            dstFiles = self.listDir(dstPath, firstDst, spec, dstRootPath, False)
+            try:
+                dstFiles = self.listDir(dstPath, firstDst, spec, dstRootPath, False)
+            except Exception:
+                self.syncWithOutHave(srcPath, dstPath, spec, srcRootPath, dstRootPath, firstDst)
+                return
         except Exception:
-            # 已在listDir做出日志打印等操作，此处啥都不用做
             return
         for key in srcFiles.keys():
             # 如果是文件
@@ -486,7 +502,7 @@ def syncWithOutHave(self, srcPath, dstPath, spec, srcRootPath, dstRootPath, firs
         status = 2
         errMsg = None
         try:
-            self.alistClient.mkdir(dstPath, self.job['scanIntervalT'])
+            self.ensurePath(dstPath)
         except Exception as e:
             status = 7
             errMsg = str(e)

version.txt

@@ -1,4 +1,4 @@
-v0.0.1,latest
+v0.0.2,latest
 
 # retrigger build at 2025-12-11 22:45