baoshi-was/app/Services/CommodityService.php

<?php

namespace App\Services;

use App\Commodity;
use App\Http\Controllers\Controller;
use App\OracleBasSKU;
use App\Owner;
use Illuminate\Support\Facades\Auth;
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 = [];
        foreach ($orderHeaders as $orderHeader) {
            array_push($customerIDs,$orderHeader['customerid']);
            $oracleDOCOrderDetails = $orderHeader['oracleDOCOrderDetails'] ?? [];
            foreach ($oracleDOCOrderDetails as $detail) {
                array_push($skus,$detail['sku']);
            }
        }
        $skus = array_unique($skus);
        $customerIDs = array_unique($customerIDs);
        $owners = Owner::query()->whereIn('code',$customerIDs)->get();
        $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) {
                $owner = $owners->where('code',$baseSKU['customerid'])->first();
                $fillable = [
                    'name' => $baseSKU['descr_c'],
                    'sku' => $baseSKU['sku'],
                    'owner_id' => $owner['id'] ?? '',
                    'length' => $baseSKU['skulength'] ?? '',
                    'width' => $baseSKU['skuwidth'] ?? '',
                    'height' => $baseSKU['skuhigh'] ?? '',
                    'volumn' => $baseSKU['cube'],
                ];
                try {
                    Commodity::query()->create($fillable);
                    array_push($logs,json_encode($fillable));
                    LogService::log(__METHOD__,__FUNCTION__,'添加商品信息'.json_encode($fillable));
                } catch (\Exception $e) {
                    array_push($errs,json_encode($fillable).$e->getMessage().$e->getTraceAsString());
                }
            }
        }
        if(count($logs)>0)
            LogService::log(__METHOD__,__FUNCTION__,'添加商品信息'.json_encode($logs));
        if(count($errs)>0)
            LogService::log(__METHOD__,__FUNCTION__,'添加商品信息'.json_encode($errs));
        return Commodity::query()->with('owner')->whereIn('sku',$skus)->get();
    }

    public function syncCommodityAttribute($noAttributeCommodity){
        $logs = [];$errs = [];

        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 = [
                    'length' => $BasSKU['SKULength'],
                    'width' => $BasSKU['SKUWidth'],
                    'height' => $BasSKU['SKUHigh'],
                    'volumn' => $BasSKU['Cube'],
                ];
                try {
                    $commodity->update($update);
                    array_push($logs,['info' =>  '商品修改「' . json_encode($commodity->toArray()) . '」']);
                } catch (\Exception $e) {
                    array_push($errs,['info' =>  '商品修改异常「' . json_encode($e) . '」']);
                }
            }
        }

        $user =  Auth::user();
        if(count($logs) > 0)
            Controller::logS(__METHOD__,__FUNCTION__,'批量修改商品「' . json_encode($logs) . '」'.$user['id']);
        if(count($errs) > 0)
            Controller::logS(__METHOD__,__FUNCTION__,'批量修改商品异常「' . json_encode($errs) . '」'.$user['id']);
    }

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