<?php


namespace App\Filters;


use App\Commodity;
use App\Order;
use App\OrderDetail;
use App\OrderIssue;
use App\OrderIssueProcessLog;
use App\OrderIssueRejectedBill;
use App\OrderPackage;
use App\OrderPackageCommodities;
use App\RejectedBill;
use App\RejectedBillItem;
use App\Shop;
use App\WorkOrder;
use Carbon\Carbon;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;


class OrderIssueFilters
{
    protected $request;
    /** @var Builder $queryBuilder */
    protected $queryBuilder;
    protected $orderQuery;
    protected $commodityQuery;
    protected $orderPackageQuery;
    protected $orderPackageCommodityQuery;
    protected $orderIssueRejectedBIllQuery;
    protected $rejectedBillQuery;
    protected $rejectedBillItemQuery;
    protected $orderIssueProcessLogQuery;
    protected $shopQuery;
    protected $workOrderQuery;
    protected $orderDetailQuery;
    protected $filters = [
        'log_content',
        'is_imported',
        'is_new_rejecting',
        'logistic',
        'custom_code',
        'hiddenTag',
        'client_code',
        'consignee_name',
        'consignee_phone',
        'logistic_number',
        'good_barcode',
        'good_name',
        'send_client_code',
        'id_quality_label',
        'id',
        'created_at_start',
        'created_at_end',
        'order_issue_type',
        'logistic_indemnity_money',
        'baoshi_indemnity_money',
        'rejectingStatus',
        'order_issue_ids',
        'settlement_at_start',
        'settlement_at_end',
        'sendOrderClientCode',
        'sendOrderLogisticNumber',
        'workgroups',
        'shop_name',
        'finance_confirm',
        'logistic_number_return',
        'final_status',
        'user_owner_group',
        'archive_at_start',
        'archive_at_end',
        'result_explain',
        'is_intercept',
        'orderCode',
        'is_work_order',
        'warehouse',
    ];
    protected $array_filter;
    protected $params = [];

    public function __construct(Request $request)
    {
        $this->request = $request;
        $this->params = $request->all();
        $this->array_filter = array_filter($this->request->only($this->filters));
    }

    private function getOrderQuery()
    {
        if (!$this->orderQuery)
            $this->orderQuery = Order::query()->selectRaw('id');
        return $this->orderQuery;
    }

    private function getCommodityQuery(): Builder
    {
        if (!$this->commodityQuery)
            $this->commodityQuery = Commodity::query()->selectRaw('id');
        return $this->commodityQuery;
    }

    private function getOrderPackageQuery(): Builder
    {
        if (is_null($this->orderPackageQuery))
            $this->orderPackageQuery = OrderPackage::query()->selectRaw('order_packages.order_id');
        return $this->orderPackageQuery;
    }

    private function getRejectedBillQuery(): Builder
    {
        if (!$this->rejectedBillQuery)
            $this->rejectedBillQuery = RejectedBill::query()->selectRaw('logistic_number_return');
        return $this->rejectedBillQuery;
    }

    private function getRejectedBillItemQuery(): Builder
    {
        if (!$this->rejectedBillItemQuery)
            $this->rejectedBillItemQuery = RejectedBillItem::query()->selectRaw('id_rejected_bill');
        return $this->rejectedBillItemQuery;
    }

    private function getOrderPackageCommodityQuery(): Builder
    {
        if (!$this->orderPackageCommodityQuery)
            $this->orderPackageCommodityQuery = OrderPackageCommodities::query()->selectRaw('order_package_commodities.order_package_id');
        return $this->orderPackageCommodityQuery;
    }

    private function getOrderIssueRejectedBillQuery(): Builder
    {
        if (!$this->orderIssueRejectedBIllQuery)
            $this->orderIssueRejectedBIllQuery = OrderIssueRejectedBill::query()->selectRaw('order_id');
        return $this->orderIssueRejectedBIllQuery;
    }

    private function getOrderIssueProcessLogQuery(): Builder
    {
        if (!$this->orderIssueProcessLogQuery)
            $this->orderIssueProcessLogQuery = OrderIssueProcessLog::query()->selectRaw('order_issue_id');
        return $this->orderIssueProcessLogQuery;
    }

    private function getShopQuery(): Builder
    {
        if (!$this->shopQuery)
            $this->shopQuery = Shop::query()->selectRaw('id');
        return $this->shopQuery;
    }

