67 lines
1.6 KiB
PHP
67 lines
1.6 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
namespace app\openapi\controller;
|
||
|
|
|
||
|
|
use think\facade\Db;
|
||
|
|
|
||
|
|
class Port extends Core
|
||
|
|
{
|
||
|
|
protected $check = false;
|
||
|
|
|
||
|
|
#检测异常接口预警
|
||
|
|
public function check_notify()
|
||
|
|
{
|
||
|
|
$cur = time();
|
||
|
|
$time = 60*6;
|
||
|
|
$whereRaw = $cur . '-unix_timestamp(create_at) <=' . $time;
|
||
|
|
$data = DB::name('merchant_order')->field("id,merchant_order_id")->whereLike('merchant_callback_msg', 'error')->whereRaw('status = 2 and ' . $whereRaw)->select();
|
||
|
|
|
||
|
|
if($data->isEmpty()){
|
||
|
|
|
||
|
|
|
||
|
|
$this->yes('ok','暂无异常订单');
|
||
|
|
}
|
||
|
|
$errorOrder=[];
|
||
|
|
foreach ($data->toArray() as $vo) {
|
||
|
|
// var_dump($vo);die;
|
||
|
|
$errorOrder[] = $vo['merchant_order_id'];
|
||
|
|
}
|
||
|
|
if($errorOrder){
|
||
|
|
$errorMsg = implode("\n", $errorOrder);
|
||
|
|
$this->no(0 ,$errorMsg);
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
#检测异常订单error过期预警
|
||
|
|
public function check_orderparam()
|
||
|
|
{
|
||
|
|
$cur = time();
|
||
|
|
$time = 60*60*25;
|
||
|
|
$whereRaw = $cur . '-unix_timestamp(create_at) <=' . $time;
|
||
|
|
$data = DB::name('merchant_order')->field("id,merchant_order_id,mid")->whereLike('param', '%error%')->whereRaw( $whereRaw)->select();
|
||
|
|
|
||
|
|
if($data->isEmpty()){
|
||
|
|
|
||
|
|
|
||
|
|
$this->yes('ok','暂无异常订单信息');
|
||
|
|
}
|
||
|
|
$errorOrder=[];
|
||
|
|
foreach ($data->toArray() as $vo) {
|
||
|
|
if(!in_array($vo['mid'],$errorOrder)){
|
||
|
|
$errorOrder[] = $vo['mid'];
|
||
|
|
}
|
||
|
|
// var_dump($vo);die;
|
||
|
|
|
||
|
|
}
|
||
|
|
if($errorOrder){
|
||
|
|
$errorMsg = implode("\n", $errorOrder);
|
||
|
|
$this->no(0 ,$errorMsg);
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
}
|
||
|
|
}
|