<?php

namespace app\mall\logic;


use app\base\logic\Freight;
use app\base\model\user\User;
use app\base\model\user\UserAddress;
use app\base\model\user\UserInfo;
use app\discount\model\DiscountCouponMy;
use app\discount\service\MyCoupon;
use app\distribution\logic\Commission;
use app\distribution\model\DistributionCommissionIncome;
use app\distribution\model\DistributionConfig;
use app\mall\model\MallCart;
use app\mall\model\MallConfig;
use app\mall\model\MallEvaluate;
use app\mall\model\MallOrder;
use app\mall\model\MallOrderCoupon;
use app\mall\model\MallOrderProduct;
use app\mall\model\MallOrderRefund;
use app\mall\model\MallProduct;
use app\mall\model\MallProductSku;
use app\mall\model\MallRefundCause;
use app\mall\model\MallSpikeProduct;
use app\mall\model\MallSpikeProductSku;
use app\money\logic\Money;
use Godruoyi\Snowflake\Snowflake;
use kdniao\Logistics;
use think\facade\Db;
use think\facade\Request;

class Order extends Base
{

    /**
     * 获取下单数据（通过产品 地址 优惠券 整合各类价钱）
     * @param int $buy_type 购买类型 1--购物车 2--立即购买
     * @param int $my_address_id 我的地址ID
     * @param int $product_id buy_type=2时，产品ID
     * @param string $product_sku buy_type=2时，产品SKU
     * @param int $number buy_type=2时，购买数量
     * @param int $is_choose_default_coupon 是否选择默认的最大可选优惠券
     * @param int $my_coupon_id 我的优惠券ID
     * @param int $type 下单类型 1--商城 2--秒杀商城
     * @param int $spike_product_id type=2时，秒杀产品ID
     * @date 2022-10-13
     */
    public function getOrderReady($buy_type, $my_address_id, $product_id, $product_sku, $number, $is_choose_default_coupon, $my_coupon_id, $type, $spike_product_id)
    {
        $address_model = new UserAddress();
        $config_model = new MallConfig();
        $coupon_my_model = new DiscountCouponMy();
        $freight_logic = new Freight();
        $order_service = new \app\mall\service\Order();
        $my_coupon_service = new MyCoupon();

        // 获取我的地址 如果前台传了地址ID，则获取选中地址；否则，获取默认地址
        if (!empty($my_address_id)) {
            // 获取指定地址
            $my_address = $address_model->getAddress($my_address_id);
        } else {
            // 获取默认地址
            $my_address = $address_model->getDefaultAddress();
        }

        // 获取购买的商品
        $order_product = $order_service->getOrderProduct($buy_type, $product_id, $product_sku, $number, $type, $spike_product_id);
        if (empty($order_product)) {
            return sendErrorArray(3001, '无有效商品');
        }

        // 商品总价钱
        $total_price = 0;
        // 运费
        $freight = 0;
        foreach ($order_product as $k => $v) {
            // 总价钱 = 总价钱 + 产品价钱 * 数量
            $total_price += $v['product_price'] * $v['number'];

            // 如果有地址，计算运费
            if (!empty($my_address)) {
                // 运费类型 1--统一运费 2--运费模板
                if ($v['freight_type'] == 2) {
                    $freight += $freight_logic->getFreight($v['freight_id'], $v['weight'], $v['number'], $v['product_price'],
                        isset($my_address['province_id']) ? $my_address['province_id'] : '',
                        isset($my_address['city_id']) ? $my_address['city_id'] : '',
                        isset($my_address['area_id']) ? $my_address['area_id'] : '');
                } else {
                    $freight += $v['freight_money'] * $v['number'];
                }
            }
            unset($order_product[$k]['product_stock']);
            unset($order_product[$k]['freight_type']);
            unset($order_product[$k]['freight_id']);
            unset($order_product[$k]['freight_money']);
            unset($order_product[$k]['weight']);
        }

        // 是否满足整单免运费，满足运费置0
        $free_freight_limit = $config_model->getField('free_freight_limit');
        if ($total_price >= $free_freight_limit) {
            $freight = 0;
        }

        // 优惠券抵用价钱
        $my_coupon_price = 0;

        // 定义选中优惠券信息
        $choose_my_coupon = [];

        // 可以使用的优惠券数量
        $result = $my_coupon_service->listChooseCoupon($total_price);
        $can_choose_coupon_number = count($result['data']['able_list']);

        // 如果有选中优惠券
        if (!empty($my_coupon_id)) {
            $choose_my_coupon = $coupon_my_model->getOneData([
                ['id', '=', $my_coupon_id]
            ], 'id,user_id,price,limit_price,name');
            // 价钱，根据情况显示整数或1位小数
            if ($choose_my_coupon['price'] == round($choose_my_coupon['price'])) {
                $choose_my_coupon['price'] = (string)round($choose_my_coupon['price']);
            }
            $my_coupon_price = $choose_my_coupon['price'];
            // 没有选中优惠券时，默认选取最大面值优惠券
        } else if (!$my_coupon_id && $is_choose_default_coupon == 1) {
            if (!empty($result['data']['able_list'])) {
                $choose_my_coupon_first = $result['data']['able_list'][0];
                $choose_my_coupon = [
                    'id' => $choose_my_coupon_first['id'],
                    'user_id' => $choose_my_coupon_first['user_id'],
                    'price' => $choose_my_coupon_first['price'],
                    'limit_price' => $choose_my_coupon_first['limit_price'],
                    'name' => $choose_my_coupon_first['name']
                ];
                $my_coupon_price = $choose_my_coupon_first['price'];
            }
        }

        // 支付价钱
        $pay_money = ($total_price - (double)$my_coupon_price >= 0 ? $total_price - (double)$my_coupon_price : 0) + $freight;
        $r_data = [
            // 选中优惠券
            'choose_my_coupon' => $choose_my_coupon,
            // 可使用优惠券数量
            'can_choose_coupon_number' => $can_choose_coupon_number,
            // 选中地址
            'my_address' => $my_address,
            // 购买产品
            'order_product' => $order_product,
            // 总价钱
            'total_price' => $total_price,
            // 运费
            'freight' => $freight,
            // 实际付款
            'pay_money' => round($pay_money, 2)
        ];

        return sendSuccessArray($r_data);
    }

    /**
     * 获取下单数据（通过产品 地址 优惠券 整合各类价钱）
     * @param int $buy_type 购买类型 1--购物车 2--立即购买
     * @param int $my_address_id 我的地址ID
     * @param int $product_id buy_type=2时，产品ID
     * @param string $product_sku buy_type=2时，产品SKU
     * @param int $number buy_type=2时，购买数量
     * @param int $my_coupon_id 我的优惠券ID
     * @param int $type 下单类型 1--商城 2--秒杀商城
     * @param int $spike_product_id type=2时，秒杀产品ID
     * @param int $pay_type 支付方式 0--不用支付 1--微信支付 2--支付宝支付 3--余额支付
     * @param string $remark 备注
     * @date 2022-10-21
     */
    public function insertOrder($buy_type, $my_address_id, $product_id, $product_sku, $number, $my_coupon_id, $type, $spike_product_id, $pay_type, $remark)
    {
        $order_model = new MallOrder();
        $order_product_model = new MallOrderProduct();
        $cart_model = new MallCart();
        $address_model = new UserAddress();
        $product_model = new MallProduct();
        $freight_logic = new Freight();
        $config_model = new MallConfig();
        $coupon_my_model = new DiscountCouponMy();
        $snow_flake_class = new Snowflake();
        $order_coupon_model = new MallOrderCoupon();
        $order_service = new \app\mall\service\Order();

        // 获取指定地址
        $my_address = $address_model->getAddress($my_address_id);

        // 获取购买的商品
        $order_product = $order_service->getOrderProduct($buy_type, $product_id, $product_sku, $number, $type, $spike_product_id);
        if (empty($order_product)) {
            return sendErrorArray(3001, '无有效商品');
        }

        // 商品总价钱
        $total_price = 0;
        // 总数量
        $total_number = 0;
        // 运费
        $freight = 0;
        foreach ($order_product as $k => $v) {
            if ($v['number'] > $v['product_stock']) {
                return sendErrorArray(3002, $v['product_name'] . '商品' . $v['product_sku_name'] . '库存不足');
            }

            // 商品快照
            $product_snapshot = $product_model->getOneData([
                ['id', '=', $v['product_id']]
            ])->toArray();

            $order_product_data[] = [
                'id' => $snow_flake_class->id(),
                'uid' => $this->mid,
                'spike_product_id' => isset($v['spike_product_id']) ? $v['spike_product_id'] : '',
                'product_id' => $v['product_id'],
                'product_name' => $v['product_name'],
                'product_cover_img' => $v['product_cover_img'],
                'is_product_spec_open' => $v['is_product_spec_open'],
                'product_sku' => $v['product_sku'],
                'product_sku_name' => $v['product_sku_name'],
                'product_price' => $v['product_price'],
                'number' => $v['number'],
                'total_price' => $v['number'] * $v['product_price'],
                'product_snapshot' => serialize($product_snapshot)
            ];

            // 总价钱 = 总价钱 + 产品价钱 * 数量
            $total_price += $v['product_price'] * $v['number'];
            // 总数量 = 总数量 + 数量
            $total_number += $v['number'];

            // 如果有地址，计算运费
            if (!empty($my_address)) {
                // 运费类型 1--统一运费 2--运费模板
                if ($v['freight_type'] == 2) {
                    $freight += $freight_logic->getFreight($v['freight_id'], $v['weight'], $v['number'], $v['product_price'],
                        $my_address['province_id'], $my_address['city_id'], $my_address['area_id']);
                } else {
                    $freight += $v['freight_money'] * $v['number'];
                }
            }
        }

        // 是否满足整单免运费，满足运费置0
        $free_freight_limit = $config_model->getField('free_freight_limit');
        if ($total_price >= $free_freight_limit) {
            $freight = 0;
        }

        //生成订单数据
        $data = [
            'uid' => $this->mid,
            'user_agent' => $this->userAgent,
            'user_id' => $this->userId,
            'type' => $type,
            'order_number' => $order_model->createOrderNumber('M'),
            // 如果是三方支付，需要下面一行存储请求三方单号
//            'fubei_order_number' => $order_model->createOrderNumber('FM'),
            'remark' => $remark,
            'total_number' => $total_number,
            'total_price' => $total_price,
            'freight' => $freight,
            'pay_type' => $pay_type,
            'linkman' => $my_address['linkman'],
            'mobile_phone' => $my_address['mobile_phone'],
            'province' => $my_address['province'],
            'city' => $my_address['city'],
            'area' => $my_address['area'],
            'address' => $my_address['address'],
            'is_pay' => 0,
            'status' => 1
        ];

        // 优惠券抵用价钱
        $my_coupon_price = 0;
        // 优惠券
        $my_coupon = [];
        // 如果有选中优惠券
        if (!empty($my_coupon_id)) {
            // 优惠券信息
            $my_coupon = $coupon_my_model->getOneData([
                ['id', '=', $my_coupon_id]
            ], 'id,user_id,price,limit_price,name,status,is_forever,end_time')->toArray();
            $my_coupon_price = $my_coupon['price'];

            if ($my_coupon['limit_price'] > $total_price) {
                return sendErrorArray(3003, '优惠券不符合使用要求');
            }

            if ($my_coupon['status'] != 1) {
                return sendErrorArray(3004, '该优惠券已使用');
            }

            if ($my_coupon['is_forever'] == 0 && $my_coupon['end_time'] <= time()) {
                return sendErrorArray(3005, '您选择的优惠券已过期');
            }
        }

        // 优惠券抵扣金额
        $data['coupon_money'] = $my_coupon_price;

        // 实际支付金额 = (产品总价 - 优惠券抵扣金额) + 运费
        $data['pay_money'] = ($total_price - $my_coupon_price >= 0 ? $total_price - $my_coupon_price : 0) + $freight;
        // 特殊情况支付金额小于0时修改为0
        if ($data['pay_money'] < 0) {
            $data['pay_money'] = 0;
        }

        Db::startTrans();

        // 存入订单总表
        $order_id = $order_model->dataUpdate($data);
        if (!$order_id) {
            Db::rollback();
            return sendErrorArray(3006, '生成总订单失败');
        }

        // 批量存入订单商品表
        foreach ($order_product_data as $k => $v) {
            $order_product_data[$k]['order_id'] = $order_id;
            $order_product_data[$k]['create_time'] = time();
            $order_product_data[$k]['update_time'] = time();
        }
        $res = $order_product_model->insertAll($order_product_data);
        if (!$res) {
            Db::rollback();
            return sendErrorArray(3007, '生成订单商品失败');
        }

        // 存入订单优惠券关联表
        if (!empty($my_coupon)) {
            $order_coupon_data[] = [
                'id' => $snow_flake_class->id(),
                'uid' => $this->mid,
                'order_id' => $order_id,
                'coupon_my_id' => $my_coupon['id'],
                'coupon_money' => $my_coupon['price'],
                'create_time' => time(),
                'update_time' => time()
            ];
            $res = $order_coupon_model->insertAll($order_coupon_data);
            if (!$res) {
                Db::rollback();
                return sendErrorArray(3008, '生成订单优惠券失败');
            }

            // 将优惠券改为已使用
            $where = [
                ['id', '=', $my_coupon_id]
            ];
            $res = $coupon_my_model
                ->update([
                    'status' => 2,
                    'use_time' => time()
                ], $where);
            if (!$res !== false) {
                Db::rollback();
                return sendErrorArray(3009, '优惠券状态更改失败');
            }
        }

        // 购物车方式清空购物车
        if ($buy_type == 1) {
            $res = $cart_model->deleteChooseCart($this->userId);
            if (!$res) {
                Db::rollback();
                return sendErrorArray(3010, '清空购物车失败');
            }
        }

        // 下单减少库存
        foreach ($order_product as $k => $v) {
            $res = $order_service->productStockChange($v['product_id'], -$v['number'], $v['product_sku'], $type, $spike_product_id);
            if ($res['code'] != 0) {
                Db::rollback();
                return $res;
            }
        }
        Db::commit();

        // 订单支付金额为0，即不用支付
        if ($data['pay_money'] == 0) {
            $res = $order_service->afterOrderPaySuccess($order_id);
            if ($res['code'] != 0) {
                return $res;
            }
            return sendSuccessArray([
                // 是否需要支付
                'need_pay' => 0
            ]);
        }

        // 调起支付
        $res = $order_service->createPayOrder($order_id);

        if ($res['code'] != 0) {
            return $res;
        }

        return $res;
    }

    /**
     * 获取订单数量
     * @date 2022-12-28
     */
    public function countOrderNumber()
    {
        $order_model = new MallOrder();

        $where1 = [
            ['uid', '=', $this->mid],
            ['user_id', '=', $this->userId],
            ['is_user_delete', '=', 0],
            ['status', '=', 1]
        ];
        $where2 = [
            ['uid', '=', $this->mid],
            ['user_id', '=', $this->userId],
            ['is_user_delete', '=', 0],
            ['status', '=', 2]
        ];
        $where3 = [
            ['uid', '=', $this->mid],
            ['user_id', '=', $this->userId],
            ['is_user_delete', '=', 0],
            ['status', '=', 3]
        ];
        $where4 = [
            ['uid', '=', $this->mid],
            ['user_id', '=', $this->userId],
            ['is_user_delete', '=', 0],
            ['status', '=', 4]
        ];
        $number['wait_pay'] = $order_model->getNumber($where1);
        $number['wait_deliver'] = $order_model->getNumber($where2);
        $number['wait_finish'] = $order_model->getNumber($where3);
        $number['wait_evaluate'] = $order_model->getNumber($where4);

        return sendSuccessArray([
            // 数量
            'number' => $number
        ]);
    }


    /**
     * 订单再支付
     * @param int $order_id 订单ID
     * @param int $pay_type 支付方式 1--微信支付 2--支付宝支付 3--余额支付
     * @date 2022-10-21
     */
    public function rePayOrder($order_id, $pay_type)
    {
        $order_model = new MallOrder();

        $order_service = new \app\mall\service\Order();
        #TODO 秒杀订单判断秒杀时间

        // 生成订单数据
        $data_update = [
            'id' => $order_id,
            'pay_type' => $pay_type
        ];

        $order = $order_model->getOneData([
            ['id', '=', $order_id]
        ], 'id,user_agent,status,order_number');

        // 非待支付状态
        if ($order['status'] != 1) {
            return sendErrorArray(3001, '订单状态不支持支付');
        }

        // 查询单号是否支付
        if ($pay_type == 1) {
            $wxpay_param = get_wxpay_config_with_weixin($order['user_agent']);
            $wxpay_class = new \tencent\wechat\pay\Wxpay($wxpay_param);

            // 查询订单
            $result = $wxpay_class->queryByOutTradeNumber($order['order_number']);
            if ($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS') {
                if ($result['trade_state'] == 'SUCCESS') {
                    return sendErrorArray(3002, '订单已支付');
                }
            }
        }

        Db::startTrans();

        // 存入订单总表
        $order_id = $order_model->dataUpdate($data_update);
        if (!$order_id) {
            Db::rollback();
            return sendErrorArray(3003, '生成总订单失败');
        }

        Db::commit();

        // 调起支付
        $res = $order_service->createPayOrder($order_id);
        if ($res['code'] != 0) {
            return $res;
        }

        return $res;
    }

    /**
     * 订单取消
     * @param int $order_id 订单ID
     * @param int $user_id 操作用户ID
     * @param int $type 操作类型 1--用户操作 2--后台操作 3--定时
     * @date 2022-10-31
     */
    public function cancelOrder($order_id, $user_id = '', $type = 1)
    {
        $order_model = new MallOrder();
        $order_product_model = new MallOrderProduct();
        $coupon_my_model = new DiscountCouponMy();
        $order_coupon_model = new MallOrderCoupon();
        $order_service = new \app\mall\service\Order();

        // 获取订单信息
        $order = $order_model->getOneData([
            ['id', '=', $order_id]
        ], 'id,user_id,type,status');

        // 订单不存在
        if (empty($order)) {
            return sendErrorArray(3001, '订单不存在');
        }

        // 用户取消验证是否是本人取消
        if ($type == 1 && $order['user_id'] != $user_id) {
            return sendErrorArray(3002, '非本人操作');
        }

        // 订单状态是否支持取消
        if ($order['status'] != 1) {
            return sendErrorArray(3003, '订单状态已改变，请刷新页面');
        }

        Db::startTrans();

        // 更改订单状态
        $data_update = [
            'id' => $order_id,
            'status' => 8,
            'cancel_time' => time()
        ];
        $res = $order_model->dataUpdate($data_update);
        if (!$res) {
            Db::rollback();
            return sendErrorArray(3004, '取消失败');
        }

        // 订单产品依次增加库存
        $order_product = $order_product_model->getAllData([
            ['order_id', '=', $order_id]
        ], 'id,product_id,product_sku,number,spike_product_id');
        foreach ($order_product as $k => $v) {
            // 产品增加库存
            $res = $order_service->productStockChange($v['product_id'], $v['number'], $v['product_sku'], $order['type'], $v['spike_product_id']);
            if ($res['code'] != 0) {
                Db::rollback();
                return $res;
            }
        }

        // 下单如果有优惠券将优惠券改为未使用
        $order_coupon_id = $order_coupon_model->where([
            ['order_id', '=', $order['id']]
        ])->column('coupon_my_id');
        if (!empty($order_coupon_id)) {
            $where = [
                ['id', 'in', $order_coupon_id],
            ];
            $res = $coupon_my_model->where($where)->update([
                'status' => 1,
                'use_time' => '',
                'update_time' => time()
            ]);
            if (!$res) {
                Db::rollback();
                return sendErrorArray(3005, '优惠券状态更改失败');
            }
        }
        Db::commit();

        return sendSuccessArray();
    }

