mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-22 18:35:35 +08:00
651 lines
25 KiB
PHP
651 lines
25 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_delivery extends erpapi_wms_request_abstract
|
||
{
|
||
// 平台收货人信息是否密文
|
||
protected $is_platform_encrypt = false;
|
||
|
||
/**
|
||
* 发货单暂停
|
||
*
|
||
* @return void
|
||
* @author
|
||
* */
|
||
|
||
public function delivery_pause($sdf)
|
||
{}
|
||
|
||
/**
|
||
* 发货单暂停恢复
|
||
*
|
||
* @return void
|
||
* @author
|
||
* */
|
||
public function delivery_renew($sdf)
|
||
{}
|
||
|
||
protected function _getEncryptOriginData(&$sdf) {
|
||
if(kernel::single('ome_security_router',$sdf['shop_type'])->is_encrypt($sdf,'delivery')) {
|
||
$encryptData = [
|
||
'shop_id' => $sdf['shop_id'],
|
||
'order_bn' => current(explode('|', $sdf['order_bn'])),
|
||
'ship_name' => $sdf['consignee']['name'],
|
||
'ship_tel' => $sdf['consignee']['telephone'],
|
||
'ship_mobile' => $sdf['consignee']['mobile'],
|
||
'ship_addr' => $sdf['consignee']['addr'],
|
||
];
|
||
$originalEncrypt = kernel::single('ome_security_router',$sdf['shop_type'])->get_encrypt_origin($encryptData, 'delivery');
|
||
if($originalEncrypt['ship_name']) $sdf['consignee']['name'] = $originalEncrypt['ship_name'];
|
||
if($originalEncrypt['ship_tel']) $sdf['consignee']['telephone'] = $originalEncrypt['ship_tel'];
|
||
if($originalEncrypt['ship_mobile']) $sdf['consignee']['mobile'] = $originalEncrypt['ship_mobile'];
|
||
if($originalEncrypt['ship_addr']) $sdf['consignee']['addr'] = $originalEncrypt['ship_addr'];
|
||
|
||
// 标识此订单为平台加密订单
|
||
if ($originalEncrypt){
|
||
$sdf['platform_encrypt'] = true;
|
||
}
|
||
}
|
||
}
|
||
|
||
protected function _needEncryptOriginData($sdf) {
|
||
$need_encrypt_list = $this->__channelObj->wms['config']['need_encrypt'];
|
||
$need_encrypt_list['xhs'] = true;
|
||
$need_encrypt_list['taobao'] = true;
|
||
$need_encrypt_list['luban'] = true;
|
||
|
||
//birken勃肯客户抖音订单需要明文推送
|
||
// if(strtolower($_SERVER['SERVER_NAME']) == 'birkenstock.erp.taoex.com'){
|
||
// $need_encrypt_list['luban'] = false;
|
||
// }
|
||
|
||
//check
|
||
if ($need_encrypt_list && $need_encrypt_list[$sdf['shop_type']]) {
|
||
return true;;
|
||
}
|
||
return false;
|
||
}
|
||
/**
|
||
* 发货单创建
|
||
*
|
||
* @return void
|
||
* @author
|
||
* */
|
||
public function delivery_create($sdf)
|
||
{
|
||
$delivery_bn = $sdf['outer_delivery_bn'];
|
||
|
||
$iscancel = kernel::single('ome_interface_delivery')->iscancel($delivery_bn);
|
||
if ($iscancel) {
|
||
return $this->succ('发货单已取消,终止同步');
|
||
}
|
||
|
||
if ($sdf['member']['uname'] && $encrytPos = strpos($sdf['member']['uname'] , '>>')){
|
||
$sdf['member']['uname'] = substr($sdf['member']['uname'] , 0, $encrytPos);
|
||
}
|
||
if ($sdf['member']['name'] && $encrytPos = strpos($sdf['member']['name'] , '>>')){
|
||
$sdf['member']['name'] = substr($sdf['member']['name'] , 0, $encrytPos);
|
||
}
|
||
// 加密推送
|
||
if ($this->_needEncryptOriginData($sdf)) {
|
||
$this->_getEncryptOriginData($sdf);
|
||
}
|
||
$title = $this->__channelObj->wms['channel_name'] . '发货单添加';
|
||
|
||
$params = $this->_format_delivery_create_params($sdf);
|
||
if (!$params) {
|
||
return $this->error('参数为空,终止同步');
|
||
}
|
||
|
||
// 判断是否加密
|
||
$gateway = '';
|
||
if (kernel::single('ome_security_router', $sdf['shop_type'])->is_encrypt($sdf, 'delivery')) {
|
||
$params['s_node_type'] = $sdf['shop_type'];
|
||
$params['s_node_id'] = $sdf['node_id'];
|
||
|
||
// 平台收货人信息是否密文
|
||
$this->is_platform_encrypt = true;
|
||
|
||
// 加密推送
|
||
$need_encrypt_list = $this->__channelObj->wms['config']['need_encrypt'];
|
||
if ($need_encrypt_list && $need_encrypt_list[$sdf['shop_type']]) {
|
||
$params['need_encrypt'] = 'true';
|
||
}
|
||
|
||
$params['order_bns'] = implode(',', explode('|', $sdf['order_bn']));
|
||
|
||
$gateway = $sdf['shop_type'];
|
||
}
|
||
|
||
$callback = array(
|
||
'class' => get_class($this),
|
||
'method' => 'delivery_create_callback',
|
||
'params' => array('delivery_bn' => $delivery_bn, 'obj_bn' => $delivery_bn, 'obj_type' => 'delivery'),
|
||
);
|
||
|
||
$retry = array(
|
||
'obj_bn' => $delivery_bn,
|
||
'obj_type' => 'delivery',
|
||
'channel' => 'wms',
|
||
'channel_id' => $this->__channelObj->wms['channel_id'],
|
||
'method' => 'delivery_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;
|
||
}
|
||
|
||
return $this->__caller->call($this->_get_create_api_name(), $params, $callback, $title, 10, $delivery_bn, true, $gateway);
|
||
}
|
||
|
||
/**
|
||
* 发货单创建接口名
|
||
*
|
||
* @return void
|
||
* @author
|
||
*/
|
||
protected function _get_create_api_name()
|
||
{
|
||
return WMS_SALEORDER_CREATE;
|
||
}
|
||
|
||
protected function _format_delivery_create_params($sdf)
|
||
{
|
||
$operInfo = kernel::single('ome_func')->getDesktopUser();
|
||
|
||
$productId = array(0);
|
||
foreach ($sdf['delivery_items'] as $item) {
|
||
$productId[] = $item['product_id'];
|
||
}
|
||
$outSysProductBn = $this->_getOutSysProductBn($productId);
|
||
|
||
$itemCode = array();
|
||
if ($this->outSysProductField == 'item_code') {
|
||
$itemCode = $outSysProductBn;
|
||
}
|
||
|
||
$delivery_bn = $sdf['outer_delivery_bn'];
|
||
|
||
$delivery_items = $sdf['delivery_items'];
|
||
$sdf['item_total_num'] = $sdf['line_total_count'] = count($delivery_items);
|
||
|
||
$items = array('item' => array());
|
||
if ($delivery_items) {
|
||
|
||
if($sdf['wms_node_type'] == 'yjdf'){
|
||
//@todo:升序排序后,金额平摊不均拆分成2条时,数量1的排序在前面,导致推送云交易失败了;
|
||
//sort($delivery_items);
|
||
}else{
|
||
sort($delivery_items);
|
||
}
|
||
|
||
$line_i = 0;
|
||
foreach ($delivery_items as $k => $v)
|
||
{
|
||
//行号
|
||
$line_i++;
|
||
|
||
//items
|
||
$items['item'][$line_i] = array(
|
||
'item_code' => $itemCode[$v['product_id']] ? $itemCode[$v['product_id']] : $v['bn'],
|
||
'item_name' => $v['product_name'],
|
||
'item_quantity' => (int) $v['number'],
|
||
'item_price' => (float) $v['price'],
|
||
'item_line_num' => $line_i, // 订单商品列表中商品的行项目编号，即第n行或第n个商品
|
||
'trade_code' => $sdf['order_bn'], //可选(若是淘宝交易订单，并且不是赠品，必须要传订单来源编号)
|
||
'item_id' => $v['bn'], // 外部系统商品sku
|
||
'is_gift' => $v['is_gift'] == 'ture' ? '1' : '0', // 是否赠品
|
||
'item_remark' => $v['memo'], // TODO: 商品备注
|
||
'inventory_type' => '1', // TODO: 库存类型1可销售库存101类型用来定义残次品201冻结类型库存301在途库存
|
||
'item_sale_price' => (float) $v['sale_price'], //成交额
|
||
);
|
||
|
||
//额外的字段
|
||
if(isset($v['discount_price'])){
|
||
$items['item'][$line_i]['discount_price'] = $v['discount_price'];
|
||
}
|
||
}
|
||
|
||
//去除数组下标
|
||
$items['item'] = array_values($items['item']);
|
||
}
|
||
|
||
// 发票信息
|
||
if ($sdf['is_order_invoice'] == 'true' && $sdf['is_wms_invoice'] == 'true') {
|
||
$invoice = $sdf['invoice'];
|
||
$is_invoice = 'true';
|
||
$invoice_type = $invoice['invoice_type']; // ?什么情况
|
||
$invoice_title = $invoice['invoice_title']['title'];
|
||
|
||
// 增值税抬头信息
|
||
if ($invoice['invoice_type'] == 'increment') {
|
||
$invoice_info = array(
|
||
'name' => $invoice['invoice_title']['uname'],
|
||
'phone' => $invoice['invoice_title']['tel'],
|
||
'address' => $invoice['invoice_title']['reg_addr'],
|
||
'taxpayer_id' => $invoice['invoice_title']['identify_num'],
|
||
'bank_name' => $invoice['invoice_title']['bank_name'],
|
||
'bank_account' => $invoice['invoice_title']['bank_account'],
|
||
);
|
||
$invoice_info = json_encode($invoice_info);
|
||
}
|
||
|
||
// 发票明细
|
||
if ($invoice['invoice_items']) {
|
||
$invoice_items = array();
|
||
$i_money = 0;
|
||
foreach ($invoice['invoice_items'] as $val) {
|
||
$price = round($val['money'], 2);
|
||
$invoice_items[] = array(
|
||
'name' => $val['item_name'],
|
||
'spec' => $val['spec'],
|
||
'quantity' => $val['nums'],
|
||
'price' => $price,
|
||
);
|
||
$i_money += $price;
|
||
}
|
||
}
|
||
|
||
if ($invoice['content_type'] == 'items') {
|
||
$invoice_item = json_encode($invoice_items);
|
||
$invoice_money = $i_money;
|
||
} else {
|
||
$invoice_desc = $invoice['invoice_desc'];
|
||
$invoice_money = round($invoice['invoice_money'], 2);
|
||
}
|
||
}
|
||
|
||
$create_time = preg_match('/-|\//', $sdf['create_time']) ? $sdf['create_time'] : date("Y-m-d H:i:s", $sdf['create_time']);
|
||
|
||
$logistics_code = $this->_getCpCode(['corp_id' => $sdf['logi_id'], 'type' => $sdf['logi_code']]);
|
||
|
||
$shop_code = kernel::single('wmsmgr_func')->getWmsShopCode($this->__channelObj->wms['channel_id'], $sdf['shop_code']);
|
||
$params = array(
|
||
'uniqid' => self::uniqid(),
|
||
'out_order_code' => $delivery_bn,
|
||
'order_source' => $sdf['shop_type'] ? strtoupper($sdf['shop_type']) : 'OTHER',
|
||
'shipping_type' => 'EXPRESS',
|
||
'shipping_fee' => $sdf['logistics_costs'],
|
||
'platform_order_code' => $sdf['order_bn'],
|
||
'logistics_code' => $logistics_code ? $logistics_code : $sdf['logi_code'],
|
||
'shop_code' => $shop_code ? $shop_code : $sdf['shop_code'],
|
||
'seller_nick' => $sdf['shop_name'],
|
||
'remark' => $sdf['memo'], //订单上的客服备注
|
||
'created' => $create_time,
|
||
'wms_order_code' => $delivery_bn,
|
||
'is_finished' => 'true',
|
||
'current_page' => 1, // 当前批次,用于分批同步
|
||
'total_page' => 1, // 总批次,用于分批同步
|
||
'has_invoice' => $is_invoice == 'true' ? 'true' : 'false',
|
||
'invoice_type' => $invoice_type,
|
||
'invoice_title' => $invoice_title,
|
||
'invoice_fee' => $invoice_money,
|
||
'invoice_info' => $invoice_info,
|
||
'invoice_desc' => $invoice_desc,
|
||
'invoice_item' => $invoice_item,
|
||
'discount_fee' => $sdf['discount_fee'],
|
||
'is_protect' => $sdf['is_protect'],
|
||
'protect_fee' => $sdf['cost_protect'],
|
||
'is_cod' => $sdf['is_cod'], //是否货到付款。可选值:true(是),false(否)
|
||
'cod_fee' => $sdf['cod_fee'], //应收货款（用于货到付款）
|
||
'cod_service_fee' => '0', //cod服务费（货到付款 必填）
|
||
'total_goods_fee' => $sdf['total_goods_amount'] - $sdf['goods_discount_fee'], //商品原始金额-商品优惠金额
|
||
'total_trade_fee' => $sdf['total_amount'], //订单交易金额
|
||
'receiver_name' => $sdf['consignee']['name'],
|
||
'receiver_zip' => $sdf['consignee']['zip'],
|
||
'receiver_phone' => $sdf['consignee']['telephone'],
|
||
'receiver_mobile' => $sdf['consignee']['mobile'],
|
||
'receiver_state' => (string)$sdf['consignee']['province'], //省
|
||
'receiver_city' => (string)$sdf['consignee']['city'], //市
|
||
'receiver_district' => (string)$sdf['consignee']['district'], //区
|
||
'receiver_town' => (string)$sdf['consignee']['town'], //镇
|
||
'receiver_address' => $sdf['consignee']['addr'], //详细地址
|
||
'receiver_email' => $sdf['consignee']['email'],
|
||
'receiver_time' => $sdf['consignee']['r_time'], // TODO: 要求到货时间
|
||
'line_total_count' => $sdf['line_total_count'], // TODO: 订单行项目数量
|
||
'item_total_num' => $sdf['item_total_num'],
|
||
'storage_code' => $sdf['storage_code'], // 库内存放点编号
|
||
'items' => json_encode($items),
|
||
'print_remark' => $sdf['print_remark'] ? json_encode($sdf['print_remark']) : '',
|
||
'dispatch_time' => $sdf['delivery_time'],
|
||
'warehouse_code' => $this->get_warehouse_code($this->__channelObj->wms['channel_id'], $sdf['branch_bn']),
|
||
'cert_id' => $sdf['cert_id'], // 身份证
|
||
'buyer_nick' => (string)$sdf['member']['uname'],
|
||
'operatorName' => $operInfo['op_name'], //操作员(审核员)名称
|
||
);
|
||
|
||
//补发订单传平台原订单号给WMS
|
||
if($sdf['order_type'] == 'bufa' && $sdf['relate_order_bn']){
|
||
//关联订单号
|
||
$params['platform_order_code'] = $sdf['relate_order_bn'];
|
||
}elseif($sdf['order_source'] == 'platformexchange' && $sdf['platform_order_bn']){
|
||
//平台订单号(平台换货生成新订单的场景)
|
||
$params['platform_order_code'] = $sdf['platform_order_bn'];
|
||
}
|
||
|
||
if($sdf['logi_no']) {
|
||
$params['logistics_no'] = $sdf['logi_no'];
|
||
}
|
||
return $params;
|
||
}
|
||
|
||
/**
|
||
* delivery_create_callback
|
||
* @param mixed $response response
|
||
* @param mixed $callback_params 参数
|
||
* @return mixed 返回值
|
||
*/
|
||
public function delivery_create_callback($response, $callback_params)
|
||
{
|
||
$deliveryObj = app::get('ome')->model('delivery');
|
||
|
||
$rsp = $response['rsp'];
|
||
$err_msg = $response['err_msg'];
|
||
$data = $response['data'];
|
||
$msg_id = $response['msg_id'];
|
||
$res = $response['res']; //error_code错误编码
|
||
|
||
$delivery_bn = $callback_params['delivery_bn'];
|
||
|
||
if ($data) {
|
||
$data = @json_decode($data, true);
|
||
}
|
||
|
||
if (is_array($data) && $data['wms_order_code'])
|
||
{
|
||
$oDelivery_extension = app::get('console')->model('delivery_extension');
|
||
$ext_data['original_delivery_bn'] = $data['wms_order_code'];
|
||
$ext_data['delivery_bn'] = $delivery_bn;
|
||
$oDelivery_extension->create($ext_data);
|
||
|
||
//保存WMS仓储返回的外部单号
|
||
$deliveryObj->update(array('original_delivery_bn'=>$data['wms_order_code']), array('delivery_bn'=>$delivery_bn));
|
||
}
|
||
|
||
//发货单信息
|
||
$deliverys = $deliveryObj->dump(array('delivery_bn' => $delivery_bn), 'delivery_id');
|
||
|
||
$msg = $err_msg ? $err_msg : $res;
|
||
$api_status = $rsp == 'succ' ? 'send_succ' : 'send_fail';
|
||
kernel::single('console_delivery')->update_sync_status($deliverys['delivery_id'], $api_status, $msg, $res);
|
||
|
||
// if ($rsp == 'succ' && $this->_getNextObjType()) {
|
||
// //把单号加进队列
|
||
// $failApiModel = app::get('erpapi')->model('api_fail');
|
||
// $api_data = array(
|
||
// 'obj_type' => $this->_getNextObjType(),
|
||
// 'obj_bn' => $delivery_bn,
|
||
// 'obj_id' => $deliverys['delivery_id'],
|
||
|
||
// );
|
||
// $failApiModel->publish_api_fail(WMS_SALEORDER_GET, $api_data, array('rsp' => 'fail'));
|
||
|
||
// }
|
||
$callback_params['obj_bn'] = $delivery_bn;
|
||
// $callback_params['obj_type'] = 'delivery';
|
||
|
||
//log
|
||
if($rsp != 'succ'){
|
||
$operationLogObj = app::get('ome')->model('operation_log');
|
||
$operationLogObj->write_log('delivery_modify@ome', $deliverys['delivery_id'], 'WMS响应结果：'. $msg);
|
||
}
|
||
|
||
return $this->callback($response, $callback_params);
|
||
}
|
||
|
||
/**
|
||
* 发货单取消
|
||
*
|
||
* @return void
|
||
* @author
|
||
* */
|
||
public function delivery_cancel($sdf)
|
||
{
|
||
$delivery_bn = $sdf['outer_delivery_bn'];
|
||
|
||
$title = $this->__channelObj->wms['channel_name'] . '发货单取消';
|
||
|
||
$params = $this->_format_delivery_cancel_params($sdf);
|
||
|
||
return $this->__caller->call(WMS_SALEORDER_CANCEL, $params, null, $title, 10, $delivery_bn);
|
||
|
||
}
|
||
|
||
protected function _format_delivery_cancel_params($sdf)
|
||
{
|
||
$params = array(
|
||
'warehouse_code' => $sdf['branch_bn'],
|
||
'out_order_code' => $sdf['outer_delivery_bn'],
|
||
);
|
||
return $params;
|
||
}
|
||
|
||
/**
|
||
* 发货单查询
|
||
*
|
||
* @return void
|
||
* @author
|
||
* */
|
||
public function delivery_search($sdf)
|
||
{
|
||
$delivery_bn = $sdf['delivery_bn'];
|
||
|
||
$title = $this->__channelObj->wms['channel_name'] . '发货单查询';
|
||
|
||
$params = $this->_format_delivery_search_params($sdf);
|
||
$rs = $this->__caller->call(WMS_SALEORDER_GET, $params, null, $title, 10, $delivery_bn);
|
||
$failModel = app::get('erpapi')->model('api_fail');
|
||
|
||
$retry = array(
|
||
'obj_bn' => $delivery_bn,
|
||
'obj_type' => 'search_delivery',
|
||
'channel' => 'wms',
|
||
'channel_id' => $this->__channelObj->wms['channel_id'],
|
||
'method' => 'delivery_search',
|
||
'args' => func_get_args(),
|
||
);
|
||
$apiFailId = $failModel->saveRunning($retry);
|
||
|
||
$rsp = 'fail';
|
||
$api_status = 'search_succ';
|
||
if ($rs['rsp'] == 'fail') {
|
||
$api_status = 'search_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.delivery.status_update')->dispatch($result['data']);
|
||
|
||
//如果succ 删除fail_log
|
||
if ($rs['rsp'] == 'succ') {
|
||
$rsp = 'succ';
|
||
$api_status = 'search_succ';
|
||
}
|
||
|
||
if ($rs['rsp'] == 'succ'
|
||
&& in_array($result['data']['status'], array('CLOSE', 'FAILED', 'DELIVERY'))) {
|
||
$failModel->delete(array('id' => $apiFailId));
|
||
}
|
||
}
|
||
}
|
||
|
||
//更新推单状态为失败
|
||
$deliveryObj = app::get('ome')->model('delivery');
|
||
$deliverys = $deliveryObj->dump(array('delivery_bn' => $delivery_bn), 'delivery_id');
|
||
|
||
$msg = $rs['err_msg'] ? $rs['err_msg'] : $rs['res'];
|
||
|
||
kernel::single('console_delivery')->update_sync_status($deliverys['delivery_id'], $api_status, $msg);
|
||
//把单号加进队列
|
||
// $failApiModel = app::get('erpapi')->model('api_fail');
|
||
// $api_data = array(
|
||
// 'obj_type' => 'search_delivery',
|
||
// 'obj_bn' => $delivery_bn,
|
||
|
||
// );
|
||
|
||
// $failApiModel->publish_api_fail(WMS_SALEORDER_GET, $api_data, array('rsp' => $rsp));
|
||
|
||
return $rs;
|
||
}
|
||
|
||
protected function _format_delivery_search_params($sdf)
|
||
{
|
||
$params = array(
|
||
'out_order_code' => $sdf['out_order_code'],
|
||
);
|
||
return $params;
|
||
}
|
||
|
||
protected function _deal_search_result($rs)
|
||
{
|
||
return $rs;
|
||
}
|
||
|
||
protected function _getNextObjType()
|
||
{
|
||
return '';
|
||
}
|
||
|
||
# 发货单截单
|
||
/**
|
||
* delivery_cut
|
||
* @param mixed $sdf sdf
|
||
* @return mixed 返回值
|
||
*/
|
||
public function delivery_cut($sdf){
|
||
$deliveryBn = $sdf['outer_delivery_bn'];
|
||
$title = $this->__channelObj->channel['channel_name'] . '发货单截单';
|
||
$params = $this->_format_cut_params($sdf);
|
||
if(empty($params['delivery_order_code'])) {
|
||
return $this->error('单号缺失');
|
||
}
|
||
$apiName = $this->_get_cut_name($sdf);
|
||
$callback = array();
|
||
$result = $this->__caller->call($apiName, $params, $callback, $title,10,$deliveryBn);
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* @param $sdf = array('delivery_bn'=>'', 'branch_id'=>'', 'branch_bn'=>'', 'original_delivery_bn'=>'')
|
||
* @return array
|
||
*/
|
||
protected function _format_cut_params($sdf) {
|
||
$params = array(
|
||
'warehouse_code' => $this->get_warehouse_code($this->__channelObj->wms['channel_id'], $sdf['branch_bn']),
|
||
'delivery_order_code' => $sdf['outer_delivery_bn'],
|
||
'order_id' => $sdf['original_delivery_bn'],
|
||
);
|
||
return $params;
|
||
}
|
||
|
||
protected function _get_cut_name($sdf) {
|
||
return WMS_SALEORDER_CALLBACK;
|
||
}
|
||
|
||
|
||
/**
|
||
* 预售付尾款通知wms接口
|
||
*
|
||
* @param $sdf
|
||
* @return string
|
||
*/
|
||
protected function get_delivery_notify_apiname($sdf)
|
||
{
|
||
return WMS_SALEORDER_CONFIRM;
|
||
}
|
||
|
||
public function delivery_notify($sdf){
|
||
|
||
$delivery_bn = $sdf['delivery_bn'];
|
||
|
||
$title = $this->__channelObj->wms['channel_name'] . '预售单通知';
|
||
|
||
$params = $this->_format_delivery_notify_params($sdf);
|
||
|
||
//method
|
||
$api_method = $this->get_delivery_notify_apiname($sdf);
|
||
|
||
//callback
|
||
$callback = array(
|
||
'class' => get_class($this),
|
||
'method' => 'delivery_notify_callback',
|
||
'params' => array('delivery_bn'=>$delivery_bn,'delivery_id'=>$sdf['delivery_id']),
|
||
);
|
||
|
||
return $this->__caller->call($api_method, $params, $callback, $title,10,$delivery_bn);
|
||
}
|
||
|
||
|
||
protected function _format_delivery_notify_params($sdf)
|
||
{
|
||
|
||
return array();
|
||
}
|
||
|
||
/**
|
||
* delivery_notify_callback
|
||
* @param mixed $response response
|
||
* @param mixed $callback_params 参数
|
||
* @return mixed 返回值
|
||
*/
|
||
public function delivery_notify_callback($response, $callback_params)
|
||
{
|
||
$rsp = $response['rsp'];
|
||
$err_msg = $response['err_msg'];
|
||
$data = $response['data'];
|
||
$msg_id = $response['msg_id'];
|
||
$res = $response['res'];
|
||
|
||
|
||
$delivery_bn = $callback_params['delivery_bn'];
|
||
$delivery_id = $callback_params['delivery_id'];
|
||
//更新同步状态
|
||
$deliveryOrderModel = app::get('ome')->model('delivery_order');
|
||
$deliveryOrderList = $deliveryOrderModel->getList('order_id',array('delivery_id'=>$delivery_id));
|
||
|
||
|
||
if ($rsp == 'succ'){
|
||
$presale_sync_status = 1;
|
||
}else{
|
||
$presale_sync_status = 2;
|
||
}
|
||
$extendObj = app::get('ome')->model('order_extend');
|
||
if ($deliveryOrderList){
|
||
foreach($deliveryOrderList as $v){
|
||
$order_id = $v['order_id'];
|
||
|
||
// 好来客户刷不动表,放弃使用
|
||
//$extendObj->update(array('presale_sync_status'=>$presale_sync_status),array('order_id'=>$order_id));
|
||
}
|
||
}
|
||
|
||
return $this->callback($response, $callback_params);
|
||
}
|
||
|
||
}
|