diff --git a/services/kdocs_uploader.py b/services/kdocs_uploader.py index 8789feb..e73c08a 100644 --- a/services/kdocs_uploader.py +++ b/services/kdocs_uploader.py @@ -90,6 +90,15 @@ class KDocsUploader: "image_path": image_path, } try: + # 入队前设置状态为等待上传 + try: + account = safe_get_account(user_id, account_id) + if account and self._should_mark_upload(account): + account.status = "等待上传" + self._emit_account_update(user_id, account) + except Exception: + pass + self._queue.put({"action": "upload", "payload": payload}, timeout=1) return True except queue.Full: