最全面 think php 实现微信公众号回复编号进行投票，自定义菜单功能

    public function test(){
        $nonce     = $_GET[‘nonce‘];
        $token     = ‘*******‘;
        $timestamp = $_GET[‘timestamp‘];
        $echostr   = $_GET[‘echostr‘];
        $signature = $_GET[‘signature‘];
        //形成数组，然后按字典序排序
        $array = array();
        $array = array($nonce, $timestamp, $token);
        sort($array);
        //拼接成字符串,sha1加密 ，然后与signature进行校验
        $str = sha1( implode( $array ) );
        echo  $echostr;
        exit;
    }

$file_in = file_get_contents("php://input"); //接收post数据
//用SimpleXML解析POST过来的XML数据
$postObj = simplexml_load_string($file_in,‘SimpleXMLElement‘,LIBXML_NOCDATA);
$fromUsername = $postObj->FromUserName; //获取发送方帐号（OpenID）
$toUsername = $postObj->ToUserName; //获取接收方账号
$keyword = trim($postObj->Content); //获取消息内容
$masType = $postObj->MsgType;//获取消息类型，可以作分类判断。本例默认是文本消息，不做判断
$time = time(); //获取当前时间戳








//---------- 返 回 数 据 ---------- //
//返回消息模板
$textTpl = "<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[%s]]></MsgType>
<Content><![CDATA[%s]]></Content>
</xml>";

        $msgType = "text"; //消息类型
        if($masType != ‘text‘){
            $contentStr = "回复内容*****";
        }else if(trim($keyword) == ‘‘){
            $contentStr = "发送不能为空";
        }else if(is_numeric($keyword)){
            if(!is_numeric($keyword)||strpos($keyword,".")!==false){
                $contentStr = "编号不正确，请查询后再进行投票";
                $resultStr = sprintf($textTpl,$fromUsername,$toUsername,$time,$msgType,$contentStr);
                echo $resultStr;
                return;
            }
            $data1[‘toupiao_time‘] = date("Y-m-d");

            $message = M(‘message_cun‘);

            $b = $message->where("member_id = ‘%s‘ and ip = ‘%s‘ and toupiao_time = ‘%s‘",$keyword,$fromUsername,$data1[‘toupiao_time‘])->count();
            if($b > 0 ){
                $contentStr = "您已对该项投票，请明天再来！";
                $resultStr = sprintf($textTpl,$fromUsername,$toUsername,$time,$msgType,$contentStr);
                echo $resultStr;
                return;
            }
            $a = $message->where("ip = ‘%s‘ and toupiao_time = ‘%s‘",$fromUsername,$data1[‘toupiao_time‘])->count();
            if ($a >= 10) {
                $contentStr = "您已投满10票，请明天再来！";
                $resultStr = sprintf($textTpl,$fromUsername,$toUsername,$time,$msgType,$contentStr);
                echo $resultStr;
                return;
            }else{
                $data[‘member_id‘] = $keyword;
                $data[‘ip‘] =(string) $fromUsername;
                $data[‘userName‘] = (string) $toUsername;
                $data[‘toupiao_time‘] = date("Y-m-d");
                $res = $message->data($data)->add();
                if($res){
                    $contentStr = "投票成功";
                    $resultStr = sprintf($textTpl,$fromUsername,$toUsername,$time,$msgType,$contentStr);
                    echo $resultStr;
                }
            }
        }else{
            $contentStr = "******回复内容";
        }

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

    public function http($url, $method, $postfields = null, $headers = array(), $debug = false)
    {
        $ci = curl_init();
        /* Curl settings */
        curl_setopt($ci, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
        curl_setopt($ci, CURLOPT_CONNECTTIMEOUT, 30);
        curl_setopt($ci, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($ci, CURLOPT_SSL_VERIFYHOST, FALSE);
        curl_setopt($ci, CURLOPT_TIMEOUT, 30);
        curl_setopt($ci, CURLOPT_RETURNTRANSFER, true);

        switch ($method) {
            case ‘POST‘:
                curl_setopt($ci, CURLOPT_POST, true);
                if (!empty($postfields)) {
                    curl_setopt($ci, CURLOPT_POSTFIELDS, $postfields);
                    $this->postdata = $postfields;
                }
                break;
        }
        curl_setopt($ci, CURLOPT_URL, $url);
        curl_setopt($ci, CURLOPT_HTTPHEADER, $headers);
        curl_setopt($ci, CURLINFO_HEADER_OUT, true);

        $response = curl_exec($ci);
        $http_code = curl_getinfo($ci, CURLINFO_HTTP_CODE);

        if ($debug) {
            echo "=====post data======\r\n";
            var_dump($postfields);

            echo ‘=====info=====‘ . "\r\n";
            print_r(curl_getinfo($ci));

            echo ‘=====$response=====‘ . "\r\n";
            print_r($response);
        }
        curl_close($ci);
//        return array($http_code, $response);
        return  $response;
    }

{
    "button": [
        {
            "name": "***", 
            "sub_button": [
                {
                    "type": "view", 
                    "name": "***", 
                    "url": "https://www.baidu.com/"
                } 
            ]
        }, 
        {
            "name": "***", 
            "sub_button": [
                {
                    "type": "miniprogram", 
                    "name": "小程序", 
                    "url": "****", 
                    "appid": "", 
                    "pagepath": ""
                }
            ]
        }
    ]
}

  $access_time = M("weixin_cun")->order("id desc")->getField("time");
        $time = time() - strtotime($access_time);
        if($time>2000){
            $url="https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=".$this->app_id."&secret=".$this->app_secret;
            $content = file_get_contents($url);
            $result = json_decode($content);
            $data[‘access_token‘] = $result->access_token;
            if(!empty($data[‘access_token‘])){
                $weixin = M("weixin_cun")->data($data)->add();
            }else{

            }
        }