mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-23 02:45:33 +08:00
1061 lines
34 KiB
PHP
1061 lines
34 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.
|
||
*/
|
||
/**
|
||
* 唯品会JIT相关接口
|
||
*/
|
||
class erpapi_shop_request_purchase extends erpapi_shop_request_abstract {
|
||
|
||
/**
|
||
* 组织接口参数
|
||
*
|
||
* @param string $vop_method 接口名
|
||
* @param int $is_multiple_params 是否多个参数,默认1
|
||
* @param array data 查询条件
|
||
* @return array
|
||
*/
|
||
|
||
public function _format_api_params($vop_method, $is_multiple_params=1, $data)
|
||
{
|
||
$vop_param = array();
|
||
$vop_param['vop_method'] = $vop_method;
|
||
$vop_param['is_multiple_params'] = $is_multiple_params;
|
||
$vop_param['data'] = ($data ? json_encode($data) : '{}');
|
||
|
||
return $vop_param;
|
||
}
|
||
|
||
/**
|
||
* 手工单拉PO单号
|
||
*/
|
||
public function getPullPo($param)
|
||
{
|
||
if(empty($param['po_no']))
|
||
{
|
||
return false;
|
||
}
|
||
|
||
//组织参数getPoList
|
||
$vop_param = $this->_format_api_params('getPoList', 1, $param);
|
||
|
||
$title = '获取采购单号('. $param['po_no'] .')信息';
|
||
$primary_bn = $param['po_no'];
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
if($rsp['rsp'] == 'succ')
|
||
{
|
||
$rsp = $this->getPoList_callback($rsp);
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 获取po列表
|
||
*/
|
||
public function getPoList($param)
|
||
{
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('getPoList', 1, $param);
|
||
|
||
$title = '获取店铺('. $this->__channelObj->channel['name'] .')PO单列表';
|
||
$primary_bn = 'getPoList';
|
||
|
||
$shop_info = array('shop_id'=>$this->__channelObj->channel['shop_id']);
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
if($rsp['rsp'] == 'succ')
|
||
{
|
||
$rsp = $this->getPoList_callback($rsp);
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 回调
|
||
*/
|
||
public function getPoList_callback($response, $callback_params=NULL)
|
||
{
|
||
$rsp = $response['rsp'];
|
||
$shop_id = $this->__channelObj->channel['shop_id'];
|
||
$is_empty = false;
|
||
|
||
if($rsp == 'succ')
|
||
{
|
||
$purchaseObj = app::get('purchase')->model('order');
|
||
$purchaseLib = kernel::single('purchase_purchase_order');
|
||
|
||
$data = json_decode($response['data'], true);
|
||
$data = json_decode($data['msg'], true);
|
||
|
||
$po_list = $data['result']['purchase_order_list'];//接口名getPoList
|
||
|
||
$pick_pos = array();//需要获取拣货单的PO单号
|
||
|
||
//是否为空
|
||
$is_empty = (empty($po_list) ? true : false);
|
||
|
||
if($po_list && is_array($po_list))
|
||
{
|
||
foreach ($po_list as $key => $val)
|
||
{
|
||
$val['sell_st_time'] = $val['sell_st_time'] ? strtotime($val['sell_st_time']) : 0;
|
||
$val['sell_et_time'] = $val['sell_et_time'] ? strtotime($val['sell_et_time']) : 0;
|
||
|
||
if ($val['sell_st_time'] < 0) {
|
||
$val['sell_st_time'] = 0;
|
||
}
|
||
|
||
if ($val['sell_et_time'] < 0) {
|
||
$val['sell_et_time'] = 0;
|
||
}
|
||
|
||
|
||
$poInfo = $purchaseObj->dump(array('po_bn'=>$val['po_no']), 'po_id, sales_num, unpick_num');
|
||
if($poInfo)
|
||
{
|
||
//更新
|
||
$data = array(
|
||
'po_id'=>$poInfo['po_id'],
|
||
'stock'=> intval($val['stock']),
|
||
'sales_num'=> intval($val['sales_volume']),
|
||
'unpick_num'=> intval($val['not_pick']),
|
||
'old_sales_num'=>$poInfo['sales_num'],
|
||
'old_unpick_num'=>$poInfo['unpick_num'],
|
||
'schedule_id'=>$val['schedule_id'],//档期号
|
||
'schedule_name'=>$val['schedule_name'],//档期名称
|
||
'sell_st_time'=>$val['sell_st_time'],//档期开始时间
|
||
'sell_et_time'=>$val['sell_et_time'],//档期结束时间
|
||
);
|
||
$result = $purchaseLib->update_purchase($data);
|
||
}
|
||
else
|
||
{
|
||
//新建
|
||
$data = array(
|
||
'po_bn'=>$val['po_no'],//采购单号
|
||
'shop_id'=> $shop_id,//来源店铺
|
||
'co_mode'=> $val['co_mode'],
|
||
'sell_st_time'=>$val['sell_st_time'],//档期开始时间
|
||
'sell_et_time'=>$val['sell_et_time'],//档期结束时间
|
||
'stock'=> intval($val['stock']),//虚拟总库存
|
||
'sales_num'=> intval($val['sales_volume']),//销售数量
|
||
'unpick_num'=> intval($val['not_pick']),//未拣货数量
|
||
'trade_mode'=>$val['trade_mode'],
|
||
'schedule_id'=>$val['schedule_id'],//档期号
|
||
'schedule_name'=>$val['schedule_name'],//档期名称
|
||
'supplier_name'=>$val['vendor_name'],//供应商名称
|
||
'brand_name'=>$val['brand_name'],//品牌名称
|
||
'warehouse'=>$val['warehouse'],//仓库
|
||
'is_normal'=>intval($val['normality_flag']),//是否是常态档期
|
||
);
|
||
$result = $purchaseLib->create_purchase($data);
|
||
}
|
||
|
||
//[有未拣货数量]通过Po单号获取拣货单列表
|
||
if($result && $data['unpick_num'])
|
||
{
|
||
$pick_pos[] = $val['po_no'];
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
$result = array('rsp'=>$response['rsp'], 'msg_id'=>$response['msg_id'], 'res'=>$response['res'], 'is_empty'=>$is_empty);
|
||
if($pick_pos)
|
||
{
|
||
$result['po_nos'] = $pick_pos;
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 获取拣货单列表
|
||
*/
|
||
public function getPickList($param)
|
||
{
|
||
if(empty($param))
|
||
{
|
||
return array('rsp'=>'fail', 'err_msg'=>'没有输入参数');
|
||
}
|
||
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('getPickList', 1, $param);
|
||
|
||
if($param['pick_no'])
|
||
{
|
||
$title = '获取拣货单号('. $param['pick_no'] .')信息';
|
||
$primary_bn = $param['pick_no'];
|
||
}
|
||
else
|
||
{
|
||
$title = '获取店铺('. $this->__channelObj->channel['name'] .')拣货单列表';
|
||
$primary_bn = 'getPickList';
|
||
}
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
if($rsp['rsp'] == 'succ')
|
||
{
|
||
$rsp = $this->getPickList_callback($rsp);
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 拣货单回调
|
||
*/
|
||
public function getPickList_callback($response, $callback_params=NULL)
|
||
{
|
||
$rsp = $response['rsp'];
|
||
$total = 0;
|
||
|
||
if($rsp == 'succ')
|
||
{
|
||
$data = json_decode($response['data'], true);
|
||
$data = json_decode($data['msg'], true);
|
||
$pick_list = $data['result']['picks'];
|
||
|
||
$total = (int) $data['result']['total'];
|
||
$pick_nos = array();
|
||
|
||
//获取拣货单明细
|
||
if($pick_list)
|
||
{
|
||
foreach ($pick_list as $key => $val)
|
||
{
|
||
//组织拣货单参数
|
||
$pick_nos[$val['pick_no']] = $val;
|
||
}
|
||
}
|
||
}
|
||
|
||
$result = array('rsp'=>$response['rsp'], 'msg_id'=>$response['msg_id'], 'res'=>$response['res'], 'total'=>$total);
|
||
if($pick_nos)
|
||
{
|
||
$result['po_list'] = $pick_nos;
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 拣货单明细
|
||
*/
|
||
public function getPickDetail($param)
|
||
{
|
||
if(empty($param))
|
||
{
|
||
return array('rsp'=>'fail', 'err_msg'=>'没有输入参数');
|
||
}
|
||
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('getPickDetail', 1, $param);
|
||
|
||
$title = '获取拣货单号('. $param['pick_no'] .')明细信息';
|
||
$primary_bn = $param['pick_no'];
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
//数据处理
|
||
if($rsp['rsp'] == 'succ')
|
||
{
|
||
$rsp = $this->getPickDetail_callback($rsp);
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 拣货单明细回调
|
||
*/
|
||
public function getPickDetail_callback($response, $callback_params=NULL)
|
||
{
|
||
$rsp = $response['rsp'];
|
||
|
||
$result = array('rsp'=>$response['rsp'], 'msg_id'=>$response['msg_id'], 'res'=>$response['res']);
|
||
if($rsp == 'succ'){
|
||
$data = json_decode($response['data'], true);
|
||
$data = json_decode($data['msg'], true);
|
||
|
||
if ($data['returnCode'] == '0') {
|
||
$result['pick_product_list'] = $data['result']['pick_product_list'];
|
||
$result['total'] = $data['result']['total'];
|
||
} else {
|
||
$result['rsp'] = 'fail';
|
||
$result['msg'] = $result['err_msg'] = $data['returnMessage'];
|
||
}
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 创建拣货单
|
||
*/
|
||
public function createPick($param)
|
||
{
|
||
if(empty($param['po_no']))
|
||
{
|
||
return false;
|
||
}
|
||
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('createPick', 1, $param);
|
||
|
||
$title = '采购单号('. $param['po_no'] .')创建拣货单';
|
||
$primary_bn = $param['po_no'];
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
if($rsp['rsp'] == 'succ')
|
||
{
|
||
$rsp = $this->createPick_callback($rsp);
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 创建拣货单回调
|
||
*/
|
||
public function createPick_callback($response, $callback_params=NULL)
|
||
{
|
||
$rsp = $response['rsp'];
|
||
$pick_info = array();
|
||
|
||
if($rsp == 'succ')
|
||
{
|
||
$data = json_decode($response['data'], true);
|
||
$data = json_decode($data['msg'], true);
|
||
|
||
$pick_info = $data['result'];
|
||
}
|
||
|
||
$result = array('rsp'=>$response['rsp'], 'msg_id'=>$response['msg_id'], 'res'=>$response['res']);
|
||
if($pick_info)
|
||
{
|
||
$result['pick_info'] = $pick_info;
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 创建出仓单
|
||
*/
|
||
public function createDelivery($param)
|
||
{
|
||
if(empty($param['po_no']) || empty($param['delivery_no']) || empty($param['warehouse']))
|
||
{
|
||
return false;
|
||
}
|
||
|
||
if(empty($param['arrival_time']) || empty($param['carrier_name']) || empty($param['carrier_code']))
|
||
{
|
||
return false;
|
||
}
|
||
|
||
$vop_param = array (
|
||
'createPoDeliveryReq' => array (
|
||
'po_nos' => explode(',',$param['po_no']),
|
||
'logistics_no' => $param['logistics_no'] ?: $param['delivery_no'],
|
||
// 'delivery_warehouse' => $param['delivery_warehouse'],
|
||
'warehouse' => $param['warehouse'],
|
||
'delivery_time' => $param['delivery_time'],
|
||
'arrival_time' => $param['arrival_time'],
|
||
'carrier_code' => $param['carrier_code'],
|
||
'delivery_method' => $param['delivery_method'],
|
||
// 'store_sn' => $param['store_sn'],
|
||
// 'jit_type' => $param['jit_type'],
|
||
// 'is_air_embargo' => $param['is_air_embargo'],
|
||
),
|
||
);
|
||
|
||
|
||
if (kernel::single('purchase_purchase_stockout')->is_vopcp($param['carrier_code'])) {
|
||
$vop_param['createPoDeliveryReq']['delivery_warehouse'] = $param['delivery_warehouse'];
|
||
$vop_param['createPoDeliveryReq']['is_air_embargo'] = $param['is_air_embargo'];
|
||
$vop_param['createPoDeliveryReq']['arrival_time'] = '';
|
||
$vop_param['createPoDeliveryReq']['delivery_method'] = '';
|
||
}
|
||
|
||
// 如果是预调拨件货单
|
||
if (false !== strpos($param['pick_no'],'FPICK-')) {
|
||
$vop_param['createPoDeliveryReq']['jit_type'] = 3;
|
||
}
|
||
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('createPoDeliveryV2', 0, $vop_param);
|
||
|
||
$title = '出库单号('. $param['delivery_no'] .')创建出库单';
|
||
$primary_bn = $param['delivery_no'];
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
if($rsp['rsp'] == 'succ')
|
||
{
|
||
$rsp = $this->createDelivery_callback($rsp);
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 创建出仓单回调
|
||
*/
|
||
public function createDelivery_callback($response, $callback_params=NULL)
|
||
{
|
||
$rsp = $response['rsp'];
|
||
$delivery = array();
|
||
|
||
if($rsp == 'succ')
|
||
{
|
||
$data = json_decode($response['data'], true);
|
||
$data = json_decode($data['msg'], true);
|
||
$data = $data['result'];
|
||
|
||
$delivery = array(
|
||
'delivery_id' => $data['delivery_id'],
|
||
'storage_no' => $data['storage_no'],
|
||
'logistics_no' => $data['logistics_no'],
|
||
'delivery_method' => $data['delivery_method'],
|
||
'arrival_time' => $data['arrival_time'],
|
||
);
|
||
}
|
||
|
||
$result = array('rsp'=>$response['rsp'], 'msg_id'=>$response['msg_id'], 'res'=>$response['res']);
|
||
if($delivery)
|
||
{
|
||
$result['delivery'] = $delivery;
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 创建出仓单2.0
|
||
*/
|
||
public function createMultiPoDelivery($param)
|
||
{
|
||
$chk_param = $param['createMultiPoDeliveryRequest'];
|
||
|
||
if(empty($chk_param['po_no']) || empty($chk_param['delivery_no']) || empty($chk_param['warehouse']))
|
||
{
|
||
return false;
|
||
}
|
||
if(empty($chk_param['arrival_time']) || empty($chk_param['carrier_code']))
|
||
{
|
||
return false;
|
||
}
|
||
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('createMultiPoDelivery', 0, $param);
|
||
|
||
$title = '出库单号('. $chk_param['delivery_no'] .')创建出库单';
|
||
$primary_bn = $chk_param['delivery_no'];
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
if($rsp['rsp'] == 'succ')
|
||
{
|
||
$rsp = $this->createMultiPoDelivery_callback($rsp);
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 创建出仓单回调2.0
|
||
*/
|
||
public function createMultiPoDelivery_callback($response, $callback_params=NULL)
|
||
{
|
||
$rsp = $response['rsp'];
|
||
$delivery = array();
|
||
|
||
if($rsp == 'succ')
|
||
{
|
||
$data = json_decode($response['data'], true);
|
||
$data = json_decode($data['msg'], true);
|
||
$storage_no = $data['result'];
|
||
|
||
if($storage_no)
|
||
{
|
||
$delivery = array('storage_no'=>$storage_no);
|
||
}
|
||
}
|
||
|
||
$result = array('rsp'=>$response['rsp'], 'msg_id'=>$response['msg_id'], 'res'=>$response['res']);
|
||
if($delivery)
|
||
{
|
||
$result['delivery'] = $delivery;
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 修改出仓单信息
|
||
*/
|
||
public function editDelivery($param)
|
||
{
|
||
$stockout_no = $param['stockout_no'];
|
||
unset($param['stockout_no']);
|
||
|
||
if(empty($stockout_no) || empty($param['storage_no']) || empty($param['warehouse']))
|
||
{
|
||
return false;
|
||
}
|
||
|
||
$vop_param = array (
|
||
'editDeliveryReq' => array (
|
||
'storage_no' => $param['storage_no'],
|
||
'logistics_no' => $param['delivery_no'],
|
||
// 'delivery_warehouse' => $param[''],
|
||
'warehouse' => $param['warehouse'],
|
||
'delivery_time' => $param['delivery_time'],
|
||
// 'arrival_time' => $param[''],
|
||
'carrier_code' => $param['carrier_code'],
|
||
// 'delivery_method' => $param[''],
|
||
// 'store_sn' => $param[''],
|
||
// 'is_air_embargo' => $param[''],
|
||
),
|
||
);
|
||
|
||
if (kernel::single('purchase_purchase_stockout')->is_vopcp($param['carrier_code'])) {
|
||
$vop_param['editDeliveryReq']['delivery_warehouse'] = $param['delivery_warehouse'];
|
||
$vop_param['editDeliveryReq']['is_air_embargo'] = $param['is_air_embargo'];
|
||
}
|
||
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('editPoDeliveryV2', 0, $vop_param);
|
||
|
||
$title = '出库单号('. $stockout_no .')修改出仓单信息';
|
||
$primary_bn = $stockout_no;
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
if($rsp['rsp'] == 'succ')
|
||
{
|
||
$rsp = $this->editDelivery_callback($rsp);
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 修改出仓单回调
|
||
*/
|
||
public function editDelivery_callback($response, $callback_params=NULL)
|
||
{
|
||
$rsp = $response['rsp'];
|
||
$delivery = array();
|
||
|
||
if($rsp == 'succ')
|
||
{
|
||
$data = json_decode($response['data'], true);
|
||
$data = json_decode($data['msg'], true);
|
||
|
||
//失败原因
|
||
if($data['returnCode'] != '0' && $data['returnMessage'])
|
||
{
|
||
$response['rsp'] = 'fail';
|
||
$response['err_msg'] = json_encode(array('returnMessage'=>$data['returnMessage']));
|
||
}
|
||
}
|
||
|
||
$result = array('rsp'=>$response['rsp'], 'msg_id'=>$response['msg_id'], 'res'=>$response['res'], 'err_msg'=>$response['err_msg']);
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 将出仓明细信息导入到出仓单中（目前该接口明细信息最大导入量在500条SKU信息）
|
||
*/
|
||
public function importDeliveryDetail($param)
|
||
{
|
||
$stockout_no = $param['stockout_no'];
|
||
unset($param['stockout_no']);
|
||
|
||
if(empty($stockout_no) || empty($param['po_no']) || empty($param['storage_no']))
|
||
{
|
||
return false;
|
||
}
|
||
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('importMultiPoDeliveryDetail', 1, $param);
|
||
|
||
$title = '出库单号('. $stockout_no .')导入出仓明细信息';
|
||
$primary_bn = $stockout_no;
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
if($rsp['rsp'] == 'succ')
|
||
{
|
||
$rsp = $this->importDeliveryDetail_callback($rsp);
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 导入出仓明细信息回调
|
||
*/
|
||
public function importDeliveryDetail_callback($response, $callback_params=NULL)
|
||
{
|
||
$rsp = $response['rsp'];
|
||
$delivery = array();
|
||
|
||
if($rsp == 'succ')
|
||
{
|
||
$data = json_decode($response['data'], true);
|
||
$data = json_decode($data['msg'], true);
|
||
|
||
//失败原因
|
||
if($data['returnCode'] != '0' && $data['returnMessage'])
|
||
{
|
||
$response['rsp'] = 'fail';
|
||
$response['err_msg'] = json_encode(array('returnMessage'=>$data['returnMessage']));
|
||
}
|
||
}
|
||
|
||
$result = array('rsp'=>$response['rsp'], 'msg_id'=>$response['msg_id'], 'res'=>$response['res'], 'err_msg'=>$response['err_msg']);
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 确认出仓单
|
||
*/
|
||
public function confirmDelivery($param)
|
||
{
|
||
$stockout_no = $param['stockout_no'];
|
||
unset($param['stockout_no']);
|
||
|
||
if(empty($stockout_no) || empty($param['storage_no']))
|
||
{
|
||
return false;
|
||
}
|
||
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('confirmDelivery', 1, $param);
|
||
|
||
$title = '出库单号('. $stockout_no .')确认出仓单';
|
||
$primary_bn = $stockout_no;
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
if($rsp['rsp'] == 'succ')
|
||
{
|
||
$rsp = $this->confirmDelivery_callback($rsp);
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 确认出仓单回调
|
||
*/
|
||
public function confirmDelivery_callback($response, $callback_params=NULL)
|
||
{
|
||
$rsp = $response['rsp'];
|
||
$delivery = array();
|
||
|
||
if($rsp == 'succ')
|
||
{
|
||
$data = json_decode($response['data'], true);
|
||
$data = json_decode($data['msg'], true);
|
||
|
||
//失败原因
|
||
if($data['returnCode'] != '0' && $data['returnMessage'])
|
||
{
|
||
$response['rsp'] = 'fail';
|
||
$response['err_msg'] = json_encode(array('returnMessage'=>$data['returnMessage']));
|
||
}
|
||
}
|
||
|
||
$result = array('rsp'=>$response['rsp'], 'msg_id'=>$response['msg_id'], 'res'=>$response['res'], 'err_msg'=>$response['err_msg']);
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 同步承运商
|
||
*/
|
||
function getCarrierList($param)
|
||
{
|
||
$chk_param = $param['carrierRequest'];
|
||
$shop_id = $this->__channelObj->channel['shop_id'];
|
||
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('getCarrierList', 0, $param);
|
||
|
||
$title = '同步承运商';
|
||
$primary_bn = 'carrier';
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
if($rsp['rsp'] == 'succ')
|
||
{
|
||
$rsp = $this->getCarrierList_callback($rsp, $shop_id);
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 同步承运商回调
|
||
*/
|
||
public function getCarrierList_callback($response, $shop_id)
|
||
{
|
||
$rsp = $response['rsp'];
|
||
$delivery = array();
|
||
|
||
if($rsp == 'succ')
|
||
{
|
||
$data = json_decode($response['data'], true);
|
||
$data = json_decode($data['msg'], true);
|
||
$dataList = $data['result']['carriers'];
|
||
|
||
if($dataList)
|
||
{
|
||
$stockLib = kernel::single('purchase_purchase_stockout');
|
||
|
||
foreach ($dataList as $key => $val)
|
||
{
|
||
$save_data = array(
|
||
'tms_carrier_id'=>$val['tms_carrier_id'],
|
||
'carrier_code'=>$val['carrier_code'],
|
||
'carrier_name'=>$val['carrier_name'],
|
||
'carrier_shortname'=>$val['carrier_shortname'],
|
||
'carrier_isvalid'=>$val['carrier_isvalid'],
|
||
'shop_id'=>$shop_id,
|
||
);
|
||
|
||
$stockLib->saveCarrier($save_data);
|
||
}
|
||
}
|
||
}
|
||
|
||
$result = array('rsp'=>$response['rsp'], 'msg_id'=>$response['msg_id'], 'res'=>$response['res']);
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 获取ReturnInfo
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getReturnInfo($sdf)
|
||
{
|
||
$shop_id = $this->__channelObj->channel['shop_id'];
|
||
$param = [
|
||
'warehouse' => $sdf['warehouse'],
|
||
'st_create_time' => $sdf['start_date'],
|
||
'ed_create_time' => $sdf['end_date'],
|
||
'page' => $sdf['page_no'],
|
||
'limit' => $sdf['page_size'],
|
||
];
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('getReturnInfo', 1, $param);
|
||
$vop_param['vop_type'] = 'vreturn';
|
||
|
||
$title = '同步退供单';
|
||
$primary_bn = 'vopreturn';
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
//数据处理
|
||
if($rsp['data'])
|
||
{
|
||
$data = json_decode($rsp['data'], 1);
|
||
if ($data['msg']) {
|
||
$data['msg'] = json_decode($data['msg'],1);
|
||
$rsp['data'] = $data['msg']['result']['returnInfos'];
|
||
$rsp['total'] = $data['msg']['result']['total'];
|
||
}
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 获取ReturnDetail
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getReturnDetail($sdf)
|
||
{
|
||
$shop_id = $this->__channelObj->channel['shop_id'];
|
||
$param = [
|
||
'warehouse' => $sdf['warehouse'],
|
||
'return_sn' => $sdf['return_sn'],
|
||
];
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('getReturnDetail', 1, $param);
|
||
$vop_param['vop_type'] = 'vreturn';
|
||
|
||
$title = '同步退供单详情';
|
||
$primary_bn = $sdf['return_sn'];
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
|
||
|
||
if($rsp['data'])
|
||
{
|
||
$data = json_decode($rsp['data'], 1);
|
||
if ($data['msg']) {
|
||
$data['msg'] = json_decode($data['msg'],1);
|
||
$rsp['data'] = $data['msg']['result']['returnDeliveryInfos'][0];
|
||
$rsp['total'] = $data['msg']['result']['total'];
|
||
}
|
||
}
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* returnConfirmBySn
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回值
|
||
*/
|
||
public function returnConfirmBySn($sdf)
|
||
{
|
||
$shop_id = $this->__channelObj->channel['shop_id'];
|
||
$param = [
|
||
'return_sn_list' => json_encode([$sdf['return_sn']]),
|
||
];
|
||
//组织参数
|
||
$vop_param = $this->_format_api_params('returnConfirmBySn', 0, $param);
|
||
|
||
$title = '退供单供应商确认';
|
||
$primary_bn = $sdf['return_sn'];
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
/**
|
||
* 获取SkuPriceInfo
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getSkuPriceInfo($sdf)
|
||
{
|
||
$shop_id = $this->__channelObj->channel['shop_id'];
|
||
$param = [
|
||
'request' => [
|
||
'po_no' => $sdf['po_no'],
|
||
'barcodes' => $sdf['barcodes'],
|
||
]
|
||
];
|
||
|
||
// 组织参数
|
||
$vop_param = $this->_format_api_params('getSkuPriceInfo', 0, $param);
|
||
|
||
$title = '查询JIT供货价信息';
|
||
|
||
$primary_bn = $sdf['po_no'];
|
||
|
||
$rsp = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $vop_param, array(), $title, 10, $primary_bn);
|
||
if ($rsp['rsp'] == 'succ'){
|
||
$data = @json_decode($rsp['data'], 1);
|
||
$msg = @json_decode($data['msg'], 1);
|
||
|
||
$rsp['rsp'] = $msg['returnCode'] == '0' ? 'succ' : 'fail';
|
||
|
||
$rsp['msg'] = $rsp['err_msg'] = $msg['returnMessage'];
|
||
|
||
$rsp['data'] = $msg['result'];
|
||
}
|
||
|
||
|
||
return $rsp;
|
||
}
|
||
|
||
|
||
/**
|
||
* 退供差明细列表
|
||
*
|
||
*
|
||
* @param array $sdf
|
||
* @return array
|
||
* */
|
||
public function getReturnDiffInterDetail($params)
|
||
{
|
||
$title = sprintf('[%s]退供明细列表', $this->__channelObj->channel['name']);
|
||
|
||
|
||
|
||
$result = $this->__caller->call(SHOP_RETURNORDER_DIFF_DETAIL_GET, $params, array(), $title, 10);
|
||
|
||
if ($result['rsp'] == 'succ' && $result['data']){
|
||
$data = @json_decode($result['data'], true);
|
||
|
||
if ($data && $data['msg']) {
|
||
$msg = @json_decode($data['msg'], true);
|
||
|
||
if ($msg && $msg['returnCode'] != 0) {
|
||
$result['rsp'] = 'fail';
|
||
$result['msg'] = $result['err_msg'] = $msg['returnMessage'];
|
||
return $result;
|
||
}
|
||
|
||
|
||
$result['data'] = $msg['result'];
|
||
}
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
|
||
/**
|
||
* 获取ReturnDiffInterList
|
||
* @param mixed $params 参数
|
||
* @return mixed 返回结果
|
||
*/
|
||
public function getReturnDiffInterList($params)
|
||
{
|
||
$title = sprintf('[%s]退供差主单列表', $this->__channelObj->channel['name']);
|
||
|
||
$result = $this->__caller->call(SHOP_RETURNORDER_DIFF_LIST_GET, $params, array(), $title, 10);
|
||
|
||
if ($result['rsp'] == 'succ' && $result['data']){
|
||
$data = @json_decode($result['data'], true);
|
||
|
||
if ($data && $data['msg']) {
|
||
$msg = @json_decode($data['msg'], true);
|
||
|
||
if ($msg && $msg['returnCode'] != 0) {
|
||
$result['rsp'] = 'fail';
|
||
$result['msg'] = $result['err_msg'] = $msg['returnMessage'];
|
||
return $result;
|
||
}
|
||
|
||
|
||
$result['data'] = $msg['result'];
|
||
}
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* JIT订单明细查询
|
||
* API文档：https://vop.vip.com/home#/api/method/detail/com.vip.vis.order.jit.service.order.JitOrderVopService-1.0.0/getJitOrderDetail
|
||
*
|
||
* @param $param array
|
||
* @return array
|
||
*/
|
||
public function getJitorderdetail($param)
|
||
{
|
||
if(empty($param['request']['po']) || empty($param['request']['pick_no'])){
|
||
return array('rsp'=>'fail', 'error_msg'=>'po单号、拣货单号不能为空');
|
||
}
|
||
|
||
$title = '获取JIT订单明细查询';
|
||
$primary_bn = $param['request']['pick_no'];
|
||
|
||
//data
|
||
$requestData = $param;
|
||
|
||
//params
|
||
$requestParams = array(
|
||
'vop_type' => 'JitOrder',
|
||
'vop_service' => 'com.vip.vis.order.jit.service.order.JitOrderVopService', //服务名
|
||
'vop_method' => 'getJitOrderDetail', //方法名
|
||
'is_multiple_params' => 0, //是否多个参数：默认1,必须填写0
|
||
'data' => json_encode($requestData),
|
||
);
|
||
|
||
//request
|
||
$result = $this->__caller->call(SHOP_COMMONS_VOP_JIT, $requestParams, array(), $title, 10, $primary_bn);
|
||
|
||
//数据处理
|
||
if($result['rsp'] == 'succ'){
|
||
$result = $this->getJitorderdetail_callback($result);
|
||
}
|
||
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* JIT订单明细查询--数据格式化
|
||
*
|
||
* @param $response
|
||
* @param $callback_params
|
||
* @return array
|
||
*/
|
||
public function getJitorderdetail_callback($response, $callback_params=NULL)
|
||
{
|
||
$total = 0;
|
||
|
||
//format
|
||
$order_detail_list = array();
|
||
if($response['data']){
|
||
if($response['data'] && is_array($response['data'])){
|
||
$data = $response['data'];
|
||
}else{
|
||
$data = json_decode($response['data'], true);
|
||
}
|
||
|
||
//content
|
||
if($data['msg'] && is_array($data['msg'])){
|
||
$data = $data['msg'];
|
||
}else{
|
||
$data = json_decode($data['msg'], true);
|
||
}
|
||
|
||
$total = (isset($data['result']['total']) ? $data['result']['total'] : 0);
|
||
$total = intval($total);
|
||
|
||
//JIT订单明细列表
|
||
if(isset($data['result']['order_detail_list'])){
|
||
$order_detail_list = $data['result']['order_detail_list'];
|
||
}
|
||
}
|
||
|
||
//result
|
||
$result = array(
|
||
'rsp' => $response['rsp'],
|
||
'res' => $response['res'],
|
||
'msg_id' => $response['msg_id'],
|
||
'total' => $total,
|
||
'dataList' => $order_detail_list,
|
||
);
|
||
|
||
return $result;
|
||
}
|
||
}
|