本文实例为大家分享了php微信高级接口群发、多客服源码,供大家参考,具体内容如下
/** * 微信接口调用 * 依赖 * 全局变量 * global $uid 公众号用户id, $wid 公众号id, $wechatid 粉丝唯一id; * 参数 * $postStr = $GLOBALS["HTTP_RAW_POST_DATA"]; * $postObj = simplexml_load_string($postStr, "SimpleXMLElement", LIBXML_NOCDATA); * 缓存类 自定义 * Cache:set * Cache:get * 具体业务修改 * 1.上传图文信息至微信素材库 * function uploadArticlesToWeiXinServer() * 2.关键字匹配图文回复 * function getArticleData() * * usage: * $options = array( * "token"=>"tokenaccesskey", //填写你设定的key * "appid"=>"wxdk1234567890", //填写高级调用功能的app id * "appsecret"=>"xxxxxxxxxxxxxxxxxxx", //填写高级调用功能的密钥 * ); */ class WeiXinTool { private $appid; private $appsecret; private $access_token; private $mediaType = array("image" => array("jpg"), "voice" => array("amr", "MP3"), "video" => array("mp4"), "thumb" => array("jpg")); private $mediaMaxSize = array("image" => 131072, "voice" => 262144, "video" => 1048576, "thumb" => 65536); private $tem_file_path = ""; // 授权地址 const AUTH_URL = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s"; // 素材上传 const UPLOAD_MEDIA_URL = "http://file.api.weixin.qq.com/cgi-bin/media/upload?access_token=%s&type=%s"; const GET_MEDIA_URL = "http://file.api.weixin.qq.com/cgi-bin/media/get?access_token=%s&media_id=%s"; const UPLOAD_NEWS_URL = "https://api.weixin.qq.com/cgi-bin/media/uploadnews?access_token=%s"; public function __construct($options) { $this->appid = isset($options["appid"]) ? $options["appid"] : ""; $this->appsecret = isset($options["appsecret"]) ? $options["appsecret"] : ""; //需修改 //上传图片临时文件目录自定义 $this->tem_file_path = YYUC_FRAME_PATH . YYUC_PUB . "/" . Session::get("upath"); } /** * 需修改 * 具体业务需求,图文信息上传至素材库 * 微站文章上传至微信素材 * @param type $wid * @param type $aid * @return int */ public function uploadArticlesToWeiXinServer($wid, $aid) { //具体图文组装过程,需修改 $m = new Model("website_article"); $m_pubs = new Model("pubs"); $m_pubs->find(array("id" => $wid)); $m->find(array("wid" => $wid, "id" => $aid)); $res = array(); if ($m->has_id() && $m_pubs->has_id()) { $res[] = $m->get_model_array(); // var_dump($res); $m->votetouser = json_decode($m->votetouser, TRUE); $articles = $m->votetouser[0]; $m_article = new Model("website_article"); $ress = $m_article->where(array("wid" => $wid, "id" => $articles))->list_all_array(); $res = array_merge($res, $ress); } else { $errarr = array(); $errarr["errcode"] = 44003; $errarr["errmsg"] = self::$errorno[$errarr["errcode"]]; return $errarr; } $items = array(); foreach ($res as $k => $v) { $mediaid = $this->uploadMedia($v["picurl"]); if ($mediaid["media_id"]) { $thumb_media_id = $mediaid["media_id"]; } else { return $mediaid; } $item = array( "thumb_media_id" => $thumb_media_id, "author" => $m_pubs->pubun, "title" => $v["title"], "content_source_url" => WeiXinTool::complateUrl(WeiSite::parseArticleLinkData($v)), "content" => $v["reply_content"], //内容 富文本 "digest" => $v["description"]//描述 ); $items[] = $item; } //以上具体图文组装过程,需修改 $postData["articles"] = $items; $error = $this->uploadNews($postData); return $error; } /** * 需修改 * 微站文章关键字匹配数据解析 */ public static function getArticleData($keyword) { global $wid; $m = new Model("website_article"); $m->find(array("wid" => $wid, "keyword@~" => " " . $keyword . " ")); $res = array(); if ($m->has_id()) { $res[] = array("tit" => $m->title, "pic" => $m->picurl, "dec" => $m->description, "url" => WeiSite::parseArticleLinkData($m->get_model_array())); $m->votetouser = json_decode($m->votetouser, TRUE); $articles = $m->votetouser[0]; if (!empty($articles)) { foreach ($articles as $v) { $m_article = new Model("website_article"); $m_article->find(array("wid" => $wid, "id" => $v)); $res[] = array("tit" => $m_article->title, "pic" => $m_article->picurl, "dec" => $m_article->description, "url" => WeiSite::parseArticleLinkData($m_article->get_model_array())); } } return $res; } } /** * 获取accesstoken * @param type $flag 强制刷新accesstoken 开关 * @return type */ public function getAccessToken($flag = FALSE) { $url = sprintf(self::AUTH_URL, $this->appid, $this->appsecret); $result = Cache::get(md5($url)); if ($flag || empty($result)) { $result = $this->http_get($url); $result = json_decode($result, TRUE); if ($result["errcode"]) { return $result["errcode"]; } Cache::set(md5($url), $result, 1); } $this->access_token = $result["access_token"]; return true; } /** * 上传媒体 * @param type $file 媒体文件 $url或者物理路径地址 * @param type $type 类型 * @return int * return array (size=3) "type" => string "image" (length=5) "media_id" => string "-0Lr3rX9mDYBB7i5bDydvwFHHm3zW2Uxt0OoDFBPmGRfYiwckiALqHH_DlP9jCm_" (length=64) "created_at" => int 1400477181 */ public function uploadMedia($file, $type = "image") { $file = self::complateUrl($file); $urlarr = parse_url($file); $filetype = explode(".", $urlarr["path"]); $filetype = strtolower($filetype[count($filetype) - 1]); $resizeSize = 100; //图片处理后另存质量 if (!key_exists($type, $this->mediaType) || !in_array($filetype, $this->mediaType[$type])) { // return 40005; //格式错误 $errarr = array(); $errarr["errcode"] = 40005; $errarr["errmsg"] = self::$errorno[$errarr["errcode"]]; return $errarr; } $temp_file = $this->tem_file_path . "uploadMedia." . $filetype; $temp_file_resize = $this->tem_file_path . "uploadMediaResize." . $filetype; file_put_contents($temp_file, self::http_get($file)); $handle = fopen($temp_file, "r"); $fstat = fstat($handle); if ($fstat["size"] > $this->mediaMaxSize[$type]) { $resizeSize = intval($this->mediaMaxSize[$type] / $fstat["size"] * 100); ImageTool::resizeImage($temp_file_resize, $temp_file, 400, 400, $resizeSize); //图片太大再处理压缩 $temp_file = $temp_file_resize; // return 40006; //大小错误 } $filePath = realpath($temp_file); $uploadUrl = sprintf(self::UPLOAD_MEDIA_URL, $this->access_token, $type); $postData = array("r" => time(), "media" => "@{$filePath}"); $result = self::http_post($uploadUrl, $postData); $result = json_decode($result, TRUE); return $result; } /** * 群发图文信息 * @param type $touser 粉丝数组/粉丝组id * @param type $media_id * @return type */ public function sendArticles($touser, $media_id) { $errarr = array(); $postData = array(); $postData["mpnews"] = array("media_id" => $media_id); $postData["msgtype"] = "mpnews"; if (is_array($touser)) { //用户列表群发 $postData["touser"] = $touser; $url = "https://api.weixin.qq.com/cgi-bin/message/mass/send?access_token=%s"; } else { $group = intval($touser); $groups = $this->getGroups(true); if (key_exists($group, $groups["list"])) { $postData["filter"] = array("group_id" => $group); } else { $errarr["errcode"] = 40050; //无效分组id $errarr["errmsg"] = self::$errorno[$errarr["errcode"]]; return $errarr; } $url = "https://api.weixin.qq.com/cgi-bin/message/mass/sendall?access_token=%s"; } $url = sprintf($url, $this->access_token); $result = self::http_post($url, self::json_encode($postData)); $result = json_decode($result, TRUE); return $result; } /** * 删除群发信息 * @param type $msgid * @return type */ public function delSend($msgid) { $url = "https://api.weixin.qq.com/cgi-bin/message/mass/delete?access_token=%s"; $url = sprintf($url, $this->access_token); $postData = array("msgid" => $msgid, "r" => time()); $result = self::http_post($url, self::json_encode($postData)); $result = json_decode($result, TRUE); return $result; } /** * 群发图文素材上传 $postData = array("articles" => array($item, $item,...)); $item = array( "thumb_media_id" => "WMQubqCECMQwAjqh8CI500LfhyoG0vmTTlKKJM5oP-of0uLML1_2s26j8XeIorDL", "author" => "xxx", "title" => "Happy Day", "content_source_url" => "www.qq.com", "content" => "content", "digest" => "digest" ); * return array (size=3) "type" => string "news" (length=4) "media_id" => string "OuXqv2dgZzxAmK4z-tvStgr6InG18oIllWkD6Tj1qJZVRg-2f64FDU2D3J7dptHs" (length=64) "created_at" => int 1400477183 */ public function uploadNews($postData) { $uploadUrl = sprintf(self::UPLOAD_NEWS_URL, $this->access_token); $result = self::http_post($uploadUrl, self::json_encode($postData)); $result = json_decode($result, TRUE); return $result; } /** * 获取粉丝列表 * @param type $nextOpenId * @return type */ public function getAllConnects($nextOpenId = "") { $url = "https://api.weixin.qq.com/cgi-bin/user/get?access_token=%s&next_openid=%s"; $url = sprintf($url, $this->access_token, $nextOpenId); $result = self::http_get($url); $result = json_decode($result, TRUE); $count = count($result["data"]["openid"]); $list = $result["data"]["openid"]; if ($result["data"]["openid"][$count - 1] == $result["next_openid"]) { return $result["data"]["openid"]; } else { $templist = $this->getAllConnects($result["next_openid"]); $list = array_merge($list, $templist); return $list; } } /** * 根据粉丝唯一id获取微信信息 * @param type $openid * @return type */ public function getFansInfo($openid) { $url = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=%s&openid=%s&lang=zh_CN"; $url = sprintf($url, $this->access_token, $openid); $result = self::http_get($url); $result = json_decode($result, TRUE); return $result; } /** * 更新粉丝组信息 * @param type $openid * @param type $groupid * @return type */ public function updateFansGroups($openid, $groupid) { $url = "https://api.weixin.qq.com/cgi-bin/groups/members/update?access_token=%s"; $url = sprintf($url, $this->access_token); $postData = array("to_groupid" => $groupid, "openid" => $openid); $result = self::http_post($url, self::json_encode($postData)); $result = json_decode($result, TRUE); $this->getGroups(true); return $result; } /** * 获取粉丝组信息 * @param type $openid * @return type */ public function getFansGroupInfo($openid) { $url = "https://api.weixin.qq.com/cgi-bin/groups/getid?access_token=%s"; $url = sprintf($url, $this->access_token); $postData = array("r" => time(), "openid" => $openid); $result = self::http_post($url, self::json_encode($postData)); $result = json_decode($result, TRUE); return $result["groupid"]; } /** * 获取唯一key * @param type $key * @return type */ public function getKey($key) { return md5($this->appid . $this->appsecret . $key); } /** * 获取媒体图片到本地 * @param type $mediaid * @return string */ public function getMedia($mediaid) { $url = sprintf(self::GET_MEDIA_URL, $this->access_token, $mediaid); $result = self::http_get($url); $temp_file = $this->tem_file_path . "getMedia.jpg"; file_put_contents($temp_file, $result); return $temp_file; } /** * 用户组 * @param type $flag 强制刷新用户组 * @return type */ public function getGroups($flag = false) { $key = $this->appid . "gasdfev" . $this->appsecret; $result = Cache::get($key); if (empty($result) || $flag) { $url = "https://api.weixin.qq.com/cgi-bin/groups/get?access_token=%s"; $url = sprintf($url, $this->access_token); $result = self::http_get($url); $result = json_decode($result, TRUE); $temg = array(); $temlist = array(); foreach ($result["groups"] as $k => $v) { $temg[$v["id"]] = $v; $temlist[$v["id"]] = $v["name"]; } $result["map"] = $temg; $result["list"] = $temlist; Cache::set($key, $result); } return $result; } /** * 新增用户组 * @param type $name * @return type */ public function createGroup($name) { $url = "https://api.weixin.qq.com/cgi-bin/groups/create?access_token=%s"; $url = sprintf($url, $this->access_token); $result = self::http_post($url, self::json_encode(array("group" => array("name" => $name)))); $result = json_decode($result, TRUE); return $result; } /** * 修改用户组 * @param type $id * @param type $name * @return type */ public function modifyGroup($id, $name) { $url = "https://api.weixin.qq.com/cgi-bin/groups/update?access_token=%s"; $url = sprintf($url, $this->access_token); $result = self::http_post($url, self::json_encode(array("group" => array("id" => $id, "name" => $name)))); $result = json_decode($result, TRUE); return $result; } /** * 多客服接入 * @global type $wid * @param type $postObj */ public static function responseService($postObj) { global $wid; $fromUsername = $postObj->FromUserName; $toUsername = $postObj->ToUserName; $textTpl = "<xml> <ToUserName><![CDATA[%s]]></ToUserName> <FromUserName><![CDATA[%s]]></FromUserName> <CreateTime>%s</CreateTime> <MsgType><![CDATA[transfer_customer_service]]></MsgType> </xml>"; $resstr = sprintf($textTpl, $fromUsername, $toUsername, time()); echo $resstr; } /** * 微信回复多图文 * @global type $wid * @param type $res * array(array(),array() * ); * @param type $rid * @param type $postObj */ public static function response_morearts($res, $postObj) { global $wid; $fromUsername = $postObj->FromUserName; $toUsername = $postObj->ToUserName; $textTpl = "<xml> <ToUserName><![CDATA[%s]]></ToUserName> <FromUserName><![CDATA[%s]]></FromUserName> <CreateTime>%s</CreateTime> <MsgType><![CDATA[%s]]></MsgType> <ArticleCount>%s</ArticleCount> <Articles> ITEM </Articles> </xml>"; $resstr = sprintf($textTpl, $fromUsername, $toUsername, time(), "news", count($res)); $item = ""; $subitem = "<item> <Title><![CDATA[%s]]></Title> <Description><![CDATA[%s]]></Description> <PicUrl><![CDATA[%s]]></PicUrl> <Url><![CDATA[%s]]></Url> </item>"; foreach ($res as $r) { $r["url"] = self::parseUrl($r["url"]); $item .= sprintf($subitem, $r["tit"], $r["des"], self::complateUrl($r["pic"]), self::replaceToWXUrl(self::complateUrl($r["url"]), $postObj)); } $resstr = str_replace("ITEM", $item, $resstr); echo $resstr; } /** * url解析 * @param type $url * @return string */ public static function complateUrl($url) { if (false === stristr($url, "http://")) {//查找http:// 如果不存在 if (0 === strpos($url, "/")) {//查找首字母 如果存在 $url = substr($url, 1); //去除/ } $url = "http://" . $_SERVER["HTTP_HOST"] . "/" . $url; //拼接完整路径 } return $url; } /** * 微信url固定参数替换 * @param type $url * @param type $postObj * @return type */ public static function replaceToWXUrl($url, $postObj) { global $wechatid; return str_ireplace("fromUsername", $wechatid, $url); } /** * 完成以下行为 * parseUrlParam * setUrlPublicParam * buildUrlParam * @param type $url * @param type $other 附加参数 基础参数wid wxid wechatid */ public static function parseUrl($url, $other = array()) { $url = self::parseUrlParam($url); $url = self::setUrlPublicParam($url); if (is_array($other) && !empty($other)) { $url["param"] = array_merge($url["param"], $other); } $url = self::buildUrlParam($url); return $url; } /** * 分析url * @param type $url * @return type */ public static function parseUrlParam($url) { $temp = explode("?", $url); $url0 = $temp[0]; $url1 = $temp[1]; $p = explode("&", $url1); $param = array(); foreach ($p as $v) { $tempp = explode("=", $v); $param[$tempp[0]] = $tempp[1]; } return array("url" => $url0, "param" => $param); } /** * 组装url * @param type $arr * @return type */ public static function buildUrlParam($arr) { $url = $arr["url"]; $param = $arr["param"]; $param_arr = array(); foreach ($param as $k => $v) { if ($k == "") continue; $param_arr[] = $k . "=" . $v; } return $url . "?" . implode("&", $param_arr) . "#mp.weixin.qq.com"; } /** * 设置微信保留参数信息 * @global type $uid * @global type $wid * @global type $wechatid * @param type $url * @return type */ public static function setUrlPublicParam($url) { global $uid, $wid, $wechatid; $url["param"]["wid"] = $wid; $url["param"]["wxid"] = $wechatid; $url["param"]["wechatid"] = $wechatid; return $url; } public static $errorno = array( "-1" => "系统繁忙", "0" => "请求成功", "40001" => "获取access_token时AppSecret错误,或者access_token无效", "40002" => "不合法的凭证类型", "40003" => "不合法的OpenID", "40004" => "不合法的媒体文件类型", "40005" => "不合法的文件类型", "40006" => "不合法的文件大小", "40007" => "不合法的媒体文件id", "40008" => "不合法的消息类型", "40009" => "不合法的图片文件大小", "40010" => "不合法的语音文件大小", "40011" => "不合法的视频文件大小", "40012" => "不合法的缩略图文件大小", "40013" => "不合法的APPID", "40014" => "不合法的access_token", "40015" => "不合法的菜单类型", "40016" => "不合法的按钮个数", "40017" => "不合法的按钮个数", "40018" => "不合法的按钮名字长度", "40019" => "不合法的按钮KEY长度", "40020" => "不合法的按钮URL长度", "40021" => "不合法的菜单版本号", "40022" => "不合法的子菜单级数", "40023" => "不合法的子菜单按钮个数", "40024" => "不合法的子菜单按钮类型", "40025" => "不合法的子菜单按钮名字长度", "40026" => "不合法的子菜单按钮KEY长度", "40027" => "不合法的子菜单按钮URL长度", "40028" => "不合法的自定义菜单使用用户", "40029" => "不合法的oauth_code", "40030" => "不合法的refresh_token", "40031" => "不合法的openid列表", "40032" => "不合法的openid列表长度", "40033" => "不合法的请求字符,不能包含uxxxx格式的字符", "40035" => "不合法的参数", "40038" => "不合法的请求格式", "40039" => "不合法的URL长度", "40050" => "不合法的分组id", "40051" => "分组名字不合法", "40059" => "不合法的消息id", "41001" => "缺少access_token参数", "41002" => "缺少appid参数", "41003" => "缺少refresh_token参数", "41004" => "缺少secret参数", "41005" => "缺少多媒体文件数据", "41006" => "缺少media_id参数", "41007" => "缺少子菜单数据", "41008" => "缺少oauth code", "41009" => "缺少openid", "42001" => "access_token超时", "42002" => "refresh_token超时", "42003" => "oauth_code超时", "43001" => "需要GET请求", "43002" => "需要POST请求", "43003" => "需要HTTPS请求", "43004" => "需要接收者关注", "43005" => "需要好友关系", "44001" => "多媒体文件为空", "44002" => "POST的数据包为空", "44003" => "图文消息内容为空", "44004" => "文本消息内容为空", "45001" => "多媒体文件大小超过限制", "45002" => "消息内容超过限制", "45003" => "标题字段超过限制", "45004" => "描述字段超过限制", "45005" => "链接字段超过限制", "45006" => "图片链接字段超过限制", "45007" => "语音播放时间超过限制", "45008" => "图文消息超过限制", "45009" => "接口调用超过限制", "45010" => "创建菜单个数超过限制", "45015" => "回复时间超过限制", "45016" => "系统分组,不允许修改", "45017" => "分组名字过长", "45018" => "分组数量超过上限", "46001" => "不存在媒体数据", "46002" => "不存在的菜单版本", "46003" => "不存在的菜单数据", "46004" => "不存在的用户", "47001" => "解析JSON/XML内容错误", "48001" => "api功能未授权", "50001" => "用户未授权该api" ); /** * GET 请求 * @param string $url */ public static function http_get($url) { if (!function_exists("curl_init")) { die("curl 未开启"); }; $oCurl = curl_init(); if (stripos($url, "https://") !== FALSE) { curl_setopt($oCurl, CURLOPT_SSL_VERIFYPEER, FALSE); curl_setopt($oCurl, CURLOPT_SSL_VERIFYHOST, FALSE); } curl_setopt($oCurl, CURLOPT_URL, $url); curl_setopt($oCurl, CURLOPT_RETURNTRANSFER, 1); $sContent = curl_exec($oCurl); $aStatus = curl_getinfo($oCurl); curl_close($oCurl); if (intval($aStatus["http_code"]) == 200) { return $sContent; } else { return false; } } /** * POST 请求 * @param string $url * @param array $param * @return string content */ public static function http_post($url, $param, $httpBuildQuery = false) { if (!function_exists("curl_init")) { die("curl 未开启"); }; $oCurl = curl_init(); if (stripos($url, "https://") !== FALSE) { curl_setopt($oCurl, CURLOPT_SSL_VERIFYPEER, FALSE); curl_setopt($oCurl, CURLOPT_SSL_VERIFYHOST, false); } curl_setopt($oCurl, CURLOPT_URL, $url); curl_setopt($oCurl, CURLOPT_RETURNTRANSFER, 1); // curl_setopt($oCurl, CURLOPT_HTTPHEADER, $header);//设置HTTP头 curl_setopt($oCurl, CURLOPT_POST, 1); if ($httpBuildQuery) { $param = http_build_query($param); } curl_setopt($oCurl, CURLOPT_POSTFIELDS, $param); $sContent = curl_exec($oCurl); $aStatus = curl_getinfo($oCurl); curl_close($oCurl); if (intval($aStatus["http_code"]) == 200) { return $sContent; } else { return false; } } /** * 微信api不支持中文转义的json结构 * @param array $arr */ static function json_encode($arr) { $parts = array(); $is_list = false; //Find out if the given array is a numerical array $keys = array_keys($arr); $max_length = count($arr) - 1; if (($keys [0] === 0) && ($keys [$max_length] === $max_length )) { //See if the first key is 0 and last key is length - 1 $is_list = true; for ($i = 0; $i < count($keys); $i ++) { //See if each key correspondes to its position if ($i != $keys [$i]) { //A key fails at position check. $is_list = false; //It is an associative array. break; } } } foreach ($arr as $key => $value) { if (is_array($value)) { //Custom handling for arrays if ($is_list) $parts [] = self::json_encode($value); /* :RECURSION: */ else $parts [] = """ . $key . "":" . self::json_encode($value); /* :RECURSION: */ } else { $str = ""; if (!$is_list) $str = """ . $key . "":"; //Custom handling for multiple data types if (is_numeric($value) && $value < 2000000000) $str .= $value; //Numbers elseif ($value === false) $str .= "false"; //The booleans elseif ($value === true) $str .= "true"; else $str .= """ . addslashes($value) . """; //All other things // :TODO: Is there any more datatype we should be in the lookout for? (Object?) $parts [] = $str; } } $json = implode(",", $parts); if ($is_list) return "[" . $json . "]"; //Return numerical JSON return "{" . $json . "}"; //Return associative JSON } }
以上就是本文的全部内容,希望对大家学习php程序设计有所帮助。