    /**
     * 我的订单列表
     * @param int $last_id 列表的最后一条数据ID
     * @param int $index 订单状态 0--所有 1--待支付 2--待发货 3--待收货 4--待评价
     * @param string $keyword 订单关键字
     * @date 2022-09-28
     */
    public function listMyOrder($last_id = '', $index = 0, $keyword = '')
    {
        $order_model = new MallOrder();

        $where = [
            ['user_id', '=', $this->userId],
            // 用户未删除
            ['is_user_delete', '=', 0]
        ];
        // 在最后一条数据ID之前的订单
        if (!empty($last_id)) {
            $where[] = ['mall_order.id', '<', $last_id];
        }
        // index 0--所有 1--待支付 2--待发货 3--待收货 4--待评价
        if (!empty($index)) {
            $where[] = ['status', '=', $index];
        }
        // 关联订单产品表查询条件
        $where_order_product = [];
        if (!empty($keyword)) {
            $where_order_product[] = ['product_name', 'like', '%' . $keyword . '%'];
        }
        $filed = 'id,order_number,status,total_number,pay_money,is_evaluate_add,create_time';
        $data_list = $order_model->listMyOrderByLastId($where, $where_order_product, $filed);

        return sendSuccessArray([
            'list' => $data_list
        ]);
    }

    /**
     * 获取我的订单详情
     * @param int $order_id 订单ID
     * @date 2022-09-28
     */
    public function getMyOrderDetail($order_id)
    {
        $order_model = new MallOrder();
        $config_model = new MallConfig();
        $refund_model = new MallOrderRefund();

        $where = [
            ['uid', '=', $this->mid],
            ['user_id', '=', $this->userId],
            // 用户未删除
            ['is_user_delete', '=', 0],
            ['id', '=', $order_id]
        ];

        $field = 'id,order_number,status,pay_type,total_price,freight,coupon_money,pay_money,remark,create_time,pay_time,express_time,confirm_time,cancel_time,is_evaluate_add,linkman,mobile_phone,province,city,area,address';
        // 获取我的订单详情
        $order = $order_model->getMyOrder($where, $field);

        // 订单不存在
        if (empty($order)) {
            return sendErrorArray(3001, '订单不存在');
        }

        // 未付款状态下,获取自动取消订单倒计时
        $order['cancel_rest_second'] = 0;

        if ($order['status'] == 1) {
            // 获取商城配置-X分钟自动取消订单
            $order_cancel_minute = $config_model->getOneData([
                ['uid', '=', $this->mid]
            ], 'order_cancel_minute');

            // 剩余X秒自动取消订单
            $order['cancel_rest_second'] = strtotime($order['create_time']) + $order_cancel_minute * 60 - time();
        }

        // 订单产品退款详情
        foreach ($order['mallOrderProduct'] as $k => &$v) {
            // 是否有退款记录
            $refund_number = $refund_model->getNumber([
                ['user_id', '=', $order['user_id']],
                ['id', '=', $order['id']],
                ['order_product_id', '=', $v['id']]
            ]);

            // 是否有退款记录
            $v['is_has_refund'] = empty($refund_number) ? 0 : 1;

            // 已退款数量 = 该产品下单总数量，文案显示已退款
            if ($v['refund_total_number'] == $v['number']) {
                $v['refund_status'] = 3;
                $v['refund_status_text'] = '已退款';
                // 退款中数量 > 0，文案显示退款中
            } else if ($v['refund_cur_number'] > 0) {
                $v['refund_status'] = 2;
                $v['refund_status_text'] = '退款中';
                // 其他，显示退款
            } else {
                $v['refund_status'] = 1;
                $v['refund_status_text'] = '退款';
            }
        }

        return sendSuccessArray([
            'data' => $order
        ]);

    }


    /**
     * 订单删除
     * @param int $order_id 订单ID
     * @param int $user_id 操作用户ID
     * @param integer $type 操作类型 1--用户操作 2--后台操作
     * @date 2021-03-01
     */
    public function orderDel($order_id, $user_id = '', $type = 1)
    {
        $order_model = new MallOrder();

        //获取订单信息
        $order = $order_model->getOneData([
            ['id', '=', $order_id]
        ]);
        if (empty($order)) {
            return sendErrorArray(3001, '订单不存在');
        }
        if ($type == 1 && $order['user_id'] != $user_id) {
            return sendErrorArray(3002, '非本人操作');
        }
        if (!($order['status'] == 8 || $order['status'] == 7 || $order['status'] == 5 || $order['status'] == 4)) {
            return sendErrorArray(3003, '订单状态不支持删除');
        }

        //更改订单状态
        $data_update = [
            'is_user_delete' => 1,
            'user_delete_time' => time()
        ];
        $res = $order_model->dataUpdate($data_update, [
            ['id', '=', $order_id]
        ]);
        if (!$res) {
            return sendErrorArray(3004, '删除失败');
        }

        return sendSuccessArray();
    }

    /**
     * 订单再次购买
     * @param int $order_id 订单ID
     * @param int $user_id 操作用户ID
     * @param integer $type 操作类型 1--用户操作 2--后台操作
     * @date 2021-03-01
     */
    public function orderReBuy($order_id, $user_id = '', $type = 1)
    {
        $order_model = new MallOrder();
        $cart_model = new MallCart();
        $product_logic = new \app\mall\logic\Product();

        // 获取订单信息
        $order = $order_model->getMyOrder([
            ['id', '=', $order_id]
        ]);
        if (empty($order)) {
            return sendErrorArray(3001, '订单不存在');
        }
        if ($type == 1 && $order['user_id'] != $user_id) {
            return sendErrorArray(3002, '非本人操作');
        }
        if ($order['status'] != 8) {
            return sendErrorArray(3003, '订单状态不支持再次购买');
        }

        //获取商品详情
        foreach ($order['mallOrderProduct'] as $k => $v) {
            //判断库存是否足够mallOrderProduct
            $cart_number = $cart_model->getOneData([
                ['user_id', '=', $order['user_id']],
                ['product_id', '=', $v['product_id']],
                ['product_sku', '=', $v['product_sku']],
            ], 'number');

            $cart_number = $cart_number ?? 0;
            $number = $v['number'] + $cart_number;//购物车本身的数量+新增数量

            $res = $product_logic->isStockEnough($v['product_id'], $v['product_sku'], $number);
            if ($res['code'] != 0) {
                continue;
//                return $res;
            }

            //加入购物车
            $data = [
                'uid' => $order['uid'],
                'user_agent' => $this->userAgent,
                'user_id' => $order['user_id'],
                'product_id' => $v['product_id'],
                'is_product_spec_open' => $v['is_product_spec_open'],
                'product_sku' => $v['product_sku'],
                'number' => $v['number'],
                'is_select' => 1
            ];
            $res = $cart_model->updateCart($data);
            if (!$res) {
                return sendErrorArray(4001, '更新购物车失败');
            }
        }
        return sendSuccessArray();
    }

