mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-23 19:05:34 +08:00
400 lines
12 KiB
PHP
400 lines
12 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 wangbiao@shopex.cn
|
||
* @version 2024.04.11
|
||
*/
|
||
class erpapi_dealer_request_order extends erpapi_dealer_request_abstract
|
||
{
|
||
/**
|
||
* 淘宝全链路
|
||
*
|
||
* @return void
|
||
* @author
|
||
* */
|
||
|
||
public function message_produce($sdf,$queue=false){}
|
||
|
||
/**
|
||
* 获取店铺订单详情
|
||
*
|
||
* @param String $order_bn 订单号
|
||
* @return void
|
||
* @author
|
||
* */
|
||
public function get_order_detial($order_bn)
|
||
{
|
||
$params['tid'] = $order_bn;
|
||
$params = $this->__forma_params_get_order_detial($params);
|
||
$title = "店铺(".$this->__channelObj->channel['name'].")获取前端店铺".$order_bn."的订单详情";
|
||
|
||
$order_type = ($this->__channelObj->channel['business_type'] == 'zx') ? 'direct' : 'agent';
|
||
|
||
$api_name = $order_type == 'direct' ? SHOP_TRADE_FULLINFO_RPC : SHOP_FENXIAO_TRADE_FULLINFO_RPC;
|
||
|
||
$rsp = $this->__caller->call($api_name,$params,array(),$title,10,$order_bn);
|
||
|
||
$result = array();
|
||
$result['rsp'] = $rsp['rsp'];
|
||
$result['err_msg'] = $rsp['err_msg'];
|
||
$result['msg_id'] = $rsp['msg_id'];
|
||
$result['res'] = $rsp['res'];
|
||
$result['data'] = json_decode($rsp['data'],1);
|
||
$result['order_type'] = $order_type;
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* __forma_params_get_order_detial
|
||
* @param mixed $params 参数
|
||
* @return mixed 返回值
|
||
*/
|
||
public function __forma_params_get_order_detial($params)
|
||
{
|
||
return $params;
|
||
}
|
||
|
||
#获取订单状态
|
||
/**
|
||
* 获取OrderStatus
|
||
* @param mixed $arrOrderBn arrOrderBn
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getOrderStatus($arrOrderBn)
|
||
{
|
||
$order_bn = implode(',', $arrOrderBn);
|
||
$params = array('tids' => $order_bn);
|
||
$title = "店铺(" . $this->__channelObj->channel['name'] . ")获取前端店铺" . $order_bn . "的订单详情";
|
||
$rsp = $this->__caller->call(SHOP_GET_ORDER_STATUS, $params, array(), $title, 10, $order_bn);
|
||
return $this->doGetOrderStatusRet($rsp);
|
||
}
|
||
|
||
protected function doGetOrderStatusRet($rsp) {
|
||
$rsp['data'] = json_decode($rsp['data'], 1);
|
||
return $rsp;
|
||
}
|
||
|
||
#订单编辑
|
||
public function updateIframe($order,$is_request=true,$ext=array()) {
|
||
// 默认本地编辑
|
||
$data = array('edit_type'=>'local');
|
||
return array('rsp'=>'success','msg'=>'本地订单编辑','data'=>$data);
|
||
}
|
||
|
||
protected function getReceivedParams($sdf) {
|
||
return [];
|
||
}
|
||
|
||
/**
|
||
* received
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回值
|
||
*/
|
||
public function received($sdf){
|
||
$order = $sdf['order'];
|
||
list($api_name, $params) = $this->getReceivedParams($sdf);
|
||
if(empty($params)) {
|
||
return $this->succ('没有该接口');
|
||
}
|
||
$callback = array(
|
||
'class' => get_class($this),
|
||
'method' => 'callback',
|
||
);
|
||
$response = $this->__caller->call($api_name,$params,$callback,'订单接收回传',10,$order['order_bn']);
|
||
|
||
return $response;
|
||
}
|
||
|
||
/**
|
||
* reject
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回值
|
||
*/
|
||
public function reject($sdf){}
|
||
|
||
/**
|
||
* lackApply
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回值
|
||
*/
|
||
public function lackApply($sdf){}
|
||
|
||
#订单更新
|
||
/**
|
||
* 更新Order
|
||
* @param mixed $order order
|
||
* @return mixed 返回值
|
||
*/
|
||
public function updateOrder($order){}
|
||
|
||
/**
|
||
* 更新OrderStatus
|
||
* @param mixed $order order
|
||
* @param mixed $status status
|
||
* @param mixed $memo memo
|
||
* @param mixed $mode mode
|
||
* @return mixed 返回值
|
||
*/
|
||
public function updateOrderStatus($order , $status='' , $memo='' , $mode='sync'){}
|
||
|
||
/**
|
||
* 更新OrderTax
|
||
* @param mixed $order order
|
||
* @return mixed 返回值
|
||
*/
|
||
public function updateOrderTax($order){}
|
||
|
||
/**
|
||
* 更新OrderShipStatus
|
||
* @param mixed $order order
|
||
* @param mixed $queue queue
|
||
* @return mixed 返回值
|
||
*/
|
||
public function updateOrderShipStatus($order,$queue = false) {}
|
||
|
||
/**
|
||
* 更新OrderPayStatus
|
||
* @param mixed $order order
|
||
* @return mixed 返回值
|
||
*/
|
||
public function updateOrderPayStatus($order){}
|
||
|
||
/**
|
||
* 更新OrderMemo
|
||
* @param mixed $order order
|
||
* @param mixed $memo memo
|
||
* @return mixed 返回值
|
||
*/
|
||
public function updateOrderMemo($order,$memo){}
|
||
|
||
/**
|
||
* 添加OrderMemo
|
||
* @param mixed $order order
|
||
* @param mixed $memo memo
|
||
* @return mixed 返回值
|
||
*/
|
||
public function addOrderMemo($order,$memo){}
|
||
|
||
/**
|
||
* 添加OrderCustomMark
|
||
* @param mixed $order order
|
||
* @param mixed $memo memo
|
||
* @return mixed 返回值
|
||
*/
|
||
public function addOrderCustomMark($order,$memo){}
|
||
|
||
protected function __formatUpdateOrderShippingInfo($order) {
|
||
return array();
|
||
}
|
||
|
||
/**
|
||
* 更新OrderShippingInfo
|
||
* @param mixed $order order
|
||
* @return mixed 返回值
|
||
*/
|
||
public function updateOrderShippingInfo($order)
|
||
{
|
||
$rs = array('rsp'=>'fail','msg'=>'','data'=>'');
|
||
if (!$order) {
|
||
$rs['msg'] = 'no order';
|
||
return $rs;
|
||
}
|
||
$params = $this->__formatUpdateOrderShippingInfo($order);
|
||
if(empty($params)) {
|
||
$rs['msg'] = 'no params';
|
||
return $rs;
|
||
}
|
||
$callback = array(
|
||
'class' => get_class($this),
|
||
'method' => 'callback',
|
||
);
|
||
$title = '店铺('.$this->__channelObj->channel['name'].')更新[交易收货人信息]:'.$params['receiver_name'].'(订单号:'.$order['order_bn'].')';
|
||
$rs = $this->__caller->call(SHOP_UPDATE_TRADE_SHIPPING_ADDRESS_RPC,$params,$callback,$title,10,$order['order_bn']);
|
||
return $rs;
|
||
}
|
||
|
||
/**
|
||
* 更新OrderConsignerinfo
|
||
* @param mixed $order order
|
||
* @return mixed 返回值
|
||
*/
|
||
public function updateOrderConsignerinfo($order){}
|
||
|
||
/**
|
||
* 更新OrderSellagentinfo
|
||
* @param mixed $order order
|
||
* @return mixed 返回值
|
||
*/
|
||
public function updateOrderSellagentinfo($order){}
|
||
|
||
/**
|
||
* 更新OrderLimitTime
|
||
* @param mixed $order order
|
||
* @param mixed $order_limit_time order_limit_time
|
||
* @return mixed 返回值
|
||
*/
|
||
public function updateOrderLimitTime($order,$order_limit_time){}
|
||
|
||
#获取店铺指定时间范围内的订单
|
||
/**
|
||
* 获取OrderList
|
||
* @param mixed $start_time start_time
|
||
* @param mixed $end_time end_time
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getOrderList($start_time,$end_time) {
|
||
$rs = array('rsp'=>'fail','msg'=>'','data'=>array(),'is_update_time'=>'false');
|
||
$orderModel = app::get('ome')->model('orders');
|
||
$params = array(
|
||
'start_time' => date("Y-m-d H:i:s",$start_time),
|
||
'end_time' => date("Y-m-d H:i:s",$end_time),
|
||
'page_size' => 100,
|
||
'fields' => 'tid,status,pay_status,ship_status,modified',
|
||
'page_no' => 1,
|
||
);
|
||
|
||
$channel = $this->__channelObj->channel;
|
||
|
||
|
||
$trades = array();$lastmodify = null;
|
||
do {
|
||
$title = sprintf('获取店铺%s(%s-%s内)的订单%s',$channel['name'],$params['start_time'],$params['end_time'],$params['page_no']);
|
||
|
||
$return_data = $this->__caller->call(SHOP_GET_TRADES_SOLD_RPC,$params,array(),$title,10,$channel['shop_id']);
|
||
if ($return_data['data']) $return_data['data'] = @json_decode($return_data['data'], true);
|
||
|
||
if ($return_data['rsp'] != 'succ') break;
|
||
|
||
if (($params['page_no']-1)*$params['page_size']>intval($return_data['data']['total_results'])) break;
|
||
|
||
$tids = array();
|
||
foreach((array)$return_data['data']['trades'] as $t){
|
||
$trades[$t['tid']] = $t;
|
||
|
||
$tids[] = $t['tid'];
|
||
|
||
$lastmodify = strtotime($t['modified']);
|
||
}
|
||
|
||
if ($tids) {
|
||
$erporders = $orderModel->getList('outer_lastmodify,order_bn',array('order_bn'=>$tids,'shop_id'=>$channel['shop_id']));
|
||
// 判断是否漏单
|
||
foreach ($erporders as $order) {
|
||
if ($order['outer_lastmodify']>=strtotime($trades[$order['order_bn']]['modified'])) {
|
||
unset($trades[$order['order_bn']]);
|
||
}
|
||
}
|
||
}
|
||
|
||
$params['page_no']++;
|
||
} while (true);
|
||
|
||
$return = array(
|
||
'rsp' => $return_data['rsp'] == 'succ' ? 'success' : 'fail',
|
||
'msg' => ($return_data['rsp'] == 'succ' && !$trades) ? '未发现漏单' : $return_data['msg'],
|
||
'msg_id' => $return_data['msg_id'],
|
||
'data' => $trades,
|
||
'lastmodify' => $lastmodify,
|
||
);
|
||
|
||
return $return;
|
||
}
|
||
|
||
/**
|
||
* cleanStockFreeze
|
||
* @param mixed $order order
|
||
* @return mixed 返回值
|
||
*/
|
||
public function cleanStockFreeze($order){}
|
||
|
||
/**
|
||
* oid_sync
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回值
|
||
*/
|
||
public function oid_sync($sdf){}
|
||
|
||
/**
|
||
* serial_sync
|
||
* @param mixed $serialNumber serialNumber
|
||
* @return mixed 返回值
|
||
*/
|
||
public function serial_sync($serialNumber) {
|
||
$params = [];
|
||
$billId = [];
|
||
$billNo = '';
|
||
foreach ($serialNumber as $value) {
|
||
$billId[$value['bill_id']] = $value['bill_id'];
|
||
$billNo = $value['bill_no'];
|
||
$params[$value['bill_no']][] = $value['serial_number'];
|
||
}
|
||
$params = ['serial_number_data'=>json_encode($params)];
|
||
$title = '同步唯一码';
|
||
$obj = app::get('ome')->model('product_serial_history');
|
||
$snFilter = ['bill_id'=>$billId, 'bill_type'=>'3', 'sync|noequal'=>'succ'];
|
||
$obj->update(['sync'=>'run'], $snFilter);
|
||
$return_data = $this->__caller->call(SHOP_SERIALNUMBER_UPDATE,$params,array(),$title,10,$billNo);
|
||
if($return_data['rsp'] == 'succ') {
|
||
$obj->update(['sync'=>'succ'], $snFilter);
|
||
} else {
|
||
$obj->update(['sync'=>'fail'], $snFilter);
|
||
}
|
||
return $return_data;
|
||
}
|
||
|
||
/**
|
||
* 通知平台是否允许修改收货人地址
|
||
* @todo：现在只有抖音平台支持；
|
||
*
|
||
* @param $sdf
|
||
* @return array
|
||
*/
|
||
public function confirmModifyAdress($sdf)
|
||
{
|
||
$shop_type = $this->__channelObj->channel['shop_type'];
|
||
$plat_order_bn = $sdf['plat_order_bn'];
|
||
|
||
//只有抖音平台支持通知平台修改地址
|
||
if(!in_array($shop_type, array('luban'))){
|
||
return $this->succ();
|
||
}
|
||
|
||
/**
|
||
* 参数介绍：
|
||
* 0:同意;
|
||
* 1001:订单已进入拣货环节
|
||
* 1002:订单已进入配货环节
|
||
* 1003:订单已进入仓库环节
|
||
* 1004:订单已进入出库环节
|
||
* 1005:订单已进入发货环节
|
||
*/
|
||
$params = [
|
||
'tid' => $plat_order_bn,
|
||
'is_approved' => $sdf['confirm'] ? '0' : '1003',
|
||
'delivery_mode' => $this->__channelObj->channel['delivery_mode'], //标记(不重要的参数,只作为标记)
|
||
'shop_type' => $this->__channelObj->channel['shop_type'], //标记(不重要的参数,只作为标记)
|
||
];
|
||
|
||
$title = '通知平台买家修改收货地址';
|
||
$result = $this->__caller->call(SHOP_CONFIRM_ADDRESS_MODIFY, $params, array(), $title, 20, $plat_order_bn);
|
||
|
||
return $result;
|
||
}
|
||
} |