diff --git a/services/task_service.py b/services/task_service.py
index 4db5f9b..351de56 100644
--- a/services/task_service.py
+++ b/services/task_service.py
@@ -7,6 +7,7 @@ import time
 import base64
 import threading
 from urllib.parse import quote
+from requests.exceptions import ConnectionError, ConnectTimeout
 from PIL import Image
 
 from extensions import s3_client, redis_client, db
@@ -15,6 +16,36 @@ from config import Config
 from services.logger import system_logger
 from utils import get_proxied_url
 
+
+def _extract_error_detail(data, default="未知错误"):
+    """从API响应中提取详细的错误信息"""
+    if not isinstance(data, dict):
+        return default
+
+    # 按优先级尝试多个常见的错误字段
+    candidates = [
+        data.get('fail_reason'),
+        data.get('error', {}).get('message') if isinstance(data.get('error'), dict) else data.get('error'),
+        data.get('message'),
+        data.get('detail'),
+        data.get('data', {}).get('fail_reason') if isinstance(data.get('data'), dict) else None,
+        data.get('data', {}).get('message') if isinstance(data.get('data'), dict) else None,
+        data.get('data', {}).get('error') if isinstance(data.get('data'), dict) else None,
+    ]
+
+    for c in candidates:
+        if c and isinstance(c, str) and c.strip():
+            return c.strip()
+
+    # 如果所有字段都没有，返回响应摘要帮助排查
+    # 过滤掉大字段，只保留状态类信息
+    summary_keys = {'status', 'code', 'error_code', 'fail_code', 'type'}
+    summary = {k: v for k, v in data.items() if k in summary_keys and v}
+    if summary:
+        return f"{default} ({json.dumps(summary, ensure_ascii=False)})"
+
+    return default
+
 def sync_images_background(app, record_id, raw_urls):
     """后台同步图片至 MinIO，并生成缩略图，带重试机制"""
     with app.app_context():
@@ -107,22 +138,34 @@ def process_image_generation(app, user_id, task_id, payload, api_key, target_api
                 try:
                     # 添加 async=true 参数启用异步模式
                     submit_resp = requests.post(
-                        get_proxied_url(target_api), 
+                        get_proxied_url(target_api),
                         params={"async": "true"},
-                        json=payload, 
-                        headers=headers, 
-                        timeout=Config.PROXY_TIMEOUT_DEFAULT 
+                        json=payload,
+                        headers=headers,
+                        timeout=Config.PROXY_TIMEOUT_DEFAULT
                     )
-                    
+
                     if submit_resp.status_code == 200:
                         break # 成功
                     else:
                         system_logger.warning(f"任务提交失败(第{attempt+1}次): {submit_resp.status_code} - {submit_resp.text[:100]}", user_id=user_id, task_id=task_id)
                         last_error = f"HTTP {submit_resp.status_code}: {submit_resp.text}"
+                except (ConnectTimeout, ConnectionError) as e:
+                    # 连接阶段的错误(DNS失败、连接拒绝、连接超时)，请求大概率未发出，可安全重试
+                    err_str = str(e)
+                    if 'RemoteDisconnected' in err_str or 'ReadTimeout' in err_str:
+                        # 连接建立后断开 = 请求可能已发送到上游，不要重试以免重复任务
+                        system_logger.warning(f"任务提交后响应丢失(第{attempt+1}次)，不再重试: {err_str}", user_id=user_id, task_id=task_id)
+                        last_error = err_str
+                        break
+                    system_logger.warning(f"任务提交连接异常(第{attempt+1}次): {err_str}", user_id=user_id, task_id=task_id)
+                    last_error = err_str
+                    time.sleep(1)
                 except Exception as e:
+                    # 其他未知异常，保守起见不重试
                     system_logger.warning(f"任务提交异常(第{attempt+1}次): {str(e)}", user_id=user_id, task_id=task_id)
                     last_error = str(e)
-                    time.sleep(1) # 短暂等待重试
+                    break
             
             if not submit_resp or submit_resp.status_code != 200:
                 raise Exception(f"任务提交失败(重试3次后): {last_error}")
@@ -205,7 +248,7 @@ def process_image_generation(app, user_id, task_id, payload, api_key, target_api
                                 generation_success = True
                                 break
                         elif remote_status == 'FAILURE':
-                             raise Exception(f"生成任务失败: {poll_data.get('fail_reason', '未知错误')}")
+                             raise Exception(f"生成任务失败: {_extract_error_detail(poll_data)}")
                              
                     except requests.RequestException:
                         continue # 网络波动重试
@@ -360,13 +403,11 @@ def process_video_generation(app, user_id, internal_task_id, payload, api_key, c
                             video_url = poll_result['url']
                     break
                 elif status in ['FAILURE', 'FAILED', 'ERROR']:
-                    reason = poll_result.get('fail_reason') or poll_result.get('message') or '未知错误'
-                    raise Exception(f"视频生成失败: {reason}")
-            
+                    raise Exception(f"视频生成失败: {_extract_error_detail(poll_result)}")
+
             if not video_url:
-                if status in ['FAILURE', 'FAILED', 'ERROR']: # 防止循环结束时正好是失败状态但未抛出的极端情况
-                     reason = poll_result.get('fail_reason') or poll_result.get('message') or '未知错误'
-                     raise Exception(f"视频生成失败: {reason}")
+                if status in ['FAILURE', 'FAILED', 'ERROR']:
+                     raise Exception(f"视频生成失败: {_extract_error_detail(poll_result)}")
                 raise Exception("超时未获取到视频地址")
 
             # 3. 持久化记录