mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-22 18:35:35 +08:00
512 lines
18 KiB
PHP
512 lines
18 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_mdl_api_fail extends dbeav_model{
|
|
|
|
public $objTypeProperty = array(
|
|
'search_inpurchase' => array(
|
|
'text' => '查询采购单状态',
|
|
'method' => 'console_event_trigger_purchase:searchPurchase',
|
|
'filter' => array(
|
|
'app' => 'purchase',
|
|
'model' => 'po',
|
|
'obj_bn' => 'po_bn',
|
|
'check_status' => '2',
|
|
'po_status' => '1'
|
|
)
|
|
),
|
|
'search_delivery' => array(
|
|
'text' => '查询发货单状态',
|
|
'method' => 'ome_delivery_notice:searchDelivery',
|
|
'filter' => array(
|
|
'app' => 'ome',
|
|
'model' => 'delivery',
|
|
'obj_bn' => 'delivery_bn',
|
|
'status' => array('ready','progress'),
|
|
'parent_id' => '0',
|
|
)
|
|
),
|
|
'search_outpurchase_return' => array(
|
|
'text' => '查询采购退货单',
|
|
'method' => 'console_event_trigger_purchasereturn:searchPurchaseReturn',
|
|
'filter' => array(
|
|
'app' => 'purchase',
|
|
'model' => 'returned_purchase',
|
|
'obj_bn' => 'rp_bn',
|
|
'check_status' => '2',
|
|
'return_status' => array('1','4')
|
|
)
|
|
),
|
|
'search_reship' => array(
|
|
'text' => '退货单查询',
|
|
'method' => 'wms_trigger_reship:reshipSearch',
|
|
'filter' => array(
|
|
'app' => 'ome',
|
|
'model' => 'reship',
|
|
'obj_bn' => 'reship_bn',
|
|
'is_check' => array('1', '11')
|
|
)
|
|
),
|
|
'search_iso' => array(
|
|
'text' => '查询直接出入库单',
|
|
'method' => 'console_event_trigger_iso:search',
|
|
'filter' => array(
|
|
'app' => 'taoguaniostockorder',
|
|
'model' => 'iso',
|
|
'obj_bn' => 'iso_bn',
|
|
'status' => 'Y',
|
|
'confirm' => 'N'
|
|
)
|
|
),
|
|
'deliveryBack' => array(
|
|
'text' => '物流信息回传平台',
|
|
'method' => 'ome_event_trigger_shop_delivery:delivery_confirm_send_fromsub',
|
|
'filter' => array(
|
|
'app' => 'ome',
|
|
'model' => 'delivery',
|
|
'obj_bn' => 'delivery_bn',
|
|
'status' => array('ready','progress','succ'),
|
|
// 'parent_id' => '0',
|
|
)
|
|
),
|
|
'bookingrefund_back' => array(
|
|
'text' => '订单退款回传平台',
|
|
'method' => '',
|
|
'filter' => array(),
|
|
),
|
|
'upload_invoice' => array(
|
|
'text' => '电子发票上传',
|
|
'method' => 'invoice_event_trigger_einvoice:upload',
|
|
'filter' => array(
|
|
'app' => 'invoice',
|
|
'model' => 'order_electronic_items',
|
|
'obj_bn' => 'invoice_no',
|
|
),
|
|
),
|
|
);
|
|
|
|
/**
|
|
* 获取ObjTypeText
|
|
* @return mixed 返回结果
|
|
*/
|
|
public function getObjTypeText() {
|
|
$arrText = array();
|
|
foreach($this->objTypeProperty as $k => $val) {
|
|
$arrText[$k] = $val['text'];
|
|
}
|
|
return $arrText;
|
|
}
|
|
|
|
/**
|
|
* modifier_obj_type
|
|
* @param mixed $col col
|
|
* @return mixed 返回值
|
|
*/
|
|
public function modifier_obj_type($col)
|
|
{
|
|
return $this->objTypeProperty[$col] ? $this->objTypeProperty[$col]['text'] : $col;
|
|
}
|
|
|
|
/**
|
|
* modifier_err_msg
|
|
* @param mixed $col col
|
|
* @return mixed 返回值
|
|
*/
|
|
public function modifier_err_msg($col){
|
|
$col = strip_tags($col);
|
|
return sprintf("<span alt='%s' title='%s'>%s</span>",$col, $col, $col);
|
|
}
|
|
|
|
/**
|
|
* 发布失败日志
|
|
*
|
|
* 已弃用 Thu May 5 11:04:32 2022 chenping@shopex.cn
|
|
*
|
|
* @return void
|
|
* @author
|
|
* */
|
|
public function publish_api_fail($method, $callback_params, $result)
|
|
{
|
|
|
|
$obj_bn = $callback_params['obj_bn'];
|
|
$obj_type = $callback_params['obj_type'];
|
|
$err_msg = $result['err_msg'];
|
|
$res = $result['res'];
|
|
$status = $result['rsp'];
|
|
|
|
if (!$obj_bn || !$obj_type || !$method) return true;
|
|
|
|
$fail = $this->dump(array('obj_bn'=>$obj_bn,'obj_type'=>$obj_type));
|
|
if ($status == 'fail') {
|
|
$fail_params = array(
|
|
'obj_bn' => $obj_bn,
|
|
'obj_type' => $obj_type,
|
|
'method' => $method,
|
|
'err_msg' => $err_msg.'('.$res.')'.$result['msg'],
|
|
'fail_times' => ((int)$fail['fail_times'] + 1),
|
|
'status' => 'fail',
|
|
'last_modify'=> time(),
|
|
|
|
'msg_id' => $result['msg_id'],
|
|
'params' => $callback_params['params'],
|
|
);
|
|
if ($fail) $fail_params['id'] = $fail['id'];
|
|
if(!$fail) $fail_params['create_time'] = time();
|
|
$this->save($fail_params);
|
|
$apifail_mq = app::get('ome')->getConf('ome.saas.apifail_mq');
|
|
$retryapiErrcode = $this->getretryapiErrcode();
|
|
// 判断是不是超时
|
|
if ((in_array($res,$retryapiErrcode) || in_array($result['msg_code'],$retryapiErrcode)) && $fail_params['fail_times']<3 && $apifail_mq!='true') {
|
|
|
|
$retrytime = app::get('ome')->getConf('ome.apifail.retry');
|
|
$retrytime = $retrytime ? $retrytime * 60 : 600;
|
|
$push_params = array(
|
|
'data' => array(
|
|
'log_id' => $fail_params['id'],
|
|
'task_type' => 'autoretryapi',
|
|
'exectime' => (time() + $retrytime),
|
|
'obj_bn' => $obj_bn,
|
|
'obj_type' => $obj_type,
|
|
'method' => $method,
|
|
'id' => $fail_params['id'],
|
|
),
|
|
'url' => kernel::openapi_url('openapi.autotask','service')
|
|
);
|
|
|
|
$flag = kernel::single('taskmgr_interface_connecter')->push($push_params);
|
|
|
|
// if ($flag) {
|
|
// $this->update(array('status'=>'running'),array('id'=>$fail_params['id']));
|
|
// }
|
|
}
|
|
} elseif ($status=='succ' && $fail) {
|
|
$this->delete(array('id'=>$fail['id']));
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* 获取retryapiErrcode
|
|
* @return mixed 返回结果
|
|
*/
|
|
public function getretryapiErrcode(){
|
|
|
|
$errcode = kernel::single('erpapi_errcode')->errcode;
|
|
|
|
$retryCode = array();
|
|
foreach($errcode as $key=>$val){
|
|
|
|
foreach($val as $vk=>$vv){
|
|
if ( $vv['retry'] == '1' ){
|
|
$retryCode[] = $vk;
|
|
}
|
|
}
|
|
|
|
}
|
|
return $retryCode;
|
|
}
|
|
|
|
//异步请求重试 重新组装数据
|
|
/**
|
|
* 保存TriggerRequest
|
|
* @param mixed $objBn objBn
|
|
* @param mixed $objType objType
|
|
* @param mixed $api_method api_method
|
|
* @param mixed $errMsg errMsg
|
|
* @param mixed $sub_obj_bn sub_obj_bn
|
|
* @return mixed 返回操作结果
|
|
*/
|
|
public function saveTriggerRequest($objBn, $objType, $api_method='', $errMsg='', $sub_obj_bn = '') {
|
|
$sdf = array(
|
|
'obj_bn' => $objBn,
|
|
'obj_type' => $objType,
|
|
'method' => $api_method,
|
|
'retry_params' => 'trigger_request',
|
|
'status' => 'running',
|
|
'last_modify' => time(),
|
|
'sub_obj_bn' => $sub_obj_bn,
|
|
);
|
|
if($errMsg) {
|
|
$sdf['status'] = 'fail';
|
|
$sdf['err_msg'] = $errMsg;
|
|
}
|
|
$data = $this->getList('id', array('obj_bn'=>$objBn, 'obj_type'=>$objType, 'sub_obj_bn' => $sub_obj_bn), 0, 1);
|
|
if($data) {
|
|
if($this->update($sdf, array('id'=>$data[0]['id']))) {
|
|
return $data[0]['id'];
|
|
}
|
|
} else {
|
|
$sdf['create_time'] = time();
|
|
if($this->insert($sdf)) {
|
|
return $sdf['id'];
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* 异步请求重试 不重新组装数据
|
|
* @param [type] $params [description]
|
|
* @return [type] [description]
|
|
*/
|
|
public function saveRunning($params) {
|
|
$sdf = array(
|
|
'obj_bn' => $params['obj_bn'],
|
|
'obj_type' => $params['obj_type'],
|
|
'retry_params' => serialize(array(
|
|
'channel' => $params['channel'],
|
|
'channel_id' => $params['channel_id'],
|
|
'method' => $params['method'],
|
|
'args' => $params['args'],
|
|
'next_obj_type' => $params['next_obj_type']
|
|
)),
|
|
'status' => 'running',
|
|
'last_modify' => time(),
|
|
);
|
|
if($params['total_page']) {
|
|
$page = array();
|
|
for($i = 0; $i < $params['total_page']; $i++) {
|
|
$page[$i+1] = '';
|
|
}
|
|
$sdf['page_content'] = serialize(array(
|
|
'page'=>$page,
|
|
'err_msg'=>''
|
|
));
|
|
}
|
|
$data = $this->getList('id', array('obj_bn'=>$params['obj_bn'], 'obj_type'=>$params['obj_type']), 0, 1);
|
|
if($data) {
|
|
if($this->update($sdf, array('id'=>$data[0]['id']))) {
|
|
return $data[0]['id'];
|
|
}
|
|
} else {
|
|
$sdf['create_time'] = time();
|
|
if($this->insert($sdf)) {
|
|
return $sdf['id'];
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
# 同步请求重试 不重新组装数据
|
|
/**
|
|
* 保存SyncRequest
|
|
* @param mixed $params 参数
|
|
* @return mixed 返回操作结果
|
|
*/
|
|
public function saveSyncRequest($params) {
|
|
if($params['rsp'] == 'succ') {
|
|
$this->delete(array('obj_bn'=>$params['obj_bn'], 'obj_type'=>$params['obj_type']));
|
|
return true;
|
|
}
|
|
$sdf = array(
|
|
'obj_bn' => $params['obj_bn'],
|
|
'obj_type' => $params['obj_type'],
|
|
'retry_params' => serialize(array(
|
|
'channel' => $params['channel'],
|
|
'channel_id' => $params['channel_id'],
|
|
'method' => $params['method'],
|
|
'args' => $params['args'],
|
|
)),
|
|
'err_msg' => $params['err_msg'],
|
|
'msg_id' => $params['msg_id'],
|
|
'status' => 'fail',
|
|
'last_modify' => time(),
|
|
);
|
|
$data = $this->getList('id,fail_times',
|
|
array('obj_bn'=>$params['obj_bn'], 'obj_type'=>$params['obj_type']), 0, 1);
|
|
if($data) {
|
|
$sdf['fail_times'] = (int) $data[0]['fail_times'] + 1;
|
|
if($this->update($sdf, array('id'=>$data[0]['id']))) {
|
|
return $data[0]['id'];
|
|
}
|
|
} else {
|
|
$sdf['create_time'] = time();
|
|
if($this->insert($sdf)) {
|
|
return $sdf['id'];
|
|
}
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* dealCallback
|
|
* @param mixed $status status
|
|
* @param mixed $apiFailId ID
|
|
* @param mixed $msg msg
|
|
* @param mixed $msg_id ID
|
|
* @return mixed 返回值
|
|
*/
|
|
public function dealCallback($status,$apiFailId, $msg, $msg_id) {
|
|
if(strpos($apiFailId, '-')) {
|
|
list($id, $page) = explode('-', $apiFailId);
|
|
$data = $this->db_dump(array('id'=>$id), '*');
|
|
$pageContent = unserialize($data['page_content']);
|
|
$is_finish = true;
|
|
$is_success = true;
|
|
foreach($pageContent['page'] as $k => &$val) {
|
|
if($k == $page) {
|
|
$val = $status;
|
|
}
|
|
if(empty($val)) {
|
|
$is_finish = false;
|
|
} elseif($val != 'success') {
|
|
$is_success = false;
|
|
}
|
|
}
|
|
if($status != 'success' && strpos($pageContent['err_msg'], $msg) == false) {
|
|
$pageContent['err_msg'] .= $msg;
|
|
}
|
|
$this->update(array('page_content'=>serialize($pageContent)), array('id'=>$id));
|
|
if($is_finish) {
|
|
$status = $is_success ? 'success' : 'fail';
|
|
$msg = $pageContent['err_msg'];
|
|
} else {
|
|
return null;
|
|
}
|
|
} else {
|
|
$id = $apiFailId;
|
|
$data = $this->db_dump(array('id'=>$id), '*');
|
|
}
|
|
if($status == 'success') {
|
|
$this->delete(array('id'=>$id));
|
|
|
|
$retryParams = @unserialize($data['retry_params']);
|
|
if($retryParams['next_obj_type'] && $this->objTypeProperty[$retryParams['next_obj_type']]['method']) {
|
|
$sdf = array(
|
|
'obj_bn' => $data['obj_bn'],
|
|
'obj_type' => $retryParams['next_obj_type'],
|
|
'retry_params' => 'trigger_request',
|
|
'status' => 'running',
|
|
'last_modify' => time(),
|
|
);
|
|
|
|
$this->db_save($sdf);
|
|
}
|
|
} else {
|
|
$this->updateFail($id, $msg, $msg_id);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 更新Fail
|
|
* @param mixed $id ID
|
|
* @param mixed $errMsg errMsg
|
|
* @param mixed $msgId ID
|
|
* @return mixed 返回值
|
|
*/
|
|
public function updateFail($id, $errMsg, $msgId) {
|
|
$data = $this->getList('fail_times', array('id'=>$id), 0, 1);
|
|
if(empty($data)) {
|
|
return false;
|
|
}
|
|
$upData = array(
|
|
'err_msg' => $errMsg,
|
|
'msg_id' => $msgId,
|
|
'fail_times' => (int) $data[0]['fail_times'] + 1,
|
|
'status' => 'fail',
|
|
'last_modify' => time(),
|
|
);
|
|
return $this->update($upData, array('id'=>$id));
|
|
}
|
|
|
|
# 失败重试
|
|
/**
|
|
* retry
|
|
* @param mixed $log log
|
|
* @return mixed 返回值
|
|
*/
|
|
public function retry($log)
|
|
{
|
|
$property = $this->objTypeProperty[$log['obj_type']];
|
|
|
|
if($property['filter']
|
|
&& $property['filter']['obj_bn']
|
|
&& $property['filter']['app']
|
|
&& $property['filter']['model'])
|
|
{
|
|
$filter = $property['filter'];
|
|
|
|
$objBn = $filter['obj_bn'];
|
|
$appName = $filter['app'];
|
|
$modelName = $filter['model'];
|
|
unset($filter['obj_bn'], $filter['app'], $filter['model']);
|
|
|
|
$filter[$objBn] = $log['obj_bn'];
|
|
$modelObject = app::get($appName)->model($modelName);
|
|
$primaryKey = $modelObject->schema['idColumn'];
|
|
$row = $modelObject->dump($filter, $primaryKey);
|
|
|
|
if(empty($row)) {
|
|
$this->delete(array('id'=>$log['id']));
|
|
return array('rsp'=>'fail');
|
|
}
|
|
|
|
if($log['retry_params'] == 'trigger_request') {
|
|
if($property['method']) {
|
|
list($objectName, $method) = explode(':', $property['method']);
|
|
return kernel::single($objectName)->$method($row[$primaryKey]);
|
|
} else {
|
|
$this->delete(array('id'=>$log['id']));
|
|
return array('rsp'=>'fail');
|
|
}
|
|
}
|
|
}
|
|
// 验证单据状态
|
|
switch ($log['obj_type']) {
|
|
case 'deliveryBack':
|
|
$delivery = app::get('ome')->model('delivery')->dump(array('delivery_bn'=>$log['obj_bn']),'delivery_id,logi_no');
|
|
$shipmentLogModel = app::get('ome')->model('shipment_log');
|
|
if($shipmentLogModel->db_dump(array('deliveryCode'=>$delivery['logi_no'], 'status'=>'succ'), 'log_id')) {
|
|
$this->delete(array('id'=>$log['id']));
|
|
return array('rsp'=>'fail');
|
|
}
|
|
|
|
break;
|
|
case 'logistics_back':
|
|
if (false !== strpos($log['err_msg'], '运单号已使用')) {
|
|
$this->delete(array('id'=>$log['id']));
|
|
return array('rsp'=>'fail');
|
|
}
|
|
break;
|
|
case 'upload_invoice':
|
|
if (false !== strpos($log['err_msg'], '订单无开票记录')) {
|
|
$this->delete(array('id'=>$log['id']));
|
|
return array('rsp'=>'fail');
|
|
}
|
|
break;
|
|
}
|
|
|
|
$retryParams = @unserialize($log['retry_params']);
|
|
|
|
if(empty($retryParams['method']) || empty($retryParams['channel']) || empty($retryParams['channel_id'])) {
|
|
$upData = array(
|
|
'err_msg' => '参数不全，无法重试',
|
|
'fail_times' => 100,
|
|
'status' => 'fail',
|
|
'last_modify' => time(),
|
|
);
|
|
$this->update($upData, array('id'=>$log['id']));
|
|
return array('rsp'=>'fail');
|
|
}
|
|
|
|
$obj = kernel::single('erpapi_router_request')->set($retryParams['channel'], $retryParams['channel_id']);
|
|
|
|
return call_user_func_array(array($obj, $retryParams['method']), $retryParams['args']);
|
|
}
|
|
}
|