微信公众平台开发（三） 订阅事件（subscribe）处理

一、简介

新用户关注微信公众平台，将产生一个订阅事件，即subscribe事件，默认代码中没有对这一事件进行相应回复处理。

在新用户关注公众平台后，可能想知道该平台提供了哪些功能，以及怎样使用该平台，通俗一点讲就是该平台的“使用说明书”。

本文将详细讲述对subscribe事件的处理过程，回复相应信息提升交互性。

二、思路分析

微信目前提供了五种消息类型，分别为：

• 文本消息（text）；
• 图片消息（image）；
• 地理位置消息（location）；
• 链接消息（link）；
• 事件推送（event）；
  

接收到消息后，首先需要对消息类型做出判断，然后再针对不同类型的消息做出处理。在事件推送中，事件类型又分为三种，subscribe（订阅）、unsubscribe（取消订阅）、CLICK（自定义菜单点击事件），还需要再加一次判断；判断为subscribe事件后，根据设定好的欢迎消息，回复给用户。

三、判断消息类型

1. $postObj = simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);
   
2. $RX_TYPE = trim($postObj->MsgType);
   
3. 
   
4. switch($RX_TYPE)
   
5. {
   
6.     case "text":
   
7.         $resultStr = $this->handleText($postObj);
   
8.         break;
   
9.     case "event":
   
10.         $resultStr = $this->handleEvent($postObj);
    
11.         break;
    
12.     default:
    
13.         $resultStr = "Unknow msg type: ".$RX_TYPE;
    
14.         break;
    
15. }

复制代码

说明：

$RX_TYPE = trim($postObj->MsgType); 　　得到消息类型；

case "text":
　　$resultStr = $this->handleText($postObj); 　　使用handleText() 函数处理文本消息；

case "event":
　　$resultStr = $this->handleEvent($postObj); 　　使用handleEvent() 函数处理事件推送；

四、判断事件类型

1. switch ($object->Event)
   
2. {
   
3.     case "subscribe":
   
4.         $contentStr = "感谢您关注【卓锦苏州】"."\n"."微信号：zhuojinsz"."\n"."卓越锦绣，名城苏州，我们为您提供苏州本地生活指南，苏州相关信息查询，做最好的苏州微信平台。"."\n"."目前平台功能如下："."\n"."【1】 查天气，如输入：苏州天气"."\n"."【2】 查公交，如输入：苏州公交178"."\n"."【3】 翻译，如输入：翻译I love you"."\n"."【4】 苏州信息查询，如输入：苏州观前街"."\n"."更多内容，敬请期待...";
   
5.         break;
   
6.     default :
   
7.         $contentStr = "Unknow Event: ".$object->Event;
   
8.         break;
   
9. }

复制代码

说明：

如果是subscribe事件，设定回复内容为“感谢您关注【卓锦苏州】...”；

五、完整代码

1. <?php
   
2. /**
   
3.   * wechat php test
   
4.   */
   
5. 
   
6. //define your token
   
7. define("TOKEN", "zhuojin");
   
8. $wechatObj = new wechatCallbackapiTest();
   
9. $wechatObj->responseMsg();
   
10. //$wechatObj->valid();
    
11. 
    
12. class wechatCallbackapiTest
    
13. {
    
14.     /*public function valid()
    
15.     {
    
16.         $echoStr = $_GET["echostr"];
    
17. 
    
18.         //valid signature , option
    
19.         if($this->checkSignature()){
    
20.             echo $echoStr;
    
21.             exit;
    
22.         }
    
23.     }*/
    
24. 
    
25.     public function responseMsg()
    
26.     {
    
27.         //get post data, May be due to the different environments
    
28.         $postStr = $GLOBALS["HTTP_RAW_POST_DATA"];
    
29. 
    
30.         //extract post data
    
31.         if (!empty($postStr)){
    
32.                 
    
33.                 $postObj = simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);
    
34.                 $RX_TYPE = trim($postObj->MsgType);
    
35. 
    
36.                 switch($RX_TYPE)
    
37.                 {
    
38.                     case "text":
    
39.                         $resultStr = $this->handleText($postObj);
    
40.                         break;
    
41.                     case "event":
    
42.                         $resultStr = $this->handleEvent($postObj);
    
43.                         break;
    
44.                     default:
    
45.                         $resultStr = "Unknow msg type: ".$RX_TYPE;
    
46.                         break;
    
47.                 }
    
48.                 echo $resultStr;
    
49.         }else {
    
50.             echo "";
    
51.             exit;
    
52.         }
    
53.     }
    