    /**
     * 订单提醒发货
     * @param int $order_id 订单ID
     * @param int $user_id 操作用户ID
     * @date 2021-03-01
     */
    public function orderRemind($order_id, $user_id = '')
    {
        $order_model = new MallOrder();
        $cart_model = new MallCart();
        $product_logic = new \app\mall\logic\Product();

        //获取订单信息
        $order = $order_model->getOneData([
            ['id', '=', $order_id]
        ]);
        if (empty($order)) {
            return sendErrorArray(3001, '订单不存在');
        }
        if ($order['user_id'] != $user_id) {
            return sendErrorArray(3002, '非本人操作');
        }
        if ($order['status'] != 2) {
            return sendErrorArray(3003, '订单状态不支持提醒发货');
        }

        //更改订单状态
        $data_update = [
            'remind_time' => time()
        ];
        $res = $order_model->dataUpdate($data_update, [
            ['id', '=', $order_id]
        ]);
        if (!$res) {
            return sendErrorArray(3004, '提醒发货失败');
        }
        return sendSuccessArray();
    }

    /**
     * 订单确认发货
     * @param int $order_id 订单ID
     * @param int $user_id 操作用户ID
     * @param integer $type 1--用户操作 2--后台操作 3--定时操作
     * @date 2021-03-01
     */
    public function orderFinish($order_id, $user_id = '', $type = 1)
    {
        $order_model = new MallOrder();
        $info_model = new UserInfo();
        $income_model = new DistributionCommissionIncome();
        $commission_service = new \app\distribution\service\Commission();

        //获取订单信息
        $order = $order_model->getOneData([
            ['id', '=', $order_id]
        ]);
        if (empty($order)) {
            return sendErrorArray(3001, '订单不存在');
        }
        if ($order['user_id'] != $user_id) {
            return sendErrorArray(3002, '非本人操作');
        }
        if ($order['status'] != 3) {
            return sendErrorArray(3003, '订单状态不支持确认收货');
        }


        //更改订单状态
        $data_update = [
            'status' => 4,
            'confirm_time' => time()
        ];
        $res = $order_model->dataUpdate($data_update, [
            ['id', '=', $order_id]
        ]);
        if (!$res) {
            return sendErrorArray(3004, '确认收货失败');
        }


        //更改佣金记录表为已入账
        $where = [
            ['remark', '=', serialize([
                'mall_order_id' => $order['id']
            ])]
        ];
        $income_data = $income_model->getOneData($where);
        if (!empty($income_data)) {
            $res = $income_model->where($where)->save([
                'status' => 2
            ]);
            if (!$res) {
                return sendErrorArray(3005, '更新佣金记录失败');
            }


            //获取用户昵称
            $nickname = $info_model->getOneData([
                ['user_id', '=', $order['user_id']]
            ], 'nick_name');

            //记录佣金明细表并更新总佣金
            //获取佣金
            $income = $income_model->getAllData($where);
            foreach ($income as $k => $v) {
                $res = $commission_service->change($v['distributor_user_id'], 2, $v['commission'], $nickname . '带来的佣金', $order['order_number'], [
                    'mall_order_id' => $order['id']
                ]);
                if (!$res) {
                    return sendErrorArray(3006, '更新佣金失败');
                }
            }
        }

        return sendSuccessArray();
    }

    /**
     * 订单评价
     * @param int $order_id 订单ID
     * @param array $order_product 订单产品带评价数据数组
     * @param int $user_id 操作用户ID
     * @date 2021-03-01
     */
    public function orderEvaluate($order_id, $order_product, $user_id = '')
    {
        $order_model = new MallOrder();
        $evaluate_model = new MallEvaluate();
        $snow_flake_class = new Snowflake();

        //获取订单信息
        $order = $order_model->getOneData([
            ['id', '=', $order_id]
        ], 'uid,user_id,status');
        if (empty($order)) {
            return sendErrorArray(3001, '订单不存在');
        }
        if ($order['user_id'] != $user_id) {
            return sendErrorArray(3002, '非本人操作');
        }
        if ($order['status'] != 4) {
            return sendErrorArray(3003, '订单状态不支持评论');
        }

        //存入评价表
        $star_rank = ['1' => 1, '2' => 1, '3' => 2, '4' => 3, '5' => 3];
        $evaluate_data = [];
        foreach ($order_product as $k => $v) {
            $evaluate_data[] = [
                'id' => $snow_flake_class->id(),
                'uid' => $order['uid'],
                'user_agent' => $this->userAgent,
                'user_id' => $order['user_id'],
                'order_id' => $order_id,
                'order_product_id' => $v['id'],
                'product_id' => $v['product_id'],
                'product_name' => $v['product_name'],
                'product_cover_img' => $v['product_cover_img'],
                'product_price' => $v['product_price'],
                'is_product_spec_open' => $v['is_product_spec_open'],
                'product_sku' => $v['product_sku'],
                'product_sku_name' => strtr($v['product_sku_name'], ' ', ','),
                'star' => $v['star'],
                'star_rank' => $star_rank[$v['star']],
                'content' => $v['content'],
                'has_video' => empty($v['video_path']) ? 1 : 2,
                'video_path' => serialize($v['video_path']),
//                'video_cover_img' => $v['video_cover_img'],
                'has_img' => empty($v['img_path']) ? 1 : 2,
                'img_path' => serialize($v['img_path']),
                'create_time' => time(),
                'update_time' => time(),
            ];
        }

        $res = $evaluate_model->insertAll($evaluate_data);
        if (!$res) {
            return sendErrorArray(3004, '存入评论失败');
        }

        //更改订单状态
        $data_update = [
            'status' => 5,
            'evaluate_time' => time()
        ];
        $res = $order_model->dataUpdate($data_update, [
            ['id', '=', $order_id]
        ]);
        if (!$res) {
            return sendErrorArray(3005, '评论失败');
        }

        return sendSuccessArray();
    }

