<?php

namespace App\Services;

use App\Amqp\Producer\CancelUnpayOrdersDelayDirectProducer;
use App\Constants\DoctorTitleCode;
use App\Constants\HttpEnumCode;
use App\Model\Hospital;
use App\Model\OrderInquiry;
use App\Model\OrderInquiryCase;
use App\Model\OrderPrescription;
use App\Model\OrderPrescriptionProduct;
use App\Model\OrderProduct;
use App\Model\OrderProductItem;
use App\Model\Product;
use App\Model\UserDoctor;
use App\Model\UserShipAddress;
use Extend\Wechat\WechatPay;
use Hyperf\Amqp\Producer;
use Hyperf\DbConnection\Db;
use Hyperf\Snowflake\IdGeneratorInterface;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;

/**
 * 患者订单
 */
class PatientOrderService extends BaseService
{
    /**
     * 获取患者问诊订单列表
     * @return array
     */
    public function getPatientInquiryOrderList(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $inquiry_status = $this->request->input('inquiry_status',0);
        $family_id = $this->request->input('family_id');
        $page = $this->request->input('page',1);
        $per_page = $this->request->input('per_page',10);

        $params = array();
        $params['patient_id'] = $user_info['client_user_id'];
        if (!empty($family_id)){
            $params['family_id'] = $family_id;
        }

        $inquiry_status_params = [];
        if (!empty($inquiry_status) && $inquiry_status != 0){
            // 问诊订单状态（0:全部 1:待支付 2:待接诊 3:问诊中 4:完成/取消
            // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消）
            if ($inquiry_status == 1){
                $inquiry_status_params = [1];
            }

            if ($inquiry_status == 2){
                $inquiry_status_params = [2,3];
            }

            if ($inquiry_status == 3){
                $inquiry_status_params = [4];
            }

            if ($inquiry_status == 4){
                $inquiry_status_params = [5,6,7];
            }
        }

        $params['is_delete'] = 0;

        $fields = [
            'order_inquiry_id',
            'patient_id',
            'doctor_id',
            'family_id',
            'inquiry_type',
            'inquiry_mode',
            'inquiry_status',
            'is_delete',
            'inquiry_refund_status',
            'inquiry_pay_channel',
            'inquiry_pay_status',
            'inquiry_no',
            'escrow_trade_no',
            'amount_total',
            'payment_amount_total',
            'patient_name',
            'patient_name_mask',
            'patient_sex',
            'patient_age',
            'created_at',
        ];
        $order_inquiry = OrderInquiry::getPatientOrderInquiryPage($params,$inquiry_status_params,$fields,$page,$per_page);
        if (empty($order_inquiry['data'])){
            return success();
        }

        foreach ($order_inquiry['data'] as &$item){
            $item['disease_desc'] = $item['OrderInquiryCase']['disease_desc'];
            unset($item['OrderInquiryCase']);

            // 获取医生数据
            $item['user_doctor'] = [];
            if (!empty($item['doctor_id'])){
                $fields = [
                    'doctor_id',
                    'user_name',
                    'doctor_title',
                    'hospital_id',
                ];

                $params = array();
                $params['doctor_id'] = $item['doctor_id'];
                $user_doctor = UserDoctor::getOne($params,$fields);
                if (empty($user_doctor)){
                    return fail(HttpEnumCode::SERVER_ERROR);
                }

                // 转换医生职称
                $user_doctor['doctor_title'] = empty($user_doctor['doctor_title']) ? "" : DoctorTitleCode::getMessage($user_doctor['doctor_title']);

                // 获取医生医院名称
                $user_doctor['hospital_name'] = "";
                $user_doctor['hospital_level_name'] = "";

                $fields = [
                    'hospital_id',
                    'hospital_name',
                    'hospital_level_name',
                ];

                $params = array();
                $params['hospital_id'] = $user_doctor['hospital_id'];
                $hospital = Hospital::getOne($params,$fields);
                if (!empty($hospital)){
                    $user_doctor['hospital_name'] = $hospital['hospital_name'];
                    $user_doctor['hospital_level_name'] = $hospital['hospital_level_name'];
                }

                $item['user_doctor'] = $user_doctor;
                unset($hospital);
                unset($user_doctor);
            }
        }

        return success($order_inquiry);
    }

