<?php

namespace app\admin\controller\shopro\order;

use addons\shopro\library\Export;
use addons\shopro\model\Config as ModelConfig;
use app\admin\model\shopro\order\OrderExpress;
use think\Db;
use think\Config;
use app\common\controller\Backend;
use PhpOffice\PhpSpreadsheet\Cell\Coordinate;
use PhpOffice\PhpSpreadsheet\Reader\Xlsx;
use PhpOffice\PhpSpreadsheet\Reader\Xls;
use PhpOffice\PhpSpreadsheet\Reader\Csv;
use app\admin\controller\shopro\Base;

/**
 * 订单管理
 *
 * @icon fa fa-circle-o
 */
class Order extends Base
{
    protected $noNeedRight = ['getType', 'getExpress'];

    /**
     * Order模型对象
     * @var \app\admin\model\shopro\order\Order
     */
    protected $model = null;

    public function _initialize()
    {
        parent::_initialize();

        // 手动加载语言包
        $this->loadlang('shopro/order/order_item');
        $this->loadlang('shopro/dispatch/dispatch');
        $this->loadlang('shopro/goods/goods');

        $this->model = new \app\admin\model\shopro\order\Order;
        $this->view->assign("typeList", $this->model->getTypeList());
        $this->view->assign("statusList", $this->model->getStatusList());
        $this->view->assign("payTypeList", $this->model->getPayTypeList());
        $this->view->assign("platformList", $this->model->getPlatformList());
    }

    /**
     * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法
     * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑
     * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改
     */


    /**
     * 查看
     */
    public function index($dealer_id = null)
    {
        //当前是否为关联查询
        $this->relationSearch = true;
        //设置过滤方法
        $this->request->filter(['strip_tags', 'trim']);
        if ($this->request->isAjax()) {
            //如果发送的来源是Selectpage，则转发到Selectpage
            if ($this->request->request('keyField')) {
                return $this->selectpage();
            }

            $nobuildfields = ['status', 'aftersale_sn', 'dispatch_type', 'goods_type', 'nickname', 'user_phone', 'goods_title'];
            list($where, $sort, $order, $offset, $limit) = $this->custombuildparams(null, $nobuildfields);

            $total = $this->buildSearchOrder()
                ->where($where)
                ->order($sort, $order)
                ->count();

            $list = $this->buildSearchOrder()
                ->where($where)
                ->with(['user', 'item'])
                ->order($sort, $order)
                ->limit($offset, $limit)
                ->select();

            // foreach ($list as $row) {
            //     $row->visible(['id','type','order_sn','user','item','user_id','phone','consignee','province_name','city_name','area_name','address','status','memo','remark','total_amount','total_fee','createtime']);
            // }

            $list = collection($list)->toArray();

            foreach ($list as $key => $od) {
                // 处理 未支付订单 的 订单 item status_code 状态
                $list[$key] = $this->model->setOrderItemStatusByOrder($od);
            }

            $result = array("total" => $total, "rows" => $list);

            return $this->success('操作成功', null, $result);
        }
        $this->assignconfig('dealer_id',$dealer_id);
        return $this->view->fetch();
    }