    /**
     * 订单追加评价
     * @param int $order_id 订单ID
     * @param array $order_product 订单产品带评价数据数组
     * @param int $user_id 操作用户ID
     * @date 2021-03-01
     */
    public function orderEvaluateAdd($order_id, $order_product, $user_id = '')
    {
        $order_model = new MallOrder();
        $evaluate_model = new MallEvaluate();
        $snow_flake_class = new Snowflake();

        //获取订单信息
        $order = $order_model->getOneData([
            ['id', '=', $order_id]
        ]);
        if (empty($order)) {
            return sendErrorArray(3001, '订单不存在');
        }
        if ($order['user_id'] != $user_id) {
            return sendErrorArray(3002, '非本人操作');
        }
        if ($order['status'] != 5) {
            return sendErrorArray(3003, '订单状态不支持评论');
        }

        //获取评论信息
        $evaluate = $evaluate_model->getOneData([
            ['evaluate_id', '=', 0],
            ['order_id', '=', $order_id]
        ]);
        if (empty($evaluate)) {
            return sendErrorArray(3001, '订单初评不存在');
        }

        //存入评价表
        $evaluate_data = [];
        foreach ($order_product as $k => $v) {
//            $video = [];
//            foreach($v['video_path'] as $k1=>$v1){
//                $result = getVideoScreenshot($v1);
//                $video[$k1]['video_path'] = $v1;
//                $video[$k1]['video_cover_img'] = $result['url'];
//            }
            $evaluate_data[] = [
                'id' => $snow_flake_class->id(),
                'uid' => $order['uid'],
                'user_agent' => $this->userAgent,
                'user_id' => $order['user_id'],
                'evaluate_id' => $evaluate['id'],
                'order_id' => $order_id,
                'order_product_id' => $v['id'],
                'product_id' => $v['product_id'],
                'product_name' => $v['product_name'],
                'product_cover_img' => $v['product_cover_img'],
                'product_price' => $v['product_price'],
                'is_product_spec_open' => $v['is_product_spec_open'],
                'product_sku' => $v['product_sku'],
                'product_sku_name' => strtr($v['product_sku_name'], ' ', ','),
                'content' => $v['content'],
                'has_video' => empty($v['video_path']) ? 1 : 2,
                'video_path' => serialize($v['video_path']),
                'has_img' => empty($v['img_path']) ? 1 : 2,
                'img_path' => serialize($v['img_path']),
                'create_time' => time(),
                'update_time' => time(),
            ];
        }
        $res = $evaluate_model->insertAll($evaluate_data);
        if (!$res) {
            return sendErrorArray(3004, '存入评论失败');
        }

        //修改评论表
        $evaluate_data_update = [
            'id' => $evaluate['id'],
            'is_add' => 1
        ];
        $res = $evaluate_model->dataUpdate($evaluate_data_update);
        if (!$res) {
            return sendErrorArray(3005, '追加评论失败');
        }

        //更改订单状态
        $data_update = [
            'is_evaluate_add' => 1,
            'evaluate_time' => time()
        ];
        $res = $order_model->dataUpdate($data_update, [
            ['id', '=', $order_id]
        ]);
        if (!$res) {
            return sendErrorArray(3006, '追加评论失败');
        }


        return sendSuccessArray();
    }

    /*
     * 订单退款
     * @param int $order_product_id order_product主键ID
     * @param int $number 退款数量
     * @param int $refund_id 退款原因主键ID
     * @param array $refund_images 退款原因图片
     * @param string $remark 退款备注
     * @date 2021-06-01
     */
    public function orderRefund($order_product_id, $number, $refund_id, $refund_images, $remark)
    {
        $order_model = new MallOrder();
        $order_product_model = new MallOrderProduct();
        $refund_model = new MallOrderRefund();
        $cause_model = new MallRefundCause();

        //获取退款金额
        $res = $this->getOrderRefundMoney($order_product_id, $number);
        if ($res['code'] != 0) {
            return $res;
        }
        $refund_money = $res['data']['refund_money'];
        $order = $res['data']['order'];

        //获取退款原因
        $cause = $cause_model->getOneData(['id' => $refund_id]);
        if (empty($cause)) {
            return sendErrorArray(4001, '退款原因不存在');
        }

        //存入退款表
        $refund_data = [
            'uid' => $this->mid,
            'user_agent' => $this->userAgent,
            'user_id' => $order['user_id'],
            'order_number' => $refund_model->createOrderNumber('MR'),
            'order_id' => $order['id'],
            'order_product_id' => $order_product_id,
            'refund_money' => $refund_money,
            'refund_number' => $number,
            'refund_type' => $order['pay_type'],
            'cause_id' => $cause['id'],
            'cause_content' => $cause['content'],
            'cause_img' => $refund_images,
            'remark' => $remark,
            'status' => 1
        ];
        $res = $refund_model->dataUpdate($refund_data);
        if (!$res) {
            return sendErrorArray(4002, '存入退款表失败');
        }

        //更新订单产品表数量
        $update_data = [
            'id' => $order_product_id,
            'refund_cur_number' => Db::raw('refund_cur_number + ' . $number)  // 退款中数量增加
        ];
        $res = $order_product_model->dataUpdate($update_data);
        if (!$res) {
            return sendErrorArray(4003, '更新订单产品表失败');
        }

        //更新订单状态
        //获取已退总数量
        $total_refund_number = $refund_model->getSum('refund_number', [
            ['order_id', '=', $order['id']],
            ['status', 'in', [1, 2]]    //待审核和已退款状态
        ]);
        if ($total_refund_number == $order['total_number']) {
            $order_update_data = [
                'id' => $order['id'],
                'status' => 6
            ];
            $res = $order_model->dataUpdate($order_update_data);
            if (!$res) {
                return sendErrorArray(4003, '更新订单表失败');
            }
        }

        return sendSuccessArray();
    }

    /*
     * 订单退款被拒绝
     * @param int $order_refund_id order_refund主键ID
     * @param string $refuse_text 拒绝原因
     * @date 2021-06-01
     */
    public function orderRefundFail($order_refund_id, $refuse_text = '')
    {
        $refund_model = new MallOrderRefund();
        $order_model = new MallOrder();
        $order_product_model = new MallOrderProduct();

        //查找退款数据
        $where = [
            ['uid', '=', $this->mid],
            ['id', '=', $order_refund_id],
        ];
        $refund = $refund_model->getOneData($where);
        if ($refund['status'] != 1) {
            return sendErrorArray(3001, '审核状态发生变化，请刷新重试');
        }

        //退款订单数据变更
        $update_data = [
            'id' => $order_refund_id,
            'status' => 3,
            'refuse_text' => $refuse_text
        ];
        $res = $refund_model->dataUpdate($update_data);
        if (!$res) {
            return sendErrorArray(3002, '修改退款状态失败');
        }

        //修改订单商品退款中数量
        $order_product_updata_data = [
            'id' => $refund['order_product_id'],
            'refund_cur_number' => Db::raw('refund_cur_number - ' . $refund['refund_number'])
        ];
        $res = $order_product_model->dataUpdate($order_product_updata_data);
        if (!$res) {
            return sendErrorArray(3003, '修改订单产品表失败');
        }

        //更新订单状态为退款前状态
        //获取已退总数量
        $total_refund_number = $refund_model->getSum('refund_number', [
            ['order_id', '=', $refund['order_id']],
            ['status', 'in', [1, 2]]    //待审核和已退款状态
        ]);
        $order = $order_model->getOneData([
            ['id', '=', $refund['order_id']]
        ], 'total_number,express_time');
        if ($total_refund_number < $order['total_number']) {    //没有全部退款
            $order_update_data = [
                'id' => $refund['order_id'],
                'status' => empty($order['express_time']) ? 2 : 3   //没有发货时间更改为2--待发货 否则更改为3--待收货
            ];
            $res = $order_model->dataUpdate($order_update_data);
            if (!$res) {
                return sendErrorArray(3004, '更新订单表失败');
            }
        }

        return sendSuccessArray();
    }

