微信开发模式（php）

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

<?php /** * wechat php test *///define your tokendefine( "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></tousername>                    <fromusername></fromusername>                    <createtime>%s</createtime>                    <msgtype></msgtype>                    <content></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></title>                    <description></description>                    <picurl></picurl>                    <url></url>                    </item>";        $item_str = "";        foreach ( $arr_item as $item )            $item_str .= sprintf( $itemTpl, $item['Title'], $item['Description'], $item['PicUrl'], $item['Url'] );        $newsTpl = "<xml>                    <tousername></tousername>                    <fromusername></fromusername>                    <createtime>%s</createtime>                    <msgtype></msgtype>                    <content></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;        }    }}?>