mall/modules/admin/models/adopt/AdoptCostOrderListForm.php

<?php
/**
 * 重庆赤晓店信息科技有限公司
 * https://www.chixiaodian.com
 * Copyright (c) 2023 赤店商城 All rights reserved.
 */
namespace app\modules\admin\models\adopt;

use app\models\common\admin\order\CommonOrderSearch;
use app\models\DeliveryInfo;
use app\models\Express;
use app\models\Md;
use app\models\Order;
use app\models\OrderDetail;
use app\models\OrderForm;
use app\models\OrderRefund;
use app\models\OrderStateFlow;
use app\models\SaasUser;
use app\models\Shop;
use app\models\User;
use app\plugins\adopt\models\AdoptCostOrder;
use app\plugins\adopt\models\AdoptOrderInfo;
use app\utils\Delivery\Delivery;
use app\utils\Export;
use app\utils\ExportList;
use yii\base\Model;
use yii\db\Query;
use yii\helpers\Json;

class AdoptCostOrderListForm extends Model
{
    public $store_id;
    public $user_id;
    public $keyword;
    public $status;
    public $page;
    public $limit;

    public $md_name;
    public $order_no;
    public $goods_name;
    public $mobile;


    public $is_offline;
    public $clerk_id;
    public $parent_id;
    public $shop_id;
    public $order_type;

    public $dateStart;
    public $dateEnd;
    public $express_type;
    public $keywordType;
    public $seller_comments;

    public $fields;
    public $type;
    public $mch_id;
    public $flag; // 是否导出

    public $supplier_id;
    public $supplier;


    /**
     * @var 所属平台
     */
    public $platform;//所属平台
    /**
     * @var bool 是否是配送员订单
     */
    public $is_delivery = false;//是否是配送员订单
    /**
     * @var bool 是否是配送员订单
     */
    public $is_same_city = false;//是否是配送员订单
    /**
     * @var 获取默写城市的订单 例如：["\u5357\u5b81","\u4e0a\u6d77"]
     */
    public $shop_list;
    public $order_id;

    public function rules()
    {
        return [
            [['keyword', 'flag'], 'trim'],
            [['status', 'page', 'limit', 'user_id', 'is_offline', 'clerk_id', 'shop_id', 'keywordType', 'platform', 'order_type'], 'integer'],
            [['status',], 'default', 'value' => -1],
            [['page',], 'default', 'value' => 1],
            [['dateStart', 'dateEnd', 'express_type', 'md_name', 'order_no', 'goods_name', 'mobile'], 'trim'],
            [['seller_comments', 'flag'], 'string'],
            [['fields', 'is_delivery', 'shop_list'], 'safe']
        ];
    }

