微信开发模式（php）

一时失言乱红尘 2024-02-17 14:55 55阅读 0赞

才开始学习微信开发模式和PHP，在此记录以供后阅。

<?php
    /**
     * wechat php test
     */
    
    //define your token
    define( "TOKEN", "weixin" );
    $wechatObj = new wechatCallbackapiTest();
    if ( !isset( $_GET['echostr'] ) ) {
        $wechatObj->responseMsg();
    }else {
        $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 ) ) {
                /* libxml_disable_entity_loader is to prevent XML eXternal Entity Injection,
                       the best way is to check the validity of xml by yourself */
                libxml_disable_entity_loader( true );
                $postObj = simplexml_load_string( $postStr, 'SimpleXMLElement', LIBXML_NOCDATA );
                $RX_TYPE = trim( $postObj->MsgType );
                switch ( $RX_TYPE ) {
                case "text":
                    $resultStr = $this->receiveText( $postObj );
                    break;
                case "event":
                    $resultStr = $this->receiveEvent( $postObj );
                    break;
                default:
                    $resultStr = "";
                    break;
                }
                echo $resultStr;
            } else {
                echo "";
                exit;
            }
        }
    
        private function receiveText( $object ) {
            $getkeyword = $object->Content;
            switch ( $getkeyword ) {
            case '产品':
                $funcFlag = 0;
                $contentStr = "产品链接:http://www.xxx.com/products/";
                $resultStr = $this->transmitText( $object, $contentStr, $funcFlag );
                break;
            case '新闻':
                $funcFlag = 0;
                $contentStr ="新闻链接:http://www.xxx.com/news/";
                $resultStr = $this->transmitText( $object, $contentStr, $funcFlag );
                break;
            case '方案':
                $funcFlag = 0;
                $contentStr ="方案链接:http://www.xxx.com/articles/";
                $resultStr = $this->transmitText( $object, $contentStr, $funcFlag );
                break;
            case '我们':
                $funcFlag = 0;
                $contentStr ="我们链接:http://www.xxx.com/culture/?type=detail&id=1";
                $resultStr = $this->transmitText( $object, $contentStr, $funcFlag );
                break;
            default:
                break;
            }
    
            return $resultStr;
        }
    
        private function receiveEvent( $object ) {
            $contentStr = "";
            switch ( $object->Event ) {
            case "subscribe":
                $contentStr = "欢迎您关注xxx";
            case "unsubscribe":
                break;
            case "CLICK":
                switch ( $object->EventKey ) {
                case "V1001_GETCODE":
                    $contentStr = "xxx";
                    break;
                case "V1002_HISTORY":
                    $contentStr[] = array( "Title" =>"最后一条历史记录",
                        "Description" =>"xxx",
                        "PicUrl" =>"xxx",
                        "Url" =>"xxx" );
                    break;
                case "V2001_INTERDUCE":
                    $contentStr[] = array( "Title" =>"xxx",
                        "Description" =>"xxx",
                        "Url" =>"http://mp.weixin.qq.com/xxx" );
                    break;
                case "V3001_JOIN":
                    $getuid = $this->getUid( $object );
                    if ( $getuid==1 ) {
                        $contentStr = 'Could not connect: '.mysql_error();
                    }else {
                        $contentStr = "唯一码：".$getuid;
                    }
                    break;
                default:
                    $contentStr[] = array( "Title" =>"默认菜单回复",
                        "Description" =>"xxx",
                        "PicUrl" =>"xxx",
                        "Url" =>"xxx" );
                    break;
                }
                break;
            default:
                break;
    
            }
            if ( is_array( $contentStr ) ) {
                $resultStr = $this->transmitNews( $object, $contentStr );
            }else {
                $resultStr = $this->transmitText( $object, $contentStr );
            }
            return $resultStr;
        }
    
        private function transmitText( $object, $content, $funcFlag = 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, $funcFlag );
            return $resultStr;
        }
    
        private function transmitNews( $object, $arr_item, $funcFlag = 0 ) {
    
            if ( !is_array( $arr_item ) )
                return;
    
            $itemTpl = "<item>
                        <Title><![CDATA[%s]]></Title>
                        <Description><![CDATA[%s]]></Description>
                        <PicUrl><![CDATA[%s]]></PicUrl>
                        <Url><![CDATA[%s]]></Url>
                        </item>";
            $item_str = "";
            foreach ( $arr_item as $item )
                $item_str .= sprintf( $itemTpl, $item['Title'], $item['Description'], $item['PicUrl'], $item['Url'] );
    
            $newsTpl = "<xml>
                        <ToUserName><![CDATA[%s]]></ToUserName>
                        <FromUserName><![CDATA[%s]]></FromUserName>
                        <CreateTime>%s</CreateTime>
                        <MsgType><![CDATA[news]]></MsgType>
                        <Content><![CDATA[]]></Content>
                        <ArticleCount>%s</ArticleCount>
                        <Articles>$item_str</Articles>
                        <FuncFlag>%s</FuncFlag>
                        </xml>";
            $resultStr = sprintf( $newsTpl, $object->FromUserName, $object->ToUserName, time(), count( $arr_item ), $funcFlag );
            return $resultStr;
        }
    
        /* 生成唯一码*/
        public function getUid( $object ) {
            $getOpenid = $object->FromUserName;
            $con = mysql_connect( "localhost", "root", "xxx" );
            mysql_select_db( "xxx", $con );
            if ( !$con ) {
                return 1;
            }
            $flag = true;
            $getUserresult = mysql_query( "SELECT * FROM loginuser WHERE openid = '".$getOpenid."'" );
            $getuserrow = mysql_num_rows( $getUserresult );
            if ( $getuserrow>0 ) {
                $userrow = mysql_fetch_array( $getUserresult );
                if ( $userrow['state']==0 ) {
                    return $userrow['userPassword']."[未完成考试]";
                    $flag = false;
                }else {
                    return $userrow['userPassword']."[已完成考试]";
                    $flag = false;
                }
            }
            /* 循环确定唯一性 */
            while ( $flag ) {
                $uid = uniqid( true );
                $uid = substr( $uid, -8 );
                $result = mysql_query( "SELECT * FROM loginuser where userPassword = '".$uid."'" );
                $row = mysql_num_rows( $result );
                if ( $row == 0 ) {
                    mysql_query( "INSERT INTO loginuser (userPassword,state,openid) VALUES ('".$uid."','0','".$getOpenid."')" );
                    mysql_close( $con );
                    return $uid;
                    $flag =false;
    
                }
            }
    
        }
        private function getUidtest( $object ) {
            return $object->FromUserName;
        }
        private function checkSignature() {
            // you must define TOKEN by yourself
            if ( !defined( "TOKEN" ) ) {
                throw new Exception( 'TOKEN is not defined!' );
            }
    
            $signature = $_GET["signature"];
            $timestamp = $_GET["timestamp"];
            $nonce = $_GET["nonce"];
    
            $token = TOKEN;
            $tmpArr = array( $token, $timestamp, $nonce );
            // use SORT_STRING rule
            sort( $tmpArr, SORT_STRING );
            $tmpStr = implode( $tmpArr );
            $tmpStr = sha1( $tmpStr );
    
            if ( $tmpStr == $signature ) {
                return true;
            }else {
                return false;
            }
        }
    }
    
    ?>