getTranslate('delete');//'删除'; $status[1] = Ec_Lang::getInstance()->getTranslate('Draft');//'草稿'; $status[2] = Ec_Lang::getInstance()->getTranslate('Confirm');//'确认'; $status[3] = Ec_Lang::getInstance()->getTranslate('PendingAudit');//'待审核'; $status[4] = Ec_Lang::getInstance()->getTranslate('Audited');//'已审核'; $status[5] = Ec_Lang::getInstance()->getTranslate('onway');//'在途'; $status[6] = Ec_Lang::getInstance()->getTranslate('ReceiptOf');//'收货中'; $status[7] = Ec_Lang::getInstance()->getTranslate('ReceiptComplete');//'收货完成'; return $status; } public static $itemStatus = array( 0 => 'Awaiting', 1 => 'Receiving', 2 => 'Finished', ); public static $AsnType = array( 0 => 'Normal', 1 => 'By Po', 2 => 'Refund', 3 => 'Reject', 4 => 'Return', ); public static function getAsnType(){ $status[0] = Ec_Lang::getInstance()->getTranslate('Standard');//'标准'; //$status[1] = Ec_Lang::getInstance()->getTranslate('OrdersReturns');//'订单退货'; //$status[2] = Ec_Lang::getInstance()->getTranslate('SpecifyTheProductBackPieces');//'指定产品退件'; //$status[3] = Ec_Lang::getInstance()->getTranslate('Transit');//'中转'; return $status; } public static $applicationType = array( 1 => 'avrived', 2 => 'receive', 3 => 'putaway', ); //异常状态 public static $underreviewStatus = array( 0 => 'Normal', //无 1 => 'Abnormal', ); public function __construct($pro = 'BHR') { $this->setCustomer(); $this->_pro = $pro; $this->_date = date('Y-m-d H:i:s'); } private function setCustomer($customerId = '') { $customerService = new Service_Customer(); if (!isset($this->_customerId) && $customerId == '') { $customerInfo = $customerService->getLoginInfo(); $customerRow = $customerInfo->customer; } elseif ($customerId != '') { $customerRow = $customerService->getByField($customerId); } $this->_customerId = $customerRow['customer_id']; $this->_customerInfo = $customerRow; } /** * @author william-fan * @todo 创建一条新的 ASN 信息 事务处理 (备货模式) * @param $order ASN ,$item ASN产品 ,$customerId 客户ID * @return array('ask' => 0, 'msg' => '','Error'=>array(array('errorCode'=>'','errorMessage')), 'ASNCode' => ''); */ public function createTransaction($data,$customerId = '', $warehouseId = '') { $result = array('ask' => 0, 'msg' => '', 'error' => array(), 'ASNCode' => ''); //exit('ffsss'); $data['customerId'] = $customerId; $error = self::validate($data,$customerId); //var_dump($error); //exit('cccnnn'); if(!empty($error)){ $result['error'] = $error; return $result; } //exit('fff00sssf'); try { $DB = Common_Common::getAdapter(); $DB->beginTransaction(); $date = date('Y-m-d H:i:s'); if (isset($data['ref_code']) && $data['ref_code'] != '') { $r = self::checkReferenceNo(array('reference_no' => $data['ref_code'], 'customer_id' => $customerId,'receiving_status_arr'=>array('1','2','3','4','5','6','7'))); if (!empty($r)) { throw new Exception(Ec_Lang::getInstance()->getTranslate('CustomerReferenceNumberExistence')); } } if ($customerId) { $this->setCustomer($customerId); } if ($this->_customerInfo['customer_status'] != 2) { throw new Exception(Ec_Lang::getInstance()->getTranslate('AccountIsNotActivated')); } if ($warehouseId) { $this->_warehouseId = $warehouseId; } $ASNCode = self::createCode(); $receiving['receiving_code'] = $ASNCode; $receiving['reference_no'] = $data['ref_code']; $receiving['warehouse_id'] = $warehouseId; $receiving['customer_id'] = $customerId; $receiving['customer_code'] = $this->_customerInfo['customer_code']; $receiving['receiving_type'] = isset($data['receiving_type'])?$data['receiving_type']:'0'; $receiving['receiving_status'] = '1'; $receiving['receiving_add_time']= $date; $receiving['is_delivery'] = $data['is_delivery']; //以下新增的内容 //$receiving['refercence_form_id']= $data['refercence_form_id']; $receiving['ie_port'] = $data['ie_port']; $receiving['form_type'] = $data['form_type']; $receiving['traf_name'] = $data['traf_name']; $receiving['wrap_type'] = $data['wrap_type']; $receiving['pack_no'] = $data['pack_no']; $receiving['traf_mode'] = $data['traf_mode']; $receiving ['trade_mode'] = $data ['trade_mode']; $receiving ['trans_mode'] = $data ['trans_mode']; $receiving['roughweight'] = $data['roughweight']; //$receiving['netweight'] = $data['netweight']; /* if ($data ['haveconta'] == '1') { $receiving ['haveconta'] = '1'; $receiving ['conta_id'] = $data ['conta_id']; $receiving ['conta_model'] = $data ['conta_model']; $receiving ['conta_wt'] = $data ['conta_wt']; } else { $receiving ['haveconta'] = '0'; $receiving ['conta_id'] = ''; $receiving ['conta_model'] = ''; $receiving ['conta_wt'] = '0'; } */ $receiving ['haveconta'] = '0'; $receiving ['conta_id'] = ''; $receiving ['conta_model'] = ''; $receiving ['conta_wt'] = '0'; $receiving ['receiving_description'] = $data ['instructions']; $receiving['receive_model_type'] = '0'; if (! isset ( $receiving ['receiving_type'] ) || $receiving ['receiving_type'] === '') { throw new Exception (Ec_Lang::getInstance()->getTranslate('ASNTypeIsEmpty')); } /* * $receiving['receiving_status'] = * isset($data['receiving_status'])?$data['receiving_status']:'0'; * $receiving['receiving_description'] = $data['instructions']; * $receiving['receiving_add_time'] = $date; * $receiving['refercence_form_id'] = $data['refercence_form_id']; * $receiving['ie_port'] = $data['ie_port']; * $receiving['form_type'] = $data['form_type']; * $receiving['traf_name'] = $data['traf_name']; * $receiving['wrap_type'] = $data['wrap_type']; * $receiving['pack_no'] = $data['pack_no']; * $receiving['traf_mode'] = $data['traf_mode']; * $receiving['trade_mode'] = $data['trade_mode']; * $receiving['trans_mode'] = $data['trans_mode']; * $receiving['conta_id'] = $data['conta_id']; * $receiving['conta_model'] = $data['conta_model']; * $receiving['conta_wt'] = $data['conta_wt']; */ if ($warehouseId === '') { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehouseIsEmpty')); } $warehouse = Common_DataCache::getWareHouse(); if (!isset($warehouse[$warehouseId])) { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehousingDoesNotExist')); } if (!isset($receiving['customer_id']) || $receiving['customer_id'] == '') { $receiving['customer_id'] = $this->_customerId; } $receiving_id = Service_Receiving::add($receiving); /* echo $receiving_id; $DB->rollBack(); exit; */ //receiving_detail $session = new Zend_Session_Namespace('customerAuth'); $sessionData = $session->data; $customerCode = $sessionData['code']; $product_sku = $data['product_sku']; $sku = $data['sku']; $haveDeclare = false; if(isset($data['declared_value'])){ $haveDeclare=true; $declare =$data['declared_value']; } /*if(isset($data['is_new_goods_id'])){ $haveNewGoodId=true; $isNewGoodsId =$data['is_new_goods_id']; }*/ if(isset($data['hs_code'])){ $haveHsCode=true; $HsCode =$data['hs_code']; } if(isset($data['hs_goods_name'])){ $haveHsGoodsName=true; $HsGoodsName =$data['hs_goods_name']; } if(isset($data['g_model'])){ $haveGmodel=true; $Gmodel =$data['g_model']; } foreach ($product_sku as $k=>$v) { $productList = Service_Product::getByCondition(array('product_sku'=>$v,'customer_code'=>$this->_customerInfo['customer_code']),"*"); //$product = Service_Product::getByField($v,'product_sku'); $product = $productList[0]; if($haveDeclare){ $declare_vale = $declare[$k]; }else{ $declare_vale = $product['product_declared_value']; } $hs_code = ""; if($haveHsCode){ $hs_code = $HsCode[$k]; if($hs_code!=$product['hs_code']) throw new Exception("sku[".$v."]的海关编码[".$hs_code."]与原海关编码[".$product['hs_code']."]不一致!"); } $hs_goods_name = ""; if($haveHsGoodsName){ $hs_goods_name = $HsGoodsName[$k]; } $g_model = ""; if($haveGmodel){ $g_model = $Gmodel[$k]; } $hemList = Service_HsElementMap::getByCondition(array('product_id'=>$product['product_id']), 'hem_detail'); $elements = array(); foreach($hemList as $hemRow){ if($hemRow['hem_detail']!="") $elements[] = $hemRow['hem_detail']; } $existGmodel = implode('|',$elements); $is_new_goods_id = 0; $goods_id = $product['goods_id']; if($haveHsCode&&$haveHsGoodsName&&$haveGmodel){ if(($hs_code!=""&&$hs_code!=$product['hs_code'])||($hs_goods_name!=""&&$hs_goods_name!=$product['hs_goods_name'])||($g_model!=""&&$existGmodel!=$g_model)){ $con = array( 'product_id'=>$k, 'hs_code'=>$hs_code, 'hs_goods_name'=>$hs_goods_name, 'g_model'=>$g_model ); $exGoods = Service_Goods::getByCondition($con,"*"); if(empty($exGoods)){ $is_new_goods_id = 1; $goods_id = Service_CustomerProcess::generateGoodsId($product['customer_id'], $product['has_invoice']); }else{ $goods_id = $exGoods[0]['goods_id']; } } } $receivingDetail = array( 'receiving_id'=>$receiving_id, 'receiving_code'=>$ASNCode, 'rd_status'=>'0', 'product_id'=>$product['product_id'], 'product_barcode'=>$product['product_barcode'], 'op_declared_value'=>trim($declare_vale), 'rd_receiving_qty'=>trim($sku[$k]), 'rd_add_time'=>$date, 'rd_goods_id'=>$goods_id, ); if($is_new_goods_id){ $goodsRow = array( 'product_id'=>$k, 'goods_id'=>$goods_id, 'hs_code'=>$hs_code, 'hs_goods_name'=>$hs_goods_name, 'g_model'=>$g_model ); Service_Goods::add($goodsRow); } $receivingDetailArr[] = $receivingDetail; if(!Service_ReceivingDetail::add($receivingDetail)){ throw new Exception(Ec_Lang::getInstance()->getTranslate('AddASNDetailsFail')); } } $note = 'create'; foreach ($receivingDetailArr as $val) { $productRow = Service_Product::getByField($val['product_id'], 'product_id', array('product_sku')); $note .= ' sku:' . $productRow['product_sku'] . ' quantity:' . $val['rd_receiving_qty'] . ' '; } $ASNLog = array( 'receiving_id'=>$receiving_id, 'receiving_code' => $ASNCode, 'user_id'=>'-1', 'customer_code' => $this->_customerInfo['customer_code'], 'rl_note' => $note, 'rl_add_time'=>$date, 'rl_status_from'=>'1', 'rl_status_to'=>'1', 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); $result['ask']='1'; $result['msg'] = "收货订单[{$ASNCode}]创建成功."; //'ASN创建成功'; $result['ASNCode'] = $ASNCode; //$DB->rollBack(); $DB->commit(); } catch (Exception $e) { $DB->rollBack(); $result['error'][] = $e->getMessage(); $result['msg'] = $e->getMessage(); return $result; } return $result; } public function createPoAsn($data,$insertId,$customerId = '', $warehouseId = '') { $result = array('ask' => 0, 'msg' => '', 'error' => array(), 'ASNCode' => ''); //exit('ffsss'); $supllierSession= Service_Customer::getLoginInfo(); $supllier=$supllierSession->data; $data['customerId'] = $customerId; $error = self::validatePoAsn($data,$customerId); if(!empty($error)){ $result['error'] = $error; return $result; } //exit('fff00sssf'); try { $date = date('Y-m-d H:i:s'); if (isset($data['ref_code']) && $data['ref_code'] != '') { $r = self::checkReferenceNo(array('reference_no' => $data['ref_code'], 'customer_id' => $customerId,'receiving_status_arr'=>array('1','2','3','4','5','6','7'))); if (!empty($r)) { throw new Exception(Ec_Lang::getInstance()->getTranslate('CustomerReferenceNumberExistence')); } } if (empty($customerId)) { throw new Exception('客户ID不能为空'); }else{ $this->setCustomer($customerId); } if ($this->_customerInfo['customer_status'] != 2) { throw new Exception(Ec_Lang::getInstance()->getTranslate('AccountIsNotActivated')); } if ($warehouseId) { $this->_warehouseId = $warehouseId; } $customerInfo= Service_Customer::getByField($customerId); $ASNCode = self::createCode(); $receiving['receiving_code'] = $ASNCode; $receiving['reference_no'] = $data['ref_code']; $receiving['warehouse_id'] = $warehouseId; $receiving['customer_id'] = $customerId; $receiving['customer_code'] = $customerInfo['customer_code']; $receiving['receiving_type'] = isset($data['receiving_type'])?$data['receiving_type']:'0'; $receiving['receiving_status'] = '3'; $receiving['receiving_add_time']= $date; $receiving['is_delivery'] = $data['is_delivery']; //以下新增的内容 //$receiving['refercence_form_id']= $data['refercence_form_id']; $receiving['ie_port'] = $data['ie_port']; $receiving['form_type'] = $data['form_type']; $receiving['traf_name'] = $data['traf_name']; $receiving['wrap_type'] = $data['wrap_type']; $receiving['pack_no'] = $data['pack_no']; $receiving['traf_mode'] = $data['traf_mode']; $receiving ['trade_mode'] = $data ['trade_mode']; $receiving ['trans_mode'] = $data ['trans_mode']; $receiving['roughweight'] = $data['roughweight']; //$receiving['netweight'] = $data['netweight']; /* if ($data ['haveconta'] == '1') { $receiving ['haveconta'] = '1'; $receiving ['conta_id'] = $data ['conta_id']; $receiving ['conta_model'] = $data ['conta_model']; $receiving ['conta_wt'] = $data ['conta_wt']; } else { $receiving ['haveconta'] = '0'; $receiving ['conta_id'] = ''; $receiving ['conta_model'] = ''; $receiving ['conta_wt'] = '0'; } */ $receiving ['haveconta'] = '0'; $receiving ['conta_id'] = ''; $receiving ['conta_model'] = ''; $receiving ['conta_wt'] = '0'; $receiving['supplier_id']=$supllier['id']; $receiving ['receiving_description'] = $data ['instructions']; $receiving['receive_model_type'] = '0'; if (! isset ( $receiving ['receiving_type'] ) || $receiving ['receiving_type'] === '') { throw new Exception (Ec_Lang::getInstance()->getTranslate('ASNTypeIsEmpty')); } /* * $receiving['receiving_status'] = * isset($data['receiving_status'])?$data['receiving_status']:'0'; * $receiving['receiving_description'] = $data['instructions']; * $receiving['receiving_add_time'] = $date; * $receiving['refercence_form_id'] = $data['refercence_form_id']; * $receiving['ie_port'] = $data['ie_port']; * $receiving['form_type'] = $data['form_type']; * $receiving['traf_name'] = $data['traf_name']; * $receiving['wrap_type'] = $data['wrap_type']; * $receiving['pack_no'] = $data['pack_no']; * $receiving['traf_mode'] = $data['traf_mode']; * $receiving['trade_mode'] = $data['trade_mode']; * $receiving['trans_mode'] = $data['trans_mode']; * $receiving['conta_id'] = $data['conta_id']; * $receiving['conta_model'] = $data['conta_model']; * $receiving['conta_wt'] = $data['conta_wt']; */ if ($warehouseId === '') { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehouseIsEmpty')); } $warehouse = Common_DataCache::getWareHouse(); if (!isset($warehouse[$warehouseId])) { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehousingDoesNotExist')); } $receiving_id = Service_Receiving::add($receiving); $product_sku = $data['product_sku']; $haveDeclare = false; if(isset($data['declared_value'])){ $haveDeclare=true; $declare =$data['declared_value']; } foreach ($product_sku as $k=>$v) { $productList = Service_Product::getByCondition(array('product_sku'=>$v,'customer_code'=>$customerInfo['customer_code']),"*"); //$product = Service_Product::getByField($v,'product_sku'); $product = $productList[0]; if($haveDeclare){ $declare_vale = $declare[$k]; }else{ $declare_vale = $product['product_declared_value']; } $receivingDetail = array( 'receiving_id'=>$receiving_id, 'receiving_code'=>$ASNCode, 'rd_status'=>'0', 'product_id'=>$product['product_id'], 'product_barcode'=>$product['product_barcode'], 'op_declared_value'=>$product['product_declared_value'], 'rd_receiving_qty'=>$data['num'][$k], 'rd_add_time'=>$date ); $receivingDetailArr[] = $receivingDetail; if(!Service_ReceivingDetail::add($receivingDetail)){ throw new Exception(Ec_Lang::getInstance()->getTranslate('AddASNDetailsFail')); } } $note = 'create'; foreach ($receivingDetailArr as $val) { $productRow = Service_Product::getByField($val['product_id'], 'product_id', array('product_sku')); $note .= ' sku:' . $productRow['product_sku'] . ' quantity:' . $val['rd_receiving_qty'] . ' '; } $ASNLog = array( 'receiving_id'=>$receiving_id, 'receiving_code' => $ASNCode, 'user_id'=>'-1', 'customer_code' =>$customerInfo['customer_code'], 'rl_note' => $note, 'rl_add_time'=>$date, 'rl_status_from'=>'1', 'rl_status_to'=>'1', 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); if($receiving['trade_mode']=="9610"||$receiving['trade_mode']=="1210"){ $goodsIdArr = Service_ReceivingDetail::getGoodsId($receiving['receiving_code']); $sumNetWeight = Service_ReceivingDetail::sumNetWeight($receiving['receiving_code']); $goodsIdArr = array_chunk($goodsIdArr,35); $subIndex = 1; $gross_wt = ($receiving['roughweight']-$sumNetWeight)/count($goodsIdArr); foreach($goodsIdArr as $gk=>$gv){ if($subIndex<10){ $sub_receiving_code = $receiving['receiving_code']."-0".$subIndex; }else{ $sub_receiving_code = $receiving['receiving_code']."-".$subIndex; } $subIndex++; $receivingXml = array( 'receiving_code'=>$receiving['receiving_code'], 'sub_receiving_code'=>$sub_receiving_code, 'gross_wt'=>'0', 'net_wt'=>'0', 'pack_no'=>'0', 'refercence_form_id'=>'', 'rx_add_time'=>date("Y-m-d H:i:s"), 'receiving_xml_status'=>'3', ); Service_ReceivingXml::add($receivingXml); $RXdbObj = new Table_ReceivingXml(); $rxId = $RXdbObj->getAdapter()->lastInsertId(); $net_wt = 0; $pack_no = 0; $G_NO_index = 1; foreach($gv as $goods_id){ $productList = Service_ReceivingDetail::getJoinProductByCondition(array('goods_id'=>$goods_id,'receiving_code'=>$receiving['receiving_code'])); $productRow = Service_Product::getByField($productList[0]['product_id'],'product_id',"*"); $currencyRow = Service_Currency::getByField($productRow['currency_code'],'currency_code',"*"); $receivingXmlDetail = array( 'rx_id'=>$rxId, 'from_id'=>$receiving['receiving_code'], 'sub_receiving_code'=>$sub_receiving_code, 'g_no'=>$G_NO_index, 'goods_id'=>$productList[0]['goods_id'], 'merger_g_no'=>$G_NO_index, 'code_ts'=>$productList[0]['hs_code'], 'g_name_cn'=>$productList[0]['hs_goods_name'], //'decl_price'=>"", 'curr'=>$currencyRow['currency_hs_code'], 'qty_1'=>0, 'unit_1'=>'', 'qty_2'=>'', 'unit_2'=>'', ); $g_qty = 0; $decl_total = 0; $decl_price = 0; foreach($productList as $p){ if($receiving['receive_model_type']=="1"){ $quantity = $p['op_quantity']; $g_qty+=$p['op_quantity']; }else{ $quantity = $p['rd_receiving_qty']; $g_qty+=$p['rd_receiving_qty']; } $hemList = Service_HsElementMap::getByCondition(array('product_id'=>$p['product_id']), 'hem_detail'); $elements = array(); foreach($hemList as $hemRow) $elements[] = $hemRow['hem_detail']; $receivingXmlDetail['g_model'] = implode('|',$elements); $hs_uom_map = Service_HsUomMap::getByField($p['product_id'],'product_id',"*"); $quantitylaw1 = isset($hs_uom_map['hum_quantity_law'])?$hs_uom_map['hum_quantity_law']:'0'; $receivingXmlDetail['qty_1'] += $quantitylaw1*$quantity; $quantitylaw2 = isset($hs_uom_map['hum_quantity_second'])?$hs_uom_map['hum_quantity_second']:"0"; $receivingXmlDetail['qty_2'] += $quantitylaw2*$quantity; if(!empty($hs_uom_map)) $hs_uom = Service_HsUom::getByField($hs_uom_map['hu_id'],'hu_id',"*"); $receivingXmlDetail['unit_1'] = isset($hs_uom['pu_code_law'])?$hs_uom['pu_code_law']:""; $receivingXmlDetail['unit_2'] = isset($hs_uom['pu_code_second'])?$hs_uom['pu_code_second']:""; $product = Service_Product::getByField($p['product_id'],"product_id","*"); $decl_total += $product['product_declared_value']*$quantity; $receivingXmlDetail['g_unit'] = $product['pu_code']; } $pack_no+=$g_qty; $ntWeight = Service_ReceivingDetail::calNetWeightByCondition(array('goods_id'=>$goods_id,'receiving_code'=>$receiving['receiving_code'])); $net_wt+= $ntWeight; $decl_price = sprintf("%.4f",$decl_total/$g_qty); $receivingXmlDetail['decl_price'] = $decl_price; $receivingXmlDetail['g_qty'] = $g_qty; $receivingXmlDetail['decl_total'] = $decl_total; Service_ReceivingXmlDetail::add($receivingXmlDetail); $G_NO_index++; } $updateReceivingXml = array( 'gross_wt'=>$net_wt+$gross_wt, 'net_wt'=>$net_wt, 'pack_no'=>$pack_no, ); Service_ReceivingXml::update($updateReceivingXml,$sub_receiving_code,'sub_receiving_code'); $aMessage['fmt_code'] = 'MRK'; $aMessage['fmt_type'] = 'BSG011'; $aMessage['refercence_no'] = $sub_receiving_code; $aMessage['fml_status'] = 1; $aMessage['fml_add_time'] = date('Y-m-d H:i:s'); Service_FtpMessageSendlist::add($aMessage); } } foreach($insertId as $s=>$poTrakcingId){ Service_PoOrderTracking::update(array('is_created_asn'=>1,'receiving_id'=>$receiving_id), $poTrakcingId); } if($receiving['is_delivery']=='1'){ //提货的ASN要提货费 //冻结提货费 $objOtherCalculte = new Common_CalculateOtherFee(); $keys = array( 'warehouseId' => $receiving['warehouse_id'], 'receiving_code'=>$ASNCode, ); $objOtherCalculte->setParams($keys); $otherfeeArr = $objOtherCalculte->getOtherFee('TIHUO'); $otherfee_tihuo = $otherfeeArr['data']['otherFee']['tihuo']; if($otherfee_tihuo['price']>0){ $balanceProcess = new Service_CustomerBalanceProcess(); $feeResult = $balanceProcess->freezeASNFee($ASNCode, $customerInfo['customer_id'],$receiving); if($feeResult !== true) { throw new Exception($feeResult); } } } $law_weight = Service_ReceivingDetail::sumLawWeight($ASNCode); if($law_weight > $receiving['roughweight']) { throw new Exception('法定单位为千克的SKU的总重量大于ASN毛重，请修改SKU的法定单位重量'); } if($customerInfo['customer_platform']=="FX"){ $ftpMessageSendlistRow = array( 'fmt_code'=>'ASNSH-TO-FX', 'fmt_type'=>'FXSYS', 'refercence_no'=>$ASNCode, 'fml_status'=>'1', 'fml_add_time'=>date("Y-m-d H:i:s"), ); Service_FtpMessageSendlist::add($ftpMessageSendlistRow); $ftpMessageSendlistRow = array( 'fmt_code'=>'ASNWCSH-TO-FX', 'fmt_type'=>'FXSYS', 'refercence_no'=>$ASNCode, 'fml_status'=>'1', 'fml_add_time'=>date("Y-m-d H:i:s"), ); Service_FtpMessageSendlist::add($ftpMessageSendlistRow); } $result['ask']='1'; $result['msg'] = "收货订单[{$ASNCode}]创建成功."; //'ASN创建成功'; $result['ASNCode'] = $ASNCode; //$DB->rollBack(); } catch (Exception $e) { $result['error'][] = $e->getMessage(); $result['msg'] = $e->getMessage(); return $result; } return $result; } /** * @author william-fan * @todo 创建集货货模式的ASN */ public function createjihuoTransaction($data,$customerId = '', $warehouseId = ''){ $result = array('ask' => 0, 'msg' => '', 'error' => array(), 'ASNCode' => ''); //exit('ffsss'); //exit('fff00sssf'); $session = new Zend_Session_Namespace('customerAuth'); $sessionData = $session->data; try { $DB = Common_Common::getAdapter(); $DB->beginTransaction(); $error = self::validate($data,$customerId); $errorOrder = self::validOrder($data); $errorAll = array_merge($error,$errorOrder['error']); if(!empty($errorAll)){ $result['error'] = $errorAll; $result['detail'] = $errorOrder['detail']; throw new Exception("错误"); //return $result; } $date = date('Y-m-d H:i:s'); if (isset($data['ref_code']) && $data['ref_code'] != '') { $r = self::checkReferenceNo(array('reference_no' => $data['ref_code'], 'customer_id' => $customerId,'receiving_status_arr'=>array('1','2','3','4','5','6','7'))); if (!empty($r)) { throw new Exception(Ec_Lang::getInstance()->getTranslate('CustomerReferenceNumberExistence')); } } if ($customerId) { $this->setCustomer($customerId); } if ($this->_customerInfo['customer_status'] != 2) { throw new Exception(Ec_Lang::getInstance()->getTranslate('AccountIsNotActivated')); } if ($warehouseId) { $this->_warehouseId = $warehouseId; } $ASNCode = self::createCode(); $receiving['receiving_code'] = $ASNCode; $receiving['reference_no'] = $data['ref_code']; $receiving['warehouse_id'] = $warehouseId; $receiving['customer_id'] = $customerId; $receiving['customer_code'] = $this->_customerInfo['customer_code']; $receiving['receiving_type'] = isset($data['receiving_type'])?$data['receiving_type']:'0'; $receiving['receiving_status'] = '1'; $receiving['receiving_add_time']= $date; $receiving['receiving_update_time'] = date("Y-m-d H:i:s"); $receiving['is_delivery'] = $data['is_delivery']; //以下新增的内容 //$receiving['refercence_form_id']= $data['refercence_form_id']; $receiving['ie_port'] = $data['ie_port']; $receiving['form_type'] = $data['form_type']; $receiving['traf_name'] = $data['traf_name']; $receiving['wrap_type'] = $data['wrap_type']; $receiving['pack_no'] = $data['pack_no']; $receiving['traf_mode'] = $data['traf_mode']; $receiving ['trade_mode'] = $data ['trade_mode']; $receiving ['trans_mode'] = $data ['trans_mode']; $receiving['roughweight'] = $data['roughweight']; //$receiving['netweight'] = $data['netweight']; /* if ($data ['haveconta'] == '1') { $receiving ['haveconta'] = '1'; $receiving ['conta_id'] = $data ['conta_id']; $receiving ['conta_model'] = $data ['conta_model']; $receiving ['conta_wt'] = $data ['conta_wt']; } else { $receiving ['haveconta'] = '0'; $receiving ['conta_id'] = ''; $receiving ['conta_model'] = ''; $receiving ['conta_wt'] = '0'; } */ $receiving ['haveconta'] = '0'; $receiving ['conta_id'] = ''; $receiving ['conta_model'] = ''; $receiving ['conta_wt'] = '0'; $receiving['receive_model_type'] = '1'; $receiving ['receiving_description'] = $data ['instructions']; if (! isset ( $receiving ['receiving_type'] ) || $receiving ['receiving_type'] === '') { throw new Exception (Ec_Lang::getInstance()->getTranslate('ASNTypeIsEmpty')); } if ($warehouseId === '') { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehouseIsEmpty')); } $warehouse = Common_DataCache::getWareHouse(); if (!isset($warehouse[$warehouseId])) { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehousingDoesNotExist')); } if (!isset($receiving['customer_id']) || $receiving['customer_id'] == '') { $receiving['customer_id'] = $this->_customerId; } $receiving_id = Service_Receiving::add($receiving); /* echo $receiving_id; $DB->rollBack(); exit; */ //receiving_detail //增加到receiving_order_detail表中 asn和订单关联表 /*$rab = array( 'receiving_id'=>$receiving_id, 'receiving_code'=>$ASNCode, 'onway_time'=>date("Y-m-d H:i:s") ); Service_ReceivingAttribute::add($rab);*/ $asnOrders = $data['asn_order']; //$sku = $data['sku']; foreach ($asnOrders as $keyo=>$orderCode) { //$product = Service_Product::getByField($v,'product_sku'); $orderInfo = Service_Orders::getByField($orderCode,'order_code'); $receiving_order_detail = array( 'receiving_id'=>$receiving_id, 'receiving_code'=>$ASNCode, 'rd_status'=>'0', 'order_code'=>$orderCode, 'rd_add_time'=>$date ); $receivingOrderDetailArr[] = $receiving_order_detail; if(!Service_ReceivingOrderDetail::add($receiving_order_detail)){ throw new Exception(Ec_Lang::getInstance()->getTranslate('AddASNDetailsFail')); } //修改订单到已提交状态 $orderRow = array( 'order_status'=>'4', 'update_time'=>$date ); Service_Orders::update($orderRow, $orderCode,'order_code'); $ol_type = 1; if($orderInfo['order_status']!=4){ $ol_type = 0; } $logRow = array( 'order_id'=>$orderInfo['order_id'], 'order_code'=>$orderInfo['order_code'], 'ol_type'=>$ol_type, 'order_status_from'=>$orderInfo['order_status'], 'order_status_to'=>4, 'ol_add_time'=>date('Y-m-d H:i:s'), 'user_id'=>'-1', 'account_id' => Service_Login::getUserId(), 'ol_ip'=>Common_Common::getIP() ); Service_OrderLog::add($logRow); $w = Service_Warehouse::getByField($orderInfo['warehouse_id'],'warehouse_id','*'); $shipOrderTracking = array( 'order_code'=>$orderInfo['order_code'], 'sot_location'=>"客户仓库", 'sot_add_time'=>date("Y-m-d H:i:s"), 'warehouse_id'=>$orderInfo['warehouse_id'], 'sot_description'=>'集货ASN新建成功,集货订单自动提交', 'sot_type'=>'0', 'sot_time_offset'=>'', 'tracking_number'=>$orderInfo['order_code'], 'ref_tracking_number'=>'', 'status_desc'=>'已提交', 'user_id'=>-1*$sessionData['id'] ); Service_ShipOrderTracking::add($shipOrderTracking); $orderOperationTime = array( 'order_id'=>$orderInfo['order_id'], 'order_code'=>$orderCode, 'submit_time'=>date("Y-m-d H:i:s"), 'submit_user_id'=>-1*$sessionData['id'] ); Service_OrderOperationTime::update($orderOperationTime,$orderCode,"order_code"); //预扣费 $balanceProcess = new Service_CustomerBalanceProcess(); $feeResult = $balanceProcess->freezeFee($orderCode, $customerId); if($feeResult !== true) throw new Exception($feeResult); } $note = 'create ASN'; /* foreach ($receivingOrderDetailArr as $val) { $productRow = Service_Product::getByField($val['product_id'], 'product_id', array('product_sku')); $note .= ' sku:' . $productRow['product_sku'] . ' quantity:' . $val['rd_receiving_qty'] . ' '; } */ $ASNLog = array( 'receiving_id'=>$receiving_id, 'receiving_code' => $ASNCode, 'user_id'=>'-1', 'customer_code' => $this->_customerInfo['customer_code'], 'rl_note' => $note, 'rl_add_time'=>$date, 'rl_status_from'=>'1', 'rl_status_to'=>'1', 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); $result['ask']='1'; $result['msg'] = "收货单号:{$ASNCode}创建成功"; //Ec_Lang::getInstance()->getTranslate('ASNCreatingSuccess'); //'ASN创建成功'; $result['ASNCode'] = $ASNCode; //$DB->rollBack(); $DB->commit(); } catch (Exception $e) { $DB->rollBack(); $result['error'][] = $e->getMessage(); $result['msg'] = $e->getMessage(); return $result; } return $result; } /** * @author william-fan * @todo 用于添加asn详情 * @return array('ask'=>0,'Error'=>array()); */ public function createAsnDetail($asnCode = '', $itemArr = array()) { $return = array('ask' => 0, 'Error' => array()); $addItem = array( 'receiving_code' => $asnCode, 'created' => date('Y-m-d H:i:s'), 'status' => 0 ); //print_r($itemArr); $productIds = $errorArr = array(); foreach ($itemArr as $key => $val) { if (!in_array($val['product_id'], $productIds)) { $productIds[] = $val['product_id']; } else { $errorArr[] = 'No.' . ($key + 1) . ' 产品存在.'; continue; } $result = $this->checkProductStatus($val['product_id']); //var_dump($result.'ss'); if (!isset($result['productInfo']['product_sku'])) { $errorArr[] = array( 'errorCode' => 20038, 'errorMessage' => 'No.' . ($key + 1) . ' product exists.' ); } if (isset($result['productInfo']['product_type']) && !in_array($result['productInfo']['product_type'], array('0', '2'))) { $errorArr[] = array( 'errorCode' => 20009, 'errorMessage' => 'SKU:' . $result['productInfo']['product_sku'] . ' type error.' ); } if ($result['ask'] == '0') { $errorArr[] = array( 'errorCode' => 20008, 'errorMessage' => 'Item ' . $key . ' can not be found.' ); continue; } if ($result['ask'] == '2') { $errorArr[] = array( 'errorCode' => 20010, 'errorMessage' => 'SKU: ' . $result['productInfo']['product_sku'] . ' can not be found.' ); continue; } $addItem['po'] = isset($val['po']) ? $val['po'] : ''; // $addItem['po_line'] = isset($val['po_line']) ? $val['po_line'] : ''; //po if (!empty($addItem['po'])) { $poRows = Merchant_Service_PurchaseOrder::getByCondition(array('po_code' => $addItem['po'], 'customer_id' => $this->_customerId), '*'); if (empty($poRows)) { $errorArr[] = array( 'errorCode' => 20011, 'errorMessage' => 'POCode: ' . $addItem['po'] . ' can not be found.' ); }else{ $poProductRows=Merchant_Service_PurchaseOrderProduct::getByCondition(array('po_id'=>$poRows[0]['po_id'],'product_id'=>$val['product_id']),'*'); if(empty($poProductRows)){ $errorArr[] = array( 'errorCode' => 20011, 'errorMessage' => 'POCode: ' . $addItem['po'] . ' The product does not match. '.$result['productInfo']['product_sku'] ); } } /* if (empty($addItem['po_line'])) { $errorArr[] = array( 'errorCode' => 20012, 'errorMessage' => 'POLine: ' . $addItem['po_line'] . ' can not be empty.' ); } */ } if (!empty($errorArr)) { continue; } $addItem['product_id'] = $val['product_id']; $addItem['order_qty'] = $val['order_qty']; $addItem['attribute'] = isset($val['attribute']) ? $val['attribute'] : ''; Service_ReceivingDetail::add($addItem); } if (!empty($errorArr)) { $return['Error'] = $errorArr; } else { $return['ask'] = 1; } return $return; } /* * 更新 ASN 信息（备货模式） * @param $order ASN ,$item ASN产品 ,$customerId 客户ID * @return array('ask' => 0, 'msg' => '', 'Error'=>array(),'ASNCode' => ''); */ public function updateTransaction($data,$customerId = '', $warehouseId = '') { $result = array('ask' => 0, 'msg' => '', 'error' => array(), 'ASNCode' => ''); $data['customerId'] = $customerId; $error = self::validate($data,$customerId); //var_dump($error); //exit('cccnnn'); if(!empty($error)){ $result['error'] = $error; return $result; } //print_r($data);var_dump($data['haveconta']=='1');exit; $date = date('Y-m-d H:i:s'); try { if (isset($order['ref_id'])) { unset($order['ref_id']); } $DB = Common_Common::getAdapter(); $DB->beginTransaction(); //var_dump($customerId); if ($customerId) { $this->setCustomer($customerId); } //var_dump($this->_customerInfo); $ASNCode = $data['ASNCode']; if (empty($ASNCode)) { throw new Exception('ASNCode '.Ec_Lang::getInstance()->getTranslate('DoesNotExist')); } $asnRows = Service_Receiving::getByCondition(array('receiving_code' => $ASNCode, 'customer_id' => $this->_customerId), '*'); $this->_receiving = $asnRows[0]; $this->_warehouseId = $asnRows[0]['warehouse_id']; if (empty($asnRows)) { throw new Exception('ASNCode:' . $ASNCode . ' can not be found.', 20013); } $ASNRow = $asnRows[0]; if (!in_array($ASNRow['receiving_status'], array('1')) || (isset($order['receiving_status']) && !in_array($ASNRow['receiving_status'], array('0', '1')))) { throw new Exception(Ec_Lang::getInstance()->getTranslate('CanNotBeModified').",ASNCode:" . $ASNCode . " ".Ec_Lang::getInstance()->getTranslate('StateDoesNotAllow')); } if (isset($data['warehouse_id']) && $data['warehouse_id'] == '') { throw new Exception("AsnCode:".Ec_Lang::getInstance()->getTranslate('WarehousingDoesNotExist').'.', 20007); } $warehouseAll = Common_DataCache::getWareHouse(); if (isset($order['warehouse_id']) && !isset($warehouseAll[$order['warehouse_id']])) { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehousingDoesNotExist')."."); } $order['modified'] = $date; //$receiving['receiving_code'] = $ASNCode; $receiving['reference_no'] = $data['ref_code']; //$receiving['warehouse_id'] = $warehouseId; //$receiving['customer_id'] = $customerId; //$receiving['customer_code'] = $this->_customerInfo['customer_code']; //$receiving['receiving_type'] = isset($data['receiving_type'])?$data['receiving_type']:'0'; //$receiving['receiving_add_time']= $date; $receiving['receiving_update_time'] = $date; $receiving['is_delivery'] = $data['is_delivery']; //以下新增的内容 //$receiving['refercence_form_id']= $data['refercence_form_id']; $receiving['ie_port'] = $data['ie_port']; $receiving['form_type'] = $data['form_type']; $receiving['traf_name'] = $data['traf_name']; $receiving['wrap_type'] = $data['wrap_type']; $receiving['pack_no'] = $data['pack_no']; $receiving['traf_mode'] = $data['traf_mode']; $receiving['trade_mode'] = $data['trade_mode']; $receiving['trans_mode'] = $data['trans_mode']; $receiving['roughweight'] = $data['roughweight']; $receiving['netweight'] = $data['netweight']; if($data['haveconta']=='1'){ $receiving['haveconta'] = '1'; $receiving['conta_id'] = $data['conta_id']; $receiving['conta_model'] = $data['conta_model']; $receiving['conta_wt'] = $data['conta_wt']; }else{ $receiving['haveconta'] = '0'; $receiving['conta_id'] = ''; $receiving['conta_model'] = ''; $receiving['conta_wt'] = '0'; } $receiving['receiving_description'] = $data['instructions']; $receiving['receiving_update_time'] = date("Y-m-d H:i:s"); Service_Receiving::update($receiving, $ASNCode, 'receiving_code'); $note = 'update'; $session = new Zend_Session_Namespace('customerAuth'); $sessionData = $session->data; $customerCode = $sessionData['code']; if(isset($data['product_sku'])){ $product_sku = $data['product_sku']; $sku = $data['sku']; $haveDeclare = false; if(isset($data['declared_value'])){ $haveDeclare=true; $declare =$data['declared_value']; } Service_ReceivingDetail::delete($ASNCode, 'receiving_code'); foreach ($product_sku as $k=>$v) { //$product = Service_Product::getByField($v,'product_sku'); $productList = Service_Product::getByCondition(array('product_sku'=>$v,'customer_code'=>$customerCode),"*"); //$product = Service_Product::getByField($v,'product_sku'); $product = $productList[0]; if($haveDeclare){ $declare_vale = $declare[$k]; }else{ $declare_vale = $product['product_declared_value']; } $receivingDetail = array( 'receiving_id'=>$ASNRow['receiving_id'], 'receiving_code'=>$ASNCode, 'rd_status'=>'0', 'product_id'=>$product['product_id'], 'product_barcode'=>$product['product_barcode'], 'op_declared_value'=>trim($declare_vale), 'rd_receiving_qty'=>trim($sku[$k]), 'rd_add_time'=>$date ); $receivingDetailArr[] = $receivingDetail; if(!Service_ReceivingDetail::add($receivingDetail)){ throw new Exception(Ec_Lang::getInstance()->getTranslate('AddASNDetailsFail')); } } foreach ($receivingDetailArr as $val) { $productRow = Service_Product::getByField($val['product_id'], 'product_id', array('product_sku')); $note .= ' sku:' . $productRow['product_sku'] . ' quantity:' . $val['rd_receiving_qty'] . ' '; } $ASNLog = array( 'receiving_id'=>$ASNRow['receiving_id'], 'receiving_code' => $ASNCode, 'user_id'=>'-1', 'customer_code' => $this->_customerInfo['customer_code'], 'rl_note' => $note, 'rl_status_from'=>$ASNRow['receiving_status'], 'rl_status_to'=>$ASNRow['receiving_status'], //'rl_add_time'=>date("Y-m-d H:i:s"), //'rl_ip'=>Common_Common::getIP() ); //print_r($ASNLog); self::createAsnLog($ASNLog); } //$DB->rollBack(); $DB->commit(); return array('ask' => 1, 'msg' => "收货订单[{$ASNCode}]".Ec_Lang::getInstance()->getTranslate('update').Ec_Lang::getInstance()->getTranslate('success').'.', 'error' => array(), 'ASNCode' => $ASNCode); } catch (Zend_Exception $e) { $DB->rollBack(); $result['error'][] = $e->getInternalError(); $result['msg'] = $e->getInternalError(); return $result; } catch (Exception $e) { $DB->rollBack(); $result['error'][] = $e->getMessage(); $result['msg'] = $e->getMessage(); return $result; } } /** * @author william-fan * @todo 用于集货模式的ASN更新 */ public function updatejihuoTransaction($data,$customerId = '', $warehouseId = ''){ $result = array('ask' => 0, 'msg' => '', 'error' => array(), 'ASNCode' => ''); $error = self::validate($data,$customerId); //var_dump($error); //exit('cccnnn'); if(!empty($error)){ $result['error'] = $error; return $result; } //print_r($data);var_dump($data['haveconta']=='1');exit; $date = date('Y-m-d H:i:s'); try { if (isset($order['ref_id'])) { unset($order['ref_id']); } $DB = Common_Common::getAdapter(); $DB->beginTransaction(); //var_dump($customerId); if ($customerId) { $this->setCustomer($customerId); } //var_dump($this->_customerInfo); $ASNCode = $data['ASNCode']; if (empty($ASNCode)) { throw new Exception('ASNCode '.Ec_Lang::getInstance()->getTranslate('DoesNotExist')); } $asnRows = Service_Receiving::getByCondition(array('receiving_code' => $ASNCode, 'customer_id' => $this->_customerId), '*'); $this->_receiving = $asnRows[0]; $this->_warehouseId = $asnRows[0]['warehouse_id']; if (empty($asnRows)) { throw new Exception('ASNCode:' . $ASNCode . ' can not be found.', 20013); } $ASNRow = $asnRows[0]; if (!in_array($ASNRow['receiving_status'], array('1')) || (isset($order['receiving_status']) && !in_array($ASNRow['receiving_status'], array('0', '1')))) { throw new Exception(Ec_Lang::getInstance()->getTranslate('CanNotBeModified').",ASNCode:" . $ASNCode . " ".Ec_Lang::getInstance()->getTranslate('StateDoesNotAllow')); } if (isset($data['warehouse_id']) && $data['warehouse_id'] == '') { throw new Exception("AsnCode:".Ec_Lang::getInstance()->getTranslate('WarehousingDoesNotExist').'.', 20007); } $warehouseAll = Common_DataCache::getWareHouse(); if (isset($order['warehouse_id']) && !isset($warehouseAll[$order['warehouse_id']])) { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehousingDoesNotExist')."."); } $order['modified'] = $date; //$receiving['receiving_code'] = $ASNCode; $receiving['reference_no'] = $data['ref_code']; //$receiving['warehouse_id'] = $warehouseId; //$receiving['customer_id'] = $customerId; //$receiving['customer_code'] = $this->_customerInfo['customer_code']; //$receiving['receiving_type'] = isset($data['receiving_type'])?$data['receiving_type']:'0'; //$receiving['receiving_add_time']= $date; $receiving['receiving_update_time'] = $date; $receiving['is_delivery'] = $data['is_delivery']; //以下新增的内容 //$receiving['refercence_form_id']= $data['refercence_form_id']; $receiving['ie_port'] = $data['ie_port']; $receiving['form_type'] = $data['form_type']; $receiving['traf_name'] = $data['traf_name']; $receiving['wrap_type'] = $data['wrap_type']; $receiving['pack_no'] = $data['pack_no']; $receiving['traf_mode'] = $data['traf_mode']; $receiving['trade_mode'] = $data['trade_mode']; $receiving['trans_mode'] = $data['trans_mode']; $receiving['roughweight'] = $data['roughweight']; $receiving['netweight'] = $data['netweight']; if($data['haveconta']=='1'){ $receiving['haveconta'] = '1'; $receiving['conta_id'] = $data['conta_id']; $receiving['conta_model'] = $data['conta_model']; $receiving['conta_wt'] = $data['conta_wt']; }else{ $receiving['haveconta'] = '0'; $receiving['conta_id'] = ''; $receiving['conta_model'] = ''; $receiving['conta_wt'] = '0'; } $receiving['receiving_description'] = $data['instructions']; $receiving['receiving_update_time'] = date("Y-m-d H:i:s"); Service_Receiving::update($receiving, $ASNCode, 'receiving_code'); $note = 'update'; $asnOrders = $data['asn_order']; //$sku = $data['sku']; /*得到原来的收货单的订单列表*/ $oldReceivingOrders = Service_ReceivingOrderDetail::getByCondition(array('receiving_code'=>$ASNCode)); $oldReceivingOrderCodeList = array(); if($oldReceivingOrders){ foreach($oldReceivingOrders as $oldReceivingOrder){ $oldReceivingOrderCodeList[] = $oldReceivingOrder['order_code']; } } /*得到新的收货单的订单列表*/ $newReceivingOrderCodeList = array(); foreach ($asnOrders as $keyo=>$orderCode) { $newReceivingOrderCodeList[] = $orderCode; } /*构成订单变化*/ if($newReceivingOrderCodeList != $oldReceivingOrderCodeList){ $AddedOrders = array_diff($newReceivingOrderCodeList,$oldReceivingOrderCodeList); //新增加的订单 $DeletedAddOrders = array_diff($oldReceivingOrderCodeList,$newReceivingOrderCodeList); //被删除的订单 } if($DeletedAddOrders){//将删除的订单的状态改为确认状态 foreach($DeletedAddOrders as $keyDeleteno=>$orderCode){ $orderInfo = Service_Orders::getByField($orderCode,'order_code'); $orderRow = array( 'order_status'=>'2', 'update_time'=>date("Y-m-d H:i:s") ); Service_Orders::update($orderRow, $orderCode,'order_code'); $logRow = array( 'order_id'=>$orderInfo['order_id'], 'order_code'=>$orderCode, 'ol_type'=>'1', 'order_status_from'=>$orderInfo['order_status'], 'order_status_to'=>2, 'ol_add_time'=>date("Y-m-d H:i:s"), 'user_id'=>'-1', 'account_id' => Service_Login::getUserId(), 'ol_ip'=>Common_Common::getIP() ); Service_OrderLog::add($logRow); $warehouse = Service_Warehouse::getByField($orderInfo['warehouse_id'],'warehouse_id'); $shipOrderTracking = array( 'order_code'=>$orderCode, 'sot_location'=>'客户仓库', 'sot_add_time'=>date("Y-m-d H:i:s"), 'warehouse_id'=>$orderInfo['warehouse_id'], 'sot_description'=>'从集货入库单中被删除导致订单状态变为确认状态', 'sot_type'=>'0', 'sot_time_offset'=>'', 'tracking_number'=>$orderCode, 'ref_tracking_number'=>'', 'status_desc'=>'确认', 'user_id'=>-1 ); Service_ShipOrderTracking::add($shipOrderTracking); /*解冻*/ $balanceProcess = new Service_CustomerBalanceProcess(); $feeResult = $balanceProcess->unfreezeFee($orderCode); if($feeResult !== true){ throw new Exception($feeResult);} } }//if($DeletedAddOrders){ Service_ReceivingOrderDetail::delete($ASNCode,'receiving_code'); foreach ($asnOrders as $keyo=>$orderCode) { //$product = Service_Product::getByField($v,'product_sku'); $orderInfo = Service_Orders::getByField($orderCode,'order_code'); $receiving_order_detail = array( 'receiving_id'=>$ASNRow['receiving_id'], 'receiving_code'=>$ASNCode, 'rd_status'=>'0', 'order_code'=>$orderCode, 'rd_add_time'=>$date ); $receivingOrderDetailArr[] = $receiving_order_detail; Service_ReceivingOrderDetail::add($receiving_order_detail); //修改订单到已提交状态 $orderRow = array( 'order_status'=>'4', 'update_time'=>$date ); Service_Orders::update($orderRow, $orderCode,'order_code'); $customerId = $this->_customerId; if(in_array($orderCode,$AddedOrders)){ $logRow = array( 'order_id'=>$orderInfo['order_id'], 'order_code'=>$orderCode, 'ol_type'=>'1', 'order_status_from'=>$orderInfo['order_status'], 'order_status_to'=>4, 'ol_add_time'=>date("Y-m-d H:i:s"), 'user_id'=>'-1', 'account_id' => Service_Login::getUserId(), 'ol_ip'=>Common_Common::getIP() ); Service_OrderLog::add($logRow); $warehouse = Service_Warehouse::getByField($orderInfo['warehouse_id'],'warehouse_id'); $shipOrderTracking = array( 'order_code'=>$orderCode, 'sot_location'=>'客户仓库', 'sot_add_time'=>date("Y-m-d H:i:s"), 'warehouse_id'=>$orderInfo['warehouse_id'], 'sot_description'=>'入库单编辑致订单状态变为已提交状态', 'sot_type'=>'0', 'sot_time_offset'=>'', 'tracking_number'=>$orderCode, 'ref_tracking_number'=>'', 'status_desc'=>'已提交', 'user_id'=>-1 ); Service_ShipOrderTracking::add($shipOrderTracking); //预扣费 $balanceProcess = new Service_CustomerBalanceProcess(); $feeResult = $balanceProcess->freezeFee($orderCode, $customerId); if($feeResult !== true) throw new Exception($feeResult); } } $ASNLog = array( 'receiving_id'=>$ASNRow['receiving_id'], 'receiving_code' => $ASNCode, 'user_id'=>'-1', 'customer_code' => $this->_customerInfo['customer_code'], 'rl_note' => $note, 'rl_status_from'=>$ASNRow['receiving_status'], 'rl_status_to'=>$ASNRow['receiving_status'], //'rl_add_time'=>date("Y-m-d H:i:s"), //'rl_ip'=>Common_Common::getIP() ); //print_r($ASNLog); self::createAsnLog($ASNLog); //$DB->rollBack(); $DB->commit(); return array('ask' => 1, 'msg' => "收货单[{$ASNCode}]更新成功.", 'error' => array(), 'ASNCode' => $ASNCode); //return array('ask' => 1, 'msg' => Ec_Lang::getInstance()->getTranslate('update').Ec_Lang::getInstance()->getTranslate('success'), 'error' => array(), 'ASNCode' => $ASNCode); } catch (Zend_Exception $e) { $DB->rollBack(); $result['error'][] = $e->getInternalError(); $result['msg'] = $e->getInternalError(); return $result; } catch (Exception $e) { $DB->rollBack(); $result['error'][] = $e->getMessage(); $result['msg'] = $e->getMessage(); return $result; } } /* * 删除 ASN 信息 * @param $order ASN ,$productArr=array() ASN产品 ,$customerId 客户ID * @return array('ask' => 0, 'msg' => '','errorCode'=>array(), 'ASNCode' => $ASNCode); */ public function deleteAsnProductTransaction($ASNCode = '', $productArr = array(), $customerId = '') { $result = array('ask' => 0, 'msg' => '', 'errorCode' => array(), 'ASNCode' => $ASNCode); $date = date('Y-m-d H:i:s'); try { $DB = Default_Service_Common::getAdapter(); $DB->beginTransaction(); if ($customerId != '') { $this->_customerId = $customerId; } if (empty($ASNCode) || empty($productArr)) { throw new Exception('request Data Err.', 20000); } $ASNRow = Merchant_Service_Receiving::getByField($ASNCode, 'receiving_code'); if (!isset($ASNRow['customer_id']) || $ASNRow['customer_id'] != $this->_customerId) { throw new Exception('ASNCode:' . $ASNCode . ' can not be found.', 20013); } if (!in_array($ASNRow['status'], array('1'))) { throw new Exception("permission deny,ASNCode:" . $ASNCode . " status is not allow.", 20002); } $order['customer_id'] = $this->_customerId; $this->_warehouseId = $ASNRow['warehouse_id']; $oldProductIds = array(); $oldItemStatus = array(); $oldItemIds = $delProduct = array(); $note = 'delete'; $itemRows = Merchant_Service_ReceivingItem::getByCondition(array('receiving_code' => $ASNCode), '*'); foreach ($itemRows as $val) { $oldProductIds[] = $val['product_id']; $oldItemStatus[$val['product_id']] = $val['status']; $oldItemIds[$val['product_id']] = $val['ri_id']; if (in_array($val['product_id'], $productArr)) { $delProduct[$val['product_id']] = $val['order_qty']; } } //删除产品 foreach ($productArr as $productId) { $productRow = Merchant_Service_Product::getByField($productId, 'product_id'); if (!in_array($productId, $oldProductIds)) { throw new Exception('ASNCode:' . $ASNCode . ' ,sku:' . $productRow['product_sku'] . ' is not belong this AsnCode', 20003); } if (!in_array($oldItemStatus[$productId], array('0'))) { throw new Exception('permission deny,AsnCode:' . $ASNCode . ' ,sku:' . $productRow['product_sku'] . ' status is not allow.', 20002); } Merchant_Service_ReceivingItem::delete($oldItemIds[$productId], 'ri_id'); $note .= ' sku:' . $productRow['product_sku'] . ' '; } //当所有产品删除后,删除ASN if (count($productArr) == count($oldProductIds)) { Merchant_Service_Receiving::delete($ASNCode, 'receiving_code'); } else { $order['modified'] = $date; Merchant_Service_Receiving::update($order, $ASNCode, 'receiving_code'); } //库存调整 self::deleteInventory($ASNCode, $delProduct, $ASNRow['warehouse_id'], 'delete asn product'); $ASNLog = array( 'receiving_code' => $ASNCode, 'customer_id' => $this->_customerId, 'rl_statu_now' => $ASNRow['status'], 'rl_note' => $note ); self::createAsnLog($ASNLog); $DB->commit(); return array('ask' => 1, 'msg' => 'Success', 'errorCode' => array(), 'ASNCode' => $ASNCode); } catch (Zend_Exception $e) { $DB->rollBack(); $result['Error'][] = array( 'errorMessage' => $e->getInternalError(), 'errorCode' => $e->getCode(), ); $result['msg'] = $e->getInternalError(); return $result; } catch (Exception $e) { $DB->rollBack(); $result['Error'][] = array( 'errorCode' => $e->getCode(), 'errorMessage' => $e->getMessage() ); $result['msg'] = $e->getMessage(); return $result; } } /** * @author william-fan * @todo 检查 receiving 表 ref_id 字段值(客户参考号)的唯一性 * $referenceNo已存在返回 false;不存在返回 true; */ public static function checkReferenceNo($params = array()) { $condition = array( 'reference_no' => $params['reference_no'], 'customer_id' => $params['customer_id'], 'receiving_status_arr'=>$params['receiving_status_arr'] ); $rows = Service_Receiving::getByCondition($condition, '*'); return $rows; } /* * 检查产品状态是否可用 * @params $productId,customerId * @return ask 0:没有数据 1:符合customerId 2:有数据不符合customerId 3:产品不可用 ; productInfo=>产品数据 */ public function checkProductStatus($productId = '', $customerId = null) { if (!$customerId) { $customerId = $this->_customerId; } $result = array('ask' => 0, 'productInfo' => array()); $productRow = Service_Product::getByField($productId, 'product_id'); var_dump(Service_Product::getByField($productId, 'product_id'));exit; $result['productInfo'] = $productRow; if (empty($productRow)) { return $result; } elseif ($productRow['customer_id'] != $customerId) { $result['ask'] = 2; return $result; } elseif ($productRow['product_status'] == '0') { $result['ask'] = 3; return $result; } else { $result['ask'] = 1; return $result; } return array('ask' => 0, 'productInfo' => $productRow); } /* * 针对指定用户，生成一个新的相应 AsnCode * @return ASNCode */ public function createCode() { if ($this->_pro == '') { //$this->_pro = 'RE'; $this->_pro = 'BHR'; } $this->_pro = strtoupper($this->_pro); //return Common_GetNumbers::getCode('ASN', '', $this->_pro); return Common_GetNumbers::getOnlyCode('ASNOnly', '', $this->_pro); } /* * 针对指定用户，生成一个新的相应 BoxCode * @return BoxCode */ public function createBoxCode() { return Merchant_Service_GetNumbers::getCode($this->_customerId, 'box', 'P'); } /* * 创建日志 */ public static function createAsnLog($row) { $row['rl_add_time'] = date('Y-m-d H:i:s'); $row['rl_ip'] = Common_Common::getIP(); $row['account_id'] = Service_Login::getUserId(); // 操作人账号ID，0为主账号，其他为子账号ID Service_ReceivingLog::add($row); } /* * 根据ASN订单号，获取ASN信息 */ public static function getAsnInfo($asnCode, $customerCode = '') { $result = array('ask' => 0, 'message' => '', 'Error' => array(), 'result' => array()); $asnRow = Service_Receiving::getByField($asnCode, 'receiving_code'); if (empty($asnRow) || $asnRow['customer_id'] != $customerCode) { $result['message'] = 'AsnCode:' . $asnCode . '不存在'; $result['Error'][] = array('errorCode' => '20013', 'errorMessage' => 'AsnCode:' . $asnCode . ' can not be found.'); return $result; } //集货模式的ASN /*if($asnRow['receive_model_type']=='1'){ $receiveOrders = Service_ReceivingOrderDetail::getByCondition(array('receiving_code' => $asnCode)); $asnDetail = array(); if(!empty($receiveOrders)){ foreach($receiveOrders as $keyo=>$order){ //获取订单的产品信息 $orderProducts=Service_OrderProduct::getByCondition(array('order_code'=>$order['order_code'])); if(!empty($orderProducts)){ //$product_unit = 0; foreach($orderProducts as $keyop=>$vop){ $productRow = Service_Product::getProductAllInfo($vop['product_id'],$customerCode); //$product_unit+=$val['rd_receiving_qty']; $detail = array(); $detail['goods_id'] = $productRow['goods_id']; $detail['hs_code'] = $productRow['hs_code']; $detail['product_barcode'] = $productRow['product_barcode']; $detail['hs_goods_name'] = $productRow['hs_goods_name']; $detail['product_title'] = $productRow['product_title']; $detail['product_title_en'] = $productRow['product_title_en']; //申报要素 $hemList = Service_HsElementMap::getByCondition(array('product_id'=>$vop['product_id']), 'hem_detail'); $elements = array(); foreach($hemList as $hemRow) $elements[] = $hemRow['hem_detail']; $detail['product_model'] = implode('|',$elements); //获取法定单位和数量 $detail['pu_name_law'] = ''; //法定单位 $detail['hum_quantity_law'] = ''; //法定单位数量 if(isset($productRow['hs_uom_map']['pu_name_law'])){ $detail['pu_name_law'] = $productRow['hs_uom_map']['pu_name_law']; } if(isset($productRow['hs_uom_map']['hum_quantity_law'])){ $detail['hum_quantity_law'] = $productRow['hs_uom_map']['hum_quantity_law']; } $detail['pu_name_second'] = ''; //第二单位 $detail['hum_quantity_second'] = ''; //第二单位数量 if(isset($productRow['hs_uom_map']['pu_name_second'])){ $detail['pu_name_second'] = $productRow['hs_uom_map']['pu_name_second']; } if(isset($productRow['hs_uom_map']['hum_quantity_second']) && $productRow['hs_uom_map']['hum_quantity_second']>0 ){ $detail['hum_quantity_second'] = $productRow['hs_uom_map']['hum_quantity_second']; } $detail['product_unit_price'] = $productRow['product_declared_value']/$detail['hum_quantity_law']; $detail['product_total_price'] = $productRow['product_declared_value']*$vop['op_quantity']; $asnDetail[] = $detail; } } } } $asnRow['net_weight'] = Service_ReceivingOrderDetail::sumNetWeight($asnCode); }else{ $asnItem = Service_ReceivingDetail::getByCondition(array('receiving_code' => $asnCode)); $asnDetail = array(); $product_unit = 0; foreach ($asnItem as $key => $val) { $detail = $val; $productRow = Service_Product::getProductAllInfo($val['product_id'],$customerCode); $product_unit+=$val['rd_receiving_qty']; $detail['goods_id'] = $productRow['goods_id']; $detail['hs_code'] = $productRow['hs_code']; $detail['product_barcode'] = $productRow['product_barcode']; $detail['product_title'] = $productRow['product_title']; $detail['product_title_en'] = $productRow['product_title_en']; //申报要素 $hemList = Service_HsElementMap::getByCondition(array('product_id'=>$val['product_id']), 'hem_detail'); $elements = array(); foreach($hemList as $hemRow) $elements[] = $hemRow['hem_detail']; $detail['product_model'] = implode('|',$elements); //获取法定单位和数量 $detail['pu_name_law'] = ''; //法定单位 $detail['hum_quantity_law'] = ''; //法定单位数量 if(isset($productRow['hs_uom_map']['pu_name_law'])){ $detail['pu_name_law'] = $productRow['hs_uom_map']['pu_name_law']; } if(isset($productRow['hs_uom_map']['hum_quantity_law'])){ $detail['hum_quantity_law'] = $productRow['hs_uom_map']['hum_quantity_law']; } $detail['pu_name_second'] = ''; //第二单位 $detail['hum_quantity_second'] = ''; //第二单位数量 if(isset($productRow['hs_uom_map']['pu_name_second'])){ $detail['pu_name_second'] = $productRow['hs_uom_map']['pu_name_second']; } if(isset($productRow['hs_uom_map']['hum_quantity_second']) && $productRow['hs_uom_map']['hum_quantity_second']>0 ){ $detail['hum_quantity_second'] = $productRow['hs_uom_map']['hum_quantity_second']; } $detail['product_unit_price'] = $productRow['product_declared_value']/$detail['hum_quantity_law']; $detail['product_declared_value'] = $productRow['product_declared_value']; $detail['product_total_price'] = $productRow['product_declared_value']*$val['rd_receiving_qty']; $asnDetail[$key] = $detail; } $asnRow['product_unit'] = $product_unit; $asnRow['net_weight'] = Service_ReceivingDetail::sumNetWeight($asnCode); unset($asnItem); }*/ $asnDetail = array(); if($asnRow['receive_model_type']=='1'){ $orderCodes = Service_ReceivingOrderDetail::getOrderCodes($asnCode); $asnDetail = Service_ReceivingOrderDetail::getXmlProducts($orderCodes, $asnCode); $asnRow['net_weight'] = number_format(Service_ReceivingOrderDetail::sumNetWeight($asnCode),2,'.',''); } else { $asnDetail = Service_ReceivingDetail::getXmlProducts($asnCode); $asnRow['net_weight'] = number_format(Service_ReceivingDetail::sumNetWeight($asnCode),2,'.',''); } $productList = array(); foreach($asnDetail as $info) { $hemList = Service_HsElementMap::getByCondition(array('product_id'=>$info['product_id']), 'hem_detail'); $elements = array(); foreach($hemList as $hemRow) $elements[] = $hemRow['hem_detail']; $info['product_model'] = implode('|',$elements); $info['quantity_law'] = round($info['hum_quantity_law'] * $info['quantity'], 3); $total_price = sprintf("%.2f", $info['total_price']); //$info['product_unit_price'] = sprintf("%.4f", $info['product_declared_value']/$info['hum_quantity_law']); $info['product_unit_price'] = sprintf("%.4f", $total_price/$info['quantity_law']); $info['quantity_second'] = $info['pu_code_second'] ? round($info['hum_quantity_second'], 3) : ''; //$info['product_total_price'] = sprintf("%.2f", $info['product_declared_value']*$info['quantity']); $info['product_total_price'] = $total_price; $productList[] = $info; } $warehouseAll = Common_DataCache::getWareHouse(); $warehouseCode = $warehouseAll[$asnRow['warehouse_id']]['warehouse_code']; $asnRow['warehouse_name'] = $warehouseCode; $asnRow['form_id'] = $asnRow['receiving_code']; $asnData = array( 'asnRow' => $asnRow, 'ASNCode' => $asnRow['receiving_code'], 'addTime' => $asnRow['receiving_add_time'], 'lastModifyTime' => $asnRow['receiving_update_time'], 'warehouseCode' => $warehouseCode, 'ASNDetail' => $productList, ); $result['result'] = $asnData; $result['ask'] = 1; return $result; } /** * 根据ASNItem 添加onWay库存 * @param string $asnCode * @param array $itemArr * @param string $note * @return bool * @throws Exception */ private function addInventory($asnCode = '', $itemArr = array(), $note = 'create asn') { $InventoryObj = new Service_ProductInventoryProcess(); $row = array( 'type' => 0, 'warehouse_id' => $this->_warehouseId, 'application_id' => $asnCode, 'application_type' => 2, 'note' => $note, ); foreach ($itemArr as $val) { $row['product_id'] = $val['product_id']; $row['quantity'] = $val['order_qty']; $result = $InventoryObj->update($row); if (!isset($result['ask']) || $result['ask'] != 1) { throw new Exception('update inventory error.' . $result['msg'], 20014); return false; } } return true; } /** * 根据ASNItem 更新onWay库存 * @param string $asnCode * @param array $itemArr * @param string $note * @return bool * @throws Exception */ private function updateInventory($asnCode = '', $itemArr = array(), $note = 'update asn') { $oldItem = Merchant_Service_ReceivingItem::getByCondition(array('receiving_code' => $asnCode), '*'); $InventoryObj = new Merchant_Service_ProductInventoryProcess(); $row = array( 'type' => 0, 'warehouse_id' => $this->_warehouseId, 'application_id' => $asnCode, 'application_type' => 2, 'note' => $note, ); foreach ($oldItem as $val) { $row['product_id'] = $val['product_id']; $row['quantity'] = $val['order_qty'] * -1; $row['note'] = 'delete asn product'; $result = $InventoryObj->update($row); if (!isset($result['ask']) || $result['ask'] != 1) { throw new Exception('delete inventory error.' . $result['msg'], 20014); return false; } } foreach ($itemArr as $val) { $row['product_id'] = $val['product_id']; $row['quantity'] = $val['order_qty']; $row['note'] = 'add asn product'; $result = $InventoryObj->update($row); if (!isset($result['ask']) || $result['ask'] != 1) { throw new Exception('update inventory error.' . $result['msg'], 20014); return false; } } return true; } /** * 根据ASNItem 更新onWay库存 用于删除ASN产品 * @param string $asnCode * @param array $delItemArr * @param string $warehouseId * @param string $note * @return bool * @throws Exception */ private function deleteInventory($asnCode = '', $delItemArr = array(), $warehouseId = '', $note = 'delete asn') { $InventoryObj = new Merchant_Service_ProductInventoryProcess(); $row = array( 'type' => 0, 'warehouse_id' => $warehouseId, 'application_id' => $asnCode, 'application_type' => 2, 'note' => $note, ); foreach ($delItemArr as $productId => $qty) { $row['product_id'] = $productId; $row['quantity'] = $qty * -1; $row['note'] = 'delete asn product'; $result = $InventoryObj->update($row); if (!isset($result['ask']) || $result['ask'] != 1) { throw new Exception('delete inventory error.' . $result['msg'], 20014); return false; } } return true; } /** * 转到删除状态 * @param $order ASN ,$customerId 客户ID * @return array('ask' => 0, 'msg' => '','errorCode'=>array(), 'ASNCode' => $ASNCode); */ public function deleteAsnTransaction($ASNCode = '', $customerId = '') { $result = array('ask' => 0, 'message' => '删除失败', 'errorCode' => array(), 'ASNCode' => $ASNCode); $date = date('Y-m-d H:i:s'); try { $DB = Common_Common::getAdapter(); $DB->beginTransaction(); if (empty($ASNCode)) { throw new Exception('ASN为空', 20000); } $ASNRow = Service_Receiving::getByField($ASNCode, 'receiving_code'); if (!isset($ASNRow['customer_id']) || $ASNRow['customer_id'] != $customerId) { throw new Exception('ASN不存在或无权限', 20013); } if ($ASNRow['receiving_status'] == '0') { return array('ask' => 1, 'message' => '成功删除', 'errorCode' => array(), 'ASNCode' => $ASNCode); } if (!in_array($ASNRow['receiving_status'], array('1'))) { throw new Exception("ASN状态不允许删除", 20002); } $order['customer_id'] = $customerId; $this->_warehouseId = $ASNRow['warehouse_id']; $customerInfo = Service_Customer::getByField($customerId); if($ASNRow['receive_model_type']=='1'){ //集货模式的ASN 删除ASN和订单的关联 并将订单改成确认状态 $receivingOrdersCondition = array( 'receiving_code'=>$ASNCode, ); $receivingOrders = Service_ReceivingOrderDetail::getByCondition($receivingOrdersCondition); // Service_ReceivingOrderDetail::getByCondition() //Service_ReceivingDetail::getByCondition() if(!empty($receivingOrders)){ foreach ($receivingOrders as $ko=>$vo){ $orderRow = Service_Orders::getByField($vo['order_code'],'order_code',"*"); $upOrderRow = array( 'order_status'=>'2', ); if($orderRow['sm_code']=="UKTL"||$orderRow['sm_code']=="SZY-EUB"||$orderRow['sm_code']=="SZY-ETK"||$orderRow['sm_code']=="WG-EUB"){ $upOrderRow['ref_tracking_number'] = ""; } Service_Orders::update($upOrderRow, $vo['order_code'],'order_code'); $logRow = array( 'order_id'=>$orderRow['order_id'], 'order_code'=>$vo['order_code'], 'ol_type'=>0, 'order_status_from'=>$orderRow['order_status'], 'order_status_to'=>2, 'ol_add_time'=>date('Y-m-d H:i:s'), 'user_id'=>'-1', 'ol_comments'=>'ASN删除', 'account_id' => Service_Login::getUserId(), 'ol_ip'=>Common_Common::getIP() ); Service_OrderLog::add($logRow); //退回费用 $balanceProcess = new Service_CustomerBalanceProcess(); $feeResult = $balanceProcess->unfreezeFee($vo['order_code'], 'ASN退回,解冻金额'); } Service_ReceivingOrderDetail::delete($ASNCode,'receiving_code'); } else{ throw new Exception("ASN和订单关联不存在"); } }else{ //备货模式订单和以前处理一样 //echo 'nnnn'; } $delProduct = array(); $note = 'delete asn '; Service_Receiving::update(array('receiving_status' => 0), $ASNCode, 'receiving_code'); //self::deleteInventory($ASNCode, $delProduct, $ASNRow['warehouse_id'], 'delete asn'); $ASNLog = array( 'receiving_id'=>$ASNRow['receiving_id'], 'receiving_code' => $ASNCode, 'rl_type'=>'1', 'user_id'=>'-1', 'customer_code' => $customerInfo['customer_code'], 'rl_add_time' => date('Y-m-d H:i:s',time()), 'rl_status_from'=>1, 'rl_status_to'=>0, 'rl_ip' => Common_Common::getIP() ); self::createAsnLog($ASNLog); $DB->commit(); //$DB->rollBack(); return array('ask' => 1, 'message' => "收货单号[{$ASNCode}]".'删除成功', 'errorCode' => array(), 'ASNCode' => $ASNCode); } catch (Zend_Exception $e) { $DB->rollBack(); $result['Error'][] = array( 'errorMessage' => $e->getInternalError(), 'errorCode' => $e->getCode(), ); $result['message'] = $e->getInternalError(); return $result; } catch (Exception $e) { $DB->rollBack(); $result['Error'][] = array( 'errorCode' => $e->getCode(), 'errorMessage' => $e->getMessage() ); $result['msg'] = $e->getMessage(); return $result; } } /** * @param string $ASNCode * @param array $productArr * @param string $customerId * @return array('ask' => 0,'msg'=>'', 'Error' => array(), 'ASNCode' => $ASNCode); * @throws Exception */ public function cancelProductTransaction($ASNCode = '', $productArr = array(), $customerId = '') { $result = array('ask' => 0, 'msg' => '', 'Error' => array(), 'ASNCode' => $ASNCode); $date = date('Y-m-d H:i:s'); try { $DB = Default_Service_Common::getAdapter(); $DB->beginTransaction(); if ($customerId != '') { $this->_customerId = $customerId; } if (empty($ASNCode) || empty($productArr)) { throw new Exception('request Data Err.', 20000); } $ASNRow = Merchant_Service_Receiving::getByField($ASNCode, 'receiving_code'); if (!isset($ASNRow['customer_id']) || $ASNRow['customer_id'] != $this->_customerId) { throw new Exception('ASNCode:' . $ASNCode . ' can not be found.', 20001); } if (!in_array($ASNRow['status'], array('1','2'))) { throw new Exception("permission deny,ASNCode:" . $ASNCode . " status is not allow.", 20002); } $order['customer_id'] = $this->_customerId; $this->_warehouseId = $ASNRow['warehouse_id']; $oldProductIds = array(); $oldItemStatus = array(); $oldItemIds = $delProduct = array(); $note = 'cancel'; $itemRows = Merchant_Service_ReceivingItem::getByCondition(array('receiving_code' => $ASNCode), '*'); foreach ($itemRows as $val) { $oldProductIds[] = $val['product_id']; $oldItemStatus[$val['product_id']] = $val['status']; $oldItemIds[$val['product_id']] = $val['ri_id']; if (in_array($val['product_id'], $productArr)) { $delProduct[$val['product_id']] = $val['order_qty']; } } //删除产品 foreach ($productArr as $productId) { $productRow = Merchant_Service_Product::getByField($productId, 'product_id'); if (!in_array($productId, $oldProductIds)) { throw new Exception('ASNCode:' . $ASNCode . ' ,sku:' . $productRow['product_sku'] . ' is not belong this AsnCode', 20003); } if (!in_array($oldItemStatus[$productId], array('0'))) { throw new Exception('permission deny,AsnCode:' . $ASNCode . ' ,sku:' . $productRow['product_sku'] . ' status is not allow.', 20002); } Merchant_Service_ReceivingItem::delete($oldItemIds[$productId], 'ri_id'); $note .= ' sku:' . $productRow['product_sku'] . ' '; //清除已删除的产品 unset($oldItemStatus[$productId]); } //判断是否全部未到货的产品是否全部已删除 $received = true; $newStatus = array(); foreach ($oldItemStatus as $k => $v) { if ($v == 0) { $received = false; continue; } $newStatus[] = $v; } $asnStatus = $ASNRow['status']; if ($received) { if (in_array(1, $newStatus)) { $asnStatus = 2; } elseif (!in_array(1, $newStatus) && !in_array(0, $newStatus) && in_array(2, $newStatus) ) { $asnStatus = 3; } $order['modified'] = $date; $order['status'] = $asnStatus; Merchant_Service_Receiving::update($order, $ASNCode, 'receiving_code'); } //onWay库存调整 self::deleteInventory($ASNCode, $delProduct, $ASNRow['warehouse_id'], 'cancel asn product'); $ASNLog = array( 'receiving_code' => $ASNCode, 'customer_id' => $this->_customerId, 'rl_statu_now' => $asnStatus, 'rl_note' => $note ); self::createAsnLog($ASNLog); $DB->commit(); return array('ask' => 1, 'Error' => array(), 'ASNCode' => $ASNCode); } catch (Zend_Exception $e) { $DB->rollBack(); $result['Error'][] = array( 'errorMessage' => $e->getInternalError(), 'errorCode' => $e->getCode(), ); $result['msg'] = $e->getInternalError(); return $result; } catch (Exception $e) { $DB->rollBack(); $result['Error'][] = array( 'errorCode' => $e->getCode(), 'errorMessage' => $e->getMessage() ); $result['msg'] = $e->getMessage(); return $result; } } /** * @author william-fan * @todo 备货表单数据验证 * @param array $data * @return array('ask' => 0, 'msg' => array(), 'data' => array()); */ public static function validate($data = array()) { $error = array(); if (empty($data)) { $error[]=Ec_Lang::getInstance()->getTranslate('DataError');//'数据出错'; return $error; } if ("" == $data['warehouseId']) { $error[] = Ec_Lang::getInstance()->getTranslate('WarehouseRequired');//"仓储必填"; } if(isset($data['receive_model_type'])&&($data['receive_model_type']=='0' || $data['receive_model_type']=='1')){ if($data['receive_model_type']=='1'){ //集货模式 if(!isset($data['asn_order']) || empty($data['asn_order'])){ $error[] = Ec_Lang::getInstance()->getTranslate('OrdersMustBeSelected');//"必须选择订单"; } }else{ //备货模式 if(!isset($data['product_sku']) || empty($data['product_sku'])){ $error[] = Ec_Lang::getInstance()->getTranslate('ProductsMusBeSelected');//"必须选择产品"; } } }else{ $error[] = Ec_Lang::getInstance()->getTranslate('ASNSchema').Ec_Lang::getInstance()->getTranslate('error');//"仓储必填"; } if(!(isset($data['is_delivery']) && ($data['is_delivery']=='0' || $data['is_delivery']=='1'))){ $error[] = "是否提货必须填写"; } if($data['ref_code']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('CustomerReference').Ec_Lang::getInstance()->getTranslate('require');// '客户参考号必填'; }else{ } if($data['ie_port']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('ImportexportPorts').Ec_Lang::getInstance()->getTranslate('require');//'进出口口岸必填'; } if($data['form_type']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('BusinessType').Ec_Lang::getInstance()->getTranslate('require');//'业务类型必填'; } /* if($data['form_type']==''){ $error[] = '业务类型必填'; } if($data['traf_name']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('LicensePlateNumber').Ec_Lang::getInstance()->getTranslate('require');//'车牌号必填'; } */ if($data['wrap_type']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('PackingType').Ec_Lang::getInstance()->getTranslate('require');//'包装种类必填'; } if($data['pack_no']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('TotalNumber').Ec_Lang::getInstance()->getTranslate('require');//'总件数必填'; }else{ if(!preg_match('/[0-9]+/i',$data['pack_no']) || !is_numeric($data['pack_no']) || $data['pack_no']<1 ){ $error[] =Ec_Lang::getInstance()->getTranslate('packNoError');//'总件数必须为正'; } } if($data['trade_mode']==''){ $error[] =Ec_Lang::getInstance()->getTranslate('RegulatoryApproach').Ec_Lang::getInstance()->getTranslate('require');//'监管方式必填'; } if($data['trans_mode']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('TransactionMethod').Ec_Lang::getInstance()->getTranslate('require');//'成交方式必填'; } if($data['ASNCode']!=''){ $receiving=Service_Receiving::getByField($data['ASNCode'],'receiving_code'); if(!empty($receiving) && $receiving['receiving_status']!='1'){ $error[] = Ec_Lang::getInstance()->getTranslate('CanNotEditOnThisStatus');//"收货单状态不对"; } } /* if($data['netweight'] && (!is_numeric($data['netweight']) || $data['netweight']<0)){ $error[] = Ec_Lang::getInstance()->getTranslate('netweightError');//毛重 } */ //$sessionUser = new Zend_Session_Namespace("customerAuth"); //$customerAuth = new Zend_Session_Namespace("customerAuth"); //$customerId = $customerAuth->customer['customer_id']; $customerAuth= Service_Login::getLoginInfo(); $customerId = $customerAuth['id']; /*if($data['ref_code']!='' && $data['ASNCode']){ $condition = array('reference_no'=>$data['ref_code'],'customer_id'=>$customerId,'receiving_status_arr'=>array('1','2','3','4','5','6','7')); $receivings = Service_Receiving::getByCondition($condition,'reference_no'); if($receivings){ foreach($receivings as $receiving){ if($receiving['reference_no']!=$data['ref_code']){ $error[] = Ec_Lang::getInstance()->getTranslate('CustomerReferenceNumberExistence'); //"参考号已经存在"; break; } } } }*/ if($data['ref_code']!='' && empty($data['ASNCode'])){ $condition = array('reference_no'=>$data['ref_code'],'customer_id'=>$customerId,'receiving_status_arr'=>array('1','2','3','4','5','6','7')); $receivings = Service_Receiving::getByCondition($condition,'reference_no'); if($receivings){ $error[] = Ec_Lang::getInstance()->getTranslate('CustomerReferenceNumberExistence'); //"参考号已经存在"; } } if($data['receive_model_type']!='1'){//备货模式 if(isset($data['product_sku']) && !empty($data['product_sku']) ) { $product_sku = $data['product_sku']; $sum = 0; $sku = @$data['sku']; foreach ($product_sku as $k=>$v) { $product = Service_Product::getByField($k,'product_id'); if(!$product){ $error[] = "product sku:[{$v}] ".Ec_Lang::getInstance()->getTranslate('DoesNotExist'); continue; }else{ //if(!preg_match('/[0-9]+/i',$sku[$k]) || $sku[$k]<0){ //$error[] = "产品SKU:[{$v}]的数量".Ec_Lang::getInstance()->getTranslate('NumberMustBeAnInteger'); //} //判断产品是否是普通产品 if(!in_array($product['product_type'], array('0'))){ $error[] = "product sku:[{$v}] ".Ec_Lang::getInstance()->getTranslate('ProductTypeError'); } if($product['product_status']!='1'){ $error[] = "product sku:[{$v}] ".Ec_Lang::getInstance()->getTranslate('ProductStatusError'); } $hs_code = Service_Hscodes::getByField($product['hs_code'],'hs_code'); if($hs_code['hs_code_status']=='-1'){ $error[] = "产品sku:".$product['product_sku']."海关编码{$product['hs_code']}已废止"; } } } } $total_weight = 0; if(isset($data['sku']) && !empty($data['sku']) ) { $product_sku_array = $data['product_sku']; $number_array = $data['sku']; foreach ($number_array as $k=>$number) { $number = trim($number); $product = Service_Product::getByField($k,'product_id'); $total_weight+= $product['product_weight']* $number; $sku = $product_sku_array[$k]; if(!(preg_match('/^[0-9]+$/i',$number) && is_numeric($number) && $number>0)){ $error[] = "产品SKU[{$sku}]".Ec_Lang::getInstance()->getTranslate('NumberMustBeAnInteger'); } } } if(isset($data['declared_value']) && !empty($data['declared_value']) ) { $declare = $data['declared_value']; foreach ($declare as $keyd=>$valuen){ $sku = $product_sku_array[$keyd]; $valuen = trim($valuen); if(!is_numeric($valuen) || $valuen<=0){ $error[] = "产品SKU[{$sku}]".'申报价值必须是数字'; } } } if($data['roughweight']==''){ $error[] = "毛重必填."; }elseif(!(is_numeric($data['roughweight']) && $data['roughweight']>0)){ $error[] = Ec_Lang::getInstance()->getTranslate('roughweightError');//毛重 }else{ if(isset($data['product_sku']) && !empty($data['product_sku']) ) { if($total_weight>0 && $data['roughweight']<$total_weight){ $error[] = "ASN重量({$data['roughweight']}KG)小于净重({$total_weight}KG)"; } } } }//if($data['receive_model_type']!='1')备货 //$data['asn_order'] //验证客户是否是从属客户 if( Service_CustomerProcess::getOwner( $customerAuth['code'] ) && $data['is_delivery'] == 1 ) { $error[] = Ec_Lang::getInstance()->getTranslate('deliveryNotSupported'); //"参考号已经存在"; } return $error; } public static function validatePoAsn($data = array(),$customerId) { $error = array(); if (empty($data)) { $error[]=Ec_Lang::getInstance()->getTranslate('DataError');//'数据出错'; return $error; } if ("" == $data['warehouseId']) { $error[] = Ec_Lang::getInstance()->getTranslate('WarehouseRequired');//"仓储必填"; } if(isset($data['receive_model_type'])&&($data['receive_model_type']=='0' || $data['receive_model_type']=='1')){ if($data['receive_model_type']=='1'){ //集货模式 if(!isset($data['asn_order']) || empty($data['asn_order'])){ $error[] = Ec_Lang::getInstance()->getTranslate('OrdersMustBeSelected');//"必须选择订单"; } }else{ //备货模式 if(!isset($data['product_sku']) || empty($data['product_sku'])){ $error[] = Ec_Lang::getInstance()->getTranslate('ProductsMusBeSelected');//"必须选择产品"; } } }else{ $error[] = Ec_Lang::getInstance()->getTranslate('ASNSchema').Ec_Lang::getInstance()->getTranslate('error');//"仓储必填"; } if(!(isset($data['is_delivery']) && ($data['is_delivery']=='0' || $data['is_delivery']=='1'))){ $error[] = "是否提货必须填写"; } if($data['ref_code']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('CustomerReference').Ec_Lang::getInstance()->getTranslate('require');// '客户参考号必填'; }else{ } if($data['ie_port']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('ImportexportPorts').Ec_Lang::getInstance()->getTranslate('require');//'进出口口岸必填'; } if($data['form_type']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('BusinessType').Ec_Lang::getInstance()->getTranslate('require');//'业务类型必填'; } /* if($data['form_type']==''){ $error[] = '业务类型必填'; } if($data['traf_name']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('LicensePlateNumber').Ec_Lang::getInstance()->getTranslate('require');//'车牌号必填'; } */ if($data['wrap_type']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('PackingType').Ec_Lang::getInstance()->getTranslate('require');//'包装种类必填'; } if($data['pack_no']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('TotalNumber').Ec_Lang::getInstance()->getTranslate('require');//'总件数必填'; }else{ if(!preg_match('/[0-9]+/i',$data['pack_no']) || !is_numeric($data['pack_no']) || $data['pack_no']<1 ){ $error[] =Ec_Lang::getInstance()->getTranslate('packNoError');//'总件数必须为正'; } } if($data['trade_mode']==''){ $error[] =Ec_Lang::getInstance()->getTranslate('RegulatoryApproach').Ec_Lang::getInstance()->getTranslate('require');//'监管方式必填'; } if($data['trans_mode']==''){ $error[] = Ec_Lang::getInstance()->getTranslate('TransactionMethod').Ec_Lang::getInstance()->getTranslate('require');//'成交方式必填'; } if($data['ASNCode']!=''){ $receiving=Service_Receiving::getByField($data['ASNCode'],'receiving_code'); if(!empty($receiving) && $receiving['receiving_status']!='1'){ $error[] = Ec_Lang::getInstance()->getTranslate('CanNotEditOnThisStatus');//"收货单状态不对"; } } if($data['ref_code']!='' && empty($data['ASNCode'])){ $condition = array('reference_no'=>$data['ref_code'],'customer_id'=>$customerId,'receiving_status_arr'=>array('1','2','3','4','5','6','7')); $receivings = Service_Receiving::getByCondition($condition,'reference_no'); if($receivings){ $error[] = Ec_Lang::getInstance()->getTranslate('CustomerReferenceNumberExistence'); //"参考号已经存在"; } } //判断产品 if(isset($data['po_tb_id']) && !empty($data['po_tb_id']) ) { foreach($data['po_tb_id'] as $po_tb_id){ if($po_tb_id){ $PurchaseOrderTrackingBody = Service_PoOrderTrackingBody::getByField($po_tb_id,'po_tb_id'); if(empty($PurchaseOrderTrackingBody)){ $error[]=Ec_Lang::getInstance()->getTranslate('DataError');//'数据出错 break; }else{ if($PurchaseOrderTrackingBody['is_created_asn'] == '1'){ $error[]=Ec_Lang::getInstance()->getTranslate('AddIsCreateASNFail'); break; } } } } }else{ $error[]=Ec_Lang::getInstance()->getTranslate('DataError');//'数据出错'; return $error; } $total_weight = 0; if($data['receive_model_type']!='1'){//备货模式 if(isset($data['product_sku']) && !empty($data['product_sku']) ) { $product_sku = $data['product_sku']; foreach ($product_sku as $k=>$v) { $product_id=$data['product_id'][$k]; $product = Service_Product::getByField($product_id,'product_id'); if(!$product){ $error[] = "product sku:[{$v}] ".Ec_Lang::getInstance()->getTranslate('DoesNotExist'); continue; }else{ //if(!preg_match('/[0-9]+/i',$sku[$k]) || $sku[$k]<0){ //$error[] = "产品SKU:[{$v}]的数量".Ec_Lang::getInstance()->getTranslate('NumberMustBeAnInteger'); //} //判断产品是否是普通产品 if(!in_array($product['product_type'], array('0'))){ $error[] = "product sku:[{$v}] ".Ec_Lang::getInstance()->getTranslate('ProductTypeError'); } if($product['product_status']!='1'){ $error[] = "product sku:[{$v}] ".Ec_Lang::getInstance()->getTranslate('ProductStatusError'); } $hs_code = Service_Hscodes::getByField($product['hs_code'],'hs_code'); if (empty($hs_code)) { $error[] = '产品SKU[' . $v . ']对应海关编码[' . $product['hs_code'] . ']不存在'; } if($hs_code['hs_code_status']=='-1'){ $error[] = "产品sku:".$product['product_sku']."海关编码{$product['hs_code']}已废止"; } $total_weight+= $product['product_weight']* $data['num'][$k]; } } } /* if(isset($data['declared_value']) && !empty($data['declared_value']) ) { $declare = $data['declared_value']; foreach ($declare as $keyd=>$valuen){ $sku = $product_sku_array[$keyd]; $valuen = trim($valuen); if(!is_numeric($valuen) || $valuen<=0){ $error[] = "产品SKU[{$sku}]".'申报价值必须是数字'; } } } */ if($data['roughweight']==''){ $error[] = "毛重必填."; }elseif(!(is_numeric($data['roughweight']) && $data['roughweight']>0)){ $error[] = Ec_Lang::getInstance()->getTranslate('roughweightError');//毛重 }else{ if(isset($data['product_sku']) && !empty($data['product_sku']) &&empty($error)) { if($total_weight>0 && $data['roughweight']<$total_weight){ $error[] = "ASN重量({$data['roughweight']}KG)小于净重({$total_weight}KG)"; } } } }//if($data['receive_model_type']!='1')备货 //$data['asn_order'] return $error; } /** * @author william-fan * @todo 检查订单 */ public static function validOrder($data = array()){ //检查订单 $return = array(); $error = array(); $detail = array(); $total_weight = 0; if(isset($data['asn_order']) && !empty($data['asn_order'])){ $orders = $data['asn_order']; foreach($orders as $keyo=>$ordercode){ $orderInfo = Service_Orders::getByField($ordercode,'order_code'); if(!empty($orderInfo)){ $orderInfo = Service_Orders::getByFieldUpdate($orderInfo['order_id'],"order_id","*"); if($orderInfo['order_status']!='2'){ //$error[] = Ec_Lang::getInstance()->getTranslate('orderCode').' '.$ordercode.Ec_Lang::getInstance()->getTranslate('IsNotRecognizedInTheState'); if($orderInfo['order_status']>2){ $receivingOrder = Service_ReceivingOrderDetail::getByField($ordercode,'order_code'); $error[] = "订单[{$ordercode}]已创建了入区单[{$receivingOrder['receiving_code']}]"; $detail[$ordercode] = $receivingOrder['receiving_code']; }else{ $orderStatus = Service_OrderProcess::getJHStatusText($orderInfo['order_status']); $error[] = "订单[{$ordercode}]是".$orderStatus."状态"; } } }else{ $error[] = Ec_Lang::getInstance()->getTranslate('orderCode').' '.$ordercode.''.Ec_Lang::getInstance()->getTranslate('DoesNotExist'); } $cal_array=Service_OrderProcess::calucateOrderTotalWeight($ordercode); $total_weight+=$cal_array['totalWeight']; $orderProducts = Service_OrderProduct::getByCondition(array('order_code'=>$ordercode),'*'); if(!empty($orderProducts)){ foreach($orderProducts as $kop=>$vop){ $product = Service_Product::getByField($vop['product_id'],'product_id'); if(!empty($product)){ $hs_code = Service_Hscodes::getByField($product['hs_code'],'hs_code'); if($hs_code['hs_code_status']=='-1'){ $error[] = "产品sku:".$product['product_sku']."海关编码{$product['hs_code']}已废止"; } } } } } } if($data['roughweight']==''){ $error[] = "毛重必填."; }else if(!(is_numeric($data['roughweight']) && $data['roughweight']>0)){ $error[] = Ec_Lang::getInstance()->getTranslate('roughweightError');//毛重 }else{ if(isset($data['asn_order']) && !empty($data['asn_order'])){ if(!($total_weight>0 && $data['roughweight']>$total_weight)){ //$error[] = "毛重要大于净重({$total_weight}KG)."; } } } $return = array( 'error'=>$error, 'detail'=>$detail ); return $return; } /** * @author william-fan * @todo todo 确认ASn */ public static function confirmASn($ASNCode = '',$customerId=''){ $result = array('ask' => 0, 'message' => '确认失败', 'error' => array()); $receiving = Service_Receiving::getByField($ASNCode,'receiving_code'); $error = array(); $pdfSmcode=array( '4PX-LYT_GH', //A6 '4PX-EU_PACKET', //DS '4PX-RU_POST-LINK_RMAIL', //BA '4PX-HKDHL', //A1 '4PX-YX', //AI '4PX-SG_ordinary_mail+' , 'PNLN','PNLG','BH-AZAT-G', 'DHL-BH03', 'BH-POST-NL', 'BH-SFEP', ); $sendOrderInfoSmcode=array( '4PX-Singapo_SPack_IMAIR', //B1 '4PX-OZXBTH', //BB ); if(empty($receiving)){ $error[]='ASN无效'; $return['message'] = $result['message'].'ASN无效'; }else{ if($receiving['receiving_status']!='1'){ $error[]='ASN状态错误'; $return['message'] = $result['message'].'ASN状态错误'; } } if(empty($customerId)){ $result['message'] = '客户错误'; $result['message'] = $result['message'].'客户错误'; return $result; } if(!empty($error)){ $result['error'] = $error; return $result; } if($receiving['customer_id']!=$customerId){ $result['message'] = '改ASN和客户不一致'; return $result; } //判断法定单位总和是否大于毛重 $law_weight = 0; if($receiving['receive_model_type']==0) { $law_weight = Service_ReceivingDetail::sumLawWeight($ASNCode); } else if($receiving['receive_model_type']==1) { $law_weight = Service_ReceivingOrderDetail::sumLawWeight($ASNCode); } if($law_weight > $receiving['roughweight']) { $result['message'] = '法定单位为千克的SKU的总重量['.$law_weight.']大于ASN毛重['.$receiving['roughweight'].']，请修改SKU的法定单位重量'; return $result; } try { $DB = Common_Common::getAdapter(); $DB->beginTransaction(); $receivingRow = array( 'receiving_status'=>'2', 'receiving_update_time'=>date('Y-m-d H:i:s',time()), ); if(!Service_Receiving::update($receivingRow, $ASNCode,'receiving_code')){ throw new Exception("ASN确认失败"); } $customerRow = Service_Customer::getByField($customerId); $ASNLog = array( 'receiving_id'=>$receiving['receiving_id'], 'receiving_code' => $ASNCode, 'rl_type'=>'1', 'user_id'=>'-1', 'customer_code' => $customerRow['customer_code'], 'rl_note' => "确认ASN单", 'rl_status_from'=>$receiving['receiving_status'], 'rl_status_to'=>'2', 'rl_add_time'=>date('Y-m-d H:i:s',time()), 'rl_ip'=>Common_Common::getIP() ); if($receiving['receive_model_type']=='0'){ $conDetail = array( 'receiving_code'=>$ASNCode, ); $receivingDetail = Service_ReceivingDetail::getByCondition($conDetail); if(!empty($receivingDetail)){ $totalWeight = 0; foreach ($receivingDetail as $keyde=>$valuede){ $product = Service_Product::getByField($valuede['product_id']); if(empty($product) || $product['product_type']=='1'){continue;} $totalWeight += $product['product_weight']*$valuede['rd_receiving_qty']; } } }//备货 if($receiving['receive_model_type']=='1'){ $conDetail = array( 'receiving_code'=>$ASNCode, ); $totalWeight = 0; $receivingDetail = Service_ReceivingOrderDetail::getByCondition($conDetail); if(!empty($receivingDetail)){ $totalWeight = 0; $noTracingOrder=array(); $noSendInfoOrder=array(); $errorMsg=''; foreach ($receivingDetail as $keyde=>$valuede){ $totalWeight+= Service_Orders::calculateWeight($valuede['order_code']); $orderInfo= Service_Orders::getByField($valuede['order_code'],'order_code'); if(in_array($orderInfo['sm_code'],$pdfSmcode)){ if(empty($orderInfo['ref_tracking_number'])){ $noTracingOrder[]=$orderInfo['order_code']; } } if(in_array($orderInfo['sm_code'],$sendOrderInfoSmcode)){ if($orderInfo['sync_status']!='1'){ $noSendInfoOrder[]=$orderInfo['order_code']; } } } if(!empty($noTracingOrder)){ $errorMsg.='订单'.implode(",",$noTracingOrder).'没有获取到服务商单号
'; } if(!empty($noSendInfoOrder)){ $errorMsg.='运输渠道【'.implode("】【",$noSendInfoOrder).'】订单：'.implode(",",$noSendInfoOrder).'信息没有推送到4PX
'; } if(!empty($errorMsg)){ throw new Exception($errorMsg); } } } $roughweight = $receiving['roughweight']; if($roughweight<$totalWeight){ throw new Exception("ASN重量({$roughweight}KG)小于净重({$totalWeight}KG)"); } /*$conDetail = array( 'receiving_code'=>$ASNCode, ); $receivingDetail = Service_ReceivingDetail::getByCondition($conDetail); if(!empty($receivingDetail)){ foreach ($receivingDetail as $keyde=>$valuede){ $product = Service_Product::getByField($valuede['product_id']); $conInventory = array( 'customer_id'=>$customerId, 'product_id'=>$valuede['product_id'], 'warehouse_id'=>$receiving['warehouse_id'] ); $productInventory = Service_ProductInventory::getByCondition($conInventory); if(empty($productInventory)){ //添加一条product_inventory 记录 $productInventoryRow = array( 'product_barcode'=>$product['product_barcode'], 'customer_id'=>$customerId, 'product_id'=>$product['product_id'], 'warehouse_id'=>$receiving['warehouse_id'], 'pi_onway'=>$valuede['rd_receiving_qty'], 'pi_add_time'=>date('Y-m-d H:i:s',time()), ); Service_ProductInventory::add($productInventoryRow); $productInventoryLogRow = array( 'product_id'=>$product['product_id'], 'product_barcode'=>$product['product_barcode'], 'warehouse_id'=>$receiving['warehouse_id'], 'user_id'=>'-1', 'pil_onway'=>$valuede['rd_receiving_qty'], 'pil_ip'=>Common_Common::getIP(), ); Service_ProductInventoryLog::add($productInventoryLogRow); }else{ $inventory = $productInventory[0]; //修改product_inventory 记录 $productInventoryRow = array( 'pi_onway'=>$valuede['rd_receiving_qty']+$inventory['pi_onway'], 'pi_update_time'=>date('Y-m-d H:i:s',time()), ); Service_ProductInventory::update($productInventoryRow, $inventory['pi_id']); $productInventoryLogRow = array( 'product_id'=>$product['product_id'], 'product_barcode'=>$product['product_barcode'], 'warehouse_id'=>$receiving['warehouse_id'], 'user_id'=>'-1', 'pil_onway'=>$valuede['rd_receiving_qty'], 'pil_ip'=>Common_Common::getIP(), ); Service_ProductInventoryLog::add($productInventoryLogRow); } //修改产品的have_asn字段 $productRow = array( 'have_asn'=>'1', 'product_update_time'=>date('Y-m-d H:i:s') ); Service_Product::update($productRow, $valuede['product_id']); } }*/ self::createAsnLog($ASNLog); $result['ask']='1'; $result['message'] = 'ASN确认成功'; //$DB->rollBack(); $DB->commit(); } catch (Exception $e) { $DB->rollBack(); $result['error'][] = $e->getMessage(); $result['message'] = $e->getMessage(); return $result; } //print_r($result);exit; return $result; } /** * @author william-fan * @todo 待审核 生成xml文件 */ public static function PendingAsn($ASNCode = '',$customerId){ $result = array('ask' => 0, 'message' => '确认失败', 'error' => array()); $receiving = Service_Receiving::getByField($ASNCode,'receiving_code'); $error = array(); //print_r($receiving);exit; if(empty($receiving)){ $error[]='ASN无效'; }else{ if($receiving['receiving_status']!='2'){ $error[]='ASN状态错误'; } } if(empty($customerId)){ $result['message'] = '客户错误'; return $result; } if(!empty($error)){ $result['error'] = $error; return $result; } if($receiving['customer_id']!=$customerId){ $result['message'] = '该ASN和客户不一致'; return $result; } try { $DB = Common_Common::getAdapter(); $DB->beginTransaction(); $receivingRow = array( 'receiving_status'=>'3', //方便测试暂时为4 'receiving_update_time'=>date('Y-m-d H:i:s',time()), ); if(!Service_Receiving::update($receivingRow, $ASNCode,'receiving_code')){ throw new Exception("ASN移至待审核失败"); } $customerRow = Service_Customer::getByField($customerId); $ASNLog = array( 'receiving_id'=>$receiving['receiving_id'], 'receiving_code' => $ASNCode, 'rl_type'=>'-1', 'user_id'=>'-1', 'customer_code' => $customerRow['customer_code'], 'rl_note' => "移动ASN至待审核", 'rl_status_from'=>$receiving['receiving_status'], 'rl_status_to'=>'3', //方便测试暂时为4 'rl_add_time'=>date('Y-m-d H:i:s',time()), 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); //改为自动运行程序提交审核 /**$ftProcess = new Service_FtpMessageProcess(); $fml_id = $ftProcess->addSendMessage($ASNCode); $ftProcess->ftpSendMessage($fml_id);*/ /*$aMessage['fmt_code'] = 'MRK'; $aMessage['fmt_type'] = 'BSG011'; $aMessage['refercence_no'] = $ASNCode; $aMessage['fml_status'] = 1; $aMessage['fml_add_time'] = date('Y-m-d H:i:s'); Service_FtpMessageSendlist::add($aMessage);*/ self::separateAsn($ASNCode); $objOtherCalculte = new Common_CalculateOtherFee(); if($receiving['is_delivery']=='1'){ //提货的ASN要提货费 //冻结提货费 $keys = array( 'warehouseId' => $receiving['warehouse_id'], 'receiving_code'=>$ASNCode, ); $objOtherCalculte->setParams($keys); $otherfeeArr = $objOtherCalculte->getOtherFee('TIHUO'); $otherfee_tihuo = $otherfeeArr['data']['otherFee']['tihuo']; //print_r($otherfee_tihuo); if($otherfee_tihuo['price']>0){ $balanceProcess = new Service_CustomerBalanceProcess(); $feeResult = $balanceProcess->freezeASNFee($ASNCode, $customerId); if($feeResult !== true) { throw new Exception($feeResult); } } } if($receiving['receive_model_type']==0){ $keys = array( 'warehouseId' => $receiving['warehouse_id'], 'receiving_code'=>$ASNCode, ); $objOtherCalculte->setParams($keys); //入库费 $otherfeeArr = $objOtherCalculte->getOtherFee('RUKU'); $otherfee_ruku = $otherfeeArr['data']['otherFee']['ruku']; if($otherfee_ruku['price']>0){ $balanceProcess = new Service_CustomerBalanceProcess($customerId); $feeResult = $balanceProcess->freezeOtherFee($otherfee_ruku['price'],$otherfee_ruku['currency_code'],$ASNCode,$otherfee_ruku['fee_id'],'ASN提交扣入库费，冻结余额'); } //散租费 $otherfeeArr = $objOtherCalculte->getOtherFee('SANZU'); $otherfee_sanzu = $otherfeeArr['data']['otherFee']['sanzu']; if($otherfee_sanzu['price']>0){ $balanceProcess = new Service_CustomerBalanceProcess($customerId); $feeResult = $balanceProcess->freezeOtherFee($otherfee_sanzu['price'],$otherfee_sanzu['currency_code'],$ASNCode,$otherfee_sanzu['fee_id'],'ASN提交扣散租费，冻结余额'); } //操作费-M $otherfeeArr = $objOtherCalculte->getOtherFee('CZF-M'); $otherfee_czfm = $otherfeeArr['data']['otherFee'][strtolower('CZF-M')]; if($otherfee_czfm['price']>0){ $balanceProcess = new Service_CustomerBalanceProcess($customerId); $feeResult = $balanceProcess->freezeOtherFee($otherfee_czfm['price'],$otherfee_czfm['currency_code'],$ASNCode,$otherfee_czfm['fee_id'],'ASN提交扣操作费-M，冻结余额'); } } $result['ask']='1'; $result['message'] = 'ASN审核成功'; //$DB->rollBack(); $DB->commit(); } catch (Exception $e) { $DB->rollBack(); $result['error'][] = $e->getMessage(); $result['message'] = $e->getMessage(); return $result; } //print_r($result);exit; return $result; } /** * @author william-fan * @todo 打印清单 订单到在途 */ public static function printAsn($ASNCode = '',$customerId){ $result = array('ask' => 0, 'message' => '确认失败', 'error' => array()); $receiving = Service_Receiving::getByField($ASNCode,'receiving_code'); $error = array(); //print_r($receiving);exit; if(empty($receiving)){ $error[]='ASN无效'; }else{ if($receiving['receiving_status']!='4'){ $error[]='ASN状态错误'; } } if(empty($customerId)){ $result['message'] = '客户错误'; return $result; } if(!empty($error)){ $result['error'] = $error; return $result; } if($receiving['customer_id']!=$customerId){ $result['message'] = '该ASN和客户不一致'; return $result; } $session = new Zend_Session_Namespace('customerAuth'); $sessionData = $session->data; try { $DB = Common_Common::getAdapter(); $DB->beginTransaction(); $receivingRow = array( 'receiving_status'=>'5', 'receiving_update_time'=>date('Y-m-d H:i:s',time()), ); if(!Service_Receiving::update($receivingRow, $ASNCode,'receiving_code')){ throw new Exception("ASN状态更新失败"); } if($receiving['receive_model_type']=="1"){ $rod = Service_ReceivingOrderDetail::getByCondition(array('receiving_code'=>$receiving['receiving_code']),"*"); foreach($rod as $rodk=>$rodv){ $o = Service_Orders::getByField($rodv['order_code'],"order_code","*"); //$w = Service_Warehouse::getByField($o['warehouse_id'],"warehouse_id","*"); $shipOrderTracking = array( 'order_code'=>$o['order_code'], 'sot_location'=>"运输途中", 'sot_add_time'=>date("Y-m-d H:i:s"), 'warehouse_id'=>$o['warehouse_id'], 'sot_description'=>'集货ASN运输途中', 'sot_type'=>'0', 'sot_time_offset'=>'', 'tracking_number'=>$o['order_code'], 'ref_tracking_number'=>'', 'status_desc'=>'已提交', 'user_id'=>-1*$sessionData['id'] ); Service_ShipOrderTracking::add($shipOrderTracking); } } $conDetail = array( 'receiving_code'=>$ASNCode, ); $receivingDetail = Service_ReceivingDetail::getByCondition($conDetail); if(!empty($receivingDetail)){ foreach ($receivingDetail as $keyde=>$valuede){ $product = Service_Product::getByField($valuede['product_id']); $conInventory = array( 'customer_id'=>$customerId, 'product_id'=>$valuede['product_id'], 'warehouse_id'=>$receiving['warehouse_id'] ); $productInventory = Service_ProductInventory::getByCondition($conInventory); if(empty($productInventory)){ //添加一条product_inventory 记录 $productInventoryRow = array( 'product_barcode'=>$product['product_barcode'], 'customer_id'=>$customerId, 'product_id'=>$product['product_id'], 'warehouse_id'=>$receiving['warehouse_id'], 'pi_onway'=>$valuede['rd_receiving_qty'], 'pi_add_time'=>date('Y-m-d H:i:s',time()), ); Service_ProductInventory::add($productInventoryRow); $productInventoryLogRow = array( 'product_id'=>$product['product_id'], 'product_barcode'=>$product['product_barcode'], 'warehouse_id'=>$receiving['warehouse_id'], 'reference_code'=>$valuede['receiving_code'], 'user_id'=>'-1', 'pil_onway'=>$valuede['rd_receiving_qty'], 'pil_ip'=>Common_Common::getIP(), 'from_it_code'=>'Audited', 'to_it_code'=>'onway', 'pil_add_time'=>date('Y-m-d H:i:s',time()), 'pil_note'=>'清单打印', 'pil_quantity'=>$valuede['rd_receiving_qty'], ); Service_ProductInventoryLog::add($productInventoryLogRow); }else{ $inventory = $productInventory[0]; //修改product_inventory 记录 $productInventoryRow = array( 'pi_onway'=>$valuede['rd_receiving_qty']+$inventory['pi_onway'], 'pi_update_time'=>date('Y-m-d H:i:s',time()), ); Service_ProductInventory::update($productInventoryRow, $inventory['pi_id']); $productInventoryLogRow = array( 'product_id'=>$product['product_id'], 'product_barcode'=>$product['product_barcode'], 'warehouse_id'=>$receiving['warehouse_id'], 'reference_code'=>$valuede['receiving_code'], 'user_id'=>'-1', 'pil_onway'=>$valuede['rd_receiving_qty'], 'pil_pending'=>$inventory['pi_pending'], 'pil_sellable'=>$inventory['pi_sellable'], 'pil_unsellable'=>$inventory['pi_unsellable'], 'pil_reserved'=>$inventory['pi_reserved'], 'pil_shipped'=>$inventory['pi_shipped'], 'pil_ip'=>Common_Common::getIP(), 'from_it_code'=>'Audited', 'to_it_code'=>'onway', 'pil_add_time'=>date('Y-m-d H:i:s',time()), 'pil_note'=>'清单打印', 'pil_quantity'=>$valuede['rd_receiving_qty'], ); Service_ProductInventoryLog::add($productInventoryLogRow); } //修改产品的have_asn字段 $productRow = array( 'have_asn'=>'1', 'product_update_time'=>date('Y-m-d H:i:s') ); Service_Product::update($productRow, $valuede['product_id']); } } $customerRow = Service_Customer::getByField($customerId); $ASNLog = array( 'receiving_id'=>$receiving['receiving_id'], 'receiving_code' => $ASNCode, 'rl_type'=>'-1', 'user_id'=>'-1', 'customer_code' => $customerRow['customer_code'], 'rl_note' => "打印ASN单", 'rl_status_from'=>$receiving['receiving_status'], 'rl_status_to'=>'5', 'rl_add_time'=>date('Y-m-d H:i:s',time()), 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); $rab = array( 'receiving_id'=>$receiving['receiving_id'], 'receiving_code'=>$ASNCode, 'onway_time'=>date("Y-m-d H:i:s") ); Service_ReceivingAttribute::add($rab); $result['ask']='1'; $result['message'] = 'ASN状态更新成功'; //$DB->rollBack(); $DB->commit(); } catch (Exception $e) { $DB->rollBack(); $result['error'][] = $e->getMessage(); $result['message'] = $e->getMessage(); return $result; } return $result; } /** * @author william-fan * @todo 用于ASn关闭 */ public static function closeAssn($rd_id,$customerId){ $result = array('ask' => 0, 'message' => '关闭失败', 'error' => array()); $receivingDetail = Service_ReceivingDetail::getByField($rd_id); $error = array(); if(!empty($receivingDetail)){ $receiving = Service_Receiving::getByField($receivingDetail['receiving_code'],'receiving_code'); if($receivingDetail['rd_status']!='1'){ $error[] = '状态不是收货中不能关闭'; } if($receiving['receiving_status']!='6'){ $error[] = 'ASN状态不是收货中'; $result['message'] = 'ASN状态不是收货中'; } }else{ $error[] = '该ASN产品无效'; } if(!empty($error)){ $result['error'] = $error; return $result; } //送货数量和收货数量的差值 $gapreceives=$receivingDetail['rd_receiving_qty']-$receivingDetail['rd_received_qty']; if($gapreceives==0){ $result['message'] = '送货数量和收货数量一致,不能关闭'; return $result; } if(isset($receiving['customer_id']) && $receiving['customer_id']!=$customerId){ $result['message'] = '该ASN和客户不一致'; return $result; } try { $DB = Common_Common::getAdapter(); $DB->beginTransaction(); $datetime = date('Y-m-d H:i:s',time()); //获取asn产品信息 $receivingdetails = array( 'receiving_code'=>$receivingDetail['receiving_code'] ); $updateReceiving = true; //是否更新ASN状态 if(count($receivingdetails)>1){ foreach($receivingdetails as $red=>$valred){ if($valred['rd_id']!=$rd_id){ if($valred['rd_status']=='1'){ //还有收货中的产品不要更新ASN状态 $updateReceiving = false; break; } } } } $receivingDetailRow = array( 'rd_status'=>'1', 'rd_update_time'=>$datetime ); if(Service_ReceivingDetail::update($receivingDetailRow, $rd_id)){ //写日志 $customerRow = Service_Customer::getByField($customerId); $ASNLog = array( 'receiving_id'=>$rd_id, 'receiving_code' => $receivingDetail['receiving_code'], 'rl_type'=>'-1', 'user_id'=>'-1', 'customer_code' => $customerRow['customer_code'], 'rl_note' => "关闭ASN产品信息{$receivingDetail['product_barcode']},减少在途库存{$receivingDetail['rd_received_qty']}-{$receivingDetail['rd_received_qty']}", 'rl_add_time'=>date('Y-m-d H:i:s',time()), 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); //减少 product_inventory中pi_onway（在途）库存 $conInventory = array( 'customer_id'=>$customerId, 'product_id'=>$receivingDetail['product_id'], 'warehouse_id'=>$receiving['warehouse_id'], ); /* print_r($conInventory); exit; */ $productInventory=Service_ProductInventory::getByCondition($conInventory);//查找product_inventory中该customer_id该产品 该仓储的 if(!empty($productInventory)){ $productInventoryInfo = $productInventory[0]; $productInventoryRow = array( 'pi_onway'=>$productInventoryInfo['pi_onway']-$gapreceives, 'pi_update_time'=>$datetime, ); Service_ProductInventory::update($productInventoryRow, $productInventory[0]['pi_id']); $productInventoryLogRow = array( 'product_id'=>$receivingDetail['product_id'], 'product_barcode'=>$receivingDetail['product_barcode'], 'warehouse_id'=>$receiving['warehouse_id'], 'pil_onway'=>$productInventoryInfo['pi_onway']-$gapreceives, 'from_it_code'=>'onway', 'to_it_code'=>'onway', 'pil_quantity'=>$gapreceives, 'application_code'=>'userClose', 'pil_add_time'=>$datetime, 'pil_ip'=>Common_Common::getIP(), ); Service_ProductInventoryLog::add($productInventoryLogRow); //更新ASN单 if($updateReceiving){ $receivingRow = array( 'receiving_status'=>'7', 'receiving_update_time'=>$datetime, ); if(!Service_Receiving::update($receivingRow, $receiving['receiving_code'],'receiving_code')){ throw new Exception("ASN状态更新失败"); } $ASNLog = array( 'receiving_id'=>$receiving['receiving_id'], 'receiving_code' => $receiving['receiving_code'], 'rl_type'=>'-1', 'user_id'=>'-1', 'customer_code' => $customerRow['customer_code'], 'rl_note' => "关闭ASN,ASN状态改变", 'rl_add_time'=>$datetime, 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); } }else{ throw new Exception("{$receivingDetail['product_barcode']}无库存信息"); } }else{ //更新失败 throw new Exception("关闭失败,ASN详情数据更新失败"); } $result['ask']='1'; $result['message'] = 'ASN确认成功'; //$DB->rollBack(); $DB->commit(); } catch (Exception $e) { $DB->rollBack(); $result['error'][] = $e->getMessage(); $result['message'] = $e->getMessage(); return $result; } return $result; } /** * @author william-fan * @todo 移至草稿 */ public static function draftAsn($ASNCode = '',$customerId=''){ $result = array('ask' => 0, 'message' => '移至草稿失败', 'error' => array()); $receiving = Service_Receiving::getByField($ASNCode,'receiving_code'); $error = array(); if(empty($receiving)){ $error[]='收货单不存在'; $return['message'] = $result['message'].'收货单不存在'; return $result; }else{ if($receiving['receiving_status']!='0' && $receiving['receiving_status']!='2' ){ $error[]='ASN状态错误'; $return['message'] = $result['message'].'收货单状态只有删除和确认状态才能移至草稿'; return $result; } } if(empty($customerId)){ $result['message'] = '客户错误'; $result['message'] = $result['message'].'客户错误'; return $result; } $condition = array('reference_no'=>$receiving['reference_no'],'customer_id'=>$customerId,'receiving_status_arr'=>array('1','2','3','4','5','6','7')); $receivings = Service_Receiving::getByCondition($condition,'*'); $receiving = $receivings[0]; if(!empty($receivings) && $receiving['receiving_code']!=$ASNCode){ $result['message'] = "客户参考号已经存在"; return $result; } if(!empty($error)){ $result['error'] = $error; return $result; } if($receiving['customer_id']!=$customerId){ $result['message'] = '该收货单不属于当前客户'; return $result; } try { $DB = Common_Common::getAdapter(); $DB->beginTransaction(); $receivingRow = array( 'receiving_status'=>'1', 'receiving_update_time'=>date('Y-m-d H:i:s',time()), ); if(!Service_Receiving::update($receivingRow, $ASNCode,'receiving_code')){ throw new Exception("移至草稿失败"); } $customerRow = Service_Customer::getByField($customerId); $ASNLog = array( 'receiving_id'=>$receiving['receiving_id'], 'receiving_code' => $ASNCode, 'rl_type'=>'1', 'user_id'=>'-1', 'customer_code' => $customerRow['customer_code'], 'rl_status_from'=> $receiving['receiving_status'], 'rl_status_to'=>1, 'rl_note' => "ASN移至草稿", 'rl_add_time'=>date('Y-m-d H:i:s',time()), 'rl_ip'=>Common_Common::getIP() ); $conDetail = array( 'receiving_code'=>$ASNCode, ); /* $receivingDetail = Service_ReceivingDetail::getByCondition($conDetail); if(!empty($receivingDetail)){ foreach ($receivingDetail as $keyde=>$valuede){ $product = Service_Product::getByField($valuede['product_id']); $conInventory = array( 'customer_id'=>$customerId, 'product_id'=>$valuede['product_id'], 'warehouse_id'=>$receiving['warehouse_id'] ); $productInventory = Service_ProductInventory::getByCondition($conInventory); if(!empty($productInventory)){ $inventory = $productInventory[0]; //修改product_inventory 记录 $productInventoryRow = array( 'pi_onway'=>$inventory['pi_onway']-$valuede['rd_receiving_qty'], 'pi_update_time'=>date('Y-m-d H:i:s',time()), ); Service_ProductInventory::update($productInventoryRow, $inventory['pi_id']); $productInventoryLogRow = array( 'product_id'=>$product['product_id'], 'product_barcode'=>$product['product_barcode'], 'warehouse_id'=>$receiving['warehouse_id'], 'user_id'=>'-1', 'pil_onway'=>$valuede['rd_receiving_qty'], 'pil_ip'=>Common_Common::getIP(), ); Service_ProductInventoryLog::add($productInventoryLogRow); } //修改产品的have_asn字段 $receivingDetails =Service_ReceivingDetail::getByCondition(array('product_id'=>$valuede['product_id'])); $updateOrders = true; //是否更改产品是否有ASN if(!empty($receivingDetail)){ foreach($receivingDetails as $kde=>$vde){ $deReceiving = Service_Receiving::getByField($vde['receiving_id']); if(!$deReceiving['receiving_code']!==$ASNCode){ if($deReceiving['receiving_status']!='0' && $deReceiving['receiving_status']!='1'){ //不为草稿和删除的ASN 产品为有ASN 不能更新 $updateOrders = false; break; } } } } if($updateOrders){ $productRow = array( 'have_asn'=>'0', 'product_update_time'=>date('Y-m-d H:i:s') ); Service_Product::update($productRow, $valuede['product_id']); } } } */ self::createAsnLog($ASNLog); $result['ask']='1'; $result['message'] = "ASN{$ASNCode}移至草稿失败"; //$DB->rollBack(); $DB->commit(); } catch (Exception $e) { $DB->rollBack(); $result['error'][] = $e->getMessage(); $result['message'] = $e->getMessage(); return $result; } //print_r($result);exit; return $result; } /** * 状态统计 * @param int $customer_id * @param int $$mode_type * @param */ public static function statStatus($customer_id, $mode_type, $warehouse_ids) { $result = array(0=>array()); $statusText = self::getAsnStatus($mode_type); if($mode_type==1) unset($statusText['7']); else unset($statusText['0'], $statusText['7']); $list = Service_Receiving::stat($customer_id, $mode_type); foreach($list as $row) { if(!isset($statusText[$row['receiving_status']])) continue; $result[$row['warehouse_id']][$row['receiving_status']]['num'] = $row['num']; } $not_ids = array_diff($warehouse_ids, array_keys($result)); foreach($not_ids as $warehouse_id) $result[$warehouse_id] = array(); foreach($result as $warehouse_id=>$info) { foreach($statusText as $status=>$text) { if(isset($info[$status])) { $result[$warehouse_id][$status]['text'] = $text; } else { $result[$warehouse_id][$status]['num'] = 0; $result[$warehouse_id][$status]['text'] = $text; } if(!isset($result[0][$status])) { $result[0][$status] = array('text'=>$text,'num'=>0); } $result[0][$status]['num'] += $result[$warehouse_id][$status]['num']; } ksort($result[$warehouse_id]); } return $result; } public function createJHAsnToDsh($data,$customerId = '', $warehouseId = ''){ $result = array('ask' => 0, 'msg' => '', 'error' => array(), 'ASNCode' => ''); $session = new Zend_Session_Namespace('customerAuth'); $sessionData = $session->data; try { $DB = Common_Common::getAdapter(); $DB->beginTransaction(); $error = self::validate($data,$customerId); $errorOrder = self::validOrder($data); $errorAll = array_merge($error,$errorOrder['error']); if(!empty($errorAll)){ $result['error'] = $errorAll; $result['detail'] = $errorOrder['detail']; throw new Exception("错误"); } $date = date('Y-m-d H:i:s'); if (isset($data['ref_code']) && $data['ref_code'] != '') { $r = self::checkReferenceNo(array('reference_no' => $data['ref_code'], 'customer_id' => $customerId,'receiving_status_arr'=>array('1','2','3','4','5','6','7'))); if (!empty($r)) { throw new Exception(Ec_Lang::getInstance()->getTranslate('CustomerReferenceNumberExistence')); } } if ($customerId) { $this->setCustomer($customerId); } if ($this->_customerInfo['customer_status'] != 2) { throw new Exception(Ec_Lang::getInstance()->getTranslate('AccountIsNotActivated')); } if ($warehouseId) { $this->_warehouseId = $warehouseId; } $ASNCode = self::createCode(); $receiving['receiving_code'] = $ASNCode; $receiving['reference_no'] = $data['ref_code']; $receiving['warehouse_id'] = $warehouseId; $receiving['customer_id'] = $customerId; $receiving['customer_code'] = $this->_customerInfo['customer_code']; $receiving['receiving_type'] = isset($data['receiving_type'])?$data['receiving_type']:'0'; $receiving['receiving_status'] = '1'; $receiving['receiving_add_time']= $date; $receiving['receiving_update_time'] = date("Y-m-d H:i:s"); $receiving['is_delivery'] = $data['is_delivery']; //以下新增的内容 //$receiving['refercence_form_id']= $data['refercence_form_id']; $receiving['ie_port'] = $data['ie_port']; $receiving['form_type'] = $data['form_type']; $receiving['traf_name'] = $data['traf_name']; $receiving['wrap_type'] = $data['wrap_type']; $receiving['pack_no'] = $data['pack_no']; $receiving['traf_mode'] = $data['traf_mode']; $receiving ['trade_mode'] = $data ['trade_mode']; $receiving ['trans_mode'] = $data ['trans_mode']; $receiving['roughweight'] = $data['roughweight']; //$receiving['netweight'] = $data['netweight']; $receiving ['haveconta'] = '0'; $receiving ['conta_id'] = ''; $receiving ['conta_model'] = ''; $receiving ['conta_wt'] = '0'; $receiving['receive_model_type'] = '1'; $receiving ['receiving_description'] = $data ['instructions']; if (! isset ( $receiving ['receiving_type'] ) || $receiving ['receiving_type'] === '') { throw new Exception (Ec_Lang::getInstance()->getTranslate('ASNTypeIsEmpty')); } if ($warehouseId === '') { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehouseIsEmpty')); } $warehouse = Common_DataCache::getWareHouse(); if (!isset($warehouse[$warehouseId])) { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehousingDoesNotExist')); } if (!isset($receiving['customer_id']) || $receiving['customer_id'] == '') { $receiving['customer_id'] = $this->_customerId; } $receiving_id = Service_Receiving::add($receiving); $asnOrders = $data['asn_order']; //$sku = $data['sku']; foreach ($asnOrders as $keyo=>$orderCode) { //$product = Service_Product::getByField($v,'product_sku'); $orderInfo = Service_Orders::getByField($orderCode,'order_code'); $receiving_order_detail = array( 'receiving_id'=>$receiving_id, 'receiving_code'=>$ASNCode, 'rd_status'=>'0', 'order_code'=>$orderCode, 'rd_add_time'=>$date ); $receivingOrderDetailArr[] = $receiving_order_detail; if(!Service_ReceivingOrderDetail::add($receiving_order_detail)){ throw new Exception(Ec_Lang::getInstance()->getTranslate('AddASNDetailsFail')); } //修改订单到已提交状态 $orderRow = array( 'order_status'=>'4', 'update_time'=>$date ); Service_Orders::update($orderRow, $orderCode,'order_code'); $ol_type = 1; if($orderInfo['order_status']!=4){ $ol_type = 0; } $logRow = array( 'order_id'=>$orderInfo['order_id'], 'order_code'=>$orderInfo['order_code'], 'ol_type'=>$ol_type, 'order_status_from'=>$orderInfo['order_status'], 'order_status_to'=>4, 'ol_add_time'=>date('Y-m-d H:i:s'), 'user_id'=>'-1', 'account_id' => Service_Login::getUserId(), 'ol_ip'=>Common_Common::getIP() ); Service_OrderLog::add($logRow); $w = Service_Warehouse::getByField($orderInfo['warehouse_id'],'warehouse_id','*'); $shipOrderTracking = array( 'order_code'=>$orderInfo['order_code'], 'sot_location'=>"客户仓库", 'sot_add_time'=>date("Y-m-d H:i:s"), 'warehouse_id'=>$orderInfo['warehouse_id'], 'sot_description'=>'集货ASN新建成功,集货订单自动提交', 'sot_type'=>'0', 'sot_time_offset'=>'', 'tracking_number'=>$orderInfo['order_code'], 'ref_tracking_number'=>'', 'status_desc'=>'已提交', 'user_id'=>-1*$sessionData['id'] ); Service_ShipOrderTracking::add($shipOrderTracking); $orderOperationTime = array( 'order_id'=>$orderInfo['order_id'], 'order_code'=>$orderCode, 'submit_time'=>date("Y-m-d H:i:s"), 'submit_user_id'=>-1*$sessionData['id'] ); Service_OrderOperationTime::update($orderOperationTime,$orderCode,"order_code"); //预扣费 $balanceProcess = new Service_CustomerBalanceProcess(); $feeResult = $balanceProcess->freezeFee($orderCode, $customerId); if($feeResult !== true) throw new Exception($feeResult); } $note = 'create ASN'; $ASNLog = array( 'receiving_id'=>$receiving_id, 'receiving_code' => $ASNCode, 'user_id'=>'-1', 'customer_code' => $this->_customerInfo['customer_code'], 'rl_note' => $note, 'rl_add_time'=>$date, 'rl_status_from'=>'1', 'rl_status_to'=>'1', 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); if($receiving['receive_model_type']==0) { $law_weight = Service_ReceivingDetail::sumLawWeight($ASNCode); } else if($receiving['receive_model_type']==1) { } $law_weight = Service_ReceivingOrderDetail::sumLawWeight($ASNCode); if($law_weight > $receiving['roughweight']) { throw new Exception( '法定单位为千克的SKU的总重量['.$law_weight.']大于ASN毛重['.$receiving['roughweight'].']，请修改SKU的法定单位重量'); } $receivingRow = array( 'receiving_status'=>'2', 'receiving_update_time'=>date('Y-m-d H:i:s',time()), ); Service_Receiving::update($receivingRow, $ASNCode,'receiving_code'); $customerRow = Service_Customer::getByField($customerId); $ASNLog = array( 'receiving_id'=>$receiving_id, 'receiving_code' => $ASNCode, 'rl_type'=>'1', 'user_id'=>'-1', 'customer_code' => $customerRow['customer_code'], 'rl_note' => "确认ASN单", 'rl_status_from'=>1, 'rl_status_to'=>'2', 'rl_add_time'=>date('Y-m-d H:i:s',time()), 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); $conDetail = array( 'receiving_code'=>$ASNCode, ); $totalWeight = 0; $receivingDetail = Service_ReceivingOrderDetail::getByCondition($conDetail); if(!empty($receivingDetail)){ $totalWeight = 0; foreach ($receivingDetail as $keyde=>$valuede){ $totalWeight+= Service_Orders::calculateWeight($valuede['order_code']); } } $roughweight = $receiving['roughweight']; if($roughweight<$totalWeight){ throw new Exception("ASN重量({$roughweight}KG)小于净重({$totalWeight}KG)"); } $receivingRow = array( 'receiving_status'=>'3', //方便测试暂时为4 'receiving_update_time'=>date('Y-m-d H:i:s',time()), ); if(!Service_Receiving::update($receivingRow, $ASNCode,'receiving_code')){ throw new Exception("ASN移至待审核失败"); } $ASNLog = array( 'receiving_id'=>$receiving_id, 'receiving_code' => $ASNCode, 'rl_type'=>'-1', 'user_id'=>'-1', 'customer_code' => $customerRow['customer_code'], 'rl_note' => "移动ASN至待审核", 'rl_status_from'=>2, 'rl_status_to'=>'3', //方便测试暂时为4 'rl_add_time'=>date('Y-m-d H:i:s',time()), 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); self::separateAsn($ASNCode); if($receiving['is_delivery']=='1'){ //提货的ASN要提货费 //冻结提货费 $objOtherCalculte = new Common_CalculateOtherFee(); $keys = array( 'warehouseId' => $receiving['warehouse_id'], 'receiving_code'=>$ASNCode, ); $objOtherCalculte->setParams($keys); $otherfeeArr = $objOtherCalculte->getOtherFee('TIHUO'); $otherfee_tihuo = $otherfeeArr['data']['otherFee']['tihuo']; //print_r($otherfee_tihuo); if($otherfee_tihuo['price']>0){ $balanceProcess = new Service_CustomerBalanceProcess(); $feeResult = $balanceProcess->freezeASNFee($ASNCode, $customerId); if($feeResult !== true) { throw new Exception($feeResult); } } } $result['ask']='1'; $result['msg'] = "收货单号:{$ASNCode}创建成功"; //Ec_Lang::getInstance()->getTranslate('ASNCreatingSuccess'); //'ASN创建成功'; $result['ASNCode'] = $ASNCode; //$DB->rollBack(); $DB->commit(); } catch (Exception $e) { $DB->rollBack(); $result['error'][] = $e->getMessage(); $result['msg'] = $e->getMessage(); return $result; } return $result; } public function createBHAsnToDsh($data,$customerId = '', $warehouseId = ''){ $result = array('ask' => 0, 'msg' => '', 'error' => array(), 'ASNCode' => ''); $error = self::validate($data,$customerId); if(!empty($error)){ $result['error'] = $error; return $result; } $session = new Zend_Session_Namespace('customerAuth'); $sessionData = $session->data; try { $DB = Common_Common::getAdapter(); $DB->beginTransaction(); $date = date('Y-m-d H:i:s'); if (isset($data['ref_code']) && $data['ref_code'] != '') { $r = self::checkReferenceNo(array('reference_no' => $data['ref_code'], 'customer_id' => $customerId,'receiving_status_arr'=>array('1','2','3','4','5','6','7'))); if (!empty($r)) { throw new Exception(Ec_Lang::getInstance()->getTranslate('CustomerReferenceNumberExistence')); } } if ($customerId) { $this->setCustomer($customerId); } if ($this->_customerInfo['customer_status'] != 2) { throw new Exception(Ec_Lang::getInstance()->getTranslate('AccountIsNotActivated')); } if ($warehouseId) { $this->_warehouseId = $warehouseId; } $ASNCode = self::createCode(); $receiving['receiving_code'] = $ASNCode; $receiving['reference_no'] = $data['ref_code']; $receiving['warehouse_id'] = $warehouseId; $receiving['customer_id'] = $customerId; $receiving['customer_code'] = $this->_customerInfo['customer_code']; $receiving['receiving_type'] = isset($data['receiving_type'])?$data['receiving_type']:'0'; $receiving['receiving_status'] = '1'; $receiving['receiving_add_time']= $date; $receiving['is_delivery'] = $data['is_delivery']; //以下新增的内容 //$receiving['refercence_form_id']= $data['refercence_form_id']; $receiving['ie_port'] = $data['ie_port']; $receiving['form_type'] = $data['form_type']; $receiving['traf_name'] = $data['traf_name']; $receiving['wrap_type'] = $data['wrap_type']; $receiving['pack_no'] = $data['pack_no']; $receiving['traf_mode'] = $data['traf_mode']; $receiving ['trade_mode'] = $data ['trade_mode']; $receiving ['trans_mode'] = $data ['trans_mode']; $receiving['roughweight'] = $data['roughweight']; $receiving ['haveconta'] = '0'; $receiving ['conta_id'] = ''; $receiving ['conta_model'] = ''; $receiving ['conta_wt'] = '0'; $receiving ['receiving_description'] = $data ['instructions']; $receiving['receive_model_type'] = '0'; if (! isset ( $receiving ['receiving_type'] ) || $receiving ['receiving_type'] === '') { throw new Exception (Ec_Lang::getInstance()->getTranslate('ASNTypeIsEmpty')); } if ($warehouseId === '') { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehouseIsEmpty')); } $warehouse = Common_DataCache::getWareHouse(); if (!isset($warehouse[$warehouseId])) { throw new Exception(Ec_Lang::getInstance()->getTranslate('WarehousingDoesNotExist')); } if (!isset($receiving['customer_id']) || $receiving['customer_id'] == '') { $receiving['customer_id'] = $this->_customerId; } $receiving_id = Service_Receiving::add($receiving); $product_sku = $data['product_sku']; $sku = $data['sku']; $haveDeclare = false; if(isset($data['declared_value'])){ $haveDeclare=true; $declare =$data['declared_value']; } foreach ($product_sku as $k=>$v) { $productList = Service_Product::getByCondition(array('product_sku'=>$v,'customer_code'=>$this->_customerInfo['customer_code']),"*"); //$product = Service_Product::getByField($v,'product_sku'); $product = $productList[0]; if($haveDeclare){ $declare_vale = $declare[$k]; }else{ $declare_vale = $product['product_declared_value']; } $receivingDetail = array( 'receiving_id'=>$receiving_id, 'receiving_code'=>$ASNCode, 'rd_status'=>'0', 'product_id'=>$product['product_id'], 'product_barcode'=>$product['product_barcode'], 'op_declared_value'=>trim($declare_vale), 'rd_receiving_qty'=>trim($sku[$k]), 'rd_add_time'=>$date ); $receivingDetailArr[] = $receivingDetail; if(!Service_ReceivingDetail::add($receivingDetail)){ throw new Exception(Ec_Lang::getInstance()->getTranslate('AddASNDetailsFail')); } } $note = 'create'; foreach ($receivingDetailArr as $val) { $productRow = Service_Product::getByField($val['product_id'], 'product_id', array('product_sku')); $note .= ' sku:' . $productRow['product_sku'] . ' quantity:' . $val['rd_receiving_qty'] . ' '; } $ASNLog = array( 'receiving_id'=>$receiving_id, 'receiving_code' => $ASNCode, 'user_id'=>'-1', 'customer_code' => $this->_customerInfo['customer_code'], 'rl_note' => $note, 'rl_add_time'=>$date, 'rl_status_from'=>'1', 'rl_status_to'=>'1', 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); $receivingRow = array( 'receiving_status'=>'2', 'receiving_update_time'=>date('Y-m-d H:i:s',time()), ); if(!Service_Receiving::update($receivingRow, $ASNCode,'receiving_code')){ throw new Exception("ASN确认失败"); } $customerRow = Service_Customer::getByField($customerId); $ASNLog = array( 'receiving_id'=>$receiving_id, 'receiving_code' => $ASNCode, 'rl_type'=>'1', 'user_id'=>'-1', 'customer_code' => $customerRow['customer_code'], 'rl_note' => "确认ASN单", 'rl_status_from'=>1, 'rl_status_to'=>'2', 'rl_add_time'=>date('Y-m-d H:i:s',time()), 'rl_ip'=>Common_Common::getIP() ); $conDetail = array( 'receiving_code'=>$ASNCode, ); $receivingDetail = Service_ReceivingDetail::getByCondition($conDetail); if(!empty($receivingDetail)){ $totalWeight = 0; foreach ($receivingDetail as $keyde=>$valuede){ $product = Service_Product::getByField($valuede['product_id']); if(empty($product) || $product['product_type']=='1'){continue;} $totalWeight += $product['product_weight']*$valuede['rd_receiving_qty']; } } $roughweight = $receiving['roughweight']; if($roughweight<$totalWeight){ throw new Exception("ASN重量({$roughweight}KG)小于净重({$totalWeight}KG)"); } self::createAsnLog($ASNLog); $receivingRow = array( 'receiving_status'=>'3', //方便测试暂时为4 'receiving_update_time'=>date('Y-m-d H:i:s',time()), ); if(!Service_Receiving::update($receivingRow, $ASNCode,'receiving_code')){ throw new Exception("ASN移至待审核失败"); } $customerRow = Service_Customer::getByField($customerId); $ASNLog = array( 'receiving_id'=>$receiving_id, 'receiving_code' => $ASNCode, 'rl_type'=>'-1', 'user_id'=>'-1', 'customer_code' => $customerRow['customer_code'], 'rl_note' => "移动ASN至待审核", 'rl_status_from'=>2, 'rl_status_to'=>'3', //方便测试暂时为4 'rl_add_time'=>date('Y-m-d H:i:s',time()), 'rl_ip'=>Common_Common::getIP() ); self::createAsnLog($ASNLog); self::separateAsn($ASNCode); if($receiving['is_delivery']=='1'){ //提货的ASN要提货费 //冻结提货费 $objOtherCalculte = new Common_CalculateOtherFee(); $keys = array( 'warehouseId' => $receiving['warehouse_id'], 'receiving_code'=>$ASNCode, ); $objOtherCalculte->setParams($keys); $otherfeeArr = $objOtherCalculte->getOtherFee('TIHUO'); $otherfee_tihuo = $otherfeeArr['data']['otherFee']['tihuo']; //print_r($otherfee_tihuo); if($otherfee_tihuo['price']>0){ $balanceProcess = new Service_CustomerBalanceProcess(); $feeResult = $balanceProcess->freezeASNFee($ASNCode, $customerId); if($feeResult !== true) { throw new Exception($feeResult); } } } $result['ask']='1'; $result['msg'] = "收货订单[{$ASNCode}]创建成功."; //'ASN创建成功'; $result['ASNCode'] = $ASNCode; //$DB->rollBack(); $DB->commit(); } catch (Exception $e) { $DB->rollBack(); $result['error'][] = $e->getMessage(); $result['msg'] = $e->getMessage(); return $result; } return $result; } public static function separateAsn($receivingCode){ $receiving = Service_Receiving::getByField($receivingCode,'receiving_code',"*"); if($receiving['trade_mode']=="9610"||$receiving['trade_mode']=="1210"){ if($receiving['receive_model_type']=="1"){ $goodsIdArr = Service_OrderProduct::getGoodsId($receiving['receiving_code']); $sumNetWeight = Service_OrderProduct::calNetWeightByCondition(array('receiving_code'=>$receiving['receiving_code'])); }else{ $goodsIdArr = Service_ReceivingDetail::getGoodsId($receiving['receiving_code']); $sumNetWeight = Service_ReceivingDetail::sumNetWeight($receiving['receiving_code']); } $goodsIdArr = array_chunk($goodsIdArr,35); $subIndex = 1; //$gross_wt = ($receiving['roughweight']-$sumNetWeight)/count($goodsIdArr); $totalNetWeight = $sumNetWeight; foreach($goodsIdArr as $gk=>$gv){ if($subIndex<10){ $sub_receiving_code = $receiving['receiving_code']."-0".$subIndex; }else{ $sub_receiving_code = $receiving['receiving_code']."-".$subIndex; } $subIndex++; $receivingXml = array( 'receiving_code'=>$receiving['receiving_code'], 'sub_receiving_code'=>$sub_receiving_code, 'gross_wt'=>'0', 'net_wt'=>'0', 'pack_no'=>'0', 'refercence_form_id'=>'', 'rx_add_time'=>date("Y-m-d H:i:s"), 'receiving_xml_status'=>'3', ); Service_ReceivingXml::add($receivingXml); $RXdbObj = new Table_ReceivingXml(); $rxId = $RXdbObj->getAdapter()->lastInsertId(); $net_wt = 0; //$pack_no = 0; $G_NO_index = 1; foreach($gv as $goods_id){ if($receiving['receive_model_type']=="1"){ $productList = Service_OrderProduct::getJoinProductByCondition(array('goods_id'=>$goods_id,'receiving_code'=>$receiving['receiving_code'])); }else{ $productList = Service_ReceivingDetail::getJoinProductByCondition(array('goods_id'=>$goods_id,'receiving_code'=>$receiving['receiving_code'])); } $productRow = Service_Product::getByField($productList[0]['product_id'],'product_id',"*"); $currencyRow = Service_Currency::getByField($productRow['currency_code'],'currency_code',"*"); $receivingXmlDetail = array( 'rx_id'=>$rxId, 'from_id'=>$receiving['receiving_code'], 'sub_receiving_code'=>$sub_receiving_code, 'g_no'=>$G_NO_index, 'goods_id'=>$productList[0]['goods_id'], 'merger_g_no'=>$G_NO_index, 'code_ts'=>$productList[0]['hs_code'], 'g_name_cn'=>$productList[0]['hs_goods_name'], //'decl_price'=>"", 'curr'=>$currencyRow['currency_hs_code'], 'qty_1'=>0, 'unit_1'=>'', 'qty_2'=>'', 'unit_2'=>'', ); $g_qty = 0; $decl_total = 0; $decl_price = 0; foreach($productList as $p){ if($receiving['receive_model_type']=="1"){ $quantity = $p['op_quantity']; $g_qty+=$p['op_quantity']; }else{ $quantity = $p['rd_receiving_qty']; $g_qty+=$p['rd_receiving_qty']; } $hemList = Service_HsElementMap::getByCondition(array('product_id'=>$p['product_id']), 'hem_detail'); $elements = array(); foreach($hemList as $hemRow) $elements[] = $hemRow['hem_detail']; $receivingXmlDetail['g_model'] = implode('|',$elements); $hs_uom_map = Service_HsUomMap::getByField($p['product_id'],'product_id',"*"); $quantitylaw1 = isset($hs_uom_map['hum_quantity_law'])?$hs_uom_map['hum_quantity_law']:'0'; $receivingXmlDetail['qty_1'] += $quantitylaw1*$quantity; $quantitylaw2 = isset($hs_uom_map['hum_quantity_second'])?$hs_uom_map['hum_quantity_second']:"0"; $receivingXmlDetail['qty_2'] += $quantitylaw2*$quantity; if(!empty($hs_uom_map)) $hs_uom = Service_HsUom::getByField($hs_uom_map['hu_id'],'hu_id',"*"); $receivingXmlDetail['unit_1'] = isset($hs_uom['pu_code_law'])?$hs_uom['pu_code_law']:""; $receivingXmlDetail['unit_2'] = isset($hs_uom['pu_code_second'])?$hs_uom['pu_code_second']:""; $product = Service_Product::getByField($p['product_id'],"product_id","*"); $decl_total += $product['product_declared_value']*$quantity; $receivingXmlDetail['g_unit'] = $product['pu_code']; } //$pack_no+=$g_qty; $origin_country = "110"; if($receiving['receive_model_type']=="1"){ $ntWeight = Service_OrderProduct::calNetWeightByCondition(array('goods_id'=>$goods_id,'receiving_code'=>$receiving['receiving_code'])); $getTradeCountry = Service_ReceivingOrderDetail::getTradeCountry($receiving['receiving_code'],$goods_id); if(!empty($getTradeCountry)) $origin_country = $getTradeCountry[0]['trade_country']; }else{ $ntWeight = Service_ReceivingDetail::calNetWeightByCondition(array('goods_id'=>$goods_id,'receiving_code'=>$receiving['receiving_code'])); } $net_wt+= $ntWeight; $decl_price = sprintf("%.4f",$decl_total/$g_qty); $receivingXmlDetail['decl_price'] = $decl_price; $receivingXmlDetail['g_qty'] = $g_qty; $receivingXmlDetail['decl_total'] = $decl_total; $receivingXmlDetail['origin_country'] = $origin_country; Service_ReceivingXmlDetail::add($receivingXmlDetail); $G_NO_index++; } $updateReceivingXml = array( //'gross_wt'=>$net_wt+$gross_wt, 'net_wt'=>$net_wt, //'pack_no'=>$pack_no, ); Service_ReceivingXml::update($updateReceivingXml,$sub_receiving_code,'sub_receiving_code'); $aMessage['fmt_code'] = 'MRK'; $aMessage['fmt_type'] = 'BSG011'; $aMessage['refercence_no'] = $sub_receiving_code; $aMessage['fml_status'] = 1; $aMessage['fml_add_time'] = date('Y-m-d H:i:s'); Service_FtpMessageSendlist::add($aMessage); } $rxList = Service_ReceivingXml::getByCondition(array('receiving_code'=>$receivingCode),"*"); $growWeight = $receiving['roughweight']; $packNo = $receiving['pack_no']; $divPackNo = $receiving['pack_no']; foreach($rxList as $kk=>$rx){ $gross_wt = ($rx['net_wt']/$totalNetWeight)*$growWeight; $rx_pack_no = ($rx['net_wt']/$totalNetWeight)*$packNo; if($gross_wt<=1) { $gross_wt = 1; } if($kk==count($rxList)-1){ $rx_pack_no = $divPackNo; }else{ if($rx_pack_no<=1){ $rx_pack_no = 1; }else{ $rx_pack_no = floor($rx_pack_no); } $divPackNo = $divPackNo - $rx_pack_no; } if($rx_pack_no<=0) $rx_pack_no=1; $updateReceivingXml = array( 'gross_wt'=>$gross_wt, //'net_wt'=>$net_wt, 'pack_no'=>$rx_pack_no, ); Service_ReceivingXml::update($updateReceivingXml,$rx['sub_receiving_code'],'sub_receiving_code'); } } } /** * [unfreezeFeeSanZu 解冻杂费] * @param [type] $receivingData [description] * @param [type] $otherFeeObj [description] * @param [type] $otherFeeCode [description] * @return [type] [description] */ public static function unfreezeFee($receivingData,$otherFeeCode){ $lowerOtherFeeCode = strtolower($otherFeeCode); $keys = array( 'warehouseId' => (int) $receivingData['warehouse_id'], 'receiving_weight' => $receivingData['roughweight'], 'receiving_code' => $receivingData['receiving_code'], ); $objOtherCalculte = new Common_CalculateOtherFee(); $objOtherCalculte->setParams($keys); $otherfeeArr = $objOtherCalculte->getOtherFee($otherFeeCode); $otherfeeRow = $otherfeeArr['data']['otherFee'][$lowerOtherFeeCode]; if($otherfeeRow['price']>0){ $otherFeeInfo = Service_OtherFee::getByField($otherFeeCode, 'fee_code'); //解冻费用 if(!empty($otherFeeInfo)){ $asnOrder = $receivingData; $asnOrder['order_code'] = $receivingData['receiving_code']; $otherfeeArr = array( 'customer_id' => $receivingData['customer_id'], 'cbl_type' => '0', 'fee_id_gt' => '0', 'cbl_refer_code' => $receivingData['receiving_code'], 'fee_id' => $otherFeeInfo['fee_id'], ); //查询是其它费用的情况 $customerBalances = Service_CustomerBalanceLog::getByCondition($otherfeeArr); if(!empty($customerBalances)){ foreach ($customerBalances as $customerBalanceRow) { if($customerBalanceRow['un_cbl_id'] > 0){ continue; } Service_CustomerBalanceProcess::unfreezeOtherFee($asnOrder, $customerBalanceRow, 'ASN删除, 解冻'.$otherFeeInfo['fee_name']); } } } } } //通过分销平台的接口删除asn public static function deleteAsnFromFxInterface($receivingCode,$reason){ $receivingRow = Service_Receiving::getByField($receivingCode,'receiving_code',"*"); $DB = Common_Common::getAdapter(); $DB->beginTransaction(); $result = array( 'ask' => '0', 'message' => '入区单删除成功', ); try{ if($receivingRow['receive_model_type']=='1'){ $receivingOrdersCondition = array( 'receiving_code'=>$receivingCode, ); $receivingOrders = Service_ReceivingOrderDetail::getByCondition($receivingOrdersCondition); if(!empty($receivingOrders)){ foreach ($receivingOrders as $ko=>$vo){ $orderRow = Service_Orders::getByField($vo['order_code'],'order_code',"*"); $upOrderRow = array( 'order_status'=>'2', ); if($orderRow['sm_code']=="UKTL"||$orderRow['sm_code']=="SZY-EUB"||$orderRow['sm_code']=="SZY-ETK"||$orderRow['sm_code']=="WG-EUB"){ $upOrderRow['ref_tracking_number'] = ""; } Service_Orders::update($upOrderRow, $vo['order_code'],'order_code'); $logRow = array( 'order_id'=>$orderRow['order_id'], 'order_code'=>$vo['order_code'], 'ol_type'=>0, 'order_status_from'=>$orderRow['order_status'], 'order_status_to'=>2, 'ol_add_time'=>date('Y-m-d H:i:s'), 'user_id'=>'-1', 'ol_comments'=>'通过接口删除ASN:'.$reason, 'account_id' => Service_Login::getUserId(), 'ol_ip'=>Common_Common::getIP() ); Service_OrderLog::add($logRow); $balanceProcess = new Service_CustomerBalanceProcess(); $feeResult = $balanceProcess->unfreezeFee($vo['order_code'], 'ASN删除,解冻金额'); } Service_ReceivingOrderDetail::delete($receivingCode,'receiving_code'); } else{ throw new Exception("ASN和订单关联不存在"); } } //$objOtherCalculte = new Common_CalculateOtherFee(); if($receivingRow['is_delivery']=='1'){ self::unfreezeFee($receivingRow, 'TIHUO'); } if($receivingRow['receive_model_type']==0){ //解冻入库费 self::unfreezeFee($receivingRow, 'RUKU'); //解冻散租费 self::unfreezeFee($receivingRow, 'SANZU'); } $update = array( 'receiving_status' => 0, ); Service_Receiving::update($update,$receivingCode,"receiving_code"); $ASNLog = array( 'receiving_id'=>$receivingRow['receiving_id'], 'receiving_code' => $receivingCode, 'rl_type'=>'1', 'user_id'=>'-1', 'customer_code' => $receivingRow['customer_code'], 'rl_add_time' => date('Y-m-d H:i:s',time()), 'rl_status_from'=>$receivingRow['receiving_status'], 'rl_status_to'=>0, 'rl_ip' => Common_Common::getIP() ); self::createAsnLog($ASNLog); $DB->commit(); $result['ask'] = 1; }catch (Exception $e){ $DB->rollBack(); $result['ask'] = 0; $result['message'] = $e->getMessage(); } return $result; } } ?>