<?php

namespace App\Services;

use App\OracleDOCOrderHeader;
use App\OrderIssue;
use App\OrderIssueProcessLog;
use App\OrderPackage;
use App\Order;
use App\RejectedBill;
use App\RejectedBillItem;
use Illuminate\Http\Request;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Validator;

class OrderIssueService
{

    public function __construct()
    {
        app()->bind("orderService", OrderService::class);
        app()->bind("rejectedService", RejectedService::class);
        app()->bind("orderPackageCommoditiesService", OrderPackageCommoditiesService::class);
    }

    public function getQuery(array $arr, array $condition = null)
    {
        if (!isset($condition)) {
            $condition = $arr;
        }
        $user = Auth::user();
        $owner_ids = $user ? $user->getPermittingOwnerIdsAttribute() : [];
        if ($condition['owner_id'] ?? false) {
            $owner_ids = explode(',', $condition['owner_id']);
        }
        $query = OrderIssue::with(['top', 'userWorkGroup', 'issueType', 'logs' => function ($query) {
            $query->with(['user'])->orderByDesc('created_at');
        }, 'order' => function ($query) {
            $query->with(['shop', 'logistic', 'owner', 'packages' => function ($query) {
                $query->with(['commodities' => function ($query) {
                    return $query->with('commodity');
                }]);
            }]);
        }, 'rejectedBill' => function ($query) {
            $query->with(['items']);
        }, 'secondOrder' => function ($query) {
            $query->with(['shop', 'logistic', 'owner', 'packages' => function ($query) {
                return $query->with(['commodities' => function ($query) {
                    return $query->with('commodity');
                }]);
            }]);
        }])->whereHas('order', function ($query) use ($owner_ids) {
            $query->whereHas('owner', function ($query) use ($owner_ids) {
                return $query->whereIn('id', $owner_ids);
            });
        });

        $query->orderBy('order_issues.id', 'desc');
        return $query;
    }

    private function getOrderQuery(array $arr, $query)
    {
        $query->whereHas('order', function ($query) use ($arr) {
            if ($arr['client_code'] ?? false) {
                $query->where('client_code', $arr['client_code']);
            }
            if ($arr['consignee_name'] ?? false) {
                $query->where('consignee_name', 'like', $arr['consignee_name']);
            }
            if ($arr['consignee_phone'] ?? false) {
                $query->where('consignee_phone', 'like', $arr['consignee_phone']);
            }
            if ($arr['logistic_number'] ?? false) {
                $logistic_number = $arr['logistic_number'];
                $query->whereHas('packages', function ($query) use ($logistic_number) {
                    $query->where('logistic_number', $logistic_number);
                });
            }
            if (($arr['good_barcode'] ?? false) || ($arr['good_name'] ?? false)) {
                $query->whereHas('packages', function ($query) use ($arr) {
                    $query->whereHas('commodities', function ($query) use ($arr) {
                        $query->whereHas('commodity', function ($query) use ($arr) {
                            if ($arr['good_barcode'] ?? false) {
                                $query->where('sku', $arr['good_barcode']);
                            }
                            if ($arr['good_name'] ?? false) {
                                $query->where('name', $arr['good_name']);
                            }
                        });
                    });
                });
            }
        });
        return $query;
    }

    public function getRejectedBillQuery(array $arr, $query)
    {
        if ($arr['id_quality_label'] ?? false) {
            $query->whereHas('rejectedBill', function ($query) use ($arr) {
                $query->whereHas('items', function ($query) use ($arr) {
                    if ($arr['id_quality_label'] ?? false) {
                        $query->where('id_quality_label', $arr['id_quality_label']);
                    }
                });
            });
        }
        return $query;
    }