    /**
     * 获取患者问诊订单详情
     * @return array
     */
    public function getPatientInquiryOrderInfo(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_inquiry_id = $this->request->route('order_inquiry_id');

        // 获取订单数据
        $params = array();
        $params['patient_id'] = $user_info['client_user_id'];
        $params['order_inquiry_id'] = $order_inquiry_id;
        $params['is_delete'] = 0;
        $order_inquiry = OrderInquiry::getOne($params);
        if (empty($order_inquiry)){
            return fail();
        }

        // 获取病例信息
        $fields = [
            'disease_class_name',
            'disease_desc',
        ];
        $params = array();
        $params['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
        $order_inquiry_case = OrderInquiryCase::getOne($params,$fields);
        if (empty($order_inquiry_case)){
            return fail();
        }

        $order_inquiry['case'] = $order_inquiry_case->toArray();

        // 获取医生数据
        $order_inquiry['user_doctor'] = [];
        if (!empty($order_inquiry['doctor_id'])){
            $fields = [
                'doctor_id',
                'user_name',
                'doctor_title',
                'hospital_id',
                'avatar',
            ];

            $params = array();
            $params['doctor_id'] = $order_inquiry['doctor_id'];
            $user_doctor = UserDoctor::getOne($params,$fields);
            if (empty($user_doctor)){
                return fail(HttpEnumCode::SERVER_ERROR);
            }

            // 转换医生职称
            $user_doctor['doctor_title'] = empty($user_doctor['doctor_title']) ? "" : DoctorTitleCode::getMessage($user_doctor['doctor_title']);

            // 头像
            $user_doctor['avatar'] = addAliyunOssWebsite($user_doctor['avatar']);

            // 获取医生医院名称
            $user_doctor['hospital_name'] = "";
            $user_doctor['hospital_level_name'] = "";

            $fields = [
                'hospital_id',
                'hospital_name',
                'hospital_level_name',
            ];

            $params = array();
            $params['hospital_id'] = $user_doctor['hospital_id'];
            $hospital = Hospital::getOne($params,$fields);
            if (!empty($hospital)){
                $user_doctor['hospital_name'] = $hospital['hospital_name'];
                $user_doctor['hospital_level_name'] = $hospital['hospital_level_name'];
            }

            $order_inquiry['user_doctor'] = $user_doctor;
            unset($hospital);
            unset($user_doctor);
        }

        return success($order_inquiry->toArray());
    }

    /**
     * 取消患者问诊订单
     * @return array
     * @throws ContainerExceptionInterface
     * @throws NotFoundExceptionInterface
     */
    public function putCancelPatientInquiryOrder(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_inquiry_id = $this->request->route('order_inquiry_id');

        // 获取订单数据
        $params = array();
        $params['patient_id'] = $user_info['client_user_id'];
        $params['order_inquiry_id'] = $order_inquiry_id;
        $params['is_delete'] = 0;
        $order_inquiry = OrderInquiry::getOne($params);
        if (empty($order_inquiry)){
            return fail();
        }

        // 检测订单状态
        if (!in_array($order_inquiry['inquiry_status'],[1,2,3])) {
            // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消）
            return fail(HttpEnumCode::HTTP_ERROR,"订单无法取消");
        }

        if (!in_array($order_inquiry['inquiry_refund_status'],[0,4,5])) {
            // 问诊订单退款状态（0:无退款 1:申请退款 2:退款中 3:退款成功 4:拒绝退款 5:退款关闭）
            return fail(HttpEnumCode::HTTP_ERROR,"订单正在退款中");
        }

        // 支付状态（1:未支付 2:已支付 3:支付中 4:支付失败 5:支付超时 6:支付关闭 7:已撤销 8:转入退款）

        Db::beginTransaction();
        try {
            // 修改问诊订单为取消
            $data = array();
            $data['inquiry_status'] = 7;
            $data['cancel_time'] = date("Y-m-d H:i:s",time());
            $data['cancel_reason'] = 2; // 取消订单原因（1:医生未接诊 2:主动取消 3:无可分配医生 4:客服取消 5:支付超时）
            $data['updated_at'] = date("Y-m-d H:i:s",time());

            $params = array();
            $params['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
            OrderInquiry::edit($params,$data);

            // 检测支付状态，判断是否需要退款处理
            if ($order_inquiry['inquiry_pay_status'] == 2){
                // 需退款
                $inquiryService = new InquiryService();
                $inquiryService->inquiryRefund($order_inquiry['order_inquiry_id'],"取消问诊");
            }

            Db::commit();
        } catch (\Exception $e) {
            Db::rollBack();
            return fail(HttpEnumCode::HTTP_ERROR, $e->getMessage());
        }

        return success();
    }

    /**
     * 删除问诊订单
     * 支付超时
     * 取消问诊
     * 问诊结束
     * @return array
     */
    public function deletePatientInquiryOrder(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_inquiry_id = $this->request->route('order_inquiry_id');

        // 获取订单数据
        $params = array();
        $params['patient_id'] = $user_info['client_user_id'];
        $params['order_inquiry_id'] = $order_inquiry_id;
        $params['is_delete'] = 0;
        $order_inquiry = OrderInquiry::getOne($params);
        if (empty($order_inquiry)){
            return fail();
        }

        // 检测订单状态
        if (!in_array($order_inquiry['inquiry_status'],[6,7])) {
            // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消）
            return fail(HttpEnumCode::HTTP_ERROR,"订单无法删除");
        }

        // 修改订单删除状态
        $data = array();
        $data['is_delete'] = 1;

        $params = array();
        $params['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];

        OrderInquiry::edit($params,$data);

        return success();
    }

    /**
     * 问诊订单取消支付
     * @return array
     */
    public function putPatientInquiryOrderCancelPay(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_inquiry_id = $this->request->route('order_inquiry_id');

        // 获取订单数据
        $params = array();
        $params['patient_id'] = $user_info['client_user_id'];
        $params['order_inquiry_id'] = $order_inquiry_id;
        $params['is_delete'] = 0;
        $order_inquiry = OrderInquiry::getOne($params);
        if (empty($order_inquiry)){
            return fail();
        }

        // 检测订单状态
        if ($order_inquiry['inquiry_status'] != 1) {
            // 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消）
            return fail(HttpEnumCode::HTTP_ERROR,"订单无法取消支付");
        }

        if (!in_array($order_inquiry['inquiry_refund_status'],[0,4,5])) {
            // 问诊订单退款状态（0:无退款 1:申请退款 2:退款中 3:退款成功 4:拒绝退款 5:退款关闭）
            return fail(HttpEnumCode::HTTP_ERROR,"订单正在退款中");
        }

        // 修改订单状态
        $data = array();
        $data['inquiry_status'] = 7;
        $data['cancel_time'] = date("Y-m-d H:i:s",time());
        $data['cancel_reason'] = 2; // 取消订单原因（1:医生未接诊 2:主动取消 3:无可分配医生 4:客服取消 5:支付超时）
        $data['cancel_remarks'] = "主动取消";
        $data['updated_at'] = date("Y-m-d H:i:s",time());

        $params = array();
        $params['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
        OrderInquiry::edit($params,$data);

        return success();
    }

    /**
     * 获取药品订单列表
     * @return array
     */
    public function getPatientProductOrderList(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_product_status = $this->request->input('order_product_status',0);
        $family_id = $this->request->input('family_id');
        $page = $this->request->input('page',1);
        $per_page = $this->request->input('per_page',10);


        $params = array();
        $params['patient_id'] = $user_info['client_user_id'];
        if (!empty($family_id)){
            $params['family_id'] = $family_id;
        }

        if (!empty($inquiry_status_params) && $inquiry_status_params != 0){
            // 入参订单状态（1:待支付 2:待发货 3:已发货 4:已签收 5:已取消）
            // 数据库订单状态（1:待支付 2:待发货 3:已发货 4:已签收 5:已取消）
            $params['inquiry_status_params'] = $order_product_status;
        }

        $params['is_delete'] = 0;

        $fields = [
            'order_product_id',
            'order_inquiry_id',
            'order_prescription_id',
            'doctor_id',
            'patient_id',
            'family_id',
            'order_product_status',
            'pay_status',
            'cancel_reason',
            'remarks',
            'refund_status',
            'cancel_remarks',
            'created_at',
        ];

        $order_product = OrderProduct::getPatientOrderProductPage($params,$fields,$page,$per_page);
        if (empty($order_product['data'])){
            return success();
        }

        foreach ($order_product['data'] as $item){
            foreach ($item['orderProductItem'] as &$product_item){
                $product_item['product_cover_img'] = addAliyunOssWebsite($product_item['product_cover_img']);
            }
        }

        return success($order_product);
    }

    /**
     * 获取药品订单详情
     * @return array
     */
    public function getPatientProductOrderInfo(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_product_id = $this->request->route('order_product_id');

        // 获取订单数据
        $params = array();
        $params['patient_id'] = $user_info['client_user_id'];
        $params['order_product_id'] = $order_product_id;
        $params['is_delete'] = 0;
        $order_product = OrderProduct::getOne($params);
        if (empty($order_product)){
            return fail();
        }

        $params = array();
        $params['order_product_id'] = $order_product['order_product_id'];
        $order_product_item = OrderProductItem::getList($params);
        if (empty($order_product_item)){
            return fail();
        }

        // 处理商品图片
        foreach ($order_product_item as &$item){
            $item['product_cover_img'] = addAliyunOssWebsite($item['product_cover_img']);
        }

        if (!empty($order_product['doctor_id'])){
            // 获取问诊医生数据
            $fields = [
                'doctor_id',
                'user_name',
                'multi_point_status',
                'avatar',
                'doctor_title',
                'department_custom_name',
                'be_good_at',
            ];

            $params = array();
            $params['doctor_id'] = $order_product['doctor_id'];
            $user_doctor = UserDoctor::getWithHospitalOne($params,$fields);
            if (empty($user_doctor)){
                return fail(HttpEnumCode::SERVER_ERROR);
            }

            $user_doctor['avatar'] = addAliyunOssWebsite($user_doctor['avatar']);
        }

        $result = array();
        $result['user_doctor'] = $user_doctor ?? [];
        $result['order_product'] = $order_product;
        $result['order_product_item'] = $order_product_item;

        return success($result);
    }

    /**
     * 药品订单取消支付
     * @return array
     */
    public function putPatientProductOrderCancelPay(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_product_id = $this->request->route('order_product_id');

        Db::beginTransaction();

        try {
            // 获取药品订单数据
            $params = array();
            $params['patient_id'] = $user_info['client_user_id'];
            $params['order_product_id'] = $order_product_id;
            $params['is_delete'] = 0;
            $order_product = OrderProduct::getOne($params);
            if (empty($order_product)){
                Db::rollBack();
                return fail();
            }

            // 检测订单状态
            if ($order_product['order_product_status'] != 1) {
                Db::rollBack();
                // 订单状态（1:待支付 2:待发货 3:已发货 4:已签收 5:已取消）
                return fail(HttpEnumCode::HTTP_ERROR,"订单无法删除");
            }

            if ($order_product['pay_status'] != 1) {
                Db::rollBack();
                // 订单状态（1:待支付 2:待发货 3:已发货 4:已签收 5:已取消）
                return fail(HttpEnumCode::HTTP_ERROR,"订单无法删除");
            }

            if (!in_array($order_product['refund_status'],[0,4,5])) {
                Db::rollBack();
                // 商品订单退款状态（0:无退款 1:申请退款 2:退款中 3:退款成功 4:拒绝退款 5:退款关闭）
                return fail(HttpEnumCode::HTTP_ERROR,"订单正在退款中");
            }

            // 修改订单状态
            $data = array();
            $data['order_product_status'] = 5;
            $data['cancel_time'] = date("Y-m-d H:i:s",time());
            $data['cancel_reason'] = 1; // 订单取消原因（1:主动取消 2:复核失败/库存不足 3:支付超时
            $data['cancel_remarks'] = "主动取消";
            $data['updated_at'] = date("Y-m-d H:i:s",time());

            $params = array();
            $params['order_inquiry_id'] = $order_product['order_inquiry_id'];
            OrderProduct::edit($params,$data);

            Db::commit();
        } catch (\Exception $e) {
            Db::rollBack();
            return fail(HttpEnumCode::HTTP_ERROR, $e->getMessage());
        }

        return success();
    }

    /**
     * 删除药品订单
     * 已收货
     * 取消订单
     * @return array
     */
    public function deletePatientProductOrder(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_product_id = $this->request->route('order_product_id');

        // 获取订单数据
        $params = array();
        $params['patient_id'] = $user_info['client_user_id'];
        $params['order_product_id'] = $order_product_id;
        $params['is_delete'] = 0;
        $order_product = OrderProduct::getOne($params);
        if (empty($order_product)){
            return fail();
        }

        if (!in_array($order_product['order_product_status'],[4,5])) {
            Db::rollBack();
            // 订单状态（1:待支付 2:待发货 3:已发货 4:已签收 5:已取消）
            return fail(HttpEnumCode::HTTP_ERROR,"订单无法删除");
        }

        // 修改订单状态
        $data = array();
        $data['order_product_status'] = 5;
        $data['cancel_time'] = date("Y-m-d H:i:s",time());
        $data['cancel_reason'] = 1; // 订单取消原因（1:主动取消 2:复核失败/库存不足 3:支付超时
        $data['cancel_remarks'] = "主动取消";
        $data['updated_at'] = date("Y-m-d H:i:s",time());

        $params = array();
        $params['order_inquiry_id'] = $order_product['order_inquiry_id'];
        OrderProduct::edit($params,$data);

        return success();
    }

    /**
     * 获取患者订单支付数据
     * @return array
     * @throws ContainerExceptionInterface
     * @throws NotFoundExceptionInterface
     */
    public function getPatientOrderPayInfo(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_type = $this->request->input('order_type');
        $order_no = $this->request->input('order_no');

        if ($order_type == 1){
            // 问诊订单
            $params = array();
            $params['inquiry_no'] = $order_no;
            $params['patient_id'] = $user_info['client_user_id'];
            $order_inquiry = OrderInquiry::getOne($params);
            if (empty($order_inquiry)){
                return fail(HttpEnumCode::HTTP_ERROR,"非法订单");
            }

            // 验证订单状态
            if ($order_inquiry['inquiry_status'] != 1){
                return fail(HttpEnumCode::HTTP_ERROR,"订单状态错误");
            }

            // 验证订单支付状态
            if ($order_inquiry['inquiry_pay_status'] != 1){
                return fail(HttpEnumCode::HTTP_ERROR,"订单支付状态错误");
            }

            $order_id = $order_inquiry['order_inquiry_id'];
            $created_at = $order_inquiry['created_at'];
            $inquiry_type = $order_inquiry['inquiry_type'];

            // 获取订单金额
            $amount_total = $order_inquiry['amount_total'];
            $payment_amount_total = $order_inquiry['payment_amount_total'];
            $coupon_amount_total = $order_inquiry['coupon_amount_total'];

        }elseif ($order_type == 2){
            // 药品订单
            $params = array();
            $params['order_product_no'] = $order_no;
            $params['patient_id'] = $user_info['client_user_id'];
            $order_product = OrderProduct::getOne($params);
            if (empty($order_product)){
                return fail(HttpEnumCode::HTTP_ERROR,"非法订单");
            }

            // 验证订单状态
            if ($order_product['order_product_status'] != 1){
                return fail(HttpEnumCode::HTTP_ERROR,"订单状态错误");
            }

            // 验证订单支付状态
            if ($order_product['inquiry_pay_status'] != 1){
                return fail(HttpEnumCode::HTTP_ERROR,"订单支付状态错误");
            }

            $order_id = $order_product['order_product_id'];
            $created_at = $order_product['created_at'];
            $inquiry_type = 0;

            // 获取订单金额
            $amount_total = $order_product['amount_total'];
            $payment_amount_total = $order_product['payment_amount_total'];
            $coupon_amount_total = 0;
        }else{
            return fail();
        }

        // 发起支付
        $WechatPay = new WechatPay(1);

        // 获取预支付交易会话标识
        $prepay = $WechatPay->getJsapiPrepayId($order_no, $payment_amount_total * 100, $user_info['open_id']);
        if (empty($prepay)) {
            return fail(HttpEnumCode::SERVER_ERROR);
        }

        // 获取小程序支付配置
        $pay_config = $WechatPay->getAppletsPayConfig($prepay['prepay_id']);

        $result = array();
        $result['amount_total'] = $amount_total; // 订单金额
        $result['payment_amount_total'] = $payment_amount_total; // 实际订单金额
        $result['coupon_amount_total'] = $coupon_amount_total; // 优惠金额
        $result['order_no'] = $order_no; // 订单编号
        $result['order_id'] = $order_id; // 订单主键id（问诊订单：order_inquiry_id 药品订单：order_product_id）
        $result['created_at'] = $created_at; // 创建时间
        $result['inquiry_type'] = $inquiry_type; // 订单类型（1:专家问诊 2:快速问诊 3:公益问诊 4:问诊购药）
        $result['pay_config'] = $pay_config; // 小程序支付配置

        return success($result);
    }

    // 创建药品订单
    public function addPatientProductOrder(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_prescription_id = $this->request->input('order_prescription_id');
        $address_id = $this->request->input('address_id');

        // 获取处方数据
        $params = array();
        $params['order_prescription_id'] = $order_prescription_id;
        $params['patient_id'] = $user_info['client_user_id'];
        $params['is_delete'] = 0;
        $order_prescription = OrderPrescription::getOne($params);
        if (empty($order_prescription)){
            return fail();
        }

        // 验证处方状态
        if ($order_prescription['prescription_status'] == 1){
            return fail(HttpEnumCode::HTTP_ERROR,"处方未审核");
        }

        if ($order_prescription['prescription_status'] == 3){
            return fail(HttpEnumCode::HTTP_ERROR,"已失效");
        }
        if ($order_prescription['prescription_status'] == 4){
            return fail(HttpEnumCode::HTTP_ERROR,"已使用");
        }

        if ($order_prescription['pharmacist_audit_status'] != 1){
            return fail(HttpEnumCode::HTTP_ERROR,"处方未审核");
        }

        // 检测是否已经存在药品订单数据
        $params = array();
        $params['order_inquiry_id'] = $order_prescription['order_inquiry_id'];
        $params['order_prescription_id'] = $order_prescription['order_prescription_id'];
        $params['patient_id'] = $user_info['client_user_id'];
        $order_product = OrderProduct::getExists($params);
        if ($order_product){
            return fail(HttpEnumCode::HTTP_ERROR,"处方已使用");
        }

        // 获取处方药品数据
        $params = array();
        $params['order_prescription_id'] = $order_prescription['order_prescription_id'];
        $order_prescription_product = OrderPrescriptionProduct::getList($params);
        if (empty($order_prescription_product)){
            return fail(HttpEnumCode::HTTP_ERROR,"处方药品错误");
        }

        // 检测收货地址
        $params = array();
        $params['user_id'] = $user_info['user_id'];
        $params['address_id'] = $address_id;
        $user_ship_address = UserShipAddress::getOne($params);
        if (empty($user_ship_address)){
            return fail(HttpEnumCode::HTTP_ERROR,"收货地址错误");
        }


        $amount_total = 0;
        $coupon_amount_total = 0;
        $logistics_fee = 0; // 运费金额

        // 检测药品是否存在，库存是否足够,获取订单金额
        foreach ($order_prescription_product as $value){
            $params = array();
            $params['product_id'] = $value['product_id'];
            $product = Product::getOne($params);
            if (empty($product)){
                return fail(HttpEnumCode::HTTP_ERROR,"处方存在未知药品");
            }

            $amount_total += $product['product_price'];
        }

        // 获取运费金额

        // 实际支付金额
        $payment_amount_total = $amount_total + $logistics_fee;

        Db::beginTransaction();

        $generator = $this->container->get(IdGeneratorInterface::class);

        try {
            // 新增药品订单
            $data = array();
            $data['order_inquiry_id'] = $order_prescription['order_inquiry_id'];
            $data['order_prescription_id'] = $order_prescription['order_prescription_id'];
            $data['doctor_id'] = $order_prescription['doctor_id'];
            $data['patient_id'] = $order_prescription['patient_id'];
            $data['family_id'] = $order_prescription['family_id'];
            $data['order_product_no'] = $generator->generate();
            $data['order_product_status'] = 1; // 订单状态（1:待支付 2:待发货 3:已发货 4:已签收 5:已取消）
            $data['amount_total'] = $amount_total; // 订单金额
            $data['payment_amount_total'] = $payment_amount_total; // 实际付款金额
            $data['logistics_fee'] = $logistics_fee; // 运费金额
            $data['province_id'] = $user_ship_address['province_id'];
            $data['province'] = $user_ship_address['province'];
            $data['city_id'] = $user_ship_address['city_id'];
            $data['city'] = $user_ship_address['city'];
            $data['county_id'] = $user_ship_address['county_id'];
            $data['county'] = $user_ship_address['county'];
            $data['address'] = $user_ship_address['address'];
            $data['address_mask'] = $user_ship_address['address_mask'];
            $data['consignee_name'] = $user_ship_address['consignee_name'];
            $data['consignee_name_mask'] = $user_ship_address['consignee_name_mask'];
            $data['consignee_tel'] = $user_ship_address['consignee_tel'];
            $data['consignee_tel_mask'] = $user_ship_address['consignee_tel_mask'];
            $order_product = OrderProduct::addOrderProduct($data);
            if (empty($order_product)){
                Db::rollBack();
                return fail(HttpEnumCode::SERVER_ERROR);
            }

            // 新增药品订单详情
            foreach ($order_prescription_product as $item){
                $params = array();
                $params['product_id'] = $item['product_id'];
                $product = Product::getOne($params);
                if (empty($product)){
                    Db::rollBack();
                    return fail(HttpEnumCode::HTTP_ERROR,"处方存在未知药品");
                }

                $data = array();
                $data['order_product_id'] = $order_product['order_product_id'];
                $data['order_inquiry_id'] = $order_prescription['order_inquiry_id'];
                $data['order_prescription_id'] = $order_prescription['orderorder_prescription_id_inquiry_id'];
                $data['product_id'] = $item['product_id'];
                $data['product_name'] = $item['product_name'];
                $data['product_price'] = $product['product_price'];
                $data['product_platform_code'] = $product['product_platform_code'];
                $data['amount'] = $item['prescription_product_num'];
                $data['manufacturer'] = $item['manufacturer'];
                $data['product_cover_img'] = $product['product_cover_img'];
                $data['product_spec'] = $item['product_spec'];
                $order_product_item = OrderProductItem::addOrderProductItem($data);
                if (!empty($order_product_item)){
                    Db::rollBack();
                    return fail(HttpEnumCode::SERVER_ERROR);
                }
            }

            // 修正处方使用状态
            $data = array();
            $data['prescription_status'] = 4;

            $params = array();
            $params['order_prescription_id'] = $order_prescription['order_prescription_id'];
            OrderPrescription::edit($params,$data);

            // 增加至取消订单延迟队列
            $data = array();
            $data['order_no'] = $order_product['order_product_no'];
            $data['order_type'] = 2;

            $message = new CancelUnpayOrdersDelayDirectProducer($data);
            $message->setDelayMs(1000 * 60 * 30);
            $producer = $this->container->get(Producer::class);
            $res = $producer->produce($message);
            if (!$res) {
                Db::rollBack();
                return fail(HttpEnumCode::SERVER_ERROR, "订单创建失败");
            }
            Db::commit();
        } catch (\Exception $e) {
            Db::rollBack();
            return fail(HttpEnumCode::SERVER_ERROR, $e->getMessage());
        }


        return success();
    }

    /**
     * 获取处方订单列表
     * @return array
     */
    public function getPatientPrescriptionOrderList(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];
        $page = $this->request->input('page',1);
        $per_page = $this->request->input('per_page',10);

        // 获取处方数据
        $params = array();
        $params['patient_id'] = $user_info['client_user_id'];
        $params['pharmacist_audit_status'] = 1;
        $params['platform_audit_status'] = 1;
        $params['is_delete'] = 0;
        $order_prescription = OrderPrescription::getWithPage($params,['*'],$page,$per_page);
        if (!empty($order_prescription['data'])){
            foreach ($order_prescription['data'] as &$item){
                if (!empty($item['UserDoctor'])){
                    $item['UserDoctor']['doctor_title'] = DoctorTitleCode::getMessage($item['UserDoctor']['doctor_title']);
                }
            }
        }

        return success($order_prescription);
    }

    /**
     * 获取处方订单详情
     * @return array
     */
    public function getPatientPrescriptionOrderInfo(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_prescription_id = $this->request->route('order_prescription_id');

        // 获取处方数据
        $fields = [
            'order_prescription_id',
            'prescription_status',
            'prescription_img',
        ];
        $params = array();
        $params['order_prescription_id'] = $order_prescription_id;
        $params['patient_id'] = $user_info['client_user_id'];
        $params['pharmacist_audit_status'] = 1;
        $params['platform_audit_status'] = 1;
        $params['is_delete'] = 0;
        $order_prescription = OrderPrescription::getOne($params,$fields);
        if (empty($order_prescription)){
            return fail();
        }

        $order_prescription['prescription_img'] = addAliyunOssWebsite($order_prescription['prescription_img']);

        return success($order_prescription->toArray());
    }

    /**
     * 获取处方订单支付页详情
     * @return array
     */
    public function getPatientPrescriptionOrderPayInfo(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_prescription_id = $this->request->route('order_prescription_id');

        $fields = [
            "order_prescription_id"
        ];

        $params = array();
        $params['order_prescription_id'] = $order_prescription_id;
        $params['patient_id'] = $user_info['client_user_id'];
        $params['is_delete'] = 0;
        $order_prescription = OrderPrescription::getOne($params,$fields);
        if (empty($order_prescription)){
            return fail();
        }

        // 验证处方状态
        if ($order_prescription['prescription_status'] == 1){
            return fail(HttpEnumCode::HTTP_ERROR,"处方未审核");
        }

        if ($order_prescription['prescription_status'] == 3){
            return fail(HttpEnumCode::HTTP_ERROR,"处方已失效");
        }

        if ($order_prescription['prescription_status'] == 4){
            return fail(HttpEnumCode::HTTP_ERROR,"处方已使用");
        }

        // 获取处方药品信息
        $params = array();
        $params['order_prescription_id'] = $order_prescription['order_prescription_id'];
        $order_prescription_product = OrderPrescriptionProduct::getWithProductList($params);
        if (empty($order_prescription_product)){
            return fail(HttpEnumCode::SERVER_ERROR);
        }

        $amount_total = 0;
        $coupon_amount_total = 0;
        $logistics_fee = 0; // 运费金额
        foreach ($order_prescription_product as $item){
            if (!empty($item['Product']['product_price'])){
                $amount_total += $item['Product']['product_price'];
            }
        }

        // 获取运费金额

        // 实际支付金额
        $payment_amount_total = $amount_total + $logistics_fee;

        // 获取收货地址
        $params = array();
        $params['user_id'] = $user_info['user_id'];
        $user_ship_addresss = UserShipAddress::getList($params);

        foreach ($user_ship_addresss as $item){
            if ($item['is_default'] == 1){
                $user_ship_address = $item;
            }
        }

        // 无默认地址，选择第一个
        if (empty($user_ship_address)){
            $user_ship_address = $user_ship_addresss[0] ?? [];
        }

        $result = array();
        $result['amount_total'] = $amount_total;
        $result['coupon_amount_total'] = $coupon_amount_total;
        $result['payment_amount_total'] = $payment_amount_total;
        $result['logistics_fee'] = $logistics_fee;
        $result['user_ship_address'] = $user_ship_address;

        return success($result);
    }

    /**
     * 删除处方订单记录
     * @return array
     */
    public function deletePatientPrescriptionOrder(): array
    {
        $user_info = $this->request->getAttribute("userInfo") ?? [];

        $order_prescription_id = $this->request->route('order_prescription_id');

        $params = array();
        $params['order_prescription_id'] = $order_prescription_id;
        $params['patient_id'] = $user_info['client_user_id'];
        $order_prescription = OrderPrescription::getOne($params);
        if (empty($order_prescription)){
            return fail();
        }

        // 验证处方状态
        if ($order_prescription['prescription_status'] == 1){
            return fail(HttpEnumCode::HTTP_ERROR,"处方无法删除");
        }

        if ($order_prescription['is_delete'] == 1){
            return success();
        }

        $data = array();
        $data['is_delete'] = 1;

        $params = array();
        $params['order_prescription_id'] = $order_prescription['order_prescription_id'];
        OrderPrescription::edit($params,$data);

        return success();
    }
}