1 <?php
  2 //芒果数据库类库
  3 require_once ‘./mongo/vendor/autoload.php‘;
  4 //调试模式
  5 define("DEBUG",true);
  6 //认证
  7 if (isset($_GET[‘echostr‘])) {
  8     $nonce = $_GET[‘nonce‘];
  9     $token = "qosg123";
 10     $timestamp = $_GET[‘timestamp‘];
 11     $echostr = $_GET[‘echostr‘];
 12     $signature = $_GET[‘signature‘];
 13     //形成数组，然后按字典序排序
 14     $array = array();
 15     $array = array($nonce, $timestamp, $token);
 16     sort($array);
 17     //拼接成字符串,sha1加密 ，然后与signature进行校验
 18     $str = sha1(implode($array));
 19     if ($str == $signature && $echostr) {
 20         //第一次接入weixin api接口的时候
 21         echo $echostr;
 22         exit;
 23     }
 24 
 25 } else { //消息自动回复
 26     //接受消息
 27     $obj = file_get_contents(‘php://input‘);
 28     //记录日志
 29     writeLog(json_encode($obj),false);
 30 
 31     if ($obj) { //消息不为空
 32         $postSql = json_decode($obj);
 33 
 34         $content = empty($postSql->Content) ? ‘‘ : $postSql->Content; //内容
 35 
 36         $openid = $postSql->FromUserName; //用户openID
 37         $MsgId = $postSql->MsgId; //消息ID
 38         if ($postSql->MsgType == ‘event‘){  //触发消息 //消息类型
 39             if (!isset($postSql->SessionFrom)) exit();
 40             $info = json_decode($postSql->SessionFrom,true);
 41             $type = $postSql->MsgType;
 42             $data = array(
 43                 "touser" => $openid,
 44                 "msgtype" => "link",
 45                 "link" => array(
 46                     "title" => ‘标题‘,
 47                     "description" => ‘内容描述‘,
 48                     "url" => "https://www.baidu.com",
 49                     "thumb_url" => "https://www.baidu.com/icon.png"
 50                 )
 51             );
 52             $postData = [
 53                 ‘user‘ => $info[‘openid‘],
 54                 ‘qu‘   => $info[‘serverUrl‘],
 55                 ‘time‘ => $postSql->CreateTime,
 56                 ‘data‘ => json_encode($data),
 57             ];
 58             $tb = dns(‘kefu‘);
 59             if (!$tb->insertOne($postData)->isAcknowledged()){
 60                 writeLog(‘存库失败‘);
 61                 $tb->insertOne($postData);
 62             }
 63 
 64             $sendData = array(
 65                 "touser" => $openid,
 66                 "msgtype" => "text",
 67                 "text" => [‘content‘ => ‘回复内容‘],
 68             );
 69             send($sendData);
 70         }
 71         elseif ($postSql->MsgType == ‘text‘){
 72             if (isset($postSql->Content) && $postSql->Content === ‘1‘){
 73                 $tb = dns(‘kefu‘);
 74                 $data = $tb->findOne([‘user‘=>$openid],[‘sort‘=>[‘time‘=>-1]]);
 75                 if (empty($data) || empty($data[‘data‘])) exit();
 76                 send(json_decode($data[‘data‘],true));
 77                 if (!$tb->deleteMany([‘user‘=>$openid]) ) writeLog(‘删除失败‘);
 78             }
 79         }
 80         echo ‘success‘;
 81     } else {
 82         // CLog::writeLog(‘获取token4‘,$token);
 83         echo "123";
 84         exit;
 85     }
 86 
 87 }
 88 
 89 /**
 90  * 日志记录
 91  * @param $ct string 要记录的字符串
 92  * @return null 无
 93  */
 94 function writeLog($ct,$is = true) //是否强行记录
 95 {
 96     if (!DEBUG && !$is) return null;
 97     $myfile = fopen("logs.txt", "a+");
 98     if (!$myfile) return null;
 99     $content = ‘时间：‘ . date("Y-m-d H:i:s") . "\r\n------------------------\r\n";
100     $content .= $ct . "\r\n";
101     $content .= "================================\r\n\r\n";
102     fwrite($myfile, $content);
103     fclose($myfile);
104     return null;
105 }
106 
107 /**
108  * 获取token
109  * @return bool|string 失败|token
110  */
111 function access_token()
112 {
113     $appid = ‘wx0000000000000000‘;
114     $secret = ‘00000000000000000000000000000000‘;
115     $tb = dns(‘token‘);
116     $token = $tb->findOne([‘_id‘ => ‘all‘]);
117     if (empty($token) || $token[‘time‘] < time()) {
118         $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=$appid&secret=$secret"; //获取token地址
119         $data = httpGet($url); //发送请求
120         $t = json_decode($data, true); //解析数据
121         if (empty($t)) {
122             writeLog(‘获取token失败‘ . json_encode($t));
123             return false; //没有数据 返回请求失败
124         }
125         $tb->updateOne([‘_id‘ => ‘all‘], [‘$set‘ => [‘token‘ => $t[‘access_token‘], ‘time‘ => time() + 7000]], [‘upsert‘ => true])->isAcknowledged();
126         return $t[‘access_token‘];
127     }
128     return $token[‘token‘];
129 }
130 
131 //get请求
132 function httpGet($url)
133 {
134     return file_get_contents($url);
135 }
136 
137 //post请求
138 function httpPost($url, $data = [], $head = [], $outtime = 30) //请求地址
139 {
140     $ch = curl_init();
141     curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // 跳过证书检查
142     curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);  // 从证书中检查SSL加密算法是否存在
143     curl_setopt($ch, CURLOPT_URL, $url);  //设置请求地址
144     curl_setopt($ch, CURLOPT_HTTPHEADER, $head); //头信息
145     curl_setopt($ch, CURLOPT_POST, true); //post请求
146     curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data,JSON_UNESCAPED_UNICODE)); //post请求参数
147 //        curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($data)); //post请求参数
148     curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); //
149     curl_setopt($ch, CURLOPT_TIMEOUT, $outtime); //允许 cURL 函数执行的最长秒数
150     return curl_exec($ch);
151 }
152 //发送消息
153 function send($data){
154     $token = access_token();
155     if (!$token){
156         exit(‘错误‘);
157     }
158     $url = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token={$token}";
159     $head = ["Content-type: text/html; charset=utf-8"];
160     $result = httpPost($url, $data, $head);
161     writeLog(json_encode($result));
162     return null;
163 }
164 //连接数据库
165 function dns($tb){
166     //连接数据库
167     $dbs  = new MongoDB\Client("mongodb://127.0.0.1:27017");
168     return $dbs->token->$tb;
169 }