码迷，mamicode.com
首页 > 微信 > 详细

夺命雷公狗---微信开发31----微信群发消息4

时间：2016-03-02 20:04:12      阅读：447      评论：0      收藏：0      [点我收藏+]

标签：

index.php代码如下：

<?php
/**
  * wechat php test
  */

//define your token
require_once "common.php";
//这里是引入curl发送函数的类
require_once ‘WeChat.class.php‘;
define("TOKEN", "twgdh");

//这里让这个类继承了curl发送参数的类
class wechatCallbackapiTest extends WeChat
{
    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 */
                // 使用simplexml技术对xml进行解析 
                // libxml_disable_entity_loader(true), 是从安全性考虑，为了防止xml外部注入，
                //只对xml内部实体内容进行解析
                libxml_disable_entity_loader(true);
                //加载 postStr 字符串
                $postObj = simplexml_load_string($postStr, ‘SimpleXMLElement‘, LIBXML_NOCDATA);
                $fromUsername = $postObj->FromUserName;
                $toUsername = $postObj->ToUserName;
                $keyword = trim($postObj->Content);
                $time = time();
                global $tmp_arr;
                
                //当用户公众号有互动时，我们将会动hd_time字段更新
                $connect = mysql_connect(‘localhost‘,‘root‘,‘root‘) or die(‘数据库链接失败‘);
                mysql_select_db(‘wxdb‘,$connect);
                mysql_query(‘set names utf8‘);
                $sql = "update qf_users set hd_time=‘{$time}‘ where openid=‘{$fromUsername}‘";
                mysql_query($sql, $connect);
                
