微信公众平台PHP开发自动回复机器人

Test

                                本系列教程以微信公众平台应用妈妈助手（账号mmhelper:发送食物名称或拼音首字母查询孕妇、坐月子、宝宝能不能吃哪些食物。发送自己的位置查询附近的母婴类商家，以及促销、团购等信息。发送与宝宝的合照测试与宝宝的脸部相似度）为例，讲解微信接口开发过程。欢迎大家关注该账号，二维码见底部图。

        使用前提条件：拥有一个公网上的HTTP服务器主机空间，具有创建目录、上传文件等权限。推荐新浪的SAE。http://sae.sina.com.cn/

        首先请注册微信公众平台的账号，注册地址：http://mp.weixin.qq.com/

        本教程主要讲解接口的开发流程。
        事例代码也跑不通。我研究了一番，终于搞定。方法如下：

        一、写好接口程序

        在你的服务器上上传好一个接口程序文件，如http://www.yourdomain.com/weixin.php  内容如下：

1. <?php
   
2. define("TOKEN", "weixin");//自己定义的token 就是个通信的私钥
   
3. $wechatObj = new wechatCallbackapiTest();
   
4. $wechatObj->valid();
   
5. //$wechatObj->responseMsg();
   
6. class wechatCallbackapiTest
   
7. {
   
8.     public function valid()
   
9.     {
   
10.         $echoStr = $_GET["echostr"];
    
11.         if($this->checkSignature()){
    
12.             echo $echoStr;
    
13.             exit;
    
14.         }
    
15.     }
    
16.     public function responseMsg()
    
17.     {
    
18.         $postStr = $GLOBALS["HTTP_RAW_POST_DATA"];
    
19.         if (!empty($postStr)){
    
20.             $postObj = simplexml_load_string($postStr, 'SimpleXMLElement',
    
21. LIBXML_NOCDATA);
    
22.             $fromUsername = $postObj->FromUserName;
    
23.             $toUsername = $postObj->ToUserName;
    
24.             $keyword = trim($postObj->Content);
    
25.             $time = time();
    
26.             $textTpl = "<xml>
    
27.             <ToUserName><![CDATA[%s]]></ToUserName>
    
28.             <FromUserName><![CDATA[%s]]></FromUserName>
    
29.             <CreateTime>%s</CreateTime>
    
30.             <MsgType><![CDATA[%s]]></MsgType>
    
31.             <Content><![CDATA[%s]]></Content>
    
32.             <FuncFlag>0<FuncFlag>
    
33.             </xml>";
    
34.             if(!empty( $keyword ))
    
35.             {
    
36.                 $msgType = "text";
    
37.                 $contentStr = '你好啊，屌丝';
    
38.                 $resultStr = sprintf($textTpl, $fromUsername, $toUsername,
    
39. $time, $msgType, $contentStr);
    
40.                 echo $resultStr;
    
41.             }else{
    
42.                 echo '咋不说哈呢';
    
43.             }
    
44.         }else {
    
45.             echo '咋不说哈呢';
    
46.             exit;
    
47.         }
    
48.     }
    
49. 
    
50.     private function checkSignature()
    
51.     {
    
52.         $signature = $_GET["signature"];
    
53.         $timestamp = $_GET["timestamp"];
    
54.         $nonce = $_GET["nonce"];
    
55.         $token =TOKEN;
    
56.         $tmpArr = array($token, $timestamp, $nonce);
    
57.         sort($tmpArr);
    
58.         $tmpStr = implode( $tmpArr );
    
59.         $tmpStr = sha1( $tmpStr );
    
60. 
    
61.         if( $tmpStr == $signature ){
    
62.             return true;
    
63.         }else{
    
64.             return false;
    
65.         }
    
66.     }
    
67. }
    
68. ?>

复制代码

        二、配置微信公众平台回复接口
设置回复接口，填好URL和Token（url填上面的http://www.yourdomain.com/weixin.php，token必须跟上面程序里面定义的Token一致）

        三、验证接口
用自己的个人微信关注下你的公众账号，给这个账号发一条消息过去，收到原样的消息返回，即验证成功了。

四、开始自定义回复
注释掉$wechatObj->valid(); 这行，同时去掉//$wechatObj->responseMsg();这行的注释。
        你可以修改responseMsg函数里面的代码，根据用户的消息类型（'text','image','location'）和消息内容来回复用户不同的内容。
消息接口就可以使用了，发个消息试试看吧？

封装weixin.class.php

        由于微信公众平台的通信使用的是特定格式的XML数据，每次接受和回复都要去做一大堆的数据处理。
我们就考虑在这个基础上做一次封装，weixin.class.php，代码如下：

1. <?php
   