54. 
    
55.     public function handleText($postObj)
    
56.     {
    
57.         $fromUsername = $postObj->FromUserName;
    
58.         $toUsername = $postObj->ToUserName;
    
59.         $keyword = trim($postObj->Content);
    
60.         $time = time();
    
61.         $textTpl = "<xml>
    
62.                     <ToUserName><![CDATA[%s]]></ToUserName>
    
63.                     <FromUserName><![CDATA[%s]]></FromUserName>
    
64.                     <CreateTime>%s</CreateTime>
    
65.                     <MsgType><![CDATA[%s]]></MsgType>
    
66.                     <Content><![CDATA[%s]]></Content>
    
67.                     <FuncFlag>0</FuncFlag>
    
68.                     </xml>";             
    
69.         if(!empty( $keyword ))
    
70.         {
    
71.             $msgType = "text";
    
72.             $contentStr = "Welcome to wechat world!";
    
73.             $resultStr = sprintf($textTpl, $fromUsername, $toUsername, $time, $msgType, $contentStr);
    
74.             echo $resultStr;
    
75.         }else{
    
76.             echo "Input something...";
    
77.         }
    
78.     }
    
79. 
    
80.     public function handleEvent($object)
    
81.     {
    
82.         $contentStr = "";
    
83.         switch ($object->Event)
    
84.         {
    
85.             case "subscribe":
    
86.                 $contentStr = "感谢您关注【卓锦苏州】"."\n"."微信号：zhuojinsz"."\n"."卓越锦绣，名城苏州，我们为您提供苏州本地生活指南，苏州相关信息查询，做最好的苏州微信平台。"."\n"."目前平台功能如下："."\n"."【1】 查天气，如输入：苏州天气"."\n"."【2】 查公交，如输入：苏州公交178"."\n"."【3】 翻译，如输入：翻译I love you"."\n"."【4】 苏州信息查询，如输入：苏州观前街"."\n"."更多内容，敬请期待...";
    
87.                 break;
    
88.             default :
    
89.                 $contentStr = "Unknow Event: ".$object->Event;
    
90.                 break;
    
91.         }
    
92.         $resultStr = $this->responseText($object, $contentStr);
    
93.         return $resultStr;
    
94.     }
    
95.     
    
96.     public function responseText($object, $content, $flag=0)
    
97.     {
    
98.         $textTpl = "<xml>
    
99.                     <ToUserName><![CDATA[%s]]></ToUserName>
    
100.                     <FromUserName><![CDATA[%s]]></FromUserName>
     
101.                     <CreateTime>%s</CreateTime>
     
102.                     <MsgType><![CDATA[text]]></MsgType>
     
103.                     <Content><![CDATA[%s]]></Content>
     
104.                     <FuncFlag>%d</FuncFlag>
     
105.                     </xml>";
     
106.         $resultStr = sprintf($textTpl, $object->FromUserName, $object->ToUserName, time(), $content, $flag);
     
107.         return $resultStr;
     
108.     }
     
109. 
     
110.     private function checkSignature()
     
