baoshi-was/app/Services/OwnerService.php

<?php

namespace App\Services;

use App\OracleBasCustomer;
use App\Owner;
use Carbon\Carbon;
use Illuminate\Support\Facades\Auth;

Class OwnerService
{
    /*
     * array | string $column
     * 默认一些select字段,可传递string 或 array来指定select字段
     */
    public function getSelection($column = ['id', 'name'])
    {
        return Owner::filterAuthorities()->select($column)->get();
    }
    /**
     *同步WMS全部货主至WAS
     */
    public function syncOwnersData()
    {
        $basCustomers = OracleBasCustomer::query()
            ->select('CUSTOMERID', 'DESCR_C')
            ->where('DESCR_C', 'not like', '%换ERP%')
            ->where('DESCR_C', 'not like', '%退仓%')
            ->where('CUSTOMER_TYPE', 'OW')
            ->get();
        $ownerCount = Owner::count();
        if (count($basCustomers) == $ownerCount) return null;
        foreach ($basCustomers as $basCustomer) {
            $owner = Owner::where('code', $basCustomer['customerid'])->first();
            if (!isset($owner))
                Owner::query()->create([
                    'code' => $basCustomer['customerid'],
                    'name' => $basCustomer['descr_c'],
                    'created_at' => Carbon::now()->format('Y-m-d H:i:s'),
                ]);
        }
        $owners = Owner::query()->select('id', 'name')->get();
        return $owners;
    }

    public function first(array $params){
        $owner = Owner::query();
        foreach ($params as $column => $value){
            $owner->where($column, $value);
        }
        return $owner->first();
    }

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

    public function firstOrCreate(array $params, array $values = null){
        if (!$values) return Owner::query()->firstOrCreate($params);
        return Owner::query()->firstOrCreate($params,$values);
    }

    //  XXX 代码逻辑有待纠正
    public function 获取WMS订单列中对应的WAS货主列($WMSOrderHeaders)
    {
        $customerIds =  array_unique(data_get($WMSOrderHeaders, '*.customerid'));
        $owners = Owner::query()->whereIn('code', $customerIds)->get();
        $codes = data_get($owners, '*.code');
        $codeDiff = array_diff($customerIds, $codes);
        $logs = [];
        $errs = [];

        if (count($codes) > count($customerIds)) {
            $basCustomer = OracleBasCustomer::query()->whereIn('customerid', $codeDiff)->get();
            foreach ($basCustomer as $customer) {
                if($customer['descr_c'] ?? false && $customer['customerid'] && false){
                    try {
                        $owner = Owner::query()->create(['name' => $customer['descr_c'], 'code' => $customer['customerid']]);
                        $owners->push($owner);
                        array_push($logs, ['info' => '创建「' . json_encode($owner) . '」']);
                    } catch (\Exception $e) {
                        array_push($errs, ['info' => '创建「' . json_encode($errs) . '」']);
                    }
                }
            }
        }
        if(count($logs)>0)
            LogService::log(__METHOD__, __FUNCTION__, '批量创建客户「:' . json_encode($logs) . '」', Auth::user()['id']);
        if(count($errs)>0)
            LogService::log(__METHOD__, __FUNCTION__, '批量创建客户失败「:' . json_encode($errs) . '」', Auth::user()['id']);
        return $owners;
    }

    public function 获取订单跟踪的货主(){
        return Owner::query()->with('orderTrackingOwner')->whereHas('orderTrackingOwner',function($query){
            $query->where('status','启用');
        })->get();
    }

    public function getByWmsOrders($orderHeaders){
        $customerIds = array_unique(data_get($orderHeaders,'*.customerid'));
        $customerIds = array_diff($customerIds,[null,'','*']);
        $owners = Owner::query()->whereIn('code',data_get($orderHeaders,'*.customerid'))->get();

        if($owners->count() < $customerIds){
            $customerIds = array_diff($customerIds,data_get($owners,'*.code'));
            $owner_list = $this->createByWmsCustomerIds($customerIds);
            $owners->concat($owner_list);
        }
        return $owners;
    }

    public function createByWmsCustomerIds($codes){
        if(!$codes) {return [];}
        $basCustomer = OracleBasCustomer::query()
            ->where('Customer_Type','OW')
            ->whereIn('CustomerID', $codes)
            ->get();

        $insert_params = [];
        $created_at = Carbon::now()->format('Y-m-d H:i:s');
        foreach ($basCustomer as $item) {
            $insert_params[] = [
                'code' => $item->customerid,
                'name' => $item->descr_c,
                'created_at' => $created_at,
            ];
        }

        try {
            if (count($insert_params) > 0) {
                $this->insert($insert_params);
                LogService::log(__METHOD__, __FUNCTION__, '批量创建 owner error' . count($insert_params) . json_encode($insert_params) );
            }
        } catch (\Exception $e) {
            LogService::log(__METHOD__, __FUNCTION__, '批量创建 owner error' . json_encode($insert_params) . '||' . $e->getMessage() . '||' . $e->getTraceAsString());
        } finally {
            return Owner::query()->whereIn('code', $codes)->get();
        }
    }

    public function insert($fillables){
        return Owner::query()->insert($fillables);
    }



    public function getAuthorizedOwners(){
        $user = Auth::user();
        return Owner::query()->whereIn('id',$user->getPermittingOwnerIdsAttribute()??[])->get();
    }

}