    public function search($is_scan_pay = false)
    {
        if (!$this->validate()) {
            return [
                'code' => 1,
                'msg' => $this->getErrorSummary(false)[0],
            ];
        }
        $query = AdoptCostOrder::find()->alias('o')->where([
            'o.store_id' => $this->store_id
        ])->andWhere(['!=','order_type', 5]);

        if (get_md_id()) {
            $query->andWhere(['o.md_id' => get_md_id()]);
        }
        if (!is_null($this->order_type) && in_array($this->order_type, [0, 1])) {
            $query->andWhere([
                'o.order_type' => $this->order_type
            ]);
        }

        $query->leftJoin(['u' => User::tableName()], 'u.id = o.user_id')
            ->leftJoin(['su' => SaasUser::tableName()], 'su.mobile=u.binding')
            ->leftJoin(['od' => OrderDetail::tableName()], 'od.order_id=o.order_id');

        switch ($this->status) {
            case 0:
                $query->andWhere(['o.is_delete' => Order::IS_DELETE_FALSE, 'is_pay' => Order::IS_PAY_FALSE]);
                break;
            case 1:
                $query->andWhere([
                    'o.trade_status' => Order::ORDER_FLOW_NO_SEND,
                    'o.is_delete' => Order::IS_DELETE_FALSE
                ])->andWhere(['or', ['o.is_pay' => Order::IS_PAY_TRUE], ['o.pay_type' => Order::PAY_TYPE_COD]]);
                break;
            case 2:
                $query->andWhere([
                    'o.trade_status' => Order::ORDER_FLOW_SEND,
                    'o.is_delete' => Order::IS_DELETE_FALSE
                ])->andWhere(['or', ['o.is_pay' => Order::IS_PAY_TRUE], ['o.pay_type' => Order::PAY_TYPE_COD]]);
                break;
            case 3:
                $query->andWhere([
                    'o.trade_status' => Order::ORDER_FLOW_CONFIRM,
                    'o.is_delete' => Order::IS_DELETE_FALSE
                ])->andWhere(['or', ['o.is_pay' => Order::IS_PAY_TRUE], ['o.pay_type' => Order::PAY_TYPE_COD]]);
                break;
            case 4:
                break;
            case 5:
                $query->andWhere(['and',['o.is_delete' => 1]]);
                break;
            case 6:
                $query->andWhere(['and',['o.apply_delete' => Order::ORDER_APPLY_DELETE], ['!=', 'o.trade_status', Order::ORDER_FLOW_CANCEL]]);
                break;
            default:
                if (empty($this->order_id)) {
                    $query->andWhere([
                        'o.is_delete' => Order::IS_DELETE_FALSE
                    ]);
                }
                break;
        }

        if (get_params('is_recycle')) {
            $query->andWhere([
                'o.is_recycle' => Order::IS_DELETE_TRUE
            ]);
        } else {
            $query->andWhere([
                'o.is_recycle' => Order::IS_DELETE_FALSE
            ]);
        }


        if ($this->order_id && $this->order_id > 0) {
            $query->andWhere(['o.id' => $this->order_id]);
        }
        // TODO:
        $commonOrderSearch = new CommonOrderSearch();
        if (!$this->order_id) {
//            $query = $commonOrderSearch->search($query, $this);
//            $query = $commonOrderSearch->keyword($query, $this->keywordType, $this->keyword);
            if ($this->md_name) {
                $query->leftJoin(['md' => Md::tableName()], 'md.id=o.md_id')->andWhere(['like', 'md.name', $this->md_name]);
            }
            if ($this->order_no) {
                $query->andWhere(['like', 'o.order_no', $this->order_no]);
            }
            if ($this->mobile) {
                $query->andWhere([
                    'or',
                    ['like', 'o.mobile', $this->mobile],
                    ['like', 'u.binding', $this->mobile],
                ]);
            }
            if ($this->goods_name) {
                $query->andWhere(['like', 'od.goods_name', $this->goods_name]);
            }
        }

        if ($this->dateStart) {
            $query->andWhere(['>=', 'o.created_at', strtotime($this->dateStart)]);
        }
        if ($this->dateEnd) {
            $query->andWhere(['<=', 'o.created_at', strtotime($this->dateEnd)]);
        }

        if ($this->flag == Export::EXPORT) {
            $query_ex = clone $query;
            $list_ex = $query_ex;
            $export = new ExportList();
            $export->is_offline = $this->is_offline;
            $export->order_type = 0;
            $export->fields = $this->fields;
            $export->dataTransform_new($list_ex);
        }
        if (!$this->order_id) {
            $query->andWhere(['o.is_offline' => $this->is_offline]);
        }

        if ($this->platform !== null && $this->platform !== '') {
            $query->andWhere([
                'u.platform' => $this->platform
            ]);
        }

//        $refundQuery1 = OrderRefund::find()->alias('or')
//            ->select('or.status, or.order_id, or.created_at')
//            ->where(['or.store_id' => $this->store_id, 'or.is_delete' => 0]);
//        $refundQuery = (new Query())->from(['or' => $refundQuery1])->where('`or`.order_id=o.id')
//            ->select('or.status')
//            ->orderBy(['or.created_at' => SORT_DESC])
//            ->limit(1);
        $query->orderBy('o.created_at DESC')
            ->select(['o.*', 'su.name as nickname', 'u.nickname as de_name', 'u.platform',
                 'od.delivery_type', 'od.attr', 'o.name user_name', 'o.mobile user_mobile', 'o.address user_address']);
//        print_r($query);die;
        $query->groupBy('o.order_no');
        $pagination = pagination_make($query);
        $listArray = $pagination['list'];

        foreach ($listArray as $i => &$item) {
            $order = Order::find()->alias('o')
                ->leftJoin(['aoi' => AdoptOrderInfo::tableName()], 'o.id = aoi.order_id')
                ->where([
                    'o.id' => $item['order_id'],
                    'o.store_id' => $this->store_id,
                    'o.order_type' => 5
                ])->select(['o.order_no','aoi.harvest_weight'])->asArray()->one();

            $item['adopt_order_no'] = $order['order_no'];
            $item['harvest_weight'] = $order['harvest_weight'];

            $item['book'] = [];
            if ($item['order_type'] == 1) {
                $attr = Json::decode($item['attr']);
                if (count($attr) > 1) {
                    $date_data = current($attr)['date'] . '/' . end($attr)['date'];
                } else {
                    $date_data = $attr[0]['date'];
                }
                $item['book'] = [
                    'date' => $date_data
                ];
            }
            if ($item['order_type'] == 2) {
                $tmp_attr = Json::decode($item['attr']);
                $item['book']['date'] = $tmp_attr['date'] . ' ' . $tmp_attr['time'];
            }
            $item['created_at'] = date('Y-m-d H:i:s', $item['created_at']);
            $item['goods_list'] = $this->getOrderGoodsList($item['order_id']);
            $item['clerk_name'] = '';
            $shop = Shop::findOne($item['shop_id']);
            if ($shop) {
                $user = User::findOne(Shop::findOne($item['shop_id'])->user_id);
                if ($user) {
                    $item['clerk_name'] = $user->nickname;
                }
            }

            $item['integral'] = json_decode($item['integral'], true);
            if (isset($item['address_data'])) {
                $item['address_data'] = json_decode($item['address_data']);
            }
            $item['flag'] = 0;

            $item['delivery_info'] = [];
            // 同城配送配送信息
            if ($item['delivery_type'] == OrderDetail::GOODS_DELIVERY_IM) {
                $delivery_info = DeliveryInfo::findOne(['order_no' => $item['order_no']]);
                $item['delivery_info'] = [
                    'waybill_id' => $delivery_info->waybill_id,
                    'status' => Delivery::$validOrderStatus[$delivery_info->status],
                    'reason' => $delivery_info->reason_id > 0 ? Delivery::$validReason[$delivery_info->reason_id] : '',
                    'fee' => $delivery_info->fee,
                    'duct_fee' => $delivery_info->deduct_fee,
                    'delivery_type' => Delivery::$deliveryType[$delivery_info->delivery_type],
                    'rider_name' => $delivery_info->rider_name,
                    'rider_mobile' => $delivery_info->rider_mobile
                ];
            }
            $item['md_info'] = null;
            if ($item['md_id']) {
                $item['md_info'] = Md::findOne($item['md_id']);
            }
            $item['pay_user_info'] = null;
            if ($item['pay_user_id'] > 0) {
                $pay_saas_user = SaasUser::findOne(['mobile' => User::findOne($item['pay_user_id'])->binding]);
                $item['pay_user_info'] = [
                    'name' => $pay_saas_user->name,
                    'mobile' => $pay_saas_user->mobile
                ];
            }
            $item['cost_detail'] = json_decode($item['cost_detail'],true);
        }
        // 获取可导出数据
        $f = new ExportList();
        $exportList = $f->getList();
        return [
            'code' => 0,
            'msg' => 'success',
            'data' => [
                'export_list' => $exportList,
                'express_list' => $this->getExpressList(),
                'data' => $listArray,
                'pageNo' => $pagination['pageNo'],
                'totalCount' => $pagination['totalCount'],
            ],
        ];
    }

