hospital-applets-api/app/Command/ReportPreProductOrderCommand.php

<?php

declare(strict_types=1);

namespace App\Command;

use App\Model\OrderPrescription;
use App\Model\OrderProduct;
use App\Model\UserPatient;
use App\Services\MessagePush;
use App\Services\OrderPrescriptionService;
use App\Services\OrderProductService;
use App\Utils\Log;
use Hyperf\Command\Command as HyperfCommand;
use Hyperf\Command\Annotation\Command;
use Hyperf\DbConnection\Db;
use Hyperf\Redis\Redis;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\ContainerInterface;
use Psr\Container\NotFoundExceptionInterface;

/**
 * 商品订单上报处方平台
 * 此处单商品订单上报两次
 */
#[Command]
class ReportPreProductOrderCommand extends HyperfCommand
{
    public function __construct(protected ContainerInterface $container)
    {
        parent::__construct('ReportPreProductOrder:command');
    }

    public function configure()
    {
        parent::configure();
        $this->setDescription('上报处方平台商品订单');
    }

    /**
     * @throws ContainerExceptionInterface
     * @throws NotFoundExceptionInterface
     */
    public function handle()
    {
        $this->line("开始");

        try {
            // 获取可上报商品订单
            $order_product_ids = $this->getExecProductOrder();
            if (empty($order_product_ids)){
                $this->line("结束，无可上报的商品订单");
                return;
            }

            // 获取缓存
            $redis = $this->container->get(Redis::class);
        } catch (\Exception $e) {
            $this->line("错误：" . $e->getMessage());
            return;
        }

        foreach ($order_product_ids as $item){
            $this->line("本次请求订单号：" . $item['order_product_id']);

            Db::beginTransaction();

            try {
                // 检测执行次数
                $res = $this->checkHandleNumber($item['order_product_id']);
                if (!$res) {
                    Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：超出最大执行次数或检测错误");

                    // 修改药品订单表上报处方平台状态
                    $this->saveOrderProductPeportPreStatus($item['order_product_id'],2,"超出最大上报次数");

                    // 修改失败时药品订单数据
                    $this->savePreFailedOrderStatus($item['order_product_id'],"复核失败");

                    // 退款
                    $OrderProductService = new OrderProductService();
                    $OrderProductService->OrderProductRefund($item['order_product_id'],"药品订单退款");

                    Db::commit();
                    continue;
                }
            }catch(\Exception $e){
                Db::rollBack();
                // 记录失败次数
                $this->line("错误：" . $e->getMessage());
                continue;
            }

            try {
                // 上报处方平台
                $orderPrescriptionService = new OrderPrescriptionService();
                $orderPrescriptionService->reportPrescription($item['order_product_id']);

                // 修改药品订单表上报处方平台状态
                $this->saveOrderProductPeportPreStatus($item['order_product_id'],1);

                $this->line("成功");
                Db::commit();
                continue;
            } catch (\Exception $e) {
                Db::rollBack();
                $this->line("错误" . $e->getMessage());
                continue;
            }
        }
        $this->line("全部结束");
    }

    /**
     * 获取可上报商品订单
     * @return array
     */
    protected function getExecProductOrder(): array
    {
        $params = array();
        $params['order_product_status'] = 2; // 订单状态（1:待支付 2:待发货 3:已发货 4:已签收 5:已取消）
        $params['pay_status'] = 2; // 支付状态（1:未支付 2:已支付 3:支付中 4:支付失败 5:支付超时 6:支付关闭 7:已撤销 8:转入退款）
        $params['refund_status'] = 0; // 商品订单退款状态（0:无退款 1:申请退款 2:退款中 3:退款成功 4:拒绝退款 5:退款关闭  6:退款异常）
        $params['report_pre_status'] = 0; // 上报处方平台状态（0:未上报 1:已上报 2:上报失败））

        $fields = [
            'order_product_id',
            'user_id',
            'patient_id',
            'order_prescription_id',
        ];

        $order_product = OrderProduct::getList($params,$fields);
        if (empty($order_product)){
            return [];
        }

        return $order_product->toArray();
    }

    /**
     * 修改药品订单表上报处方平台状态
     * @param string $order_product_id
     * @param int $report_pre_status
     * @param string $report_pre_fail_reason
     * @return void
     */
    protected function saveOrderProductPeportPreStatus(string $order_product_id,int $report_pre_status,string $report_pre_fail_reason = ""): void
    {
        $params = array();
        $params['order_product_id'] = $order_product_id;

        $data = array();
        $data['report_pre_status'] = $report_pre_status; // 上报处方平台状态（0:未上报 1:已上报 2:上报失败））
        $data['report_pre_time'] = date('Y-m-d H:i:s',time()); // 上报处方平台时间
        if (!empty($report_pre_fail_reason)){
            $data['report_pre_fail_reason'] = ""; // 上报失败原因 置为空
        }

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

    /**
     * 修改失败时药品订单数据
     * @param string $order_product_id
     * @param string $cancel_remarks
     */
    protected function savePreFailedOrderStatus(string $order_product_id,string $cancel_remarks)
    {
        // 订单状态（1:待支付 2:待发货 3:已发货 4:已签收 5:已取消）
        $params = array();
        $params['order_product_id'] = $order_product_id;

        $data['order_product_status'] = 5;
        $data['cancel_reason'] = 2; // 订单取消原因（1:主动取消 2:复核失败/库存不足 3:支付超时 4:客服取消）
        $data['cancel_time'] = date('Y-m-d H:i:s'); // 订单取消时间
        $data['cancel_remarks'] = $cancel_remarks; // 订单取消备注（自动添加）
        OrderProduct::edit($params,$data);
    }

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

            $redis_key = "ReportPreProductOrder" . $order_product_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;
    }
}