    public function export()
    {
        $export = new Export();

        $nobuildfields = ['status', 'aftersale_sn', 'dispatch_type', 'goods_type', 'nickname', 'user_phone'];
        list($where, $sort, $order, $offset, $limit) = $this->custombuildparams(null, $nobuildfields);

        $list = $this->buildSearchOrder()
            ->where($where)
            ->with(['user', 'item' => ['goods_sku_sn']])
            ->order($sort, $order)
            ->select();

        // 经销商
        $dealer = [];
        $group_id_arr = array_column($this->auth->getGroups(), 'group_id');
        if(!in_array(1,$group_id_arr) && in_array(2,$group_id_arr)){
            $dealer = \app\admin\model\dealer\Dealer::where('admin_id',$this->auth->id)->find();
        }

        $expCellName = [
            'order_id' => 'Id',
            'order_sn' => '订单号',
            'status_text' => '订单状态',
            'paytime_text' => '支付时间',
            'user_info' => '用户信息',
        ];
        // 经销商不显示订单总金额和优惠金额
        if(!$dealer){
            $expCellName = array_merge($expCellName,[
                'total_amount' => '订单总金额',
                'discount_fee' => '优惠金额',
            ]);
        }
        $expCellName = array_merge($expCellName,[
            'pay_fee' => '实际支付金额',
            'activity_type_text' => '营销类型',
            'goods_title' => '商品名称',
            'goods_sku_sn' => '规格编号',
            'goods_original_price' => '商品原价',
            'goods_price' => '商品价格',
            'goods_sku_text' => '商品规格',
            'goods_num' => '购买数量',
            'dispatch_status_text' => '发货状态',
            'dispatch_fee' => '发货费用',
            'refund_fee' => '退款金额',
            'refund_msg' => '退款原因',
            'consignee' => '收货人',
            'phone' => '收货人电话',
            'province_name' => '省',
            'city_name' => '市',
            'area_name' => '区',
            'address' => '收货详细地址',
            'full_address' => '收货地址',
            'express_name' => '快递公司',
            'express_code' => '快递编码',
            'express_no' => '快递单号',
        ]);

        $newList = [];
        foreach ($list as $key => $order) {
            $data = [
                'order_id' => $order['id'],
                'order_sn' => $order['order_sn'],
                'status_text' => $order['status_text'],
                'paytime_text' => $order['paytime_text'],
                'user_info' => $order['user'] ? ($order['user']['nickname'] . '-' . $order['user']['mobile']) : '',
            ];
            // 经销商不显示订单总金额和优惠金额
            if(!$dealer){
                $data = array_merge($data,[
                    'total_amount' => $order['total_amount'],
                    'discount_fee' => $order['discount_fee'],
                ]);
            }
            $data = array_merge($data,[
                'pay_fee' => $order['pay_fee'],
            ]);
            foreach ($order['item'] as $k => $item) {
                if(!$dealer || ($dealer && $item['dealer_id'] == $dealer['id'])){
                    $goods_sku_sn = $item['goods_sku_sn'] ? $item['goods_sku_sn']['sn'] : '';
                    $itemData = [
                        'activity_type_text' => $item['activity_type_text'],
                        'goods_title' => $item['goods_title'],
                        'goods_sku_sn' => $goods_sku_sn,
                        'goods_original_price' => $item['goods_original_price'],
                        'goods_price' => $item['goods_price'],
                        'goods_sku_text' => $item['goods_sku_text'],
                        'goods_num' => $item['goods_num'],
                        'dispatch_status_text' => $item['dispatch_status_text'],
                        'dispatch_fee' => $item['dispatch_fee'],
                        'refund_fee' => $item['refund_fee'],
                        'refund_msg' => $item['refund_msg'],
                        'consignee' => $order['consignee'],
                        'phone' => $order['phone'],
                        'province_name' => $order['province_name'],
                        'city_name' => $order['city_name'],
                        'area_name' => $order['area_name'],
                        'address' => $order['address'],
                        'full_address' => $order['consignee'].$order['phone'].$order['province_name'].$order['city_name'].$order['area_name'].$order['address'],
                        'express_name' => $item['express_name'],
                        'express_code' => $item['express_code'],
                        'express_no' => $item['express_no'],
                    ];

                    $newList[] = array_merge($data, $itemData);
                }
            }
        }

        $total_amount = !$dealer ? "；订单总金额：￥" . array_sum(array_column($list, 'total_amount')) . "；优惠总金额：￥" . array_sum(array_column($list, 'discount_fee')) : '';
        // 增加合计
        $newList[] = [
            'order_id' => "订单总数：" . count($list) . $total_amount . "；实际支付总金额：￥" . array_sum(array_column($list, 'pay_fee'))
        ];

        $export->exportExcel('订单列表-' . date('Y-m-d H:i:s'), $expCellName, $newList);
    }


    // 获取要查询的订单类型
    public function getType()
    {
        $type = $this->model->getTypeList();
        $pay_type = $this->model->getPayTypeList();
        $platform = $this->model->getPlatformList();
        $dispatch_type = (new \app\admin\model\shopro\dispatch\Dispatch)->getTypeList();
        $activity_type = (new \app\admin\model\shopro\activity\Activity)->getTypeList();
        $goods_type = (new \app\admin\model\shopro\goods\Goods)->getTypeList();

        $result = [
            'type' => $type,
            'pay_type' => $pay_type,
            'platform' => $platform,
            'dispatch_type' => $dispatch_type,
            'activity_type' => $activity_type,
            'goods_type' => $goods_type
        ];

        $data = [];
        foreach ($result as $key => $list) {
            $data[$key][] = ['name' => '全部', 'type' => 'all'];

            foreach ($list as $k => $v) {
                $data[$key][] = [
                    'name' => $v,
                    'type' => $k
                ];
            }
        }

        return $this->success('操作成功', null, $data);
    }


    public function detail($id)
    {
        if ($this->request->isAjax()) {
            $row = $this->model->withTrashed()->with(['user', 'item.store'])->where('id', $id)->find();
            if (!$row) {
                $this->error(__('No Results were found'));
            }
            
            $row->express = OrderExpress::with(['item' => function ($query) use ($id) {
                return $query->where('order_id', $id);
            }, 'log'])->where('order_id', $id)->select();
    
            // 处理未支付 item status_code
            $row = $this->model->setOrderItemStatusByOrder($row);

            // 退款金额
            $row['refund_fee_total'] = array_sum(array_column($row['item'],'refund_fee'));

            return $this->success('获取成功', null, [
                'order' => $row,
                'item' => $row['item'],
                'express' => $row['express']
            ]);
        }

        $this->assignconfig('id', $id);
        return $this->view->fetch();
    }


