<?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);
        }


    }
}