新增im清除会话接口，新增定时商品订单上报处方平台

2023-04-11 17:20:58 +08:00
parent 179977ec26
commit 3e577c8cac
8 changed files with 240 additions and 32 deletions
@@ -0,0 +1,142 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Command;
+
+use App\Model\OrderProduct;
+use App\Services\OrderPrescriptionService;
+use Hyperf\Command\Command as HyperfCommand;
+use Hyperf\Command\Annotation\Command;
+use Hyperf\Redis\Redis;
+use Psr\Container\ContainerInterface;
+
+/**
+ * 上报处方平台商品订单
+ * 此处单商品订单上报两次
+ */
+#[Command]
+class ReportPreProductOrderCommand extends HyperfCommand
+{
+    public function __construct(protected ContainerInterface $container)
+    {
+        parent::__construct('ReportPreProductOrder:command');
+    }
+
+    public function configure()
+    {
+        parent::configure();
+        $this->setDescription('上报处方平台商品订单');
+    }
+
+    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){
+            $redis_key = "ReportPreProductOrder" . $item['order_product_id'];
+
+            try {
+                $redis_value = $redis->get($redis_key);
+                if(!empty($redis_value)){
+                    if ($redis_value > 2){
+                        // 超出最大执行次数
+                        $this->savaReportFail($item['order_product_id']);
+                    }
+                }
+
+                // 上报处方平台
+                $orderPrescriptionService = new OrderPrescriptionService();
+                $orderPrescriptionService->reportPrescription($item['order_product_id']);
+
+                // 存储上报成功
+                $this->savaReportSuccess($item['order_product_id']);
+
+                // 清空缓存
+                $redis->del($redis_key);
+            } catch (\Exception $e) {
+                // 记录失败次数
+                $redis->incr($redis_key);
+                $this->line("上报处方平台商品订单失败：" . $e->getMessage());
+                $this->savaReportFail($item['order_product_id'],$e->getMessage());
+            }
+
+            $this->line("商品订单上报处方平台成功：商品单号" . $item['order_product_id']);
+            return;
+        }
+    }
+
+    /**
+     * 获取可上报商品订单
+     * @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',
+        ];
+
+        $order_product = OrderProduct::getList($params,$fields);
+        if (empty($order_product)){
+            return [];
+        }
+
+        return $order_product->toArray();
+    }
+
+    /**
+     * 存储上报失败
+     * @param string $order_product_id 商品订单id
+     * @param string $report_pre_fail_reason 上报失败原因
+     * @return void
+     */
+    protected function savaReportFail(string $order_product_id,string $report_pre_fail_reason = ""): void
+    {
+        $params = array();
+        $params['order_product_id'] = $order_product_id;
+
+        $data = array();
+        $data['report_pre_status'] = 2; // 上报处方平台状态（0:未上报 1:已上报 2:上报失败））
+        if (!empty($report_pre_fail_reason)){
+            $data['report_pre_fail_reason'] = $report_pre_fail_reason;
+        }
+        OrderProduct::edit($params,$data);
+    }
+
+    /**
+     * 存储上报成功
+     * @param string $order_product_id 商品订单id
+     * @return void
+     */
+    protected function savaReportSuccess(string $order_product_id): void
+    {
+        $params = array();
+        $params['order_product_id'] = $order_product_id;
+
+        $data = array();
+        $data['report_pre_status'] = 1; // 上报处方平台状态（0:未上报 1:已上报 2:上报失败））
+        $data['report_pre_time'] = date('Y-m-d H:i:s',time()); // 上报处方平台时间
+        $data['report_pre_fail_reason'] = ""; // 上报失败原因 置为空
+        OrderProduct::edit($params,$data);
+    }
+}