Alarm.php 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
  1. <?php
  2. namespace common\helpers;
  3. class Alarm
  4. {
  5. // 预警平台Domain
  6. private static $url = 'http://ibs-cn.elken.com:8017';
  7. // 推送预警信息API
  8. private static $reportApi = '/api/report';
  9. public static function reportAlarm($message)
  10. {
  11. // 业务环境白名单
  12. // $allowPlatform = \Yii::$app->params['allowPlatform'];
  13. // 是否开启预警信息推送
  14. $reportAlarmOpen = Cache::getSystemConfig()['reportAlarmOpen']['VALUE'];
  15. // 业务平台token
  16. $message['platform-id'] = \Yii::$app->params['alarmAccessToken'];
  17. // 日志入库
  18. Tool::alarmCall($message);
  19. // 日志写文件
  20. LoggerTool::error($message);
  21. // 业务环境过滤
  22. if ($reportAlarmOpen /**&& (count($allowPlatform) == 0 || in_array($_SERVER['HTTP_HOST'], $allowPlatform))*/) {
  23. $result = self::curl(json_encode($message));
  24. if ($result['code'] != 200) {
  25. // 重新推送一次,如果失败,写错误日志
  26. $result = self::curl(json_encode($message));
  27. if ($result['code'] != 200) {
  28. LoggerTool::error('预警信息上报平台失败. traceId【' . $message['trace-id'] . '】');
  29. }
  30. }
  31. } else {
  32. $reason = '';
  33. if ($reportAlarmOpen == '0') {
  34. $reason = '上报预警平台状态不允许(reportAlarmOpen=关闭)';
  35. }
  36. // if (!count($allowPlatform)) {
  37. // $reason = '主机地址不在白名单中(host=' . $_SERVER['HTTP_HOST'] . ')';
  38. // }
  39. LoggerTool::error('预警信息上报平台取消. traceId【' . $message['trace-id'] . '】. 原因:' . $reason);
  40. }
  41. }
  42. private static function curl($post_string)
  43. {
  44. $ch = curl_init();
  45. curl_setopt($ch, CURLOPT_URL, self::$url . self::$reportApi);
  46. curl_setopt($ch, CURLOPT_POST, 1);
  47. curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5);
  48. curl_setopt($ch, CURLOPT_HTTPHEADER, array ('Content-Type: application/json;charset=utf-8'));
  49. curl_setopt($ch, CURLOPT_POSTFIELDS, $post_string);
  50. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  51. // 线下环境不用开启curl证书验证, 未调通情况可尝试添加该代码
  52. curl_setopt ($ch, CURLOPT_SSL_VERIFYHOST, 0);
  53. curl_setopt ($ch, CURLOPT_SSL_VERIFYPEER, 0);
  54. $response = curl_exec($ch);
  55. curl_close($ch);
  56. return json_decode($response, true);
  57. }
  58. }