2. class Weixin
   
3. {
   
4.     public $token = '';//token
   
5.     public
   
6. $debug =  false;//是否debug的状态标示，方便我们在调试的时候记录一些中间数据
   
7.     public $setFlag =
   
8. false;
   
9.     public $msgtype = 'text';   //('text','image','location')
   
10.    
    
11. public $msg = array();
    
12. 
    
13.     public function
    
14. __construct($token,$debug)
    
15.     {
    
16.         $this->token =
    
17. $token;
    
18.         $this->debug = $debug;
    
19.     }<br>　　　　
    
20. //获得用户发过来的消息（消息内容和消息类型  ）
    
21.     public function getMsg()
    
22.     {
    
23.       
    
24. $postStr = $GLOBALS["HTTP_RAW_POST_DATA"];
    
25.         if ($this->debug)
    
26. {
    
27.                         $this->write_log($postStr);
    
28.       
    
29. }
    
30.         if (!empty($postStr)) {
    
31.             $this->msg =
    
32. (array)simplexml_load_string($postStr, 'SimpleXMLElement',
    
33. LIBXML_NOCDATA);
    
34.             $this->msgtype =
    
35. strtolower($this->msg['MsgType']);
    
36.         }
    
37.     }<br>　　　　
    
38. //回复文本消息
    
39.     public function makeText($text='')
    
40.     {
    
41.       
    
42. $CreateTime = time();
    
43.         $FuncFlag = $this->setFlag ? 1 :
    
44. 0;
    
45.         $textTpl = "<xml>
    
46.            
    
47. <ToUserName><![CDATA[{$this->msg['FromUserName']}]]></ToUserName>
    
48.            
    
49. <FromUserName><![CDATA[{$this->msg['ToUserName']}]]></FromUserName>
    
50.            
    
51. <CreateTime>{$CreateTime}</CreateTime>
    
52.            
    
53. <MsgType><![CDATA[text]]></MsgType>
    
54.            
    
55. <Content><![CDATA[%s]]></Content>
    
56.            
    
57. <FuncFlag>%s</FuncFlag>
    
58.             </xml>";
    
59.       
    
60. return sprintf($textTpl,$text,$FuncFlag);
    
61.     }<br>　　　　
    
62. //根据数组参数回复图文消息
    
63.     public function makeNews($newsData=array())
    
64.    
    
65. {
    
66.         $CreateTime = time();
    
67.         $FuncFlag = $this->setFlag ? 1
    
68. : 0;
    
69.         $newTplHeader = "<xml>
    
70.            
    
71. <ToUserName><![CDATA[{$this->msg['FromUserName']}]]></ToUserName>
    
72.            
    
73. <FromUserName><![CDATA[{$this->msg['ToUserName']}]]></FromUserName>
    
74.            
    
75. <CreateTime>{$CreateTime}</CreateTime>
    
76.            
    
77. <MsgType><![CDATA[news]]></MsgType>
    
78.            
    
79. <Content><![CDATA[%s]]></Content>
    
80.            
    
81. <ArticleCount>%s</ArticleCount><Articles>";
    
82.       
    
83. $newTplItem = "<item>
    
84.            
    
85. <Title><![CDATA[%s]]></Title>
    
86.            
    
87. <Description><![CDATA[%s]]></Description>
    
88.            
    
89. <PicUrl><![CDATA[%s]]></PicUrl>
    
90.            
    
91. <Url><![CDATA[%s]]></Url>
    
92.            
    
93. </item>";
    
94.         $newTplFoot = "</Articles>
    
95.            
    
96. <FuncFlag>%s</FuncFlag>
    
97.             </xml>";
    
98.       
    
99. $Content = '';
    
100.         $itemsCount = count($newsData['items']);
     
101.       
     
102. $itemsCount = $itemsCount < 10 ? $itemsCount :
     
103. 10;//微信公众平台图文回复的消息一次最多10条
     
104.         if ($itemsCount) {
     
105.             foreach
     
106. ($newsData['items'] as $key => $item) {
     
107.                 if ($key<=9)
     
108. {
     
109.                     $Content .=
     
110. sprintf($newTplItem,$item['title'],$item['description'],$item['picurl'],$item['url']);
     
111.                
     
112. }
     
113.             }
     
114.         }
     
115.         $header =
     
116. sprintf($newTplHeader,$newsData['content'],$itemsCount);
     
117.         $footer =
     
118. sprintf($newTplFoot,$FuncFlag);
     
119.         return $header . $Content .
     
120. $footer;
     
121.     }
     
122.     public function reply($data)
     
123.     {
     
124.         if
     
125. ($this->debug) {
     
126.                   
     
127. $this->write_log($data);
     
128.         }
     
129.         echo $data;
     
130.     }
     
131.    
     
132. public function valid()
     
133.     {
     
134.         if ($this->checkSignature())
     
135. {
     
136.             if( $_SERVER['REQUEST_METHOD']=='GET' )
     
137.            
     
138. {
     
139.                 echo $_GET['echostr'];
     
140.                
     
141. exit;
     
142.             }
     
143.         }else{
     
144.            
     
145. write_log('认证失败');
     
146.             exit;
     
147.         }
     
148.     }
     
149.     private
     
150. function checkSignature()
     
151.     {
     
152.         $signature =
     
153. $_GET["signature"];
     
154.         $timestamp = $_GET["timestamp"];
     
155.       
     
156. $nonce = $_GET["nonce"];
     
157. 
     
158.         $tmpArr = array($this->token,
     
159. $timestamp, $nonce);
     
160.         sort($tmpArr);
     
161.         $tmpStr = implode(
     
162. $tmpArr );
     
163.         $tmpStr = sha1( $tmpStr );
     
164. 
     
165.         if( $tmpStr ==
     
166. $signature ){
     
167.             return true;
     
168.         }else{
     
169.            
     
170. return false;
     
171.         }
     
172.     }
     
173.     private function
     
174. write_log($log){<br>　　　　　　　//这里是你记录调试信息的地方  请自行完善  
     
175. 以便中间调试<br>　　　　}
     
176. }
     