    private function getWorkOrderQuery(): Builder
    {
        if (!$this->workOrderQuery)
            $this->workOrderQuery = WorkOrder::query()->selectRaw('order_id');
        return $this->workOrderQuery;
    }

    private function getOrderDetailQuery(): Builder
    {
        if (!$this->orderDetailQuery) {
            $this->orderDetailQuery = OrderDetail::query()->select('order_id');
        }
        return $this->orderDetailQuery;
    }

    public function apply($builder): Builder
    {
        $this->queryBuilder = $builder;
        $this->beforeApply();
        foreach ($this->array_filter as $filter => $value) {
            if (method_exists($this, $filter)) {
                $this->$filter($value, $this->queryBuilder);
            }
        }
        $this->afterApply();
        return $this->queryBuilder;
    }

    private function beforeApply()
    {
        if (empty($this->params['hidden_tag']))
            $this->queryBuilder->whereNull('order_issues.hidden_tag');

        if (isset($this->params['data'])) {
            $ids = explode(',', $this->params['data']);
            $this->id($ids);
        } elseif (!($this->params['is_handle'] ?? false) && !($this->params['final_status'] ?? false)) {
            if (!(isset($this->params['settlement_at_start']) || isset($this->params['settlement_at_end']) || isset($this->params['archive_at_end']) || isset($this->params['archive_at_start']))) {
                $this->queryBuilder->where(function ($query) {
                    $query->whereNotIn('order_issues.final_status', ['已解决', '已归档'])->orWhereNull('order_issues.final_status');
                });
            }
        }

        if (isset($this->params['owner'])) {
            $this->searchWay($this->getOrderQuery(), $this->params['owner'], 'orders.owner_id');
        } else {
            $this->getOrderQuery()->whereIn('owner_id', app("OwnerService")->getQuery());
        }

    }

    public function afterApply()
    {
        if ($this->commodityQuery)
            $this->getOrderPackageCommodityQuery()->whereIn('commodity_id', $this->commodityQuery);

        if ($this->orderPackageCommodityQuery)
            $this->getOrderPackageQuery()->whereIn('order_packages.id', $this->orderPackageCommodityQuery);

        if ($this->orderPackageQuery)
            $this->getOrderQuery()->whereIn('order_id', $this->orderPackageQuery);

        if ($this->shopQuery)
            $this->getOrderQuery()->whereIn('shop_id', $this->shopQuery);

        if ($this->orderDetailQuery) {
            $this->getOrderQuery()->whereIn('order_id', $this->orderDetailQuery);
        }

        if ($this->orderQuery)
            $this->queryBuilder->whereIn('order_issues.order_id', $this->orderQuery);

        if ($this->rejectedBillItemQuery)
            $this->getRejectedBillQuery()->whereIn('id', $this->rejectedBillItemQuery);

        if ($this->rejectedBillQuery)
            $this->getOrderIssueRejectedBIllQuery()->whereIn('logistic_number_return', $this->rejectedBillQuery);

        if ($this->orderIssueRejectedBIllQuery) {
            $this->queryBuilder->whereIn('order_issues.order_id', $this->orderIssueRejectedBIllQuery);
        }

        if ($this->orderIssueProcessLogQuery)
            $this->queryBuilder->whereIn('order_issues.id', $this->orderIssueProcessLogQuery);

        if (!array_key_exists('created_at_start',$this->array_filter)) {
            $this->queryBuilder->where('order_issues.created_at', '>=', "2022-11-01 00:00:00");
        }
    }

    private function isSearchLike($str)
    {
        if (substr($str, 0, 1) == "%" || substr($str, strlen($str) - 1, 1) == "%") {
            return true;
        }
        return false;
    }

    private function searchWay($query, $param, $column)
    {
        if ($this->isSearchLike($param)) {
            $query->where($column, 'like', $param);
        } else {
            mb_regex_encoding('utf-8');
            $query->whereIn($column, array_filter(preg_split('/[,， ]+/u', $param, -1, PREG_SPLIT_NO_EMPTY)));
        }
        return $query;
    }

    public function log_content($log_content)
    {
        $order_issue_process_log_query = OrderIssueProcessLog::query()->selectRaw('order_issue_id')->where('content', 'like', $log_content);
        if (!array_key_exists('addtime', $this->params)) {
            $order_issue_process_log_query->where('created_at', '>=', Carbon::now()->subDays(31));
        } else {
            $order_issue_process_log_query->where('created_at', '>=', Carbon::now()->subDays($this->params['addtime']));
        }
        $this->queryBuilder->whereIn('order_issues.id', $order_issue_process_log_query);
    }

