mirror of
https://gitee.com/ShopeX/OMS
synced 2026-03-22 18:35:35 +08:00
227 lines
8.6 KiB
PHP
227 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.
|
||
*/
|
||
|
||
/**
|
||
* @Author: xueding@shopex.cn
|
||
* @Vsersion: 2022/10/13
|
||
* @Describe: 预警通知Lib类
|
||
*/
|
||
class monitor_event_notify
|
||
{
|
||
/**
|
||
* 添加预警通知
|
||
* @Author: xueding
|
||
* @Vsersion: 2022/10/17 下午4:06
|
||
* @param $eventType
|
||
* @param array $params
|
||
* @param string $send_type
|
||
* @param string $is_sync
|
||
* @return bool
|
||
*/
|
||
public function addNotify($eventType, $params = array(), $is_sync = false)
|
||
{
|
||
$eventTemplateMdl = app::get('monitor')->model('event_template');
|
||
$eventNotifyMdl = app::get('monitor')->model('event_notify');
|
||
$templateList = $eventTemplateMdl->getList('*',[
|
||
'event_type' => $eventType,
|
||
'status' => '1',
|
||
'disabled' => 'false',
|
||
]);
|
||
if ($templateList) {
|
||
foreach ($templateList as $key => $templateInfo) {
|
||
$notifyData = array();
|
||
//插入数据
|
||
$notifyData['template_id'] = $templateInfo['template_id'];
|
||
$notifyData['event_type'] = $eventType;
|
||
$notifyData['original_content'] = $templateInfo['content'];
|
||
$notifyData['send_content'] = '**域名:'.kernel::base_url(1)."**\n".$this->getNotifyParams($templateInfo, $params);
|
||
$notifyData['send_type'] = $templateInfo['send_type'];
|
||
$notifyData['params'] = json_encode($params);
|
||
$notifyData['file_path'] = json_encode($params['file_path'],JSON_UNESCAPED_SLASHES);
|
||
$notifyData['org_id'] = $params['org_id'];
|
||
if(kernel::database()->isInTransaction() && !$is_sync) {
|
||
register_shutdown_function(function() use($notifyData) {
|
||
$eventNotifyMdl = app::get('monitor')->model('event_notify');
|
||
$eventNotifyMdl->insert($notifyData);
|
||
}, $notifyData);
|
||
$result = false;
|
||
} else {
|
||
$result = $eventNotifyMdl->insert($notifyData);
|
||
}
|
||
//保存发送内容
|
||
if (!$result) {
|
||
continue;
|
||
}
|
||
// $push_params = array(
|
||
// 'data' => [
|
||
// 'task_type' => 'sendnotify',
|
||
// 'notify_id' => $result,
|
||
// ],
|
||
// 'url' => kernel::openapi_url('openapi.autotask','service')
|
||
// );
|
||
//
|
||
// kernel::single('taskmgr_interface_connecter')->push($push_params);
|
||
//同步发送
|
||
if ($is_sync) {
|
||
//调用发送方法
|
||
$this->sendNotify($result);
|
||
}
|
||
}
|
||
return true;
|
||
} else {
|
||
return true;
|
||
}
|
||
}
|
||
|
||
public function sendNotify($notifyId, $notifyInfo = array())
|
||
{
|
||
if (!$notifyId) {
|
||
return false;
|
||
}
|
||
$eventNotifyMdl = app::get('monitor')->model('event_notify');
|
||
//通知内容
|
||
if (!$notifyInfo) {
|
||
$notifyInfo = $eventNotifyMdl->db_dump($notifyId);
|
||
}
|
||
|
||
if (!$notifyInfo) {
|
||
return false;
|
||
}
|
||
|
||
if ($notifyInfo['status'] == '1' || $notifyInfo['status'] == '3' ) {
|
||
return ['rsp' =>'fail','msg'=> '已发送不能重复发送'];
|
||
}
|
||
//关闭模板不发送内容
|
||
$eventTemplateMdl = app::get('monitor')->model('event_template');
|
||
$eventTemplateInfo = $eventTemplateMdl->db_dump(['template_id'=>$notifyInfo['template_id']]);
|
||
if ($eventTemplateInfo['disabled'] == 'true') {
|
||
$msg = '模板已关闭取消发送';
|
||
$eventNotifyMdl->update(['status' => '2','send_result'=>$msg], ['notify_id' => $notifyInfo['notify_id']]);
|
||
return ['rsp' =>'fail','msg'=> $msg,'notify_id'=>$notifyInfo['notify_id']];
|
||
}
|
||
$notifyInfo['template_name'] = $eventTemplateInfo['template_name'];
|
||
// 更新为处理中
|
||
$eventNotifyMdl->update(['status' => '3'], ['notify_id' => $notifyId]);
|
||
|
||
$res = kernel::single('monitor_event_trigger_notify_router')
|
||
->set_send_type($notifyInfo['send_type'])
|
||
->send($notifyInfo);
|
||
|
||
//更新发送状态
|
||
if ($res && $res['rsp'] == 'succ') {
|
||
$status = '1';
|
||
} else {
|
||
$status = '2';
|
||
}
|
||
$eventNotifyMdl->update(['status' => $status,'send_result'=>$res['msg']], ['notify_id' => $notifyInfo['notify_id']]);
|
||
|
||
$res['notify_id'] = $notifyInfo['notify_id'];
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 转换发送内容
|
||
* @Author: xueding
|
||
* @Vsersion: 2022/10/17 下午3:58
|
||
* @param $templateInfo
|
||
* @param $params
|
||
* @return string|string[]
|
||
*/
|
||
public function getNotifyParams($templateInfo, $params)
|
||
{
|
||
/**
|
||
* 示例
|
||
* $params = ['order_bn'=>['1234','567'],'list'=>[['aaa'='111','bbb'=>'222'],['aaa'='333','bbb'=>'444']],'file_path'=>['export/tmp_local/111.txt','export/tmp_local/readme.txt']];
|
||
* $templateInfo['content']： 订单有问题订单号为：{order_bn} <{ 循环内容1{aaa},循环内容2{bbb}}>
|
||
*/
|
||
if ($params) {
|
||
$find = array();
|
||
$replace = array();
|
||
if ($params['list']) {
|
||
$sendContent = $templateInfo['content'];
|
||
//开始结尾数据
|
||
$tmpData = [];
|
||
$matches = [];
|
||
preg_match_all('|<{(.*)}>|',$sendContent,$matches,PREG_PATTERN_ORDER);
|
||
$startEndStr = explode($matches[0][0],$sendContent);
|
||
//中间循环数据
|
||
$oldForStr = $matches[0][0];
|
||
$oldReplaceForStr = $matches[1][0];
|
||
|
||
$list = $params['list'];
|
||
unset($params['list']);
|
||
//开始结尾内容替换
|
||
foreach ($params as $key => $val) {
|
||
$startFind[] = '{'.$key.'}';
|
||
if (is_array($val)) {
|
||
$val = implode(',', $val);
|
||
}
|
||
$replace[] = $val;
|
||
}
|
||
foreach ($startEndStr as $val) {
|
||
$tmpData[$val] = str_replace($startFind, $replace, $val);
|
||
}
|
||
//中间循环内容替换
|
||
foreach ($list as $lk => $lv) {
|
||
$replace = array();
|
||
foreach ($lv as $key => $val) {
|
||
$bodyFind[] = '{'.$key.'}';
|
||
if (is_array($val)) {
|
||
$val = implode(',', $val);
|
||
}
|
||
$replace[] = $val;
|
||
}
|
||
$tmpData[$oldForStr] .= str_replace($bodyFind, $replace, $oldReplaceForStr). "<br>";
|
||
}
|
||
//组装发送内容
|
||
if ($tmpData) {
|
||
foreach ($tmpData as $key => $val) {
|
||
$sendContent = str_replace($key,$val,$sendContent);
|
||
}
|
||
}
|
||
return $sendContent;
|
||
}else{
|
||
foreach ($params as $key => $val) {
|
||
$find[] = '{'.$key.'}';
|
||
if (is_array($val)) {
|
||
$val = implode(',', $val);
|
||
}
|
||
$replace[] = $val;
|
||
}
|
||
$content = str_replace($find, $replace, $templateInfo['content']);
|
||
return $content;
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 自动清除同步日志
|
||
* 每天检测将超过30天的发送数据清除
|
||
*/
|
||
public function clean($clean_time = 30){
|
||
|
||
$time = time();
|
||
|
||
$where = " WHERE `at_time`<'".date('Y-m-d',$time-$clean_time*24*60*60).' 00:00:00'."' ";
|
||
|
||
$del_sql = " DELETE FROM `sdb_monitor_event_notify` $where ";
|
||
|
||
kernel::database()->exec($del_sql);
|
||
|
||
return true;
|
||
}
|
||
} |