course-tencent-cloud/app/Services/DingTalkNotice.php

<?php

namespace App\Services;

use App\Repos\Account as AccountRepo;
use App\Repos\Course as CourseRepo;
use GuzzleHttp\Client as HttpClient;
use Phalcon\Logger\Adapter\File as FileLogger;

class DingTalkNotice extends Service
{

    /**
     * @var array
     */
    protected $settings;

    /**
     * @var FileLogger
     */
    protected $logger;

    public function __construct()
    {
        $this->settings = $this->getSettings('dingtalk.robot');

        $this->logger = $this->getLogger('dingtalk');
    }

    /**
     * 测试消息
     *
     * @return bool
     */
    public function test()
    {
        $params = [
            'msgtype' => 'text',
            'text' => ['content' => '我是一条测试消息啦！'],
        ];

        return $this->send($params);
    }

    /**
     * 给技术人员发消息
     *
     * @param string $content
     * @return bool
     */
    public function atTechSupport($content)
    {
        $atMobiles = $this->parseAtMobiles($this->settings['ts_mobiles']);
        $atContent = $this->buildAtContent($content, $atMobiles);

        $params = [
            'msgtype' => 'text',
            'text' => ['content' => $atContent],
            'at' => ['atMobiles' => $atMobiles],
        ];

        return $this->send($params);
    }

    /**
     * 给客服人员发消息
     *
     * @param string $content
     * @return bool
     */
    public function atCustomService($content)
    {
        $atMobiles = $this->parseAtMobiles($this->settings['cs_mobiles']);
        $atContent = $this->buildAtContent($content, $atMobiles);

        $params = [
            'msgtype' => 'text',
            'text' => ['content' => $atContent],
            'at' => ['atMobiles' => $atMobiles],
        ];

        return $this->send($params);
    }

    /**
     * 给课程讲师发消息
     *
     * @param int $courseId
     * @param string $content
     * @return bool
     */
    public function atCourseTeacher($courseId, $content)
    {
        $courseRepo = new CourseRepo();

        $course = $courseRepo->findById($courseId);

        $accountRepo = new AccountRepo();

        $account = $accountRepo->findById($course->teacher_id);

        if (empty($account->phone)) {
            return false;
        }

        $atMobiles = $account->phone;

        $atContent = $this->buildAtContent($content, $atMobiles);

        $params = [
            'msgtype' => 'text',
            'text' => ['content' => $atContent],
            'at' => ['atMobiles' => $atMobiles],
        ];

        return $this->send($params);
    }

    /**
     * 发送消息
     *
     * @param array $params
     * @return bool
     */
    public function send($params)
    {
        if (isset($params['msgtype'])) {
            $params['msgtype'] = 'text';
        }

        $webHook = "https://oapi.dingtalk.com/robot/send?access_token=%s&timestamp=%s&sign=%s";

        $appSecret = $this->settings['app_secret'];
        $appToken = $this->settings['app_token'];

        $timestamp = time() * 1000;
        $data = sprintf("%s\n%s", $timestamp, $appSecret);
        $sign = urlencode(base64_encode(hash_hmac('sha256', $data, $appSecret, true)));
        $postUrl = sprintf($webHook, $appToken, $timestamp, $sign);

        try {

            $client = new HttpClient();

            $response = $client->post($postUrl, ['json' => $params]);

            $content = $response->getBody()->getContents();

            $content = json_decode($content, true);

            $this->logger->debug('Send Message Request ' . kg_json_encode($params));

            $this->logger->debug('Send Message Response ' . kg_json_encode($content));

            $result = $content['errcode'] == 0;

            if ($result == false) {
                $this->logger->error('Send Message Failed ' . kg_json_encode($content));
            }

        } catch (\Exception $e) {

            $this->logger->error('Send Message Exception ' . kg_json_encode([
                    'file' => $e->getFile(),
                    'line' => $e->getLine(),
                    'message' => $e->getMessage(),
                ]));

            $result = false;
        }

        return $result;
    }

    /**
     * @param string $mobiles
     * @return array
     */
    protected function parseAtMobiles($mobiles)
    {
        if (empty($mobiles)) {
            return [];
        }

        $mobiles = explode(',', $mobiles);

        return array_map(function ($mobile) {
            return trim($mobile);
        }, $mobiles);
    }

    /**
     * @param string $content
     * @param array $mobiles
     * @return string
     */
    protected function buildAtContent($content, $mobiles = [])
    {
        if (count($mobiles) == 0) {
            return $content;
        }

        $result = '';

        foreach ($mobiles as $mobile) {
            $result .= sprintf('@%s ', $mobile);
        }

        $result .= $content;

        return $result;
    }

}