mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-23 02:45:33 +08:00
478 lines
18 KiB
PHP
478 lines
18 KiB
PHP
<?php
|
||
/**
|
||
* Copyright 2012-2026 ShopeX (https://www.shopex.cn)
|
||
*
|
||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||
* you may not use this file except in compliance with the License.
|
||
* You may obtain a copy of the License at
|
||
*
|
||
* http://www.apache.org/licenses/LICENSE-2.0
|
||
*
|
||
* Unless required by applicable law or agreed to in writing, software
|
||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||
* See the License for the specific language governing permissions and
|
||
* limitations under the License.
|
||
*/
|
||
/**
|
||
* @author ykm 2015-12-15
|
||
* @describe 电子面单请求类
|
||
*/
|
||
class erpapi_logistics_request_electron extends erpapi_logistics_request_abstract
|
||
{
|
||
protected $title;
|
||
protected $timeOut = 10;
|
||
protected $primaryBn = '';
|
||
protected $cacheLimit = 5000;
|
||
protected $directNum = 1;
|
||
protected $everyNum = 100;
|
||
|
||
//电子面单请求统一出口
|
||
final protected function requestCall($method,$params,$callback=array(),$orign_params=array(),$gateway='')
|
||
{
|
||
if(!$this->title) {
|
||
$this->title = $this->__channelObj->channel['name'] . $this->__channelObj->channel['channel_type'] . '获取电子面单';
|
||
}
|
||
// 御城河-运单直连
|
||
if (!$callback && $orign_params['order_bns']) {
|
||
$hchsafe = array(
|
||
'to_node_id' => $this->__configObj->get_to_node_id(),
|
||
'tradeIds' => $orign_params['order_bns'],
|
||
);
|
||
|
||
kernel::single('base_hchsafe')->order_push_log($hchsafe);
|
||
}
|
||
$this->__caller->writeFailLog = false;
|
||
|
||
return $this->__caller->call($method,$params,$callback,$this->title, $this->timeOut, $this->primaryBn,true,$gateway);
|
||
}
|
||
|
||
//回收电子面单 默认都做作废处理
|
||
/**
|
||
* recycleWaybill
|
||
* @param mixed $waybillNumber waybillNumber
|
||
* @param mixed $delivery_bn delivery_bn
|
||
* @return mixed 返回值
|
||
*/
|
||
|
||
public function recycleWaybill($waybillNumber,$delivery_bn = '') {
|
||
app::get('logisticsmanager')->model('waybill')->update(array('status'=>2,'create_time'=>time()),array('waybill_number'=>$waybillNumber));
|
||
}
|
||
|
||
protected function bufferBackToRet($rlt) {//各自实现
|
||
return array();
|
||
}
|
||
|
||
//缓存池异步回调方法
|
||
/**
|
||
* bufferRequestCallBack
|
||
* @param mixed $result result
|
||
* @param mixed $callback_params 参数
|
||
* @return mixed 返回值
|
||
*/
|
||
public function bufferRequestCallBack($result, $callback_params){
|
||
$rlt = $this->callback($result, $callback_params);
|
||
$arrWaybill = $this->bufferBackToRet($rlt);
|
||
if(empty($arrWaybill)) {
|
||
return array('rsp'=>'fail', 'msg'=>'数据处理失败');
|
||
}
|
||
$objChannel = app::get('logisticsmanager')->model('channel');
|
||
$channel = $objChannel->dump(array('channel_id'=>$callback_params['channel_id'], 'status'=>'true'));
|
||
if(empty($channel)) {
|
||
return array('rsp'=>'fail', 'msg'=>'电子面单来源缺失或停用');
|
||
}
|
||
$waybillModel = app::get('logisticsmanager')->model('waybill');
|
||
$data = array();
|
||
foreach($arrWaybill as $val) {
|
||
$val = trim($val);
|
||
$row = $waybillModel->dump(array('channel_id'=>$channel['channel_id'], 'waybill_number'=>$val), 'id');
|
||
if(!$row) {
|
||
$data[] = array(
|
||
'waybill_number' => $val,
|
||
'channel_id' => $channel['channel_id'],
|
||
'logistics_code' => $channel['logistics_code'],
|
||
'status' => 0,
|
||
'create_time' => time(),
|
||
);
|
||
}
|
||
}
|
||
if(empty($data)) {
|
||
return array('rsp'=>'fail', 'msg'=>'没有可用的单号');
|
||
}
|
||
$insertSql = ome_func::get_insert_sql($waybillModel, $data);
|
||
$ret = $waybillModel->db->exec($insertSql);
|
||
if($ret) {
|
||
return array('rsp'=>'succ', 'msg'=>'数据写入成功');
|
||
} else {
|
||
return array('rsp'=>'fail', 'msg'=>'数据写入失败');
|
||
}
|
||
}
|
||
|
||
//回传物流公司请求统一接口
|
||
final protected function deliveryCall($method,$logData,$params,$gateway='',$isAsync=true){
|
||
if(!$this->title) {
|
||
$this->title = $this->__channelObj->channel['name'] . $this->__channelObj->channel['channel_type'] . '电子面单物流回传';
|
||
}
|
||
$this->__caller->writeFailLog = false;
|
||
|
||
$logData['obj_bn'] = $this->primaryBn;
|
||
if($isAsync){
|
||
$callback = array(
|
||
'class' => get_class($this),
|
||
'method' => 'deliveryBack',
|
||
'params' => $logData
|
||
);
|
||
}
|
||
|
||
$ret = $this->__caller->call($method, $params, $callback, $this->title, $this->timeOut, $this->primaryBn,true,$gateway);
|
||
if(empty($callback)) {
|
||
return $this->deliveryBack($ret, $logData);
|
||
}
|
||
$this->logisticsLog($logData['logi_no'], $logData['delivery_id'], $params);
|
||
|
||
return true;
|
||
|
||
|
||
}
|
||
|
||
/**
|
||
* deliveryBack
|
||
* @param mixed $result result
|
||
* @param mixed $callback_params 参数
|
||
* @return mixed 返回值
|
||
*/
|
||
public function deliveryBack($result, $callback_params) {
|
||
|
||
if (in_array($callback_params['channel_type'],array('ems','360buy'))){
|
||
$rlt = $this->callback($result, $callback_params);
|
||
|
||
$logisticsLogObj = app::get('logisticsmanager')->model('logistics_log');
|
||
if ($rlt['rsp'] == 'succ'){
|
||
$logisticsLogObj->update(array('status'=>'success'),array('delivery_id'=>$callback_params['delivery_id'],'logi_no'=>$callback_params['logi_no']));
|
||
} else {
|
||
$logisticsLogObj->update(array('status'=>'fail'),array('delivery_id'=>$callback_params['delivery_id'],'logi_no'=>$callback_params['logi_no']));
|
||
}
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
protected function logisticsLog($logiNo, $delivery_id, $params) {
|
||
if (in_array($this->__channelObj->channel['channel_type'],array('ems','360buy'))){
|
||
//回填日志只针对EMS 和京东记录便于重试
|
||
$logisticsLogObj = app::get('logisticsmanager')->model('logistics_log');
|
||
$row = $logisticsLogObj->dump(array('logi_no'=>$logiNo, 'delivery_id'=>$delivery_id), 'log_id, retry');
|
||
if($row['log_id']) {
|
||
return $logisticsLogObj->update(array('retry'=>$row['retry']+1), array('log_id'=>$row['log_id']));
|
||
}
|
||
$logSdf = array(
|
||
'logi_no' => $logiNo,
|
||
'delivery_id' => $delivery_id,
|
||
'channel_id' => $this->__channelObj->channel['channel_id'],
|
||
'channel_type'=>$this->__channelObj->channel['channel_type'],
|
||
'status' => 'running',
|
||
'create_time' => time(),
|
||
'params' => $params,
|
||
);
|
||
return $logisticsLogObj->insert($logSdf);
|
||
}else{
|
||
return true;
|
||
}
|
||
|
||
}
|
||
|
||
//是否直辖市
|
||
/**
|
||
* isMunicipality
|
||
* @param mixed $province province
|
||
* @return mixed 返回值
|
||
*/
|
||
public function isMunicipality($province) {
|
||
$municipality = array('北京市', '上海市', '天津市', '重庆市');
|
||
$status = false;
|
||
foreach ($municipality as $zxs) {
|
||
if (substr($zxs, 0, strlen($province)) == $province) {
|
||
$status = true;
|
||
break;
|
||
}
|
||
}
|
||
return $status;
|
||
}
|
||
|
||
#过滤特殊字符
|
||
/**
|
||
* charFilter
|
||
* @param mixed $str str
|
||
* @return mixed 返回值
|
||
*/
|
||
public function charFilter($str){
|
||
if(strpos($str, '@hash')) {
|
||
return $str;
|
||
}
|
||
$str = str_replace(array('"','“','"','"',), '”', $str);
|
||
$str = str_replace(array("<",">","&","'",'"','','+','\\'),'',$str);
|
||
return $str;
|
||
}
|
||
|
||
/**
|
||
* 处理直连返回结果
|
||
*
|
||
*/
|
||
public function directDataProcess($data){
|
||
$channel = $this->__channelObj->channel;
|
||
|
||
$objWaybill = app::get('logisticsmanager')->model('waybill');
|
||
$waybillExtendModel = app::get('logisticsmanager')->model('waybill_extend');
|
||
foreach ($data as $val){
|
||
|
||
if($val['succ']) {
|
||
$logi_no = trim($val['logi_no']);
|
||
$arrWaybill = $objWaybill->dump(array('channel_id' => $channel['channel_id'], 'waybill_number' => $logi_no),'id,status');
|
||
if (!$arrWaybill) {
|
||
$arrWaybill = array(
|
||
'waybill_number' => $logi_no,
|
||
'channel_id' => $channel['channel_id'],
|
||
'logistics_code' => $channel['logistics_code'],
|
||
'status' => 1,
|
||
'create_time' => time(),
|
||
);
|
||
$ret = $objWaybill->insert($arrWaybill);
|
||
|
||
} elseif ($arrWaybill['status'] == '2') {
|
||
$objWaybill->update(array('status'=>'1'),array('id'=>$arrWaybill['id']));
|
||
}
|
||
if(!$val['noWayBillExtend']) {
|
||
$waybillExtend = array(
|
||
'waybill_id' => $arrWaybill['id'],
|
||
'mailno_barcode' => $val['mailno_barcode'],
|
||
'qrcode' => $val['qrcode'],
|
||
'sort_code' => $val['sort_code'],
|
||
'position' => $val['position']?:'',
|
||
'position_no' => $val['position_no']?:'',
|
||
'package_wdjc' => $val['package_wdjc'],
|
||
'package_wd' => $val['package_wd'],
|
||
'print_config' => $val['print_config'],
|
||
'json_packet' => $val['json_packet'],
|
||
);
|
||
|
||
$filter = array('waybill_id' => $waybillExtend['waybill_id']);
|
||
if (!$waybillExtendModel->dump($filter)) {
|
||
$ret = $waybillExtendModel->insert($waybillExtend);
|
||
} else {
|
||
$ret = $waybillExtendModel->update($waybillExtend, $filter);
|
||
}
|
||
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
/**
|
||
* bind
|
||
* @return mixed 返回值
|
||
*/
|
||
public function bind() {
|
||
$params = array(
|
||
'app' => 'app.applyNodeBind',
|
||
'node_id' => base_shopnode::node_id('ome'),
|
||
'from_certi_id' => base_certificate::certi_id(),
|
||
'callback' => kernel::openapi_url('openapi.ome.shop','shop_callback',array('channel_type'=>$this->node_type)),
|
||
'sess_callback' => urlencode(kernel::openapi_url('openapi.ome.shop','shop_callback',array('channel_type'=>$this->node_type))),
|
||
'api_url' => kernel::base_url(1).kernel::url_prefix().'/api',
|
||
'node_type' => $this->node_type,
|
||
'to_node' => $this->to_node,
|
||
'shop_name' => $this->shop_name,
|
||
);
|
||
if ($api_version = $this->getBindApiVersion()) {
|
||
$params['api_version'] = $api_version;
|
||
}
|
||
$params['certi_ac'] = $this->genBindSign($params);
|
||
$api_url = MATRIX_RELATION_URL . 'api.php';
|
||
$headers = array(
|
||
'Connection' => 5,
|
||
);
|
||
|
||
$core_http = kernel::single('base_httpclient');
|
||
$response = $core_http->set_timeout(5)->post($api_url, $params, $headers);
|
||
|
||
$response = json_decode($response,true);
|
||
|
||
$status = false;
|
||
if($response['res']=='succ' || $response['msg']['errorDescription'] == '绑定关系已存在,不需要重复绑定') {
|
||
$status = true;
|
||
}
|
||
return $status;
|
||
}
|
||
|
||
/**
|
||
* 获取BindApiVersion
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getBindApiVersion(){}
|
||
|
||
public function genBindSign($params) {
|
||
return base_certificate::getCertiAC($params);
|
||
}
|
||
|
||
protected function _formate_receiver_city($receiver_city)
|
||
{
|
||
$zhixiashi = array('北京','上海','天津','重庆');
|
||
$zizhiqu = array('内蒙古','宁夏回族','新疆维吾尔','西藏','广西壮族');
|
||
|
||
if (in_array($receiver_city,$zhixiashi)) {
|
||
$receiver_city = $receiver_city.'市';
|
||
}else if (in_array($receiver_city,$zizhiqu)) {
|
||
$receiver_city = $receiver_city.'自治区';
|
||
}else if($receiver_city == '广西'){
|
||
$receiver_city = $receiver_city.'壮族自治区';
|
||
}else if($receiver_city == '宁夏'){
|
||
$receiver_city = $receiver_city.'回族自治区';
|
||
|
||
}else if($receiver_city == '新疆'){
|
||
$receiver_city = $receiver_city.'维吾尔自治区';
|
||
}elseif(!preg_match('/(.*?)省/',$receiver_city)){
|
||
$receiver_city = $receiver_city.'省';
|
||
}
|
||
return $receiver_city;
|
||
}
|
||
|
||
//获取关联信息
|
||
/**
|
||
* 获取LogisticRelate
|
||
* @param mixed $logiId ID
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getLogisticRelate($logiId){
|
||
$dlyCorpRes = app::get('ome')->model('dly_corp')->dump(array('corp_id'=>$logiId),'channel_id,prt_tmpl_id');
|
||
$logChannelRes = app::get('logisticsmanager')->model('channel')->dump(array('channel_id'=>$dlyCorpRes['channel_id']),'shop_id');
|
||
list($jdbusinesscode,$shop_id) = explode('|||',$logChannelRes['shop_id']);
|
||
return array('prt_tmpl_id' => $dlyCorpRes['prt_tmpl_id'],'jd_businesscode' => $jdbusinesscode);
|
||
}
|
||
|
||
//是否为京东打印控件
|
||
/**
|
||
* isJdPrintControl
|
||
* @param mixed $corp_id ID
|
||
* @return mixed 返回值
|
||
*/
|
||
public function isJdPrintControl($corp_id){
|
||
$corp = app::get('ome')->model('dly_corp')->db_dump($corp_id, 'prt_tmpl_id, channel_id');
|
||
|
||
if ($corp['channel_id'] != $this->__channelObj->channel['channel_id']) {
|
||
$prtTmpl = app::get('ome')->model('dly_corp_channel')->db_dump(
|
||
array('channel_id' => $this->__channelObj->channel['channel_id'], 'corp_id' => $corp_id), 'prt_tmpl_id');
|
||
|
||
if ($prtTmpl) {
|
||
$corp['prt_tmpl_id'] = $prtTmpl['prt_tmpl_id'];
|
||
}
|
||
}
|
||
|
||
$tmpRes = app::get('logisticsmanager')->model('express_template')->dump(array('template_id'=>$corp['prt_tmpl_id']),'control_type');
|
||
|
||
return $tmpRes['control_type'] == 'jd'?true:false;
|
||
}
|
||
|
||
//获取京东打印数据
|
||
/**
|
||
* 获取PrintData
|
||
* @param mixed $deliveryIdList ID
|
||
* @param mixed $delivery delivery
|
||
* @param mixed $jdBusinesscode jdBusinesscode
|
||
* @param mixed $jpwj jpwj
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getPrintData($deliveryIdList,$delivery,$jdBusinesscode,$jpwj='jp'){
|
||
$this->title = '获取京东打印数据';
|
||
$orderNo = $delivery['order_bns'][0];
|
||
$mapCode = [];
|
||
$params = [];
|
||
if($jpwj == 'jp') {
|
||
$mapCode['ewCustomerCode'] = $jdBusinesscode;
|
||
|
||
$params['cp_code'] = 'JD';
|
||
}
|
||
|
||
if($jpwj == 'wj') {
|
||
$jdalpha = explode('|||',$this->__channelObj->channel['shop_id']);
|
||
$mapCode['eCustomerCode'] = $jdalpha[2];
|
||
}
|
||
|
||
$shopRes = app::get('ome')->model('shop')->dump(array('shop_id'=>$delivery['shop_id']),'tbbusiness_type');
|
||
$popFlag = $shopRes['tbbusiness_type'] == 'SOP'?1:0;
|
||
|
||
$waybillInfos = array();
|
||
foreach ($deliveryIdList as $key => $logiNo) {
|
||
$waybillInfos[$key]['orderNo'] = $orderNo;
|
||
$waybillInfos[$key]['popFlag'] = $popFlag;
|
||
$waybillInfos[$key]['wayBillCode'] = $logiNo;
|
||
$waybillInfos[$key]['jdWayBillCode'] = $logiNo;
|
||
}
|
||
|
||
$params['map_code'] = json_encode($mapCode);
|
||
$params['waybill_infos'] = json_encode($waybillInfos);
|
||
$params['object_id'] = substr(time(), 4).uniqid();
|
||
$back = $this->requestCall(STORE_USER_DEFINE_AREA, $params);
|
||
|
||
$printData = '';
|
||
if($back['rsp'] == 'succ'){
|
||
$data = json_decode($back['data'],true);
|
||
$printData = $data['jingdong_printing_printData_pullData_responce']['returnType']['prePrintDatas'][0]['perPrintData']?:'';
|
||
}
|
||
return [$printData, $back['res']];
|
||
}
|
||
|
||
/**
|
||
* 获取EncryptPrintData
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getEncryptPrintData($sdf) {return $this->error('不支持获取打印数据');}
|
||
|
||
/**
|
||
* 替换使用平台订单号，进行取号电子面单
|
||
*
|
||
* @param $deliveryInfo
|
||
* @return void
|
||
*/
|
||
public function _formatPlatformOrderBn($deliveryInfo)
|
||
{
|
||
$orderMdl = app::get('ome')->model('orders');
|
||
|
||
//order_bns
|
||
$orderBns = $deliveryInfo['order_bns'];
|
||
|
||
//order_bn这个下标应该是不存在的
|
||
if($deliveryInfo['order_bn']){
|
||
$orderBns = array_merge($orderBns, array($deliveryInfo['order_bn']));
|
||
}
|
||
|
||
//unique
|
||
$orderBns = array_unique(array_filter($orderBns));
|
||
|
||
//orders
|
||
$yjdfOrders = $orderMdl->getList('order_id,order_bn,platform_order_bn', array('order_bn'=>$orderBns));
|
||
$yjdfOrders = array_column($yjdfOrders, null, 'order_bn');
|
||
if(empty($yjdfOrders)){
|
||
return array();
|
||
}
|
||
|
||
//format
|
||
$dlyOrderBns = $deliveryInfo['order_bns'];
|
||
$dly_order_bn = $deliveryInfo['order_bn'];
|
||
foreach ($dlyOrderBns as $key => $order_bn)
|
||
{
|
||
if(isset($yjdfOrders[$order_bn]) && $yjdfOrders[$order_bn]['platform_order_bn']){
|
||
$dlyOrderBns[$key] = $yjdfOrders[$order_bn]['platform_order_bn'];
|
||
|
||
//order_bn
|
||
if($dly_order_bn && $dly_order_bn == $order_bn){
|
||
$dly_order_bn = $yjdfOrders[$order_bn]['platform_order_bn'];
|
||
}
|
||
}
|
||
}
|
||
|
||
return array('order_bns'=>$dlyOrderBns, 'order_bn'=>$dly_order_bn);
|
||
}
|
||
}
|