baoshi-was/app/Http/Controllers/PriceModelController.php

<?php

namespace App\Http\Controllers;

use App\Components\AsyncResponse;
use App\Imports\ExpressImport;
use App\Imports\OwnerPriceDirectLogisticDetailImport;
use App\Imports\OwnerPriceLogisticDetailImport;
use App\Owner;
use App\OwnerPriceDirectLogistic;
use App\OwnerPriceDirectLogisticCar;
use App\OwnerPriceExpress;
use App\OwnerPriceExpressProvince;
use App\OwnerPriceLogistic;
use App\OwnerPriceLogisticDetail;
use App\OwnerPriceOperation;
use App\OwnerPriceOperationItem;
use App\OwnerStoragePriceModel;
use App\Services\common\BatchUpdateService;
use App\Services\common\ExportService;
use App\Services\LogService;
use App\Services\OwnerPriceOperationItemService;
use App\Services\OwnerPriceOperationService;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Gate;
use Illuminate\Support\Facades\Validator;
use Maatwebsite\Excel\Facades\Excel;

class PriceModelController extends Controller
{
    use AsyncResponse;
    public function storageIndex(Request $request)
    {
        if(!Gate::allows('计费模型-仓储')){ return redirect('denied');  }
        $models = app('OwnerStoragePriceModelService')->paginate($request->input("id"),["unit","owners","timeUnit"]);
        return response()->view('maintenance.priceModel.storage.index',compact("models"));
    }

    public function storageCreate()
    {
        if(!Gate::allows('计费模型-仓储-录入')){ return redirect('denied');  }
        $units = app('UnitService')->getSelection();
        $owners = app("OwnerService")->getIntersectPermitting();
        return response()->view('maintenance.priceModel.storage.create',compact("units","owners"));
    }

