|
|
@@ -5,6 +5,8 @@ namespace App\Http\Controllers\Api\thirdPart\flux;
|
|
|
use App\Http\Controllers\Controller;
|
|
|
use App\Jobs\MarkPackageExcepted;
|
|
|
use App\Logistic;
|
|
|
+use App\OracleDOCOrderHeader;
|
|
|
+use App\OracleDOCWaveHeader;
|
|
|
use App\Owner;
|
|
|
use App\Package;
|
|
|
use App\WMSReflectPackage;
|
|
|
@@ -142,7 +144,7 @@ class PackageController extends Controller
|
|
|
{
|
|
|
return Validator::make($data, [
|
|
|
'request.TASKID' => ['required', 'string', 'max:191'],
|
|
|
- 'request.Orderno' => ['required', 'string', 'max:191'],
|
|
|
+ 'request.Orderno' => ['nullable', 'string', 'max:191'],
|
|
|
'request.palletid' => ['required', 'string', 'max:191'],
|
|
|
'request.SOReference5' => ['required', 'string', 'max:191'],
|
|
|
'request.Customer' => ['nullable', 'string', 'max:191'],
|
|
|
@@ -170,43 +172,59 @@ class PackageController extends Controller
|
|
|
public function accomplishToWMS(Package $package)
|
|
|
{
|
|
|
try{
|
|
|
-
|
|
|
if($package['status']=='已上传'&&strstr($package['batch_rule'],'组合')){
|
|
|
if(isset($package['forceUpload'])&&$package['forceUpload']!=true){
|
|
|
- $this->log(__METHOD__,'跳过_'.__FUNCTION__,'未实际上传,之前有上传成功且无变动:'.json_encode($package),null);
|
|
|
- return ['result'=>'success'];
|
|
|
+ $this->log(__METHOD__,'跳过1_'.__FUNCTION__,'未实际上传,之前有上传成功且无变动:'.json_encode($package),null);
|
|
|
+// return ['result'=>'success']; //不写WMS接口则不需要中断
|
|
|
}
|
|
|
}
|
|
|
- $json=["request"=>['TASKID'=>$package->WMSReflectPackage_name,
|
|
|
- 'SOReference5'=>$package->logistic_number,
|
|
|
- 'Weigh'=>$package->weight,
|
|
|
- 'Addwho'=>'',
|
|
|
- 'Addtime'=>Carbon::now(),
|
|
|
- 'Package'=>$package->paperBox_name,
|
|
|
- 'USERDEFINE1'=>$package->batch_number,
|
|
|
- 'USERDEFINE2'=>$package->batch_rule,
|
|
|
- 'USERDEFINE3'=>'OK',
|
|
|
- ]];
|
|
|
- $json=json_encode($json);
|
|
|
- $url=url(config('api.flux.package.new'));
|
|
|
- $response = Zttp::post($url, json_decode($json));
|
|
|
- $this->log(__METHOD__,'Sign'.__FUNCTION__,json_encode($response->json()),null);
|
|
|
- $response=$response->json();
|
|
|
- $noIssues=true;
|
|
|
- if(!$response||!isset($response['response'])||!$response['response']['flag']=='Y'){
|
|
|
- $noIssues=false;
|
|
|
- }
|
|
|
- if($noIssues&&$response['response']['flag']=='Y'){
|
|
|
- $this->log(__METHOD__,'SUCCESS_'.__FUNCTION__,json_encode($json).'| response: '.json_encode($response),null);
|
|
|
- return ['result'=>'success'];
|
|
|
- }
|
|
|
- $this->log(__METHOD__,'ERROR_'.__FUNCTION__,json_encode($json).'| response: '.json_encode($response),null);
|
|
|
- return ['result'=>'false'];
|
|
|
+ $this->log(__METHOD__,'common_'.__FUNCTION__,'标记WMS波次:'.$package['batch_number'].'进入中',null);
|
|
|
+ $this->markWMS($package['batch_number']);
|
|
|
+ return ['result'=>'success'];
|
|
|
+ //对WMS接口请求不需要了,直接写其数据库
|
|
|
+// $json=["request"=>['TASKID'=>$package->WMSReflectPackage_name,
|
|
|
+// 'SOReference5'=>$package->logistic_number,
|
|
|
+// 'Weigh'=>$package->weight,
|
|
|
+// 'Addwho'=>'',
|
|
|
+// 'Addtime'=>Carbon::now(),
|
|
|
+// 'Package'=>$package->paperBox_name,
|
|
|
+// 'USERDEFINE1'=>$package->batch_number,
|
|
|
+// 'USERDEFINE2'=>$package->batch_rule,
|
|
|
+// 'USERDEFINE3'=>'OK',
|
|
|
+// ]];
|
|
|
+// $json=json_encode($json);
|
|
|
+// $url=url(config('api.flux.package.new'));
|
|
|
+// $response = Zttp::post($url, json_decode($json));
|
|
|
+// $this->log(__METHOD__,'Sign'.__FUNCTION__,json_encode($response->json()),null);
|
|
|
+// $response=$response->json();
|
|
|
+// $noIssues=true;
|
|
|
+// if(!$response||!isset($response['response'])||!$response['response']['flag']=='Y'){
|
|
|
+// $noIssues=false;
|
|
|
+// }
|
|
|
+// if($noIssues&&$response['response']['flag']=='Y'){
|
|
|
+// $this->log(__METHOD__,'SUCCESS_'.__FUNCTION__,json_encode($json).'| response: '.json_encode($response),null);
|
|
|
+// return ['result'=>'success'];
|
|
|
+// }
|
|
|
+// $this->log(__METHOD__,'ERROR_'.__FUNCTION__,json_encode($json).'| response: '.json_encode($response),null);
|
|
|
+// return ['result'=>'false'];
|
|
|
}catch (\Exception $exception){
|
|
|
- Controller::logS(__METHOD__,'Exception_'.__FUNCTION__,'CURL请求异常:'.$exception->getMessage(),null);
|
|
|
+ Controller::logS(__METHOD__,'Exception_'.__FUNCTION__,'请求异常:'.$exception->getMessage(),null);
|
|
|
return ['result'=>'false'];
|
|
|
}
|
|
|
}
|
|
|
+ private function markWMS($batchNumber){
|
|
|
+ $docWaveHeader=OracleDOCWaveHeader::where('waveno',$batchNumber)->first();
|
|
|
+ if($docWaveHeader){
|
|
|
+ $docWaveHeader['userdefine3'] = 'Y';
|
|
|
+ OracleDOCWaveHeader::select('waveno','userdefine3')->where('waveno',$batchNumber)
|
|
|
+ ->update(['userdefine3'=>'Y']);
|
|
|
+// $docWaveHeader->update();
|
|
|
+ $docWaveHeader=OracleDOCWaveHeader::where('waveno',$batchNumber)->first();
|
|
|
+ $this->log(__METHOD__,'SUCCESS_'.__FUNCTION__,'标记WMS波次:'.$batchNumber.',userdefine3='.$docWaveHeader['userdefine3'],null);
|
|
|
+ }else{
|
|
|
+ $this->log(__METHOD__,'ERROR'.__FUNCTION__,'标记WMS波次:'.$batchNumber.'未取到',null);
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
|
|
|
}
|