tp5.1发送公众号/小程序模板、订阅消息

<?php
// +----------------------------------------------------------------------
// | ThinkPHP 5.1
// +----------------------------------------------------------------------
// | Author: 自然 <c1516k@163.com>
// +----------------------------------------------------------------------
 
// +----------------------------------------------------------------------
// | 微信操作类
// +----------------------------------------------------------------------
 
namespace app\common\controller;
 
class Wechat
{
 
	//公众号参数
	private $appid;
    private $secret;
 
    //初始化
    public function __construct($appid='', $secret='')
    {
        $this->appid = $appid;
        $this->secret = $secret;
    }
 
   	/**
     * 构造获取code的url连接
     * @param string $redirectUrl 微信服务器回跳的url，需要url编码
     * @return 返回构造好的url
     */
    public function getCodeUrl($redirectUrl='')
    {
    	if (!$redirectUrl) return "回调地址为空";	
    	$redirectUrl = urlencode($redirectUrl);
    	$scope = "snsapi_base";	//snsapi_base 无感知授权，snsapi_userinfo 用来获取用户基本信息，需要手动同意
    	$url = "https://open.weixin.qq.com/connect/oauth2/authorize?appid=".$this->appid."&redirect_uri=".$redirectUrl."&response_type=code&scope=".$scope."#wechat_redirect";
    	return $url;
    }
 
    /**
     * 获取微信用户openid
     * @param   [type]         $code [description]
     * @return  string
     */
    public function getOpenid($code)
    {
    	$url = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=".$this->appid."&secret=".$this->secret."&code=".$code."&grant_type=authorization_code";
    	$data = $this->http_request($url);
    	$data = json_decode($data, true);
    	//返回错误信息
    	if (!isset($data['openid'])) return $data['errmsg'];
    	return $data['openid'];
    }
 
    //获取access_token
    public function getAccessToken()
    {
    	$access_token = cache('wxAccessToken');
    	if (empty($access_token))
    	{
    		$url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=".$this->appid."&secret=".$this->secret;
	    	$json_token = $this->http_request($url);
			$data = json_decode($json_token, true);
			//存入缓存 expires_in 时效
			cache('wxAccessToken', $data['access_token'], $data['expires_in']);
			$access_token = $data['access_token'];
    	}
		return $access_token;
    }
 
    /**
     * 发送模板消息
     * 参考文档 https://developers.weixin.qq.com/doc/offiaccount/Message_Management/Template_Message_Interface.html
     * @param   int         $type        消息模板类型 1:模板消息 2:订阅消息
     * @param   string         $openid      
     * @param   integer        $template_id 模板ID
     * @param   string         $url         消息模板跳转url，可不填
     * @param   string         $color       主题字体颜色
     * @param   array          $data        模板数据
     * @return  string
     */
    public function sendTempMsg($type = 1, $openid, $template_id='', $url='', $color='', array $data)
    {
    	$access_token = $this->getAccessToken();
	    //模板消息
	    $template_data = $this->_sendTempMsg($openid, $template_id, $url, $color, $data);
	    //模板消息类型
	    $type = ($type == 1) ? 'send' : 'subscribe';
	    
	     $url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/{$type}?access_token={$access_token}";//小程序
	   // $url = "https://api.weixin.qq.com/cgi-bin/message/template/{$type}?access_token={$access_token}";//公众号
	    $res = $this->http_request($url, $template_data);
	    print_r($res);
        $res = json_decode($res, true);
	    if ($res['errcode']==0) {
	        return '发送成功';
	    }
	    else {
            //失败返回错误信息
	        return $res;
	    }
	}
 
	private function _sendTempMsg($openid, $template_id, $url, $color, $data)
	{
        //模板消息
        $template_data = [
            'touser'=> $openid, //用户openid
            'template_id'=>$template_id, //在公众号下配置的模板id
            'url'=>$url, //点击模板消息会跳转的链接
            'color'=>$color,//消息字体颜色，不填默认为黑色
            'data'=>$data,
        ];
        $template_data = json_encode($template_data);
        
        return $template_data;
    }
 
	//请求
    private function http_request($url, $data = null)
    {
		$curl = curl_init();
		curl_setopt($curl, CURLOPT_URL, $url);
		curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
		curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);
		if (!empty($data)){
			curl_setopt($curl, CURLOPT_POST, 1);
			curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
		}
		curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
		$output = curl_exec($curl);
		curl_close($curl);
		return $output;
	}
}