zoukankan      html  css  js  c++  java
  • 小程序客服消息接口,接入及消息接收

     
      public function index(){
         //判断是否为认证 
            if (isset($_GET['echostr'])) {
            //如果认证去验证
                $this->valid();
            }else{
            //否则接收客户发送消息
                $this->responseMsg();
            }
            
        }
      //验证前置方法
        public function valid()
        {
            $echoStr = $_GET["echostr"];
            if($this->checkSignature()){
                header('content-type:text');
                echo $echoStr;
                exit;
            }else{
                echo $echoStr.'+++'.TOKEN;
                exit;
            }
        }
    
      //签名校验
        private function checkSignature()
        {
         //微信加密签名
            $signature = $_GET["signature"];
         //时间戳
            $timestamp = $_GET["timestamp"];
         //随机数
            $nonce = $_GET["nonce"];
          //服务端配置的TOKEN
            $token = '自己配置的TOKEN';
        //将token,时间戳,随机数进行字典排序
            $tmpArr = array($token, $timestamp, $nonce);
            sort($tmpArr, SORT_STRING);
        //拼接字符串
            $tmpStr = implode( $tmpArr );
            $tmpStr = sha1( $tmpStr );
        
            if( $tmpStr == $signature ){
                return true;
            }else{
                return false;
            }
        }
        public function responseMsg()
        {
        //接收来自小程序的客户消息JSON
            $postStr = $GLOBALS["HTTP_RAW_POST_DATA"];
            if (!empty($postStr) && is_string($postStr)){
                //禁止引用外部xml实体
                //libxml_disable_entity_loader(true);
                
                //$postObj = simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);
                $postArr = json_decode($postStr,true);
                if(!empty($postArr['MsgType']) && $postArr['MsgType'] == 'text'){   //文本消息
                    $fromUsername = $postArr['FromUserName'];   //发送者openid
                    $toUserName = $postArr['ToUserName'];       //小程序id
                    $textTpl = array(
                        "ToUserName"=>$fromUsername,
                        "FromUserName"=>$toUserName,
                        "CreateTime"=>time(),
                        "MsgType"=>"transfer_customer_service",
                    );
                    exit(json_encode($textTpl));
                }elseif(!empty($postArr['MsgType']) && $postArr['MsgType'] == 'image'){ //图文消息
                    $fromUsername = $postArr['FromUserName'];   //发送者openid
                    $toUserName = $postArr['ToUserName'];       //小程序id
                    $textTpl = array(
                        "ToUserName"=>$fromUsername,
                        "FromUserName"=>$toUserName,
                        "CreateTime"=>time(),
                        "MsgType"=>"transfer_customer_service",
                    );
                    exit(json_encode($textTpl));
                }elseif($postArr['MsgType'] == 'event' && $postArr['Event']=='user_enter_tempsession'){ //进入客服动作
                    $fromUsername = $postArr['FromUserName'];   //发送者openid
                    $content = '您好,有什么能帮助你?';
                    $data=array(
                        "touser"=>$fromUsername,
                        "msgtype"=>"text",
                        "text"=>array("content"=>$content)
                    );
                    $json = json_encode($data,JSON_UNESCAPED_UNICODE);  //php5.4+
                    
                    $access_token = $this->get_accessToken();
                    /* 
                     * POST发送https请求客服接口api
                     */
                    $url = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=".$access_token;
                    //以'json'格式发送post的https请求
                    $curl = curl_init();
                    curl_setopt($curl, CURLOPT_URL, $url);
                    curl_setopt($curl, CURLOPT_POST, 1); // 发送一个常规的Post请求
                    curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
                    curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);
                    if (!empty($json)){
                        curl_setopt($curl, CURLOPT_POSTFIELDS,$json);
                    }
                    curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
                    //curl_setopt($curl, CURLOPT_HTTPHEADER, $headers );
                    $output = curl_exec($curl);
                    if (curl_errno($curl)) {
                        echo 'Errno'.curl_error($curl);//捕抓异常
                    }
                    curl_close($curl);
                    if($output == 0){
                        echo 'success';exit;
                    }
                    
                }else{
                    exit('aaa');
                }
            }else{
                echo "";
                exit;
            }
        }
        /* 调用微信api,获取access_token,有效期7200s -xzz0704 */
        public function get_accessToken(){
            /* 在有效期,直接返回access_token */
            if(S('access_token')){
                return S('access_token');
            }
            /* 不在有效期,重新发送请求,获取access_token */
            else{
                $url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=wx6056****&secret=30e46f3ef07b****';
                $result = curl_get_https($url);
                $res = json_decode($result,true);   //json字符串转数组
        
                if($res){
                    S('access_token',$res['access_token'],7100);
                    return S('access_token');
                }else{
                    return 'api return error';
                }
            }
        }
    
    
        public function message(){
    
            $code = $_GET['code'];
            $appid='wx6da1e8575401a942';
            $appSecret='e64fa3f371bb91bfc2b6c28f008f3174';
            $url = 'https://api.weixin.qq.com/sns/jscode2session?appid='.$appid.'&secret='.$appSecret.'&js_code='.$code.'&grant_type=authorization_code';
            
            $res = $this->http_request($url);
            $res1 = json_decode($res);
            $access_token = $this->oauth2_access_token($code);
            $this->ajaxReturn(array('data'=>$res1,'access_token'=>$access_token));
        }
    
        public function oauth2_access_token($code)
         {
             $appid='wx6da1e8575401a942';
            $appSecret='e64fa3f371bb91bfc2b6c28f008f3174';
             $url = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=".$appid."&secret=".$appSecret."&code=".$code."&grant_type=authorization_code";
             $res = $this->http_request($url);
             return json_decode($res, true);
         }
    
        protected function http_request($url, $data = null)
         {
             $curl = curl_init();
             curl_setopt($curl, CURLOPT_URL, $url);
             curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
             curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);
             if (!empty($data)){
                 curl_setopt($curl, CURLOPT_POST, 1);
                 curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
             }
             curl_setopt($curl, CURLOPT_RETURNTRANSFER, TRUE);
             $output = curl_exec($curl);
             curl_close($curl);
             return $output;
         }
  • 相关阅读:
    mybatis遍历map
    程序员开发思考-1
    linux shell学习-1
    IDEA tomcat部署
    理解TCP/IP协议
    winform实现自定义折叠面板控件
    目录特殊符号导致的应用程序处于中断模式
    Vue-element-admin实现菜单根据用户权限动态加载
    基于EF的一个简单实战型分层架构
    Linux开启SELinux的情况下怎么解决nginx403跟502错误
  • 原文地址:https://www.cnblogs.com/objects/p/7889088.html
Copyright © 2011-2022 走看看