|
|
@@ -179,6 +179,38 @@ class FixNewVideoTasks720pCommand extends Command
|
|
|
|
|
|
$segmentSynced = $this->syncSegmentUrls($task, $newResult, $newCompressed);
|
|
|
$recordSynced = $this->syncAnimeRecordUrls($task, $newResult);
|
|
|
+
|
|
|
+ // 只更新不新增；完全没有 assistant 记录时需要即时通知人工确认
|
|
|
+ if ($recordSynced === 0) {
|
|
|
+ $assistantTotal = DB::table('mp_anime_records')
|
|
|
+ ->where('video_task_id', $task->id)
|
|
|
+ ->where('role', 'assistant')
|
|
|
+ ->count();
|
|
|
+ if ($assistantTotal === 0) {
|
|
|
+ $notice = sprintf(
|
|
|
+ '任务#%d 在 mp_anime_records 中完全没有 assistant 记录（只更新不新增），请人工确认是否需要补录',
|
|
|
+ $task->id
|
|
|
+ );
|
|
|
+ $this->warn($notice);
|
|
|
+ dLog('command')->warning($notice, [
|
|
|
+ 'task_id' => $task->id,
|
|
|
+ 'old_result_url' => $task->result_url,
|
|
|
+ 'new_result_url' => $newResult,
|
|
|
+ ]);
|
|
|
+ logDB('command', 'warning', $notice, [
|
|
|
+ 'task_id' => $task->id,
|
|
|
+ 'old_result_url' => $task->result_url,
|
|
|
+ 'new_result_url' => $newResult,
|
|
|
+ ]);
|
|
|
+ } else {
|
|
|
+ $this->warn(sprintf(
|
|
|
+ '任务#%d 有 %d 条 assistant 记录但均未指向旧 result_url，跳过 anime_records 同步',
|
|
|
+ $task->id,
|
|
|
+ $assistantTotal
|
|
|
+ ));
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
$this->line(sprintf(
|
|
|
'#%d 已更新任务 URL（分镜同步：%s；anime_records 同步：%d 条）',
|
|
|
$task->id,
|
lh