                //根据接收到的消息类型，来进行分支处理(switch)
                switch($postObj->MsgType)
                {
                    case ‘event‘:
                        if($postObj->Event == ‘subscribe‘)
                        {
                            
                            $contentStr = "欢迎关注leigood微信测试号噢";
                            $resultStr = sprintf($tmp_arr[‘text‘], $fromUsername, $toUsername, $time, $contentStr);
                            echo $resultStr; 
                            
                            //消息回复后，我们将该用户加入qf_users表里面
                            $time = time();
                            $sql = "insert into qf_users (id,openid,hd_time) values(NULL,‘{$fromUsername}‘,‘{$time}‘)";
                            mysql_query($sql,$connect);
                        }
                        
                        //如果对方取消关注了，那么我们就需要从数据库里面删除掉
                        if($postObj->Event == ‘unsubscribe‘){
                            $sql = "delete from qf_users where openid=‘{$fromUsername}‘";
                            mysql_query($sql,$connect);
                        }
                        
                        break;
                    case ‘text‘: //回复文本模块
                        //这里开始测试客服消息接口了
                        if($keyword == ‘文本‘){
                           //获取token
                           require ‘get_token.php‘;
                           $contentStr = ‘这是客服接口的回复，我们可以帮助您什么？‘;
                           //对发送的内容进行urlencode编码，防止中文乱码
                           $contentStr = urlencode($contentStr);
                           //到时候我们我发送的内容我们放到一个数组里面去了
                           $content_arr = array(‘content‘=>"{$contentStr}");
                           //这里的意思是将来我要发送消息给这个用户
                           $reply_arr = array(‘touser‘=>"{$fromUsername}",‘msgtype‘=>‘text‘,‘text‘=>$content_arr);
                           //下一步就是将编码转成规定的json格式
                           $post = json_encode($reply_arr);
                           //url解码，如果不解码他将会发来一段二进制代码
                           $post = urldecode($post);
                           $url = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token={$access_token}";
                           //这里我们来使用类的继承机制，来简化代码
                           $this -> http_request($url,$post);
                           //这里是可以回复多条消息的，只需要在执行下这个函数即可
                           //$this -> http_request($url,$post);
                        }else{
                            $contentStr = ‘您输入的格式有误‘;
                            $resultStr = sprintf($tmp_arr[‘text‘], $fromUsername, $toUsername, $time, $contentStr);
                            echo $resultStr;
                        }
                        break;
                    case ‘image‘: //处理用户上传图片
                        $media_id = $postObj -> MediaId; //获取到用户上传的图片的mediaid
                        $resultStr = sprintf($tmp_arr[‘image‘], $fromUsername, $toUsername, $time, $media_id);
                        echo $resultStr;
                        
                        //将图片保存到本地服务器的文件系统
                        //1.先给图片创建一个名字
                        $image_file_name = time().‘.jpg‘;
                        //2.获取该图片的内容
                        $image_file = file_get_contents($postObj->PicUrl);
                        //3.保存到本地服务器的文件系统
                        //提醒：一定要保证您创建的文件夹是www用户可读可写，否则无法保存该图片到文件夹下
                        file_put_contents("./uploadimage/".$image_file_name,$image_file);
                        
                        //将图片的路径和相关信息入库
                        //1.创建一张表
                        //2.链接mysql数据库，并且添加图片信息
                        $connect = mysql_connect(‘localhost‘,‘root‘,‘root‘);
                        mysql_select_db(‘wxdb‘,$connect);
                        mysql_query(‘set names utf8‘);
                        $media_path = "./uploadimage/".$image_file_name; //路径
                        $sql = "insert into keep_image_uploads (id,openid,media_id,media_path) values(NULL,‘{$fromUsername}‘,‘{$media_id}‘,‘{$media_path}‘)";
                        mysql_query($sql,$connect);
                        break;
                    case ‘voice‘: //处理用户上传语言的业务逻辑
                        $media_id = $postObj -> MediaId; //获取media_id的id号
                        $resultStr = sprintf($tmp_arr[‘voice‘], $fromUsername, $toUsername, $time, $media_id);
                        echo $resultStr;
                        break;
                    case ‘location‘: //处理用户上传的地理位置信息
                        $Location_X = $postObj -> Location_X; //获取上传地理位置的纬度
                        $Location_Y = $postObj -> Location_Y; //获取上传地地理位置经度
                        $contentStr = "您上报的地理位置是:\n经度是：{$Location_Y} \n纬度是: {$Location_X}";
                        $resultStr = sprintf($tmp_arr[‘text‘], $fromUsername, $toUsername, $time, $contentStr);
                        echo $resultStr;
                        break;
                    case ‘link‘: //接收并回复链接信息
                        //获取到用户上传的链接信息
                        $Title = $postObj -> Title;
                        $Url = $postObj -> Url;
                        $contentStr = "<a href=‘{$Url}‘>{$Title}</a>";
                        $resultStr = sprintf($tmp_arr[‘text‘], $fromUsername, $toUsername, $time, $contentStr);
                        echo $resultStr;
                        break;
                        
                }
        }else {
            echo "";
            exit;
        }
    }
        
    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;
        }
    }
}

//如果这段代码放在上面，那程序将会报错，因为继承的问题，会显示类没有找到
$wechatObj = new wechatCallbackapiTest();
//当接入成功后，请注销这句话，否则，会反复验证。
//$wechatObj->valid();
//添加响应请求的语句
$wechatObj->responseMsg();

?>

 

 

然后修改模版代码，common.php代码如下所示：

<?php
    $tmp_arr = array(
    ‘text‘ => <<<XML
<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[%s]]></Content>
<FuncFlag>0</FuncFlag>
</xml>
XML
,
    ‘image‘=> <<<XML
<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[image]]></MsgType>
<Image>
<MediaId><![CDATA[%s]]></MediaId>
</Image>
</xml>
XML
,
    ‘voice‘=> <<<XML
<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[voice]]></MsgType>
<Voice>
<MediaId><![CDATA[%s]]></MediaId>
</Voice>
</xml>
XML
,
    ‘music‘=> <<<XML
