<?php

declare(strict_types=1);

namespace App\Amqp\Consumer;

use App\Amqp\Producer\PrescriptionExpiredDelayDirectProducer;
use App\Model\OrderInquiry;
use App\Model\OrderPrescription;
use App\Model\OrderPrescriptionFile;
use App\Model\OrderPrescriptionProduct;
use App\Model\ReportRegulatory;
use App\Model\UserDoctor;
use App\Model\UserPatient;
use App\Model\UserPharmacist;
use App\Services\CaService;
use App\Services\ImService;
use App\Services\MessagePush;
use App\Services\OrderPrescriptionService;
use App\Utils\Log;
use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;
use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
use Hyperf\Amqp\Message\Type;
use Hyperf\Amqp\Producer;
use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\DbConnection\Db;
use Hyperf\Redis\Redis;
use PhpAmqpLib\Message\AMQPMessage;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;

/**
 * 药师审核并ca签章
 */
#[Consumer(nums: 1)]
class AutoPharmacistCaVerifyDelayDirectConsumer extends ConsumerMessage
{
    use ProducerDelayedMessageTrait;
    use ConsumerDelayedMessageTrait;

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

    protected ?string $queue = 'auto.pharmacist.ca.verify.delay.queue';

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

    protected string|array $routingKey = 'AutoPharmacistCaVerify';

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

        // 检测入参参数
        $res = $this->checkParams($data);
        if (!$res) {
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：执行参数错误");
            return Result::ACK;
        }

        // 获取处方数据
        $params = array();
        $params['order_prescription_id'] = $data['order_prescription_id'];
        $order_prescription = OrderPrescription::getOne($params);
        if (empty($order_prescription)) {
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：处方数据错误");
            return Result::ACK;
        }