    public function is_imported($is_imported)
    {
        $this->queryBuilder->where('order_issues.imported_status', $is_imported);
    }

    public function is_new_rejecting($is_new_rejecting)
    {
        $this->getOrderDetailQuery()->where('order_details.is_new_rejecting', $is_new_rejecting);
    }

    public function logistic($logistic_id)
    {
        if (strpos($logistic_id, ',') || strpos($logistic_id, '，') || strpos($logistic_id, ' ')) {
            $arr = array_filter(preg_split('/[,， ]+/is', $logistic_id));
            $this->getOrderQuery()->whereIn('orders.logistic_id', $arr);
        } else {
            $this->getOrderQuery()->where('orders.logistic_id', $logistic_id);
        }
    }

    public function custom_code($custom_code)
    {
        $this->queryBuilder->where('order_issues.custom_code', $custom_code);
    }

    public function hiddenTag($hiddenTag)
    {
        $this->queryBuilder->where('order_issues.hidden_tag', $hiddenTag);
    }

    public function client_code($client_code)
    {
        $this->searchWay($this->getOrderQuery(), $client_code, 'orders.client_code');
    }

    public function consignee_name($consignee_name)
    {
        $this->searchWay($this->getOrderQuery(), $consignee_name, 'orders.consignee_name');
    }

    public function consignee_phone($consignee_name)
    {
        $this->searchWay($this->getOrderQuery(), $consignee_name, 'orders.consignee_phone');
    }

    public function logistic_number($logistic_number)
    {
        $this->searchWay($this->getOrderPackageQuery(), $logistic_number, 'logistic_number');
    }

    public function good_barcode($good_barcode)
    {
        $this->searchWay($this->getCommodityQuery(), $good_barcode, 'sku');
    }

    public function good_name($good_name)
    {
        $this->searchWay($this->getCommodityQuery(), $good_name, 'name');
    }

    public function send_client_code($send_client_code)
    {
        $this->searchWay($this->queryBuilder, $send_client_code, 'order_issues.second_client_no');
    }

    public function logistic_number_return($logistic_number_return)
    {
        $this->searchWay($this->getOrderIssueRejectedBillQuery(), $logistic_number_return, 'logistic_number_return');
    }

    public function id_quality_label($id_quality_label)
    {
        $this->getRejectedBillItemQuery()->where('id_quality_label', $id_quality_label);
    }

    public function id($id)
    {
        $this->queryBuilder->whereIn('order_issues.id', $id);
    }

    public function created_at_start($created_at_start)
    {
        $this->queryBuilder->where('order_issues.created_at', '>=', $created_at_start . " 00:00:00");
    }

    public function created_at_end($created_at_end)
    {
        $this->queryBuilder->where('order_issues.created_at', '<=', $created_at_end . " 23:59:59");
    }

    public function order_issue_type($order_issue_type_id)
    {
        $this->searchWay($this->queryBuilder, $order_issue_type_id, 'order_issues.order_issue_type_id');
    }

    public function logistic_indemnity_money($logistic_indemnity_money)
    {
        if ($logistic_indemnity_money === '是')
            $this->queryBuilder->whereNotNull('order_issues.logistic_indemnity_money');
        elseif ($logistic_indemnity_money === '否')
            $this->queryBuilder->whereNull('order_issues.logistic_indemnity_money');
    }

    public function baoshi_indemnity_money($baoshi_indemnity_money)
    {
        if ($baoshi_indemnity_money === '是')
            $this->queryBuilder->whereNotNull('order_issues.baoshi_indemnity_money');
        elseif ($baoshi_indemnity_money === '否')
            $this->queryBuilder->whereNull('order_issues..baoshi_indemnity_money');
    }

    public function rejectingStatus($rejectingStatus)
    {
        $this->getOrderDetailQuery()->where('order_details.rejecting_status', $rejectingStatus);
    }

    public function order_issue_ids($order_issue_ids)
    {
        $this->searchWay($this->queryBuilder, $order_issue_ids, 'order_issues.id');
    }

    public function settlement_at_start($settlement_at_start)
    {
        $this->getOrderIssueProcessLogQuery()->where('created_at', '>=', $settlement_at_start . ' 00:00:00')->where('type', '结束');
    }

