baoshi-was/app/Services/CommodityService.php

<?php

namespace App\Services;

use App\Commodity;
use App\OracleBasSKU;
use App\Owner;
use App\Services\common\BatchUpdateService;

Class CommodityService
{
    public function firstOrCreate($param,$column = null){
        if ($column) return Commodity::query()->firstOrCreate($param,$column);
        return Commodity::query()->firstOrCreate($param);
    }
    public function updateOrCreate($param,$column = null){
        if ($column) return Commodity::query()->updateOrCreate($param,$column);
        return Commodity::query()->updateOrCreate($param);
    }

    public function get(array $params){
        $query = Commodity::query();
        if ($params["owner_id"] ?? false){
            $query->where("owner_id", $params["owner_id"]);
        }
        if ($params["sku"] ?? false){
            if (!is_array($params["sku"]))$params["sku"] = [$params["sku"]];
            $query->whereIn('sku', $params["sku"]);
        }
        return $query->get();
    }

    public function insert(array $params){
        return Commodity::query()->insert($params);
    }

    public function getWASCommoditiesByWMSOrderHeaders($orderHeaders)
    {
        $skus = [];
        $customerIDs = [];
        $logs = [];
        $errs = [];
        $fillables = [];
        $owners_list = [];

        foreach ($orderHeaders as $orderHeader) {
            $customerIDs[] = $orderHeader['customerid'];
            $oracleDOCOrderDetails = $orderHeader['oracleDOCOrderDetails'] ?? [];
            foreach ($oracleDOCOrderDetails as $detail) {
                $skus[] = $detail['sku'];
            }
        }
        $skus = array_unique($skus);
        $customerIDs = array_unique($customerIDs);

        $owners = Owner::query()->whereIn('code',$customerIDs)->get();

        foreach ($owners as $owner) {
            $key = 'code='.$owner->code;
            $owners_list[$key] = $owner;
        }

        $commodities = Commodity::query()->with('owner')->whereIn('sku',$skus)->get();

        if(count($skus) > $commodities->count()){ //需要更新
            $commoditiesSku = data_get($commodities,'*.sku');
            $diffSku = array_diff($skus,$commoditiesSku);
            $baseSKUs = OracleBasSKU::query()->whereIn('sku',$diffSku)->whereIn('CustomerID',$customerIDs)->get();
            foreach ($baseSKUs as $baseSKU) {
                $key = 'code='.$baseSKU['customerid'];
                $owner = $owners_list[$key] ?? '';
                $fillables[] = [
                    'name' => $baseSKU['descr_c'],
                    'sku' => $baseSKU['sku'],
                    'owner_id' => $owner['id'] ?? '',
                    'length' => $baseSKU['skulength'] ?? '',
                    'width' => $baseSKU['skuwidth'] ?? '',
                    'height' => $baseSKU['skuhigh'] ?? '',
                    'volumn' => $baseSKU['cube'],
                ];
            }
        }
        try {
            if(count($fillables) > 0){
                Commodity::query()->create($fillables);
                LogService::log(__METHOD__,__FUNCTION__,'添加商品信息'.json_encode($fillables));
            }
        } catch (\Exception $e) {
            array_push($errs,json_encode($fillables).$e->getMessage().$e->getTraceAsString());
        }
        unset($customerIDs,$logs,$errs,$fillables);
        return Commodity::query()->with('owner')->whereIn('sku',$skus)->get();
    }

    public function syncCommodityAttribute($noAttributeCommodity){
        /** @var BatchUpdateService $batchUpdateService */
        $batchUpdateService = app('batchUpdateService');
        $multipleData = [];
        $multipleData[] = ['id','length','width','height','volumn'];

        $noAttributeCommodity = array_unique($noAttributeCommodity);
        if(count($noAttributeCommodity) > 1){
            $SkuCode = data_get($noAttributeCommodity,'*.sku');
            $BasSKUs = OracleBasSKU::query()->whereIn('sku',$SkuCode)->get();
            foreach ($noAttributeCommodity as $commodity){
                $BasSKU = $BasSKUs
                    ->where('sku',$commodity['code'])
                    ->where('CustomerID',$commodity['owner']['code'])
                    ->first();
                $update = [
                    'id' => $commodity['id'],
                    'length' =>  $BasSKU['skulength'] ?? 0,
                    'width' => $BasSKU['skuwidth'] ?? 0,
                    'height' => $BasSKU['skuhigh'] ?? 0,
                    'volumn' => $BasSKU['cube'] ?? 0,
                ];
                if($commodity['length'] !==$update['length'] ||$commodity['width'] !==$update['width'] ||$commodity['height'] !==$update['height'] ||$commodity['volumn'] !==$update['volumn'] ){
                    $multipleData[] = $update;
                }
            }
        }
        if(count($multipleData) > 1){
            try {
                $tableName = 'commodities';
                $batchUpdateService->batchUpdate($tableName, $multipleData);
                LogService::log(__METHOD__,__FUNCTION__,'批量更新'.count($multipleData).json_encode($multipleData));
            } catch (\Exception $e) {
                LogService::log(__METHOD__,__FUNCTION__,'批量更新失败'.json_encode($multipleData).$e->getMessage(),$e->getTraceAsString());
            } finally {
                unset($multipleData);
            }
        }
    }

    public function 根据sku和货主同步商品信息($sku,$owner)
    {
        try {
            $basSku = OracleBasSKU::query()->where('sku', $sku)->where('CustomerID', $owner['code'])->first();
            $commodity = Commodity::query()->where('sku', $sku)->where('owner_id', $owner['id'])->first();
            $syncInfo = [
                'name' => $basSku['descr_c'],
                'sku' => $sku,
                'owner_id' => $owner['id'],
                'length' => $basSku['skulength'],
                'width' => $basSku['skuwidth'],
                'height' => $basSku['skuhigh'],
                'volumn' => $basSku['cube'],
            ];
            if ($commodity) {
                $commodity->update($syncInfo);
            } else {
                $commodity = Commodity::query()->create($syncInfo);
            }
        } catch (\Exception $e) {
            $log = ['info'=>'根据sku和货主同步商品信息','mesaage'=>$e->getMessage(),'trace'=>$e->getTraceAsString()];
            LogService::log(__METHOD__,__FUNCTION__,json_encode($log));
        } finally {
            return $commodity ?? null;
        }
    }


    public function getOwnerCommodities(array $params){
        $query = Commodity::query();
        foreach ($params as $column => $value){
            if (!is_array($value)){
                $value = [$value];
            }
            $query->whereIn($column,$value);
        }
        return $query->get();
    }

    public function batchUpdate(array $params){
        return app(BatchUpdateService::class)->batchUpdate('commodities', $params);
    }
}