    public function getConditionQuery(array $arr, array $condition = null)
    {
        $query = $this->getQuery($arr, $condition);
        $query = $this->getOrderQuery($condition ?? $arr, $query);
        $query = $this->getRejectedBillQuery($condition ?? $arr, $query);

        if (!isset($condition)) {
            $condition = $arr;
        }
        if (isset($condition['created_at_start'])) {
            $query->where('created_at', '>=', $condition['created_at_start'] . " 00:00:00");
        }
        if (isset($condition['created_at_end'])) {
            $query->where('created_at', '<=', $condition['created_at_end'] . " 23:59:59");
        }
        if (isset($condition['final_status'])) {
            $query->where('final_status', $condition['final_status']);
        }
        if (isset($condition['order_issue_type_id'])) {
            $query->where('order_issue_type_id', $condition['order_issue_type_id']);
        }
        if (!($condition['is_handle'] ?? false) && !($condition['final_status'] ?? false)) {
            $query->where(function ($query) {
                $query->where('final_status', '<>', '已解决')->orWhereNull('final_status');
            });
        }
        if (isset($condition['logistic_indemnity_money'])) {
            $query->where('logistic_indemnity_money', $condition['logistic_indemnity_money']);
        }
        if (isset($condition['baoshi_indemnity_money'])) {
            $query->where('baoshi_indemnity_money', $condition['baoshi_indemnity_money']);
        }
        if (isset($condition['order_issue_ids'])) {
            $orderIssuesId = $condition['order_issue_ids'];
            if (is_string($orderIssuesId)) {
                $orderIssuesId = explode(',', $orderIssuesId);
            }
            $query->whereIn('order_issues.id', $orderIssuesId);
        }

        return $query;
    }

    public function getSqlList(array $params){
        $orderPackageSql = OrderPackage::query()->selectRaw('order_packages.logistic_number order_package_logistic_number')
            ->leftJoin('order_package_commodities','order_packages.id','order_package_commodities.order_package_id')
                ->selectRaw('order_package_commodities.amount commodity_amount')
            ->leftJoin('commodities','order_package_commodities.commodity_id','commodities.id')
                ->selectRaw('commodities.name commodity_name,commodities.sku commodity_sku')
            ->leftJoin('order_issues','order_packages.order_id','order_issues.order_id')
                ->selectRaw('order_issues.id order_issue_id')
            ->sql();
        $secondOrderPackageSql = Order::query()->from('order_packages','s_o_p')->selectRaw('s_o_p.logistic_number')
            ->leftJoin('order_package_commodities as s_o_p_c','s_o_p_c.order_package_id','s_o_p.id')
                ->selectRaw('s_o_p_c.amount s_o_p_c_amount')
            ->leftJoin('commodities as s_c','s_o_p_c.commodity_id','s_c.id')
                ->selectRaw('s_c.sku s_c_sku,s_c.name s_c_name')
            ->leftJoin('order_issues','s_o_p.order_id','order_issues.second_order_id')
                ->selectRaw('order_issues.id order_issue_id')
            ->sql();
        $rejectedBillItemSql = RejectedBillItem::query()->selectRaw('rejected_bill_items.remark,rejected_bill_items.amount rejected_bill_amount,rejected_bill_items.name_goods,rejected_bill_items.barcode_goods')
            ->leftJoin('order_issues','rejected_bill_items.id_rejected_bill','order_issues.rejected_bill_id')
                ->selectRaw('order_issues.id order_issue_id')
            ->sql();
        $logSql = OrderIssueProcessLog::query()->selectRaw('order_issue_process_logs.content log_content,order_issue_process_logs.type log_type')
            ->leftJoin('users','order_issue_process_logs.user_id','users.id')
                ->selectRaw('users.name user_name')
            ->leftJoin('order_issues','order_issue_process_logs.order_issue_id','order_issues.id')
                ->selectRaw('order_issues.id order_issue_id')
            ->sql();
        $column = "order_issues.id,order_issues.rejected_bill_id,order_issues.rejecting_status,order_issues.created_at order_issues_created_at,order_issues.result_explain,order_issues.final_status,";
        $column .= "order_issues.logistic_indemnity_money,order_issues.logistic_express_remission,order_issues.baoshi_indemnity_money,order_issues.baoshi_express_remission";
        $orderIssueSql =  $this->getConditionQuery($params)->selectRaw($column)
            ->leftJoin('order_issue_types','order_issues.order_issue_type_id','order_issue_types.id')
                ->selectRaw('order_issue_types.`name` order_issue_type_name')
            ->leftJoin('orders','order_issues.order_id','orders.id')
                ->selectRaw('orders.id order_id,orders.address,orders.district,orders.city,orders.province,orders.consignee_phone,orders.consignee_name,orders.client_code,orders.created_at order_created_at')
          /*  ->leftJoin('order_packages','order_packages.order_id','orders.id')
                ->selectRaw('order_packages.id order_package_id,order_packages.logistic_number order_package_logistic_name')
            ->leftJoin('order_package_commodities','order_packages.id','order_package_commodities.order_package_id')
                ->selectRaw('order_package_commodities.id order_package_commodity_id,order_package_commodities.amount commodity_amount')
            ->leftJoin('commodities','order_package_commodities.commodity_id','commodities.id')
                ->selectRaw('commodities.name commodity_name,commodities.sku commodity_sku')*/
            ->leftJoin('logistics','logistics.id','orders.logistic_id')
                ->selectRaw('logistics.name logistic_name')
            ->leftJoin('owners','owners.id','orders.owner_id')
                ->selectRaw('owners.name owner_name')
            ->leftJoin('shops','orders.shop_id','shops.id')
                ->selectRaw('shops.name shop_name')
/*            ->leftJoin('rejected_bills','order_issues.rejected_bill_id','rejected_bills.id')*/
            /*->leftJoin('rejected_bill_items','rejected_bills.id','rejected_bill_items.id_rejected_bill')
                ->selectRaw('rejected_bill_items.id rejected_bill_item_id,rejected_bill_items.remark,rejected_bill_items.amount rejected_bill_amount,rejected_bill_items.name_goods,rejected_bill_items.barcode_goods')*/
            /*->leftJoin('order_issue_process_logs','order_issues.id','order_issue_process_logs.order_issue_id')
                ->selectRaw('order_issue_process_logs.content log_content,order_issue_process_logs.type log_type')
            ->leftJoin('users','order_issue_process_logs.user_id','users.id')
                ->selectRaw('users.name user_name')*/
            ->leftJoin('orders as s_o','s_o.id','order_issues.second_order_id')
                ->selectRaw('s_o.id s_o_id,s_o.client_code s_o_client_code')
            /*->leftJoin('order_packages as s_o_p','s_o_p.order_id','s_o.id')
                ->selectRaw('s_o_p.id s_o_p_id,s_o_p.logistic_number')
            ->leftJoin('order_package_commodities as s_o_p_c','s_o_p_c.order_package_id','s_o_p.id')
                ->selectRaw('s_o_p_c.id s_o_p_c_id,s_o_p_c.amount s_o_p_c_amount')
            ->leftJoin('commodities as s_c','s_o_p_c.commodity_id','s_c.id')
                ->selectRaw('s_c.sku s_c_sku,s_c.name s_c_name')*/
            ->leftJoin('logistics as s_logistics','s_o.logistic_id','s_logistics.id')
                ->selectRaw('s_logistics.name s_logistics_name')
            ->leftJoin('user_workgroups','user_workgroups.id','order_issues.user_workgroup_id')
                ->selectRaw('user_workgroups.name user_workgroup_name')
            ->sql();
            return compact('orderPackageSql','secondOrderPackageSql','orderIssueSql','rejectedBillItemSql','logSql');
    }

