nizongfeng
/
ZZWX
1
0
Fork 0
Código Incidencias 0 Pull Requests 0 Lanzamientos 0 Wiki Actividad
No puede seleccionar más de 25 temas Los temas deben comenzar con una letra o número, pueden incluir guiones ('-') y pueden tener hasta 35 caracteres de largo.
2 Commits
1 Rama
38 MiB
 
 
 
 
 
 
Rama: master
Ramas Etiquetas
${ item.name }
Crear rama ${ searchTerm }
desde 'master'
${ noResults }
ZZWX/wechat/Common/WeChat.class.php

886 líneas
40 KiB
Original Enlace permanente Blame Histórico 

  1. <?php

  2. 

  3. class WeChat

  4. {

  5.     private $_appid;

  6.     private $_appsecret;

  7.     private $_accessToken;

  8.     public $debug = DEBUG;

  9.     public $MsgType = 'text';

  10.     public $msg = array();

  11. 

  12.     /* //QRCode类型

  13.     const QRCODE_TYPE_TEMP=1;

  14.     const QRCODE_TYPE_LIMIT=2;

  15.     const QRCODE_TYPE_LIMIT_STR=3; */

  16.     public function __construct($appid, $appsecret)

  17.     {

  18. 

  19.         $this->_appid = $appid;

  20.         $this->_appsecret = $appsecret;

  21.         if (isset($_GET['echostr'])) {

  22.             $this->valid();

  23.         }

  24.         if (ALWAYSCHECK == true) {

  25.             $check = $this->checkSignature();

  26.             if (!$check) {

  27.                 $this->writelog("checkSignature()--非法服务器");

  28.                 exit;

  29.             }

  30.         }

  31.         $this->_accessToken = $this->getAccessToken();

  32.     }

  33. 

  34.     public function getAccessToken()

  35.     {

  36. 

  37.         // access_token 应该全局存储与更新，以下代码以写入到文件中做示例

  38.         $data = json_decode($this->get_php_file("access_token.php"));

  39.         if ($data->expire_time < time()) {

  40.             // 如果是企业号用以下URL获取access_token

  41.             // $url = "https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=$this->appId&corpsecret=$this->appSecret";

  42.             $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$this->_appid}&secret={$this->_appsecret}";

  43.             $res = json_decode($this->_requestGet($url));

  44.             $access_token = $res->access_token;

  45.             $this->writelog("url获取的token:" . $access_token);

  46.             if ($access_token) {

  47.                 $data->expire_time = time() + 3600;

  48.                 $data->access_token = $access_token;

  49.                 $this->set_php_file("access_token.php", json_encode($data));

  50.                 $this->writelog("生成access_token:" . $access_token);

  51.             }

  52.         } else {

  53.             $access_token = $data->access_token;

  54.             $this->writelog("文件中读取的token:" . $access_token);

  55.         }

  56.         return $access_token;

  57.     }

  58. 

  59.     private function get_php_file($filename)

  60.     {

  61.         $dir = __DIR__ . "/../Log/";

  62.         if (!is_dir($dir)) {

  63.             mkdir($dir);

  64.         }

  65.         $token_file = $dir . $filename;

  66.         return trim(substr(file_get_contents($token_file), 15));

  67.     }

  68. 

  69.     private function set_php_file($filename, $content)

  70.     {

  71.         $dir = __DIR__ . "/../Log/";

  72.         if (!is_dir($dir)) {

  73.             mkdir($dir);

  74.         }

  75.         $token_file = $dir . $filename;

  76.         $fp = fopen($token_file, "w");

  77.         fwrite($fp, "<?php exit();?>" . $content);

  78.         fclose($fp);

  79.     }

  80. 

  81.     private function _requestGet($url, $ssl = true)

  82.     {

  83.         $curl = curl_init();

  84.         curl_setopt($curl, CURLOPT_URL, $url);

  85.         /* $user_agent=isset($_SERVER['HTTP_USER_AGENT'])?$_SERVER['HTTP_USER_AGENT']:'';

  86.         curl_setopt($curl, CURLOPT_USERAGENT, $user_agent); */

  87.         curl_setopt($curl, CURLOPT_AUTOREFERER, true);

  88.         if ($ssl) {

  89.             curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);

  90.             curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 2);

  91.         }

  92.         curl_setopt($curl, CURLOPT_HEADER, false);

  93.         curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);

  94.         $response = curl_exec($curl);

  95.         if ($response === false) {

  96.             $this->writelog('_requestGet()--返回值错误');

  97.             return false;

  98.         }

  99.         return $response;

  100.     }

  101. 

  102.     private function _requestPost($url, $data, $ssl = true)

  103.     {

  104.         $curl = curl_init();

  105.         curl_setopt($curl, CURLOPT_URL, $url);

  106.         $user_agent = isset($_SERVER['HTTP_USER_AGENT']) ? $_SERVER['HTTP_USER_AGENT'] : '';

  107.         curl_setopt($curl, CURLOPT_USERAGENT, $user_agent);

  108.         curl_setopt($curl, CURLOPT_AUTOREFERER, true);

  109.         if ($ssl) {

  110.             curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);

  111.             curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 1);

  112.         }

  113.         curl_setopt($curl, CURLOPT_POST, true);

  114.         curl_setopt($curl, CURLOPT_POSTFIELDS, $data);

  115.         curl_setopt($curl, CURLOPT_HEADER, false);

  116.         curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);

  117.         $response = curl_exec($curl);

  118.         if ($response === false) {

  119.             $this->writelog('_requestPost()--返回值错误');

  120.             return false;

  121.         }

  122.         //$error=json_decode($response,true);

  123.         $this->writelog("url:" . $url);

  124.         $this->writelog("curl返回值为" . $response);

  125. 

  126.         return $response;

  127.     }

  128. 

  129.     public function valid()

  130.     {

  131.         $echoStr = $_GET["echostr"];

  132.         //valid signature , option

  133.         if ($this->checkSignature()) {

  134.             $this->writelog("valid()--第一次验证成功");

  135.             echo $echoStr;

  136.             exit;

  137.         } else {

  138.             $this->writelog("valid()--第一次验证，非法服务器");

  139.             exit();

  140.         }

  141.     }

  142. 

  143.     private function checkSignature()

  144.     {

  145.         // you must define TOKEN by yourself

  146.         if (!defined("TOKEN")) {

  147.             throw new Exception('TOKEN is not defined!');

  148.         }

  149. 

  150.         $signature = isset($_GET["signature"]) ? $_GET["signature"] : "";

  151.         $timestamp = isset($_GET["timestamp"]) ? $_GET["timestamp"] : "";

  152.         $nonce = isset($_GET["nonce"]) ? $_GET["nonce"] : "";

  153. 

  154.         $token = TOKEN;

  155.         $tmpArr = array($token, $timestamp, $nonce);

  156.         // use SORT_STRING rule

  157.         sort($tmpArr, SORT_STRING);

  158.         $tmpStr = implode($tmpArr);

  159.         $tmpStr = sha1($tmpStr);

  160. 

  161.         if ($tmpStr == $signature) {

  162.             return true;

  163.         } else {

  164.             return false;

  165.         }

  166.     }

  167. 

  168.     private function writelog($activation)

  169.     {

  170.         $dir = "./Log";

  171.         if (!is_dir($dir)) {

  172.             mkdir($dir);

  173.         }

  174.         $filename = date("Y-m-d") . ".txt";

  175.         $open = fopen($dir . "/" . $filename, "a");

  176.         fwrite($open, date("Y-m-d H:i:s") . "\t" . $activation . "\r\n");

  177.         fclose($open);

  178.     }

  179. 

  180.     //获取消息

  181.     public function responseMsg()

  182.     {

  183.         //get post data, May be due to the different environments

  184.         //$postStr = $GLOBALS["HTTP_RAW_POST_DATA"];

  185.         $postStr = file_get_contents("php://input");

  186. 

  187.         if ($this->debug) {

  188.             $this->writelog("function:responseMsg--接收到的消息为--" . $postStr);

  189.         }

  190.         //extract post data

  191.         if (!empty($postStr)) {

  192.             /* libxml_disable_entity_loader is to prevent XML eXternal Entity Injection,

  193.              the best way is to check the validity of xml by yourself */

  194.             libxml_disable_entity_loader(true);

  195.             $this->msg = (array)simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);

  196.             foreach ($this->msg as $key => $v) {

  197.                 $this->writelog("function:responseMsg--接收到的消息为--" . $key);

  198.                 $this->writelog("function:responseMsg--接收到的消息为--" . $v);

  199.             }

  200.             $this->MsgType = strtolower($this->msg['MsgType']);

  201.             return $this->msg;

  202.         } else {

  203.             $this->writelog("消息为空");

  204.             return false;

  205.         }

  206.     }

  207. 

  208.     public function eventMsg($array)

  209.     {

  210.         $result = "";

  211.         $this->writelog("eventMsg array:" . json_encode($array));

  212.         switch ($array['Event']) {

  213.             case 'subscribe':

  214.                 $from_qrcode_id = 0;

  215.                 if (!empty($array['EventKey'])) {

  216.                     $from_qrcode_txt = substr($array['EventKey'], 8);

  217.                     $from_qrcode_id = (int)$from_qrcode_txt;

  218.                 }

  219.                 $pdo = conn();

  220.                 //$sql_update = " INSERT INTO wechat_user(`OPENID`,`IS_REGISTER`) values('{$array['FromUserName']}',1) ON DUPLICATE KEY UPDATE IS_REGISTER = 1 ";

  221.                 $sql_update = " INSERT INTO wechat_user(`OPENID`,`IS_REGISTER`,`FROM_QRCODE_ID`) values('{$array['FromUserName']}',1,{$from_qrcode_id}) ON DUPLICATE KEY UPDATE IS_REGISTER = 1,FROM_QRCODE_ID={$from_qrcode_id} ";

  222.                 $selectDate = $pdo->exec($sql_update);

  223.                 /*

  224.                 $contentStr="Hi，『蜘蛛出行』每天为无数乘客提供便捷的交通出行服务，快来尝试一下吧！

  225. 如果您已经预订了车票，请按以下格式回复“#订单号#预定时预留的手机号”进行订单绑定。

  226. 绑定后可在『更多服务』—『行程』中查看巴士定位、车牌号码和司机电话等信息。

  227. （＃号需输入，不可跳过，订单号请查找蜘蛛出行为您发送的手机短信）";

  228.                 $textTpl="

  229.         <xml>

  230.         <ToUserName><![CDATA[%s]]></ToUserName>

  231.         <FromUserName><![CDATA[%s]]></FromUserName>

  232.         <CreateTime>%s</CreateTime>

  233.         <MsgType><![CDATA[%s]]></MsgType>

  234.         <Content><![CDATA[%s]]></Content>

  235.         </xml>";

  236.                 $msgType="text";

  237.                 $result= sprintf($textTpl, $array['FromUserName'], $array['ToUserName'], time(), $msgType, $contentStr);

  238.                 return $result;

  239.                 */

  240. 

  241.                 $data_media_id = '{"media_id":"AuXDjP791-NMcyJajUxBL0jmNmYMjTJ6fTQTEQV8Gh8"}';

  242.                 $url = "https://api.weixin.qq.com/cgi-bin/material/get_material?access_token=" . $this->_accessToken;

  243.                 $response = $this->_requestPost($url, $data_media_id);

  244.                 $this->writelog("返回--" . $response);

  245.                 $media = json_decode($response, true);

  246.                 $mediaArray = $media['news_item'];

  247.                 $content = array();

  248.                 foreach ($mediaArray as $k => $v) {

  249.                     if ($k == 0 || $k == 1)

  250.                         $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['url']);

  251.                     elseif ($k == 2) {

  252.                         $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['content_source_url']);

  253.                     } else

  254.                         $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['content_source_url']);

  255.                 }

  256.                 $this->writelog("返回--" . json_encode($content));

  257.                 if (is_array($content)) {

  258.                     if (isset($content[0]['PicUrl'])) {

  259.                         $result = $this->transmitNews($array, $content);

  260.                         $this->writelog(json_encode($result));

  261.                         return $result;

  262.                     }

  263.                 }

  264.                 if (!empty($array['EventKey'])) {

  265.                     /*

  266.                     $id=substr($array['EventKey'],strpos($array['EventKey'],"qrscene_")+8);

  267.                     $openid=$array['FromUserName'];

  268.                     $time=date("Y-m-d H:i:s");

  269.                     $pdo = new PDO("sqlsrv:Server=".HOST.";Database=".DB, USER, PASSWORD);//5.6版本pdo连接sqlsrv

  270.                     $sql="SELECT id FROM qrcodeDetail WHERE qrcodeId=".$id." AND openId='".$openid."'";

  271.                     $selectDate=$pdo->query($sql);

  272.                     $selectRes=$selectDate->fetchAll(PDO::FETCH_ASSOC);

  273.                     if (empty($selectRes)){

  274.                         $sql1="INSERT INTO  qrcodeDetail values($id,'$openid','subscribe','$time')";

  275.                         $this->writelog("eventMsg function : subscribe:result id=".$id."--sql1-".$sql1);

  276.                         $result=$pdo->exec($sql1);

  277.                     }

  278. 

  279.                     $sql2="SELECT media_id,url FROM qrcode WHERE id=".$id;

  280.                     $selectDate2=$pdo->query($sql2);

  281.                     $selectRes2=$selectDate2->fetchAll(PDO::FETCH_ASSOC);

  282.                     if (!empty($selectRes2)){

  283.                         $media_id= $selectRes2[0]['media_id'];

  284.                         $Rurl= $selectRes2[0]['url'];

  285.                     }else {

  286.                         //$media_id="AuXDjP791-NMcyJajUxBLzhsCmTK5evvwTjASqBwmv8";

  287.                         $media_id="AuXDjP791-NMcyJajUxBL5N9VCy5YnysR-dDWT2XFWg";

  288.                         $Rurl="http://wx.zhizhuchuxing.com/bookingHomePage/mdidiDetail.html?prod_code=NSPTSM01";

  289.                     }*/

  290. 

  291. 

  292.                     $media_id = "AuXDjP791-NMcyJajUxBL0jmNmYMjTJ6fTQTEQV8Gh8";

  293.                     $data = '{"media_id":"' . $media_id . '"}';

  294.                     $url = "https://api.weixin.qq.com/cgi-bin/material/get_material?access_token=" . $this->_accessToken;

  295.                     $response = $this->_requestPost($url, $data);

  296.                     $this->writelog("返回--" . $response);

  297.                     $media = json_decode($response, true);

  298. 

  299.                     $mediaArray = $media['news_item'];

  300.                     $content = array();

  301.                     foreach ($mediaArray as $k => $v) {

  302.                         if ($k == 0 || $k == 1)

  303.                             $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['url']);

  304.                         else

  305.                             $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['content_source_url']);

  306.                     }

  307.                     $this->writelog("返回--" . json_encode($content));

  308.                     if (is_array($content)) {

  309.                         if (isset($content[0]['PicUrl'])) {

  310.                             $result = $this->transmitNews($array, $content);

  311.                             return $result;

  312.                         }

  313.                     }

  314.                 } else {

  315. 

  316.                     //$data='{"media_id":"AuXDjP791-NMcyJajUxBLw7rLLVx_s0V9I0l_sS92c0"}';

  317.                     /* $data='{"media_id":"AuXDjP791-NMcyJajUxBL5N9VCy5YnysR-dDWT2XFWg"}';

  318.                     $url="https://api.weixin.qq.com/cgi-bin/material/get_material?access_token=".$this->_accessToken;

  319.                     $response=$this->_requestPost($url, $data);

  320.                     $this->writelog("返回--".$response);

  321.                     $media=json_decode($response,true);

  322.                     $mediaArray=$media['news_item'];

  323.                     $content = array();

  324.                     foreach ($mediaArray as $k=>$v){

  325.                         if ($k==0 || $k==1)

  326.                             $content[] = array("Title"=>$v['title'], "Description"=>$v['digest'], "PicUrl"=>$v['thumb_url'], "Url" =>$v['url']);

  327.                         else

  328.                             $content[] = array("Title"=>$v['title'], "Description"=>$v['digest'], "PicUrl"=>$v['thumb_url'], "Url" =>$v['content_source_url']);

  329.                     }

  330.                     $this->writelog("返回--".json_encode($content));

  331.                     if(is_array($content)){

  332.                         if (isset($content[0]['PicUrl'])){

  333.                             $result = $this->transmitNews($array, $content);

  334.                         }

  335.                     } */

  336. 

  337.                     $data_media_id = '{"media_id":"AuXDjP791-NMcyJajUxBL0jmNmYMjTJ6fTQTEQV8Gh8"}';

  338.                     $url = "https://api.weixin.qq.com/cgi-bin/material/get_material?access_token=" . $this->_accessToken;

  339.                     $response = $this->_requestPost($url, $data_media_id);

  340.                     $this->writelog("返回--" . $response);

  341.                     $media = json_decode($response, true);

  342.                     $mediaArray = $media['news_item'];

  343.                     $content = array();

  344.                     foreach ($mediaArray as $k => $v) {

  345.                         if ($k == 0 || $k == 1)

  346.                             $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['url']);

  347.                         elseif ($k == 2) {

  348.                             $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['content_source_url']);

  349.                         } else

  350.                             $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['content_source_url']);

  351.                     }

  352.                     $this->writelog("返回--" . json_encode($content));

  353.                     if (is_array($content)) {

  354.                         if (isset($content[0]['PicUrl'])) {

  355.                             $result = $this->transmitNews($array, $content);

  356.                             $this->writelog(json_encode($result));

  357.                             return $result;

  358.                         }

  359.                     }

  360. 

  361.                 }

  362. 

  363.                 break;

  364.             case 'SCAN':

  365.                 if (isset($array['EventKey'])) {

  366.                     /*

  367.                     $pdo = new PDO("sqlsrv:Server=".HOST.";Database=".DB, USER, PASSWORD);//5.6版本pdo连接sqlsrv

  368.                     $id=$array['EventKey'];

  369.                     $openid=$array['FromUserName'];

  370.                     $time=date("Y-m-d H:i:s");

  371.                     $sql="SELECT id FROM qrcodeDetail WHERE qrcodeId=".$id." AND openId='".$openid."'";

  372.                     $selectDate=$pdo->query($sql);

  373.                     $selectRes=$selectDate->fetchAll(PDO::FETCH_ASSOC);

  374.                     if (empty($selectRes)){

  375.                         $sql1="INSERT INTO  qrcodeDetail values($id,'$openid','SCAN','$time')";

  376.                         $this->writelog("eventMsg function : SCAN:result id=".$id."--sql1-".$sql1);

  377.                         $result=$pdo->exec($sql1);

  378.                     }*/

  379. 

  380.                     /* $this->writelog("eventMsg function : SCAN:result id=".$id."---".json_encode($result));

  381.                     $errinfo=$pdo->errorInfo();

  382.                     if ($errinfo[0] !='00000')

  383.                         $this->writelog("eventMsg function : SCAN:error id=".$id."---".$errinfo[2]);

  384.                     else{

  385.                         $res=$result->fetchAll(PDO::FETCH_ASSOC);

  386.                         $this->writelog("eventMsg function : SCAN:res id=".$id."---".json_encode($res));

  387.                         $headUrl=$res[0]['url'];

  388.                         $this->writelog("eventMsg function : SCAN:headUrl id=".$id."---".$headUrl);

  389. 

  390.                         header("Location: $headUrl");exit;

  391.                     } */

  392. //					$data='{"media_id":"AuXDjP791-NMcyJajUxBLw7rLLVx_s0V9I0l_sS92c0"}';

  393.                     /*

  394.                     $sql2="SELECT media_id,url FROM qrcode WHERE id=".$id;

  395.                     $selectDate2=$pdo->query($sql2);

  396.                     $selectRes2=$selectDate2->fetchAll(PDO::FETCH_ASSOC);

  397.                     if (!empty($selectRes2)){

  398.                         $media_id= $selectRes2[0]['media_id'];

  399.                         $Rurl= $selectRes2[0]['url'];

  400.                     }else {

  401.                         //$media_id="AuXDjP791-NMcyJajUxBLzhsCmTK5evvwTjASqBwmv8";

  402.                         $media_id="AuXDjP791-NMcyJajUxBL5N9VCy5YnysR-dDWT2XFWg";

  403.                         $Rurl="http://wx.zhizhuchuxing.com/bookingHomePage/mdidiDetail.html?prod_code=NSPTSM01";

  404.                     }*/

  405. 

  406.                     /*

  407.                     $pdo=conn();

  408.                     $sql_update = " INSERT INTO wechat_user(`OPENID`,`IS_REGISTER`) values('{$array['FromUserName']}',1) ON DUPLICATE KEY UPDATE IS_REGISTER = 1 ";

  409.                     $selectDate = $pdo->exec($sql_update);

  410. 

  411.                     $contentStr="Hi，『蜘蛛出行』每天为无数乘客提供便捷的交通出行服务，快来尝试一下吧！

  412. 如果您已经预订了车票，请按以下格式回复“#订单号#预定时预留的手机号”进行订单绑定。

  413. 绑定后可在『更多服务』—『行程』中查看巴士定位、车牌号码和司机电话等信息。

  414. （＃号需输入，不可跳过，订单号请查找蜘蛛出行为您发送的手机短信）";

  415.                     $textTpl="

  416.         <xml>

  417.         <ToUserName><![CDATA[%s]]></ToUserName>

  418.         <FromUserName><![CDATA[%s]]></FromUserName>

  419.         <CreateTime>%s</CreateTime>

  420.         <MsgType><![CDATA[%s]]></MsgType>

  421.         <Content><![CDATA[%s]]></Content>

  422.         </xml>";

  423.                     $msgType="text";

  424.                     $result= sprintf($textTpl, $array['FromUserName'], $array['ToUserName'], time(), $msgType, $contentStr);

  425.                     return $result;

  426.                     */

  427.                     $from_qrcode_id = 0;

  428.                     if (!empty($array['EventKey'])) {

  429.                         $from_qrcode_txt = substr($array['EventKey'], 8);

  430.                         $from_qrcode_id = (int)$from_qrcode_txt;

  431.                     }

  432.                     $this->writelog("SCAN CODE:" . json_encode($array));

  433.                     $pdo = conn();

  434.                     $sql_update = " INSERT INTO wechat_user(`OPENID`,`IS_REGISTER`,`FROM_QRCODE_ID`) values('{$array['FromUserName']}',1,{$from_qrcode_id}) ON DUPLICATE KEY UPDATE IS_REGISTER = 1,FROM_QRCODE_ID={$from_qrcode_id} ";

  435.                     $selectDate = $pdo->exec($sql_update);

  436.                     if ($from_qrcode_id != 0) {

  437.                         //发送微信红包

  438.                         $this->sendWxRedPack($array['FromUserName']);

  439.                     }

  440.                     $data_media_id = '{"media_id":"AuXDjP791-NMcyJajUxBL0jmNmYMjTJ6fTQTEQV8Gh8"}';

  441.                     $url = "https://api.weixin.qq.com/cgi-bin/material/get_material?access_token=" . $this->_accessToken;

  442.                     $response = $this->_requestPost($url, $data_media_id);

  443.                     $this->writelog("返回--" . $response);

  444.                     $media = json_decode($response, true);

  445.                     $mediaArray = $media['news_item'];

  446.                     $content = array();

  447.                     foreach ($mediaArray as $k => $v) {

  448.                         if ($k == 0 || $k == 1)

  449.                             $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['url']);

  450.                         elseif ($k == 2) {

  451.                             $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['content_source_url']);

  452.                         } else

  453.                             $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['content_source_url']);

  454.                     }

  455.                     $this->writelog("返回--" . json_encode($content));

  456.                     if (is_array($content)) {

  457.                         if (isset($content[0]['PicUrl'])) {

  458.                             $result = $this->transmitNews($array, $content);

  459.                             $this->writelog(json_encode($result));

  460.                             return $result;

  461.                         }

  462.                     }

  463. 

  464.                     /*

  465.                     $data='{"media_id":"'.$media_id.'"}';

  466.                     $url="https://api.weixin.qq.com/cgi-bin/material/get_material?access_token=".$this->_accessToken;

  467.                     $response=$this->_requestPost($url, $data);

  468.                     $this->writelog("返回--".$response);

  469.                     $media=json_decode($response,true);

  470.                     $mediaArray=$media['news_item'];

  471.                     $content = array();

  472.                     foreach ($mediaArray as $k=>$v){

  473.                         if ($k==0 || $k==1)

  474.                             $content[] = array("Title"=>$v['title'], "Description"=>$v['digest'], "PicUrl"=>$v['thumb_url'], "Url" =>$v['url']);

  475.                         elseif($k==2){

  476.                             $content[] = array("Title"=>$v['title'], "Description"=>$v['digest'], "PicUrl"=>$v['thumb_url'], "Url" =>$v['content_source_url']);

  477.                         }

  478.                         else

  479.                             $content[] = array("Title"=>$v['title'], "Description"=>$v['digest'], "PicUrl"=>$v['thumb_url'], "Url" =>$v['content_source_url']);

  480.                     }

  481.                     $this->writelog("返回--".json_encode($content));

  482.                     if(is_array($content)){

  483.                         if (isset($content[0]['PicUrl'])){

  484.                             $result = $this->transmitNews($array, $content);

  485.                         }

  486.                     }*/

  487.                 }

  488.                 break;

  489.             case 'CLICK':

  490.                 $pdo = conn();

  491.                 $contantConfig = require dirname(dirname(__DIR__)) . '/config/moduleConfig/module/site.contants.config.php';

  492.                 $sql_update = " INSERT INTO wechat_user(`OPENID`,`IS_REGISTER`,`from_source`) values('{$array['FromUserName']}',1,{$contantConfig['org_id']}) ON DUPLICATE KEY UPDATE IS_REGISTER = 1 ";

  493.                 $selectDate = $pdo->exec($sql_update);

  494.                 /*

  495.                 $contentStr="Hi，『蜘蛛出行』每天为无数乘客提供便捷的交通出行服务，快来尝试一下吧！

  496. 如果您已经预订了车票，请按以下格式回复“#订单号#预定时预留的手机号”进行订单绑定。

  497. 绑定后可在『更多服务』—『行程』中查看巴士定位、车牌号码和司机电话等信息。

  498. （＃号需输入，不可跳过，订单号请查找蜘蛛出行为您发送的手机短信）";

  499.                 $textTpl="

  500.         <xml>

  501.         <ToUserName><![CDATA[%s]]></ToUserName>

  502.         <FromUserName><![CDATA[%s]]></FromUserName>

  503.         <CreateTime>%s</CreateTime>

  504.         <MsgType><![CDATA[%s]]></MsgType>

  505.         <Content><![CDATA[%s]]></Content>

  506.         </xml>";

  507.                 $msgType="text";

  508.                 $result= sprintf($textTpl, $array['FromUserName'], $array['ToUserName'], time(), $msgType, $contentStr);

  509.                 return $result;

  510.                 */

  511.                 if (isset($array['EventKey']) && $array['EventKey'] == 'Push-Photo-List') {

  512. 

  513.                     $data = '{"media_id":"AuXDjP791-NMcyJajUxBL0jmNmYMjTJ6fTQTEQV8Gh8"}';

  514.                     $url = "https://api.weixin.qq.com/cgi-bin/material/get_material?access_token=" . $this->_accessToken;

  515.                     $response = $this->_requestPost($url, $data);

  516.                     $this->writelog("CLICK返回response--" . $response);

  517.                     $media = json_decode($response, true);

  518.                     $mediaArray = $media['news_item'];

  519.                     $content = array();

  520.                     foreach ($mediaArray as $k => $v) {

  521.                         if ($k == 0 || $k == 1)

  522.                             $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['url']);

  523.                         else

  524.                             $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['content_source_url']);

  525.                     }

  526.                     $this->writelog("CLICK返回content--" . json_encode($content));

  527.                     if (is_array($content)) {

  528.                         if (isset($content[0]['PicUrl'])) {

  529.                             $result = $this->transmitNews($array, $content);

  530.                         }

  531.                     }

  532.                 } elseif (isset($array['EventKey']) && $array['EventKey'] == 'MSG_LIANXIKEFU') {

  533.                     $textTpl = '' . "

  534. <xml>

  535. <ToUserName><![CDATA[%s]]></ToUserName>

  536. <FromUserName><![CDATA[%s]]></FromUserName>

  537. <CreateTime>%s</CreateTime>

  538. <MsgType><![CDATA[transfer_customer_service]]></MsgType>

  539. </xml>";

  540.                     $result = sprintf($textTpl, $array['FromUserName'], $array['ToUserName'], time());

  541.                 }

  542. 

  543.         }

  544.         /*

  545.         $data='{"type":"news","offset":0,"count":20}';

  546.         $url="https://api.weixin.qq.com/cgi-bin/material/batchget_material?access_token=".$this->_accessToken;

  547.         $response=$this->_requestPost($url, $data);

  548.         $this->writelog("返回--".$response); */

  549.         $this->writelog("回复用户event--" . json_encode($result));

  550.         return $result;

  551. 

  552.     }

  553. 

  554.     /**

  555.      * Function Description:发送微信红包

  556.      * Function Name: sendWxRedPack

  557.      * @param $openId

  558.      *

  559.      * @return bool

  560.      *

  561.      * @author 倪宗锋

  562.      */

  563.     public function sendWxRedPack($openId)

  564.     {

  565.         $path = dirname(dirname(__DIR__));

  566.         $config = require $path . "/config/wxpay.config.php";

  567.         //准备数据

  568.         $params = array(

  569.             'openid' => $openId,

  570.             'act_id' => 1

  571.         );

  572.         $params['sign'] = $this->getSign($params, $config['key']);//安全机制 秘钥签名

  573.         $url = 'http://' . $_SERVER['HTTP_HOST'] . '/module/activity/redpack/sendRedPack?';

  574.         $url .= http_build_query($params);

  575.         //调用接口

  576.         $curl = curl_init();

  577.         curl_setopt($curl, CURLOPT_URL, $url);

  578.         curl_setopt($curl, CURLOPT_AUTOREFERER, true);

  579.         curl_setopt($curl, CURLOPT_POST, true);

  580.         curl_setopt($curl, CURLOPT_POSTFIELDS, array());

  581.         curl_setopt($curl, CURLOPT_HEADER, false);

  582.         curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);

  583.         //1秒超时 不等待

  584.         curl_setopt($curl, CURLOPT_TIMEOUT, 1);

  585.         curl_exec($curl);

  586.         return true;

  587.     }

  588. 

  589.     /**

  590.      * Function Description:获取签名

  591.      * Function Name: getSign

  592.      * @param $params

  593.      * @param $key string 配置类型

  594.      *

  595.      * @return string

  596.      *

  597.      * @author 倪宗锋

  598.      */

  599.     public static function getSign($params, $key)

  600.     {

  601.         if (isset($params['sign'])) {

  602.             unset($params['sign']);

  603.         }

  604.         //签名步骤一：按字典序排序参数

  605.         ksort($params);

  606.         $string = self::ToUrlParams($params);

  607.         //签名步骤二：在string后加入KEY

  608.         $string = $string . "&key=" . $key;

  609.         //签名步骤三：MD5加密

  610.         $string = md5($string);

  611.         //签名步骤四：所有字符转为大写

  612.         $result = strtoupper($string);

  613.         return $result;

  614. 

  615.     }

  616. 

  617.     /**

  618.      * Function Description:格式化参数 格式化成url参数

  619.      * Function Name: ToUrlParams

  620.      * @param $params

  621.      *

  622.      * @return string

  623.      *

  624.      * @author 倪宗锋

  625.      */

  626.     public static function ToUrlParams($params)

  627.     {

  628.         $buff = "";

  629.         foreach ($params as $k => $v) {

  630.             if ($k != "sign" && $v != "" && !is_array($v)) {

  631.                 $buff .= $k . "=" . $v . "&";

  632.             }

  633.         }

  634.         $buff = trim($buff, "&");

  635.         return $buff;

  636.     }

  637. 

  638.     //把openid存入数据库

  639.     public function insertOpenid($data, $type)

  640.     {

  641.         $openid = $data['FromUserName'];

  642.         if ($type == 'subscribe') {

  643.             $sql = "insert into wx_user(openid) values('{$openid}')";

  644.         } else if ($type == 'unsubscribe') {

  645.             $sql = "delete from wx_user where openid='{$openid}'";

  646.         }

  647.         $result = '';

  648.         try {

  649.             $pdo = new PDO("sqlsrv:Server=" . HOST . ";Database=" . DB, USER, PASSWORD);//5.6版本pdo连接sqlsrv

  650.             //$pdo=new PDO("mysql:host=".HOST.";dbname=".DB,USER,PASSWORD); //7.0版本pdo连接mysql

  651.             $result = $pdo->exec($sql);

  652.             $errinfo = $pdo->errorInfo();

  653.             if ($errinfo[0] != '00000')

  654.                 $this->writelog($errinfo[2]);

  655.         } catch (PDOException $e) {

  656.             $this->writelog($e->getMessage());

  657.         }

  658.         if ($result) {

  659.             return true;

  660.         } else {

  661.             return false;

  662.         }

  663.     }

  664. 

  665.     //有用户关注的时候推送多图文消息

  666.     private function transmitNews($array, $newsArray)

  667.     {

  668.         if (!is_array($newsArray)) {

  669.             return;

  670.         }

  671.         $itemTpl = "<item>

  672.         <Title><![CDATA[%s]]></Title>

  673.         <Description><![CDATA[%s]]></Description>

  674.         <PicUrl><![CDATA[%s]]></PicUrl>

  675.         <Url><![CDATA[%s]]></Url>

  676.     	</item>";

  677.         $item_str = "";

  678.         foreach ($newsArray as $item) {

  679.             $item_str .= sprintf($itemTpl, $item['Title'], $item['Description'], $item['PicUrl'], $item['Url']);

  680.         }

  681.         $xmlTpl = "<xml>

  682. <ToUserName><![CDATA[%s]]></ToUserName>

  683. <FromUserName><![CDATA[%s]]></FromUserName>

  684. <CreateTime>%s</CreateTime>

  685. <MsgType><![CDATA[news]]></MsgType>

  686. <ArticleCount>%s</ArticleCount>

  687. <Articles>

  688. $item_str</Articles>

  689. </xml>";

  690. 

  691.         $result = sprintf($xmlTpl, $array['FromUserName'], $array['ToUserName'], time(), count($newsArray));

  692.         return $result;

  693.     }

  694. 

  695.     private function transmitImage($array)

  696.     {

  697.         $xmlTpl = "<xml>

  698. <ToUserName><![CDATA[%s]]></ToUserName>

  699. <FromUserName><![CDATA[%s]]></FromUserName>

  700. <CreateTime>%s</CreateTime>

  701. <MsgType><![CDATA[image]]></MsgType>

  702. <Image>

  703. <MediaId><![CDATA[%s]]></MediaId>

  704. </Image>

  705. </xml>";

  706.         $result = sprintf($xmlTpl, $array['FromUserName'], $array['ToUserName'], time(), $array['media_id']);

  707.         return $result;

  708.     }

  709. 

  710.     private function transmitVoice($array)

  711.     {

  712.         $xmlTpl = "<xml>

  713. <ToUserName><![CDATA[%s]]></ToUserName>

  714. <FromUserName><![CDATA[%s]]></FromUserName>

  715. <CreateTime>%s</CreateTime>

  716. <MsgType><![CDATA[voice]]></MsgType>

  717. <Image>

  718. <MediaId><![CDATA[%s]]></MediaId>

  719. </Image>

  720. </xml>";

  721.         $result = sprintf($xmlTpl, $array['FromUserName'], $array['ToUserName'], time(), $array['media_id']);

  722.         return $result;

  723.     }

  724. 

  725.     private function transmitVideo($array)

  726.     {

  727.         $xmlTpl = "<xml>

  728. <ToUserName><![CDATA[%s]]></ToUserName>

  729. <FromUserName><![CDATA[%s]]></FromUserName>

  730. <CreateTime>%s</CreateTime>

  731. <MsgType><![CDATA[video]]></MsgType>

  732. <Video>

  733. <MediaId><![CDATA[%s]]></MediaId>

  734. <Title><![CDATA[%s]]></Title>

  735. <Description><![CDATA[%s]]></Description>

  736. </Video>

  737. </xml>";

  738.         $result = sprintf($xmlTpl, $array['FromUserName'], $array['ToUserName'], time(), $array['media_id'], $array["title"], $array["description"]);

  739.         return $result;

  740.     }

  741. 

  742.     //获取文本

  743.     public function textMsg($data)

  744.     {

  745. 

  746.         $Content = trim($data['Content']);

  747.         $textTpl = "

  748. 		<xml>

  749. 		<ToUserName><![CDATA[%s]]></ToUserName>

  750. 		<FromUserName><![CDATA[%s]]></FromUserName>

  751. 		<CreateTime>%s</CreateTime>

  752. 		<MsgType><![CDATA[%s]]></MsgType>

  753. 		<Content><![CDATA[%s]]></Content>

  754. 		</xml>";

  755.         $msgType = "text";

  756.         $word = $data['Content'];

  757. 

  758.         if ($word == '寻路') {

  759.             $this->writelog("textMsg有调用:关键字是面试");

  760.             $data_media_id = '{"media_id":"AuXDjP791-NMcyJajUxBL8LcnGB8gKQTImk6XJK53uU"}';

  761.             $url = "https://api.weixin.qq.com/cgi-bin/material/get_material?access_token=" . $this->_accessToken;

  762.             $response = $this->_requestPost($url, $data_media_id);

  763.             $this->writelog("返回--" . $response);

  764.             $media = json_decode($response, true);

  765.             $mediaArray = $media['news_item'];

  766.             $content = array();

  767.             foreach ($mediaArray as $k => $v) {

  768.                 if ($k == 0 || $k == 1)

  769.                     $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['url']);

  770.                 elseif ($k == 2) {

  771.                     $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['content_source_url']);

  772.                 } else

  773.                     $content[] = array("Title" => $v['title'], "Description" => $v['digest'], "PicUrl" => $v['thumb_url'], "Url" => $v['content_source_url']);

  774.             }

  775.             $this->writelog("返回--" . json_encode($content));

  776.             if (is_array($content)) {

  777.                 if (isset($content[0]['PicUrl'])) {

  778.                     $result = $this->transmitNews($data, $content);

  779.                     $this->writelog(json_encode($result));

  780.                     return $result;

  781.                 }

  782.             }

  783.         } else if ($word == '活动') {

  784.             $data["media_id"] = "AuXDjP791-NMcyJajUxBL2MpGN_djcS5OUH-Y5njOMA";

  785.             $result = $this->transmitImage($data);

  786.             $this->writelog(json_encode($result));

  787.             return $result;

  788.         } else if ($word == '测试定制巴士') {

  789.             $contentStr = "http://wx.zhizhuchuxing.com/ZZDZ/dzbs_login.php";

  790.             $resultStr = sprintf($textTpl, $data['FromUserName'], $data['ToUserName'], time(), $msgType, $contentStr);

  791.             return $resultStr;

  792.         } else if ($word == '订单绑定' || $word == '绑定订单' || $word == '绑定' || $word == '绑订单') {

  793.             $contentStr = "Hi，『蜘蛛出行』每天为无数乘客提供便捷的交通出行服务，快来尝试我们为您准备的新功能吧！

  794. 如果您已经预订了车票，请按以下格式回复“#订单号#预定时预留的手机号”进行订单绑定，绑定后可在『更多服务』—『行程』中查看巴士定位、车牌号码和司机电话等信息。

  795. （＃号需输入，不可跳过，订单号请查找蜘蛛出行为您发送的手机短信）

  796. 如果您还没有预订车票，请戳左下角『出行预订』！";

  797.             $resultStr = sprintf($textTpl, $data['FromUserName'], $data['ToUserName'], time(), $msgType, $contentStr);

  798.             $this->writelog($resultStr);

  799.             return $resultStr;

  800.         } else if (substr($word, 0, 1) == '#') {

  801.             $word = substr($word, 1);

  802.             $wordArr = explode("#", $word);

  803.             if (count($wordArr) != 2 || $wordArr[0] == '' || $wordArr[1] == '') {

  804.                 $contentStr = "输入格式错误";

  805.             } else if (!is_numeric($wordArr[0]) || !is_numeric($wordArr[1])) {

  806.                 $contentStr = "订单号和手机号必须整数";

  807.             } else {

  808.                 $pdo = conn();

  809.                 $sql = "CALL DRIVER_WEICHAT_BOND(" . $wordArr[0] . "," . $wordArr[1] . ",'" . $data['FromUserName'] . "')";

  810.                 $this->writelog("订单绑定" . $sql);

  811.                 $result = $pdo->query($sql);

  812.                 $rowset = $result->fetchAll(PDO::FETCH_ASSOC);

  813.                 $result->closeCursor();

  814.                 $update_sql = "UPDATE order_main SET MEMBER_ID = (SELECT id FROM wechat_user WHERE OPENID = '{$data['FromUserName']}' ) WHERE order_id = {$wordArr[0]} OR parent_order_id = {$wordArr[0]}";

  815.                 $pdo_update = conn();

  816.                 $pdo_update->exec($update_sql);

  817.                 if ($rowset[0]['code'] == 0) {

  818.                     $contentStr = "绑定成功";

  819.                 } else {

  820.                     $contentStr = $rowset[0]['info'];

  821.                 }

  822. 

  823.             }

  824.             $resultStr = sprintf($textTpl, $data['FromUserName'], $data['ToUserName'], time(), $msgType, $contentStr);

  825.             $this->writelog($resultStr);

  826.             return $resultStr;

  827. 

  828. 

  829.         } /*else{

  830. 			$contentStr="Hi，『蜘蛛出行』每天为无数乘客提供便捷的交通出行服务，快来尝试我们为您准备的新功能吧！

  831. 如果您已经预订了车票，请按以下格式回复“#订单号#预定时预留的手机号”进行订单绑定，绑定后可在『更多服务』—『行程』中查看巴士定位、车牌号码和司机电话等信息。

  832. （＃号需输入，不可跳过，订单号请查找蜘蛛出行为您发送的手机短信）

  833. 如果您还没有预订车票，请戳左下角『出行预订』！";

  834. 			$resultStr = sprintf($textTpl, $data['FromUserName'], $data['ToUserName'], time(), $msgType, $contentStr);

  835. 			return $resultStr;

  836. 		}*/

  837. 

  838. 

  839.         //$contentStr=$this->simsimiHttp($Content);

  840.         else {

  841.             $textTpl = '' . "

  842. <xml>

  843. <ToUserName><![CDATA[%s]]></ToUserName>

  844. <FromUserName><![CDATA[%s]]></FromUserName>

  845. <CreateTime>%s</CreateTime>

  846. <MsgType><![CDATA[transfer_customer_service]]></MsgType>

  847. </xml>";

  848.             $resultStr = sprintf($textTpl, $data['FromUserName'], $data['ToUserName'], time());

  849.             return $resultStr;

  850.         }

  851. 

  852.     }

  853. 

  854.     private function simsimiHttp($msg)

  855.     {

  856.         $url = "http://www.xiaodoubi.com/simsimiapi.php?msg=" . $msg;

  857.         $res = file_get_contents($url);

  858.         file_put_contents("./demo.txt", date("Y-m-d H:i:s") . "  " . $res . PHP_EOL, FILE_APPEND);

  859.         if (strpos($res, "xiaodouqqcom") !== false) {

  860.             $res = "无法回答，请不要发一下奇怪的问题或字符😒";

  861.         }

  862.         if (strpos($msg, "主人") !== false) {

  863.             $res = "我的主人就是你呀";

  864.         }

  865.         return $res;

  866.     }

  867. 

  868.     private function checkAccessToken($check)

  869.     {

  870.         if (isset($check['errcode']) && $check['errcode'] == 40001) {

  871.             $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$this->_appid}&secret={$this->_appsecret}";

  872.             $result = $this->_requestGet($url);

  873.             if (!$result) {

  874.                 $this->writelog("获取token出错");

  875.                 return false;

  876.             }

  877.             $result_obj = json_decode($result);

  878. 

  879.             file_put_contents($token_file, $result_obj->access_token);

  880.             $this->writelog("url获取的token:" . $result_obj->access_token);

  881.             return $result_obj->access_token;

  882.         }

  883.     }

  884. }

  885. 

  886. ?>