<?php

declare(strict_types=1);

namespace App\Amqp\Consumer;

use App\Model\OrderInquiry;
use App\Model\UserDoctor;
use App\Services\MessagePush;
use App\Utils\Log;
use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;
use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
use Hyperf\Amqp\Message\Type;
use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\DbConnection\Db;
use PhpAmqpLib\Message\AMQPMessage;

/**
 * 医生xx时间未接诊提醒
 */
#[Consumer(nums: 1)]
class DoctorNotYetInquiryDelayDirectConsumer extends ConsumerMessage
{
    use ProducerDelayedMessageTrait;
    use ConsumerDelayedMessageTrait;

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

    protected ?string $queue = 'doctor.not.uet.inquiry.delay.queue';

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

    protected string|array $routingKey = 'DoctorNotYetInquiry';

    public function consumeMessage($data, AMQPMessage $message): string
    {
        Log::getInstance("queue-DoctorNotYetInquiry")->info("开始：" . json_encode($data, JSON_UNESCAPED_UNICODE));

        if (!isset($data['order_inquiry_id'])){
            Log::getInstance("queue-DoctorNotYetInquiry")->error("缺少参数");
            return Result::ACK;
        }

        try {
            // 获取问诊订单数据
            $params = array();
            $params['order_inquiry_id'] = $data['order_inquiry_id'];
            $order_inquiry = OrderInquiry::getOne($params);
            if (empty($order_inquiry)){
                Log::getInstance("queue-DoctorNotYetInquiry")->error("未找到对应问诊订单");
                return Result::ACK;
            }

            // 检测问诊订单状态
            if ($order_inquiry['inquiry_status'] != 3){
                Log::getInstance("queue-DoctorNotYetInquiry")->error("状态非待接诊，无需发送");
                return Result::ACK;
            }

            // 获取订单医生数据
            $params = array();
            $params['doctor_id'] = $order_inquiry['doctor_id'];
            $user_doctor = UserDoctor::getOne($params);
            if (empty($user_doctor)) {
                Log::getInstance("queue-DoctorNotYetInquiry")->error("医生数据错误");
            }

            // 发送站内、订阅消息-医生-超时未接诊
            $MessagePush = new MessagePush($user_doctor['user_id'],$order_inquiry['order_inquiry_id']);
            $MessagePush->doctorNotYetInquiry();
        }catch (\Throwable $e){
            Log::getInstance("queue-DoctorNotYetInquiry")->error("失败：" . $e->getMessage());
            return Result::ACK;
        }

        return Result::ACK;
    }
}