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

<?php

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

use App\Http\Controllers\Controller;
use App\RejectedBillItem;
use App\Store;
use App\WMSReflectReceive;
use App\WMSReflectReceiveSku;
use Zttp\Zttp;

class StoreController extends Controller
{

    /**
     * 入库回传给WMS
     * @param Store $store
     * @return bool
     */
    public function accomplishToWMS(Store $store)
    {
        $wmsReceiveds=WMSReflectReceive::where('ASNNO',$store['asn_code'])->get();
        if($wmsReceiveds->isEmpty()){
            (new Controller())->log(__METHOD__,'error_'.__FUNCTION__,'没有本地WMS入库单');
            return false;
        }
        $success=true;
        $wmsReceiveds->each(function ($wmsReceived)use(&$store,&$amountsItem,&$success){

            $wmsSkus=$wmsReceived->skus()->get();
            $orderNumberCode=$wmsReceived['ASNREFERENCE1']??$store['order_number'];
            $amountsSku=(function()use($wmsSkus){
                $result=[];
                $wmsSkus->each(function($sku)use(&$result){
                    $result[$sku['id']]= $sku['EXPECTEDQTY_EACH'];
                });
                return $result;
            })();
            $skuStrList=[];
            $customerCode=$store->owner()->first()['code'];
            $wmsSkus->each(function(WMSReflectReceiveSku $sku)use(&$skuList,&$amountsItem,&$amountsSku,&$skuStrList,$wmsReceived,$customerCode) {
//                    $STATUS=$item['id_quality_label']==1?'ZP':'CC';
                $STATUS = 'ZP';
//                    $STATUS_code=$item['id_quality_label']==1?'01':'02';
                $STATUS_code = '01';
                $skuStr = "
                        {
                            \"ORDERNUMBERCODE\": \"{$wmsReceived['ASNNO']}\",
                            \"ASNLINENO\": \"{$sku['ASNLINENO']}\",
                            \"SKUCODE\": \"{$sku['SKU']}\",
                            \"QUANTITY\": \"{$sku['EXPECTEDQTY_EACH']}\",
                            \"LOTATT04\": \"{$sku['LOTATT04']}\",
                            \"LOTATT05\": \"{$sku['LOTATT05']}\",
                            \"STATUS\": \"{$STATUS}\",
                            \"USERDEFINE1\": \"{$customerCode}{$STATUS_code}\",
                            \"USERDEFINE2\": \"\",
                            \"USERDEFINE3\": \"\",
                            \"UNIQUE_CODE_LIST\": [" .
//                                {
//                                    \"ORDERNUMBERCODE\": \"{$wmsReceived['ASNNO']}\",
//                                    \"SKUCODE\": \"{$sku['SKU']}\",
//                                    \"STATUS\": \"{$STATUS}\",
//                                    \"PRODUCTION DATE\": \"{$item['made_at']}\",
//                                    \"EXPIRATION DATE\": \"{$item['validity_at']}\",
//                                    \"LOTATT05\": \"{$sku['LOTATT05']}\",
//                                    \"UNIQUE_CODE\": \"\"
//                                }
                    "]
                        }
                    ";
                $skuStrList[] = $skuStr;
            });
            $skuStrList = implode(',',$skuStrList);
            $json="
                {
                    \"request\": [
                        {
                            \"ORDERNUMBERCODE\": \"{$wmsReceived['ASNNO']}\",
                            \"CUSTOMERID\": \"{$wmsReceived['CUSTOMERID']}\",
                            \"ASNTYPE\": \"{$wmsReceived['ASNTYPE']}\",
                            \"ASNREFERENCE1\": \"{$wmsReceived['ASNREFERENCE1']}\",
                            \"ADDWHO\": \"WCS\",
                            \"USERDEFINE1\": \"\",
                            \"USERDEFINE2\": \"\",
                            \"USERDEFINE3\": \"\",
                            \"SKU_LIST\": [{$skuStrList}]
                        }
                    ]
                }
        ";

            $sendingJson = json_decode($json,true);
            $url=url(config('api.flux.receive.new'));
            $response = Zttp::post($url, $sendingJson);
            $noIssues=true;
            $json = $response->json();
            (new Controller())->log(__METHOD__,__FUNCTION__,$response->body());
            if(!$json||!isset($json['Response'])||!$json['Response']['return']['returnFlag']=='1'){
                $noIssues=false;
            }
            if($json&&isset($json['Response'])){
                if($json['Response']['return']['returnFlag']=='2'){
                    (new Controller())->log(__METHOD__,'error_'.__FUNCTION__,$response->body());
                    return true;
                }
                if(isset($json['Response']['return']['returnDesc'])&&strpos($json['Response']['return']['returnDesc'],'唯一约束')!==false){
                    (new Controller())->log(__METHOD__,'error_'.__FUNCTION__,$response->body());
                    return true;
                }
                if(isset($json['Response']['return']['errordescr'])&&strpos($json['Response']['return']['errordescr'],'已完成')!==false){
                    (new Controller())->log(__METHOD__,'error_'.__FUNCTION__,$response->body());
                    return true;
                }
            }
            if($noIssues&&$json['Response']['return']['returnFlag']=='1'){
                $wmsReceived['is_uploaded']=1;
                $wmsReceived->save();
                (new Controller())->log(__METHOD__, 'success_' . __FUNCTION__, $response->body() );
                return true;
            }else {
                $success = false;
                (new Controller())->log(__METHOD__, 'error_' . __FUNCTION__, $response->body());
            }
        });


        return $success;
    }

}