aklast/common/helpers/Alarm.php

<?php

namespace common\helpers;


class Alarm
{
    // 预警平台Domain
    private static string $url = 'http://ibs-cn.elken.com:8017';

    // 推送预警信息API
    private static string $reportApi = '/api/report';

    // 业务环境白名单
    private static array $allowPlatform = ['fapi.ekhkad.com', 'bapi.ekhkad.com'];

    public static function reportAlarm($message)
    {
        // 是否开启预警信息推送
        $reportAlarmOpen = Cache::getSystemConfig()['reportAlarmOpen']['VALUE'];
        // 业务平台token
        $message['platform-id'] = \Yii::$app->params['alarmAccessToken'];
        // 日志入库
        Tool::alarmCall($message);

        // 业务环境过滤
        if ($reportAlarmOpen && (count(self::$allowPlatform) == 0 || in_array($_SERVER['HTTP_HOST'], self::$allowPlatform))) {
            $result = self::curl(json_encode($message));
            if ($result['code'] != 200) {
                // 重新推送一次,如果失败,写错误日志
                $result = self::curl(json_encode($message));
                if ($result['code'] != 200) {
                    LoggerTool::error('预警信息上报平台失败. traceId【' . $message['trace-id'] . '】');
                }
            }
        } else {
            if ($reportAlarmOpen == '0') {
                $reason = '上报预警平台状态不允许(reportAlarmOpen=关闭)';
            } else {
                $reason = '主机地址不在白名单中(host=' . $_SERVER['HTTP_HOST'] . ')';
            }
            LoggerTool::error('预警信息上报平台取消. traceId【' . $message['trace-id'] . '】. 原因：' . $reason);
        }
    }

    private static function curl($post_string)
    {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, self::$url . self::$reportApi);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array ('Content-Type: application/json;charset=utf-8'));
        curl_setopt($ch, CURLOPT_POSTFIELDS, $post_string);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        // 线下环境不用开启curl证书验证, 未调通情况可尝试添加该代码
        curl_setopt ($ch, CURLOPT_SSL_VERIFYHOST, 0);
        curl_setopt ($ch, CURLOPT_SSL_VERIFYPEER, 0);
        $response = curl_exec($ch);
        curl_close($ch);

        return json_decode($response, true);
    }
}