|
|
@@ -0,0 +1,186 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+namespace App\Imports;
|
|
|
+
|
|
|
+use App\City;
|
|
|
+use App\OwnerPriceLogistic;
|
|
|
+use App\OwnerPriceLogisticDetail;
|
|
|
+use App\Province;
|
|
|
+use App\Services\common\BatchUpdateService;
|
|
|
+use App\Services\LogService;
|
|
|
+use Illuminate\Support\Collection;
|
|
|
+use Illuminate\Support\Facades\Cache;
|
|
|
+use Maatwebsite\Excel\Concerns\ToCollection;
|
|
|
+use Maatwebsite\Excel\Concerns\WithHeadingRow;
|
|
|
+use Maatwebsite\Excel\Imports\HeadingRowFormatter;
|
|
|
+
|
|
|
+
|
|
|
+HeadingRowFormatter::default('none');
|
|
|
+class OwnerPriceLogisticDetailImport implements ToCollection,WithHeadingRow
|
|
|
+{
|
|
|
+ protected $logistic;
|
|
|
+ public function __construct(OwnerPriceLogistic $logistic = null)
|
|
|
+ {
|
|
|
+ $this->logistic = $logistic;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * @param Collection $collection
|
|
|
+ * @return bool
|
|
|
+ */
|
|
|
+ public function collection(Collection $collection)
|
|
|
+ {
|
|
|
+
|
|
|
+ if (!$this->logistic){
|
|
|
+ Cache::put("logistic",["success"=>false, "data"=>"不存在父级"],86400);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ $row = $collection->first();
|
|
|
+ $header = [
|
|
|
+ "计数单位","计数区间","省份","市","单价","送货费","起始计费","起始计数","费率"
|
|
|
+ ];
|
|
|
+ foreach ($header as $str){
|
|
|
+ if (!isset($row[$str])){
|
|
|
+ Cache::put("logistic",["success"=>false, "data"=>"表头不存在“".$str."”"],86400);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //省份map
|
|
|
+ $map = [];
|
|
|
+ $provinces = Province::query()->get();
|
|
|
+ foreach ($provinces as $province){
|
|
|
+ $map[$province->name] = $province->id;
|
|
|
+ }
|
|
|
+
|
|
|
+ //市map
|
|
|
+ $cityMap = [];
|
|
|
+ $cityMappingProvince = [];
|
|
|
+ $cities = City::query()->get();
|
|
|
+ foreach ($cities as $city){
|
|
|
+ $cityMap[$city->name] = $city->id;
|
|
|
+ $cityMappingProvince[$city->id] = $city->province_id;
|
|
|
+ }
|
|
|
+
|
|
|
+ //对比单位
|
|
|
+ $unit = $this->logistic->unit ? strtoupper($this->logistic->unit->name) : '';
|
|
|
+ $otherUnit = $this->logistic->otherUnit ? strtoupper($this->logistic->otherUnit->name) : '';
|
|
|
+
|
|
|
+ //对比区间
|
|
|
+ $range = [
|
|
|
+ $unit => explode(",",$this->logistic->unit_range),
|
|
|
+ $otherUnit => explode(",",$this->logistic->other_unit_range),
|
|
|
+ ];
|
|
|
+
|
|
|
+ //已存在的计费
|
|
|
+ $existDetails = [];
|
|
|
+ foreach ($this->logistic->details as $detail){
|
|
|
+ $existDetails[$detail->unit_id.'_'.$detail->range."_".$detail->province_id."_".$detail->city_id] = $detail->id;
|
|
|
+ }
|
|
|
+
|
|
|
+ //生成列表内的重复条目
|
|
|
+ $existInsert = [];
|
|
|
+
|
|
|
+ //导入的数据整理,存在更新
|
|
|
+ $id = $this->logistic->id;
|
|
|
+ $errors = [];
|
|
|
+ $insert = [];
|
|
|
+ $update = [["id","unit_price","delivery_fee","initial_fee","initial_amount","rate","updated_at"]];
|
|
|
+ $date = date('Y-m-d H:i:s');
|
|
|
+ foreach ($collection as $index => $item){
|
|
|
+ /* 数据校验 */
|
|
|
+ if (!$item["省份"]){
|
|
|
+ $errors[] = "第“".($index+2)."”行省份为空";
|
|
|
+ continue;
|
|
|
+ }else{
|
|
|
+ if ((!isset($map[$item["省份"]]) && !isset($map[mb_substr($item["省份"], 0,-1)]))){
|
|
|
+ $errors[] = "第“".($index+2)."”行未知省份";
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (isset($map[mb_substr($item["省份"], 0,-1)]))$item["省份"] = mb_substr($item["省份"], 0,-1);
|
|
|
+ }
|
|
|
+ if (!$item["计数单位"] || (strtoupper($item["计数单位"]) != $unit && strtoupper($item["计数单位"]) != $otherUnit)){
|
|
|
+ //$errors[] = "第“".($index+2)."”行单位不符合";
|
|
|
+ //continue;
|
|
|
+ Cache::put("logistic",["success"=>false, "data"=>"第“".($index+2)."”行单位不符合"],86400);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ if (!$item["计数区间"] || array_search($item["计数区间"],$range[strtoupper($item["计数单位"])]) === false){
|
|
|
+ //$errors[] = "第“".($index+2)."”行非法首重价格";
|
|
|
+ //continue;
|
|
|
+ Cache::put("logistic",["success"=>false, "data"=>"第“".($index+2)."”行区间不符合"],86400);
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ if (!isset($cityMap[$item["市"]])){
|
|
|
+ $errors[] = "第“".($index+2)."”行未知城市";
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ if (!$item["单价"] || !is_numeric($item["单价"]) || $item["单价"] <= 0){
|
|
|
+ $errors[] = "第“".($index+2)."”行非法单价";
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ $numeric = ["送货费","起始计费","起始计数","费率"];
|
|
|
+ $sign = false;
|
|
|
+ foreach ($numeric as $column){
|
|
|
+ if ($item[$column] && (!is_numeric($item[$column]) || $item[$column] <= 0)){
|
|
|
+ $errors[] = "第“".($index+2)."”行非法".$column;
|
|
|
+ $sign = true;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if ($sign)continue;
|
|
|
+
|
|
|
+ /* 数据转换及存在校验 */
|
|
|
+ if ($cityMappingProvince[$cityMap[$item["市"]]] != $map[$item["省份"]]){
|
|
|
+ $errors[] = "第“".($index+2)."”行城市不属于该省份";
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ $item["省份"] = $map[$item["省份"]];
|
|
|
+ $item["计数单位"] = strtoupper($item["计数单位"]) == $unit ? $this->logistic->unit_id : $this->logistic->other_unit_id;
|
|
|
+ $item["市"] = $cityMap[$item["市"]];
|
|
|
+ $key = $item["计数单位"]."_".$item["计数区间"]."_".$item["省份"]."_".$item["市"];
|
|
|
+ if (isset($existInsert[$key])){
|
|
|
+ $errors[] = "第“".($index+2)."”行重复条目";
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (isset($existDetails[$key])){
|
|
|
+ $update[] = [
|
|
|
+ "id" => $existDetails[$key],
|
|
|
+ "unit_price" => $item["单价"],
|
|
|
+ "delivery_fee" => $item["送货费"],
|
|
|
+ "initial_fee" => $item["起始计费"],
|
|
|
+ "initial_amount" => $item["起始计数"],
|
|
|
+ "rate" => $item["费率"],
|
|
|
+ "updated_at" => $date,
|
|
|
+ ];
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ $insert[] = [
|
|
|
+ "owner_price_logistic_id" => $id,
|
|
|
+ "unit_id" => $item["计数单位"],
|
|
|
+ "range" => $item["计数区间"],
|
|
|
+ "province_id" => $item["省份"],
|
|
|
+ "city_id" => $item["市"],
|
|
|
+ "unit_price" => $item["单价"],
|
|
|
+ "delivery_fee" => $item["送货费"],
|
|
|
+ "initial_fee" => $item["起始计费"],
|
|
|
+ "initial_amount" => $item["起始计数"],
|
|
|
+ "rate" => $item["费率"],
|
|
|
+ "created_at" => $date,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ if (count($update) > 1){
|
|
|
+ app(BatchUpdateService::class)->batchUpdate("owner_price_logistic_details",$update);
|
|
|
+ LogService::log(__METHOD__,"物流计费导入修改",json_encode($update));
|
|
|
+ }
|
|
|
+ if (count($insert) > 0){
|
|
|
+ OwnerPriceLogisticDetail::query()->insert($insert);
|
|
|
+ LogService::log(__METHOD__,"物流计费导入录入",json_encode($insert));
|
|
|
+ }
|
|
|
+
|
|
|
+ $this->logistic->load(["details"=>function($query){$query->with(["province","unit","city"]);}]);
|
|
|
+ Cache::put("logistic",["success"=>true,"data"=>$this->logistic->details,"errors"=>$errors],86400);
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+}
|