    public function paginate(array $arr)
    {
        $query = $this->getConditionQuery($arr);
        return $query->selectRaw('order_issues.* ,order_issue_on_tops.id top_id ,order_issue_on_tops.remark,order_issue_on_tops.updated_at top_update')
            ->leftJoin('order_issue_on_tops', 'order_issue_on_tops.order_issue_id', '=', 'order_issues.id')
            ->whereNull('order_issue_on_tops.deleted_at')
            ->orderBy('order_issue_on_tops.updated_at', 'desc')->paginate($arr['paginate'] ?? 50);

    }

    public function orderIssueTag(array $arr)
    {
        $orderNos = $arr['orderNos'];
        $meg = ['success' => false];
        if ($this->verifyOrderIssue($arr)) {
            $meg['fail_info'] = '传入订单编号中对应的订单问题已有生成';
            return $meg;
        }
        foreach ($orderNos as $orderNo) {
            $orderIssue = $this->createOrFindByOrderNo($orderNo);
            OrderIssueProcessLog::create(['order_issue_id' => $orderIssue['id'], 'user_id' => Auth::user()['id'], 'content' => '标记创建订单问题件', 'type' => '创建']);
        }
        $meg['success'] = true;
        return $meg;
    }

    public function createOrFindByOrderNo($orderNo)
    {
        $orderHeader = OracleDOCOrderHeader::where('orderNo', $orderNo)->first();
        if (!$orderHeader) {
            return null;
        }
        return $this->createOrFind($orderHeader['soreference1']);
    }

