|
|
@@ -103,7 +103,7 @@ class ProcessBatchEpisodeGenerationCommand extends Command
|
|
|
->first();
|
|
|
|
|
|
if ($prevTaskInBatch && $prevTaskInBatch->status !== 'completed') {
|
|
|
- dLog('command')->info('[' . date('Y-m-d H:i:s') . '] 前一集(第' . $prevEpisodeNumber . '集)尚未完成,跳过当前任务');
|
|
|
+ dLog('command')->info('[' . date('Y-m-d H:i:s') . '] 前一集(第' . $prevEpisodeNumber . '集)尚未完成,跳过当前任务 (anime_id: ' . $task->anime_id . ')');
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
@@ -115,7 +115,7 @@ class ProcessBatchEpisodeGenerationCommand extends Command
|
|
|
->exists();
|
|
|
|
|
|
if (!$prevEpisodeExists) {
|
|
|
- dLog('command')->error('[' . date('Y-m-d H:i:s') . '] 前一集(第' . $prevEpisodeNumber . '集)不存在,无法继续生成');
|
|
|
+ dLog('command')->error('[' . date('Y-m-d H:i:s') . '] 前一集(第' . $prevEpisodeNumber . '集)不存在,无法继续生成 (anime_id: ' . $task->anime_id . ')');
|
|
|
|
|
|
// 标记为失败
|
|
|
DB::table('mp_batch_episode_generation_details')
|
|
|
@@ -138,7 +138,7 @@ class ProcessBatchEpisodeGenerationCommand extends Command
|
|
|
->exists();
|
|
|
|
|
|
if ($currentEpisodeExists) {
|
|
|
- dLog('command')->info('[' . date('Y-m-d H:i:s') . '] 第' . $task->episode_number . '集已存在,跳过生成');
|
|
|
+ dLog('command')->info('[' . date('Y-m-d H:i:s') . '] 第' . $task->episode_number . '集已存在,跳过生成 (anime_id: ' . $task->anime_id . ')');
|
|
|
|
|
|
// 标记为已完成
|
|
|
DB::table('mp_batch_episode_generation_details')
|
|
|
@@ -173,14 +173,20 @@ class ProcessBatchEpisodeGenerationCommand extends Command
|
|
|
// 使用"继续策划下一集"逻辑
|
|
|
$requestData['prompt'] = '继续策划下一集';
|
|
|
|
|
|
- dLog('command')->info('[' . date('Y-m-d H:i:s') . '] 开始生成第' . $task->episode_number . '集...');
|
|
|
+ dLog('command')->info('[' . date('Y-m-d H:i:s') . '] 开始生成第' . $task->episode_number . '集... (anime_id: ' . $task->anime_id . ')');
|
|
|
|
|
|
- // 调用非流式生成方法
|
|
|
- $result = $this->deepSeekService->chatForAceNonStream($requestData);
|
|
|
+ // 调用非流式生成方法,并记录实际执行耗时
|
|
|
+ $chatStartTime = microtime(true);
|
|
|
+ try {
|
|
|
+ $result = $this->deepSeekService->chatForAceNonStream($requestData);
|
|
|
+ } finally {
|
|
|
+ $chatDuration = round(microtime(true) - $chatStartTime, 2);
|
|
|
+ dLog('command')->info('[' . date('Y-m-d H:i:s') . '] chatForAceNonStream 执行完成,耗时: ' . $chatDuration . ' 秒 (anime_id: ' . $task->anime_id . ', 第' . $task->episode_number . '集)');
|
|
|
+ }
|
|
|
|
|
|
// 检查是否有错误
|
|
|
if (isset($result['error']) && $result['error']) {
|
|
|
- dLog('command')->error('[' . date('Y-m-d H:i:s') . '] 生成失败: ' . $result['error']);
|
|
|
+ dLog('command')->error('[' . date('Y-m-d H:i:s') . '] 生成失败: ' . $result['error'] . ' (anime_id: ' . $task->anime_id . ', 第' . $task->episode_number . '集)');
|
|
|
|
|
|
// 更新重试次数
|
|
|
$retryCount = $task->retry_count + 1;
|
|
|
@@ -196,7 +202,7 @@ class ProcessBatchEpisodeGenerationCommand extends Command
|
|
|
]);
|
|
|
|
|
|
// 记录错误日志
|
|
|
- logDB('batch_episode_generation', 'error', "第{$task->episode_number}集生成失败", [
|
|
|
+ logDB('batch_episode_generation', 'error', "anime_id: {$task->anime_id} 第{$task->episode_number}集生成失败", [
|
|
|
'anime_id' => $task->anime_id,
|
|
|
'episode_number' => $task->episode_number,
|
|
|
'error' => $result['error']
|
|
|
@@ -215,12 +221,13 @@ class ProcessBatchEpisodeGenerationCommand extends Command
|
|
|
// 'updated_at' => now()
|
|
|
]);
|
|
|
|
|
|
- dLog('command')->info('[' . date('Y-m-d H:i:s') . '] 第' . $task->episode_number . '集生成成功');
|
|
|
+ dLog('command')->info('[' . date('Y-m-d H:i:s') . '] 第' . $task->episode_number . '集生成成功 (anime_id: ' . $task->anime_id . ')');
|
|
|
|
|
|
continue;
|
|
|
|
|
|
} catch (\Exception $e) {
|
|
|
- dLog('command')->error('[' . date('Y-m-d H:i:s') . '] 生成失败: ' . $e->getMessage());
|
|
|
+ $animeLogInfo = isset($task) ? ' (anime_id: ' . $task->anime_id . ', 第' . $task->episode_number . '集)' : '';
|
|
|
+ dLog('command')->error('[' . date('Y-m-d H:i:s') . '] 生成失败: ' . $e->getMessage() . $animeLogInfo);
|
|
|
|
|
|
if (isset($task)) {
|
|
|
// 更新重试次数
|
|
|
@@ -237,7 +244,7 @@ class ProcessBatchEpisodeGenerationCommand extends Command
|
|
|
]);
|
|
|
|
|
|
// 记录错误日志
|
|
|
- logDB('batch_episode_generation', 'error', "第{$task->episode_number}集生成失败", [
|
|
|
+ logDB('batch_episode_generation', 'error', "anime_id: {$task->anime_id} 第{$task->episode_number}集生成失败", [
|
|
|
'anime_id' => $task->anime_id,
|
|
|
'episode_number' => $task->episode_number,
|
|
|
'error' => $e->getMessage(),
|