|
|
@@ -6,7 +6,9 @@ use App\Http\Controllers\Controller;
|
|
|
use App\Store;
|
|
|
use App\WMSReflectReceive;
|
|
|
use App\WMSReflectReceiveSku;
|
|
|
+use Carbon\Carbon;
|
|
|
use Illuminate\Support\Facades\Auth;
|
|
|
+use Illuminate\Support\Facades\DB;
|
|
|
use Zttp\Zttp;
|
|
|
|
|
|
class StoreController extends Controller
|
|
|
@@ -23,7 +25,7 @@ class StoreController extends Controller
|
|
|
$METHOD=__METHOD__;
|
|
|
$FUNCTION=__FUNCTION__;
|
|
|
Controller::logS(__METHOD__, __FUNCTION__, '快递入库进入WMS接口:' . $store['asn_code']);
|
|
|
- $wmsReceiveds=WMSReflectReceive::where('ASNNO',$store['asn_code'])->get();
|
|
|
+ $wmsReceiveds=WMSReflectReceive::query()->where('ASNNO',$store['asn_code'])->get();
|
|
|
if($wmsReceiveds->isEmpty()){
|
|
|
(new Controller())->log(__METHOD__,'error_'.__FUNCTION__,'没有本地WMS入库单');
|
|
|
return false;
|
|
|
@@ -127,4 +129,457 @@ class StoreController extends Controller
|
|
|
return $success;
|
|
|
}
|
|
|
|
|
|
+ public function quickStorage($asnno){
|
|
|
+ $docno = ""; //订单号 非ASN号
|
|
|
+ //判断单据有效性
|
|
|
+ $cus_bs_asnheader = DB::connection('oracle')->select(DB::raw("SELECT t.addwho FROM CUS_BS_ASNHEADER t WHERE t.asnreferencel = '".$docno."'"));
|
|
|
+ if (!$cus_bs_asnheader) return ['success'=>false, 'data'=>'单据不存在'];
|
|
|
+ $addwho = $cus_bs_asnheader[0]->addwho;
|
|
|
+ if ($addwho == "WCS"){
|
|
|
+ //判断单据状态
|
|
|
+ $cus_bs_asnheader = DB::connection('oracle')->select(
|
|
|
+ DB::raw("SELECT COUNT(1) FROM CUS_BS_ASNHEADER t INNER JOIN DOC_ASN_HEADER a ON a.asnno = t.asnno WHERE t.asnreference1 = '".$docno."' AND a.asnstatus < '40'"));
|
|
|
+ if (!$cus_bs_asnheader) return ['success'=>false, 'data'=>"该单据已完成收货"];
|
|
|
+
|
|
|
+ $sql = "select a.warehouseid,a.asnno as docno,a1.asnlineno,a.customerid,t1.sku,a1.packid,t1.receivedqty_each,t1.lotatt01,t1.lotatt02,";
|
|
|
+ $sql .= " t1.lotatt04,t1.lotatt05,t1.lotatt08,t1.userdefine1 as new_traceid,a.userdefine1,a.userdefine2,a.userdefine3,a.userdefine4,a.userdefine5,t.addwho";
|
|
|
+ $sql .= " from doc_asn_details a1";
|
|
|
+ $sql .= " inner join doc_asn_header a on a.asnno = a1.asnno";
|
|
|
+ $sql .= " inner join cus_bs_asndetails t1 on t1.asnno = a.asnno and t1.asnlineno = a1.asnlineno";
|
|
|
+ $sql .= " inner join cus_bs_asnheader t on t.asnno = a1.asnno";
|
|
|
+ $sql .= " where t.asnreference1 = ".$docno." and nvl(t1.rcvflag,'N') = 'N'";
|
|
|
+ $doc_asn_details = DB::connection('oracle')->select(DB::raw($sql));
|
|
|
+ $that = $this;
|
|
|
+ DB::transaction(function ()use($doc_asn_details,$that){
|
|
|
+ foreach ($doc_asn_details as $doc_asn_detail){
|
|
|
+ $resule = $that->exe($doc_asn_detail->warehouseid,'3',$doc_asn_detail->docno,$doc_asn_detail->asnlineno,'',$doc_asn_detail->new_traceid,'00','正常','OK','正常',
|
|
|
+ '',$doc_asn_detail->customerid,$doc_asn_detail->sku,$doc_asn_detail->receivedqty_each,'','EA',$doc_asn_detail->packid,'',$doc_asn_detail->lotatt01,$doc_asn_detail->lotatt02,
|
|
|
+ '',$doc_asn_detail->lotatt04,$doc_asn_detail->lotatt05,'','',$doc_asn_detail->lotatt08,'','','','',
|
|
|
+ '0.00','0.00','0.00','0.00',$doc_asn_detail->userdefine1,$doc_asn_detail->userdefine2,$doc_asn_detail->userdefine3,$doc_asn_detail->userdefine4,$doc_asn_detail->userdefine5,'STAGE'.$doc_asn_detail->warehouseid,
|
|
|
+ 'STAGE'.$doc_asn_detail->warehouseid,'OK','','','*',$doc_asn_detail->addwho,'','','cn',$doc_asn_detail->addwho,'');
|
|
|
+ if (substr($resule,1,3) == '000'){
|
|
|
+ exe2();
|
|
|
+ }else{
|
|
|
+ exe3();
|
|
|
+ DB::rollBack();
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
+ DB::commit();
|
|
|
+ return ['success'=>true, 'data'=>"OK"];
|
|
|
+ }
|
|
|
+ if ($addwho == "BSERP"){
|
|
|
+ $cus_bs_asnheader = DB::connection('oracle')->select(DB::raw('SELECT t.asnreference1 FROM cus_bs_asnheader t'));
|
|
|
+ if (!$cus_bs_asnheader) return ['success'=>false, 'data'=>'单据不存在'];
|
|
|
+ $asnreference1 = $cus_bs_asnheader[0]->asnreference1;
|
|
|
+ return ['success'=>true, 'data'=>$asnreference1];
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /** $In_Process_Action为来源渠道,快速入库调用固定值 为 '3' */
|
|
|
+ private function exe($IN_Warehouse, $In_Process_Action, $In_ASNNo_C, $In_ASNLineNo_C, $In_FMTraceID_C, $In_New_TraceID_C, $In_ProductStatus,
|
|
|
+ $In_ProductStatus_Descr, $In_HoldRejectCode_C, $In_HoldRejectReason_C, $In_PONo_C, $In_CustomerID, $In_SKU, $In_ReceivedQty, $In_RejectedQty,
|
|
|
+ $In_UOM, $In_PackID, $In_ContainerID, $In_LotAtt01_C, $In_LotAtt02_C, $In_LotAtt03_C, $In_LotAtt04_C, $In_LotAtt05_C, $In_LotAtt06_C,
|
|
|
+ $In_LotAtt07_C, $In_LotAtt08_C, $In_LotAtt09_C, $In_LotAtt10_C, $In_LotAtt11_C, $In_LotAtt12_C,
|
|
|
+ $In_TotalCubic, $In_TotalGrossWeight, $In_TotalNetWeight, $In_TotalPrice, $In_UserDefine1, $In_UserDefine2,
|
|
|
+ $In_UserDefine3, $In_UserDefine4, $In_UserDefine5, $In_FMLocation, $In_TOLocation_C, $In_QC_Type_C, $In_PlanToLoc_C,
|
|
|
+ $In_ReceivingTime, $In_LPN, $In_Operator, $IN_RCVModule, $IN_RCVStation, $In_Language, $In_UserID, $OUT_Return_Code)
|
|
|
+ {
|
|
|
+ /*$r_NO_COMMIT $R_CurrentTime $OUT_Return_Code $R_ReceivingTime $r_LPN $r_UDF2_AD $r_UDF2_IN
|
|
|
+ $R_Qty_PlanPutaway $R_QCTaskID $R_HOLD_FLAG $R_PA_TaskID $R_PA_Flag $R_QC_Sequence $R_PA_Sequence
|
|
|
+ $R_Reserve_Flag $R_QtyMVOut $r_TotalGrossWeight $r_TotalCubic r_TotalNetWeight r_TotalPrice In_LotAtt01
|
|
|
+ In_LotAtt02 In_LotAtt03 In_LotAtt04 In_LotAtt05 In_LotAtt06 In_LotAtt07 In_LotAtt08 In_LotAtt09 In_LotAtt10
|
|
|
+ In_LotAtt11 In_LotAtt12 In_HoldRejectCode In_HoldRejectReason
|
|
|
+ */
|
|
|
+ if ($OUT_Return_Code == "NO_COMMIT" || $OUT_Return_Code == "*_*"){
|
|
|
+ $r_NO_COMMIT = 'N';
|
|
|
+ }else{
|
|
|
+ $r_NO_COMMIT = 'Y';
|
|
|
+ }
|
|
|
+ //初始化
|
|
|
+ $R_CurrentTime = Carbon::now();
|
|
|
+ $OUT_Return_Code ='000';
|
|
|
+ if (!$In_ReceivingTime){
|
|
|
+ $R_ReceivingTime = Carbon::now();
|
|
|
+ }else{
|
|
|
+ $R_ReceivingTime = $In_ReceivingTime;
|
|
|
+ }
|
|
|
+ //else R_ReceivingTime:=To_Date( IN_ReceivingTime,'YYYY/MM/DD hh24:mi:ss'); --2008-11-25 15:53:33
|
|
|
+
|
|
|
+ if ($In_LPN && $In_LPN != "*"){
|
|
|
+ $r_LPN = $In_LPN;
|
|
|
+ }else $r_LPN = "*";
|
|
|
+
|
|
|
+ $bascode = DB::select(DB::raw("SELECT udf2 FROM BAS_CODES WHERE codeid ='TRN_TYP' AND code='AD'"));
|
|
|
+ $r_UDF2_AD = $bascode[0]->udf2 ?? 'N';
|
|
|
+
|
|
|
+ $bascode = DB::select(DB::raw("SELECT udf2 FROM BAS_CODES WHERE codeid ='TRN_TYP' AND code='IN'"));
|
|
|
+ $r_UDF2_IN = $bascode[0]->udf2 ?? 'N';
|
|
|
+
|
|
|
+ $R_Qty_PlanPutaway = 0;
|
|
|
+ $R_QCTaskID = '*';
|
|
|
+ $R_HOLD_FLAG = 'N';
|
|
|
+ $R_PA_TaskID = '*';
|
|
|
+ $R_PA_Flag = 'N';
|
|
|
+ $R_QC_Sequence = 0;
|
|
|
+ $R_PA_Sequence = 0;
|
|
|
+ $R_Reserve_Flag = 'N';
|
|
|
+ $R_QtyMVOut = 0;
|
|
|
+
|
|
|
+ $r_TotalGrossWeight = $In_TotalGrossWeight;
|
|
|
+ $r_TotalCubic = $In_TotalCubic;
|
|
|
+ $r_TotalNetWeight = $In_TotalNetWeight ?? 0;
|
|
|
+ $r_TotalPrice = $In_TotalPrice;
|
|
|
+
|
|
|
+ $In_LotAtt01 = $In_LotAtt01_C;
|
|
|
+ $In_LotAtt02 = $In_LotAtt02_C;
|
|
|
+ $In_LotAtt03 = $In_LotAtt03_C;
|
|
|
+ $In_LotAtt04 = $In_LotAtt04_C;
|
|
|
+ $In_LotAtt05 = $In_LotAtt05_C;
|
|
|
+ $In_LotAtt06 = $In_LotAtt06_C;
|
|
|
+ $In_LotAtt07 = $In_LotAtt07_C;
|
|
|
+ $In_LotAtt08 = $In_LotAtt08_C;
|
|
|
+ $In_LotAtt09 = $In_LotAtt09_C;
|
|
|
+ $In_LotAtt10 = $In_LotAtt10_C;
|
|
|
+ $In_LotAtt11 = $In_LotAtt11_C;
|
|
|
+ $In_LotAtt12 = $In_LotAtt12_C;
|
|
|
+
|
|
|
+ $In_HoldRejectCode = $In_HoldRejectCode_C;
|
|
|
+ $In_HoldRejectReason = $In_HoldRejectReason_C;
|
|
|
+
|
|
|
+ $In_TOLocation = $In_TOLocation_C;
|
|
|
+ $In_New_TraceID = $In_New_TraceID_C ?? '*';
|
|
|
+ $In_QC_Type = $In_QC_Type_C;
|
|
|
+ $In_FMTraceID = $In_FMTraceID_C;
|
|
|
+ $In_ASNNo = $In_ASNNo_C;
|
|
|
+ $In_ASNLineNo = $In_ASNLineNo_C;
|
|
|
+ $In_PONo = $In_PONo_C;
|
|
|
+ $In_PlanToLoc = $In_PlanToLoc_C;
|
|
|
+
|
|
|
+ $r_nrow = 0;
|
|
|
+
|
|
|
+ $OUT_Return_Code = '*_*';
|
|
|
+ //此处调用必然返回000,所以直接忽视判断进入下层逻辑
|
|
|
+ $OUT_Return_Code = $this->SPUDF_ProcessA($IN_Warehouse,'RCV_BEFORE',$In_ASNNo,$In_ASNLineNo,$In_ReceivedQty,$In_Language,$In_UserID,$OUT_Return_Code);
|
|
|
+
|
|
|
+ //TODO 盲收逻辑 SPASN_Receiving_Process:536行 $In_Process_Action = 2
|
|
|
+
|
|
|
+ //如果订单已经关闭或者取消,则报错
|
|
|
+ $doc_asn_header = DB::connection('oracle')->select(DB::raw("Select count(1) from DOC_ASN_Header where ASNNO='".$In_ASNNo."' and (ASNStatus='90' or ASNStatus='99')"));
|
|
|
+ if ($doc_asn_header) return '201';
|
|
|
+
|
|
|
+ //收货数量必须大于0
|
|
|
+ if ($In_ReceivedQty <= 0 && ((!$In_ProductStatus) || $In_ProductStatus == '00')) return '204';
|
|
|
+
|
|
|
+ //批次属性自动复制 系统配置是否允许超量收货
|
|
|
+ $customer = DB::connection('oracle')->select(DB::raw("SELECT OverReceiving,OverRCVPercentage,ASN_LNK_PO,AsnRef1ToLot4,AsnRef2ToLot5,AsnRef3ToLot6,AsnRef4ToLot7,AsnRef5ToLot8 FROM Bas_Customer WHERE CustomerID='".$In_CustomerID."' AND Customer_Type = 'OW'"));
|
|
|
+ if (!$customer) return '888BAS_Customer,OPEN';
|
|
|
+
|
|
|
+ $R_OverReceiving = $customer[0]->overreceiving ?? 'N';
|
|
|
+ $R_OverRCVPercentage_Customer = $customer[0]->overrcvpercentage ?? 0;
|
|
|
+ $r_ASN_LNK_PO = $customer[0]->asn_lnk_po ?? 'Y';
|
|
|
+ $R_AsnRef1ToLot4 = $customer[0]->asnref1tolot4;
|
|
|
+ $R_AsnRef2ToLot5 = $customer[0]->asnref2tolot5;
|
|
|
+ $R_AsnRef3ToLot6 = $customer[0]->asnref3tolot6;
|
|
|
+ $R_AsnRef4ToLot7 = $customer[0]->asnref4tolot7;
|
|
|
+ $R_AsnRef5ToLot8 = $customer[0]->asnref5tolot8;
|
|
|
+
|
|
|
+ $DOC_ASN_Header = DB::connection('oracle')->select(DB::raw("SELECT ASNReference1,ASNReference2,ASNReference3,ASNReference4,ASNReference5,ExpectedArriveTime1,ExpectedArriveTime2,QCStatus,ASNType,WarehouseID,ReleaseStatus,Priority FROM DOC_ASN_Header WHERE ASNNO='".$In_ASNNo."'"));
|
|
|
+ if (!$DOC_ASN_Header) return '888DOC_ASN_Header,OPEN';
|
|
|
+
|
|
|
+ $r_ASNReference1 = $DOC_ASN_Header[0]->asnreference1;
|
|
|
+ $r_ASNReference2 = $DOC_ASN_Header[0]->asnreference2;
|
|
|
+ $r_ASNReference3 = $DOC_ASN_Header[0]->asnreference3;
|
|
|
+ $r_ASNReference4 = $DOC_ASN_Header[0]->asnreference4;
|
|
|
+ $r_ASNReference5 = $DOC_ASN_Header[0]->asnreference5;
|
|
|
+ $r_ExpectedArriveTime1 = $DOC_ASN_Header[0]->expectedarrivetime1 ?? "2000-01-01 00:00:00";
|
|
|
+ $r_ExpectedArriveTime2 = $DOC_ASN_Header[0]->expectedarrivetime2 ?? "2099-12-31 00:00:00";
|
|
|
+ $r_QCStatus = $DOC_ASN_Header[0]->qcstatus;
|
|
|
+ $r_ASNType = $DOC_ASN_Header[0]->asntype;
|
|
|
+ $r_WarehouseID = $DOC_ASN_Header[0]->warehouseid;
|
|
|
+ $R_ReleaseStatus = $DOC_ASN_Header[0]->releasestatus;
|
|
|
+ $r_Priority = $DOC_ASN_Header[0]->priority ?? '3';
|
|
|
+
|
|
|
+ if ($R_AsnRef1ToLot4 == 'Y' && ($r_ASNReference1 && $r_ASNReference1 != "*") && ((!$In_LotAtt04) || $In_LotAtt04=='*')){
|
|
|
+ $In_LotAtt04 = $r_ASNReference1;
|
|
|
+ }
|
|
|
+ if ($R_AsnRef2ToLot5 == 'Y' && ($r_ASNReference2 && $r_ASNReference2 != "*") && ((!$In_LotAtt05) || $In_LotAtt05=='*')){
|
|
|
+ $In_LotAtt05 = $r_ASNReference2;
|
|
|
+ }
|
|
|
+ if ($R_AsnRef3ToLot6 == 'Y' && ($r_ASNReference3 && $r_ASNReference3 != "*") && ((!$In_LotAtt06) || $In_LotAtt06=='*')){
|
|
|
+ $In_LotAtt06 = $r_ASNReference3;
|
|
|
+ }
|
|
|
+ if ($R_AsnRef4ToLot7 == 'Y' && ($r_ASNReference4 && $r_ASNReference4 != "*") && ((!$In_LotAtt07) || $In_LotAtt07=='*')){
|
|
|
+ $In_LotAtt07 = $r_ASNReference4;
|
|
|
+ }
|
|
|
+ if ($R_AsnRef5ToLot8 == 'Y' && ($r_ASNReference5 && $r_ASNReference5 != "*") && ((!$In_LotAtt08) || $In_LotAtt08=='*')){
|
|
|
+ $In_LotAtt08 = $r_ASNReference5;
|
|
|
+ }
|
|
|
+
|
|
|
+ if ($In_LotAtt01 == 'YYYY-MM-DD') $In_LotAtt01 = null;
|
|
|
+ if ($In_LotAtt02 == 'YYYY-MM-DD') $In_LotAtt02 = null;
|
|
|
+ if ($In_LotAtt03 == 'YYYY-MM-DD') $In_LotAtt03 = null;
|
|
|
+
|
|
|
+ // TODO SPASN_Receiving_Process:643行 IN_ProductStatus固定值00 跳过
|
|
|
+
|
|
|
+ //生产日期、入库日期、失效日期的逻辑校验
|
|
|
+ if (($In_LotAtt01 && $In_LotAtt02 && Carbon::parse($In_LotAtt01)->gte(Carbon::parse($In_LotAtt02))) || ($In_LotAtt01 && Carbon::parse($In_LotAtt01)->gt(Carbon::parse($R_CurrentTime)))){
|
|
|
+ return "260";
|
|
|
+ }
|
|
|
+ $r_ASN_MDT_CHK = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'ASN_MDT_CHK');
|
|
|
+
|
|
|
+ //入库生产日期不能小于在库库存生产日期
|
|
|
+ if ($r_ASN_MDT_CHK == 'Y' && trim($In_LotAtt01)){
|
|
|
+ $data = DB::connection('oracle')->select(DB::raw("SELECT count(*) c FROM INV_LOT_LOC_ID a,INV_LOT_ATT b, bas_location c WHERE a.CUSTOMERID='".$In_CustomerID.
|
|
|
+ "' AND a.sku='".$In_SKU."' AND a.LotNum=b.LotNum AND a.LocationID=c.LocationID AND c.LocationUsage<>'ST' AND b.LotAtt01>'".$In_LotAtt01."'"));
|
|
|
+ if ($data) return '266INV_LOT_LOC_ID';
|
|
|
+ }
|
|
|
+
|
|
|
+ //批次属性必输校验
|
|
|
+ $BAS_lotID = DB::connection('oracle')->select(DB::raw("SELECT LotAtt01_Flag,LotAtt02_Flag,LotAtt03_Flag,LotAtt04_Flag,LotAtt05_Flag,LotAtt06_Flag,".
|
|
|
+ "LotAtt07_Flag,LotAtt08_Flag,LotAtt09_Flag,LotAtt10_Flag,LotAtt11_Flag,LotAtt12_Flag,OverRCVPercentage,a.LotID,PackID,".
|
|
|
+ "GrossWeight,Cube,CopyPackIDToLotAtt12,AllowReceiving,A.SKU_Group1 FROM Bas_SKU a, BAS_lotID b WHERE a.CustomerID='".$In_CustomerID."' AND a.sku='".$In_SKU."' AND a.LotID=b.LotID"));
|
|
|
+ if (!$BAS_lotID)return "888From Bas_SKU*BAS_lotID,OPEN";
|
|
|
+ $r_LotAtt01_Flag = $BAS_lotID[0]->lotatt01_flag;
|
|
|
+ $r_LotAtt02_Flag = $BAS_lotID[0]->lotatt02_flag;
|
|
|
+ $r_LotAtt03_Flag = $BAS_lotID[0]->lotatt03_flag;
|
|
|
+ $r_LotAtt04_Flag = $BAS_lotID[0]->lotatt04_flag;
|
|
|
+ $r_LotAtt05_Flag = $BAS_lotID[0]->lotatt05_flag;
|
|
|
+ $r_LotAtt06_Flag = $BAS_lotID[0]->lotatt06_flag;
|
|
|
+ $r_LotAtt07_Flag = $BAS_lotID[0]->lotatt07_flag;
|
|
|
+ $r_LotAtt08_Flag = $BAS_lotID[0]->lotatt08_flag;
|
|
|
+ $r_LotAtt09_Flag = $BAS_lotID[0]->lotatt09_flag;
|
|
|
+ $r_LotAtt10_Flag = $BAS_lotID[0]->lotatt10_flag;
|
|
|
+ $r_LotAtt11_Flag = $BAS_lotID[0]->lotatt11_flag;
|
|
|
+ $r_LotAtt12_Flag = $BAS_lotID[0]->lotatt12_flag;
|
|
|
+ $r_OverRCVPercentage_SKU = $BAS_lotID[0]->overrcvpercentage ?? 0;
|
|
|
+ $r_SKU_LOTID = $BAS_lotID[0]->lotid;
|
|
|
+ $r_SKU_PackID = $BAS_lotID[0]->packid;
|
|
|
+ $r_SKU_GrossWeight = $BAS_lotID[0]->grossweight;
|
|
|
+ $r_SKU_Cube = $BAS_lotID[0]->cube;
|
|
|
+ $r_CopyPackIDToLotAtt12 = $BAS_lotID[0]->copypackidtolotatt12;
|
|
|
+ $r_AllowReceiving = $BAS_lotID[0]->allowreceiving;
|
|
|
+ $r_SKU_Group1 = $BAS_lotID[0]->sku_group1;
|
|
|
+ //是否被设置禁止入库
|
|
|
+ if ($r_AllowReceiving == 'N') return "117";
|
|
|
+ if (($r_LotAtt01_Flag == '3' && !$In_LotAtt01) ||
|
|
|
+ ($r_LotAtt02_Flag == "3" && !$In_LotAtt02) ||
|
|
|
+ ($r_LotAtt03_Flag == "3" && !$In_LotAtt03) ||
|
|
|
+ ($r_LotAtt04_Flag == "3" && !$In_LotAtt04) ||
|
|
|
+ ($r_LotAtt05_Flag == "3" && !$In_LotAtt05) ||
|
|
|
+ ($r_LotAtt06_Flag == "3" && !$In_LotAtt06) ||
|
|
|
+ ($r_LotAtt07_Flag == "3" && !$In_LotAtt07) ||
|
|
|
+ ($r_LotAtt08_Flag == "3" && !$In_LotAtt08) ||
|
|
|
+ ($r_LotAtt09_Flag == "3" && !$In_LotAtt09) ||
|
|
|
+ ($r_LotAtt10_Flag == "3" && !$In_LotAtt10) ||
|
|
|
+ ($r_LotAtt11_Flag == "3" && !$In_LotAtt11) ||
|
|
|
+ ($r_LotAtt12_Flag == "3" && !$In_LotAtt12))return "221".$In_ASNLineNo_C;
|
|
|
+ if ($r_LotAtt01_Flag == '1' && $In_LotAtt01) $In_LotAtt01 = null;
|
|
|
+ if ($r_LotAtt02_Flag == '1' && $In_LotAtt02) $In_LotAtt02 = null;
|
|
|
+ if ($r_LotAtt03_Flag == '1' && $In_LotAtt03) $In_LotAtt03 = null;
|
|
|
+ if ($r_LotAtt04_Flag == '1' && $In_LotAtt04) $In_LotAtt04 = null;
|
|
|
+ if ($r_LotAtt05_Flag == '1' && $In_LotAtt05) $In_LotAtt05 = null;
|
|
|
+ if ($r_LotAtt06_Flag == '1' && $In_LotAtt06) $In_LotAtt06 = null;
|
|
|
+ if ($r_LotAtt07_Flag == '1' && $In_LotAtt07) $In_LotAtt07 = null;
|
|
|
+ if ($r_LotAtt08_Flag == '1' && $In_LotAtt08) $In_LotAtt08 = null;
|
|
|
+ if ($r_LotAtt09_Flag == '1' && $In_LotAtt09) $In_LotAtt09 = null;
|
|
|
+ if ($r_LotAtt10_Flag == '1' && $In_LotAtt10) $In_LotAtt10 = null;
|
|
|
+ //if ($r_LotAtt11_Flag == '1' && $In_LotAtt11) $In_LotAtt11 = null;
|
|
|
+ if ($r_LotAtt12_Flag == '1' && $In_LotAtt12) $In_LotAtt12 = null;
|
|
|
+
|
|
|
+ $R_LOT_12_PKG = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'LOT_#12_PKG');
|
|
|
+ // 批次属性12被设置为跟踪包装数量,不允许输入非数字字符'
|
|
|
+ if ($R_LOT_12_PKG == 'Y' && !is_numeric($In_LotAtt12)) return "232";
|
|
|
+
|
|
|
+ if ($r_OverRCVPercentage_SKU != 0) $r_OverRCVPercentage = $r_OverRCVPercentage_SKU;
|
|
|
+ else $r_OverRCVPercentage = $R_OverRCVPercentage_Customer;
|
|
|
+
|
|
|
+ // TODO 药品相关逻辑 SPASN_Receiving_Process:817行 药品有效期 证书有效期 经营许可证有效期校验提示
|
|
|
+
|
|
|
+ //基础设置是否维护完全校验
|
|
|
+ $R_BAS_PAC_CHK = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'BAS_PAC_CHK');
|
|
|
+ $R_BAS_LOT_CHK = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'BAS_LOT_CHK');
|
|
|
+ $R_BAS_GWT_CHK = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'BAS_GWT_CHK');
|
|
|
+ $R_BAS_CUB_CHK = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'BAS_CUB_CHK');
|
|
|
+ if ($R_BAS_PAC_CHK == 'Y' && !$r_SKU_PackID)return '110'.$In_SKU;
|
|
|
+ if ($R_BAS_LOT_CHK == 'Y' && !$r_SKU_LOTID)return '111';
|
|
|
+ if ($R_BAS_GWT_CHK == 'Y' && $r_SKU_GrossWeight == 0)return '112';
|
|
|
+ if ($R_BAS_CUB_CHK == 'Y' && $r_SKU_Cube == 0)return '113';
|
|
|
+
|
|
|
+ //订单释放状态校验
|
|
|
+ if($R_ReleaseStatus == 'N') return '226';
|
|
|
+
|
|
|
+ /*参数准备 */
|
|
|
+ //必须输入价格
|
|
|
+ $R_UNT_PRI_CTL = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'UNT_PRI_CTL');
|
|
|
+ //收货后打印上架标签
|
|
|
+ $R_PRT_PTA_LBL = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'PRT_PTA_LBL');
|
|
|
+ //ASN收货自动产生跟踪号
|
|
|
+ $r_ASN_GEN_TID = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'ASN_GEN_TID');
|
|
|
+ //收货后将收货结果更新ASN明细
|
|
|
+ $r_ASN_RCV_UPD = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'ASN_RCV_UPD');
|
|
|
+ //完全收货后自动关闭ASN
|
|
|
+ $r_RCV_CTL = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'RCV_CTL');
|
|
|
+ //超过产品有效期控制天数是否拒收
|
|
|
+ $r_EXP_CTL = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'EXP_CTL');
|
|
|
+ //码盘后才能收货
|
|
|
+ $r_PLT_RCV = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'PLT_RCV');
|
|
|
+ //跨区域货物是否允许收到一个托盘上
|
|
|
+ $r_RCV_CRS_ARA = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'RCV_CRS_ARA');
|
|
|
+ //收货时必须指定跟踪号
|
|
|
+ $r_RCV_TID_CTL = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'RCV_TID_CTL');
|
|
|
+ //超额收货
|
|
|
+ $R_OverReceiving = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'OVR_RCV');
|
|
|
+ //收货时间必须在预期到货时间范围内
|
|
|
+ $r_RCV_TIM_CTL = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'RCV_TIM_CTL');
|
|
|
+ //同一跟踪号不允许在收货区重复收货
|
|
|
+ $r_RCV_MIX_TID = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'RCV_MIX_TID');
|
|
|
+ //只有上架确认后才能关闭ASN
|
|
|
+ $r_PTA_CLS_CHK = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'PTA_CLS_CHK');
|
|
|
+ //收货数量拆分寻找目标库位
|
|
|
+ $r_RCV_BRK_TSK = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'RCV_BRK_TSK');
|
|
|
+ //扫描收货时记录箱码和序列号
|
|
|
+ $r_SN_CTL = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'SN#_CTL','0');
|
|
|
+ //质检后才能收货
|
|
|
+ $r_QC_RCV_CTL = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'QC_RCV_CTL');
|
|
|
+ //目标库位为拆零拣货位拆箱时作废箱码
|
|
|
+ $r_PCK_LOS_SN = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'PCK_LOS_SN');
|
|
|
+ //服装行业插件开关
|
|
|
+ $r_IND_TEX = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'IND_TEX');
|
|
|
+
|
|
|
+ if ($In_Process_Action != '2'){
|
|
|
+ $DOC_ASN_DETAiLS = DB::connection('oracle')->select(DB::raw("SELECT ExpectedQty_Each,ReceivedQty_Each,POLineNO,PONO,OverRCVPercentage,ContainerID,QCStatus FROM DOC_ASN_DETAiLS WHERE ASNNO='".$In_ASNNo."' AND ASNLineNo='".$In_ASNLineNo."' FOR UPDATE"));
|
|
|
+ if (!$DOC_ASN_DETAiLS)return '104'.$In_ASNNo.":".$In_ASNLineNo;
|
|
|
+ $r_ExpectedQty_Each_ASN = $DOC_ASN_DETAiLS[0]->expectedqty_each;
|
|
|
+ $r_ReceivedQty_Each_ASN = $DOC_ASN_DETAiLS[0]->receivedqty_each;
|
|
|
+ $r_POLineNO = $DOC_ASN_DETAiLS[0]->polineno;
|
|
|
+ $r_PONO = $DOC_ASN_DETAiLS[0]->pono;
|
|
|
+ $R_OverRCVPercentage_ASN = $DOC_ASN_DETAiLS[0]->overrcvpercentage;
|
|
|
+ $r_ASNContainerID = $DOC_ASN_DETAiLS[0]->containerid ?? '';
|
|
|
+ $r_QCStatus = $DOC_ASN_DETAiLS[0]->qcstatus ?? '';
|
|
|
+ }
|
|
|
+
|
|
|
+ //目标库位属性
|
|
|
+ if ($In_TOLocation == '*' || !trim($In_TOLocation))$In_TOLocation = $In_FMLocation;
|
|
|
+
|
|
|
+ $BAS_Location = DB::connection('oracle')->select(DB::raw("SELECT LocationUsage,LoseID_Flag,Mix_Flag,Mix_LotFlag,LocationAttribute,SKUCount FROM BAS_Location WHERE LocationID='".$In_TOLocation."'"));
|
|
|
+ if (!$BAS_Location)return '104'.$In_TOLocation;
|
|
|
+ $R_LocationUsage = $BAS_Location[0]->locationusage;
|
|
|
+ $R_LoseID_Flag = $BAS_Location[0]->loseid_flag ?? 'N';
|
|
|
+ $R_Mix_Flag = $BAS_Location[0]->mix_flag ?? 'Y';
|
|
|
+ $R_Mix_LotFlag = $BAS_Location[0]->mix_lotflag ?? 'Y';
|
|
|
+ $r_LocationAttribute = $BAS_Location[0]->locationattribute;
|
|
|
+ $r_SKUCount = $BAS_Location[0]->skucount;
|
|
|
+
|
|
|
+ if($r_QC_RCV_CTL == 'Y' && $r_QCStatus != '20')return '272';
|
|
|
+
|
|
|
+ //如果ASN中ContainerID有值,并且收货SP没有传递跟踪号,则以ContainerID作为跟踪号
|
|
|
+ if ($r_ASNContainerID && (!$In_New_TraceID || $In_New_TraceID == '*'))$In_New_TraceID = $r_ASNContainerID;
|
|
|
+
|
|
|
+ $IN_New_TraceID_OLD = $In_New_TraceID;
|
|
|
+
|
|
|
+ if ($r_RCV_TID_CTL == 'Y' && (!$In_New_TraceID || $In_New_TraceID=='*'))return '270';
|
|
|
+ //必须维护单价后才能收货
|
|
|
+ if ($R_UNT_PRI_CTL == 'Y'){
|
|
|
+ if (!$In_TotalPrice || $In_TotalPrice <= 0)return '050';
|
|
|
+ }
|
|
|
+
|
|
|
+ if($r_RCV_TIM_CTL == 'Y' && ($R_CurrentTime->lt(Carbon::parse($r_ExpectedArriveTime1)) || $R_CurrentTime->gt($r_ExpectedArriveTime2)))return '271';
|
|
|
+
|
|
|
+ // 同一跟踪号不允许混收产品
|
|
|
+ if (strtoupper($In_FMLocation) == 'SCANSTATION')$r_RCV_MIX_SKU = 'Y';
|
|
|
+ else $r_RCV_MIX_SKU=$this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'RCV_MIX_SKU', 'Y');
|
|
|
+
|
|
|
+ $r_RCV_MIX_GR1 = $this->GETSYS_configuration($IN_Warehouse, $In_CustomerID, $r_ASNType, 'RCV_MIX_GR1', 'Y','C');
|
|
|
+
|
|
|
+ //跟踪号的校验处理
|
|
|
+ if ($In_New_TraceID != '*' && trim($In_New_TraceID)){
|
|
|
+ if ($R_LoseID_Flag == 'N'){
|
|
|
+ if ($r_RCV_MIX_TID == 'N'){ //跟踪号是否可以多次收货
|
|
|
+ $INV_LOT_LOC_ID = DB::connection('oracle')->select(DB::raw("SELECT COUNT(*) FROM INV_LOT_LOC_ID a INNER JOIN view_MultiWarehouse b ON a.LOCATIONID = b.LOCATIONID WHERE b.WAREHOUSEID = '".
|
|
|
+ $IN_Warehouse."' AND TraceID='".$In_New_TraceID."' AND qty>0"));
|
|
|
+ if ($INV_LOT_LOC_ID) return '218跟踪号重复错误ID='.$In_New_TraceID;
|
|
|
+ }else{
|
|
|
+ if ($r_RCV_MIX_SKU == 'N'){
|
|
|
+ $TABLE_INV_LOT_LOC_ID = DB::connection('oracle')->select(DB::raw("SELECT COUNT(*) FROM INV_LOT_LOC_ID a INNER JOIN view_MultiWarehouse b ON a.locationid = b.LocationID WHERE b.WarehouseID = '".
|
|
|
+ $IN_Warehouse."' AND TraceID = '".$In_New_TraceID."' AND sku <> '".$In_SKU."' AND qty>0"));
|
|
|
+ if ($TABLE_INV_LOT_LOC_ID) return '273';
|
|
|
+ }elseif ($r_RCV_MIX_GR1 == 'N'){}//TODO 1065行
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return $OUT_Return_Code;
|
|
|
+ }
|
|
|
+
|
|
|
+ /** 对于快速入库 $IN_Parameter1 = 'RCV_AFTER' | 'RCV_BEFORE'
|
|
|
+ * 目前该SP只存在 RCV_AFTER(校验近期产品) 且已被注释
|
|
|
+ */
|
|
|
+ private function SPUDF_ProcessA($IN_Warehouse, $IN_Parameter1, $IN_Parameter2, $IN_Parameter3, $IN_Parameter4, $IN_Language, $IN_UserID, $OUT_Return_Code){
|
|
|
+ $r_CurrentTime = Carbon::now();
|
|
|
+
|
|
|
+ //TODO 状态为 分配之前 走此逻辑,本快速入库不存在分配之前 不会走此逻辑 保留一下
|
|
|
+ if ($IN_Parameter1='ALLOCATION_BEFORE'){
|
|
|
+ $doc_order_header = DB::connection('oracle')->select(DB::raw("SELECT t.Carrierid,t.soreference5 FROM DOC_ORDER_HEADER t WHERE ORDERNO='".$IN_Parameter2."'"));
|
|
|
+ $r_Carrierid = $doc_order_header[0]->carrierid;
|
|
|
+ $r_soreference5 = $doc_order_header[0]->soreference5;
|
|
|
+ if (in_array($r_Carrierid,['ZTO','YUNDA','POSTB','YTO','STO','EMS','SF']) && !$r_soreference5){
|
|
|
+ $OUT_Return_Code = '999面单号未获取!';
|
|
|
+ DB::rollBack();
|
|
|
+ return $OUT_Return_Code;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //TODO 状态为 导入后的逻辑:SPUDF_ProcessA 77行起 此处忽略 IN_Parameter1='SO_IMPORT_AFTER'
|
|
|
+
|
|
|
+ //TODO 装箱完成前,做一些数据处理:SPUDF_ProcessA 125行起 此处忽略 IN_Parameter1='PACKING_BEFORE'
|
|
|
+
|
|
|
+ //TODO 装箱完成后,做一些数据处理:SPUDF_ProcessA 132行起 此处忽略 IN_Parameter1='PACKING_AFTER'
|
|
|
+
|
|
|
+ //TODO 打印标记:SPUDF_ProcessA 281行起 此处忽略 IN_Parameter1='PRINT'
|
|
|
+
|
|
|
+ //TODO 发货前校验是否全部复核:SPUDF_ProcessA 553行起 此处忽略 IN_Parameter1='SHIP_BEFORE'
|
|
|
+
|
|
|
+ //TODO 转移时校验库位是否允许混放批次:SPUDF_ProcessA 594行起 此处忽略 IN_Parameter1='TRAPPROVE_BEFORE'
|
|
|
+
|
|
|
+ //TODO 分配之后,如果是单品单件订单,更新deliveryno:SPUDF_ProcessA 658行起 此处忽略 IN_Parameter1='ALLOCATION_AFTER'
|
|
|
+
|
|
|
+ //TODO 上架前,校验此货主是否必须有拣货位,如果无拣货位,则拦截 by mxl 20191205:SPUDF_ProcessA 675行起 此处忽略 IN_Parameter1='PA_BEFORE'
|
|
|
+
|
|
|
+ //TODO ASN关闭后 针对JIANSHANG货主,订单关闭后将数据写入临时表CUS_ADJ_H by mxl 20191217:SPUDF_ProcessA 700行起 此处忽略 IN_Parameter1='ASNCLOSE_AFTER'
|
|
|
+
|
|
|
+ //TODO SO关闭后 针对JIANSHANG货主,订单关闭后将数据写入临时表CUS_ADJ_H by mxl 20191217:SPUDF_ProcessA 734行起 此处忽略 IN_Parameter1='SHIP_AFTER'
|
|
|
+
|
|
|
+ $OUT_Return_Code = '000';
|
|
|
+ return $OUT_Return_Code;
|
|
|
+ }
|
|
|
+
|
|
|
+ private function GETSYS_configuration($IN_WarehouseID, $IN_CustomerID, $IN_OrderType, $IN_ConfigID, $IN_DefaultValue = 'N', $IN_ValueType = 'C')
|
|
|
+ {
|
|
|
+ if ($IN_ValueType == 'C'){
|
|
|
+ $sys_configuration = DB::connection('oracle')->select(DB::raw("SELECT VALUE_STRING FROM sys_configuration WHERE WarehouseID='".($IN_WarehouseID ?? '*')."' AND CustomerID='".($IN_CustomerID ?? '*')."' AND OrderType='".($IN_OrderType ?? '*')."' AND CONFIG_ID='".$IN_ConfigID."'"));
|
|
|
+ if (!$sys_configuration){
|
|
|
+ $sys_configuration = DB::connection('oracle')->select(DB::raw("SELECT VALUE_STRING FROM sys_configuration WHERE WarehouseID='".($IN_WarehouseID ?? '*')."' AND CustomerID='".($IN_CustomerID ?? '*')."' AND OrderType='*' AND CONFIG_ID='".$IN_ConfigID."'"));
|
|
|
+ if (!$sys_configuration){
|
|
|
+ $sys_configuration = DB::connection('oracle')->select(DB::raw("SELECT VALUE_STRING FROM sys_configuration WHERE WarehouseID='".($IN_WarehouseID ?? '*')."' AND CustomerID='*' AND OrderType='*' AND CONFIG_ID='".$IN_ConfigID."'"));
|
|
|
+ if (!$sys_configuration){
|
|
|
+ $sys_configuration = DB::connection('oracle')->select(DB::raw("SELECT VALUE_STRING FROM sys_configuration WHERE WarehouseID='*' AND CustomerID='*' AND OrderType='*' AND CONFIG_ID='".$IN_ConfigID."'"));
|
|
|
+ if (!$sys_configuration) return $IN_DefaultValue;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return trim($sys_configuration[0]->value_string);
|
|
|
+ }
|
|
|
+ $sys_configuration = DB::connection('oracle')->select(DB::raw("SELECT VALUE_INT FROM sys_configuration WHERE WarehouseID='".($IN_WarehouseID ?? '*')."' AND CustomerID='".($IN_CustomerID ?? '*')."' AND OrderType='".($IN_OrderType ?? '*')."' AND CONFIG_ID='".$IN_ConfigID."'"));
|
|
|
+ if (!$sys_configuration){
|
|
|
+ $sys_configuration = DB::connection('oracle')->select(DB::raw("SELECT VALUE_INT FROM sys_configuration WHERE WarehouseID='".($IN_WarehouseID ?? '*')."' AND CustomerID='".($IN_CustomerID ?? '*')."' AND OrderType='*' AND CONFIG_ID='".$IN_ConfigID."'"));
|
|
|
+ if (!$sys_configuration){
|
|
|
+ $sys_configuration = DB::connection('oracle')->select(DB::raw("SELECT VALUE_INT FROM sys_configuration WHERE WarehouseID='".($IN_WarehouseID ?? '*')."' AND CustomerID='*' AND OrderType='*' AND CONFIG_ID='".$IN_ConfigID."'"));
|
|
|
+ if (!$sys_configuration){
|
|
|
+ $sys_configuration = DB::connection('oracle')->select(DB::raw("SELECT VALUE_INT FROM sys_configuration WHERE WarehouseID='*' AND CustomerID='*' AND OrderType='*' AND CONFIG_ID='".$IN_ConfigID."'"));
|
|
|
+ if (!$sys_configuration) return $IN_DefaultValue;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return trim($sys_configuration[0]->value_string);
|
|
|
+ }
|
|
|
}
|