    public function createOrFind($clientCode)
    {
        $orderService = app('orderService');
        $rejectedService = app('rejectedService');
        $orderHeader = OracleDOCOrderHeader::where('SOREFERENCE1', $clientCode)->first();
        if (!$orderHeader) {
            return null;
        }
        $order = $orderService->findOrCreateByClientCode($clientCode);
        $arr = [
            'order_id' => $order['id'],
        ];
        $orderIssue = OrderIssue::create($arr);
        if ($order->client_code) {
            $rejectedBill = $rejectedService->getRejectedByClientNo($clientCode);
            if ($rejectedBill) {
                $orderIssue->rejected_bill_id = $rejectedBill['id'];
                $orderIssue->save();
            } else {
                if ($orderHeader['orderno']) {
                    $rejectedBill = RejectedBill::where('order_number', $orderHeader['orderno'])->first();
                    if ($rejectedBill) {
                        $orderIssue->rejected_bill_id = $rejectedBill['id'];
                        $orderIssue->save();
                    }
                }
            }
        }
        $this->judgeRejectingStatus($orderIssue);
        $orderIssue->order = $order;
        return $orderIssue;
    }

    public function validatorCreate(Request $request)
    {
        return Validator::make($request->input(), [
            'rejected_bill_id' => ['nullable'],
            'order_id' => ['nullable'],
            'owner_id' => ['required'],
            'second_order_id' => ['nullable'],
            'logistic_id' => ['nullable'],
            'order_issue_type_id' => ['required'],
            'baoshi_indemnity_money' => ['numeric', 'nullable'],
            'logistic_indemnity_money' => ['numeric', 'nullable'],
            'final_status' => ['nullable'],
            'result_explain' => ['nullable']
        ], [
            'required' => ':attribute 为必填项',
            'unique' => ':attribute 已存在',
            'numeric' => ':attribute 为数组',
        ], [
            'owner_id' => '货主',
            'rejected_bill_id' => '退回单号',
            'order_id' => '订单ID',
            'second_order_id' => '退回订单id',
            'logistic_id' => '承运人',
            'order_issue_type_id' => '问题类别',
            'baoshi_indemnity_money' => '宝时赔偿金额',
            'logistic_indemnity_money' => '承运商赔偿金额',
            'final_status' => '最终状态',
            'result_explain' => '处理结果说明',
        ]);
    }

    public function create(array $arr)
    {
        $orderIssue = OrderIssue::create($arr);
        if (!$arr['order_id']) {
            $order = Order::create($arr);
            $orderIssue->order_id = $order['id'];
            $orderIssue->save();
        }
        if (!$arr['rejected_bill_id']) {
            $orderIssue->update(['rejecting_status' => '无']);
        } else {
            $this->judgeRejectingStatus($orderIssue);
        }
        return $orderIssue;
    }

    public function judgeRejectingStatus(OrderIssue $orderIssue)
    {
        $orderPackageCommoditiesService = new OrderPackageCommoditiesService();
        $rejectedItems = [];
        $orderItems = [];
        if ($orderIssue->rejected_bill_id) {
            $rejectedBill = RejectedBill::query()->find($orderIssue->rejected_bill_id)->first();
            $rejectedBillItems = RejectedBillItem::query()->where('id_rejected_bill', $rejectedBill->id)->get();
            if ($rejectedBillItems) {
                foreach ($rejectedBillItems as $item) {
                    if (!isset($rejectedItems[$item->barcode_goods])) {
                        $rejectedItems[$item->barcode_goods] = 0;
                    }
                    $rejectedItems[$item->barcode_goods] = $item->amount + $rejectedItems[$item->barcode_goods] ?? 0;
                }
            }
        } else {
            $orderIssue->update(['rejecting' => '无']);
            $orderIssue->save();
            return;
        }
        if ($orderIssue->order_id) {
            $orderPackageCommodities = $orderPackageCommoditiesService->getOrderPackageCommoditiesByOrderId($orderIssue->order_id);
            if ($orderPackageCommodities) {
                foreach ($orderPackageCommodities as $key => $item) {
                    if (!isset($orderItems[$item->commodity->sku])) {
                        Arr::add($orderItems, $item->commodity->sku, 0);
                    }
                    $orderItems[$item->commodity->sku] = $orderItems[$item->commodity->sku] ?? 0 + $item->amount;
                }
            } else {
                $orderIssue->update(['rejecting_status' => '未退回']);
                $orderIssue->save();
                return;
            }
        }

        $rejectedExcess = 0;    // 退回差异
        $rejectedReview = 0;    // 退回复核  $rejectedItems == $orderItems
        foreach ($rejectedItems as $key => $items) {
            if (!isset($orderItems[$key])) {
                $rejectedExcess++;
            } else {
                if ($rejectedItems[$key] == $orderItems[$key]) {
                    $rejectedReview++;
                }
            }
        }
        if ($rejectedExcess > 0) {
            $orderIssue->update(['rejecting_status' => '差异退回']);
            $orderIssue->save();
            return;
        }
        $isExcess = 0; // 超量 $orderItems < $rejectedItems
        $isDiff = 0;   // 部分 $orderItems > $rejectedItems
        $isAccord = 0; // 相同 $orderItems == $rejectedItems
        $isLack = 0;   // 缺少 $orderItems != $rejectedItems
        foreach ($orderItems as $key => $item) {
            if (isset($rejectedItems[$key])) {
                if ($orderItems[$key] > $rejectedItems[$key]) {
                    $isExcess++;
                } else if ($orderItems[$key] < $rejectedItems[$key]) {
                    $isDiff++;
                } else if ($orderItems[$key] == $rejectedItems[$key]) {
                    $isAccord++;
                }
            } else {
                $isLack++;
            }
        }
        if ($isAccord == $rejectedReview) {
            $orderIssue->update(['rejecting_status' => '全部退回']);
            $orderIssue->save();
            return;
        } else if ($isDiff > 0 and $isLack >= 0) {
            $orderIssue->update(['rejecting_status' => '部分退回']);
            $orderIssue->save();
            return;
        } else if ($isExcess > 0 and $isDiff == 0) {
            $orderIssue->update(['rejecting_status' => '超量退回']);
            $orderIssue->save();
            return;
        }
    }

