mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-22 18:35:35 +08:00
320 lines
12 KiB
PHP
320 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.
|
||
*/
|
||
|
||
/**
|
||
* 退货单推送
|
||
*
|
||
* @category
|
||
* @package
|
||
* @author chenping<chenping@shopex.cn>
|
||
* @version $Id: Z
|
||
*/
|
||
class erpapi_wms_request_reship extends erpapi_wms_request_abstract
|
||
{
|
||
|
||
/**
|
||
* 退货单创建
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
public function reship_create($sdf)
|
||
{
|
||
$reship_bn = $sdf['reship_bn'];
|
||
|
||
// 判断是否已被删除
|
||
$iscancel = kernel::single('console_service_commonstock')->iscancel($reship_bn);
|
||
if ($iscancel) {
|
||
$this->succ('退货单已取消,终止同步');
|
||
}
|
||
$this->_dealEncryptData($sdf);
|
||
$title = $this->__channelObj->wms['channel_name'] . '退货单添加';
|
||
|
||
$params = $this->_format_reship_create_params($sdf);
|
||
|
||
$callback = array(
|
||
'class' => get_class($this),
|
||
'method' => 'reship_create_callback',
|
||
'params' => array('reship_bn' => $reship_bn, 'obj_bn' => $reship_bn, 'obj_type' => 'reship'),
|
||
);
|
||
|
||
$retry = array(
|
||
'obj_bn' => $reship_bn,
|
||
'obj_type' => 'reship',
|
||
'channel' => 'wms',
|
||
'channel_id' => $this->__channelObj->wms['channel_id'],
|
||
'method' => 'reship_create',
|
||
'args' => func_get_args(),
|
||
'next_obj_type' => $this->_getNextObjType()
|
||
);
|
||
$apiFailId = app::get('erpapi')->model('api_fail')->saveRunning($retry);
|
||
if($apiFailId) {
|
||
$callback['params']['api_fail_id'] = $apiFailId;
|
||
}
|
||
|
||
// 判断是否加密
|
||
$gateway = '';
|
||
$sdf['shop_type'] = $sdf['shop_type'] == 'tmall' ? 'taobao' : $sdf['shop_type'];
|
||
if (kernel::single('ome_security_router', $sdf['shop_type'])->is_encrypt($sdf, 'reship')) {
|
||
$params['s_node_type'] = $sdf['shop_type'];
|
||
$params['s_node_id'] = $sdf['node_id'];
|
||
$params['order_bns'] = $sdf['order_bn'];
|
||
|
||
$need_encrypt_list = $this->__channelObj->wms['config']['need_encrypt'];
|
||
if ($need_encrypt_list && $need_encrypt_list[$sdf['shop_type']]) {
|
||
$params['need_encrypt'] = 'true';
|
||
}
|
||
|
||
$gateway = $sdf['shop_type'];
|
||
}
|
||
|
||
return $this->__caller->call(WMS_RETURNORDER_CREATE, $params, $callback, $title, 10, $reship_bn, true, $gateway);
|
||
}
|
||
|
||
protected function _dealEncryptData(&$sdf) {
|
||
$shop_type = $sdf['shop_type'] == 'tmall' ? 'taobao' : $sdf['shop_type'];
|
||
if (kernel::single('ome_security_router', $shop_type)->is_encrypt($sdf, 'reship')) {
|
||
foreach ($sdf as $key => $string) {
|
||
if(is_string($string)) {
|
||
$is_encrypt = kernel::single('ome_security_hash')->check_encrypt($string);
|
||
if ($is_encrypt) {
|
||
if($index = strpos($string, '>>')) {
|
||
$sdf[$key] = substr($string, 0, $index);
|
||
continue;
|
||
}
|
||
|
||
if($index = strpos($string, '@hash')) {
|
||
$sdf[$key] = substr($string, 0, $index);
|
||
continue;
|
||
}
|
||
|
||
if($index = strpos($string, '>>')) {
|
||
$sdf[$key] = substr($string, 0, $index);
|
||
continue;
|
||
}
|
||
}
|
||
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
public function reship_create_callback($response, $callback_params)
|
||
{
|
||
// 更新外部编码
|
||
$rsp = $response['rsp'];
|
||
$err_msg = $response['err_msg'];
|
||
$data = @json_decode($response['data'], true);
|
||
$data = is_array($data) ? $data : [];
|
||
$msg_id = $response['msg_id'];
|
||
$res = $response['res'];
|
||
|
||
$reship_bn = $callback_params['reship_bn'];
|
||
$reshipObj = app::get('ome')->model('reship');
|
||
if ($data['wms_order_code'] && $reship_bn) {
|
||
$reshipObj->db->exec("UPDATE sdb_ome_reship SET out_iso_bn='" . $data['wms_order_code'] . "' WHERE reship_bn='" . $reship_bn . "'");
|
||
}
|
||
$reshipObj->update(['sync_status'=>($rsp == 'succ' ? '3' : '2'),'sync_msg'=>$err_msg], ['reship_bn'=>$reship_bn]);
|
||
/***
|
||
* @todo：(已咨询同事)注销此段代码;
|
||
* $this->_getNextObjType()方法不存在,导致回调报500错误;
|
||
*
|
||
if ($rsp == 'succ' && $this->_getNextObjType()) {
|
||
//把单号加进队列
|
||
$failApiModel = app::get('erpapi')->model('api_fail');
|
||
$api_data = array(
|
||
'obj_type' => $this->_getNextObjType(),
|
||
'obj_bn' => $reship_bn,
|
||
'obj_id' => '',
|
||
'params' => $callback_params['params'],
|
||
|
||
);
|
||
$failApiModel->publish_api_fail(WMS_INORDER_GET, $api_data, array('rsp' => 'fail'));
|
||
|
||
}
|
||
***/
|
||
|
||
$callback_params['obj_bn'] = $reship_bn;
|
||
$callback_params['obj_type'] = 'reship';
|
||
return $this->callback($response, $callback_params);
|
||
}
|
||
|
||
protected function _format_reship_create_params($sdf)
|
||
{
|
||
$sdf['item_total_num'] = $sdf['line_total_count'] = count($sdf['items']);
|
||
|
||
$items = array('item' => array());
|
||
if ($sdf['items']) {
|
||
sort($sdf['items']);
|
||
foreach ((array) $sdf['items'] as $k => $v) {
|
||
// 获取外部商品sku
|
||
$items['item'][] = array(
|
||
'item_code' => $v['bn'],
|
||
'item_name' => $v['name'],
|
||
'item_quantity' => (int) $v['num'],
|
||
'item_price' => $v['price'] ? (float) $v['price'] : 0, // TODO: 商品价格
|
||
'item_line_num' => ($k + 1), // TODO: 订单商品列表中商品的行项目编号，即第n行或第n个商品
|
||
'trade_code' => '', //可选(若是淘宝交易订单，并且不是赠品，必须要传订单来源编号)
|
||
'item_id' => $v['bn'], // 商品ID
|
||
'is_gift' => '0', // TODO: 判断是否为赠品0:不是1:是
|
||
'item_remark' => '', // TODO: 商品备注
|
||
'inventory_type' => $sdf['branch_type'] == 'damaged' ? '101' : '1', // TODO: 库存类型1可销售库存101类型用来定义残次品201冻结类型库存301在途库存
|
||
);
|
||
}
|
||
}
|
||
|
||
$create_time = preg_match('/-|\//', $sdf['create_time']) ? $sdf['create_time'] : date("Y-m-d H:i:s", $sdf['create_time']);
|
||
$reship_bn = $sdf['reship_bn'];
|
||
|
||
$shop_code = kernel::single('wmsmgr_func')->getWmsShopCode($this->__channelObj->wms['channel_id'], $sdf['shop_bn']);
|
||
|
||
$params = array(
|
||
'uniqid' => self::uniqid(),
|
||
'source' => (string)$shop_code,
|
||
'wms_supplier' => '', // TODO: 服务提供商编号
|
||
'out_order_code' => $reship_bn,
|
||
'warehouse_code' => $sdf['branch_bn'],
|
||
'orig_order_code' => $sdf['original_delivery_bn'],
|
||
'created' => $create_time,
|
||
'logistics_no' => $sdf['logi_no'],
|
||
'logistics_code' => $this->get_logistics_code($sdf['logi_name']),
|
||
'logistics_name' => $sdf['logi_name'], //物流公司名称
|
||
'remark' => $sdf['memo'],
|
||
'platform_order_code' => $sdf['order_bn'], //订单号
|
||
'wms_order_code' => $reship_bn,
|
||
'is_finished' => 'true',
|
||
'current_page' => '1', // 当前批次,用于分批同步
|
||
'total_page' => '1', // 总批次,用于分批同步
|
||
'receiver_name' => $sdf['receiver_name'],
|
||
'receiver_zip' => $sdf['receiver_zip'],
|
||
'receiver_state' => $sdf['receiver_state'],
|
||
'receiver_city' => $sdf['receiver_city'],
|
||
'receiver_district' => $sdf['receiver_district'],
|
||
'receiver_address' => $sdf['receiver_addr'],
|
||
'receiver_phone' => $sdf['receiver_tel'],
|
||
'receiver_mobile' => $sdf['receiver_mobile'],
|
||
'receiver_email' => $sdf['receiver_email'],
|
||
'sign_code' => '', // TODO: 节点标识，请求唯一标识
|
||
'dest_plan' => '', // TODO: 目的计划点
|
||
'line_total_count' => $sdf['line_total_count'], // TODO: 订单行项目数量
|
||
'storage_code' => $sdf['storage_code'], // 库内存放点编号
|
||
'items' => json_encode($items),
|
||
'shop_nick' => $this->_getShopCode(array('shop_bn' => $sdf['shop_bn'])),
|
||
'return_reason' => $sdf['return_reason'],
|
||
);
|
||
|
||
return $params;
|
||
}
|
||
|
||
public function reship_cancel($sdf)
|
||
{
|
||
return $this->error('接口方法不存在', 'w402');
|
||
}
|
||
|
||
/**
|
||
* 退货单创建取消
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
/*
|
||
public function reship_cancel($sdf){
|
||
$reship_bn = $sdf['reship_bn'];
|
||
|
||
$title = $this->__channelObj->wms['channel_name'].'退货单取消'.$reship_bn;
|
||
|
||
$params = $this->_format_reship_cancel_params($sdf);
|
||
|
||
return $this->__caller->call(WMS_RETURNORDER_CANCEL, $params, null, $title, 10, $reship_bn);
|
||
}*/
|
||
|
||
/**
|
||
* undocumented function
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
protected function _format_reship_cancel_params($sdf)
|
||
{
|
||
$params = array(
|
||
'out_order_code' => $sdf['reship_bn'],
|
||
'warehouse_code' => $sdf['branch_bn'],
|
||
);
|
||
|
||
return $params;
|
||
}
|
||
|
||
protected function _get_search_api() {
|
||
return '';
|
||
}
|
||
/**
|
||
* 退货单查询
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
public function reship_search($sdf)
|
||
{
|
||
$title = $this->__channelObj->wms['channel_name'] . '退货单查询';
|
||
|
||
$params = $this->_format_search_params($sdf);
|
||
|
||
$apiName = $this->_get_search_api();
|
||
if(empty($apiName)) {
|
||
return;
|
||
}
|
||
$rs = $this->__caller->call($apiName, $params, null, $title, 10, $sdf['stockin_bn']);
|
||
$failModel = app::get('erpapi')->model('api_fail');
|
||
if ($rs['rsp'] == 'succ') {
|
||
$result = $this->_deal_search_result($rs);
|
||
if ($result['data']) {
|
||
$rs = kernel::single('erpapi_router_response')->set_node_id($this->__channelObj->wms['node_id'])->set_api_name('wms.reship.status_update')->dispatch($result['data']);
|
||
if ($rs['rsp'] == 'succ' && $result['data']['status'] != 'PARTIN' && $result['io_status'] != 'PARTIN') {
|
||
$failModel->delete(array('id' => $sdf['obj_id']));
|
||
}
|
||
}
|
||
} else {
|
||
$failModel->db->exec("UPDATE sdb_erpapi_api_fail SET fail_times=fail_times+1,msg_id='" . $rs['msg_id'] . "' WHERE id=" . $sdf['obj_id']);
|
||
}
|
||
}
|
||
|
||
protected function _format_search_params($sdf)
|
||
{
|
||
$params = array(
|
||
'out_order_code' => $sdf['out_order_code'],
|
||
);
|
||
return $params;
|
||
}
|
||
|
||
protected function _deal_search_result($rs)
|
||
{
|
||
return $rs;
|
||
}
|
||
|
||
//同步WMS仓储的售后原因
|
||
public function reship_resaon($sdf)
|
||
{
|
||
return $this->error('接口方法不存在', 'w402');
|
||
}
|
||
|
||
//同步第三方仓储WMS异常错误码
|
||
public function reship_errorcode($sdf)
|
||
{
|
||
return $this->error('接口方法不存在', 'w402');
|
||
}
|
||
}
|