    public function settlement_at_end($settlement_at_end)
    {
        $this->getOrderIssueProcessLogQuery()->where('created_at', '<=', $settlement_at_end . ' 23:59:59')->where('type', '结束');
    }

    public function sendOrderClientCode($sendOrderClientCode)
    {
        $this->searchWay($this->queryBuilder, $sendOrderClientCode, 'order_issues.second_client_no');
    }

    public function workgroups($user_work_groups)
    {
        if (is_string($user_work_groups)) {
            $user_work_groups = explode(',', $user_work_groups);
        }
        if (in_array('空', $user_work_groups)) {
            $this->queryBuilder->whereNotIn('order_issues.id', function ($query) use ($user_work_groups) {
                $query->from('order_issue_user_workgroup')->selectRaw('order_issue_id');
            });
        } else {
            $this->queryBuilder->whereIn('order_issues.id', function ($query) use ($user_work_groups) {
                $query->from('order_issue_user_workgroup')->selectRaw('order_issue_id')->whereIn('user_workgroup_id', $user_work_groups);
            });
        }
    }

    public function sendOrderLogisticNumber($sendOrderLogisticNumber)
    {
        $order_issue_query = OrderIssue::query()->selectRaw('id');
        $this->searchWay($order_issue_query, $sendOrderLogisticNumber, 'second_logistic_number');
        $order_issues = $order_issue_query->get();
        if (count($order_issues) > 0) {
            $this->queryBuilder->whereIn('order_issues.id', $order_issues->map(function ($orderIssue) {
                return $orderIssue->id;
            }));
        }
        $orders = Order::query()->selectRaw('client_code')->whereIn('id', function ($query) use ($sendOrderLogisticNumber) {
            $query->from('order_packages')->selectRaw('order_id');
            $this->searchWay($query, $sendOrderLogisticNumber, 'logistic_number');
        })->get();
        if ($orders->count() > 0) {
            $this->queryBuilder->whereIn('order_issues.second_client_no', $orders->map(function ($order) {
                return $order->client_code;
            }));
        }
    }

    public function shop_name($shop_name)
    {
        $this->searchWay($this->getShopQuery(), $shop_name, 'name');
        if (isset($this->params['shop_name_limit_time'])) {
            $this->queryBuilder->Where('order_issues.created_at', '>=', Carbon::now()->subDays($this->params['shop_name_limit_time']));
        } else {
            $this->queryBuilder->Where('order_issues.created_at', '>=', Carbon::now()->subDays(31));
        }
    }

    public function final_status($final_status)
    {
        if ($final_status === 'null')
            $this->queryBuilder->whereNull('order_issues.final_status');
        else
            $this->queryBuilder->where('order_issues.final_status', $final_status);

    }

    public function finance_confirm($finance_confirm)
    {
        $this->queryBuilder->where('order_issues.finance_confirm', $finance_confirm);
    }

    public function user_owner_group($user_owner_group_id)
    {
        $this->queryBuilder->where('order_issues.user_owner_group_id', $user_owner_group_id);
    }

    public function archive_at_start($archive_at_start)
    {
        $this->queryBuilder->where('order_issues.archive_at', '>=', $archive_at_start . ' 00:00:00');
    }

    public function archive_at_end($archive_at_end)
    {
        $this->queryBuilder->where('order_issues.archive_at', '<=', $archive_at_end . ' 23:59:59');
    }

    public function result_explain($result_explain)
    {
        $this->queryBuilder->where('order_issues.result_explain', 'like', "%{$result_explain}%");
    }

    public function is_intercept($is_intercept)
    {
        $this->queryBuilder->where('order_issues.is_intercept', 1);
    }

    public function orderCode($orderCode)
    {
        $this->getOrderQuery();
        $this->searchWay($this->getOrderQuery(), $orderCode, 'orders.code');
    }

    // 是否有对应工单
    public function is_work_order($is_work_order)
    {
        if ($is_work_order == '1') {
            $this->queryBuilder->whereIn('order_id', $this->getWorkOrderQuery());
        } else if ($is_work_order == '2') {
            $this->queryBuilder->whereNotIn('order_id', $this->getWorkOrderQuery());
        }
    }

    public function warehouse($warehouseIds)
    {
        $this->searchWay($this->getOrderQuery(), $warehouseIds, 'orders.warehouse_id');
    }
}