mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-23 02:45:33 +08:00
318 lines
13 KiB
PHP
318 lines
13 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_stockout extends erpapi_wms_request_abstract
|
||
{
|
||
protected $_stockout_pagination = false;
|
||
protected $_stockout_pagesize = 3000;
|
||
|
||
protected function transfer_stockout_type($io_type)
|
||
{
|
||
$stockout_type = array(
|
||
'PURCHASE_RETURN' => 'OUT_PURCHASE_RETURN', //采购退货
|
||
'ALLCOATE' => 'OUT_ALLCOATE', //调拨出库
|
||
'DEFECTIVE' => 'OUT_DEFECTIVE', // 残损出库
|
||
'ADJUSTMENT' => 'OUT_ADJUSTMENT', // 调帐出库
|
||
'VOPSTOCKOUT' => 'OUT_JITCK', // 唯品会JIT出库
|
||
);
|
||
|
||
return isset($stockout_type[$io_type]) ? $stockout_type[$io_type] : 'OUT_OTHER';
|
||
}
|
||
|
||
/**
|
||
* 出库单创建
|
||
*
|
||
* @return void
|
||
* @author
|
||
* */
|
||
|
||
public function stockout_create($sdf){
|
||
$stockout_bn = $sdf['io_bn'];
|
||
|
||
//唯品会出库
|
||
$io_type = purchase_purchase_stockout::_io_type;
|
||
$is_vop = ($sdf['io_type']==$io_type ? true : false);
|
||
|
||
//是否取消状态
|
||
$iscancel = kernel::single('console_service_commonstock')->iscancel($stockout_bn, $is_vop);
|
||
if ($iscancel) {
|
||
return $this->succ('出库单已取消,终止同步');
|
||
}
|
||
|
||
$title = $this->__channelObj->wms['channel_name'] . '出库单添加';
|
||
|
||
// 分页请求
|
||
$items = $sdf['items']; sort($items);
|
||
|
||
$total = count($items); $page_no = 1; $page_size = $this->_stockout_pagesize;
|
||
$total_page = $this->_stockout_pagination ? ceil($total/$page_size) : 1;
|
||
|
||
$retry = array(
|
||
'obj_bn' => $stockout_bn,
|
||
'obj_type' => strtolower($sdf['io_type']),
|
||
'channel' => 'wms',
|
||
'channel_id' => $this->__channelObj->wms['channel_id'],
|
||
'method' => 'stockout_create',
|
||
'total_page' => $total_page,
|
||
'args' => func_get_args(),
|
||
'next_obj_type' => $this->_getNextObjType(strtolower($sdf['io_type']))
|
||
);
|
||
$apiFailId = app::get('erpapi')->model('api_fail')->saveRunning($retry);
|
||
|
||
do {
|
||
|
||
$offset = ($page_no - 1) * $page_size;
|
||
|
||
$sdf['items'] = $total_page > 1 ? array_slice($items, $offset, $page_size, true) : $items;
|
||
|
||
//唯品会出库
|
||
if($is_vop){
|
||
$params = $this->_vop_format_stockout_create_params($sdf);
|
||
}else{
|
||
$params = $this->_format_stockout_create_params($sdf);
|
||
}
|
||
|
||
$params['is_finished'] = ($page_no >= $total_page) ? 'true' : 'false';
|
||
$params['current_page'] = $page_no;
|
||
$params['total_page'] = $total_page;
|
||
$params['item_total_num'] = $total;
|
||
$params['line_total_count'] = $total;
|
||
|
||
|
||
$callback = array(
|
||
'class' => get_class($this),
|
||
'method' => 'stockout_create_callback',
|
||
'params' => array('stockout_bn'=>$stockout_bn,'io_type'=>$sdf['io_type'],'obj_bn'=>$stockout_bn,'obj_type'=>strtolower($sdf['io_type'])),
|
||
);
|
||
|
||
if($apiFailId) {
|
||
$callback['params']['api_fail_id'] = $apiFailId . '-' . $page_no;
|
||
}
|
||
|
||
$this->__caller->call(WMS_OUTORDER_CREATE, $params, $callback, $title, 10, $stockout_bn);
|
||
|
||
if ($params['is_finished'] == 'true') break;
|
||
|
||
$page_no++;
|
||
} while (true);
|
||
}
|
||
|
||
/**
|
||
* stockout_create_callback
|
||
* @param mixed $response response
|
||
* @param mixed $callback_params 参数
|
||
* @return mixed 返回值
|
||
*/
|
||
public function stockout_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'];
|
||
|
||
$stockout_bn = $callback_params['stockout_bn'];
|
||
$io_type = $callback_params['io_type'];
|
||
|
||
$upData = [];
|
||
if($rsp == 'succ') {
|
||
$upData['sync_status'] = '3';
|
||
$upData['sync_msg'] = '';
|
||
} else {
|
||
$upData['sync_status'] = '2';
|
||
$upData['sync_msg'] = '失败：'.$err_msg;
|
||
}
|
||
if ($data['wms_order_code']) {
|
||
$upData['out_iso_bn'] = $data['wms_order_code'];
|
||
}
|
||
if($upData) {
|
||
if ($io_type == 'PURCHASE_RETURN') {
|
||
app::get('purchase')->model('returned_purchase')->update($upData, ['rp_bn'=>$stockout_bn]);
|
||
} else {
|
||
app::get('taoguaniostockorder')->model('iso')->update($upData, ['iso_bn'=>$stockout_bn]);
|
||
}
|
||
}
|
||
// if ($rsp =='succ' && $this->_getNextObjType()){
|
||
// //把单号加进队列
|
||
// $failApiModel = app::get('erpapi')->model('api_fail');
|
||
// $api_data = array(
|
||
// 'obj_type' => $this->_getNextObjType(),
|
||
// 'obj_bn' => $stockout_bn,
|
||
// 'obj_id' => '',
|
||
// 'params' => $callback_params['params'],
|
||
|
||
// );
|
||
// $failApiModel->publish_api_fail(WMS_OUTORDER_GET,$api_data,array('rsp'=>'fail'));
|
||
// }
|
||
|
||
$callback_params['obj_bn'] = $stockout_bn;
|
||
$callback_params['obj_type'] = strtolower($io_type);
|
||
return $this->callback($response, $callback_params);
|
||
}
|
||
|
||
protected function _format_stockout_create_params($sdf)
|
||
{
|
||
$stockout_bn = $sdf['io_bn'];
|
||
|
||
//items
|
||
$items = array('item'=>array());
|
||
if ($sdf['items']){
|
||
foreach ($sdf['items'] as $k => $v){
|
||
$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
|
||
$create_time = preg_match('/-|\//',$sdf['create_time']) ? $sdf['create_time'] : date("Y-m-d H:i:s",$sdf['create_time']);
|
||
|
||
//供应商信息
|
||
$supplierInfo = array();
|
||
if($sdf['supplier_id']) {
|
||
$supplierInfo = app::get('purchase')->model('supplier')->dump($sdf['supplier_id']);
|
||
$supplierInfo['supplier_bn'] = $supplierInfo['bn'];
|
||
|
||
//获取第三方仓储配置的供应商映射关系
|
||
$sdf['supplier_bn'] = $this->_getSupplierCode($supplierInfo);
|
||
$sdf['shipper_name'] = ($sdf['shipper_name'] ? $sdf['shipper_name'] : $supplierInfo['name']);
|
||
}
|
||
|
||
//params
|
||
$params = array(
|
||
'uniqid' => self::uniqid(),
|
||
'customer_id' => '',// 客户编码
|
||
'out_order_code' => $stockout_bn,
|
||
'order_type' => $this->transfer_stockout_type($sdf['io_type']),
|
||
'created' => $create_time,
|
||
'wms_order_code' => $stockout_bn,
|
||
'shipping_type' => 'EXPRESS',// TODO: 运输方式 EXPRESS-快递 EMS-邮政速递
|
||
'logistics_code' => $sdf['logi_code'],// TODO: 快递公司（如果是汇购传递快递公司，则该项目不能为空，否则可以为空处理）
|
||
'remark' => $sdf['memo'],
|
||
'total_amount' => $sdf['total_goods_fee'],// 订单商品总价（精确到小数点后2位）
|
||
'receiver_name' => $sdf['receiver_name'] ? $sdf['receiver_name'] : '未知',
|
||
'receiver_zip' => $sdf['receiver_zip'] ? $sdf['receiver_zip'] : '123211',// TODO: 收货人邮政编码
|
||
'receiver_state' => $sdf['receiver_state'] ? $sdf['receiver_state'] : '未知',// TODO: 退货人所在省
|
||
'receiver_city' => $sdf['receiver_city'] ? $sdf['receiver_city'] : '未知',// TODO: 退货人所在市
|
||
'receiver_district' => $sdf['receiver_district'] ? $sdf['receiver_district'] : '未知',// TODO: 退货人所在县（区），注意有些市下面是没有区的
|
||
'receiver_address' => $sdf['receiver_address'] ? $sdf['receiver_address'] : '未知',// TODO: 收货地址（出库时非空）
|
||
'receiver_phone' => $sdf['receiver_phone'] ? $sdf['receiver_phone'] : '11111111111',// TODO: 收货人电话号码（如有分机号用“-”分隔）(电话和手机必选一项)
|
||
'receiver_mobile' => $sdf['receiver_mobile'] ? $sdf['receiver_mobile'] : '11111111111',// TODO: 收货人手机号码(电话和手机必选一项)
|
||
'receiver_email' => $sdf['receiver_email'] ? $sdf['receiver_email'] : '',// TODO: 收货人手机号码(电话和手机必选一项)
|
||
'receiver_time' => '',
|
||
'sign_standard' => '',// TODO: 签收标准（如：身仹证150428197502205130）
|
||
'source_plan' => '',// TODO: 来源计划点
|
||
'storage_code' => $sdf['storage_code'],// 库内存放点编号
|
||
'items' => json_encode($items),
|
||
'supplierCode' => $sdf['supplier_bn'], //供应商编码
|
||
'supplierName' => $sdf['shipper_name'], //供应商名称
|
||
);
|
||
|
||
return $params;
|
||
}
|
||
|
||
/**
|
||
* 出库单取消
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
public function stockout_cancel($sdf){
|
||
$stockout_bn = $sdf['io_bn'];
|
||
|
||
$title = $this->__channelObj->wms['channel_name'] . '出库单取消';
|
||
|
||
$params = $this->_format_stockout_cancel_params($sdf);
|
||
|
||
return $this->__caller->call(WMS_OUTORDER_CANCEL, $params, null, $title, 10, $stockout_bn);
|
||
|
||
}
|
||
|
||
protected function _format_stockout_cancel_params($sdf)
|
||
{
|
||
$params = array(
|
||
'out_order_code' => $sdf['io_bn'],
|
||
'order_type' => $this->transfer_stockout_type($sdf['io_type']),
|
||
);
|
||
|
||
return $params;
|
||
}
|
||
|
||
/**
|
||
* 出库查询
|
||
*
|
||
* @return void
|
||
* @author
|
||
**/
|
||
public function stockout_search($sdf)
|
||
{
|
||
$stockout_bn = $sdf['stockout_bn'];
|
||
|
||
$title = $this->__channelObj->wms['channel_name'] . '出库单查询';
|
||
|
||
$params = $this->_format_stockout_search_params($sdf);
|
||
|
||
$rs = $this->__caller->call(WMS_OUTORDER_GET, $params, null, $title, 10, $stockout_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.stockout.status_update')->dispatch($result['data']);
|
||
//如果succ 删除fail_log
|
||
if ($rs['rsp'] == 'succ'){
|
||
$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']);
|
||
}
|
||
return $rs;
|
||
|
||
}
|
||
|
||
protected function _format_stockout_search_params($sdf)
|
||
{
|
||
$params = array(
|
||
'out_order_code' =>$sdf['stockout_bn'],
|
||
);
|
||
return $params;
|
||
}
|
||
|
||
protected function _deal_search_result($rs) {
|
||
return $rs;
|
||
}
|
||
}
|