baoshi-was/app/Imports/ExpressImport.php

<?php

namespace App\Imports;

use App\OwnerPriceExpress;
use App\OwnerPriceExpressProvince;
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\Concerns\WithMultipleSheets;
use Maatwebsite\Excel\Imports\HeadingRowFormatter;

HeadingRowFormatter::default('none');
class ExpressImport implements ToCollection,WithHeadingRow,WithMultipleSheets
{

    public function sheets(): array
    {
        return [
            0 => $this,
        ];
    }

    protected $express;
    public function __construct(OwnerPriceExpress $express = null)
    {
        $this->express = $express;
    }

    /**
    * @param Collection $collection
    * @return bool
    */
    public function collection(Collection $collection)
    {
        $row = $collection->first();
        $header = [
            "省","首重价格","续重价格"
        ];
        foreach ($header as $str){
            if (!isset($row[$str])){
                Cache::put("express",["success"=>false, "data"=>"表头不存在“".$str."”"],86400);
                return false;
            }
        }

        //省份map
        $map = [];
        $provinces = Province::query()->get();
        foreach ($provinces as $province){
            $map[mb_substr($province->name,0,2)] = $province->id;
        }

        if (!$this->express){
            return $this->readonly($collection,$map);
        }

        //已存在的计费
        $existDetails = [];
        foreach ($this->express->details as $detail){
            $existDetails[$detail->province_id] = $detail->id;
        }

        //导入的数据整理，存在更新
        $id = $this->express->id;
        $errors = [];
        $insert = [];
        $update = [["id","initial_weight_price","additional_weight_price","updated_at"]];
        $date = date('Y-m-d H:i:s');
        foreach ($collection as $index => $item){
            $province = mb_substr($item["省"],0,2);
            if (!isset($map[$province])){
                $errors[] = "第“".($index+2)."”行未知省份";
                continue;
            }
            if (!is_numeric($item["首重价格"]) || $item["首重价格"] <= 0){
                $errors[] = "第“".($index+2)."”行非法首重价格";
                continue;
            }
            if (!is_numeric($item["续重价格"]) || $item["续重价格"] <= 0){
                $errors[] = "第“".($index+2)."”行非法续重价格";
                continue;
            }
            if (isset($existDetails[$map[$province]])){
                $update[] = [
                    "id" => $existDetails[$map[$province]],
                    "initial_weight_price" => $item["首重价格"],
                    "additional_weight_price" => $item["续重价格"],
                    "updated_at" => $date,
                ];
                continue;
            }
            $insert[] = [
                "owner_price_express_id" => $id,
                "province_id" => $map[$province],
                "initial_weight_price" => $item["首重价格"],
                "additional_weight_price" => $item["续重价格"],
                "created_at" => $date,
            ];
        }
        if (count($update) > 1){
            app(BatchUpdateService::class)->batchUpdate("owner_price_express_provinces",$update);
            LogService::log(__METHOD__,"快递计费导入修改",json_encode($update));
        }
        if (count($insert) > 0){
            OwnerPriceExpressProvince::query()->insert($insert);
            LogService::log(__METHOD__,"快递计费导入录入",json_encode($insert));
        }

        $this->express->load(["details"=>function($query){$query->with("province");}]);
        Cache::put("express",["success"=>true,"data"=>$this->express->details,"errors"=>$errors],86400);
        return true;
    }

    private function readonly(Collection $collection, array $map)
    {
        $errors = [];
        $data = [];
        foreach ($collection as $index => $item){
            $province = mb_substr($item["省"],0,2);
            if (!isset($map[$province])){
                $errors[] = "第“".($index+2)."”行未知省份";
                continue;
            }
            if (!is_numeric($item["首重价格"]) || $item["首重价格"] <= 0){
                $errors[] = "第“".($index+2)."”行非法首重价格";
                continue;
            }
            if (!is_numeric($item["续重价格"]) || $item["续重价格"] <= 0){
                $errors[] = "第“".($index+2)."”行非法续重价格";
                continue;
            }
            $data[] = [
                "province_id" => $map[$province],
                "initial_weight_price" => $item["首重价格"],
                "additional_weight_price" => $item["续重价格"],
            ];
        }
        Cache::put("express",["success"=>true,"data"=>$data,"errors"=>$errors],86400);
        return true;
    }
}