    public function createByLogisticNumber(array $arr)
    {
        $order = Order::create($arr);
        $orderIssue = OrderIssue::create($arr);
        $orderIssue->order_id = $order['id'];
        OrderPackage::create(['order_id' => $order->id, 'logistic_number' => $arr['logistic_number_return']]);
        $orderIssue->update();
        return $orderIssue;
    }

    public function verifyOrderIssue(array $arr)
    {
        $orderIds = $arr['orderNos'];
        $orders = Order::whereIn('code', $orderIds)->get();
        if (count($orders) == 0) {
            return false;
        }
        $order_ids = [];
        foreach ($orders as $order) {
            $order_ids[] = $order->id;
        }
        $count = OrderIssue::whereIn('order_id', $order_ids)->count();
        return $count != 0;
    }

    public function exportExcel(Request $request)
    {
        $result = null;
        if ($request->getMethod() == 'GET') {
            if ($request->has('checkAllSign')) {
                $result = $this->getConditionQuery($request->all(), null)->get();
            }
        } else if ($request->getMethod() == 'POST') {
            $orderIssueIds = $request->input('data');
            $ids = explode(',', $orderIssueIds);
            $request['order_issue_ids'] = $ids;

            $result = $this->getConditionQuery($request->all(), null)->get();
        }
        return $result;
    }

    public function updateOrderIssue(OrderIssue $orderIssue, array $arr)
    {
        if ($arr['rejectedBill'] ?? false) {
            if ($arr['rejectedBill']['id'] ?? false) {
                $rejectedBill = RejectedBill::where('id', $arr['rejectedBill']['id'])->first();
                $rejectedBill->fill($arr['rejectedBill']);
                $rejectedBill->update();
                $rejectedBill->syncOrderIssue();
                $request['orderIssues']['rejected_bill_id'] = $rejectedBill['id'];
            } else if ($arr['rejectedBill']['id_logistic_return'] ?? false && $arr['rejectedBill']['logistic_number_return'] ?? false) {
                $rejectedBill = RejectedBill::firstOrCreate([
                        'id_logistic_return' => $arr['rejectedBill']['id_logistic_return'],
                        'id_owner' => $arr['rejectedBill']['id_owner'],
                        'logistic_number_return' => $arr['rejectedBill']['logistic_number_return'],]
                );
                $rejectedBill->save();
                $rejectedBill->syncOrderIssue();
                $request['orderIssues']['rejected_bill_id'] = $rejectedBill['id'];

            }
        }
        if ($arr['order'] ?? false) {
            $order = Order::where('id', $arr['order']['id'])->first();
            $order->fill($arr['order']);
            $order->update();
        }
        $orderIssue->fill($arr['orderIssues']);
        $orderIssue->update();
    }

}