    // 发货
    public function send($id, $item_id = '', $express_id = 0)
    {
        if ($this->request->isAjax()) {
            $express_name = $this->request->post('express_name', '');
            $express_code = $this->request->post('express_code', '');
            $express_no = $this->request->post('express_no', '');
            $item_id = $item_id ? explode(',', $item_id) : [];
            if (!$item_id) {
                $this->error('请选择要发货的商品');
            }
            if (!$express_name || !$express_code || !$express_no) {
                $this->error('请填写完整发货信息');
            }

            $order = $this->model->payed()->where('id', $id)->find();

            if (!$order) {
                $this->error('订单不存在或未支付');
            }

            // 编辑包裹
            $orderExpress = null;
            $need_subscribe = true;
            if ($express_id) {
                // 修改包裹
                $orderExpress = OrderExpress::where('id', $express_id)->find();
                if (!$orderExpress) {
                    $this->error('包裹不存在');
                }

                if ($orderExpress->express_no == $express_name && $orderExpress->express_code == $express_code) {
                    // 没有编辑快递信息，不需要重新订阅快递
                    $need_subscribe = false;
                }
            }

            // 查询要发货的商品
            $where = [
                'order_id' => $id,
                'id' => ['in', $item_id],
                'dispatch_type' => 'express'        // 必须是物流快递的商品
            ];
            $dispatchWhere = [
                \app\admin\model\shopro\order\OrderItem::DISPATCH_STATUS_NOSEND,
            ];
            if ($express_id) {
                // 修改可以修改已发货的 商品
                $dispatchWhere[] = \app\admin\model\shopro\order\OrderItem::DISPATCH_STATUS_SENDED;
            }
            $where['dispatch_status'] = ['in', $dispatchWhere];

            $item_list = \app\admin\model\shopro\order\OrderItem::where($where)->select();

            if (!$item_list) {
                $this->error('没有要发货的订单商品');
            }

            $orderExpress = Db::transaction(function () use ($order, $item_list, $orderExpress, $express_name, $express_code, $express_no, $item_id) {
                foreach ($item_list as $key => $item) {
                    $order->sendItem($order, $item, [
                        "express_name" => $express_name,
                        "express_code" => $express_code,
                        "express_no" => $express_no,
                        "oper" => $this->auth->getUserInfo(),
                        "oper_type" => 'admin',
                    ]);
                }
                
                if (!$orderExpress) {
                    // 添加包裹
                    $orderExpress = new OrderExpress();
                    $orderExpress->user_id = $order->user_id;
                    $orderExpress->order_id = $order->id;
                } else {
                    // 查询包裹老的商品,并且不在这次所选择之中，改为未发货
                    \app\admin\model\shopro\order\OrderItem::where('order_id', $order['id'])
                                        ->where('id', 'not in', $item_id)
                                        ->where('express_no', $orderExpress->express_no)
                                        ->where('express_code', $orderExpress->express_code)->update([
                                            'express_name' => null,
                                            'express_code' => null,
                                            'express_no' => null,
                                            'dispatch_status' => \app\admin\model\shopro\order\OrderItem::DISPATCH_STATUS_NOSEND
                                        ]);
                }

                $orderExpress->express_name = $express_name;
                $orderExpress->express_code = $express_code;
                $orderExpress->express_no = $express_no;
                $orderExpress->save();

                // 查询已经没有商品的包裹，并且删除
                OrderExpress::whereNotExists(function ($query) use ($order) {
                    $order_table_name = (new OrderExpress())->getQuery()->getTable();
                    $table_name = (new \app\admin\model\shopro\order\OrderItem())->getQuery()->getTable();
                    $query->table($table_name)->where($table_name . '.express_no=' . $order_table_name . '.express_no')
                                    ->where($table_name . '.express_code=' . $order_table_name . '.express_code')
                                    ->where('order_id', $order['id']);
                })->where('order_id', $order['id'])->delete();

                return $orderExpress;
            });

            // 将快递信息上报快递 api
            if ($need_subscribe) {
                try {
                    $expressLib = new \addons\shopro\library\Express();
                    $expressLib->subscribe([
                        'express_code' => $express_code,
                        'express_no' => $express_no
                    ], $orderExpress, $order);
                } catch (\Exception $e) {
                    $sub_msg = $e->getMessage();
                }
            }

            // 重新获取订单
            $order = $this->model->with(['item'])->where('id', $id)->find();

            return $this->success('发货成功' . (isset($sub_msg) ? ': '. $sub_msg : ''), null, $order);
        }
    }