    /*
     * 订单退款审核通过
     * @param int $order_refund_id order_refund主键ID
     * @date 2021-06-01
     */
    public function orderRefundSuccess($order_refund_id)
    {
        $refund_model = new MallOrderRefund();
        $order_model = new MallOrder();
        $order_product_model = new MallOrderProduct();
        $coupon_my_model = new DiscountCouponMy();
        $order_coupon_model = new MallOrderCoupon();
        $order_service = new \app\mall\service\Order();

        //查找退款数据
        $where = [
            ['uid', '=', $this->mid],
            ['id', '=', $order_refund_id],
        ];
        $refund = $refund_model->getOneData($where);
        if ($refund['status'] != 1) {
            return sendErrorArray(3001, '审核状态发生变化，请刷新重试');
        }

        //退款订单数据变更
        $update_data = [
            'id' => $order_refund_id,
            'status' => 2,  // 已退款
        ];
        $res = $refund_model->dataUpdate($update_data);
        if (!$res) {
            return sendErrorArray(3002, '修改退款状态失败');
        }

        //修改订单商品退款中和退款总数量
        $order_product_updata_data = [
            'id' => $refund['order_product_id'],
            'refund_cur_number' => Db::raw('refund_cur_number - ' . $refund['refund_number']),
            'refund_total_number' => Db::raw('refund_total_number + ' . $refund['refund_number']),
        ];
        $res = $order_product_model->dataUpdate($order_product_updata_data);
        if (!$res) {
            return sendErrorArray(3003, '修改订单产品表失败');
        }

        $total_refund_number = $refund_model->getSum('refund_number', [
            ['order_id', '=', $refund['order_id']],
            ['status', 'in', [2]]    //已退款状态
        ]);
        $order = $order_model->getOneData([
            ['id', '=', $refund['order_id']]
        ], 'uid,user_agent,user_id,order_number,type,pay_type,total_number,pay_money');
        if ($total_refund_number == $order['total_number']) {    //全部产品退款
            //更改订单表为已退款
            $order_update_data = [
                'id' => $refund['order_id'],
                'status' => 7
            ];
            $res = $order_model->dataUpdate($order_update_data);
            if (!$res) {
                return sendErrorArray(3004, '更新订单表失败');
            }

            //优惠券退回
            $order_coupon_id = $order_coupon_model->where([
                ['order_id', '=', $order['id']]
            ])->column('coupon_my_id');
            if (!empty($order_coupon_id)) {
                $where = [
                    ['id', 'in', $order_coupon_id],
                ];
                #TODO  修改寫法為saveALl 自動更新update_time
                $res = $coupon_my_model->where($where)->update([
                    'status' => 1,
                    'use_time' => '',
                    'update_time' => time()
                ]);
                if (!$res) {
                    return sendErrorArray(3005, '优惠券状态更改失败');
                }
            }
        }

        //产品库存退回
        $order_product = $order_product_model->getOneData([
            ['id', '=', $refund['order_product_id']]
        ]);//获取订单产品数据
        $res = $order_service->productStockChange($order_product['product_id'], $refund['refund_number'], $order_product['product_sku'], $order['type'], $order_product['spike_product_id']);
        if ($res['code'] != 0) {
            return $res;
        }

        //产品销量减少（该版本为付款成功加销量）
        $res = $order_service->productSalesChange($order_product['product_id'], -$refund['refund_number'], $order['type'], $order_product['spike_product_id']);
        if ($res['code'] != 0) {
            return $res;
        }

        //退款
        switch ($order['pay_type']) {
            // 微信退款
            case 1:
                $wxpay_param = get_wxpay_config_with_weixin($order['user_agent']);
                $wxpay_class = new \tencent\wechat\pay\Wxpay($wxpay_param);

                //退款
                $result = $wxpay_class->refund($order['order_number'], $refund['order_number'], $order['pay_money'], $refund['refund_money']);

                //记录日志
                platformLog([
                    'order_number' => $order['order_number'],
                    'refund_order_number' => $refund['order_number'],
                    'pay_money' => $order['pay_money'],
                    'refund_money' => $refund['refund_money']
                ], $result, 'easywechat_wxpay_refund_' . $this->mid);


                if ($result['return_code'] != 'SUCCESS' || $result['result_code'] != 'SUCCESS') {
                    return sendErrorArray(3006, $result['return_msg'] != 'OK' ? $result['return_msg'] : $result['err_code_des']);
                }

                //返回状态码和业务结果均为成功，退款成功修改退款表状态
                $update_data = [
                    'id' => $order_refund_id,
                    'is_arrival' => 1,
                    'arrival_time' => time(),
                    'transaction_id' => $result['transaction_id']
                ];
                $res = $refund_model->dataUpdate($update_data);

                // 统计系统 - 新增交易流水（退款）
                $statistics_class = new \jucheng\tongji\Statistics();
                $result = $statistics_class->updateTurnoverMoney(-$refund['refund_money']);

                // 统计系统 - 新增订单信息（退款）
                $statistics_class = new \jucheng\tongji\Statistics();
                $result = $statistics_class->updateOrderInfo(-$refund['refund_money'], 0);
                break;
            // 支付宝退款
            case 2:
                switch ($order['user_agent']) {
                    // APP项目
                    case 'app':
                        $ali_pay_param = get_app_alipay_config();
                        break;
                    // 小程序项目
                    case 'mp_alipay':
                        $ali_pay_param = get_mp_alipay_config();
                        break;
                    // H5项目
                    case 'h5':
                        $ali_pay_param = get_h5_alipay_config();
                        break;
                    // 其他
                    default:
                        $ali_pay_param = [];
                        break;
                }

                $ali_pay_class = new \ali\alipay\pay\AliPay($ali_pay_param);

                //退款
                $result = $ali_pay_class->refund($order['order_number'], $refund['order_number'], $refund['refund_money']);

                if ($result['code'] !== '10000') {
                    return sendErrorArray($result['code'], $result['sub_msg']);
                }

                //退款成功修改退款表状态
                $update_data = [
                    'id' => $order_refund_id,
                    'is_arrival' => 1,
                    'arrival_time' => time(),
                    'transaction_id' => $result['trade_no']
                ];
                $res = $refund_model->dataUpdate($update_data);

                // 统计系统 - 新增交易流水（退款）
                $statistics_class = new \jucheng\tongji\Statistics();
                $result = $statistics_class->updateTurnoverMoney(-$refund['refund_money']);

                // 统计系统 - 新增订单信息（退款）
                $statistics_class = new \jucheng\tongji\Statistics();
                $result = $statistics_class->updateOrderInfo(-$refund['refund_money'], 0);
                break;
            case 3://余额退款
                $money_service = new \app\money\service\Money();

                //退款
                $result = $money_service->change($order['user_id'], 5, $refund['refund_money'], "退款-商城订单", $order['order_number'], [
                    'mall_order_refund_id' => $order_refund_id
                ]);
                if ($result['code'] == 0) {
                    $update_data = [
                        'id' => $order_refund_id,
                        'is_arrival' => 1,
                        'arrival_time' => time()
                    ];
                    $res = $refund_model->dataUpdate($update_data);
                    if (!$res) {
                        return sendErrorArray(3008, '余额到账失败');
                    }
                }
                break;
            default:
                break;
        }
        return sendSuccessArray();
    }