111.     {
     
112.         $signature = $_GET["signature"];
     
113.         $timestamp = $_GET["timestamp"];
     
114.         $nonce = $_GET["nonce"];    
     
115.                 
     
116.         $token = TOKEN;
     
117.         $tmpArr = array($token, $timestamp, $nonce);
     
118.         sort($tmpArr);
     
119.         $tmpStr = implode( $tmpArr );
     
120.         $tmpStr = sha1( $tmpStr );
     
121.         
     
122.         if( $tmpStr == $signature ){
     
123.             return true;
     
124.         }else{
     
125.             return false;
     
126.         }
     
127.     }
     
128. }
     
129. 
     
130. ?>

复制代码

源码：<?php

/**

  * wechat php test

  */

//define your token

define("TOKEN", "weixin");

$wechatObj = new wechatCallbackapiTest();

$wechatObj->responseMsg();

//$wechatObj->valid();

class wechatCallbackapiTest

{

    /*public function valid()

    {

        $echoStr = $_GET["echostr"];

        //valid signature , option

        if($this->checkSignature()){

            echo $echoStr;

            exit;

        }

    }*/

    public function responseMsg()

    {

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

        $postStr = $GLOBALS["HTTP_RAW_POST_DATA"];

        //extract post data

        if (!empty($postStr)){

                

                $postObj = simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);

                $RX_TYPE = trim($postObj->MsgType);

                switch($RX_TYPE)

                {

                    case "text":

                        $resultStr = $this->handleText($postObj);

                        break;

                    case "event":

                        $resultStr = $this->handleEvent($postObj);

                        break;

                    default:

                        $resultStr = "Unknow msg type: ".$RX_TYPE;

                        break;

                }

                echo $resultStr;

        }else {

            echo "";

            exit;

        }

    }

    public function handleText($postObj)

    {

        $fromUsername = $postObj->FromUserName;

        $toUsername = $postObj->ToUserName;

        $keyword = trim($postObj->Content);

        $time = time();

        $textTpl = "<xml>

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

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

                    <CreateTime>%s</CreateTime>

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

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

                    <FuncFlag>0</FuncFlag>

                    </xml>";             

        if(!empty( $keyword ))

        {

            $msgType = "text";

            $contentStr = "Welcome to zhuzhipeng world!";

            $resultStr = sprintf($textTpl, $fromUsername, $toUsername, $time, $msgType, $contentStr);

            echo $resultStr;

        }else{

            echo "Input something...";

        }

    }

    public function handleEvent($object)

    {

        $contentStr = "";

        switch ($object->Event)

        {

            case "subscribe":

                $contentStr = "感谢您关注【卓锦苏州】"."\n"."微信号：zhuojinsz"."\n"."卓越锦绣，名城苏州，我们为您提供苏州本地生活指南，苏州相关信息查询，做最好的苏州微信平台。"."\n"."目前平台功能如下："."\n"."【1】 查天气，如输入：苏州天气"."\n"."【2】 查公交，如输入：苏州公交178"."\n"."【3】 翻译，如输入：翻译I love you"."\n"."【4】 苏州信息查询，如输入：苏州观前街"."\n"."更多内容，敬请期待...";

                break;

            default :

                $contentStr = "Unknow Event: ".$object->Event;

                break;

        }

        $resultStr = $this->responseText($object, $contentStr);

        return $resultStr;

    }

    

    public function responseText($object, $content, $flag=0)

    {

        $textTpl = "<xml>

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

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

                    <CreateTime>%s</CreateTime>

                    <MsgType><![CDATA[text]]></MsgType>

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

                    <FuncFlag>%d</FuncFlag>

                    </xml>";

        $resultStr = sprintf($textTpl, $object->FromUserName, $object->ToUserName, time(), $content, $flag);

        return $resultStr;

    }

    private function checkSignature()

    {

        $signature = $_GET["signature"];

        $timestamp = $_GET["timestamp"];

        $nonce = $_GET["nonce"];    

                

        $token = TOKEN;

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

        sort($tmpArr);

        $tmpStr = implode( $tmpArr );

        $tmpStr = sha1( $tmpStr );

        

        if( $tmpStr == $signature ){

            return true;

        }else{

            return false;

        }

    }

}

?>