<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[music]]></MsgType>
<Music>
<Title><![CDATA[%s]]></Title>
<Description><![CDATA[%s]]></Description>
<MusicUrl><![CDATA[%s]]></MusicUrl>
<HQMusicUrl><![CDATA[%s]]></HQMusicUrl>
</Music>
</xml>
XML
,
    ‘singlenews‘=> <<<XML
<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[news]]></MsgType>
<ArticleCount>1</ArticleCount>
<Articles>
<item>
<Title><![CDATA[%s]]></Title> 
<Description><![CDATA[%s]]></Description>
<PicUrl><![CDATA[%s]]></PicUrl>
<Url><![CDATA[%s]]></Url>
</item>
</Articles>
</xml> 
XML
,
    ‘newses‘=> <<<XML
<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[news]]></MsgType>
<ArticleCount>4</ArticleCount>
<Articles>
<item>
<Title><![CDATA[%s]]></Title> 
<Description><![CDATA[%s]]></Description>
<PicUrl><![CDATA[%s]]></PicUrl>
<Url><![CDATA[%s]]></Url>
</item>
<item>
<Title><![CDATA[%s]]></Title> 
<Description><![CDATA[%s]]></Description>
<PicUrl><![CDATA[%s]]></PicUrl>
<Url><![CDATA[%s]]></Url>
</item>
<item>
<Title><![CDATA[%s]]></Title> 
<Description><![CDATA[%s]]></Description>
<PicUrl><![CDATA[%s]]></PicUrl>
<Url><![CDATA[%s]]></Url>
</item>
<item>
<Title><![CDATA[%s]]></Title> 
<Description><![CDATA[%s]]></Description>
<PicUrl><![CDATA[%s]]></PicUrl>
<Url><![CDATA[%s]]></Url>
</item>
</Articles>
</xml> 
XML
,
    ‘video‘=> <<<XML
<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[video]]></MsgType>
<Video>
<MediaId><![CDATA[%s]]></MediaId>
<Title><![CDATA[%s]]></Title>
<Description><![CDATA[%s]]></Description>
</Video> 
</xml>
XML
);

        function http_request($url, $data=null){
            //我们使用curl函数
            //初始化
            $ch = curl_init();
            //设置变量
            curl_setopt($ch, CURLOPT_URL,$url); //这意思是，设置好发送的url地址发送到那
            //curl_setopt($ch, CURLOPT_SSL_VERIFYPEER,$url); 这样的意思是对方要不要验证，如果不用则按照下面的即可
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER,FALSE); //如果不用验证，这样即可
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST,FALSE); //如果不用验证HOST主机这样即可
            if(!empty($data)){
                curl_setopt($ch,CURLOPT_POST,1);//启用时会发送一个常规的POST请求，就像表单提交的一样。
                curl_setopt($ch,CURLOPT_POSTFIELDS,$data);//全部数据使用HTTP协议中的"POST"操作来
            }
            curl_setopt($ch, CURLOPT_RETURNTRANSFER,1); //将curl_exec()获取的信息以文件流的形式返回，而不是直接输出
            //执行
            $output = curl_exec($ch); //返回来的值是一个json格式的值
            //关闭句柄
            curl_close($ch);
            return $output;
        }

 

get_token.php代码如下所示：

<?php
    //原理，就是使用curl函数，发出http请求，获取access_token
    $appid = ‘wxed89d8f74fa6fc51‘;
    $appsecret = ‘d4624c36b6795d1d99dcf0547af5443d‘;
    $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$appid}&secret={$appsecret}";
    
    //我们使用curl函数
    //初始化
    $ch = curl_init();
    //设置变量
    curl_setopt($ch, CURLOPT_URL,$url); //这意思是，设置好发送的url地址发送到那
    //curl_setopt($ch, CURLOPT_SSL_VERIFYPEER,$url); 这样的意思是对方要不要验证，如果不用则按照下面的即可
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER,FALSE); //如果不用验证，这样即可
    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST,FALSE); //如果不用验证HOST主机这样即可
    curl_setopt($ch, CURLOPT_RETURNTRANSFER,1); //将curl_exec()获取的信息以文件流的形式返回，而不是直接输出
    //执行
    $output = curl_exec($ch); //返回来的值是一个json格式的值
    //关闭句柄
    curl_close($ch);
    //对返回的json结果要将他转为一个数组
    $jsoninfo = json_decode($output,true);
    //测试以下，看下是否拿到返的回数组
    //var_dump($jsoninfo); 
    
    $access_token = $jsoninfo[‘access_token‘];
