operationSoap = new SoapClient(null, array('location' =>$this->ordersOperationUrl,'uri'=>$this->ordersOperationUrl));
$this->otherSoap = new SoapClient(null, array('location' =>$this->trackGetUrl,'uri'=>$this->trackGetUrl));
}catch(Exception $e){
$this->errorMsg = $e->__toString();
}
}
//调用不存在的方法，报错提示
public function __call($name, $arguments) {
throw new Exception('当前没有此服务方法，请检查方法名是否有误');
}
// 对象转数组
protected function objectTransferArray($obj) {
$arr = is_object($obj)? get_object_vars($obj) : $obj;
$result = array();
foreach ($arr as $key => $val) {
$val = (is_array($val)) || is_object($val) ? $this->objectTransferArray($val) : $val;
$result[$key] = $val;
}
return $result;
}
//数组转对象
protected function arrayTransferObject($arr) {
$clsName = new stdClass();
foreach($arr as $key => $value) {
$clsName->$key = $value;
}
return $clsName;
}
//合并数组
protected function mergeArray($arrs0, $arrs1) {
foreach($arrs0 as $key0 => $value0) {
if(isset($arrs1[$key0]) && !empty($arrs1[$key0])) {
$arrs0[$key0] = $arrs1[$key0];
} else {
unset($arrs0[$key0]);
}
}
return $arrs0;
}
//将简单xml文件转换成数组
protected function simplest_xml_to_array($xmlstring) {
return json_decode(json_encode((array) simplexml_load_string($xmlstring)), true);
}
public function submitOrderForecast($orderRow){
//订单信息
$this->orderInfo = $orderRow;
// 收货地址
$orderReceiveAddress = Service_OrderAddressBook::getByCondition(array('order_code'=>$orderRow['order_code'],'oab_type'=>'0'),"*");
//收货国家
$reCountry = Service_Country::getByField($orderReceiveAddress[0]['oab_country_id'],"country_id","*");
$orderProduct = Service_OrderProduct::getByCondition(array('order_code'=>$orderRow['order_code']),"*");
$grossWeight= Service_Orders::calculateWeight($orderRow['order_code']);
$orderRow['customerWeight'] = sprintf('%.3f',$grossWeight); //客户重量
$withBattery = 0;
foreach($orderProduct as $value){
$productInfo = Service_Product::getByField($value['product_id'],"product_id","*");
$xmlCenterPart .= ''.
''.$productInfo['product_title'].''.//申报品名
''.$value['product_title_en'].''.//申报英文品名
''.//配货信息
''.round(($value['op_purpose_declared_value']*$value['op_quantity']),2).''.//申报价值
''.$value['op_quantity'].''.//申报数量
''.$productInfo['hs_code'].''.//海关货物编号
''.//配货备注
'USD'.//单位
''.$value['op_purpose_declared_value'].''.//申报单价
''.
''.round(($productInfo['product_weight']*$value['op_quantity']),3).''.
''.$productInfo['product_sku'].''.//产品sku
'';
if($productInfo['with_battery'] == 1){
$withBattery = 1;
}
}
//向服务商发送何种运输方式代码
$channelid = ($orderRow['sm_code'] == 'DHL-BH03') ? 'DHL03' : 'POSTNL5';
$xmlHeadPart = ''.
''.
''.$this->authToken.''.
''.$this->clientId.''.
''.
''.
''.
''.$orderRow['order_code'].''.//订单号
''.$channelid.''.//运输方式,运输方式为DHL-BH03强制改成DHL03发送服务商
''.$orderReceiveAddress[0]['oab_firstname'].$orderReceiveAddress[0]['oab_lastname'].''.//收件人名
''.$orderReceiveAddress[0]['oab_street_address1'].''.//收件人地址1
''.$orderReceiveAddress[0]['oab_street_address2'].''.//收件人地址2
''.$orderReceiveAddress[0]['oab_cell_phone'].''.//收件人电话
''.$orderReceiveAddress[0]['oab_company'].''.//收件人公司名称
''.$orderReceiveAddress[0]['oab_state'].''.//收件人省(州)
''.$orderReceiveAddress[0]['oab_city'].''.//收件人城市
''.$orderReceiveAddress[0]['oab_postcode'].''.//收件人邮编
''.$orderReceiveAddress[0]['oab_email'].''.//收件人电子邮箱
''.$reCountry['country_code'].''.//国检二字码
''.$orderRow['customerWeight'].''.//总重量（kg）
''.$withBattery.''.
'';
$xmlFootPart = ''.
''.
''.
'';
$xml = $xmlHeadPart.$xmlCenterPart.$xmlFootPart;
//header("Content-type:text/xml");
//echo $xml.'
';
//echo '';
//var_dump($this->simplest_xml_to_array($xml));
//echo '
';
return $this->push(__function__,$xml);
}
public function getOrderPrintLabel($orderRow){
//订单信息
$this->orderInfo = $orderRow;
//查询订单跟踪号
$orderRow = Service_Orders::getByField($orderRow['order_code'],'order_code',"*");
$xml = ''.
''.
''.$this->authToken.''.
''.$this->clientId.''.
''.$orderRow['ref_tracking_number'].''.
'http://k5.kingtrans.cn/'.//接口根地址
'100-100'.//打印纸张
'1,2,3'.
'0'.
'';
//echo $xml.'
';
return $this->push(__function__,$xml);
}
public function getTransBillidByCorpBillid($orderRow){
//订单信息
$this->orderInfo = $orderRow;
//查询订单跟踪号
$orderRow = Service_Orders::getByField($orderRow['order_code'],'order_code',"*");
//根据服务商系统单号获取获取运单号和转单号
$xml = ''.
''.
''.$this->authToken.''.
''.$this->clientId.''.
''.
''.$orderRow['agent_mailno'].''.
''.
'';
//echo '';
//var_dump($this->simplest_xml_to_array($xml));
//echo '
';
return $this->push(__function__,$xml);
}
public function getTrack($orderRow){
//订单信息
$this->orderInfo = $orderRow;
//查询订单跟踪号
$orderRow = Service_Orders::getByField($orderRow['order_code'],'order_code',"*");
$shipOrderRow = Service_ShipOrder::getByField($orderRow['order_code'],'order_code',"*");
if($orderRow['ref_tracking_number'] != $shipOrderRow['tracking_number']){
$trackingNumber = $shipOrderRow['tracking_number'];
}else{
$trackingNumber = $orderRow['ref_tracking_number'];
}
//根据追踪号获取轨迹信息
$xml = ''.
''.
''.$this->authToken.''.
''.$this->clientId.''.
''.$trackingNumber.''.
''.$this->trackLanguage.''.
'';
//echo '';
//var_dump($this->simplest_xml_to_array($xml));
//echo '
';
return $this->push(__function__,$xml);
}
//创建订单返回处理
private function submitOrderForecastResultProcess($result,$orderInfo){
$response = array(
'status' => 0,
'message' => ''
);
if(preg_match('/执行成功/',$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['Ack'])){
if($orderInfo['sm_code'] == 'DHL-BH03'){
$updateOrder = array(
'ref_tracking_number'=>$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['OrderItem']['billid'],//服务商单号,追踪号
//''=>$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['OrderItem']['refnumb'],//参考号,客户订单号
'agent_mailno'=>$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['OrderItem']['corpbillid'],//系统单号,单据编号,临时存放至agent_mailno字段
//''=>$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['OrderItem']['channelid'],//运输方式如：DHL,UPS 等
//''=>$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['OrderItem']['curflag'],//订单当前状态(0-待检查,1-已确认,2-待确认,3-已预报,4-已收货,5-已发货,6-已退货,7-已删除,8-缺货)
//'sync_status'=>'1'
);
}else{
$updateOrder = array(
'ref_tracking_number'=>$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['OrderItem']['billid'],//服务商单号,追踪号
//''=>$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['OrderItem']['refnumb'],//参考号,客户订单号
//'agent_mailno'=>$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['OrderItem']['corpbillid'],//系统单号,单据编号,临时存放至agent_mailno字段
//''=>$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['OrderItem']['channelid'],//运输方式如：DHL,UPS 等
//''=>$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['OrderItem']['curflag'],//订单当前状态(0-待检查,1-已确认,2-待确认,3-已预报,4-已收货,5-已发货,6-已退货,7-已删除,8-缺货)
//'sync_status'=>'1'
);
}
$orderLog = array(
'order_id' => $orderInfo['order_id'],
'order_code' => $orderInfo['order_code'],
'ol_type' => '1',
'order_status_from' => $orderInfo['order_status'],
'order_status_to' => $orderInfo['order_status'],
'ol_add_time' => date("Y-m-d H:i:s"),
'user_id' => 0,
'ol_comments' => $orderInfo['sm_code'].'自动取服务商单号'
);
//写入日志信息
Service_OrderLog::add($orderLog);
//更新数据库
Service_Orders::update($updateOrder, $orderInfo['order_id'], "order_id");
$response['status'] = 1;
$response['message'] = "订单" . $orderInfo['order_code'] . "获取单号" . $result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['OrderItem']['billid'] . "成功\n";
}else{
$response['message'] = '创建并预报订单失败，'.$result['CreateOrderServiceResponseArray']['CreateOrderServiceResponse']['Error'];
//防止正常多次请求服务商单号记录为错误日志，判断orders表中ref_tracking_number字段是否为空
$errorLog = array(
'order_code' => $orderInfo['order_code'],
'sm_code' => $orderInfo['sm_code'],
'content' => $response['message'],
);
if(empty($orderInfo['ref_tracking_number'])){
$errorLogId = Service_TrackingErrorLog::add($errorLog);
}
}
return $response;
}
//标签返回处理
private function getOrderPrintLabelResultProcess($result,$orderInfo){
$response = array(
'status' => 0,
'message' => ''
);
$file = APPLICATION_PATH . '/../data/pdf/KFive/' . $orderInfo['order_code'] . '.pdf';
if($result['Ack'] == 'true'){
$response['status'] = 1;
$response['message'] = '订单' . $orderInfo['order_code'] . "获取面单打印数据成功";
}else{
$response['message'] = '标签获取失败，'.$result['Errror'];
}
//远程读取PDF文件
if(!empty($result['printurl'])){
$fileContent = file_get_contents($result['printurl']);
}
//PDF文件不存在则创建
if(!file_exists($file)){
if('' != $fileContent){
// 没有文件夹则创建
$path_dir = APPLICATION_PATH . '/../data/pdf';
if(!is_readable($path_dir)){
is_file($path_dir) or mkdir($path_dir,0755);
}
$path_dir = APPLICATION_PATH . '/../data/pdf/KFive';
if(!is_readable($path_dir)){
is_file($path_dir) or mkdir($path_dir,0755);
}
$fp=fopen($file, "w+");
file_put_contents($file,$fileContent);
fclose($fp);
Service_OrdersLabel::add(array(
'order_code'=>$orderInfo['order_code'],
'ol_content'=> base64_encode($fileContent),
'ol_time'=>date('Y-m-d H:i:s')
));
}
}
return $response;
}
//查询运单号和转单号返回处理
private function getTransBillidByCorpBillidResultProcess($result,$orderInfo){
//查询订单跟踪号
$orderRow = Service_Orders::getByField($orderInfo['order_code'],'order_code',"*");
$response = array(
'status' => 0,
'message' => ''
);
if($result['Ack'] == 'true'){
$updateOrder = array(
'ref_tracking_number'=>$result['ReBillidArr']['transbillid'],//获取转单号
'agent_mailno'=>''//获取转单号成功后，跟踪号不一致，删除临时记录的接口方系统单号
);
//跟踪号不一致则更新覆盖
if($orderRow['ref_tracking_number'] !== $updateOrder['ref_tracking_number']){
$orderLog = array(
'order_id' => $orderInfo['order_id'],
'order_code' => $orderInfo['order_code'],
'ol_type' => '1',
'order_status_from' => $orderInfo['order_status'],
'order_status_to' => $orderInfo['order_status'],
'ol_add_time' => date("Y-m-d H:i:s"),
'user_id' => 0,
'ol_comments' => '服务商单号由'.$orderRow['ref_tracking_number'].'变为'.$updateOrder['ref_tracking_number']
);
//写入日志信息
Service_OrderLog::add($orderLog);
//更新数据库
Service_ShipOrder::update(array('tracking_number'=>$updateOrder['ref_tracking_number']), $orderInfo['order_code'] ,'order_code');
unset($updateOrder['ref_tracking_number']);
Service_Orders::update($updateOrder, $orderInfo['order_id'], "order_id");
}
$response['status'] = 1;
$response['message'] = "订单" . $orderInfo['order_code'] . "获取运单号或转单号成功\n";
}else{
$response['message'] = '根据订单号获取运单号和转单号失败,'.$result['Errror'];
$errorLog = array(
'order_code' => $orderInfo['order_code'],
'sm_code' => $orderInfo['sm_code'],
'content' => $response['message'],
);
$errorLogId = Service_TrackingErrorLog::add($errorLog);
}
return $response;
}
//查询获取轨迹信息处理
private function getTrackResultProcess($result,$orderInfo){
$response = array(
'status' => 0,
'message' => ''
);
if($result['Ack'] == 'true'){
foreach($result['Trackitem'] as $trackitem){
if(empty($trackitem['place']))continue;
$condtion=array(
'order_code'=>$orderInfo['order_code'],
'sot_location'=>$trackitem['place'],
'sot_description'=>$trackitem['intro']
);
$exitTracking= Service_ShipOrderTracking::getByCondition($condtion,'count(*)');
if(!$exitTracking){
$shipTracking=array(
'order_code'=>$orderInfo['order_code'],
'sot_location'=>$trackitem['place'],
'sot_add_time'=>$trackitem['sdate'],
//'sot_time_offset'=>'',
'warehouse_id'=>$orderInfo['warehouse_id'],
'sot_description'=>$trackitem['intro'],
//'sot_info_type'=>'',
'tracking_number'=>$result['Track']['transbillid'],
'ref_tracking_number'=>$orderInfo['ref_tracking_number'],
'status_desc'=>'物流完成'
);
Service_ShipOrderTracking::add($shipTracking);
}
}
//检测签收人字段是否为空，不为空，则表示已签收
if(!empty($result['Track']['deliverer'])){
$updateOrder = array(
'order_status' => 13,
'sync_status'=>'1'
);
$orderLog = array(
'order_id'=>$orderInfo['order_id'],
'order_code'=>$orderInfo['order_code'],
'ol_type'=>'1',
'order_status_from'=>$orderInfo['order_status'],
'order_status_to'=>13,
'ol_add_time'=>date("Y-m-d H:i:s"),
'user_id'=>0,
'ol_comments'=>'自动取运输轨迹,已签收'
);
Service_Orders::update($updateOrder, $orderInfo['order_code']);
Service_OrderLog::add($orderLog);
}
$response['status'] = 1;
$response['message'] = "订单" . $orderInfo['order_code'] . "获取物流轨迹成功\n";
}else{
$response['message'] = '根据运单号或转单号查询物流轨迹失败,'.$result['Error'];
$errorLog = array(
'order_code' => $orderInfo['order_code'],
'sm_code' => $orderInfo['sm_code'],
'content' => $response['message'],
);
$errorLogId = Service_TrackingErrorLog::add($errorLog);
}
return $response;
}
// 推送API
protected function push($method, $arr) {
$response = array(
'status' => 0,
'message' => '推送失败'
);
if (in_array($method, $this->operationArr)) {
$result = $this->operationSoap->__soapCall($method, array($arr));
}elseif(in_array($method,$this->otherArr)){
$result = $this->otherSoap->__soapCall($method, array($arr));
}
if (!$result) {
return $response;
}
$result = $this->simplest_xml_to_array(is_array($result) || is_object($result) ? $this->objectTransferArray($result) : $result);
//echo '';
//var_dump($result);
//echo '
';
$resultProcessFun = $method.'ResultProcess';
return $this->$resultProcessFun($result,$this->orderInfo);
}
}