    /**
     * 获取物流快递信息
     */
    public function getExpress($express_id = 0) {
        $type = $this->request->get('type');

        // 获取包裹
        $orderExpress = OrderExpress::with('order')->where('id', $express_id)->find();
        if (!$orderExpress) {
            return $this->error('包裹不存在');
        }

        $expressLib = new \addons\shopro\library\Express();

        try {
            if ($type == 'subscribe') {
                // 重新订阅
                $expressLib->subscribe([
                    'express_code' => $orderExpress['express_code'],
                    'express_no' => $orderExpress['express_no']
                ], $orderExpress, $orderExpress->order);
            } else {
                // 手动查询
                $result = $expressLib->search([
                    'express_code' => $orderExpress['express_code'],
                    'express_no' => $orderExpress['express_no']
                ], $orderExpress, $orderExpress->order);
    
                // 差异更新物流信息
                $expressLib->checkAndAddTraces($orderExpress, $result);
            }

            $order = $this->model->with(['item'])->where('id', $orderExpress['order_id'])->find();
            
        } catch (\Exception $e) {
            return $this->error(($type == 'subscribe' ? '订阅失败' : '刷新失败') . $e->getMessage());
        }

        return $this->success(($type == 'subscribe' ? '订阅成功' : '刷新成功'), null, $order);
    }


    // public function aftersaleFinish($id, $item_id)
    // {
    //     if ($this->request->isAjax()) {

    //         $where = [
    //             'order_id' => $id,
    //             'id' => $item_id,
    //             'aftersale_status' => \app\admin\model\shopro\order\OrderItem::AFTERSALE_STATUS_AFTERING
    //         ];

    //         $order = $this->model->where('status', 'in', [
    //                 \app\admin\model\shopro\order\Order::STATUS_PAYED,
    //                 \app\admin\model\shopro\order\Order::STATUS_FINISH
    //             ]
    //         )
    //             ->where('id', $id)->find();
    //         $item = \app\admin\model\shopro\order\OrderItem::where($where)->find();

    //         if (!$order || !$item) {
    //             $this->error('订单不存在或不是售后订单');
    //         }

    //         Db::transaction(function () use ($order, $item) {
    //             $item->aftersale_status = \app\admin\model\shopro\order\OrderItem::AFTERSALE_STATUS_OK;    // 售后完成
    //             $item->save();

    //             \addons\shopro\model\OrderAction::operAdd($order, $item, $this->auth->getUserInfo(), 'admin', '管理员售后完成订单');
    //         });

    //         $item_list = \app\admin\model\shopro\order\OrderItem::where(['order_id' => $id])->select();
    //         return $this->success('操作成功', null, $item_list);
    //     }
    // }


    // /**
    //  * 拒绝退款
    //  */
    // public function refundRefuse($id = 0, $item_id = 0)
    // {
    //     if ($this->request->isAjax()) {
    //         $refund_msg = $this->request->post('refund_msg');

    //         $where = [
    //             'order_id' => $id,
    //             'id' => $item_id,
    //             'refund_status' => \app\admin\model\shopro\order\OrderItem::REFUND_STATUS_ING
    //         ];

    //         $order = $this->model->where('status', 'in', [
    //                 \app\admin\model\shopro\order\Order::STATUS_PAYED,
    //                 \app\admin\model\shopro\order\Order::STATUS_FINISH
    //             ]
    //         )->where('id', $id)->find();

    //         $item = \app\admin\model\shopro\order\OrderItem::where($where)->find();

    //         if (!$order || !$item) {
    //             $this->error('订单不存在或不是退款订单');
    //         }

    //         Db::transaction(function () use ($order, $item, $refund_msg) {
    //             // 订单退款拒绝前
    //             $data = ['order' => $order, 'item' => $item];
    //             \think\Hook::listen('order_refund_refuse_before', $data);

    //             $item->refund_status = \app\admin\model\shopro\order\OrderItem::REFUND_STATUS_REFUSE;    // 拒绝退款
    //             $item->refund_msg = $refund_msg;
    //             $item->save();

    //             \addons\shopro\model\OrderAction::operAdd($order, $item, $this->auth->getUserInfo(), 'admin', '管理员拒绝订单退款');

    //             // 订单退款拒绝后
    //             $data = ['order' => $order, 'item' => $item];
    //             \think\Hook::listen('order_refund_refuse_after', $data);
    //         });

    //         $item_list = \app\admin\model\shopro\order\OrderItem::where(['order_id' => $id])->select();
    //         return $this->success('操作成功', null, $item_list);
    //     }
    // }