<?php
    //原理，就是使用curl函数，发出http请求，获取access_token
    $appid = ‘wxed89d8f74fa6fc51‘;
    $appsecret = ‘d4624c36b6795d1d99dcf0547af5443d‘;
    $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$appid}&secret={$appsecret}";
    
    //我们使用curl函数
    //初始化
    $ch = curl_init();
    //设置变量
    curl_setopt($ch, CURLOPT_URL,$url); //这意思是，设置好发送的url地址发送到那
    //curl_setopt($ch, CURLOPT_SSL_VERIFYPEER,$url); 这样的意思是对方要不要验证，如果不用则按照下面的即可
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER,FALSE); //如果不用验证，这样即可
    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST,FALSE); //如果不用验证HOST主机这样即可
    curl_setopt($ch, CURLOPT_RETURNTRANSFER,1); //将curl_exec()获取的信息以文件流的形式返回，而不是直接输出
    //执行
    $output = curl_exec($ch); //返回来的值是一个json格式的值
    //关闭句柄
    curl_close($ch);
    //对返回的json结果要将他转为一个数组
    $jsoninfo = json_decode($output,true);
    //测试以下，看下是否拿到返的回数组
    //var_dump($jsoninfo); 
    
    $access_token = $jsoninfo[‘access_token‘];

 

 

qf.php代码如下：

<?php
    header("Content-Type:text/html;Charset=utf-8");
    //获取token
    require_once ‘get_token.php‘;
    require_once ‘common.php‘;
    //链接数据库取出所有48小时内互动过的用户
    $connect = mysql_connect(‘localhost‘,‘root‘,‘root‘) or die(‘数据库连接失败‘);
    mysql_select_db(‘wxdb‘,$connect);
    mysql_query(‘set names utf8‘);
    //在48小时内互动过的用户
    $time = time()-48*3600;
    $sql = "select openid from qf_users where hd_time>‘{$time}‘";
    $res = mysql_query($sql);
    $row = array();
    //循环取出48小时用过的用户
    while($row = mysql_fetch_assoc($res)){
        //这里可以写得更人性化一点，通过表单post过来即可
        $contentStr = "这是调试消息群发接口的";
        //将openid压进$fromUsername变量里面
        $fromUsername = $row[‘openid‘];
        //因为可能会存在中文所以需要url编码
        $contentStr = urlencode($contentStr);
         //到时候我们我发送的内容我们放到一个数组里面去了
         $content_arr = array(‘content‘=>"{$contentStr}");
         //这里的意思是将来我要发送消息给这个用户
        $reply_arr = array(‘touser‘=>"{$fromUsername}",‘msgtype‘=>‘text‘,‘text‘=>$content_arr);
        //下一步就是将编码转成规定的json格式
        $post = json_encode($reply_arr);
        //url解码，如果不解码他将会发来一段二进制代码
        $post = urldecode($post);
        $url = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token={$access_token}";
        //这里我们来使用类的继承机制，来简化代码
        http_request($url,$post);
    }
    
    echo "恭喜您，您已经成功群发消息";

 

然后在浏览器上进行访问qf.php即可实现群发功能，每刷以下，消息即可群发一条，但注意的是公众号是和客户互动48小时内的客户才可收到消息

夺命雷公狗---微信开发31----微信群发消息4

标签：

原文地址：http://www.cnblogs.com/leigood/p/5236161.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！