Update app.py

app.py

@@ -525,46 +525,47 @@ async def unbanUser(chatId, userId):
         await sendTelegramMessage(chatId, f"用户 {userId} 已被解禁。")
         print(f"用户 {userId} 在群组 {chatId} 中被解禁。")
 
-async def unbanUser(chatId, userId):
-    if userId in BANNED_USERS:
-        del BANNED_USERS[userId]
-        await sendTelegramMessage(chatId, f"用户 {userId} 已被解禁。")
-        print(f"用户 {userId} 在群组 {chatId} 中被解禁。")
-
 def webdav_upload(filename, data):
     url = urljoin(WEBDAV_URL, f"{WEBDAV_DIR}{filename}")
     
+    # 使用 curl 上传
+    curl_command = [
+        'curl',
+        '-k',  # 忽略证书验证
+        '-u', f'{WEBDAV_USERNAME}:{WEBDAV_PASSWORD}',
+        '-X', 'PUT',
+        '-H', 'Content-Type: application/json',
+        '--data', json.dumps(data, default=str),
+        url
+    ]
+    
     try:
-        #尝试创建目录
-        dir_url = urljoin(WEBDAV_URL, f"{WEBDAV_DIR}")
-        subprocess.run(['curl', '-X', 'MKCOL', '-u', f'{WEBDAV_USERNAME}:{WEBDAV_PASSWORD}', dir_url], check=True, capture_output=True)
-        print(f"WebDAV 目录创建成功: {WEBDAV_DIR}")
-    except subprocess.CalledProcessError as e:
-        if b'405' in e.stderr:
-            print(f"WebDAV 目录已存在: {WEBDAV_DIR}")
-        else:
-            print(f"WebDAV 目录创建失败: {WEBDAV_DIR}, {e.stderr.decode()}")
-            return
-
-    try:
-        # 上传文件
-        json_data = json.dumps(data, default=str)
-        process = subprocess.run(['curl', '-X', 'PUT', '-u', f'{WEBDAV_USERNAME}:{WEBDAV_PASSWORD}', '-H', 'Content-Type: application/json', '--data', json_data, url], check=True, capture_output=True)
-        print(f"WebDAV 上传成功: {filename}")
+        result = subprocess.run(curl_command, capture_output=True, text=True, check=True)
+        print(f"WebDAV 上传成功: {filename}, {result.stdout.strip()}")
     except subprocess.CalledProcessError as e:
-        print(f"WebDAV 上传失败: {filename}, {e.stderr.decode()}")
+        print(f"WebDAV 上传失败: {filename}, {e.stderr.strip()}")
 
 def webdav_download(filename):
     url = urljoin(WEBDAV_URL, f"{WEBDAV_DIR}{filename}")
+    
+    # 使用 curl 下载
+    curl_command = [
+        'curl',
+        '-k',  # 忽略证书验证
+        '-u', f'{WEBDAV_USERNAME}:{WEBDAV_PASSWORD}',
+        '-H', 'Accept: application/json',
+        url
+    ]
+    
     try:
-        process = subprocess.run(['curl', '-u', f'{WEBDAV_USERNAME}:{WEBDAV_PASSWORD}', '-H', 'Accept: application/json', url], capture_output=True, check=True)
+        result = subprocess.run(curl_command, capture_output=True, text=True, check=True)
         print(f"WebDAV 下载成功: {filename}")
-        if process.stdout:
-            return json.loads(process.stdout.decode())
-        else:
-             return None
+        return json.loads(result.stdout)
     except subprocess.CalledProcessError as e:
-        print(f"WebDAV 下载失败: {filename}, {e.stderr.decode()}")
+        print(f"WebDAV 下载失败: {filename}, {e.stderr.strip()}")
+        return None
+    except json.JSONDecodeError as e:
+        print(f"WebDAV JSON 解析失败: {filename}, {e}")
         return None
 
 def sync_data_to_webdav():