改进缓存机制：将上传和下载缓存分离到隐藏目录

myscripts/working_tool.py

@@ -6,8 +6,15 @@ import requests
 import tempfile
 import json
 
-# 存储上次上传的信息
+# 缓存目录和文件配置
-LAST_UPLOAD_FILE = '.last_upload.json'
+CACHE_DIR = '.working_cache'
+UPLOAD_CACHE_FILE = os.path.join(CACHE_DIR, 'upload.json')
+DOWNLOAD_CACHE_FILE = os.path.join(CACHE_DIR, 'download.json')
+
+# 确保缓存目录存在
+def ensure_cache_dir():
+    """确保缓存目录存在"""
+    os.makedirs(CACHE_DIR, exist_ok=True)
 
 
 def get_file_hash(file_path):
@@ -19,14 +26,19 @@ def get_file_hash(file_path):
     return hash_md5.hexdigest()
 
 
-def get_working_files():
+def get_working_dir():
-    """从环境变量WORKING_FILES获取要打包的文件列表"""
+    """获取工作目录，处理默认值和路径转换"""
-    working_files_env = os.environ.get('WORKING_FILES', '')
     working_dir = os.environ.get('WORKING_DIR', '.')
-    
     # 确保WORKING_DIR是绝对路径
     if not os.path.isabs(working_dir):
         working_dir = os.path.abspath(working_dir)
+    return working_dir
+
+
+def get_working_files():
+    """从环境变量WORKING_FILES获取要打包的文件列表"""
+    working_files_env = os.environ.get('WORKING_FILES', '')
+    working_dir = get_working_dir()
     
     if not working_files_env:
         return []
@@ -64,8 +76,8 @@ def check_files_modified(working_files):
             current_hashes[file_path] = get_file_hash(file_path)
     
     # 读取上次的哈希值
-    if os.path.exists(LAST_UPLOAD_FILE):
+    if os.path.exists(UPLOAD_CACHE_FILE):
-        with open(LAST_UPLOAD_FILE, 'r') as f:
+        with open(UPLOAD_CACHE_FILE, 'r') as f:
             last_data = json.load(f)
         
         # 比较哈希值
@@ -124,9 +136,9 @@ def download_and_extract(download_url, extract_dir='.', password=None):
         os.makedirs(extract_dir, exist_ok=True)
         
         # 检查是否与最后一次下载的URL相同
-        last_upload_file = LAST_UPLOAD_FILE
+        ensure_cache_dir()
-        if os.path.exists(last_upload_file):
+        if os.path.exists(DOWNLOAD_CACHE_FILE):
-            with open(last_upload_file, 'r') as f:
+            with open(DOWNLOAD_CACHE_FILE, 'r') as f:
                 last_data = json.load(f)
             
             if last_data.get('download_url') == download_url:
@@ -191,6 +203,11 @@ def download_and_extract(download_url, extract_dir='.', password=None):
         with open(download_info_file, 'w') as f:
             json.dump(download_info, f, indent=2)
         
+        # 保存下载信息到全局缓存
+        ensure_cache_dir()
+        with open(DOWNLOAD_CACHE_FILE, 'w') as f:
+            json.dump(download_info, f, indent=2)
+        
         print(f"Download information saved to {download_info_file}")
         return True
     except (requests.exceptions.RequestException, zipfile.BadZipFile, IOError, Exception) as e:
@@ -224,9 +241,7 @@ def upload_working_files(password=None):
     
     try:
         # 获取WORKING_DIR
-        working_dir = os.environ.get('WORKING_DIR', '.')
+        working_dir = get_working_dir()
-        if not os.path.isabs(working_dir):
-            working_dir = os.path.abspath(working_dir)
         
         # 打包文件
         with zipfile.ZipFile(zip_path, 'w', zipfile.ZIP_DEFLATED) as zipf:
@@ -237,22 +252,31 @@ def upload_working_files(password=None):
         
         # 如果提供了密码，创建加密ZIP文件
         if password:
-            # 直接创建加密ZIP文件，替换原有的非加密文件
+            # 删除原有的非加密文件
             os.unlink(zip_path)
             
             # 获取WORKING_DIR
-            working_dir = os.environ.get('WORKING_DIR', '.')
+            working_dir = get_working_dir()
-            if not os.path.isabs(working_dir):
-                working_dir = os.path.abspath(working_dir)
             
-            # 使用内置的zipfile模块创建加密ZIP
+            # 尝试使用7zip创建加密ZIP文件
-            with zipfile.ZipFile(zip_path, 'w', zipfile.ZIP_DEFLATED, compresslevel=9) as zipf:
+            try:
+                import subprocess
+                
+                # 构建7zip命令 - 注意：7zip参数之间没有空格
+                cmd = ['7z', 'a', '-tzip', '-p' + password, '-mx9', zip_path]
+                
+                # 添加所有文件到命令中
                 for file_path in working_files:
                     # 计算相对路径，保持目录结构
                     arcname = os.path.relpath(file_path, working_dir)
-                    zipf.write(file_path, arcname)
+                    # 7zip需要相对路径，从working_dir开始
-                # 设置密码用于解密
+                    cmd.append(os.path.relpath(file_path, working_dir))
-                zipf.setpassword(password.encode())
+                
+                # 切换到working_dir执行命令，确保相对路径正确
+                subprocess.run(cmd, check=True, capture_output=True, cwd=working_dir)
+            except (subprocess.CalledProcessError, FileNotFoundError):
+                # 如果7zip不可用，抛出错误
+                raise Exception("Failed to create encrypted ZIP file: 7zip is not available or failed to execute")
         
         # 上传到tmpfile
         download_url = upload_to_tmpfile(zip_path)
@@ -264,7 +288,8 @@ def upload_working_files(password=None):
                 current_hashes[file_path] = get_file_hash(file_path)
         
         # 保存本次上传信息
-        with open(LAST_UPLOAD_FILE, 'w') as f:
+        ensure_cache_dir()
+        with open(UPLOAD_CACHE_FILE, 'w') as f:
             json.dump({
                 'hashes': current_hashes,
                 'download_url': download_url,