微信消息自动回复 json版

<?php
//芒果数据库类库
require_once './mongo/vendor/autoload.php';
//调试模式
define("DEBUG",true);
//认证
if (isset($_GET['echostr'])) {
    $nonce = $_GET['nonce'];
    $token = "qosg123";
    $timestamp = $_GET['timestamp'];
    $echostr = $_GET['echostr'];
    $signature = $_GET['signature'];
    //形成数组，然后按字典序排序
    $array = array();
    $array = array($nonce, $timestamp, $token);
    sort($array);
    //拼接成字符串,sha1加密 ，然后与signature进行校验
    $str = sha1(implode($array));
    if ($str == $signature && $echostr) {
        //第一次接入weixin api接口的时候
        echo $echostr;
        exit;
    }

} else { //消息自动回复
    //接受消息
    $obj = file_get_contents('php://input');
    //记录日志
    writeLog(json_encode($obj),false);

    if ($obj) { //消息不为空
        $postSql = json_decode($obj);

        $content = empty($postSql->Content) ? '' : $postSql->Content; //内容

        $openid = $postSql->FromUserName; //用户openID
        $MsgId = $postSql->MsgId; //消息ID
        if ($postSql->MsgType == 'event'){  //触发消息 //消息类型
            if (!isset($postSql->SessionFrom)) exit();
            $info = json_decode($postSql->SessionFrom,true);
            $type = $postSql->MsgType;
            $data = array(
                "touser" => $openid,
                "msgtype" => "link",
                "link" => array(
                    "title" => '标题',
                    "description" => '内容描述',
                    "url" => "https://www.baidu.com",
                    "thumb_url" => "https://www.baidu.com/icon.png"
                )
            );
            $postData = [
                'user' => $info['openid'],
                'qu'   => $info['serverUrl'],
                'time' => $postSql->CreateTime,
                'data' => json_encode($data),
            ];
            $tb = dns('kefu');
            if (!$tb->insertOne($postData)->isAcknowledged()){
                writeLog('存库失败');
                $tb->insertOne($postData);
            }

            $sendData = array(
                "touser" => $openid,
                "msgtype" => "text",
                "text" => ['content' => '回复内容'],
            );
            send($sendData);
        }
        elseif ($postSql->MsgType == 'text'){
            if (isset($postSql->Content) && $postSql->Content === '1'){
                $tb = dns('kefu');
                $data = $tb->findOne(['user'=>$openid],['sort'=>['time'=>-1]]);
                if (empty($data) || empty($data['data'])) exit();
                send(json_decode($data['data'],true));
                if (!$tb->deleteMany(['user'=>$openid]) ) writeLog('删除失败');
            }
        }
        echo 'success';
    } else {
        // CLog::writeLog('获取token4',$token);
        echo "123";
        exit;
    }

}

/**
 * 日志记录
 * @param $ct string 要记录的字符串
 * @return null 无
 */
function writeLog($ct,$is = true) //是否强行记录
{
    if (!DEBUG && !$is) return null;
    $myfile = fopen("logs.txt", "a+");
    if (!$myfile) return null;
    $content = '时间：' . date("Y-m-d H:i:s") . "
------------------------
";
    $content .= $ct . "
";
    $content .= "================================

";
    fwrite($myfile, $content);
    fclose($myfile);
    return null;
}

/**
 * 获取token
 * @return bool|string 失败|token
 */
function access_token()
{
    $appid = 'wx0000000000000000';
    $secret = '00000000000000000000000000000000';
    $tb = dns('token');
    $token = $tb->findOne(['_id' => 'all']);
    if (empty($token) || $token['time'] < time()) {
        $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=$appid&secret=$secret"; //获取token地址
        $data = httpGet($url); //发送请求
        $t = json_decode($data, true); //解析数据
        if (empty($t)) {
            writeLog('获取token失败' . json_encode($t));
            return false; //没有数据 返回请求失败
        }
        $tb->updateOne(['_id' => 'all'], ['$set' => ['token' => $t['access_token'], 'time' => time() + 7000]], ['upsert' => true])->isAcknowledged();
        return $t['access_token'];
    }
    return $token['token'];
}

//get请求
function httpGet($url)
{
    return file_get_contents($url);
}

//post请求
function httpPost($url, $data = [], $head = [], $outtime = 30) //请求地址
{
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // 跳过证书检查
    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);  // 从证书中检查SSL加密算法是否存在
    curl_setopt($ch, CURLOPT_URL, $url);  //设置请求地址
    curl_setopt($ch, CURLOPT_HTTPHEADER, $head); //头信息
    curl_setopt($ch, CURLOPT_POST, true); //post请求
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data,JSON_UNESCAPED_UNICODE)); //post请求参数
//        curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($data)); //post请求参数
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); //
    curl_setopt($ch, CURLOPT_TIMEOUT, $outtime); //允许 cURL 函数执行的最长秒数
    return curl_exec($ch);
}
//发送消息
function send($data){
    $token = access_token();
    if (!$token){
        exit('错误');
    }
    $url = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token={$token}";
    $head = ["Content-type: text/html; charset=utf-8"];
    $result = httpPost($url, $data, $head);
    writeLog(json_encode($result));
    return null;
}
//连接数据库
function dns($tb){
    //连接数据库
    $dbs  = new MongoDBClient("mongodb://127.0.0.1:27017");
    return $dbs->token->$tb;
}

 参考地址：https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140453