177. ?>

复制代码

Test

        调用weixin.class.php

        把你的微信公众平台主接口文件（如前面定义的http://www.yourdomain.com/weixin.php）中，修改代码为：

1. <?php
   
2. 
   
3. include_once('weixin.class.php');//引用刚定义的微信消息处理类<br>define("TOKEN",
   
4. "mmhelper");<br>define('DEBUG', true);
   
5. $weixin = new
   
6. Weixin(TOKEN,DEBUG);//实例化
   
7. $weixin->getMsg();
   
8. $type =
   
9. $weixin->msgtype;//消息类型
   
10. $username =
    
11. $weixin->msg['FromUserName'];//哪个用户给你发的消息,这个$username是微信加密之后的，但是每个用户都是一一对应的
    
12. if
    
13. ($type==='text') {
    
14.     if ($weixin->msg['Content']=='Hello2BizUser')
    
15. {//微信用户第一次关注你的账号的时候，你的公众账号就会受到一条内容为'Hello2BizUser'的消息
    
16.         $reply =
    
17. $weixin->makeText('欢迎你关注妈妈助手哦，屌丝');
    
18.     }else{//这里就是用户输入了文本信息
    
19.       
    
20. $keyword = $weixin->msg['Content'];   //用户的文本消息内容
    
21.                
    
22. include_once("chaxun.php");//文本消息 调用查询程序
    
23.                 $chaxun= new
    
24. chaxun(DEBUG,$keyword,$username);
    
25.                 $results['items']
    
26. =$chaxun->search();//查询的代码
    
27.             
    
28.                 $reply =
    
29. $weixin->makeNews($results);
    
30.     }
    
31. }elseif ($type==='location')
    
32. {
    
33.       //用户发送的是位置信息  稍后的文章中会处理                 
    
34. }elseif
    
35. ($type==='image') {
    
36.       //用户发送的是图片 稍后的文章中会处理
    
37. }elseif ($type==='voice')
    
38. {   
    
39.       //用户发送的是声音 稍后的文章中会处理
    
40. }
    
41. $weixin->reply($reply);
    
42. 
    
43. ?>

复制代码

        查询代码

        还需要将数据库里面的查询结果格式化为特定的形式

1. <?php
   
2. public function search(){
   
3.        $record=array();  //定义返回结果的数组
   
4.       
   
5. $list = $this->search($this->keyword);//普通的根据关键词查询数据库的操作
   
6. 代码就不用分享了
   
7. 　　　　if(is_array($list)&&!empty($list)){               
   
8. 
   
9.                foreach($list as $msg){
   
10. 
    
11. 　　　　　　　　　　　　　　　　$record[]=array(//以下代码，将数据库中查询返回的数组格式化为微信返回消息能接收的数组形式，即title、description、picurl、url
    
12. 详见微信官方的文档描述
    
13.                     'title'
    
14. =>$msg['title'],
    
15.                     'description'
    
16. =>$msg['discription'],
    
17.                     'picurl' =>
    
18. $msg['pic_url'],
    
19.                     'url'
    
20. =>$msg['url']
    
21.                 );
    
22. 　　　　　　　　}
    
23. 　　　　}
    
24. 　　　　return
    
25. $record;
    
26. }
    
27. ?>

复制代码