    /**
     * @param $data array 需要处理的数据
     */
    public function dataTransform($data)
    {
        //TODO 测试数据 需要换成真实的字段
        $newFields = [];
        foreach ($this->fields as &$item) {
            if ($this->is_offline == 1) {
                if (in_array($item['key'], ['clerk_name', 'shop_name'])) {
                    $item['selected'] = 1;
                }
            } else {
                if (in_array($item['key'], ['express_price', 'express_no', 'express'])) {
                    $item['selected'] = 1;
                }
            }
            if (isset($item['selected']) && $item['selected'] == 1) {
                $newFields[$item['key']] = $item['value'];
            }
        }

        $newList = [];
        foreach ($data as $datum) {
            $newItem = [];
            $newItem['order_no'] = $datum->order_no;
            $newItem['nickname'] = $datum->user->nickname;
            $newItem['name'] = $datum->name;
            $newItem['mobile'] = $datum->mobile;
            $newItem['address'] = $datum->address;
            $newItem['total_price'] = $datum->total_price;
            $newItem['pay_price'] = $datum->pay_price;
            $newItem['pay_time'] = $datum->pay_time ? date('Y-m-d H:i', $datum->pay_time) : '';
            $newItem['send_time'] = $datum->send_time ? date('Y-m-d H:i', $datum->send_time) : '';
            $newItem['confirm_time'] = $datum->confirm_time ? date('Y-m-d H:i', $datum->confirm_time) : '';
            $newItem['words'] = $datum->words;
            $newItem['goods_list'] = $this->getOrderGoodsList($datum['id']);
            $newItem['is_pay'] = $datum['is_pay'] == 1 ? "已付款" : "未付款";
            $newItem['addtime'] = date('Y-m-d H:i', $datum['created_at']);
            $newItem['express_price'] = $datum['express_price'] . "元";
            $newItem['apply_delete'] = ($datum['apply_delete'] == Order::ORDER_APPLY_DELETE) ? ($datum['trade_status'] == Order::ORDER_FLOW_CANCEL || $datum['is_delete'] == Order::IS_DELETE_TRUE ? '取消成功' : '取消中') : "无";
            $newItem['trade_status'] = OrderStateFlow::getFlowWords($datum['trade_status']);

            // 是否到店自提 0--否 1--是
            if ($datum['is_offline']) {
                $newItem['clerk_name'] = $datum->clerk ? $datum->clerk->nickname : '';
                $newItem['shop_name'] = $datum->shop ? $datum->shop->name : '';
            } else {
                $newItem['express_price'] = $datum->express_price;
                $newItem['express_no'] = $datum->express_no;
                $newItem['express'] = $datum->express;
            }

            if ($datum->orderForm) {
                $str = '';
                foreach ($datum->orderForm as $key => $item) {
                    $str .= $item['key'] . ':' . $item['value'] . ',';
                }
                $newItem['content'] = rtrim($str, ',');
            } else {
                $newItem['content'] = $datum->content;
            }

            $newList[] = $newItem;
        }
        //Export::order_3($newList, $newFields);
    }

