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

<?php

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

use App\Batch;
use App\Http\Controllers\Controller;
use App\Order;
use App\OrderBarcode;
use App\SkuNew;
use App\WMSReflectPackage;
use App\WMSReflectReceive;
use App\WMSReflectReceiveSku;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Validator;
use Zttp\Zttp;

class PackageController extends Controller
{

    public function new_(Request $request)
    {
        $errors=$this->validatorForNew($request->all())->errors();
        if(count($errors)>0){
            return ['response'=>['flag'=>'W','message'=>'fields wrong, see Errors report please.',
                'errors'=>$errors]];
        }
        $receiveInputs=$request->input('request');
        $receive = new WMSReflectPackage($receiveInputs);
        $receive->save();
        return response()->json(['response'=>['flag'=>'Y','code'=>'0000','message'=>'正确接收']])
            ->setEncodingOptions(JSON_UNESCAPED_UNICODE);
    }

    protected function validatorForNew(array $data)
    {
        return Validator::make($data, [
            'request' => ['required', 'array', 'min:1'],
            'request.TASKID' => ['required', 'string', 'max:191'],
            'request.Orderno' => ['required', 'string', 'max:191'],
            'request.palletid' => ['required', 'string', 'max:191'],
            'request.SOReference5' => ['required', 'string', 'max:191'],
            'request.Customer' => ['nullable', 'string', 'max:191'],
            'request.Consigneename' => ['nullable', 'string', 'max:191'],
            'request.CarrierID' => ['nullable', 'string', 'max:191'],
            'request.USERDEFINE1' => ['nullable', 'string', 'max:191'],
            'request.USERDEFINE2' => ['nullable', 'string', 'max:191'],
            'request.USERDEFINE3' => ['nullable', 'string', 'max:191'],
        ],[],[
            'request.TASKID' => 'TASKID',
            'request.USERDEFINE1' => 'USERDEFINE1',
            'request.USERDEFINE2' => 'USERDEFINE2',
            'request.USERDEFINE3' => 'USERDEFINE3',
        ]);
    }
    /**
     * 完成的包裹称量发送给WMS
     */
    public function accomplishToWMS()
    {
        $json='
{
    "request":
        {
            "TASKID": "TS000001",
            "SOReference5": "806086633425772945",
            "Weigh": "50",
            "Package": "bz0987651234",
            "USERDEFINE1": "",
            "USERDEFINE2": "",
            "USERDEFINE3": "",
        }
}
        ';
        $json = json_decode($json,true);
        $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'){
            return ['result'=>'success'];
        }
        return $this->apiError(__METHOD__,$response->body());
    }


}