<?php

namespace app\listener\order;

use app\jobs\MiniOrderJob;
use app\model\order\StoreOrder;
use app\services\order\StoreOrderCartInfoServices;
use app\services\order\StoreOrderServices;
use app\services\wechat\WechatUserServices;
use crmeb\exceptions\AdminException;
use crmeb\interfaces\ListenerInterface;
use crmeb\services\easywechat\orderShipping\MiniOrderService;

class OrderShippingListener implements ListenerInterface
{
    public function handle($event): void
    {
        /** @var StoreOrder $order */
        [$order_type, $order, $delivery_type, $delivery_id, $delivery_code] = $event;
        $order_shipping_open = sys_config('order_shipping_open', 0);  // 小程序发货信息管理服务开关
        $secs = 0;
        if ($order && $order_shipping_open) {
            //判断订单是否拆单
            $delivery_mode = 1;
            $is_all_delivered = true;
            if ($order_type == 'product') {  // 商品订单
                if ($order['is_channel'] == 1 && $order['pay_type'] == 'weixin') {
                    $out_trade_no = $order['order_id'];
                    /** @var StoreOrderCartInfoServices $orderInfoServices */
                    $orderInfoServices = app()->make(StoreOrderCartInfoServices::class);
                    $item_desc = $orderInfoServices->getCarIdByProductTitle((int)$order['id'], true);

                    if ($order['pid'] > 0) {
                        $delivery_mode = 2;
                        // 判断订单是否全部发货
                        /** @var StoreOrderServices $orderServices */
                        $orderServices = app()->make(StoreOrderServices::class);
                        $is_all_delivered = $orderServices->checkSubOrderNotSend((int)$order['pid'], (int)$order['id']);
                        $p_order = $orderServices->get((int)$order['pid']);
                        if (!$p_order) {
                            throw new AdminException('拆单异常');
                        }
                        $out_trade_no = $p_order['order_id'];
                    }
                    $pay_uid = $order['pay_uid'];
                    $path = 'pages/goods/order_details/index?order_id=' . $out_trade_no;
                } else {
                    return;
                }
            } else if ($order_type == 'recharge') {  // 充值订单
                if ($order['recharge_type'] == 'weixin') {
                    $delivery_type = 3;
                    $item_desc = '用户充值' . $order['price'];
                    $out_trade_no = $order['order_id'];
                    $pay_uid = $order['uid'];
                    $secs = 10;
                    $path = '/pages/users/user_bill/index?type=2';
                } else {
                    return;
                }
            } else if ($order_type == 'member') {  // 会员订单
                if ($order['pay_type'] == 'weixin') {
                    $delivery_type = 3;
                    $item_desc = '用户购买' . $order['member_type'] . '会员卡';
                    $out_trade_no = $order['order_id'];
                    $pay_uid = $order['uid'];
                    $secs = 10;
                    $path = '/pages/annex/vip_paid/index';
                } else {
                    return;
                }
            } else {
                return;
            }
            // 整理商品信息
            $shipping_list = [
                ['item_desc' => $item_desc]
            ];
            //判断订单物流模式
            if (!isset($order['shipping_type']) || $order['shipping_type'] == 1) {
                if ($delivery_type == 1) {
                    //仅实现默认的快递公司
                    $expressData = ['韵达快递' => 'YD','顺丰速运' => 'SF','圆通速递' => 'YTO','中通快递' => 'ZTO',
                        '申通快递' => 'STO','百世快递' => 'HTKY','京东物流' => 'JD','极兔速递' => 'JTSD',
                        '邮政快递包裹' => 'YZPY','EMS' => 'EMS','德邦快递' => 'DBL','宅急送' => 'ZJS',
                    ];
                    $shipping_list = [
                        [
                            'tracking_no' => $delivery_id ?? '',
                            'express_company' => $delivery_code,
                            'item_desc' => $item_desc,
                            'contact' => [
                                'receiver_contact' => $order['user_phone']
                            ]
                        ]
                    ];
                }
                $logistics_type = $delivery_type;
            } else {
                $logistics_type = 4;
            }
            //查找支付者openid
            /** @var WechatUserServices $wechatUserService */
            $wechatUserService = app()->make(WechatUserServices::class);
            $payer_openid = $wechatUserService->uidToOpenid($pay_uid, 'routine');
            if (empty($payer_openid)) {
                throw new AdminException('订单支付人异常');
            }
            if ($secs) {
                MiniOrderJob::dispatchSecs($secs, 'doJob', [$out_trade_no, $logistics_type, $shipping_list, $payer_openid, $path, $delivery_mode, $is_all_delivered]);
            } else {
                MiniOrderJob::dispatch('doJob', [$out_trade_no, $logistics_type, $shipping_list, $payer_openid, $path, $delivery_mode, $is_all_delivered]);
            }
        }
    }
}