    /*
     * 订单退款取消
     * @param int $refund_id 订单退款表ID
     * @date 2021-06-01
     */
    public function orderRefundCancel($refund_id)
    {
        $order_model = new MallOrder();
        $order_product_model = new MallOrderProduct();
        $refund_model = new MallOrderRefund();

        //获取退款数据
        $refund = $refund_model->getOneData([
            ['id', '=', $refund_id]
        ]);

        //获取订单产品数据
        $order_product = $order_product_model->getOneData([
            ['id', '=', $refund['order_product_id']]
        ]);

        //获取订单数据
        $order = $order_model->getOneData([
            ['id', '=', $refund['order_id']]
        ]);

        // 存入退款表
        $refund_data = [
            'id' => $refund['id'],
            'cancel_time' => time(),
            'status' => 4
        ];
        $res = $refund_model->dataUpdate($refund_data);
        if (!$res) {
            return sendErrorArray(4002, '更新退款表失败');
        }

        // 更新订单产品表数量
        $update_data = [
            'id' => $refund['order_product_id'],
            'refund_status' => ($order_product['refund_cur_number'] - $refund['refund_number'] == 0) ? 1 : 2,
            'refund_cur_number' => Db::raw('refund_cur_number - ' . $refund['refund_number'])
        ];
        $res = $order_product_model->dataUpdate($update_data);
        if (!$res) {
            return sendErrorArray(4003, '更新订单产品表失败');
        }

        $order_update_data = [
            'id' => $refund['order_id'],
            'status' => empty($order['express_time']) ? 2 : 3
        ];
        $res = $order_model->dataUpdate($order_update_data);
        if (!$res) {
            return sendErrorArray(4004, '更新订单表失败');
        }

        return sendSuccessArray();
    }

    /*
     * 获取订单退款金额
     * @param int $order_product_id 订单产品表ID
     * @param int $number 退款数量
     * @date 2021-06-01
     */
    public function getOrderRefundMoney($order_product_id, $number = 1)
    {
        $order_model = new MallOrder();
        $order_product_model = new MallOrderProduct();
        $refund_model = new MallOrderRefund();

        $order_product = $order_product_model->getOneData([
            ['id', '=', $order_product_id]
        ]);
        if (empty($order_product)) {
            return sendErrorArray(3001, '订单不存在');
        }

        if ($number > $order_product['number'] - $order_product['refund_total_number'] - $order_product['refund_cur_number']) {
            return sendErrorArray(3002, '申请退款数量不能多于购买数量');
        }

        $order = $order_model->getOneData(['id' => $order_product['order_id']]);
        if (!$order) {
            return sendErrorArray(3003, '订单不存在');
        }

        $total_number = $order_product_model->getOneData(['order_id' => $order['id']], 'SUM(number - refund_total_number - refund_cur_number) as actual_number');
        if (empty($order['pay_money'])) {
            $refund_money = 0;
        } else {
            if ($total_number == $number) {    //退最后1个
                // 获取已退金额
                $total_refund_money = $refund_model->getSum('refund_money', [
                    ['order_id', '=', $order['id']],
                    ['status', 'in', [1, 2]]
                ]);
                $refund_money = $order['pay_money'] - $total_refund_money;
            } else {   //不是退最后1个
                $refund_money = round($order_product['product_price'] * $number - $order['coupon_money'] * $order_product['product_price'] * $number / $order['total_price'], 2);
            }
        }

        return sendSuccessArray(['refund_money' => $refund_money, 'order' => $order, 'order_product' => $order_product]);
    }

    /**
     * 订单物流
     * @param int $order_id 订单ID
     * @date 2022-11-22
     */
    public function getLogistics($order_id)
    {
        $order_model = new MallOrder();
        $kdniao_param = get_kdniao_config();
        $logistic_class = new Logistics($kdniao_param);

        $where = [
            ['uid', '=', $this->mid],
            ['user_id', '=', $this->userId],
            ['is_user_delete', '=', 0],
            ['id', '=', $order_id]
        ];

        // 查找订单
        $field = 'id,order_number,total_number,express_name,express_number,express_code,province,city,area,address';
        $order = $order_model->getMyOrder($where,$field);
        if (empty($order)) {
            return sendErrorArray(3001, '订单不存在');
        }

        $order = $order->toArray();
        foreach ($order['mallOrderProduct'] as $k=>$v){
            unset($order['mallOrderProduct'][$k]['is_product_spec_open']);
            unset($order['mallOrderProduct'][$k]['product_sku']);
            unset($order['mallOrderProduct'][$k]['product_sku_name']);
            unset($order['mallOrderProduct'][$k]['refund_total_number']);
            unset($order['mallOrderProduct'][$k]['refund_cur_number']);
            unset($order['mallOrderProduct'][$k]['total_price']);
        }

        // 查看物流
        $result = $logistic_class->getLogistics($order['express_number'], $order['express_code']);

        // 有错误
        if ($result['Success'] != 'true') {
            // 物流状态
            $logistics['logistics_status'] = 0;
            // 物流状态显示文本
            $logistics['logistics_text'] = $result['Reason'];
            // 物流轨迹
            $logistics['logistics'] = [
                [
                    'accept_date' => '',
                    'accept_time' => '',
                    'content' => '该订单编号暂时无法获取物流轨迹'
                ]
            ];
        } else {
            // 物流状态
            $logistics['logistics_status'] = $result['State'];
            // 物流状态显示文本
            $logistics['logistics_text'] = $result['logistics_text'];

            // 物流轨迹
            $result['Traces'] = array_reverse($result['Traces']);
            foreach ($result['Traces'] as $k => $v) {
                $logistics['logistics'][$k]['accept_date'] = date('Y-m-d', strtotime($v['AcceptTime']));
                $logistics['logistics'][$k]['accept_time'] = date('H:i:s', strtotime($v['AcceptTime']));
                $logistics['logistics'][$k]['content'] = $v['AcceptStation'];
            }
        }

        return sendSuccessArray([
            // 订单信息
            'order' => $order,
            // 物流信息
            'logistics' => $logistics
        ]);
    }


}