Update app.py

app.py

@@ -5,8 +5,6 @@ from flask import Flask, request, jsonify
 from datetime import datetime, timedelta
 import asyncio
 import re
-import subprocess
-import time
 
 app = Flask(__name__)
 
@@ -15,12 +13,8 @@ AI_API_ENDPOINT = os.environ.get('AI_API_ENDPOINT')
 AI_API_KEY = os.environ.get('AI_API_KEY')
 AI_MODEL = os.environ.get('AI_MODEL')
 PHP_PROXY_URL = os.environ.get('PHP_PROXY_URL')
-WEBDAV_URL = os.environ.get('WEBDAV_URL')
-WEBDAV_USERNAME = os.environ.get('WEBDAV_USERNAME')
-WEBDAV_PASSWORD = os.environ.get('WEBDAV_PASSWORD')
-WEBDAV_BASE_DIR = os.environ.get('WEBDAV_BASE_DIR', 'tg_bot')
 
-if not all([TELEGRAM_BOT_TOKEN, AI_API_ENDPOINT, AI_API_KEY, AI_MODEL, WEBDAV_URL, WEBDAV_USERNAME, WEBDAV_PASSWORD]):
+if not all([TELEGRAM_BOT_TOKEN, AI_API_ENDPOINT, AI_API_KEY, AI_MODEL]):
     raise ValueError("请设置所有必要的环境变量")
 
 AI_API_HEADERS = {
@@ -478,100 +472,5 @@ async def unbanUser(chatId, userId):
         await sendTelegramMessage(chatId, f"用户 {userId} 已被解禁。")
         print(f"用户 {userId} 在群组 {chatId} 中被解禁。")
 
-def backup_data():
-    global chatHistories, GROUP_SETTINGS, USER_SETTINGS, USER_LAST_ACTIVE, GROUP_ACTIVE_USERS, GROUP_INFO, BANNED_USERS
-    data = {
-        'chatHistories': chatHistories,
-        'GROUP_SETTINGS': GROUP_SETTINGS,
-        'USER_SETTINGS': USER_SETTINGS,
-        'USER_LAST_ACTIVE': USER_LAST_ACTIVE,
-        'GROUP_ACTIVE_USERS': GROUP_ACTIVE_USERS,
-        'GROUP_INFO': GROUP_INFO,
-        'BANNED_USERS': BANNED_USERS,
-    }
-    timestamp = datetime.now().strftime("%Y%m%d%H%M%S")
-    filename = f"backup_{timestamp}.json"
-    filepath = os.path.join(WEBDAV_BASE_DIR, filename)
-    
-    try:
-        json_data = json.dumps(data)
-        curl_command = [
-            "curl",
-            "-v",
-            "-X", "PUT",
-            "-u", f"{WEBDAV_USERNAME}:{WEBDAV_PASSWORD}",
-            "--data-binary", f"@{'-'}",
-            f"{WEBDAV_URL}/{filepath}"
-        ]
-        process = subprocess.Popen(curl_command, stdin=subprocess.PIPE, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-        stdout, stderr = process.communicate(input=json_data.encode('utf-8'))
-        if process.returncode != 0:
-            print(f"备份失败: {stderr.decode('utf-8')}")
-        else:
-            print(f"备份成功: {filename} 已上传")
-    except Exception as e:
-        print(f"备份过程中发生错误: {e}")
-
-def restore_data():
-    global chatHistories, GROUP_SETTINGS, USER_SETTINGS, USER_LAST_ACTIVE, GROUP_ACTIVE_USERS, GROUP_INFO, BANNED_USERS
-    
-    try:
-        curl_command = [
-            "curl",
-            "-v",
-            "-u", f"{WEBDAV_USERNAME}:{WEBDAV_PASSWORD}",
-            f"{WEBDAV_URL}/{WEBDAV_BASE_DIR}/"
-        ]
-        process = subprocess.Popen(curl_command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-        stdout, stderr = process.communicate()
-        if process.returncode != 0:
-            print(f"获取文件列表失败: {stderr.decode('utf-8')}")
-            return
-
-        files = re.findall(r'href="([^"]*\.json)"', stdout.decode('utf-8'))
-        if not files:
-            print("没有找到备份文件")
-            return
-        files.sort(reverse=True)
-        latest_file = files[0]
-        
-        curl_command = [
-            "curl",
-            "-v",
-            "-u", f"{WEBDAV_USERNAME}:{WEBDAV_PASSWORD}",
-            f"{WEBDAV_URL}/{WEBDAV_BASE_DIR}/{latest_file}"
-        ]
-        process = subprocess.Popen(curl_command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-        stdout, stderr = process.communicate()
-        if process.returncode != 0:
-            print(f"下载最新备份失败: {stderr.decode('utf-8')}")
-            return
-
-        try:
-            data = json.loads(stdout.decode('utf-8'))
-            chatHistories = data.get('chatHistories', {})
-            GROUP_SETTINGS = data.get('GROUP_SETTINGS', {})
-            USER_SETTINGS = data.get('USER_SETTINGS', {})
-            USER_LAST_ACTIVE = data.get('USER_LAST_ACTIVE', {})
-            GROUP_ACTIVE_USERS = data.get('GROUP_ACTIVE_USERS', {})
-            GROUP_INFO = data.get('GROUP_INFO', {})
-            BANNED_USERS = data.get('BANNED_USERS', {})
-            print(f"数据已从 {latest_file} 恢复")
-        except json.JSONDecodeError as e:
-            print(f"JSON解析失败: {e}")
-    except Exception as e:
-        print(f"恢复数据时发生错误: {e}")
-
 if __name__ == '__main__':
-    restore_data()
-    
-    def schedule_backup():
-        while True:
-            backup_data()
-            time.sleep(60)
-    
-    import threading
-    backup_thread = threading.Thread(target=schedule_backup, daemon=True)
-    backup_thread.start()
-    
-    app.run(host='0.0.0.0', port=int(os.environ.get('PORT', 7860)))
+    app.run(host='0.0.0.0', port=int(os.environ.get('PORT', 7860)))