nizongfeng
/
XMWXC
1
0
Fork 0
Code Issues 0 Pull Requests 0 Releases 0 Wiki Activity
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
2 Commits
1 Branch
29 MiB
 
 
 
 
 
Branch: master
Branches Tags
${ item.name }
Create branch ${ searchTerm }
from 'master'
${ noResults }
XMWXC/wechat/Common/WeChat.class.php

763 lines
30 KiB
Raw Permalink Blame History 

  1. <?php

  2. class WeChat{

  3. 	private $_appid;

  4. 	private $_appsecret;

  5. 	private $_accessToken;

  6. 	public $debug=DEBUG;

  7. 	public $MsgType='text';

  8. 	public $msg=array();

  9. 	/* //QRCode类型

  10. 	const QRCODE_TYPE_TEMP=1;

  11. 	const QRCODE_TYPE_LIMIT=2;

  12. 	const QRCODE_TYPE_LIMIT_STR=3; */

  13. 	public function __construct($appid,$appsecret){

  14. 

  15. 		$this->_appid=$appid;

  16. 		$this->_appsecret=$appsecret;

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

  18. 			$this->valid();

  19. 		}

  20. 		if (ALWAYSCHECK==true){

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

  22. 			if (!$check){

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

  24. 				exit;

  25. 			}

  26. 		}

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

  28. 	}

  29. 	public function getAccessToken(){

  30. 	

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

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

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

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

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

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

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

  38. 				$access_token = $res->access_token;

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

  40. 				if ($access_token) {

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

  42. 					$data->access_token = $access_token;

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

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

  45. 				}

  46. 			} else {

  47. 				$access_token = $data->access_token;

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

  49. 			}

  50. 			return $access_token;

  51. 	}

  52. 	private function get_php_file($filename) {

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

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

  55. 			mkdir($dir);

  56. 		}

  57. 		$token_file=$dir.$filename;

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

  59. 	}

  60. 	private function set_php_file($filename, $content) {

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

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

  63. 			mkdir($dir);

  64. 		}

  65. 		$token_file=$dir.$filename;

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

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

  68. 		fclose($fp);

  69. 	}

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

  71. 		$curl=curl_init();

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

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

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

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

  76. 		if ($ssl){

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

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

  79. 		}

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

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

  82. 		$response=curl_exec($curl);

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

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

  85. 			return false;

  86. 		}

  87. 		return $response;

  88. 	}

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

  90. 		$curl=curl_init();

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

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

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

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

  95. 		if ($ssl){

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

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

  98. 		}

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

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

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

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

  103. 		$response=curl_exec($curl);

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

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

  106. 			return false;

  107. 		}

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

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

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

  111. 		

  112. 		return $response;

  113. 	}

  114. 	

  115. 	public function valid()

  116. 	{

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

  118. 		//valid signature , option

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

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

  121. 			echo $echoStr;

  122. 			exit;

  123. 		}else {

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

  125. 			exit();

  126. 		}

  127. 	}

  128. 	private function checkSignature()

  129. 	{

  130. 		// you must define TOKEN by yourself

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

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

  133. 		}

  134. 	

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

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

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

  138. 	

  139. 		$token = TOKEN;

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

  141. 		// use SORT_STRING rule

  142. 		sort($tmpArr, SORT_STRING);

  143. 		$tmpStr = implode( $tmpArr );

  144. 		$tmpStr = sha1( $tmpStr );

  145. 	

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

  147. 			return true;

  148. 		}else{

  149. 			return false;

  150. 		}

  151. 	}

  152. 	private function writelog($activation){

  153. 		$dir="./Log";

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

  155. 			mkdir($dir);

  156. 		}

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

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

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

  160. 		fclose($open);

  161. 	}

  162. 	//获取消息

  163. 	public function responseMsg()

  164. 	{

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

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

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

  168. 		

  169. 		if ($this->debug){

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

  171. 		}

  172. 		//extract post data

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

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

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

  176. 			libxml_disable_entity_loader(true);

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

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

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

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

  181. 			}

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

  183. 			return $this->msg;

  184. 		}else {

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

  186. 			return false;

  187. 		}

  188. 	}

  189. 	public function eventMsg($array){

  190. 		$result = "";

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

  192. 			case 'subscribe':

  193. 				$pdo=conn();

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

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

  196. 				$pdo2=conn_ctsdata();

  197. 				$selectDate = $pdo2->exec($sql_update);

  198. 				/*

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

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

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

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

  203. 				$textTpl="

  204. 		<xml>

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

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

  207. 		<CreateTime>%s</CreateTime>

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

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

  210. 		</xml>";

  211. 				$msgType="text";

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

  213. 				return $result;

  214. 				*/

  215. 

  216. 				$data_media_id='{"media_id":"99eQLZw0myQ1ZvOS4rjpsl7AN87CEwwqLRGrk9vSa90"}';

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

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

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

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

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

  222. 				$content = array();

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

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

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

  226. 					elseif($k==2){

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

  228. 					}

  229. 					else

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

  231. 				}

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

  233. 				if(is_array($content)){

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

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

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

  237. 						return $result;

  238. 					}

  239. 				}

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

  241. 					/*

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

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

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

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

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

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

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

  249. 					if (empty($selectRes)){

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

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

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

  253. 					}

  254. 					

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

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

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

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

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

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

  261. 					}else {

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

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

  264. 						$Rurl="http://xmwxc.zhizhuchuxing.cn/bookingHomePage/mdidiDetail.html?prod_code=NSPTSM01";

  265. 					}*/

  266. 

  267. 

  268. 					$media_id="99eQLZw0myQ1ZvOS4rjpsl7AN87CEwwqLRGrk9vSa90";

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

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

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

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

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

  274. 					

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

  276. 					$content = array();

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

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

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

  280. 						else

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

  282. 					}

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

  284. 					if(is_array($content)){

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

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

  287. 						}

  288. 					}

  289. 				}else{

  290. 					

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

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

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

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

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

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

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

  298. 					$content = array();

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

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

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

  302. 						else 

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

  304. 					}

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

  306. 					if(is_array($content)){

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

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

  309. 						}

  310. 					} */

  311. 

  312. 					$data_media_id='{"media_id":"99eQLZw0myQ1ZvOS4rjpsl7AN87CEwwqLRGrk9vSa90"}';

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

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

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

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

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

  318. 					$content = array();

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

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

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

  322. 						elseif($k==2){

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

  324. 						}

  325. 						else

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

  327. 					}

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

  329. 					if(is_array($content)){

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

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

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

  333. 							return $result;

  334. 						}

  335. 					}

  336. 

  337. 				}

  338. 				

  339. 				break;

  340. 			case 'SCAN':

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

  342. 					/*

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

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

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

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

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

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

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

  350. 					if (empty($selectRes)){

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

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

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

  354. 					}*/

  355. 					

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

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

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

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

  360. 					else{

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

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

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

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

  365. 						

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

  367. 					} */

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

  369. 					/*

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

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

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

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

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

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

  376. 					}else {

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

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

  379. 						$Rurl="http://xmwxc.zhizhuchuxing.cn/bookingHomePage/mdidiDetail.html?prod_code=NSPTSM01";

  380. 					}*/

  381. 

  382. 					$pdo=conn();

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

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

  385. 					$pdo2=conn_ctsdata();

  386. 					$selectDate = $pdo2->exec($sql_update);

  387. 					/*

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

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

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

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

  392. 					$textTpl="

  393. 		<xml>

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

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

  396. 		<CreateTime>%s</CreateTime>

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

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

  399. 		</xml>";

  400. 					$msgType="text";

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

  402. 					return $result;

  403. 					*/

  404. 					$data_media_id='{"media_id":"99eQLZw0myQ1ZvOS4rjpsl7AN87CEwwqLRGrk9vSa90"}';

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

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

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

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

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

  410. 					$content = array();

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

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

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

  414. 						elseif($k==2){

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

  416. 						}

  417. 						else

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

  419. 					}

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

  421. 					if(is_array($content)){

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

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

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

  425. 							return $result;

  426. 						}

  427. 					}

  428. 

  429. 					/*

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

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

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

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

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

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

  436. 					$content = array();

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

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

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

  440. 						elseif($k==2){

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

  442. 						}

  443. 						else

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

  445. 					}

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

  447. 					if(is_array($content)){

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

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

  450. 						}

  451. 					}*/

  452. 				}

  453. 				break;

  454. 			case 'CLICK':

  455. 				$pdo=conn();

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

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

  458. 				$pdo2=conn_ctsdata();

  459. 				$selectDate = $pdo2->exec($sql_update);

  460. 				/*

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

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

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

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

  465. 				$textTpl="

  466. 		<xml>

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

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

  469. 		<CreateTime>%s</CreateTime>

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

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

  472. 		</xml>";

  473. 				$msgType="text";

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

  475. 				return $result;

  476. 				*/

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

  478. 					

  479. 					$data='{"media_id":"99eQLZw0myQ1ZvOS4rjpsl7AN87CEwwqLRGrk9vSa90"}';

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

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

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

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

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

  485. 					$content = array();

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

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

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

  489. 						else

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

  491. 					}

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

  493. 					if(is_array($content)){

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

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

  496. 						}

  497. 					}

  498. 				} else if( isset($array['EventKey']) && $array['EventKey']=='XMWX_QIJIANDIAN' ) {

  499. 					$contentStr="佰廉官网\nhttp://m.xmwtt.com\n天猫旗舰店\nhttp://t.cn/RZ9LO29\n去哪儿旗舰店\nhttp://t.cn/R7PGfpP";

  500. 					$textTpl="

  501. 		<xml>

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

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

  504. 		<CreateTime>%s</CreateTime>

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

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

  507. 		</xml>";

  508. 					$msgType="text";

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

  510. 					return $result;

  511. 				} else if( isset($array['EventKey']) && $array['EventKey']=='XMWX_TOUSUJIANYI' ) {

  512. 					$contentStr="投诉与建议\n李先生：0592-330114";

  513. 					$textTpl="

  514. 		<xml>

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

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

  517. 		<CreateTime>%s</CreateTime>

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

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

  520. 		</xml>";

  521. 					$msgType="text";

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

  523. 					return $result;

  524. 				}

  525. 				break;

  526. 				

  527. 		}

  528. 		/* 

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

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

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

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

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

  534. 		return $result;

  535. 		

  536. 	}

  537. 	//把openid存入数据库

  538. 	public function insertOpenid($data,$type){

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

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

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

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

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

  544. 		}

  545. 		$result='';

  546. 		try {

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

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

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

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

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

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

  553. 		} catch (PDOException $e) {

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

  555. 		}

  556. 		if ($result){

  557. 			return true;

  558. 		}else {

  559. 			return false;

  560. 		}

  561. 	}

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

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

  564.     {

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

  566.             return;

  567.         }

  568.         $itemTpl = "<item>

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

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

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

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

  573.     	</item>";

  574.         $item_str = "";

  575.         foreach ($newsArray as $item){

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

  577.         }

  578.         $xmlTpl = "<xml>

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

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

  581. <CreateTime>%s</CreateTime>

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

  583. <ArticleCount>%s</ArticleCount>

  584. <Articles>

  585. $item_str</Articles>

  586. </xml>";

  587. 

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

  589.         return $result;

  590.     }

  591. 	private function transmitImage( $array ) {

  592. 		$xmlTpl = "<xml>

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

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

  595. <CreateTime>%s</CreateTime>

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

  597. <Image>

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

  599. </Image>

  600. </xml>";

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

  602. 		return $result;

  603. 	}

  604. 

  605. 	private function transmitVoice( $array ) {

  606. 		$xmlTpl = "<xml>

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

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

  609. <CreateTime>%s</CreateTime>

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

  611. <Image>

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

  613. </Image>

  614. </xml>";

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

  616. 		return $result;

  617. 	}

  618. 

  619. 	private function transmitVideo( $array ) {

  620. 		$xmlTpl = "<xml>

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

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

  623. <CreateTime>%s</CreateTime>

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

  625. <Video>

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

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

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

  629. </Video>

  630. </xml>";

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

  632. 		return $result;

  633. 	}

  634. 

  635. 	//获取文本

  636. 	public function textMsg($data){

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

  638. 		$textTpl="

  639. 		<xml>

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

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

  642. 		<CreateTime>%s</CreateTime>

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

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

  645. 		</xml>";

  646. 		$msgType = "text";

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

  648. 	

  649. 		/*if ($word=='寻路'){

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

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

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

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

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

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

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

  657. 					$content = array();

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

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

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

  661. 						elseif($k==2){

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

  663. 						}

  664. 						else

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

  666. 					}

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

  668. 					if(is_array($content)){

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

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

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

  672. 							return $result;

  673. 						}

  674. 					}

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

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

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

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

  679. 			return $result;

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

  681. 			$contentStr="http://xmwxc.zhizhuchuxing.cn/ZZDZ/dzbs_login.php";

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

  683. 			return $resultStr;

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

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

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

  687. （＃号需输入，不可跳过，订单号请查找佰廉国旅为您发送的手机短信）

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

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

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

  691. 			return $resultStr;

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

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

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

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

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

  697. 			}

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

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

  700. 			}else{

  701. 				$pdo=conn();

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

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

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

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

  706. 				$result->closeCursor();

  707. 				$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]}";

  708. 				$pdo_update = conn();

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

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

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

  712. 				}else{

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

  714. 				}

  715. 				

  716. 			}

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

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

  719. 			return $resultStr;

  720. 			

  721. 			

  722. 		} else{

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

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

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

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

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

  728. 			return $resultStr;

  729. 		}*/

  730. 		

  731. 		

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

  733. 		

  734. 	}

  735. 	private function simsimiHttp($msg){

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

  737. 		$res = file_get_contents($url);

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

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

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

  741. 		}

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

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

  744. 		}

  745. 		return $res;

  746. 	}

  747. 	private function checkAccessToken($check){

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

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

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

  751. 			if(!$result){

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

  753. 				return false;

  754. 			}

  755. 		$result_obj=json_decode($result);

  756. 		

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

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

  759. 		return $result_obj->access_token;

  760. 		}

  761. 	}

  762. }

  763. ?>