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

<?php

namespace App\Jobs;

use App\Services\AiTranslateService;
use App\Services\RabbitMQService;
use Illuminate\Support\Facades\Log;

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 (\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)
    {
        $us = ['openai.com', 'googleapis.com', 'x.ai', 'anthropic.com'];
        $data = AiTranslateService::makeByTask($taskId, $aiAssistantId);
        $mq = app(RabbitMQService::class);
        $queue = 'ai_translate_cn';
        $found = array_filter($us, function ($value) use ($data) {
            return str_contains($data['model']['url'], $value);
        });
        if (count($found) > 0) {
            $queue = 'ai_translate_us';
        }
        $mq->publishMessage($queue, $data);
    }
}