getConf('XCX_WARNING');
//获取需要发送邮件的警告日志
$this->processWarning();
//发送邮件
//$smtp = new SmtpSend();
//$smtp->send($xcx_warn_set['accept_email'],'福利商城小程序关键节点告警信息','这是一份测试邮件，请勿回复');
}
//获取警告信息发送并处理发送结果
protected function processWarning()
{
$where = ' xwb.`send_status` <> 2 and xwb.`create_time`>'.(time()-3600); //1个小时内未发送和发送失败的消息
$que_sql = "SELECT xwb.`id`,xwb.`member_id`,xwb.`mobile`,xwb.`create_time`,xwb.`type`,xwb.`ip`,xwb.`url`,xwb.`param`,xwt.`desc` as type_desc
FROM ims_superdesk_shop_xcx_warning_body xwb
LEFT JOIN ims_superdesk_shop_xcx_warning_type AS xwt ON xwb.`type` = xwt.`id`
WHERE {$where};
";
$queryBuild = new QueryBuilder();
$queryBuild->raw($que_sql);
$res_data = DbManager::getInstance()->query($queryBuild, true, 'default')->toArray();
$formatData = $this->formatMessage($res_data['result']);
//发送邮件同时更新日志状态
$this->send_mail($formatData);
}
/**
* 获取需要发送的日志记录，每10条记录合成一份邮件内容
* @param $warn_msg 未发送的警告记录
* @return Array [content]邮件内容 [warn_id]数组，包含邮件里对应日志记录的ID
*
*/
protected function formatMessage($warn_msg){
$msg_count = (int)(count($warn_msg)/10);
if(count($warn_msg)%10>0){$msg_count++;}
$formatData = Array();
for($i=0;$i<$msg_count;$i++){
$start_index = $i*10;
$end_index = $i*10+9;
$tmp_content = '';
$tmp_warn_id = Array();
for($j=$start_index;$j<=$end_index;$j++){
if(!empty($warn_msg[$j])){
$tmp_content .= "
用户ID：{$warn_msg[$j]['member_id']}
手机号：{$warn_msg[$j]['mobile']}
时间：" . date("Y-m-d H:i:s",$warn_msg[$j]['create_time']) . "
内容：{$warn_msg[$j]['type_desc']}
IP：{$warn_msg[$j]['ip']}
URL：{$warn_msg[$j]['url']}
参数：{$warn_msg[$j]['param']}
";
$tmp_warn_id[] = $warn_msg[$j]['id'];
}
}
$formatData[] = ['content'=>$tmp_content,'warn_id'=>$tmp_warn_id];
}
return $formatData;
}
//发送邮件更新日志状态
protected function send_mail($formatData){
//定时任务的执行逻辑
$xcx_warn_set = Config::getInstance()->getConf('XCX_WARNING');
$smtp = new SmtpSend();
foreach($formatData as $value){
$is_send = $smtp->send($xcx_warn_set['accept_email'],'福利商城小程序关键节点告警信息',$value['content']);
//批量更新状态
$status = $is_send?2:3;
$res = WarningBody::create()->update([
'send_status' => $status
], $value['warn_id']);
}
}
public function onException(\Throwable $throwable)
{
// 捕获 run 方法内所抛出的异常
}
}