<?php

namespace app\queue\redis;

use Webman\RedisQueue\Consumer;
use support\Log;
use app\common\model\WordpressSite;
use app\common\model\WordpressUsedCar;
use app\common\model\UsedCarDetail;
use app\common\service\WordpressSiteService;

class WordPressPush implements Consumer
{
    // 要消费的队列名
    public $queue = 'wordpress-push';

    // 连接名
    public $connection = 'default';

    /**
     * 消费 WordPress 推送任务
     * @param array $data
     *   - car_id: 车辆ID
     *   - site_id: WordPress站点ID（可选，默认使用启用的站点）
     */
    public function consume($data)
    {
        $carId = $data['car_id'] ?? null;
        $siteId = $data['site_id'] ?? null;

        if (empty($carId)) {
            Log::error('WordPress推送：车辆ID为空', ['data' => $data]);
            return;
        }

        try {
            // 获取车辆信息
            $car = UsedCarDetail::find($carId);
            if (!$car) {
                Log::warning('WordPress推送：车辆不存在', ['car_id' => $carId]);
                return;
            }

            // 获取WordPress站点
            if ($siteId) {
                $site = WordpressSite::find($siteId);
            } else {
                $site = WordpressSite::where('status', 1)->first();
            }

            if (!$site) {
                $msg = '没有启用的WordPress站点';
                Log::warning('WordPress推送失败：' . $msg, ['car_id' => $carId]);
                // 推送失败，更新车辆状态为5
                $car->update(['status' => 5]);
                return;
            }

            // 检查是否已推送过
            $existing = WordpressUsedCar::where('wp_site_id', $site->id)
                ->where('used_car_id', $carId)
                ->where('status', 1)
                ->first();

            if ($existing) {
                Log::info('WordPress推送：车辆已推送过，跳过', [
                    'car_id' => $carId,
                    'wp_product_id' => $existing->wp_product_id
                ]);
                return;
            }

            // 执行推送
            $wpService = new WordpressSiteService();
            $result = $wpService->createProductForNewSite($site, $carId);

            // 推送成功（没有抛出异常），更新车辆状态为4
            $car->update(['status' => 4]);
            Log::info('WordPress推送成功，车辆状态已更新为推送成功', [
                'car_id' => $carId,
                'wp_post_id' => $result['result']['id'] ?? null,
            ]);

        } catch (\Throwable $e) {
            Log::error('WordPress推送异常', [
                'car_id' => $carId,
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString(),
            ]);
            // 推送失败，更新车辆状态为5
            try {
                if ($car) {
                    $car->update(['status' => 5]);
                }
            } catch (\Throwable $updateError) {
                Log::error('更新车辆状态失败', [
                    'car_id' => $carId,
                    'error' => $updateError->getMessage(),
                ]);
            }
            // 不再重新抛出异常，让队列正常处理下一条
        }
    }

    /**
     * 消费失败回调
     */
    public function onConsumeFailure(\Throwable $e, $package)
    {
        Log::error('WordPress推送消费失败', [
            'error' => $e->getMessage(),
            'package' => $package,
        ]);

        // 获取车辆ID并更新状态
        $carId = $package['data']['car_id'] ?? null;
        if ($carId) {
            try {
                UsedCarDetail::where('id', $carId)->update(['status' => 5]);
            } catch (\Throwable $updateError) {
                Log::error('推送失败后更新车辆状态异常', [
                    'car_id' => $carId,
                    'error' => $updateError->getMessage(),
                ]);
            }
        }
    }
}