        // 检测处方数据
        $res = $this->checkPrescriptionData($order_prescription);
        if (!empty($res)) {
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $res);
            return Result::ACK;
        }

        // 获取问诊订单数据
        $params = array();
        $params['order_inquiry_id'] = $order_prescription['order_inquiry_id'];
        $order_inquiry = OrderInquiry::getOne($params);
        if (empty($order_inquiry)) {
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：问诊订单数据错误");
            return Result::ACK;
        }

        // 检测问诊订单数据
        $res = $this->checkOrderInquiryData($order_inquiry);
        if (!empty($res)) {
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $res);
            return Result::ACK;
        }

        // 获取医生数据
        $params = array();
        $params['doctor_id'] = $order_prescription['doctor_id'];
        $user_doctor = UserDoctor::getOne($params);
        if (empty($user_doctor)) {
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：医生数据错误");
            return Result::ACK;
        }

        // 获取用户数据
        $params = array();
        $params['patient_id'] = $order_prescription['patient_id'];
        $user_patient = UserPatient::getOne($params);
        if (empty($user_patient)) {
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：患者数据错误");
            return Result::ACK;
        }

        // 获取药师数据
        $params = array();
        $params['pharmacist_id'] = $order_prescription['pharmacist_id'];
        $user_pharmacist = UserPharmacist::getOne($params);
        if (empty($user_pharmacist)) {
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：药师数据错误");
            return Result::ACK;
        }

        // 获取处方商品数据
        $product_name = "";
        $params = array();
        $params['order_prescription_id'] = $order_prescription['order_prescription_id'];
        $order_prescription_product = OrderPrescriptionProduct::getList($params);
        if (!empty($order_prescription_product)){
            $product_name_array = array_column($order_prescription_product->toArray(),'product_name');
            if (count($product_name_array) > 1){
                $product_name = implode('、',$product_name_array);
            }else{
                $product_name = $product_name_array[0];
            }
        }

        try {
            Log::getInstance("queue-AutoPharmacistCaVerify")->info("信息：检测执行次数");

            // 检测执行次数
            $res = $this->checkHandleNumber($data['prescription_file_id']);
        }catch (\Throwable $e){
            // 检测次数失败
            Log::getInstance("queue-AutoPharmacistCaVerify")->info("错误：" . $e->getMessage());
            return Result::ACK;
        }

        if (!$res) {
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：超出最大执行次数或检测错误");

            Db::beginTransaction();
            try {
                // 修改处方表为未通过
                $this->modifyOrderPrescription($data['order_prescription_id'], 2, "请联系平台客服，请勿重开处方");

                // 医生-开具的处方审核未通过
                $MessagePush = new MessagePush($user_doctor['user_id'], $order_prescription['order_inquiry_id']);
                $MessagePush->prescriptionVerifyFail($data['order_prescription_id']);

                // 患者-处方审核未通过
                $MessagePush = new MessagePush($user_patient['user_id'], $order_prescription['order_inquiry_id']);
                $MessagePush->patientPrescriptionVerifyFail();
                Db::commit();

                return Result::ACK;
            }catch (\Throwable $e){
                Db::rollBack();
                Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $e->getMessage());
                return Result::ACK;
            }
        }

        // 下载医生签章文件
        Db::beginTransaction();
        try {
            // 检测执行次数
            $res = $this->checkHandleNumber($data['prescription_file_id']);
            if (!$res) {
                Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：超出最大执行次数或检测错误");

                // 修改处方表为未通过
                $this->modifyOrderPrescription($data['order_prescription_id'],2,"请联系平台客服，请勿重开处方");

                Db::commit();
            }

            // 获取处方文件数据
            $params = array();
            $params['prescription_file_id'] = $data['prescription_file_id'];
            $params['order_prescription_id'] = $data['order_prescription_id'];
            $order_prescription_file = OrderPrescriptionFile::getOne($params);
            if (empty($order_prescription_file)) {
                Db::rollBack();
                Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：处方文件数据错误");
                return Result::REQUEUE;
            }

            // 检测处方文件数据
            $res = $this->checkPrescriptionFileData($order_prescription_file);
            if (!empty($res)) {
                Db::rollBack();
                Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $res);
                return Result::REQUEUE;
            }

            // 下载医生的签章pdf并上传至oss
            Log::getInstance("queue-AutoPharmacistCaVerify")->info("下载医生的签章pdf并上传至oss");
            $CaService = new CaService($order_prescription,2,$user_doctor['user_id']);
            $prescription_pdf_oss_path = $CaService->downCaPdfToOss($order_prescription_file['doctor_ca_file_id']);
            if ($prescription_pdf_oss_path == "") {
                Db::rollBack();
                Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $prescription_pdf_oss_path);
                return Result::REQUEUE;
            }

            // 药师签章
            Log::getInstance("queue-AutoPharmacistCaVerify")->info("药师签章");
            $OrderPrescriptionService = new OrderPrescriptionService();
            $prescription_open_result = $OrderPrescriptionService->openPrescription($data['order_prescription_id'],3,$user_pharmacist['user_id']);
            if (empty($prescription_open_result['file_id'])){
                Db::rollBack();
                Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：药师签章失败");
                return Result::REQUEUE;
            }

            // 下载药师签章pdf并上传至oss
            Log::getInstance("queue-AutoPharmacistCaVerify")->info("下载药师的签章pdf并上传至oss");
            $CaService = new CaService($order_prescription,3,$user_pharmacist['user_id']);
            $prescription_pdf_oss_path = $CaService->downCaPdfToOss($prescription_open_result['file_id']);
            if ($prescription_pdf_oss_path == "") {
                Db::rollBack();
                Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $prescription_pdf_oss_path);
                return Result::REQUEUE;
            }

            // 医院签章
            Log::getInstance("queue-AutoPharmacistCaVerify")->info("医院签章");
            $OrderPrescriptionService = new OrderPrescriptionService();
            $prescription_open_result = $OrderPrescriptionService->openPrescription($data['order_prescription_id'],1);
            if (empty($prescription_open_result['file_id'])){
                Db::rollBack();
                Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：医院签章失败");
                return Result::REQUEUE;
            }

            // 下载医院签章pdf并上传至oss
            Log::getInstance("queue-AutoPharmacistCaVerify")->info("下载医院的签章pdf并上传至oss");
            $CaService = new CaService($order_prescription,1);
            $prescription_pdf_oss_path = $CaService->downCaPdfToOss($prescription_open_result['file_id']);
            if ($prescription_pdf_oss_path == "") {
                Db::rollBack();
                Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $prescription_pdf_oss_path);
                return Result::REQUEUE;
            }

            // 修改处方文件表，添加prescription_pdf_oss_path字段
            $this->modifyOrderPrescriptionFile($data['prescription_file_id'],$prescription_pdf_oss_path,$prescription_open_result['file_id']);

            // 修改处方表为通过
            $this->modifyOrderPrescription($data['order_prescription_id'],1);

            Db::commit();
            Log::getInstance("queue-AutoPharmacistCaVerify")->info("成功");
        } catch (\Throwable $e) {
            Db::rollBack();
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("异常错误：" . $e->getMessage());

            return Result::REQUEUE; // 重回队列
        }

        // 发送消息
        try {
            // 药师审核成功
            // 发送IM消息-处方已开具
            $imService = new ImService();
            $imService->prescriptionIssued($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id'],$product_name,(string)$data['order_prescription_id'],7);

            // 发送站内、短信消息-患者的处方被药师审核通过
            $MessagePush = new MessagePush($order_inquiry['user_id'],$order_inquiry['order_inquiry_id']);
            $MessagePush->patientPrescriptionVerifyPass();

            // 站内、订阅失败发送短信-医生开具的处方审核通过
            // 发送目标不同，重新实例化
            $MessagePush = new MessagePush($user_doctor['user_id'],$order_inquiry['order_inquiry_id']);
            $MessagePush->prescriptionVerifySuccess();

            // 添加处方过期队列
            $data = array();
            $data['order_prescription_id'] = (string)$order_prescription['order_prescription_id'];

            $message = new PrescriptionExpiredDelayDirectProducer($data);
            $message->setDelayMs(1000 * 60 * 60 * 24 * 3);
            $producer = $this->container->get(Producer::class);
            $res = $producer->produce($message);
            if (!$res) {
                Log::getInstance("queue-AutoPharmacistCaVerify")->error("添加处方过期队列失败！");
                return Result::ACK;
            }
        }catch(\Throwable $e){
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("发送消息异常错误：" . $e->getMessage());
            return Result::ACK;
        }

        return Result::ACK;
    }

    /**
     * 检测执行参数
     * @param array $data
     * @return bool
     */
    protected function checkParams(array $data): bool
    {
        if (!isset($data['prescription_file_id'])) {
            return false;
        }

        if (!isset($data['order_prescription_id'])) {
            return false;
        }
        return true;
    }

    /**
     * 检测处方数据
     * @param array|object $order_prescription
     * @return string
     */
    protected function checkPrescriptionData(array|object $order_prescription): string
    {
        // 验证处方状态
        if ($order_prescription['prescription_status'] == 2) {
            // 处方状态（1:待审核 2:待使用 3:已失效 4:已使用）
            return "处方已审核";
        }

        if ($order_prescription['prescription_status'] == 3) {
            // 处方状态（1:待审核 2:待使用 3:已失效 4:已使用）
            return "处方已审核并失效";
        }

        if ($order_prescription['prescription_status'] == 4) {
            // 处方状态（1:待审核 2:待使用 3:已失效 4:已使用）
            return "处方已审核并使用";
        }

        // 验证处方审核状态
        if ($order_prescription['pharmacist_audit_status'] != 0) {
            // 药师审核状态（0:审核中 1:审核成功 2:审核驳回）
            return "处方已审核";
        }

        // 处方平台审核状态
        if ($order_prescription['platform_audit_status'] != 0) {
            // 处方平台审核状态（0:审核中 1:审核成功 2:审核驳回）
            return "处方已审核";
        }

        return "";
    }

    /**
     * 检测问诊订单数据
     * @param array|object $order_inquiry
     * @return string
     */
    protected function checkOrderInquiryData(array|object $order_inquiry): string
    {
        if (in_array($order_inquiry['inquiry_status'], [1, 2, 3, 7])) {
            // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消）
            return "问诊订单状态错误，无法继续审核";
        }

        return "";
    }

    /**
     * 检测处方文件数据
     * @param array|object $order_prescription_file
     * @return string
     */
    protected function checkPrescriptionFileData(array|object $order_prescription_file): string
    {
        if (empty($order_prescription_file['doctor_ca_file_id'])) {
            return "缺少医生签章pdf文件id";
        }

        return "";
    }

    /**
     * 检测执行次数
     * @param string $prescription_file_id
     * @return bool
     * @throws ContainerExceptionInterface
     * @throws NotFoundExceptionInterface
     */
    protected function checkHandleNumber(string $prescription_file_id): bool
    {
        try {
            $redis = $this->container->get(Redis::class);

            $redis_key = "AutoPharmacistCaVerify" . $prescription_file_id;
            $redis_value = $redis->get($redis_key);
            if (empty($redis_value)) {
                $redis->set($redis_key, 1, 60 * 60 * 24 * 5);
                return true;
            }

            // 问诊订单执行退款次数过多
            if ($redis_value > 3) {
                // 加入短信队列,通知管理员

                return false;
            }

            $redis->incr($redis_key);
        } catch (\Exception $e) {
            return false;
        }

        return true;
    }

    /**
     * 修改处方文件表
     * @param string $prescription_file_id 主键id
     * @param string $prescription_pdf_oss_path pdf的oss地址
     * @param string $hospital_ca_file_id 医院签章文件id
     * @return void
     */
    protected function modifyOrderPrescriptionFile(string $prescription_file_id,string $prescription_pdf_oss_path,string $hospital_ca_file_id): void
    {
        try {
            $params = array();
            $params['prescription_file_id'] = $prescription_file_id;

            $data = array();
            $data['hospital_ca_file_id'] = $hospital_ca_file_id;
            $data['prescription_pdf_oss_path'] = $prescription_pdf_oss_path;

            OrderPrescriptionFile::edit($params,$data);
        }catch(\Exception $e){
            // 失败不做处理
            Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：修改处方文件表失败" . $e->getMessage());
        }
    }

    /**
     * 修改处方表
     * @param string $order_prescription_id 处方id
     * @param int $status 审核状态 1：成功 2：驳回
     * @param string $pharmacist_fail_reason 驳回理由
     * @return void
     */
    protected function modifyOrderPrescription(string $order_prescription_id,int $status,string $pharmacist_fail_reason = ""): void
    {
        // 修改处方审核状态
        $data = array();
        if ($status == 1){
            // 审核成功
            $data['prescription_status'] = 2;
            $data['pharmacist_audit_status'] = 1;
            $data['platform_audit_status'] = 1;
        }else{
            $data['pharmacist_audit_status'] = 2;
            $data['pharmacist_fail_reason'] = $pharmacist_fail_reason;
        }
        $data['pharmacist_verify_time'] = date('Y-m-d H:i:s',time());

        $params = array();
        $params['order_prescription_id'] = $order_prescription_id;

        OrderPrescription::edit($params,$data);
    }
}