mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-22 18:35:35 +08:00
166 lines
8.6 KiB
PHP
166 lines
8.6 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.
|
|
*/
|
|
|
|
class erpapi_router_mapping
|
|
{
|
|
|
|
private static $_rsp_method_mapping = array(
|
|
'ome.remark.add' => 'shop.remark.add',
|
|
'ome.logistics.push' => 'hqepay.logistics.push',
|
|
'ome.payment.add' => 'shop.payment.add',
|
|
'ome.payment.status_update' => 'shop.payment.statusUpdate',
|
|
'ome.aftersale.add' => 'shop.aftersale.add',
|
|
'ome.aftersale.status_update' => 'shop.aftersale.statusUpdate',
|
|
'ome.aftersale.logistics_update' => 'shop.aftersale.logisticsUpdate',
|
|
'ome.refund.add' => 'shop.refund.add',
|
|
'ome.refund.aftersale_add' => 'shop.refund.aftersale_add',
|
|
'ome.refund.status_update' => 'shop.refund.statusUpdate',
|
|
'ome.order.payment_update' => 'shop.order.payment_update',
|
|
'ome.order.memo_update' => 'shop.order.memo_update',
|
|
'ome.order.memo_add' => 'shop.order.memo_add',
|
|
'ome.order.custom_mark_update' => 'shop.order.custom_mark_update',
|
|
'ome.order.custom_mark_add' => 'shop.order.custom_mark_add',
|
|
'ome.order.ship_status_update' => 'shop.order.ship_status_update',
|
|
'ome.order.pay_status_update' => 'shop.order.pay_status_update',
|
|
'ome.order.status_update' => 'shop.order.status_update',
|
|
'ome.order.add' => 'shop.order.add',
|
|
'ome.aftersalev2.add' => 'shop.aftersalev2.add',
|
|
'ome.unionpay.push' => 'unionpay.logistics.push',
|
|
'ome.invoice.message_push' => 'shop.invoice.message_push',
|
|
'ome.qianniu.address' => 'shop.qianniu.address_modify',
|
|
'ome.qianniu.address_notify' => 'shop.qianniu.order_addr_modify',//地址更新
|
|
'ome.shopbee.ordermsg' => 'shop.bookingrefund.ordermsg', //预约退款
|
|
'ome.order.delivergoods' => 'shop.delivergoods.urgent', //催发货
|
|
'ome.order.promise' => 'shop.delivergoods.promise', //晚发赔时间更新
|
|
'ome.order.invoice' => 'shop.invoice.add', //自助开发票
|
|
'ome.order.express' => 'shop.express.assign', //指定快递
|
|
'ome.order.getcorp' => 'shop.express.getcorp', //指定快递可用物流公司
|
|
'ome.exchange.add' => 'shop.exchange.add',
|
|
'ome.xc.order.add' => 'shop.branch.wait',
|
|
'system.msg.notify' => 'system.msg.notify',
|
|
'ome.goods.add' => 'shop.goods.add',
|
|
'ome.goods.delete' => 'shop.goods.delete',
|
|
'ome.qianniu.modifysku' => 'shop.qianniu.modifysku',
|
|
'ome.stock.get' => 'shop.stock.get',
|
|
'matrix_message.refund_created.notify' => 'shop.tmcnotify.refund',
|
|
'ome.shop.aoxiang_signed' => 'shop.shop.aoxiang_signed', //翱象系统通知签约
|
|
'ome.goods.aoxiang.update' => 'shop.goods.aoxiang_update', //货品新建&更新结果回传
|
|
'ome.goods.aoxiang.combine_update' => 'shop.goods.aoxiang_combine_update', //组合货品新建&更新结果回传
|
|
'ome.goods.aoxiang.combine_delete' => 'shop.goods.aoxiang_delete', //货品删除结果回传
|
|
'ome.goods.aoxiang.mapping' => 'shop.goods.aoxiang_mapping', //商货品关联关系结果回传
|
|
'ome.inventory.aoxiang.query' => 'shop.stock.aoxiang_query', //实仓库存查询接口
|
|
'ome.order.deliverypriority' => 'shop.deliverypriority.comeback',//订单挽回
|
|
'store.trade.add' => 'shop.order.add', //d1m创建订单
|
|
'store.trade.refund.add' => 'shop.aftersalev2.add', //d1m创建退款单
|
|
'store.trade.aftersale.add' => 'shop.aftersalev2.add', //d1m创建售后申请单
|
|
'store.trade.aftersale.logistics.update' => 'shop.aftersalev2.logisticsUpdate', //d1m更新售后申请物流信息
|
|
'store.trade.salesmaterial.listing' => 'shop.salesmaterial.getList', //d1m主档查询
|
|
'store.trade.invoice.add' => 'shop.invoice.message_push', //d1m订单开票
|
|
'store.trade.exchange.add' => 'shop.exchange.add', //website换货
|
|
'ome.bookingrefund.ordercancle'=>'shop.bookingrefund.ordercancle',
|
|
'ome.stock.occupy' => 'shop.stock.occupy',
|
|
'ome.goods.sku_delete' => 'shop.goods.sku_delete',
|
|
'invoice.einvoice.status_update' => 'invoice.order.status_update',
|
|
'store.item.skus.add' => 'shop.goods.add',
|
|
'ome.reissue.query' => 'shop.reissue.query',
|
|
'ome.reissue.cancel' => 'shop.reissue.cancel',
|
|
'qimen.taobao.erp.order.add' => 'qimen.order.add',
|
|
'qimen.taobao.erp.order.update' => 'qimen.order.update',
|
|
);
|
|
|
|
public static $_rsp_nodetype_mapping = array(
|
|
'weimeng', 'zhe800', 'youzan', 'yintai', 'yihaodian', 'wx', 'wdwd', 'vop', 'vjia', 'ecos.b2c', 'ecos.dzg', 'shopex_b2c', 'bbc', 'ecshop_b2c', 'public_b2c', 'shopex_b2b', 'suning', 'qqbuy', 'paipai', 'mogujie', 'mia', 'mengdian', 'meilishuo', 'juanpi', 'icbc', 'gome', 'feiniu', 'dangdang', 'ccb', 'beibei', 'amazon', 'alibaba', '360buy',
|
|
);
|
|
|
|
public static $_afterSaleV2 = array(
|
|
'meilishuo', 'beibei', 'feiniu', 'yihaodian', 'zhe800',
|
|
);
|
|
|
|
private static $_tran_method = array(
|
|
'ome.order.add',
|
|
'ome.aftersalev2.add',
|
|
'ome.exchange.add',
|
|
'ome.refund.add',
|
|
'ome.qianniu.address',
|
|
);
|
|
|
|
private static $_tran_method_mapping = array(
|
|
'ome.order.add' => 'dealer.order.add',
|
|
'ome.aftersalev2.add' => 'dealer.aftersalev2.add',
|
|
'ome.exchange.add' => 'dealer.exchange.add',
|
|
'ome.refund.add' => 'dealer.refund.add',
|
|
'ome.qianniu.address' => 'dealer.qianniu.address_modify',
|
|
);
|
|
|
|
#是否映射到erpapi中response
|
|
public static function rspServiceMapping($service, $method, &$node_id)
|
|
{
|
|
//转发方法
|
|
if(in_array($method, self::$_tran_method)){
|
|
$shops = self::get_shops($node_id);
|
|
|
|
//发货模式
|
|
if(in_array($shops['delivery_mode'], array('shopyjdf'))){
|
|
if (self::$_tran_method_mapping[$method]) {
|
|
return self::$_tran_method_mapping[$method];
|
|
}
|
|
}
|
|
}
|
|
|
|
if (self::$_rsp_method_mapping[$method]) {
|
|
// [开源ERP]获取绑定的qimen节点
|
|
if(in_array($method, ['qimen.taobao.erp.order.add', 'qimen.taobao.erp.order.update'])){
|
|
// app_key
|
|
$app_key = $_REQUEST['target_appkey'];
|
|
|
|
// 获取奇门聚石塔内外互通渠道信息
|
|
$channelInfo = kernel::single('channel_channel')->getQimenJushitaErp($app_key);
|
|
if(!empty($channelInfo)){
|
|
$node_id = $channelInfo['node_id'];
|
|
}
|
|
}
|
|
|
|
return self::$_rsp_method_mapping[$method];
|
|
}
|
|
|
|
// if ($method == 'ome.order.add' && in_array(self::get_node_type($node_id), self::$_rsp_nodetype_mapping)) return 'ome.order.add';
|
|
//if ($method == 'ome.aftersalev2.add' && in_array(self::get_node_type($node_id), self::$_afterSaleV2)) return 'shop.aftersalev2.add';
|
|
|
|
return false;
|
|
}
|
|
|
|
private static function get_node_type($node_id)
|
|
{
|
|
$row = kernel::database()->selectrow('SELECT node_type FROM sdb_ome_shop WHERE node_id="' . addslashes($node_id) . '"');
|
|
|
|
return $row['node_type'];
|
|
}
|
|
|
|
private static function get_shops($node_id)
|
|
{
|
|
$shops_detail = app::get('ome')->model('shop')->dump(array('node_id'=>$node_id), '*');
|
|
if ($shops_detail['config']){
|
|
$shops_detail['config'] = @unserialize($shops_detail['config']);
|
|
}
|
|
if (is_string($shops_detail['addon']) && $shops_detail['addon']){
|
|
$shops_detail['addon'] = @unserialize($shops_detail['addon']);
|
|
}
|
|
|
|
return $shops_detail;
|
|
}
|
|
}
|