    /**
     * 同意退款
     */
    public function refund($id = 0, $item_id = 0)
    {
        if ($this->request->isAjax()) {
            $refund_money = round($this->request->post('refund_money', 0), 2);

            if ($refund_money <= 0) {
                $this->error('退款金额必须大于 0');
            }

            $order = $this->model->where('status', 'in', [
                    \app\admin\model\shopro\order\Order::STATUS_PAYED,
                    \app\admin\model\shopro\order\Order::STATUS_FINISH
                ]
            )
            ->with('item')->where('id', $id)->find();

            if (!$order) {
                $this->error('订单不存在或不可退款');
            }

            $items = $order->item;
            $items = array_column($items, null, 'id');

            // 当前订单已退款总金额
            $refunded_money = array_sum(array_column($items, 'refund_fee'));
            // 剩余可退款金额
            $refund_surplus_money = $order->pay_fee - $refunded_money;
            // 如果退款金额大于订单支付总金额
            if ($refund_money > $refund_surplus_money) {
                $this->error('退款总金额不能大于实际支付金额');
            }

            if ($item_id) {
                $item = $items[$item_id];
                if (!$item || in_array($item['refund_status'], [
                    \app\admin\model\shopro\order\OrderItem::REFUND_STATUS_OK,
                    \app\admin\model\shopro\order\OrderItem::REFUND_STATUS_FINISH,
                ])) {
                    $this->error('订单商品已退款，不能重复退款');
                }
            } else {
                $is_refund = false;
                foreach ($items as $key => $it) {
                    if (in_array($it['refund_status'], [
                        \app\admin\model\shopro\order\OrderItem::REFUND_STATUS_OK,
                        \app\admin\model\shopro\order\OrderItem::REFUND_STATUS_FINISH,
                    ])) {
                        // 已退款
                        unset($items[$key]);
                    } else {
                        $is_refund = true;
                    }
                }
                $items = array_values($items);

                if (!$is_refund) {
                    $this->error('订单已退款，不能重复退款');
                }
            }

            Db::transaction(function () use ($order, $items, $item_id, $refund_money, $refund_surplus_money) {
                if ($item_id) {
                    // 单个商品退款
                    $item = $items[$item_id];
                    \app\admin\model\shopro\order\Order::startRefund($order, $item, $refund_money, $this->auth->getUserInfo(), '管理员操作退款');
                } else {
                    // 全部退款
                    // 未退款 item 商品总金额
                    $goods_total_amount = 0;
                    foreach ($items as $ke => $it) {
                        $goods_total_amount += ($it['goods_price'] * $it['goods_num']);
                    }

                    $current_refunded_money = 0;
                    for($i = 0; $i < count($items); $i ++) {
                        if ($i == (count($items) - 1)) {
                            // 最后一条,全部退完
                            $current_refund_money = $refund_money - $current_refunded_money;
                        } else {
                            // 按比例计算当前 item 应退金额
                            $current_refund_money = round($refund_money * (($items[$i]['goods_price'] * $it['goods_num']) / $goods_total_amount), 2);
                        }
                        if (($current_refunded_money + $current_refund_money) > $refund_money) {
                            $current_refund_money = $refund_money - $current_refunded_money;
                        }

                        if ($current_refund_money > 0) {
                            $current_refunded_money += $current_refund_money;

                            \app\admin\model\shopro\order\Order::startRefund($order, $items[$i], $current_refund_money, $this->auth->getUserInfo(), '管理员操作退款');
                        }
                    }
                }
            });

            $item_list = \app\admin\model\shopro\order\OrderItem::where(['order_id' => $id])->select();
            return $this->success('操作成功', null, $item_list);
        }
    }


    // 取消订单
    public function cancel($id)
    {
        if ($this->request->isAjax()) {
            $order = $this->model->where('id', $id)->nopay()->find();
            if (!$order) {
                $this->error('订单不存在或已取消');
            }

            $order = $order->doCancel($order, $this->auth->getUserInfo(), 'admin');

            return $this->success('操作成功', null, $order);
        }
    }


    // 修改收货人信息
    public function editConsignee($id)
    {
        if ($this->request->isAjax()) {
            $params = $this->request->post();
            extract($params);

            $row = $this->model->get($id);
            if (!$row) {
                $this->error('订单不存在');
            }

            try {
                if ($this->modelValidate) {
                    $name = str_replace("\\model\\", "\\validate\\", get_class($this->model));
                    $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.edit' : $name) : $this->modelValidate;
                    $row->validateFailException(true)->validate($validate);
                }

                $result = $row->save([
                    'consignee' => $consignee,
                    'phone' => $phone,
                    'province_id' => $province_id,
                    'province_name' => $province_name,
                    'city_id' => $city_id,
                    'city_name' => $city_name,
                    'area_id' => $area_id,
                    'area_name' => $area_name,
                    'address' => $address,
                ], ['id' => $id]);
            } catch (ValidateException $e) {
                $this->error($e->getMessage());
            } catch (PDOException $e) {
                $this->error($e->getMessage());
            } catch (Exception $e) {
                $this->error($e->getMessage());
            }
            if ($result !== false) {
                $order = $this->model->with('user')->where('id', $id)->find();
                $this->success('修改成功', null, $order);
            } else {
                $this->error(__('No rows were updated'));
            }
        }
    }

