mint/api-v12/app/Jobs/ProcessAITranslateJob.php

<?php

namespace App\Jobs;

use App\Services\AiTranslateService;
use App\Services\RabbitMQService;
use Illuminate\Support\Facades\Log;
use App\Exceptions\TaskFailException;
use Illuminate\Support\Facades\Cache;

class ProcessAITranslateJob extends BaseRabbitMQJob
{
    private $aiService;

    protected function processMessage(array $messageData)
    {
        $startTime = microtime(true);
        try {
            // Laravel会自动注入
            $this->aiService = app(AiTranslateService::class);
            return $this->aiService->processTranslate($this->messageId, $messageData);
        } catch (TaskFailException $e) {
            throw $e;
        } catch (\Exception $e) {
            // 记录失败指标
            throw $e;
        } finally {
            // 记录处理时间
            $processingTime = microtime(true) - $startTime;
            Log::info('翻译处理耗时', ['time' => $processingTime]);
        }
    }

    protected function handleFinalFailure(array $messageData, \Exception $exception)
    {
        parent::handleFinalFailure($messageData, $exception);

        // 消息处理最终失败，准备发送到死信队列
        $this->aiService->handleFailedTranslate($this->messageId, $messageData, $exception);
    }
    public function stop()
    {
        parent::stop();
        $this->aiService->stop();
    }

    public static function publish(string $taskId, $aiAssistantId): string
    {
        $data = AiTranslateService::makeByTask($taskId, $aiAssistantId);
        $mq = app(RabbitMQService::class);
        $queue = 'ai_translate_v2';
        $msgId = $mq->publishMessage($queue, []);
        Cache::put("/mq/message/{$msgId}/data", $data);
        return $msgId;
    }
}