mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-22 18:35:35 +08:00
553 lines
20 KiB
PHP
553 lines
20 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.
|
||
*/
|
||
/**
|
||
* RESPONSE 路由
|
||
*
|
||
* @category
|
||
* @package
|
||
* @author chenping<chenping@shopex.cn>
|
||
* @version $Id: Z
|
||
*/
|
||
@include_once(dirname(__FILE__).'/../apiname.php');
|
||
class erpapi_router_response
|
||
{
|
||
/**
|
||
* 渠道节点
|
||
*
|
||
* @var string
|
||
* */
|
||
private $__node_id;
|
||
|
||
/**
|
||
* 接口名，如:wms.delivery.status_update
|
||
*
|
||
* @var string
|
||
* */
|
||
private $__api_name;
|
||
|
||
/**
|
||
* 渠道ID
|
||
*
|
||
* @var string
|
||
* */
|
||
private $__channel_id;
|
||
|
||
/**
|
||
* 并发KEY
|
||
*
|
||
* @var string
|
||
* */
|
||
private $__concurrent_key = '';
|
||
|
||
/**
|
||
* 设置_node_id
|
||
* @param mixed $node_id ID
|
||
* @return mixed 返回操作结果
|
||
*/
|
||
|
||
public function set_node_id($node_id)
|
||
{
|
||
$this->__node_id = $node_id;
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 设置_channel_id
|
||
* @param mixed $channel_id ID
|
||
* @return mixed 返回操作结果
|
||
*/
|
||
public function set_channel_id($channel_id)
|
||
{
|
||
$this->__channel_id = $channel_id;
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 设置_api_name
|
||
* @param mixed $api_name api_name
|
||
* @return mixed 返回操作结果
|
||
*/
|
||
public function set_api_name($api_name)
|
||
{
|
||
$this->__api_name = $api_name;
|
||
return $this;
|
||
}
|
||
|
||
private function _parse_api_name()
|
||
{
|
||
$pieces = explode('.', $this->__api_name);
|
||
$channel_type = array_shift($pieces);
|
||
$method = array_pop($pieces);
|
||
$business = implode('_', $pieces);
|
||
|
||
// list($channel_type, $business, $method) = ;
|
||
|
||
if ($channel_type == 'ome') {
|
||
$channel_type = 'shop';
|
||
}
|
||
|
||
return array($channel_type, $business, $method);
|
||
}
|
||
|
||
/**
|
||
* dispatch
|
||
* @param mixed $params 参数
|
||
* @param mixed $sign_check sign_check
|
||
* @return mixed 返回值
|
||
*/
|
||
public function dispatch($params, $sign_check = false)
|
||
{
|
||
$this->__start_time = microtime(true);
|
||
|
||
try {
|
||
// 节点和ID都不存在，抛出异常
|
||
if (!$this->__node_id && !$this->__channel_id) {
|
||
throw new erpapi_exception("节点参数必填");
|
||
}
|
||
|
||
// 接口名不存在抛出异常
|
||
if (!$this->__api_name) {
|
||
throw new erpapi_exception("接口名称必填");
|
||
}
|
||
|
||
list($channel_type, $business, $method) = $this->_parse_api_name();
|
||
|
||
// 实例化渠道类
|
||
$channel_name = 'erpapi_channel_' . $channel_type;
|
||
$channel_class = kernel::single($channel_name, array($this->__node_id, $this->__channel_id));
|
||
|
||
if (!$channel_class instanceof erpapi_channel_abstract) {
|
||
throw new erpapi_exception("{$channel_name} not instanceof erpapi_channel_abstract");
|
||
}
|
||
|
||
$channelRs = $channel_class->init($this->__node_id, $this->__channel_id);
|
||
if (!$channelRs) {
|
||
throw new erpapi_exception("节点不存在");
|
||
}
|
||
|
||
$adapter = $channel_class->get_adapter();
|
||
$platform = $channel_class->get_platform();
|
||
$ver = $channel_class->get_ver();
|
||
|
||
// 签名验证
|
||
if (in_array($adapter, array('matrix', 'openapi', 'prism')) && $sign_check) {
|
||
$signRs = $this->_check_sign($channel_class, $params);
|
||
|
||
if ($signRs == false) {
|
||
throw new erpapi_exception("签名错误");
|
||
}
|
||
|
||
return true;
|
||
}
|
||
if ($channel_type == 'front' && $sign_check) {
|
||
return true;
|
||
}
|
||
|
||
// 默认数据转换类
|
||
$object_class = $this->_get_object_class($channel_class, $params);
|
||
|
||
// 防并发
|
||
$this->__concurrent_key = '';
|
||
if (method_exists($object_class, 'concurrentKey')) {
|
||
$this->__concurrent_key = $object_class->concurrentKey($params);
|
||
if ($this->__concurrent_key) {
|
||
// 判断是否在任务执行中
|
||
$original_bn = $object_class->__apilog['original_bn'];
|
||
$lastmodify = $object_class->__lastmodify;
|
||
$cacheData = cachecore::fetch($this->__concurrent_key);
|
||
if (is_array($cacheData) && 'running' == $cacheData['status']) {
|
||
$mqmsg = '';
|
||
if ($this->__api_name == 'shop.order.add' && $lastmodify > $cacheData['lastmodify']) {
|
||
$mqmsg = $this->reWriteToMQ($params, $params['order_bn']);
|
||
}
|
||
// 制空，不删除
|
||
$this->__concurrent_key = '';
|
||
throw new erpapi_exception("订单正在处理，请稍后请求!" . $mqmsg);
|
||
}
|
||
$cacheData = array(
|
||
'status' => 'running',
|
||
'lastmodify' => $lastmodify,
|
||
);
|
||
|
||
cachecore::store($this->__concurrent_key, $cacheData, 60);
|
||
}
|
||
}
|
||
|
||
$object_class->init($channel_class);
|
||
if (method_exists($object_class, $method)) {
|
||
// 数据转成标准格式
|
||
$convert_params = $object_class->{$method}($params);
|
||
} else {
|
||
throw new erpapi_exception(sprintf('The required method "%s" does not exist for %s', $method, get_class($object_class)));
|
||
}
|
||
|
||
$title = $object_class->__apilog['title'];
|
||
$original_bn = $object_class->__apilog['original_bn'];
|
||
$convert_result = $object_class->__apilog['result'];
|
||
if (!$convert_params) {
|
||
$msg_code = $convert_result['msg_code'] ? $convert_result['msg_code'] : '';
|
||
$this->_write_log($title, $original_bn, 'fail', $params, $convert_params, $convert_result);
|
||
|
||
$failResult = array('rsp' => 'fail', 'msg' => $convert_result['msg'], 'msg_code' => $msg_code, 'data' => $convert_result['data']);
|
||
// custom 兼容部分需要返回succ的场景,判断$convert_result 是否有给出rsp值
|
||
if(isset($convert_result['rsp']) && $convert_result['rsp']){
|
||
$failResult['rsp'] = $convert_result['rsp'];
|
||
}
|
||
|
||
return $failResult;
|
||
}
|
||
|
||
// 数据验证
|
||
try {
|
||
$params_name = 'erpapi_' . $channel_type . '_response_params_' . $business;
|
||
if (class_exists($params_name)) {
|
||
$valid = kernel::single($params_name, array($channel_class))->check($convert_params, $method);
|
||
|
||
if ($valid['rsp'] != 'succ') {
|
||
|
||
$this->_write_log($title, $original_bn, 'fail', $params, $convert_params, $valid);
|
||
|
||
return array('rsp' => 'fail', 'msg' => $valid['msg'], 'msg_code' => '', 'data' => $convert_result['data']);
|
||
}
|
||
}
|
||
} catch (Exception $e) {}
|
||
|
||
// 最终的处理
|
||
$result = kernel::single('erpapi_' . $channel_type . '_response_process_' . $business, array($channel_class))->{$method}($convert_params);
|
||
|
||
$status = ($result['rsp'] == 'succ' || $result['rsp'] == 'success') ? 'success' : 'fail';
|
||
$this->_write_log($title, $original_bn, $status, $params, $convert_params, $result);
|
||
|
||
if ($result['rsp'] != 'succ' && $result['rsp'] != 'success') {
|
||
$apiParms = $result['data'];
|
||
|
||
$result['data'] = $convert_result['data'];
|
||
//放入失败队列处理
|
||
$errorCode = kernel::single('erpapi_errcode')->getErrcode($channel_type); //错误码
|
||
|
||
if ($errorCode && (in_array($result['res'], array_keys($errorCode)) || in_array($result['msg_code'], array_keys($errorCode)))) {
|
||
if (!$apiParms['obj_type']) {
|
||
$apiParms['obj_type'] = $errorCode[$result['msg_code']]['obj_type'];
|
||
}
|
||
|
||
$failApiModel = app::get('erpapi')->model('api_fail');
|
||
|
||
$failApiModel->publish_api_fail($this->__api_name, $apiParms, $result);
|
||
}
|
||
return $result;
|
||
}
|
||
$result['data'] = $result['data'] ? $result['data'] : $convert_result['data'];
|
||
return $result;
|
||
} catch (erpapi_exception $e) {
|
||
$result['msg'] = $e->getMessage() . '(' . $e->getTraceAsString() . ')';
|
||
|
||
$original_bn = $original_bn ? $original_bn : 'logic-exception';
|
||
$this->_write_log('业务异常', $original_bn, 'fail', $params, array(), $result);
|
||
|
||
return array('rsp' => 'fail', 'msg' => $e->getMessage(), 'msg_code' => '', 'data' => null);
|
||
} catch (Exception $e) {
|
||
// 异常上报
|
||
\Sentry\captureException($e);
|
||
$result['msg'] = $e->getMessage() . '(' . $e->getTraceAsString() . ')';
|
||
|
||
$original_bn = $original_bn ? $original_bn : 'response-exception';
|
||
$this->_write_log('错误异常', $original_bn, 'fail', $params, array(), $result);
|
||
|
||
return array('rsp' => 'fail', 'msg' => $e->getMessage(), 'msg_code' => '', 'data' => null);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取处理类
|
||
*
|
||
* @return void
|
||
* @author
|
||
* */
|
||
private function _get_object_class($channel_class, $params)
|
||
{
|
||
list($channel_type, $business, $method) = $this->_parse_api_name();
|
||
|
||
$adapter = $channel_class->get_adapter();
|
||
$platform = $channel_class->get_platform();
|
||
$platform_business = $channel_class->get_platform_business();
|
||
$ver = $channel_class->get_ver();
|
||
|
||
$default_object_name = 'erpapi_' . $channel_type . '_response_' . $business;
|
||
|
||
$object_name_arr = array('erpapi', $channel_type, $adapter, $platform, 'response', $business);
|
||
|
||
$object_name = implode('_', array_filter($object_name_arr));
|
||
try {
|
||
if (class_exists($object_name)) {
|
||
$object_class = kernel::single($object_name, array($channel_class));
|
||
|
||
if (!is_subclass_of($object_class, $default_object_name)) {
|
||
throw new Exception("{$object_name} is a subclass of {$default_object_name}");
|
||
}
|
||
|
||
}
|
||
} catch (Exception $e) {
|
||
|
||
}
|
||
|
||
if (!is_object($object_class) && false !== strpos($platform, 'shopex_')) {
|
||
$parentPlatForm = 'shopex';
|
||
|
||
// 自带处理类
|
||
$object_name_arr = array('erpapi', $channel_type, $adapter, $parentPlatForm, 'response', $business);
|
||
$object_name = implode('_', array_filter($object_name_arr));
|
||
try {
|
||
if (class_exists($object_name)) {
|
||
$object_class = kernel::single($object_name, array($channel_class));
|
||
|
||
if (!is_subclass_of($object_class, $default_object_name)) {
|
||
throw new Exception("{$object_name} is a subclass of {$default_object_name}");
|
||
}
|
||
|
||
}
|
||
} catch (Exception $e) {
|
||
|
||
}
|
||
}
|
||
|
||
if (!is_object($object_class) && false !== strpos($platform, 'pos_')) {
|
||
$parentPlatForm = 'pos';
|
||
|
||
// 自带处理类
|
||
$object_name_arr = array('erpapi', $channel_type, $adapter, $parentPlatForm, 'response', $business);
|
||
$object_name = implode('_', array_filter($object_name_arr));
|
||
try {
|
||
if (class_exists($object_name)) {
|
||
$object_class = kernel::single($object_name, array($channel_class));
|
||
|
||
if (!is_subclass_of($object_class, $default_object_name)) {
|
||
throw new Exception("{$object_name} is a subclass of {$default_object_name}");
|
||
}
|
||
|
||
}
|
||
} catch (Exception $e) {
|
||
|
||
}
|
||
}
|
||
|
||
// 对象内业务流转 (不建议使用， 改用platform_business)
|
||
if (is_object($object_class) && method_exists($object_class, 'business_flow')) {
|
||
$business_name = $object_class->business_flow($params);
|
||
|
||
try {
|
||
if (class_exists($business_name)) {
|
||
$object_class = kernel::single($business_name, array($channel_class));
|
||
|
||
if (!is_subclass_of($object_class, $default_object_name)) {
|
||
throw new Exception("{$object_name} is a subclass of {$default_object_name}");
|
||
}
|
||
|
||
}
|
||
} catch (Exception $e) {}
|
||
}
|
||
|
||
if($platform_business) {
|
||
// 将$platform_business插入到数据$object_name_arr的倒数第二位
|
||
array_splice( $object_name_arr, -1, 0, [$platform_business]);
|
||
|
||
// $object_name_arr = array('erpapi', $channel_type, $adapter, $platform, 'response', $platform_business, $business);
|
||
|
||
$object_name = implode('_',array_filter($object_name_arr));
|
||
|
||
try {
|
||
if (class_exists($object_name)) {
|
||
$pb_object_class = kernel::single($object_name,array($channel_class));
|
||
|
||
if (is_subclass_of($pb_object_class, $default_object_name)) {
|
||
$object_class = $pb_object_class;
|
||
}
|
||
}
|
||
} catch (Exception $e) {
|
||
|
||
}
|
||
}
|
||
|
||
// 取默认
|
||
if (!is_object($object_class)) {
|
||
$object_class = kernel::single($default_object_name, array($channel_class));
|
||
}
|
||
|
||
return $object_class;
|
||
}
|
||
|
||
/**
|
||
* 验证签名
|
||
*
|
||
* @return void
|
||
* @author
|
||
* */
|
||
private function _check_sign($channel_class, $params)
|
||
{
|
||
list($channel_type, $business, $method) = $this->_parse_api_name();
|
||
$adapter = $channel_class->get_adapter();
|
||
$platform = $channel_class->get_platform();
|
||
$ver = $channel_class->get_ver();
|
||
|
||
// 默认
|
||
$config_class = kernel::single('erpapi_' . $channel_type . '_config', array($channel_class));
|
||
|
||
// 如果有自身配置
|
||
try {
|
||
if (class_exists('erpapi_' . $channel_type . '_' . $adapter . '_' . $platform . '_config')) {
|
||
$config_class = kernel::single('erpapi_' . $channel_type . '_' . $adapter . '_' . $platform . '_config', array($channel_class));
|
||
}
|
||
} catch (Exception $e) {
|
||
try {
|
||
if (class_exists('erpapi_' . $channel_type . '_' . $adapter . '_config')) {
|
||
$config_class = kernel::single('erpapi_' . $channel_type . '_' . $adapter . '_config', array($channel_class));
|
||
}
|
||
} catch (Exception $e) {
|
||
|
||
}
|
||
}
|
||
|
||
$config_class->init($channel_class);
|
||
|
||
// 签名
|
||
$sign = $params['sign'];unset($params['sign']);
|
||
$erp_sign = $config_class->gen_sign($params);
|
||
|
||
if ($sign != $erp_sign) {
|
||
return false;
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 日志
|
||
*
|
||
* @return void
|
||
* @author
|
||
* */
|
||
private function _write_log($title, $original_bn, $status = 'succ', $params = array(), $convert_params = array(), $result = array())
|
||
{
|
||
if ($this->__concurrent_key) {
|
||
cachecore::store($this->__concurrent_key, '', 1);
|
||
}
|
||
|
||
// 写日志
|
||
$apilogModel = app::get('ome')->model('api_log');
|
||
$log_id = $apilogModel->gen_id();
|
||
|
||
if ($params['task'] && $result['rsp'] == 'succ') {
|
||
$apilogModel->set_repeat($params['task'], $log_id);
|
||
}
|
||
$logParams = json_encode($params);
|
||
$traParams = json_encode($convert_params);
|
||
// $msg = '接收参数：' . var_export($params, true) . '<hr/>转换后参数：' . var_export($convert_params, true) . '<hr/>返回结果：' . var_export($result, true);
|
||
|
||
// url
|
||
$request_uri = base_request::get_request_uri();
|
||
$source_url = $request_uri ? (strpos($request_uri, '?') !== false ? substr($request_uri, 0, strpos($request_uri, '?')) : $request_uri) : '';
|
||
|
||
// sdf
|
||
$logsdf = array(
|
||
'log_id' => $log_id,
|
||
'task_name' => $title,
|
||
'status' => $status,
|
||
'worker' => $params['method'],
|
||
'params' => strlen($logParams) < 256000 ? $logParams : '',
|
||
'transfer' => strlen($traParams) < 256000 ? $traParams : '',
|
||
'response' => json_encode($result),
|
||
'msg' => $result['msg'],
|
||
'log_type' => '',
|
||
'api_type' => 'response',
|
||
'memo' => '',
|
||
'original_bn' => $original_bn,
|
||
'createtime' => time(),
|
||
'last_modified' => time(),
|
||
'msg_id' => (string)$params['msg_id'], //矩阵给的msg_id
|
||
'spendtime' => microtime(true) - $this->__start_time,
|
||
'url' => $source_url,
|
||
);
|
||
|
||
$apilogModel->insert($logsdf);
|
||
}
|
||
|
||
private static function gen_sign($params)
|
||
{
|
||
return strtoupper(md5(strtoupper(md5(base_certificate::assemble($params))) . 'S89NCHdjs4xd3kjfhec92P'));
|
||
}
|
||
|
||
/**
|
||
* reWriteToMQ
|
||
* @param mixed $params 参数
|
||
* @param mixed $tid ID
|
||
* @return mixed 返回值
|
||
*/
|
||
public function reWriteToMQ($params, $tid)
|
||
{
|
||
// 放入队列之前，先去重
|
||
$obj_rpc_poll = app::get('base')->model('rpcpoll');
|
||
$rpc_id = $params['task'] ? $params['task'] : md5($params['task'] . $params['sign'] . $_SERVER['HTTP_HOST']);
|
||
$obj_rpc_poll->deleteRpc($rpc_id, 'response');
|
||
if (defined('SAAS_API_MQ') && SAAS_API_MQ == 'true') {
|
||
|
||
//获取http或者https
|
||
$http_prefix = kernel::request()->get_schema();
|
||
$http_prefix = strtolower($http_prefix);
|
||
$http_prefix = ($http_prefix ? $http_prefix : 'http');
|
||
|
||
//params
|
||
foreach ($params as $key => $val) {
|
||
$postAttr[] = $key . '=' . urlencode($val);
|
||
}
|
||
|
||
$content = array();
|
||
$content['spider_data']['url'] = sprintf("%s://%s%s", $http_prefix, $_SERVER['SERVER_NAME'], $_SERVER['REQUEST_URI']);
|
||
|
||
$content['spider_data']['params'] = empty($postAttr) ? '' : join('&', $postAttr);
|
||
$content['relation']['to_node_id'] = base_shopnode::node_id('ome');
|
||
$content['relation']['from_node_id'] = $params['from_node_id'];
|
||
$content['relation']['tid'] = $tid;
|
||
$content['relation']['to_url'] = $content['spider_data']['url'];
|
||
$content['relation']['time'] = time();
|
||
|
||
$routerKey = 'tg.sys.api.' . $params['from_node_id'];
|
||
|
||
$message = json_encode($content);
|
||
$mq = kernel::single('base_queue_mq');
|
||
$mq->connect($GLOBALS['_MQ_API_CONFIG'], 'TG_API_EXCHANGE', 'TG_API_QUEUE');
|
||
$mq->publish($message, $routerKey);
|
||
$mq->disconnect();
|
||
return '重新丢回队列:成功';
|
||
} else {
|
||
$push_data = array(
|
||
'task_id' => $rpc_id,
|
||
'_FROM_MQ_QUEUE' => 'true',
|
||
'task_type' => 'orderrpc',
|
||
);
|
||
$push_data = array_merge($push_data, $params);
|
||
|
||
//callback请求进队列
|
||
$push_params = array(
|
||
'data' => $push_data,
|
||
'url' => kernel::openapi_url('openapi.autotask', 'service'),
|
||
);
|
||
kernel::single('taskmgr_interface_connecter')->push($push_params);
|
||
return '重新丢回队列:成功';
|
||
}
|
||
return '';
|
||
}
|
||
}
|