baoshi-was/app/Http/Controllers/api/thirdPart/flux/PackageController.php

<?php

namespace App\Http\Controllers\Api\thirdPart\flux;

use App\Http\Controllers\Controller;
use App\Jobs\WeightQueue;
use App\Logistic;
use App\Owner;
use App\Package;
use App\WMSReflectPackage;
use Carbon\Carbon;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Validator;
use Zttp\Zttp;

class PackageController extends Controller
{

    public function new_(Request $request)
    {
        $receiveInputs=$request->all();
        $errors=$this->validatorForNew($receiveInputs)->errors();
        if(count($errors)>0){
            return ['response'=>['flag'=>'W','message'=>'fields wrong, see Errors report please.',
                'errors'=>$errors]];
        }
        $package=Package::where('logistic_number',$receiveInputs['SOReference5'])->first();
        $owner=Owner::select('id')->where('name',$receiveInputs['Customer'])->first();
        $carrier=Logistic::select('id')->where('name',$receiveInputs['CarrierID'])->first();
        if ($package){
            $package->delivery_number=$receiveInputs['palletid'];
            if ($owner){
                $package->owner_id=$owner->id;
                $packagePaperBox=new Package();
                $paperBox_id=$packagePaperBox->checkPaperBox($package->length,$package->width,$package->height,$owner->id);
                $package->paperBox_id=$paperBox_id;
            }else{
                $package->status='记录异常';
            }
            $package->recipient=$receiveInputs['Consigneename'];
            if ($carrier)$package->logistic_id=$carrier->id;
            else $package->status='记录异常';
            $package->batch_number=$receiveInputs['USERDEFINE1'];
            $package->batch_rule=$receiveInputs['USERDEFINE2'];
            if ($owner&&$carrier){
                $result=$this->accomplishToWMS($package);
                if ($result['result']=='success'){
                    $package->status="已上传";
                }else{
                    $package->status="上传异常";
                }
            }else{
                $this->log(__METHOD__,'fluxPackageApi(no owner or carrier)'.__FUNCTION__,json_encode($request->all()),null);
            }
            $package->save();
            $this->log(__METHOD__,'fluxPackageApi'.__FUNCTION__,json_encode($request->all()),null);
        }else{
            $receive = new WMSReflectPackage($receiveInputs);
            $receive->save();
            if (isset($owner->id)&&isset($carrier->id)){
                $createPackage = new Package([
                    'logistic_number'=>$receiveInputs['SOReference5'],
                    'delivery_number'=>$receiveInputs['palletid'],
                    'recipient'=>$receiveInputs['Consigneename'],
                    'owner_id'=>$owner->id,
                    'logistic_id'=>$carrier->id,
                    'batch_number'=>$receiveInputs['USERDEFINE1'],
                    'batch_rule'=>$receiveInputs['USERDEFINE2'],
                    'status'=>'未测量'
                ]);
            }else{
                $this->log(__METHOD__,'fluxPackageApi(no owner or carrier)'.__FUNCTION__,json_encode($request->all()),null);
                $createPackage = new Package([
                    'logistic_number'=>$receiveInputs['SOReference5'],
                    'delivery_number'=>$receiveInputs['palletid'],
                    'recipient'=>$receiveInputs['Consigneename'],
                    'batch_number'=>$receiveInputs['USERDEFINE1'],
                    'batch_rule'=>$receiveInputs['USERDEFINE2'],
                    'status'=>'记录异常'
                ]);
            }
            if ($createPackage->save())WeightQueue::dispatch($createPackage)->delay(Carbon::now()->addMinutes(1440));
            $this->log(__METHOD__,'fluxPackageApi'.__FUNCTION__,json_encode($request->all()),null);
        }
        return response()->json(['response'=>['flag'=>'Y','code'=>'0000','message'=>'正确接收']])
            ->setEncodingOptions(JSON_UNESCAPED_UNICODE);
    }

    protected function validatorForNew(array $data)
    {
        return Validator::make($data, [
            'TASKID' => ['required', 'string', 'max:191'],
            'Orderno' => ['required', 'string', 'max:191'],
            'palletid' => ['required', 'string', 'max:191'],
            'SOReference5' => ['required', 'string', 'max:191'],
            'Customer' => ['nullable', 'string', 'max:191'],
            'Consigneename' => ['nullable', 'string', 'max:191'],
            'CarrierID' => ['nullable', 'string', 'max:191'],
            'USERDEFINE1' => ['nullable', 'string', 'max:191'],
            'USERDEFINE2' => ['nullable', 'string', 'max:191'],
            'USERDEFINE3' => ['nullable', 'string', 'max:191'],
        ],[],[]);
    }
    /**
     * 完成的包裹称量发送给WMS
     */
    public function accomplishToWMS(Package $package)
    {
        $json=["TASKID"=>$package->WMSReflectPackage_name,
                'SOReference5'=>$package->logistic_number,
                'Weigh'=>$package->weigh,
                'Addwho'=>'',
                'Addtime'=>Carbon::now(),
                'Package'=>$package->paperBox_name,
                'USERDEFINE1'=>'',
                'USERDEFINE2'=>'',
                'USERDEFINE3'=>'',
            ];
        $json=json_encode($json);
        $url=url(config('api.accomplishToWMS_flux'));
        $response = Zttp::post($url, $json);
        $noIssues=true;
        $json = json_encode($response->body());
        if(!$json||!isset($json['response'])||!$json['response']['flag']=='Y'){
            $noIssues=false;
        }
        if($noIssues&&$json['response']['flag']=='Y'){
            $this->log(__METHOD__,'fluxAccomplishToWMSApi'.__FUNCTION__,json_encode($package),null);
            return ['result'=>'success'];
        }
        $this->log(__METHOD__,'fluxAccomplishToWMSApi(ERROR)'.__FUNCTION__,json_encode($package),null);
        return ['result'=>'false'];
    }


}