<?php

declare(strict_types=1);

namespace App\Amqp\Consumer;

use App\Model\OrderInquiry;
use App\Model\OrderInquiryCoupon;
use App\Model\OrderPrescription;
use App\Model\OrderPrescriptionProduct;
use App\Model\OrderProduct;
use App\Model\OrderProductItem;
use App\Model\Product;
use App\Model\ProductPlatformAmount;
use App\Model\UserCoupon;
use App\Services\DetectionService;
use App\Services\InquiryService;
use App\Services\OrderProductService;
use App\Services\OrderService;
use App\Utils\Log;
use App\Utils\Utils;
use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;
use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\DbConnection\Db;
use Hyperf\Redis\Redis;
use Hyperf\Snowflake\IdGeneratorInterface;
use PhpAmqpLib\Message\AMQPMessage;
use Hyperf\Amqp\Message\Type;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;

/**
 * 取消未支付药品/问诊订单
 * 延迟队列
 */
#[Consumer(nums: 1)]
class CancelUnpayOrdersDelayDirectConsumer extends ConsumerMessage
{
    use ProducerDelayedMessageTrait;
    use ConsumerDelayedMessageTrait;

    protected string $exchange = 'amqp.delay.direct';

    protected ?string $queue = 'cancel.unpay.orders.delay.queue';

    protected string $type = Type::DIRECT; //Type::FANOUT;

    protected string|array $routingKey = 'CancelUnpayOrders';

    public function consumeMessage($data, AMQPMessage $message): string
    {
        Log::getInstance("queue-CancelUnpayOrders")->info(json_encode($data, JSON_UNESCAPED_UNICODE));

        try {
            $Utils = new Utils();
            $redis_key = "cancelUnpayOrders" . $data['order_no'];
            $res = $Utils->checkHandleNumber($redis_key);
            if (!$res) {
                Log::getInstance("queue-CancelUnpayOrders")->error("超出最大执行次数或检测错误");
            }

        }catch (\Throwable $e){
            Log::getInstance("queue-CancelUnpayOrders")->error($e->getMessage());
            return Result::ACK;
        }

        Db::beginTransaction();

        try {
            $OrderService = new OrderService();

            if ($data['order_type'] == 1) {
                // 问诊订单
                $result = $OrderService->cancelUnpayOrder($data['order_no'],5,"支付超时");
            } elseif ($data['order_type'] == 2) {
                // 药品订单
                $result = $OrderService->cancelUnpayOrder($data['order_no'],3,"支付超时");
            }  elseif ($data['order_type'] == 3) {
                // 检测订单
                $result = $OrderService->cancelUnpayOrder($data['order_no'],3,"支付超时");
            }  elseif ($data['order_type'] == 4) {
                // 服务包订单
                $result = $OrderService->cancelUnpayOrder($data['order_no'],3,"支付超时");
            } else {
                Log::getInstance("queue-CancelUnpayOrders")->error("order_type类型错误");
                return Result::DROP;// 销毁
            }

            if ($result['status'] != 1) {
                Db::rollBack();
                Log::getInstance("queue-CancelUnpayOrders")->error($result['message']);
                return Result::ACK;
            }

            Db::commit();
            Log::getInstance("queue-CancelUnpayOrders")->info("成功");
            return Result::ACK;
        } catch (\Throwable $e) {
            Db::rollBack();
            Log::getInstance("queue-CancelUnpayOrders")->error($e->getMessage());
            return Result::ACK;
        }
    }
}