    // 编辑商家备注
    public function editMemo($id)
    {
        if ($this->request->isAjax()) {
            $memo = $this->request->post('memo');

            $order = $this->model->get($id);
            if (!$order) {
                $this->error('订单不存在');
            }

            $order->memo = $memo;
            $order->save();

            \addons\shopro\model\OrderAction::operAdd($order, null, $this->auth->getUserInfo(), 'admin', "修改备注：" . $memo);

            return $this->success('操作成功', null, $order);
        }
    }


    // 获取订单操作记录
    public function actions($id)
    {
        $actions = \app\admin\model\shopro\order\OrderAction::with('oper')->where('order_id', $id)->select();

        foreach ($actions as $key => $action) {
            $action = $action->toArray();
            if ($action['oper_type'] == 'admin') {
                $oper = [
                    'id' => $action['oper_id'],
                    'name' => $action['oper'] ? $action['oper']['nickname'] : ''
                ];
            } else if ($action['oper_type'] == 'user') {
                $oper = [
                    'id' => $action['oper_id'],
                    'name' => '用户'
                ];
            } else if ($action['oper_type'] == 'system') {
                $oper = [
                    'id' => $action['oper_id'],
                    'name' => '系统'
                ];
            } else {
                $oper = null;
            }

            $action['oper'] = $oper;
            $actions[$key] = $action;
        }

        return $this->success('操作成功', null, $actions);
    }


    // 构建查询条件
    private function buildSearchOrder()
    {
        $filter = $this->request->get("filter", '');
        $filter = (array)json_decode($filter, true);
        $filter = $filter ? $filter : [];

        $dispatch_type = isset($filter['dispatch_type']) ? $filter['dispatch_type'] : 'all';
        $status = isset($filter['status']) ? $filter['status'] : 'all';
        $goods_type = isset($filter['goods_type']) ? $filter['goods_type'] : 'all';
        $aftersale_sn = isset($filter['aftersale_sn']) ? $filter['aftersale_sn'] : '';
        $nickname = isset($filter['nickname']) ? $filter['nickname'] : '';
        $mobile = isset($filter['user_phone']) ? $filter['user_phone'] : '';
        $goods_title = isset($filter['goods_title']) ? $filter['goods_title'] : '';
        $dealer_id = $this->request->get('dealer_id','');

        $name = $this->model->getQuery()->getTable();
        $tableName = $name . '.';

//        $orders = $this->model->withTrashed();
        $orders = $this->model;

        if ($nickname || $mobile) {
            $orders = $orders->whereExists(function ($query) use ($nickname, $mobile, $tableName) {
                $userTableName = (new \app\admin\model\User())->getQuery()->getTable();

                $query = $query->table($userTableName)->where($userTableName . '.id=' . $tableName . 'user_id');

                if ($nickname) {
                    $query = $query->where('nickname', 'like', "%{$nickname}%");
                }

                if ($mobile) {
                    $query = $query->where('mobile', 'like', "%{$mobile}%");
                }

                return $query;
            });
        }

        // 售后单号
        if ($aftersale_sn) {
            $orders = $orders->whereExists(function ($query) use ($aftersale_sn, $tableName) {
                $itemTableName = (new \app\admin\model\shopro\order\Aftersale())->getQuery()->getTable();

                $query->table($itemTableName)->where($itemTableName . '.order_id=' . $tableName . 'id')
                    ->where('aftersale_sn', $aftersale_sn);
            });
        }

        // 经销商
        $dealer = [];
        $group_id_arr = array_column($this->auth->getGroups(), 'group_id');
        if(!in_array(1,$group_id_arr) && in_array(2,$group_id_arr)){
            $dealer = \app\admin\model\dealer\Dealer::where('admin_id',$this->auth->id)->find();
        }
        if(!$dealer && $dealer_id){
            $dealer = \app\admin\model\dealer\Dealer::where('id',$dealer_id)->find();
        }

        // 快递方式 || 商品类型 (同一个表，写在一起)
        if ($dispatch_type != 'all' || $goods_type != 'all' || $goods_title || $dealer) {
            $orders = $orders->whereExists(function ($query) use ($dispatch_type, $goods_type, $goods_title, $dealer, $tableName) {
                $itemTableName = (new \app\admin\model\shopro\order\OrderItem())->getQuery()->getTable();

                $query = $query->table($itemTableName)->where($itemTableName . '.order_id=' . $tableName . 'id');

                if ($dispatch_type != 'all') {
                    $query = $query->where('dispatch_type', $dispatch_type);
                }
                
                if ($goods_type != 'all') {
                    $query = $query->where('goods_type', $goods_type);
                }

                if ($goods_title) {
                    $query = $query->where('goods_title', 'like', "%{$goods_title}%");
                }

                if ($dealer) {
                    $query = $query->where('dealer_id', $dealer['id']);
                }

                return $query;
            });
        }

        // 订单状态
        if ($status != 'all') {
            if (in_array($status, ['invalid', 'cancel', 'nopay', 'nosend', 'noget', 'nocomment', 'aftersale', 'refund', 'payed', 'finish'])) {
                if (in_array($status, ['nosend', 'noget', 'nocomment', 'aftersale', 'refund'])) {
                    $orders = $orders->payed();
                }
                $status = $status == 'refund' ? 'refundStatus' : $status;
                $orders = $orders->{$status}();
            }
        }

        return $orders;
    }

