AI视频脚本增加去重逻辑

addons/shopro/job/AiVideoGen.php

@@ -46,6 +46,23 @@ class AiVideoGen extends BaseJob
                 return false;
             }
 
+            // 去重处理
+            $tryon = AiTryOnModel::where('id', $id)->find();
+
+            // 检查记录是否存在
+            if (!$tryon) {
+                $this->debug_log('[AI视频生成异步队列][删除Job]试戴记录不存在: id='.$id);
+                $job->delete();
+                return false;
+            }
+
+            // 检查是否已有任务ID（去重）
+            if (!empty($tryon['ai_task_id']) || $tryon['ai_status'] !== 0) {
+                $this->debug_log('[AI视频生成异步队列][删除Job]已有任务ID，跳过: id='.$id.', task_id='.$tryon['ai_task_id']);
+                $job->delete();
+                return false;
+            }
+
             // 1. 合成AI视频，返回任务ID
             $ai = new Ai();
             $res = $ai->generateVideo($id, $user_id);
@@ -65,21 +82,6 @@ class AiVideoGen extends BaseJob
 
                 // 去重处理
                 $taskid = $res['data'];
-                $tryon = AiTryOnModel::where('id', $id)->find();
-
-                // 检查记录是否存在
-                if (!$tryon) {
-                    $this->debug_log('[AI视频生成][删除Job]试戴记录不存在: id='.$id);
-                    $job->delete();
-                    return false;
-                }
-
-                // 检查是否已有任务ID（去重）
-                if (!empty($tryon['ai_task_id'])) {
-                    $this->debug_log('[AI视频生成][删除Job]已有任务ID，跳过: id='.$id.', task_id='.$tryon['ai_task_id']);
-                    $job->delete();
-                    return false;
-                }
 
                 // 更新任务ID和状态
                 AiTryOnModel::where('id', $id)->update([

addons/shopro/job/AiVideoRetry.php

@@ -44,7 +44,7 @@ class AiVideoRetry extends BaseJob
             $user = $data['user'];
             $user_id = isset($user['id']) ? $user['id'] : 0;
 
-            $this->debug_log('***************************** '.date('Y-m-d H:i:s'). '查询AI视频状态脚本开始 userid '.$user_id.' taskid:'.$taskid.' id:'.$id.' ***********************************'.PHP_EOL);
+            $this->debug_log('***************************** '.date('Y-m-d H:i:s'). ' [AI视频查询异步队列]查询AI视频状态脚本开始 userid '.$user_id.' taskid:'.$taskid.' id:'.$id.' ***********************************'.PHP_EOL);
 
             // 校验入参
             if (empty($id) || empty($user_id) || empty($taskid)) {