    public function getOrderGoodsList($order_id)
    {
        $orderDetailList = OrderDetail::find()->alias('od')
            ->where([
                'od.is_delete' => 0,
                'od.order_id' => $order_id,
            ])->select(['od.num', 'od.total_price', 'od.attr', 'od.is_level', 'od.batch_price_tips', 'name' => 'od.goods_name','od.pic', 'od.goods_info', 'od.delivery_type', 'od.shop_id', 'od.goods_id'])->asArray()->all();
        foreach ($orderDetailList as &$item) {
            $item['form'] = OrderForm::findAll(['goods_id' => $item['goods_id'], 'order_id' => $order_id]);
            $item['attr_list'] = json_decode($item['attr'], true);
            $item['unit'] = Json::decode($item['goods_info'])['unit'];
            $item['shop'] = [];
            if ($item['delivery_type'] == OrderDetail::GOODS_DELIVERY_SHOP) {
                $shop_info = Shop::find()->where(['id' => $item['shop_id']])->asArray()->one();
                $item['shop']['address'] = $shop_info['address'];
                $item['shop']['id'] = $shop_info['id'];
                $item['shop']['name'] = $shop_info['name'];
                $item['shop']['mobile'] = $shop_info['mobile'];
            }
        }

        return $orderDetailList;
    }

    public static function getCountData($store_id)
    {
        $form = new OrderListForm();
        $form->limit = 0;
        $form->store_id = $store_id;
        $data = [];

        $form->status = -1;
        $res = $form->search();
        $data['all'] = $res['row_count'];

        $form->status = 0;
        $res = $form->search();
        $data['status_0'] = $res['row_count'];

        $form->status = 1;
        $res = $form->search();
        $data['status_1'] = $res['row_count'];

        $form->status = 2;
        $res = $form->search();
        $data['status_2'] = $res['row_count'];

        $form->status = 3;
        $res = $form->search();
        $data['status_3'] = $res['row_count'];

        $form->status = 5;
        $res = $form->search();
        $data['status_5'] = $res['row_count'];

        return $data;
    }

    /**
     * @return array
     */
    private function getExpressList()
    {
        $storeExpressList = Order::find()
            ->select('express')
            ->where([
                'and',
                ['store_id' => $this->store_id],
                ['is_pay' => Order::IS_PAY_TRUE],
                ['in', 'trade_status', [Order::ORDER_FLOW_SEND, Order::ORDER_FLOW_CONFIRM]],
                ['!=', 'express', ''],
            ])->groupBy('express, send_time')->orderBy('send_time DESC')->limit(5)->asArray()->all();
        $expressLst = Express::getExpressList();
        $newStoreExpressList = [];
        foreach ($storeExpressList as $i => $item) {
            foreach ($expressLst as $value) {
                if ($value['name'] == $item['express']) {
                    $newStoreExpressList[] = $item['express'];
                    break;
                }
            }
        }

        $newPublicExpressList = [];
        foreach ($expressLst as $i => $item) {
            $newPublicExpressList[] = $item['name'];
        }

        return array_merge($newStoreExpressList, $newPublicExpressList);
    }
}