    /**
     * 批量发货
     */
    public function multiSend()
    {
        $file = $this->request->request('file');
        if (!$file) {
            $this->error(__('Parameter %s can not be empty', 'file'));
        }
        $filePath = ROOT_PATH . DS . 'public' . DS . $file;
        if (!is_file($filePath)) {
            $this->error(__('No results were found'));
        }
        //实例化reader
        $ext = pathinfo($filePath, PATHINFO_EXTENSION);
        if (!in_array($ext, ['csv', 'xls', 'xlsx'])) {
            $this->error(__('Unknown data format'));
        }
        if ($ext === 'csv') {
            $file = fopen($filePath, 'r');
            $filePath = tempnam(sys_get_temp_dir(), 'import_csv');
            $fp = fopen($filePath, "w");
            $n = 0;
            while ($line = fgets($file)) {
                $line = rtrim($line, "\n\r\0");
                $encoding = mb_detect_encoding($line, ['utf-8', 'gbk', 'latin1', 'big5']);
                if ($encoding != 'utf-8') {
                    $line = mb_convert_encoding($line, 'utf-8', $encoding);
                }
                if ($n == 0 || preg_match('/^".*"$/', $line)) {
                    fwrite($fp, $line . "\n");
                } else {
                    fwrite($fp, '"' . str_replace(['"', ','], ['""', '","'], $line) . "\"\n");
                }
                $n++;
            }
            fclose($file) || fclose($fp);

            $reader = new Csv();
        } elseif ($ext === 'xls') {
            $reader = new Xls();
        } else {
            $reader = new Xlsx();
        }

        //导入文件首行类型,默认是注释,如果需要使用字段名称请使用name
//        $importHeadType = isset($this->importHeadType) ? $this->importHeadType : 'comment';
//
//        $table = $this->model->getQuery()->getTable();
//        $database = \think\Config::get('database.database');
//        $fieldArr = [];
//        $list = db()->query("SELECT COLUMN_NAME,COLUMN_COMMENT FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME = ? AND TABLE_SCHEMA = ?", [$table, $database]);
//        foreach ($list as $k => $v) {
//            if ($importHeadType == 'comment') {
//                $fieldArr[$v['COLUMN_COMMENT']] = $v['COLUMN_NAME'];
//            } else {
//                $fieldArr[$v['COLUMN_NAME']] = $v['COLUMN_NAME'];
//            }
//        }
        $fieldArr = [
            'Id' => 'order_id',
            '订单号' => 'order_sn',
            '订单状态' => 'status_text',
            '支付时间' => 'paytime_text',
            '用户信息' => 'user_info',
            '订单总金额' => 'total_amount',
            '优惠金额' => 'discount_fee',
            '实际支付金额' => 'pay_fee',
            '营销类型' => 'activity_type_text',
            '商品名称' => 'goods_title',
            '规格编号' => 'goods_sku_sn',
            '商品原价' => 'goods_original_price',
            '商品价格' => 'goods_price',
            '商品规格' => 'goods_sku_text',
            '购买数量' => 'goods_num',
            '发货状态' => 'dispatch_status_text',
            '发货费用' => 'dispatch_fee',
            '退款金额' => 'refund_fee',
            '退款原因' => 'refund_msg',
            '收货人' => 'consignee',
            '收货人电话' => 'phone',
            '省' => 'province_name',
            '市' => 'city_name',
            '区' => 'area_name',
            '收货详细地址' => 'address',
            '收货地址' => 'full_address',
            '快递公司' => 'express_name',
            '快递编码' => 'express_code',
            '快递单号' => 'express_no',
        ];

        //加载文件
        $insert = [];
        try {
            if (!$PHPExcel = $reader->load($filePath)) {
                $this->error(__('Unknown data format'));
            }
            $currentSheet = $PHPExcel->getSheet(0);  //读取文件中的第一个工作表
            $allColumn = $currentSheet->getHighestDataColumn(); //取得最大的列号
            $allRow = $currentSheet->getHighestRow(); //取得一共有多少行
            $maxColumnNumber = Coordinate::columnIndexFromString($allColumn);
            $fields = [];
            for ($currentRow = 1; $currentRow <= 1; $currentRow++) {
                for ($currentColumn = 1; $currentColumn <= $maxColumnNumber; $currentColumn++) {
                    $val = $currentSheet->getCellByColumnAndRow($currentColumn, $currentRow)->getValue();
                    $fields[] = $val;
                }
            }

            for ($currentRow = 2; $currentRow <= $allRow; $currentRow++) {
                $values = [];
                for ($currentColumn = 1; $currentColumn <= $maxColumnNumber; $currentColumn++) {
                    $val = $currentSheet->getCellByColumnAndRow($currentColumn, $currentRow)->getValue();
                    $values[] = is_null($val) ? '' : $val;
                }
                $row = [];
                $temp = array_combine($fields, $values);
                foreach ($temp as $k => $v) {
                    if (isset($fieldArr[$k]) && $k !== '') {
                        $row[$fieldArr[$k]] = $v;
                    }
                }
                if ($row) {
                    $insert[] = $row;
                }
            }
        } catch (Exception $exception) {
            $this->error($exception->getMessage());
        }

        if (!$insert) {
            $this->error(__('No rows were updated'));
        }

        // 经销商
        $dealer = [];
        $group_id_arr = array_column($this->auth->getGroups(), 'group_id');
        if(!in_array(1,$group_id_arr) && in_array(2,$group_id_arr)){
            $dealer = \app\admin\model\dealer\Dealer::where('admin_id',$this->auth->id)->find();
        }

        try {
            foreach ($insert as $insert_order){
                if($insert_order['order_sn']){
                    $order = $this->model->payed()->where('id', $insert_order['order_id'])->find();
                    $item_where = [
                        'order_id' => $insert_order['order_id'],
                        'goods_title' => $insert_order['goods_title'],
                        'dispatch_status' => \app\admin\model\shopro\order\OrderItem::DISPATCH_STATUS_NOSEND,
                        'aftersale_status' => \app\admin\model\shopro\order\OrderItem::AFTERSALE_STATUS_NOAFTER
                    ];
                    if($dealer){
                        $item_where['dealer_id'] = $dealer['id'];
                    }
                    $item = \app\admin\model\shopro\order\OrderItem::where($item_where)->find();
                    if($order && $item){
                        // 编辑包裹
                        $orderExpress = null;
                        $need_subscribe = true;
                        if ($insert_order['express_no']) {
                            if(!$insert_order['express_code']){
                                $this->error('请填写Id为'.$insert_order['order_id'].'的快递编码');
                            }
                            // 修改包裹
                            $orderExpress = OrderExpress::where('express_no', $insert_order['express_no'])
                                ->where('express_code',$insert_order['express_code'])
                                ->where('order_id',$insert_order['order_id'])
                                ->find();
                            if ($orderExpress) {
                                // 没有编辑快递信息，不需要重新订阅快递
                                $need_subscribe = false;
                            }
                            $orderExpress = Db::transaction(function () use ($insert_order, $order, $item, $orderExpress) {
                                $order->sendItem($order, $item, [
                                    "express_name" => $insert_order['express_name'],
                                    "express_code" => $insert_order['express_code'],
                                    "express_no" => $insert_order['express_no'],
                                    "oper" => $this->auth->getUserInfo(),
                                    "oper_type" => 'admin',
                                ]);
                                if (!$orderExpress) {
                                    // 添加包裹
                                    $orderExpress = new OrderExpress();
                                    $orderExpress->user_id = $order->user_id;
                                    $orderExpress->order_id = $order->id;
                                }
                                $orderExpress->express_name = $insert_order['express_name'];
                                $orderExpress->express_code = $insert_order['express_code'];
                                $orderExpress->express_no = $insert_order['express_no'];
                                $orderExpress->save();

                                // 查询已经没有商品的包裹，并且删除
                                OrderExpress::whereNotExists(function ($query) use ($order) {
                                    $order_table_name = (new OrderExpress())->getQuery()->getTable();
                                    $table_name = (new \app\admin\model\shopro\order\OrderItem())->getQuery()->getTable();
                                    $query->table($table_name)->where($table_name . '.express_no=' . $order_table_name . '.express_no')
                                        ->where($table_name . '.express_code=' . $order_table_name . '.express_code')
                                        ->where('order_id', $order['id']);
                                })->where('order_id', $order['id'])->delete();
                                return $orderExpress;
                            });

                            // 将快递信息上报快递 api
                            if ($need_subscribe) {
                                try {
                                    $expressLib = new \addons\shopro\library\Express();
                                    $expressLib->subscribe([
                                        'express_code' => $insert_order['express_code'],
                                        'express_no' => $insert_order['express_no']
                                    ], $orderExpress, $order);
                                } catch (\Exception $e) {
                                    $sub_msg = $e->getMessage();
                                }
                            }
                        }
                    }
                }
            }
        } catch (PDOException $exception) {
            $msg = $exception->getMessage();
            if (preg_match("/.+Integrity constraint violation: 1062 Duplicate entry '(.+)' for key '(.+)'/is", $msg, $matches)) {
                $msg = "导入失败，包含【{$matches[1]}】的记录已存在";
            };
            $this->error($msg);
        } catch (Exception $e) {
            $this->error($e->getMessage());
        }
        $this->success((isset($sub_msg) ? ': '. $sub_msg : ''));
    }
}