DingMsg II

2019-08-27 加分技能阅读量

完整版, DingMsg使用记录

DingRobot

App\Support\DingRobot

<?php

namespace App\Support;

use Illuminate\Support\Facades\Log;

class DingRobot
{
    const DING_URL = 'https://oapi.dingtalk.com/robot/send?access_token=5187cd15497ab1f440cb92c49eaf29e6477ec8786251ab00133d8a89b0ee7450';

    public static function textMessage(string $url, string $msg)
    {
        try {
            $curl = new Curl();
            $curl->post_json($url, [
                'msgtype' => 'text',
                'text'    => [
                    'content' => $msg,
                ],
            ]);
        } catch (\Error $e) {
            Log::error($e->getMessage());
        }
    }
}

Curl

App\Support\Curl

<?php

namespace App\Support;

use App\Concerns\Singleton;

/**
 * Class Curl
 * @package App\Support
 */
class Curl
{
    use Singleton;

    const CONTENT_TYPE = 'Content-Type';

    // 用于读取和写入请求的cookie文件
    public $cookie_file;

    // 确定请求是否遵循重定向
    public $follow_redirects = true;

    // 请求头
    public $headers = array();

    // 请求选项
    public $options = array();

    // referer 头
    public $referer;

    public $user_agent;

    protected $error = '';

    // CURL 请求资源句柄
    protected $ch;

    /**
     * 初始化Curl对象
     * Curl constructor.
     * @param array|null $args ['headers' => [...], 'options' => [...] ]
     */
    public function __construct(array $args = null)
    {
        if (!empty($args)) {
            $this->headers = $args['headers'] ?? array();
            $this->options = $args['options'] ?? array();
        }

        $this->cookie_file = dirname(__FILE__) . DIRECTORY_SEPARATOR . 'curl_cookie.txt';

        $this->user_agent  = isset($_SERVER['HTTP_USER_AGENT'])
            ? $_SERVER['HTTP_USER_AGENT']
            : 'Curl/client';
    }

    /**
     * Curl HEAD
     *
     * @param $url
     * @param array $vars
     * @return mixed
     */
    public function head($url, $vars = array())
    {
        return $this->request('HEAD', $url, $vars);
    }

    /**
     * Curl GET
     *
     * @param $url
     * @param array $vars
     * @return mixed
     */
    public function get($url, $vars = array())
    {
        if (!empty($vars)) {
            $url .= (stripos($url, '?') !== false) ? '&' : '?';
            $url .= (is_string($vars)) ? $vars : http_build_query($vars, '', '&');
        }

        return $this->request('GET', $url);
    }

    /**
     * Curl POST
     *
     * @param $url
     * @param array $vars
     * @return mixed
     */
    public function post($url, $vars = array())
    {
        return $this->request('POST', $url, $vars);
    }

    /**
     * Curl PUT
     *
     * @param $url
     * @param array $vars
     * @return mixed
     */
    public function put($url, $vars = array())
    {
        return $this->request('PUT', $url, $vars);
    }

    /**
     * Curl DELETE
     *
     * @param $url
     * @param array $vars
     * @return mixed
     */
    public function delete($url, $vars = array())
    {
        return $this->request('DELETE', $url, $vars);
    }

    /**
     * 返回错误
     * @return string
     */
    public function error()
    {
        return $this->error;
    }

    /**
     * 将Post数据转成JSON
     *
     * @param $url
     * @param array $data
     * @return mixed
     */
    public function post_json($url, $data = array())
    {
        $this->headers[static::CONTENT_TYPE] = 'application/json;charset=utf-8';
        $vars = empty($data) ? null : json_encode($data);

        return $this->request('POST', $url, $vars);
    }

    /**
     * 将Put数据转成JSON
     * @param $url
     * @param array $data
     * @return mixed
     */
    public function put_json($url, $data = array())
    {
        $this->headers[static::CONTENT_TYPE] = 'application/json;charset=utf-8';
        $vars = empty($data) ? null : json_encode($data);

        return $this->request('PUT', $url, $vars);
    }

    /**
     * CURL 请求
     * @param $method
     * @param $url
     * @param array $vars
     * @return CurlResponse|mixed
     */
    public function request($method, $url, $vars = array())
    {
        $this->error = '';
        $this->ch    = curl_init();

        if (is_array($vars)) $vars = http_build_query($vars, '', '&');

        $this->set_request_headers();
        $this->set_request_method($method);
        $this->set_request_options($url, $vars);

        $response = curl_exec($this->ch);

        if ($response) {
            $response = new CurlResponse($response);
        } else {
            $this->error = curl_errno($this->ch) . '-' . curl_error($this->ch);
        }

        curl_close($this->ch);

        return $response;
    }

    /**
     * 设置CURL请求头
     */
    protected function set_request_headers()
    {
        $headers = array();
        foreach ($this->headers as $key => $value) {
            $headers[] = $key . ': ' . $value;
        }
        curl_setopt($this->ch, CURLOPT_HTTPHEADER, $headers);
    }

    /**
     * 为请求方法设置关联的CURL选项
     * @param $method
     */
    protected function set_request_method($method)
    {
        switch (strtoupper($method)) {
            case 'HEAD':
                curl_setopt($this->ch, CURLOPT_NOBODY, true);
                break;
            case 'GET':
                curl_setopt($this->ch, CURLOPT_HTTPGET, true);
                break;
            case 'POST':
                curl_setopt($this->ch, CURLOPT_POST, true);
                break;
            default:
                curl_setopt($this->ch, CURLOPT_CUSTOMREQUEST, $method);
        }
    }

    /**
     * 设置CURL选项
     * @param $url
     * @param $vars
     */
    protected function set_request_options($url, $vars)
    {
        curl_setopt($this->ch, CURLOPT_URL, $url);
        if (!empty($vars)) curl_setopt($this->ch, CURLOPT_POSTFIELDS, $vars);

        // 设置一些默认CURL选项
        curl_setopt($this->ch, CURLOPT_HEADER, true);
        curl_setopt($this->ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($this->ch, CURLOPT_USERAGENT, $this->user_agent);

        if ($this->cookie_file) {
            curl_setopt($this->ch, CURLOPT_COOKIEFILE, $this->cookie_file);
            curl_setopt($this->ch, CURLOPT_COOKIEJAR, $this->cookie_file);
        }

        if ($this->follow_redirects) curl_setopt($this->ch, CURLOPT_FOLLOWLOCATION, true);

        if ($this->referer) curl_setopt($this->ch, CURLOPT_REFERER, $this->referer);

        // 设置任何自定义CURL选项
        foreach ($this->options as $option => $value) {
            curl_setopt($this->ch, constant('CURLOPT_' . str_replace('CURLOPT_', '', strtoupper($option))), $value);
        }
    }
}

Singleton

App\Concerns\Singleton

<?php

namespace App\Concerns;

trait Singleton
{
    public static function getInstance()
    {
        static $instance = null;

        if (is_null($instance)) {
            $instance = new static();
        }

        return $instance;
    }
}

使用

1	DingRobot::textMessage(DingRobot::DING_URL, $msg);

/**
 * add support of ding message on ERROR detected in logging.
 *
 * @param Logger $logger
 */
public static function addDingHandler($logger)
{
    $handler = new class extends AbstractProcessingHandler {
        public function write(array $record)
        {
            if (config('logging.alert_ding', false) && $record['level'] >= 400){
                $msg = $record['channel'] . '.'. $record['level_name'] . ' ' . $record['message'];
                DingRobot::textMessage(DingRobot::DING_URL, $msg);
            }
        }
    };
    $logger->pushHandler($handler);
}