更新task_worker

task_worker.py

+import asyncio
+import json
+import os
 from urllib.parse import urlencode
 from urllib.parse import urlencode
 
 
 import execjs
 import execjs
 from celery import shared_task
 from celery import shared_task
 
 
-from errors import *
-from hub_ import *
+from errors import AppError
+from hub_ import closeBrowser
 from login import login
 from login import login
 from main import syncShop, syncShopInfo, createTemplate
 from main import syncShop, syncShopInfo, createTemplate
 from upload_video import upload_video
 from upload_video import upload_video
+from loguru import logger
 
 
+# 创建 logs 目录（如果不存在）
+os.makedirs("logs", exist_ok=True)
+
+# 添加日志文件输出，按7天滚动
+logger.add("logs/api.log", rotation="7 day", level="INFO", encoding="utf-8", backtrace=True, diagnose=True)
 
 
 @shared_task(name='sync_shop')
 @shared_task(name='sync_shop')
 def execute_sync_shop(container_name: str):
 def execute_sync_shop(container_name: str):