    public function storageStore(Request $request)
    {
        if(!Gate::allows('计费模型-仓储-录入')){ return redirect('denied');  }
        $this->storageValidator($request->input())->validate();
        /** @var OwnerStoragePriceModel $model */
        $model = app('OwnerStoragePriceModelService')->create($request->input());
        $model->owners()->sync(explode(",",$request->input("owner_id")));
        LogService::log(__METHOD__,"计费模型-创建仓储计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return response()->redirectTo('maintenance/priceModel/storage')->with('successTip',"创建成功！");
    }

    public function storageEdit($id)
    {
        if(!Gate::allows('计费模型-仓储-编辑')){ return redirect('denied');  }
        $model = app('OwnerStoragePriceModelService')->find($id,["owners"]);
        $units = app('UnitService')->getSelection();
        $owners = app("OwnerService")->getIntersectPermitting();
        return response()->view('maintenance.priceModel.storage.create',compact("units","model","owners"));
    }

    public function storageUpdate(Request $request)
    {
        if(!Gate::allows('计费模型-仓储-编辑')){ return redirect('denied');  }
        app('OwnerStoragePriceModelService')->update(["id"=>$request->input("id")],[
            "counting_type" => $request->input("counting_type"),
            "name"          => $request->input("name"),
            "using_type"    => $request->input("using_type"),
            "minimum_area"  => $request->input("minimum_area"),
            "price"         => $request->input("price"),
            "discount_type" => $request->input("discount_type"),
            "discount_value"=> $request->input("discount_value"),
            "unit_id"       => $request->input("unit_id"),
            "time_unit_id"  => $request->input("time_unit_id"),
        ]);
        $model = new OwnerStoragePriceModel();
        $model->id = $request->input("id");
        $result = $model->owners()->sync(explode(",",$request->input("owner_id")));
        app("OwnerService")->refreshRelevance($result["attached"],0);
        app("OwnerService")->refreshRelevance($result["detached"],0,true);
        LogService::log(__METHOD__,"计费模型-修改仓储计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return response()->redirectTo('maintenance/priceModel/storage')->with('successTip',"更新成功！");
    }

    public function storageDestroy($id)
    {
        app("OwnerStoragePriceModelService")->destroy($id);
        LogService::log(__METHOD__,"计费模型-删除仓储计费",$id);
        return ["success"=>true];
    }

    private function storageValidator(array $params)
    {
        return Validator::make($params,[
            'name'=>['required'],
            'counting_type'=>['required'],
            'using_type'=>['required'],
            'minimum_area'=>['nullable','numeric','min:0'],
            'discount_value'=>['nullable','numeric','min:0'],
            'price'=>['required','numeric','min:0'],
            'discount_type'=>['required'],
            'unit_id'=>['required','integer'],
            'time_unit_id'=>['required','integer'],
        ],[
            'required'=>':attribute 为必填项',
            'min'=>':attribute 不得小于0',
            'integer'=>':attribute 未选择',
        ],[
            'name'          =>"名称",
            'counting_type' =>"计费类型",
            'using_type'    =>"用仓类型",
            'minimum_area'  =>"最低起租面积",
            'price'         =>"单价",
            'discount_type' =>"减免类型",
            'discount_value'=>"减免值",
            'unit_id'       =>"单位",
            'time_unit_id'  =>"计时单位",
        ]);
    }

    public function operationIndex(Request $request){
        if(!Gate::allows('计费模型-作业-查询')){ return redirect('denied');  }
        $features = app("FeatureService")->getMapArray();
        OwnerPriceOperation::$features = $features;
        $models = app('OwnerPriceOperationService')->paginate($request->input(),["ownerPriceOperationOwners","items.unit"])->append("featureFormat");
        $owners = app("OwnerService")->getIntersectPermitting();
        return response()->view('maintenance.priceModel.operation.index',compact("models","owners"));
    }

    /* 获取出库模型规则 */
    public function getItems(Request $request)
    {
        if(!Gate::allows('计费模型-作业-查询')){ return ["success"=>false,"data"=>"无权操作"];  }
        /** @var OwnerPriceOperationItemService $service */
        $service = app('OwnerPriceOperationItemService');
        $items = $service->get(["owner_price_operation_id"=>$request->input("id")],["unit"],true)->append("featureFormat");
        return ["success"=>true,"data"=>$items];
    }
    /* 修改子规则 */
    public function updateItem(Request $request)
    {
        if(!Gate::allows('计费模型-作业-编辑')){ return ["success"=>false,"data"=>"无权操作"];  }
        /** @var OwnerPriceOperationItemService $service */
        $service = app('OwnerPriceOperationItemService');
        $row = $service->update(["id"=>$request->input("id")],[
            "amount"=>$request->input("amount"),
            "unit_id"=>$request->input("unit_id"),
            "priority"=>$request->input("priority"),
            "unit_price"=>$request->input("unit_price")]);
        if ($row == 1){
            LogService::log(__METHOD__,"计费模型-修改出库规则",json_encode($request->input()));
            return ["success"=>true];
        }
        return ["success"=>false,"data"=>"受影响数据数为：".$row];
    }

    public function createItem(Request $request)
    {
        if(!Gate::allows('计费模型-作业-编辑')){ return ["success"=>false,"data"=>"无权操作"];  }
        /** @var OwnerPriceOperationItemService $service */
        $service = app('OwnerPriceOperationItemService');
        switch ($request->input("strategy")){
            case "起步":
                $c = $service->isExist(["owner_price_operation_id"=>$request->input("owner_price_operation_id"),"strategy"=>"起步"]);
                if ($c > 0)return ["success"=>false,"data"=>"已存在起步策略"];
                break;
            case "默认":
                $c = $service->isExist(["owner_price_operation_id"=>$request->input("owner_price_operation_id"),"strategy"=>"默认"]);
                if ($c > 0)return ["success"=>false,"data"=>"已存在默认策略"];
                break;
        }
        $data = $service->create($request->input());
        $data->load("unit");
        return ["success"=>true,"data"=>$data];
    }
    public function getFeatures(Request $request)
    {
        return ["success"=>true,"data"=>app("FeatureService")->translationFeature($request->input("feature"))];
    }

    public function addFeature(Request $request)
    {
        if(!Gate::allows('计费模型-作业-编辑')){ return ["success"=>false,"data"=>"无权操作"];  }
        $id = $request->input("id");
        $features = $request->input("features");
        if (!$id || !$features)return ["success"=>false,"data"=>"非法参数"];
        $result = app("FeatureService")->analysisFeature($features);
        $feature = $result["feature"];
        $stack = [];
        if ($feature && ($feature[0]=='|' || $feature[0]=='&'))$feature=substr($feature,1);
        for ($i=0;$i<strlen($feature);$i++){
            if ($feature[$i] == '(')array_unshift($stack,'(');
            if ($feature[$i] == ')'){
                if (count($stack) == 0)return ["success"=>false,"data"=>"组标记错误，起始与结束标记必须对应"];
                array_shift($stack);
            }
        }
        if (count($stack) > 0)return ["success"=>false,"data"=>"组标记错误，起始与结束标记必须对应"];
        $row = app('OwnerPriceOperationItemService')->update(["id"=>$id],["feature"=>$feature]);
        if ($row != 1)return ["success"=>false,"data"=>"影响了“".$row."”行"];
        LogService::log(__METHOD__,"计费模型-修改出库特征",json_encode($request->input()));
        OwnerPriceOperationItem::$features = $result["map"];
        $rule = app('OwnerPriceOperationItemService')->find($id)->append("featureFormat");
        return ["success"=>true,"data"=>["featureFormat"=>$rule->featureFormat,"feature"=>$feature]];
    }

    public function getFeature(Request $request)
    {
        $features = $request->input("features");
        if (!$features)return ["success"=>false,"data"=>"非法参数"];
        $result = app("FeatureService")->analysisFeature($features);
        $feature = $result["feature"];
        $stack = [];
        if ($feature && ($feature[0]=='|' || $feature[0]=='&'))$feature=substr($feature,1);
        for ($i=0;$i<strlen($feature);$i++){
            if ($feature[$i] == '(')array_unshift($stack,'(');
            if ($feature[$i] == ')'){
                if (count($stack) == 0)return ["success"=>false,"data"=>"组标记错误，起始与结束标记必须对应"];
                array_shift($stack);
            }
        }
        if (count($stack) > 0)return ["success"=>false,"data"=>"组标记错误，起始与结束标记必须对应"];
        if ($request->has("isFormat"))$this->success(["feature"=>$feature,"featureFormat"=>app("FeatureService")->formatFeature($result["map"], $feature)]);
        $this->success($feature);
    }

    public function operationDestroy($id)
    {
        if(!Gate::allows('计费模型-作业-删除')){ return ["success"=>false,"data"=>"无权操作"];  }
        $row = app("OwnerPriceOperationService")->destroy($id);
        if ($row == 1){
            LogService::log(__METHOD__,"计费模型-删除作业计费",$id);
            return ["success"=>true];
        }
        return ["success"=>false,"data"=>"影响了“".$row."”行"];
    }

    public function operationCreate(){
        if(!Gate::allows('计费模型-作业-录入')){ return redirect('denied');  }
        $owners = app("OwnerService")->getIntersectPermitting();
        $units = app('UnitService')->getSelection();
        return response()->view('maintenance.priceModel.operation.create',compact("owners","units"));
    }

    public function operationStore(Request $request)
    {
        if(!Gate::allows('计费模型-作业-录入')){ return redirect('denied');  }
        $request->offsetSet("items",json_decode($request->input("items"),true));
        $request->offsetSet("owner_id",explode(',',$request->input("owner_id")));
        $this->operationValidator($request->input())->validate();

        //录入主表
        /** @var OwnerPriceOperationService $service */
        $service = app("OwnerPriceOperationService");
        $ownerPriceOperation = $service->create([
            "operation_type" => $request->input("operation_type"),
            "strategy" => $request->input("strategy"),
            "name" => $request->input("name"),
            "priority" => $request->input("priority"),
            "remark" => $request->input("remark"),
            "feature" => $request->input("feature"),
            "discount_count"    => request("discount_count") ? implode(",",request("discount_count")) : null,
            "total_price"       => request("total_price"),
            "total_discount_price"=> request("total_discount_price") ? implode(",",request("total_discount_price")) : null,
        ]);
        if ($request->input("items")){
            //录入子表
            $insert = [];
            foreach ($request->input("items") as $rule){
                if ($rule["discount_price"] ?? false){
                    foreach ($rule["discount_price"] as $index=>$item){
                        if ($index!=0 && !$item)$rule["discount_price"][$index] = $rule["discount_price"][$index-1];
                    }
                }
                $insert[] = [
                    "owner_price_operation_id" => $ownerPriceOperation->id,
                    "amount" => $rule["amount"],
                    "unit_id" => $rule["unit_id"],
                    "unit_price" => $rule["unit_price"],
                    "strategy" => $rule["strategy"],
                    "feature" => $rule["feature"],
                    "priority" => $rule["priority"],
                    "discount_price" =>  implode(",",$rule["discount_price"]),
                ];
            }
            $service->insertItem($insert);
        }
        //录入中间表
        /** @var OwnerPriceOperation $ownerPriceOperation */
        if ($request->input("owner_id")){
            $result = $ownerPriceOperation->ownerPriceOperationOwners()->sync($request->input("owner_id"));
            app("OwnerService")->refreshRelevance($result["attached"],1);
            app("OwnerService")->refreshRelevance($result["detached"],1,true);
        }
        LogService::log(__METHOD__,"计费模型-录入作业计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return response()->redirectTo("maintenance/priceModel/operation")->with("successTip","创建“".$request->input("name")."”成功");
    }

    public function operationEdit($id)
    {
        if(!Gate::allows('计费模型-作业-编辑')){ return redirect('denied');  }
        $model = app('OwnerPriceOperationService')->find($id,["items"]);
        $owners = app("OwnerService")->getIntersectPermitting();
        $units = app('UnitService')->getSelection();
        return response()->view('maintenance.priceModel.operation.create',compact("owners","units","model"));
    }

    public function operationUpdate($id,Request $request)
    {
        if(!Gate::allows('计费模型-作业-编辑')){ return redirect('denied');  }
        $request->offsetSet("items",json_decode($request->input("items"),true));
        $request->offsetSet("owner_id",explode(',',$request->input("owner_id")));
        $this->operationValidator($request->input(),$id)->validate();

        /** @var OwnerPriceOperationService $service */
        $service = app("OwnerPriceOperationService");

        $model = $service->find($id);
        $service->findUpdate($model,[
            "name" => $request->input("name"),
            "priority" => $request->input("priority"),
            "remark" => $request->input("remark"),
            "feature" => $request->input("feature"),
            "discount_count"    => implode(",",request("discount_count")),
            "total_price"       => request("total_price"),
            "total_discount_price"=> implode(",",request("total_discount_price")) ?? null,
        ]);
        $service->destroyItem($id);
        if ($request->input("items")){
            //录入子表
            $insert = [];
            foreach ($request->input("items") as $rule){
                $insert[] = [
                    "owner_price_operation_id" => $model->id,
                    "amount" => $rule["amount"],
                    "unit_id" => $rule["unit_id"],
                    "unit_price" => $rule["unit_price"],
                    "strategy" => $rule["strategy"],
                    "feature" => $rule["feature"],
                    "priority" => $rule["priority"],
                    "discount_price" => implode(",",$rule["discount_price"]) ?? null,
                ];
            }
            $service->insertItem($insert);
        }
        //录入中间表
        /** @var OwnerPriceOperation $model */
        if ($request->input("owner_id")){
            $result = $model->ownerPriceOperationOwners()->sync($request->input("owner_id"));
            app("OwnerService")->refreshRelevance($result["attached"],1);
            app("OwnerService")->refreshRelevance($result["detached"],1,true);
        }
        LogService::log(__METHOD__,"计费模型-修改作业计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return response()->redirectTo("maintenance/priceModel/operation")->with("successTip","修改“".$request->input("name")."”成功");
    }

    private function operationValidator(array $params, $id= null)
    {
        return Validator::make($params,[
            'operation_type'=>['required'],
            'owner_id'=>[function ($attribute, $value, $fail)use($params,$id) {
                if ($params["strategy"] == '默认'){
                    $owners = Owner::query()->whereIn("id",$value)->withCount(["ownerPriceOperations"=>function($query)use($params,$id){
                        if ($id)$query->where('id',"!=",$id);
                        $query->where("strategy","默认")->where("operation_type",$params["operation_type"]);
                    }])->get();
                    $err = [];
                    foreach ($owners as $owner){
                        if ($owner->owner_price_operations_count > 0)$err[] = $owner->name;
                    }
                    if (count($err)>0)$fail("(".implode(',',$err).') 已经绑定'.$params["operation_type"].'的默认策略');
                }
            }],
            'strategy'=>['required'],
            'name'=>['required'/*,$id?"unique:owner_price_operations,name,$id":'unique:owner_price_operations,name'*/],
            'priority'=>['sometimes','required','integer','min:0','max:100'],
            'items.*.strategy'=>['required'],
            'items.*.amount'=>["required","integer"],
            'items.*.unit_id'=>['required','integer'],
            'items.*.unit_price'=>['required','numeric',"min:0"],
        ],[
            'required'=>':attribute 为必填项',
            'min'=>':attribute 不得小于0',
            'integer'=>':attribute 必须为整数',
            'numeric'=>':attribute 必须为数字',
            'max'=>':attribute 超出最大值',
            'required_if'=>':attribute 操作类型为出库时不得为空',
        ],[
            'operation_type' =>"操作类型",
            'strategy'    =>"计费策略",
            'name'  =>"名称",
        ]);
    }

    public function expressIndex(Request $request){
        if(!Gate::allows('计费模型-快递-查询')){ return redirect('denied');  }
        $models = app('OwnerPriceExpressService')->paginate($request->input("id"));
        return response()->view('maintenance.priceModel.express.index',compact("models"));
    }

    public function expressGetDetail(Request $request)
    {
        if(!Gate::allows('计费模型-快递-查询')){ return ["success"=>false,"data"=>"无权操作"];  }
        $model = new OwnerPriceExpress();
        $model->id = $request->input("id");
        $model->load(["details"=>function($query){$query->with("province");}]);
        return ["success"=>true,"data"=>$model->details];
    }

    public function expressUpdateDetail(Request $request)
    {
        if(!Gate::allows('计费模型-快递-编辑')){ return ["success"=>false,"data"=>"无权操作"];  }
        $detail = $request->input("detail");
        if ($detail["id"]){
            app('OwnerPriceExpressService')->updateDetail(["id"=>$detail["id"]],[
                "additional_weight_price" => $detail["additional_weight_price"],
                "initial_weight_price" => $detail["initial_weight_price"],
            ]);
        }else{
            $row = app('OwnerPriceExpressService')->isExistDetail(["owner_price_express_id"=>$request->input("id"),"province_id"=>$detail["province_id"]]);
            if ($row>0)return ["success"=>false,"data"=>"已存在该省份计费模型"];
            /** @var OwnerPriceExpressProvince $detail */
            $detail = app('OwnerPriceExpressService')->createDetail([
                "owner_price_express_id" =>  $request->input("id"),
                "province_id" => $detail["province_id"],
                "additional_weight_price" => $detail["additional_weight_price"],
                "initial_weight_price" => $detail["initial_weight_price"],
            ]);
            $detail->load("province");
        }
        LogService::log(__METHOD__,"计费模型-修改快递计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return ["success"=>true,"data"=>$detail];
    }

    public function expressDestroyDetail(Request $request)
    {
        if(!Gate::allows('计费模型-快递-删除')){ return ["success"=>false,"data"=>"无权操作"];  }
        $id = $request->input("id");
        if (!$id)return ["success"=>false,"data"=>"非法参数"];
        app("OwnerPriceExpressService")->destroyDetail($id);
        LogService::log(__METHOD__,"计费模型-删除快递计费",$id);
        return ["success"=>true];
    }

    public function expressImport(Request $request){
        if(!Gate::allows('计费模型-快递-录入')){ return ["success"=>false,"data"=>"无权操作"];  }
        $fileSuffix=$request->file('file')->getClientOriginalExtension();
        if ($fileSuffix != 'xlsx' && $fileSuffix != 'xls' && $fileSuffix != 'csv')
            return ['success'=>false,'data'=>'不支持该文件类型'];
        ini_set('max_execution_time',2500);
        ini_set('memory_limit','1526M');
        $fileSuffix = ucwords($fileSuffix);

        if (!$request->has("id")){
            Excel::import(new ExpressImport(null),$request->file('file')->path(),null,$fileSuffix);
        }else{
            /** @var OwnerPriceExpress $model */
            $model = app('OwnerPriceExpressService')->find($request->input("id"),["details"]);
            Excel::import(new ExpressImport($model),$request->file('file')->path(),null,$fileSuffix);
        }

        if (Cache::has('express'))return Cache::pull('express');
        return ["success"=>false,"data"=>"导入发生错误，数据无响应"];
    }

    public function expressCreate(){
        if(!Gate::allows('计费模型-快递-录入')){ return redirect('denied');  }
        $logistics = app("LogisticService")->getSelection();
        $owners = app("OwnerService")->getIntersectPermitting();
        return response()->view('maintenance.priceModel.express.create',compact("logistics","owners"));
    }

    public function expressStore(Request $request)
    {
        if(!Gate::allows('计费模型-快递-录入')){ return redirect('denied');  }
        $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
        $request->offsetSet("logistic_id",explode(",",$request->input("logistic_id")));
        $this->expressValidator($request->input())->validate();
        /** @var OwnerPriceExpress $model */
        $model = app("OwnerPriceExpressService")->create([
            "name" => $request->input("name"),
            "initial_weight" => $request->input("initial_weight"),
            "additional_weight" => $request->input("additional_weight"),
        ]);
        $result = $model->owners()->sync($request->input("owner_id"));
        app("OwnerService")->refreshRelevance($result["attached"],2);
        app("OwnerService")->refreshRelevance($result["detached"],2,true);
        $model->logistics()->sync($request->input("logistic_id"));
        LogService::log(__METHOD__,"计费模型-录入快递计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return response()->redirectTo("maintenance/priceModel/express")->with("successTip","录入“".$request->input("name")."”成功");
    }

    public function expressEdit($id)
    {
        if(!Gate::allows('计费模型-快递-编辑')){ return redirect('denied');  }
        /** @var OwnerPriceExpress $model */
        $model = app('OwnerPriceExpressService')->find($id)->append(["owner_id","logistic_id"]);
        $owners = app("OwnerService")->getIntersectPermitting();
        $logistics = app('LogisticService')->getSelection();
        return response()->view('maintenance.priceModel.express.create',compact("owners","logistics","model"));
    }

    public function expressUpdate($id,Request $request)
    {
        if(!Gate::allows('计费模型-快递-编辑')){ return redirect('denied');  }
        $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
        $request->offsetSet("logistic_id",explode(",",$request->input("logistic_id")));
        $this->expressValidator($request->input(),$id)->validate();
        /** @var OwnerPriceExpress $model */
        app("OwnerPriceExpressService")->update(["id"=>$id],[
            "name" => $request->input("name"),
            "initial_weight" => $request->input("initial_weight"),
            "additional_weight" => $request->input("additional_weight"),
        ]);
        $model = new OwnerPriceExpress();
        $model->id = $id;
        $result = $model->owners()->sync($request->input("owner_id"));
        app("OwnerService")->refreshRelevance($result["attached"],2);
        app("OwnerService")->refreshRelevance($result["detached"],2,true);
        $model->logistics()->sync($request->input("logistic_id"));
        LogService::log(__METHOD__,"计费模型-修改快递计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return response()->redirectTo("maintenance/priceModel/express")->with("successTip","修改“".$request->input("name")."”成功");
    }

    private function expressValidator(array $params, $id=null)
    {
        return Validator::make($params,[
            'name'=>['required',$id?"unique:owner_price_expresses,name,$id":'unique:owner_price_expresses,name'],
            'initial_weight'=>['required','numeric','min:0'],
            'additional_weight'=>['required','numeric','min:0'],
            'owner_id'=>[function ($attribute, $value, $fail)use($id,$params) {
                $owners = app("OwnerPriceExpressService")->getExistOwnerName($value,$params["logistic_id"] ?? [],$id);
                if ($owners)$fail("(".implode(',',$owners).') 已经绑定计费模型');
            }],
            /*'logistic_id'=>[function ($attribute, $value, $fail)use($id) {
                $logistics = app("OwnerPriceExpressService")->getExistLogisticName($value,$id);
                if ($logistics)$fail("(".implode(',',$logistics).') 已经绑定计费模型');
            }],*/
            'items.*.province_id'=>['sometimes','required'],
            'items.*.additional_weight_price'=>['sometimes','required','numeric',"min:0"],
            'items.*.initial_weight_price'=>['sometimes','required','numeric',"min:0"],
        ],[
            'required'=>':attribute 为必填项',
            'unique' => ':attribute 已存在',
            'min' => ':attribute 不得小于0',
        ],[
            'name' =>"名称",
            'initial_weight'  =>"首重",
            'additional_weight'  =>"续重",
            "items.*.province_id"=>"省份",
            "items.*.additional_weight_price"=>"首重价格",
            "items.*.initial_weight_price"=>"续重价格",
        ]);
    }

    public function expressDestroy($id)
    {
        if(!Gate::allows('计费模型-快递-删除')){ return ["success"=>false,"data"=>"无权操作"]; };
        app("OwnerPriceExpressService")->destroy($id);
        LogService::log(__METHOD__,"计费模型-删除快递计费",$id);
        return ["success"=>true];
    }

    public function logisticIndex(Request $request)
    {
        if(!Gate::allows('计费模型-物流-查询')){ return redirect('denied');  }
        $models = app("OwnerPriceLogisticService")->paginate($request->input("id"))->append(["unit_range_json","other_unit_range_json"]);
        return response()->view('maintenance.priceModel.logistic.index',compact("models"));
    }

    public function logisticCreate()
    {
        if(!Gate::allows('计费模型-物流-录入')){ return redirect('denied');  }
        $owners = app("OwnerService")->getIntersectPermitting();
        $logistics = app('LogisticService')->getSelection();
        $units = app('UnitService')->getSelection();
        return response()->view('maintenance.priceModel.logistic.create',compact("owners","logistics","units"));
    }

    public function logisticStore(Request $request)
    {
        if(!Gate::allows('计费模型-物流-录入')){ return redirect('denied');  }
        $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
        $request->offsetSet("logistic_id",explode(",",$request->input("logistic_id")));
        $this->logisticValidator($request->input())->validate();
        /** @var OwnerPriceLogistic $model */
        $model = app("OwnerPriceLogisticService")->create([
            "name" => $request->input("name"),
            "pick_up_price" => $request->input("pick_up_price"),
            "fuel_price" => $request->input("fuel_price"),
            "service_price" => $request->input("service_price"),
            "unit_id" => $request->input("unit_id"),
            "unit_range" => $request->input("unit_range"),
            "other_unit_id" => $request->input("other_unit_id"),
            "other_unit_range" => $request->input("other_unit_range"),
        ]);
        $result = $model->owners()->sync($request->input("owner_id"));
        app("OwnerService")->refreshRelevance($result["attached"],3);
        app("OwnerService")->refreshRelevance($result["detached"],3,true);
        $model->logistics()->sync($request->input("logistic_id"));
        LogService::log(__METHOD__,"计费模型-录入物流计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return response()->redirectTo("maintenance/priceModel/logistic")->with("successTip","创建“".$request->input("name")."”成功");
    }

    public function logisticEdit($id)
    {
        if(!Gate::allows('计费模型-物流-编辑')){ return redirect('denied');  }
        $owners = app("OwnerService")->getIntersectPermitting();
        $logistics = app('LogisticService')->getSelection(['id','name'],'物流');
        $units = app('UnitService')->getSelection();
        $model = app("OwnerPriceLogisticService")->find($id)->append(["owner_id","logistic_id"]);
        return response()->view('maintenance.priceModel.logistic.create',compact("owners","logistics","units","model"));
    }

    public function logisticUpdate($id, Request $request)
    {
        if(!Gate::allows('计费模型-物流-编辑')){ return redirect('denied');  }
        $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
        $request->offsetSet("logistic_id",explode(",",$request->input("logistic_id")));
        $this->logisticValidator($request->input(),$id)->validate();
        app("OwnerPriceLogisticService")->update(["id"=>$id],[
            "name" => $request->input("name"),
            "pick_up_price" => $request->input("pick_up_price"),
            "fuel_price" => $request->input("fuel_price"),
            "service_price" => $request->input("service_price"),
            "unit_id" => $request->input("unit_id"),
            "unit_range" => $request->input("unit_range"),
            "other_unit_id" => $request->input("other_unit_id"),
            "other_unit_range" => $request->input("other_unit_range"),
        ]);
        $model = new OwnerPriceLogistic();
        $model->id = $id;
        $result = $model->owners()->sync($request->input("owner_id"));
        app("OwnerService")->refreshRelevance($result["attached"],3);
        app("OwnerService")->refreshRelevance($result["detached"],3,true);
        $model->logistics()->sync($request->input("logistic_id"));
        LogService::log(__METHOD__,"计费模型-修改物流计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return response()->redirectTo("maintenance/priceModel/logistic")->with("successTip","修改“".$request->input("name")."”成功");
    }

    public function logisticGetDetail(Request $request)
    {
        if(!Gate::allows('计费模型-物流-查询')){ return ["success"=>false,"data"=>"无权操作"];  }
        $model = new OwnerPriceLogistic();
        $model->id = $request->input("id");
        $model->load(["details"=>function($query){
            /** @var Builder $query */
            $query->with(["unit","province","city"]);
        }]);
        return ["success"=>true,"data"=>$model->details];
    }

    public function expressExport($id)
    {
        if(!Gate::allows('计费模型-快递-查询')){ return ["success"=>false,"data"=>"无权操作"];  }
        $model = app("OwnerPriceExpressService")->find($id,[
            "owners","logistics","details"=>function($query){
                /** @var Builder $query */
                $query->with("province");
            }]);
        $row = ["客户","首重","续重","承运商"];
        $list = [[
            implode(",",array_column($model->owners->toArray(),"name")),
            $model->initial_weight,
            $model->additional_weight,
            implode(",",array_column($model->logistics->toArray(),"name")),
        ],[
            "价格名称","省","首重价格","续重价格",
        ]];
        foreach ($model->details as $detail){
            $list[] = [
                $model->name,
                $detail->province ? $detail->province->name : '',
                $detail->initial_weight_price,
                $detail->additional_weight_price,
            ];
        }
        return app(ExportService::class)->json($row,$list,"快递计费模型");
    }

    public function logisticImport(Request $request)
    {
        if(!Gate::allows('计费模型-物流-录入')){ return ["success"=>false,"data"=>"无权操作"];  }
        $fileSuffix=$request->file('file')->getClientOriginalExtension();
        if ($fileSuffix != 'xlsx' && $fileSuffix != 'xls' && $fileSuffix != 'csv')
            return ['success'=>false,'data'=>'不支持该文件类型'];
        ini_set('max_execution_time',2500);
        ini_set('memory_limit','1526M');
        $fileSuffix = ucwords($fileSuffix);

        if (!$request->has("id")){
            Excel::import(new OwnerPriceLogisticDetailImport(null),$request->file('file')->path(),null,$fileSuffix);
        }else{
            /** @var OwnerPriceLogistic $model */
            $model = app('OwnerPriceLogisticService')->find($request->input("id"),["unit","otherUnit","details"]);
            Excel::import(new OwnerPriceLogisticDetailImport($model),$request->file('file')->path(),null,$fileSuffix);
        }

        if (Cache::has('logistic'))return Cache::pull('logistic');

        return ["success"=>false,"data"=>"导入发生错误，数据无响应"];
    }

    public function logisticExport($id)
    {
        if(!Gate::allows('计费模型-物流-查询')){ return ["success"=>false,"data"=>"无权操作"];  }
        $model = app("OwnerPriceLogisticService")->find($id,[
            "owners","logistics","unit","otherUnit","details"=>function($query){
                /** @var Builder $query */
                $query->with(["province","unit","city"]);
            }]);
        $row = ["客户","价格名称",
            "单位一区间/".($model->unit ? $model->unit->name : ''),
            "单位二区间/".($model->otherUnit ? $model->otherUnit->name : ''),
            "提货费","燃油附加费","信息服务费","创建时间","承运商"];
        $range = "";
        foreach (explode(",",$model->unit_range) as $str){
            $range .= $str."\r\n";
        }
        $otherRange = "";
        foreach (explode(",",$model->other_unit_range) as $str){
            $otherRange .= $str."\r\n";
        }
        $list = [[
            implode(",",array_column($model->owners->toArray(),"name")),
            $model->name,
            $range,
            $otherRange,
            $model->pick_up_price,
            $model->fuel_price,
            $model->service_price,
            $model->created_at,
            implode(",",array_column($model->logistics->toArray(),"name")),
        ],[
            "单位","区间","省份","市","单价","送货费","起始计费","起始计数","费率"
        ]];
        foreach ($model->details as $detail){
            $list[] = [
                $detail->unit ? $detail->unit->name : '',
                $detail->range,
                $detail->province ? $detail->province->name : '',
                $detail->city ? $detail->city->name : '',
                $detail->unit_price,
                $detail->delivery_fee,
                $detail->initial_fee,
                $detail->initial_amount,
                $detail->rate ? $detail->rate."%" : '',
            ];
        }
        return app(ExportService::class)->json($row,$list,"物流计费模型");
    }

    public function logisticUpdateDetail(Request $request)
    {
        if(!Gate::allows('计费模型-物流-编辑')){ return ["success"=>false,"data"=>"无权操作"];  }
        $detail = $request->input("detail");
        if ($detail["id"]){
            app('OwnerPriceLogisticService')->updateDetail(["id"=>$detail["id"]],[
                "unit_price" => $detail["unit_price"],
                "delivery_fee" => $detail["delivery_fee"],
                "initial_fee" => $detail["initial_fee"],
                "initial_amount" => $detail["initial_amount"],
                "rate" => $detail["rate"],
            ]);
        }else{
            $row = app('OwnerPriceLogisticService')->isExistDetail([
                "owner_price_logistic_id"=>$request->input("id"),
                "unit_id"=>$detail["unit_id"],
                "range"=>$detail["range"],
                "province_id"=>$detail["province_id"],
                "city_id"=>$detail["city_id"],
            ]);
            if ($row>0)return ["success"=>false,"data"=>"已存在该计费模型"];
            /** @var OwnerPriceExpressProvince $detail */
            $detail = app('OwnerPriceLogisticService')->createDetail([
                "owner_price_logistic_id"=>$request->input("id"),
                "unit_id"=>$detail["unit_id"],
                "range"=>$detail["range"],
                "province_id"=>$detail["province_id"],
                "city_id"=>$detail["city_id"],
                "unit_price" => $detail["unit_price"],
                "delivery_fee" => $detail["delivery_fee"],
                "initial_fee" => $detail["initial_fee"],
                "initial_amount" => $detail["initial_amount"],
                "rate" => $detail["rate"],
            ]);
            $detail->load("province","unit","city");
        }
        LogService::log(__METHOD__,"计费模型-修改物流计费详情",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return ["success"=>true,"data"=>$detail];
    }

    public function logisticDestroyDetail(Request $request)
    {
        if(!Gate::allows('计费模型-物流-删除')){ return ["success"=>false,"data"=>"无权操作"];  }
        $id = $request->input("id");
        if (!$id)return ["success"=>false,"data"=>"非法参数"];
        app("OwnerPriceLogisticService")->destroyDetail($id);
        LogService::log(__METHOD__,"计费模型-删除物流计费详情",$id);
        return ["success"=>true];
    }
    public function logisticDestroy($id)
    {
        if(!Gate::allows('计费模型-物流-删除')){ return ["success"=>false,"data"=>"无权操作"];  }
        if (!$id)return ["success"=>false,"data"=>"非法参数"];
        app("OwnerPriceLogisticService")->destroy($id);
        LogService::log(__METHOD__,"计费模型-删除物流计费",$id);
        return ["success"=>true];
    }

    private function logisticValidator(array $params,$id = null)
    {
        return Validator::make($params,[
            'name'=>['required',$id?"unique:owner_price_logistics,name,$id":'unique:owner_price_logistics,name'],
            'pick_up_price'=>['nullable','numeric','min:0'],
            'fuel_price'=>['nullable','numeric','min:0'],
            'service_price'=>['nullable','numeric','min:0'],
            'unit_id'=>['required'],
            'unit_range'=>['required',function ($attribute, $value, $fail) {
                $bool = app("OwnerPriceLogisticService")->checkRange($value);
                if (!$bool)$fail("格式错误,值必须为连续的且最后一个值不允许封闭");
            }],
            'other_unit_id'=>['required'],
            'other_unit_range'=>['required',function ($attribute, $value, $fail) {
                $bool = app("OwnerPriceLogisticService")->checkRange($value);
                if (!$bool)$fail("格式错误,值必须为连续的且最后一个值不允许封闭");
            }],
            'owner_id'=>[function ($attribute, $value, $fail)use($id,$params) {
                $owners = app("OwnerPriceExpressService")->getExistOwnerName($value,$params["logistic_id"] ?? [],$id,"ownerPriceLogistics");
                if ($owners)$fail("(".implode(',',$owners).') 已经绑定计费模型');
            }],
            'items.*.unit_id'=>['sometimes','required'],
            'items.*.range'=>['sometimes','required'],
            'items.*.province_id'=>['sometimes','required'],
            'items.*.city_id'=>['sometimes','required'],
            'items.*.unit_price'=>['sometimes','nullable','numeric',"min:0"],
            'items.*.delivery_fee'=>['sometimes','nullable','numeric',"min:0"],
            'items.*.initial_fee'=>['sometimes','nullable','numeric',"min:0"],
            'items.*.initial_amount'=>['sometimes','nullable','numeric',"min:0"],
            'items.*.rate'=>['sometimes','nullable','numeric',"min:0"],
        ],[
            'required'=>':attribute 为必填项',
            'unique' => ':attribute 已存在',
            'numeric' => ':attribute 必须为数字',
            'min' => ':attribute 不得为负',
        ],[
            'name' =>"名称",
            'pick_up_price'  =>"提货费",
            'fuel_price'  =>"燃油附加费",
            'service_price'  =>"信息服务费",
            'unit_id'  =>"单位一",
            'unit_range'  =>"区间值",
            'other_unit_id'  =>"单位二",
            'other_unit_range'  =>"区间值",
            'items.*.unit_id'=>"单位",
            'items.*.range'=>"区间",
            'items.*.province_id'=>"省份",
            'items.*.city_id'=>"城市",
            'items.*.unit_price'=>"单价",
            'items.*.delivery_fee'=>"送货费",
            'items.*.initial_fee'=>"起始计费",
            'items.*.initial_amount'=>"起始计数",
            'items.*.rate'=>"费率",
        ]);
    }

    public function directLogisticIndex(Request $request){
        if(!Gate::allows('计费模型-直发-查询')){ return redirect('denied');  }
        $models = app("OwnerPriceDirectLogisticService")->paginate($request->input("id"));
        return response()->view('maintenance.priceModel.directLogistic.index',compact("models"));
    }

    public function directLogisticCreate(){
        if(!Gate::allows('计费模型-直发-录入')){ return redirect('denied');  }
        $owners = app("OwnerService")->getIntersectPermitting();
        return response()->view('maintenance.priceModel.directLogistic.create',compact("owners"));
    }

    public function directLogisticStore(Request $request)
    {
        if(!Gate::allows('计费模型-直发-录入')){ return redirect('denied');  }
        $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
        $this->directLogisticValidator($request->input())->validate();
        /** @var OwnerPriceDirectLogistic $model */
        $model = app("OwnerPriceDirectLogisticService")->create([
            "name" => $request->input("name"),
            "base_km" => $request->input("base_km"),
        ]);
        $result = $model->owners()->sync($request->input("owner_id"));
        app("OwnerService")->refreshRelevance($result["attached"],4);
        app("OwnerService")->refreshRelevance($result["detached"],4,true);
        LogService::log(__METHOD__,"计费模型-录入直发车计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return response()->redirectTo("maintenance/priceModel/directLogistic")->with("successTip","创建“".$request->input("name")."”成功");
    }

    public function directLogisticDestroy($id)
    {
        if(!Gate::allows('计费模型-直发-删除')){ return ["success"=>false,"data"=>"无权操作"];  }
        $row = app("OwnerPriceDirectLogisticService")->destroy($id);
        if ($row == 1){
            LogService::log(__METHOD__,"计费模型-删除直发车计费",$id);
            return ["success"=>true];
        }
        return ["success"=>false,"data"=>"影响了“".$row."”行"];
    }

    public function directLogisticEdit($id)
    {
        if(!Gate::allows('计费模型-直发-编辑')){ return redirect('denied');  }
        $owners = app("OwnerService")->getIntersectPermitting();
        $model = app("OwnerPriceDirectLogisticService")->find($id)->append("owner_id");
        return response()->view('maintenance.priceModel.directLogistic.create',compact("model","owners"));
    }

    public function directLogisticUpdate($id, Request $request)
    {
        if(!Gate::allows('计费模型-直发-编辑')){ return redirect('denied');  }
        $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
        $this->directLogisticValidator($request->input(),$id)->validate();
        app("OwnerPriceDirectLogisticService")->update(["id"=>$id],[
            "name" => $request->input("name"),
            "base_km" => $request->input("base_km"),
        ]);
        $model = new OwnerPriceDirectLogistic();
        $model->id = $id;
        $result = $model->owners()->sync($request->input("owner_id"));
        app("OwnerService")->refreshRelevance($result["attached"],4);
        app("OwnerService")->refreshRelevance($result["detached"],4,true);
        LogService::log(__METHOD__,"计费模型-修改直发车计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return response()->redirectTo("maintenance/priceModel/directLogistic")->with("successTip","修改“".$request->input("name")."”成功");
    }

    public function directLogisticGetDetail(Request $request)
    {
        if(!Gate::allows('计费模型-直发-查询')){ return ["success"=>false,"data"=>"无权操作"];  }
        $model = new OwnerPriceDirectLogistic();
        $model->id = $request->input("id");
        $model->load(["details"=>function($query){
            /** @var Builder $query */
            $query->with("carType");
        }]);
        return ["success"=>true,"data"=>$model->details];
    }

    public function directLogisticImport(Request $request)
    {
        if(!Gate::allows('计费模型-直发-录入')){ return ["success"=>false,"data"=>"无权操作"];  }
        $fileSuffix=$request->file('file')->getClientOriginalExtension();
        if ($fileSuffix != 'xlsx' && $fileSuffix != 'xls' && $fileSuffix != 'csv')
            return ['success'=>false,'data'=>'不支持该文件类型'];
        ini_set('max_execution_time',2500);
        ini_set('memory_limit','1526M');
        $fileSuffix = ucwords($fileSuffix);

        if (!$request->has("id")){
            Excel::import(new OwnerPriceDirectLogisticDetailImport(null),$request->file('file')->path(),null,$fileSuffix);
        }else{
            $model = new OwnerPriceDirectLogistic();
            $model->id = $request->input("id");
            $model->load("details");
            Excel::import(new OwnerPriceDirectLogisticDetailImport($model),$request->file('file')->path(),null,$fileSuffix);
        }

        if (Cache::has('directLogistic'))return Cache::pull('directLogistic');
        return ["success"=>false,"data"=>"导入发生错误，数据无响应"];
    }

    public function directLogisticUpdateDetail(Request $request)
    {
        if(!Gate::allows('计费模型-直发-编辑')){ return ["success"=>false,"data"=>"无权操作"];  }
        $detail = $request->input("detail");
        if ($detail["id"]){
            app('OwnerPriceDirectLogisticService')->updateDetail(["id"=>$detail["id"]],[
                "base_fee" => $detail["base_fee"],
                "additional_fee" => $detail["additional_fee"],
            ]);
        }else{
            $row = app('OwnerPriceDirectLogisticService')->isExistDetail([
                "owner_price_direct_logistic_id"=>$request->input("id"),
                "car_type_id"=>$detail["car_type_id"],
            ]);
            if ($row>0)return ["success"=>false,"data"=>"已存在该计费模型"];
            /** @var OwnerPriceExpressProvince $detail */
            $detail = app('OwnerPriceDirectLogisticService')->createDetail([
                "owner_price_direct_logistic_id"=>$request->input("id"),
                "car_type_id"=>$detail["car_type_id"],
                "base_fee" => $detail["base_fee"],
                "additional_fee" => $detail["additional_fee"],
            ]);
            $detail->load("carType");
        }
        LogService::log(__METHOD__,"计费模型-修改直发车计费详情",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
        return ["success"=>true,"data"=>$detail];
    }

    public function directLogisticDestroyDetail(Request $request)
    {
        if(!Gate::allows('计费模型-直发-删除')){ return ["success"=>false,"data"=>"无权操作"];  }
        $id = $request->input("id");
        if (!$id)return ["success"=>false,"data"=>"非法参数"];
        app("OwnerPriceDirectLogisticService")->destroyDetail($id);
        LogService::log(__METHOD__,"计费模型-删除直发车计费详情",$id);
        return ["success"=>true];
    }

    private function directLogisticValidator(array $params, $id= null)
    {
        return Validator::make($params,[
            'name'=>['required',$id?"unique:owner_price_direct_logistics,name,$id":'unique:owner_price_direct_logistics,name'],
            'base_km'=>['required','numeric','min:0'],
            'owner_id'=>[function ($attribute, $value, $fail)use($id) {
                $owners = app("OwnerPriceDirectLogisticService")->getExistOwnerName($value,$id);
                if ($owners)$fail("(".implode(',',$owners).') 已经绑定直发计费模型');
            }],
        ],[
            'required'=>':attribute 为必填项',
            'unique' => ':attribute 已存在',
            'numeric' => ':attribute 必须为数字',
            'min' => ':attribute 不得为负',
        ],[
            'name' =>"名称",
            'base_km'  =>"起步公里数",
        ]);
    }

    public function apiStoreStorage()
    {
        $this->gate("客户管理-项目-录入");
        $errors = $this->storageValidator(request()->input())->errors();
        if (count($errors)>0)$this->success(["errors"=>$errors]);

        if (!request("owner_id"))$this->error("参数传递错误");
        $values = [
            "name"              => request("name"),
            "counting_type"     => request("counting_type"),
            "using_type"        => request("using_type"),
            "minimum_area"      => request("minimum_area") ?? 0,
            "price"             => request("price"),
            "discount_type"     => request("discount_type"),
            "discount_value"    => request("discount_value") ?? 0,
            "unit_id"           => request("unit_id"),
            "time_unit_id"      => request("time_unit_id"),
        ];
        if (request("id"))app('OwnerStoragePriceModelService')->update(["id"=>request("id")],$values);
        else{
            DB::transaction(function ()use(&$model,$values){
                $model = app('OwnerStoragePriceModelService')->create($values);
                DB::insert(DB::raw("INSERT INTO owner_storage_price_model_owner VALUES(?,?)"),[$model->id,request("owner_id")]);
                DB::commit();
            });
            $this->success($model->id);
        }
        $this->success();
    }

    public function apiStoreOperation()
    {
        $this->gate("客户管理-项目-录入");

        $params = request()->input();
        if (request("operation_type") == '入库'){
            foreach ($params["items"] as $index => $it){
                if (!$it || $it['strategy'] == '起步'){
                    unset($params["items"][$index]);
                    break;
                }
            }
        }

        $params["owner_id"] = [$params["owner_id"]];
        $errors = $this->operationValidator($params,request("id"))->errors();
        if (count($errors)>0)$this->success(["errors"=>$errors]);

        if (!request("owner_id"))$this->error("参数传递错误");
        $operation = [
            "name"              => request("name"),
            "operation_type"    => request("operation_type"),
            "strategy"          => request("strategy"),
            "feature"           => request("feature"),
            "remark"            => request("remark"),
            "discount_count"    => implode(",",request("discount_count")),
            "total_price"       => request("total_price"),
            "total_discount_price"=> implode(",",request("total_discount_price")),
        ];
        if (request("id")){
            $model = app('OwnerPriceOperationService')->find(request("id"),["items"]);
            app('OwnerPriceOperationService')->findUpdate($model,$operation);
            $delete = [];//需要删除子项
            $update = [["id","strategy","amount","unit_id","unit_price","feature","discount_price"]];//需要更新子项
            $insert = [];//需要新增子项
            foreach ($params["items"] as $item){
                $obj = [
                    "strategy"  => $item["strategy"],
                    "amount"    => $item["amount"],
                    "unit_id"   => $item["unit_id"],
                    "unit_price"=> $item["unit_price"],
                    "feature"   => $item["feature"] ?? null,
                    "discount_price"   => implode(",",$item["discount_price"] ?? []),
                ];
                if (isset($item["id"])){
                    $obj["id"] = $item["id"];
                    $update[] = $obj;
                    $delete[] = $item["id"];
                } else{
                    $obj["owner_price_operation_id"] = $model->id;
                    $obj["feature"] = $item["feature"] ?? null;
                    $insert[] = $obj;
                }
            }
            $ids = array_column($model->items->toArray(),"id");
            $delete = array_diff($ids,$delete);
            if ($delete)app("OwnerPriceOperationItemService")->destroy($delete);
            if (count($update) > 1)app(BatchUpdateService::class)->batchUpdate("owner_price_operation_items",$update);
            if ($insert)app("OwnerPriceOperationItemService")->insert($insert);
        }else{
            DB::transaction(function ()use(&$model,$params,$operation){
                $model = app('OwnerPriceOperationService')->create($operation);
                foreach ($params["items"] as &$item){
                    $item["discount_price"]  = implode(",",$item["discount_price"] ?? []);
                    $item["owner_price_operation_id"] = $model->id;
                    if (!isset($item["feature"]))$item["feature"] = null;
                    unset($item["features"]);
                    unset($item["featureFormat"]);
                    unset($item["type"]);
                }
                app("OwnerPriceOperationItemService")->insert($params["items"]);
                DB::insert(DB::raw("INSERT INTO owner_price_operation_owner(owner_price_operation_id,owner_id) VALUES(?,?)"),[$model->id,request("owner_id")]);
                DB::commit();
            });
        }
        /** @var OwnerPriceOperation $model */
        $model->load("items");
        $this->success($model);
    }

    public function apiStoreExpress()
    {
        $this->gate("客户管理-项目-录入");
        $params = request()->input();
        $params["logistic_id"] = $params["logistics"];
        $errors = $this->expressValidator($params,request("id"))->errors()->toArray();
        $exist = [];
        foreach ($params["items"] as $index => $item){
            if (isset($exist[$item["province_id"]]))$errors["items.".$index.".province_id"] = ["已存在"];
            else $exist[$item["province_id"]] = true;
        }
        if (count($errors)>0)$this->success(["errors"=>$errors]);

        $obj = [
            "name"              => request("name"),
            "initial_weight"    => request("initial_weight"),
            "additional_weight" => request("additional_weight"),
        ];
        if (request("id")){
            /** @var OwnerPriceExpress $model */
            $model = app('OwnerPriceExpressService')->find(request("id"),["details"]);
            app('OwnerPriceExpressService')->update(["id"=>request("id")],$obj);

            $delete = [];//需要删除子项
            $update = [["id","province_id","initial_weight_price","additional_weight_price"]];//需要更新子项
            $insert = [];//需要新增子项
            foreach ($params["items"] as $item){
                $obj = [
                    "province_id"               => $item["province_id"],
                    "initial_weight_price"      => $item["initial_weight_price"],
                    "additional_weight_price"   => $item["additional_weight_price"],
                ];
                if (isset($item["id"])){
                    $obj["id"] = $item["id"];
                    $update[] = $obj;
                    $delete[] = $item["id"];
                } else{
                    $obj["owner_price_express_id"] = $model->id;
                    $insert[] = $obj;
                }
            }
            $ids = array_column($model->details->toArray(),"id");
            $delete = array_diff($ids,$delete);
            if ($delete)OwnerPriceExpressProvince::destroy($delete);
            if (count($update) > 1)app(BatchUpdateService::class)->batchUpdate("owner_price_express_provinces",$update);
            if ($insert)OwnerPriceExpressProvince::query()->insert($insert);
            $model->logistics()->sync(request("logistics"));
        }else{
            DB::transaction(function ()use(&$model,$params,$obj){
                $model = app('OwnerPriceExpressService')->create($obj);
                foreach ($params["items"] as &$item)$item["owner_price_express_id"] = $model->id;
                OwnerPriceExpressProvince::query()->insert($params["items"]);
                DB::insert(DB::raw("INSERT INTO owner_price_express_owner VALUES(?,?)"),[$model->id,request("owner_id")]);
                /** @var OwnerPriceExpress $model */
                $model->logistics()->syncWithoutDetaching(request("logistics"));
                DB::commit();
            });
        }
        $model->load("details");
        $this->success($model);
    }

    public function apiStoreLogistic()
    {
        $this->gate("客户管理-项目-录入");
        $params = request()->input();
        $params["owner_id"] = [$params["owner_id"]];
        $params["logistic_id"] = $params["logistics"];
        $errors = $this->logisticValidator($params,request("id"))->errors()->toArray();
        $exist = [];
        foreach ($params["items"] as $index => $item){
            $key = $item["unit_id"]."-".$item["range"]."-".$item["province_id"]."-".$item["city_id"];
            if (isset($exist[$key]))$errors["items.".$index.".unit_id"] = ["该条已存在"];
            else $exist[$key] = true;
        }
        if (count($errors)>0)$this->success(["errors"=>$errors]);

        $obj = [
            "name"              => request('name'),
            "unit_range"        => request('unit_range'),
            "unit_id"           => request('unit_id'),
            "other_unit_range"  => request('other_unit_range'),
            "other_unit_id"     => request('other_unit_id'),
            "pick_up_price"     => request('pick_up_price'),
            "fuel_price"        => request('fuel_price'),
            "service_price"     => request('service_price'),
        ];
        if (request("id")){
            $model = app("OwnerPriceLogisticService")->find(request("id"),["details"]);
            app("OwnerPriceLogisticService")->update(["id"=>request("id")],$obj);

            $delete = [];//需要删除子项
            $update = [["id","unit_id","range","province_id","city_id","unit_price","delivery_fee","initial_fee","initial_amount","rate"]];//需要更新子项
            $insert = [];//需要新增子项
            foreach ($params["items"] as $item){
                $obj = [
                    "unit_id"        => $item["unit_id"],
                    "range"          => $item["range"],
                    "province_id"    => $item["province_id"],
                    "city_id"        => $item["city_id"],
                    "unit_price"     => $item["unit_price"],
                    "delivery_fee"   => $item["delivery_fee"],
                    "initial_fee"    => $item["initial_fee"],
                    "initial_amount" => $item["initial_amount"],
                    "rate"           => $item["rate"],
                ];
                if (isset($item["id"])){
                    $obj["id"] = $item["id"];
                    $update[] = $obj;
                    $delete[] = $item["id"];
                } else{
                    $obj["owner_price_logistic_id"] = $model->id;
                    $insert[] = $obj;
                }
            }
            $ids = array_column($model->details->toArray(),"id");
            $delete = array_diff($ids,$delete);
            if ($delete)OwnerPriceLogisticDetail::destroy($delete);
            if (count($update) > 1)app(BatchUpdateService::class)->batchUpdate("owner_price_logistic_details",$update);
            if ($insert)OwnerPriceLogisticDetail::query()->insert($insert);
            /** @var OwnerPriceLogistic $model */
            $model->logistics()->sync(request("logistics"));
        }else{
            DB::transaction(function ()use(&$model,$params,$obj){
                $model = app("OwnerPriceLogisticService")->create($obj);
                foreach ($params["items"] as &$param)$param["owner_price_logistic_id"] = $model->id;
                OwnerPriceLogisticDetail::query()->insert($params["items"]);
                DB::insert(DB::raw("INSERT INTO owner_price_logistic_owner VALUES(?,?)"),[$model->id,request("owner_id")]);
                /** @var OwnerPriceLogistic $model */
                $model->logistics()->syncWithoutDetaching(request("logistics"));
                DB::commit();
            });
        }
        $model->load("details");
        $this->success($model);
    }

    public function apiStoreDirectLogistic()
    {
        $this->gate("客户管理-项目-录入");
        $errors = $this->directLogisticValidator(request()->input(),request("id"))->errors()->toArray();
        $exist = [];
        foreach (request("items") as $index=>$item){
            if (isset($exist[$item['car_type_id']]))$errors["items.".$index.".car_type_id"] = ["已存在"];
            else $exist[$item['car_type_id']] = true;
        }
        if (count($errors)>0)$this->success(["errors"=>$errors]);

        $items = request()->input("items");
        $obj = [
            "name"      => request("name"),
            "base_km"   => request("base_km"),
        ];
        if (request("id")){
            $model = app("OwnerPriceDirectLogisticService")->find(request("id"),["details"]);
            app("OwnerPriceDirectLogisticService")->update(["id"=>request("id")],$obj);

            $delete = [];//需要删除子项
            $update = [["id","car_type_id","base_fee","additional_fee"]];//需要更新子项
            $insert = [];//需要新增子项
            foreach ($items as $item){
                $obj = [
                    "car_type_id"       => $item["car_type_id"],
                    "base_fee"          => $item["base_fee"],
                    "additional_fee"    => $item["additional_fee"],
                ];
                if (isset($item["id"])){
                    $obj["id"] = $item["id"];
                    $update[] = $obj;
                    $delete[] = $item["id"];
                } else{
                    $obj["owner_price_direct_logistic_id"] = $model->id;
                    $insert[] = $obj;
                }
            }
            $ids = array_column($model->details->toArray(),"id");
            $delete = array_diff($ids,$delete);
            if ($delete)OwnerPriceDirectLogisticCar::destroy($delete);
            if (count($update) > 1)app(BatchUpdateService::class)->batchUpdate("owner_price_direct_logistic_cars",$update);
            if ($insert)OwnerPriceDirectLogisticCar::query()->insert($insert);
        }else{
            DB::transaction(function ()use(&$model,$items,$obj){
                $model = app("OwnerPriceDirectLogisticService")->create($obj);
                foreach ($items as &$item)$item["owner_price_direct_logistic_id"] = $model->id;
                OwnerPriceDirectLogisticCar::query()->insert($items);
                DB::insert(DB::raw("INSERT INTO owner_price_direct_logistic_owner VALUES(?,?)"),[$model->id,request("owner_id")]);
                DB::commit();
            });
        }
        /** @var OwnerPriceDirectLogistic $model */
        $model->load("details");
        $this->success($model);
    }

    public function getPriceModel()
    {
        $owner = new Owner();
        $owner->id = request("id");
        $owner->load(["ownerStoragePriceModels","ownerPriceOperations"=>function($query){
            /** @var Builder $query */
            $query->with(["items"=>function($query){
                /** @var Builder $query */
                $query->orderByRaw("CASE strategy  WHEN '起步' THEN 1 WHEN '默认' THEN 2 WHEN '特征' THEN 3 END");
            }]);
        },"ownerPriceExpresses"=>function($query){
            /** @var Builder $query */
            $query->with(["details","logistics"]);
        },"ownerPriceLogistics"=>function($query){
            /** @var Builder $query */
            $query->with(["details","logistics"]);
        },"ownerPriceDirectLogistics.details"]);
        $features = app("FeatureService")->getMapArray();
        OwnerPriceOperation::$features = $features;
        OwnerPriceOperationItem::$features = $features;
        foreach ($owner->ownerPriceOperations as &$operation){
            $operation["featureFormat"] = $operation->featureFormat;
            foreach ($operation->items as &$item){
                $item["featureFormat"] = $item->featureFormat;
                if ($operation["operation_type"]==='出库' && $item["strategy"] == "起步"){
                    $item["type"] = $item["amount"] ? 0 : 1;
                }
            }
        }
        $this->success($owner);
    }

    public function apiGetStorage()
    {
        $this->gate("客户管理-项目-录入");
        $models = OwnerStoragePriceModel::query();
        if (request("customer_id")){
            $customerId = request("customer_id");
            $models->whereHas("owners",function ($query)use($customerId){
                /** @var Builder $query */
                $query->where("customer_id",$customerId);
            });
        }
        if (request("owner_id")){
            $ownerId = request("owner_id");
            $models->whereHas("owners",function ($query)use($ownerId){
                /** @var Builder $query */
                $query->where("id",$ownerId);
            });
        }
        if (request("name")){
            $models->where("name","like","%".request("name")."%");
        }
        $this->success($models->get());
    }
    public function apiGetOperation()
    {
        $this->gate("客户管理-项目-录入");
        $models = OwnerPriceOperation::query()->with("items");
        if (request("customer_id")){
            $customerId = request("customer_id");
            $models->whereHas("ownerPriceOperationOwners",function ($query)use($customerId){
                /** @var Builder $query */
                $query->where("customer_id",$customerId);
            });
        }
        if (request("owner_id")){
            $ownerId = request("owner_id");
            $models->whereHas("ownerPriceOperationOwners",function ($query)use($ownerId){
                /** @var Builder $query */
                $query->where("id",$ownerId);
            });
        }
        if (request("name")){
            $models->where("name","like","%".request("name")."%");
        }
        $features = app("FeatureService")->getMapArray();
        OwnerPriceOperation::$features = $features;
        OwnerPriceOperationItem::$features = $features;
        $models = $models->get();
        foreach ($models as &$operation){
            $operation["featureFormat"] = $operation->featureFormat;
            $items = [[],[]];
            foreach ($operation->items as $item){
                $obj = [
                    "strategy" => $item["strategy"],
                    "amount" => $item["amount"],
                    "unit_id" => $item["unit_id"],
                    "unit_price" => $item["unit_price"],
                    "discount_price" => $item["discount_price"] ?? null,
                    "feature" => $item["feature"],
                    "featureFormat" => $item->featureFormat,
                ];
                if ($item["strategy"] == '起步')$items[0] = $obj;
                if ($item["strategy"] == '默认')$items[1] = $obj;
                if ($item["strategy"] == '特征')$items[] = $obj;
            }
            if (!$items[0])$items[0] = [
                "strategy" => "起步",
                "amount" => "",
                "unit_id" => "",
                "unit_price" => "",
                "feature" => "",
            ];
            if (!$items[1])$items[1] = [
                "strategy" => "默认",
                "amount" => "",
                "unit_id" => "",
                "unit_price" => "",
                "feature" => "",
            ];
            unset($operation["items"]);
            $operation["items"] = $items;
        }
        $this->success($models);
    }
    public function apiGetExpress()
    {
        $this->gate("客户管理-项目-录入");
        $models = OwnerPriceExpress::query()->with(["details","logistics:id"]);
        if (request("customer_id")){
            $customerId = request("customer_id");
            $models->whereHas("owners",function ($query)use($customerId){
                /** @var Builder $query */
                $query->where("customer_id",$customerId);
            });
        }
        if (request("owner_id")){
            $ownerId = request("owner_id");
            $models->whereHas("owners",function ($query)use($ownerId){
                /** @var Builder $query */
                $query->where("id",$ownerId);
            });
        }
        if (request("logistic_id")){
            $logisticId = request("logistic_id");
            $models->whereHas("logistics",function ($query)use($logisticId){
                /** @var Builder $query */
                $query->where("id",$logisticId);
            });
        }
        if (request("name")){
            $models->where("name","like","%".request("name")."%");
        }
        $this->success($models->get());
    }
    public function apiGetLogistic()
    {
        $this->gate("客户管理-项目-录入");
        $models = OwnerPriceLogistic::query()->with(["details","logistics"]);
        if (request("customer_id")){
            $customerId = request("customer_id");
            $models->whereHas("owners",function ($query)use($customerId){
                /** @var Builder $query */
                $query->where("customer_id",$customerId);
            });
        }
        if (request("owner_id")){
            $ownerId = request("owner_id");
            $models->whereHas("owners",function ($query)use($ownerId){
                /** @var Builder $query */
                $query->where("id",$ownerId);
            });
        }
        if (request("logistic_id")){
            $logisticId = request("logistic_id");
            $models->whereHas("logistics",function ($query)use($logisticId){
                /** @var Builder $query */
                $query->where("id",$logisticId);
            });
        }
        if (request("name")){
            $models->where("name","like","%".request("name")."%");
        }
        $this->success($models->get());
    }
    public function apiGetDirectLogistic()
    {
        $this->gate("客户管理-项目-录入");
        $models = OwnerPriceDirectLogistic::query()->with("details");
        if (request("customer_id")){
            $customerId = request("customer_id");
            $models->whereHas("owners",function ($query)use($customerId){
                /** @var Builder $query */
                $query->where("customer_id",$customerId);
            });
        }
        if (request("owner_id")){
            $ownerId = request("owner_id");
            $models->whereHas("owners",function ($query)use($ownerId){
                /** @var Builder $query */
                $query->where("id",$ownerId);
            });
        }
        if (request("name")){
            $models->where("name","like","%".request("name")."%");
        }
        $this->success($models->get());
    }

    public function apiDelStorage()
    {
        $this->gate("客户管理-项目-录入");
        if (!request("id"))$this->error("非法参数");
        app("OwnerStoragePriceModelService")->destroy(request("id"));
        $this->success();
    }
    public function apiDelOperation()
    {
        $this->gate("客户管理-项目-录入");
        if (!request("id"))$this->error("非法参数");
        app("OwnerPriceOperationService")->destroy(request("id"));
        $this->success();
    }
    public function apiDelOperationItem()
    {
        $this->gate("客户管理-项目-录入");
        if (!request("id"))$this->error("非法参数");
        app("OwnerPriceOperationItemService")->destroy(request("id"));
        $this->success();
    }
    public function apiDelExpress()
    {
        $this->gate("客户管理-项目-录入");
        if (!request("id"))$this->error("非法参数");
        app("OwnerPriceExpressService")->destroy(request("id"));
        $this->success();
    }
    public function apiDelExpressItem()
    {
        $this->gate("客户管理-项目-录入");
        if (!request("id"))$this->error("非法参数");
        app("OwnerPriceExpressService")->destroyDetail(request("id"));
        $this->success();
    }
    public function apiDelLogistic()
    {
        $this->gate("客户管理-项目-录入");
        if (!request("id"))$this->error("非法参数");
        app("OwnerPriceLogisticService")->destroy(request("id"));
        $this->success();
    }
    public function apiDelLogisticItem()
    {
        $this->gate("客户管理-项目-录入");
        if (!request("id"))$this->error("非法参数");
        app("OwnerPriceLogisticService")->destroyDetail(request("id"));
        $this->success();
    }
    public function apiDelDirectLogistic()
    {
        $this->gate("客户管理-项目-录入");
        if (!request("id"))$this->error("非法参数");
        app("OwnerPriceDirectLogisticService")->destroy(request("id"));
        $this->success();
    }
    public function apiDelDirectLogisticItem()
    {
        $this->gate("客户管理-项目-录入");
        if (!request("id"))$this->error("非法参数");
        app("OwnerPriceDirectLogisticService")->destroyDetail(request("id"));
        $this->success();
    }

}