baoshi-was/app/Services/CommodityService.php

<?php

namespace App\Services;

use App\Commodity;
use App\OracleBasSKU;
use App\Owner;
use App\Services\common\BatchUpdateService;
use Carbon\Carbon;
use Illuminate\Database\Eloquent\Builder;

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 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);
    }

    /* 根据货主条形码查找商品 */
    private function ownerBarcodeSeekCommodityQuery(Builder $query, array $ownerParam, $barcode){
        $query->whereHas('owner',function ($builder)use($ownerParam){
            foreach ($ownerParam as $column => $param){
                $builder->where($column, $param);
            }
        });
        $query->whereHas('barcodes',function ($builder)use($barcode){
            if (is_array($barcode))$builder->whereIn('code',$barcode);
            else $builder->where('code',$barcode);
        });
        return $query;
    }
    public function ownerBarcodeSeekCommodityFirst(array $ownerParam, $barcode){
        $commodity = Commodity::query();
        $commodity = $this->ownerBarcodeSeekCommodityQuery($commodity, $ownerParam, $barcode);
        return $commodity->first();
    }
    public function ownerBarcodeSeekCommodityGet(array $ownerParam, $barcode, $isNullSku = false){
        $commodities = Commodity::query()->with('barcodes');
        if ($isNullSku)$commodities->whereNull('sku');
        $commodities = $this->ownerBarcodeSeekCommodityQuery($commodities, $ownerParam, $barcode);
        return $commodities->get();
    }

    /* 通过货主代码与条形码寻找FLUX商品补充至WMS */
    public function ownerAndBarcodeFirstOrCreate(Owner $owner,$barcode){
        $wmsCommodity = app('oracleBasSkuService')->first(['customerid'=>$owner->code, 'barcode'=>$barcode]);
        if (!$wmsCommodity) return null;

        $commodity = $this->firstOrCreate(['owner_id'=>$owner->id, 'sku'=>$wmsCommodity->sku],[
            "name" => $wmsCommodity->descr_c,
            "sku" => $wmsCommodity->sku,
            "owner_id" => $owner->id,
            "length" => $wmsCommodity->skulength,
            "width" => $wmsCommodity->skuwidth,
            "height" => $wmsCommodity->skuhigh,
            "volumn" => $wmsCommodity->cube,
        ]);
        if ($wmsCommodity->alternate_sku1)app('commodityBarcodeService')->first([
            'commodity_id' => $commodity->id,
            'code' => $wmsCommodity->alternate_sku1,
        ]);
        if ($wmsCommodity->alternate_sku2)app('commodityBarcodeService')->first([
            'commodity_id' => $commodity->id,
            'code' => $wmsCommodity->alternate_sku2,
        ]);
        return $commodity;
    }

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

    public function getByWmsOrders($orderHeaders){
        if(!$orderHeaders) return null;
        $customerId_sku_map = [];
        foreach ($orderHeaders as $orderHeader) {
            $oracleDOCOrderDetails=  $orderHeader->oracleDOCOrderDetails;
            foreach ($oracleDOCOrderDetails as $oracleDOCOrderDetail) {
                $value = [
                    'owner_code' => $oracleDOCOrderDetail->customerid,
                    'sku'=> $oracleDOCOrderDetail->sku
                ];
                if(!in_array($value,$customerId_sku_map)){
                    $customerId_sku_map[] = $value;
                }
            }
        }

        $owner_codes = array_diff(array_unique(data_get($customerId_sku_map,'*.owner_code')),['','*',null]) ;
        if(!$owner_codes) return null;

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

        $owners_code_map = [];
        $owners_id_map = [];
        foreach ($owners as $owner) {
            $owners_code_map[$owner->code] = $owner;
            $owners_id_map[$owner->id] = $owner;
        }
        $orderHeader_sku = array_diff(array_unique(data_get($customerId_sku_map,'*.sku')),['','*',null]) ;
        $commodities = Commodity::query()
            ->whereIn('owner_id',data_get($owners,'*.id'))
            ->whereIn('sku',$orderHeader_sku)
            ->groupBy('owner_id','sku')  //*!!!!!!!!
            ->get();

        if($commodities->count() < count($customerId_sku_map)){
            $commoditiesInWAS索引_sku = [];
            foreach ($commodities as $commodityInWms) {
                $owner = $owners_id_map[$commodityInWms->owner_id] ?? '';
                if(!$owner)continue;
                $key ='owner_cod='.$owner['code'].' sku='.$commodityInWms->sku;
                $commoditiesInWAS索引_sku[$key]=$commodityInWms;
            }
            $commodities需要新增=[];
            foreach ($customerId_sku_map as $commodityInWms) {
                $key ='owner_cod='.$commodityInWms['owner_code'].' sku='.$commodityInWms['sku'];
                if($commoditiesInWAS索引_sku[$key] ?? false) continue;
                $commodities需要新增[$key] = $commodityInWms;
            }
            $commodity_set = $this->createCommodities($commodities需要新增,$owners_code_map);
            $commodities = $commodities->concat($commodity_set);
        }
        return  $commodities;
    }

    public function createCommodities($params,$owners_code_map)
    {
        if(!$params) return [];
        $bas_sku_arr = OracleBasSKU::query()
            ->whereIn('CustomerID',data_get($params,'*.owner_code'))
            ->whereIn('Sku',data_get($params,'*.sku'))
            ->get();
        $insert_params = [];

        foreach ($bas_sku_arr as $bas_sku) {
            $owner = $owners_code_map[$bas_sku->customerid] ?? '';
            if(!$owner)continue;
            $created_at = Carbon::now()->format('Y-m-d H:i:s');
            $insert_params[] = [
                'owner_id' => $owner->id,
                'sku' => $bas_sku->sku,
                'name' =>$bas_sku->descr_c,
                'created_at' => $created_at,
                'length' =>$bas_sku->skulength,
                'width' => $bas_sku->skuwidth,
                'height' => $bas_sku->skuhigh,
                'volumn' => $bas_sku->cube
            ];
        }

        if(count($insert_params) > 0){
            try {
                $this->insert($insert_params);
                LogService::log(__METHOD__,__FUNCTION__,'批量添加 commodity ' . count($insert_params) .json_encode($insert_params) );
            } catch (\Exception $e) {
                LogService::log(__METHOD__,__FUNCTION__,'批量添加 commodity error' .json_encode($insert_params) ."||".$e->getMessage().'||'.$e->getTraceAsString());
            }
        }
        return Commodity::query()
            ->whereIn('owner_id',data_get($owners_code_map,'*.id'))
            ->whereIn('sku',data_get($params,'*.sku'))
            ->get();
    }
}