微信公众号-模板消息通用接口封装
近期做了微信公众号的消息通知，微信方面模板越来越规范化，跟测试的平台相差甚远（fuck，谁让人家要办硬）。
话不多说，进入代码
class OfficialSystem
{
public $tmplateConf;
private $accessToken; //微信accessToken
public function __construct( $tmplateConf ,$accessToken ){
$this->tmplateConf = $tmplateConf;
$this->accessToken = $accessToken;
}
/**
* 返回结果
* @param $error bool 1 代表错误，0 无错误
* @parame $msg string 返回信息
* @param $data Array 返回内容
* @param $isJson bool 1 返回json， 0 否
**/
public function returnResult( $error,$msg ,$data=[],$isJson=0 ){
$result = [
\'error\' => $error,
\'msg\' => $msg,
\'data\' => $data,
];
if( $isJson ){
echo json_encode($result);
exit();
}
return $result;
}
/**
* 发送消息
* @param $modelId sting 微信模板id
* @param $touser string 微信openid（公众号）
* @param $url string 跳转地址
* @param $miniPagepath string 小程序跳转路径
* @param $miniAppid string 小程序Appid
* @param $list Array 模板数据，如：[ [\'value\'=>\'您好，您有新的订单\',\'color\'=>\'blue\',...] ]
**/
public function Sendmsg( $modelId,$touser,$url,$miniPagepath,$miniAppid,$list=[] ){
if( empty($modelId) || empty($touser) || empty($list) ) $this->returnResult(1,\'参数缺失\');
$template_id = !empty( $this->tmplateConf[$modelId] ) ? $this->tmplateConf[$modelId]:$this->returnResult(1,\'模板错误\');
//模板消息内容 数组第一个作为标题，最后一个作为备注
$data = [];
foreach ($list as $k=>$v){
$key = $k==0 ? \'first\':"keyword".$k;
if( !isset( $list[$k+1] ) ) $key = \'remark\';
$data[$key] = [
\'value\' => $v[\'value\'],
\'color\' => !empty($v[\'color\'])? $v[\'color\']:\'#173177\',
];
}
$sends = $this->sendModelMsg($touser,$template_id,$url,$miniAppid,$miniPagepath,$data);
$this->returnResult(0,\'success\',$sends);
}
/**
* @param $touser 用户openid
* @param $template_id
* @param $url
* @param $miniAppid
* @param $miniPagepath 小程序跳转地址
* @param $data 模板数据
*/
public function sendModelMsg( $touser,$template_id,$url=\'\',$miniAppid=\'\',$miniPagepath=\'\',$data ){
$interfaceUrl = \'https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=\'.$this->accessToken;
$params = [
\'touser\' => $touser,
\'template_id\' => $template_id,
\'url\' => $url,
\'miniprogram\' => [ \'appid\'=>$miniAppid,\'path\'=>$miniPagepath ] ,
\'data\' => $data,
];
$sends = $this->httpPost($interfaceUrl,json_encode($params));
$sends = json_decode($sends,1);
if( $sends&&$sends[\'errmsg\']!=\'ok\' ){
$this->returnResult(1,\'消息发送失败\',$sends);
}
return $sends;
}
/**
* 获取用户信息
* @param $openid openid
* @return mixed
*/
public function getUserInfo( $openid=\'\' ){
$interfaceUrl = \'https://api.weixin.qq.com/cgi-bin/user/info?access_token=\'.$this->accessToken.\'&openid=\'.$openid;
$info = $this->httpGet( $interfaceUrl );
$result = json_decode($info,1);
return $result;
}
/**
* @param $touser
* @param $msgtype
* @param $msgContent
*/
public function sendCustomMsg( $touser,$msgtype,$msgContent){
// $params = [];
// $params[\'touser\'] = $touser;
// $params[\'msgtype\'] = $msgtype;
// $params["$msgtype"] = $msgContent;
// $params = json_encode($params);
$params = \'{"touser":"\'.$touser.\'","msgtype":"\'.$msgtype.\'","text":{\'.$msgContent.\'}}\';
$interfaceUrl = \'https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=\'.$this->accessToken;
$sends = $this->httpPost($interfaceUrl,$params);//var_dump($params,json_encode($params),$sends);die;
$sends = json_decode($sends,1);
return $sends;
}
private function httpGet($url) {
$curl = curl_init();
curl_setopt_array($curl, array(
CURLOPT_URL => $url,
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
CURLOPT_HTTPHEADER => array(
"cache-control: no-cache",
"content-type: application/x-www-form-urlencoded",
),
));
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;die;
} else {
return $response;
}
}
private function httpPost($url,$param){
$curl = curl_init();
curl_setopt_array($curl, array(
CURLOPT_URL => $url,
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => $param,
CURLOPT_HTTPHEADER => array(
"cache-control: no-cache",
"content-type: application/json",
\'Content-Length:\' . strlen($param)
),
));
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
return "cURL Error #:" . $err;
} else {
return $response;
}
}
调用事例：
$tmplateConf = [
\'1\' => \'mnscOp2RHpQtDCt7OpZBLoDTU2fjJ_W75_Mat4rnfxM\', //订货通知模板
\'2\' => \'DL4EAD47KT1tggbL2OR8iRAYLORI64V4YEM8mjQfSWU\', //入库通知模板
];
$accessToken = \'o9BuWjkDBvLGV_nch9wPU_-KRp7M\';
$OfficialSystem = new OfficialSystem($tmplateConf,$accessToken);
//消息内容
$list = [
[\'value\'=>\'您好，您有新的订单\',\'color\'=>\'blue\'],
[\'value\'=>\'P201809010001\',\'color\'=>\'\'],
[\'value\'=>\'服务中心店\',\'color\'=>\'\'],
[\'value\'=>\'2018-06-01 10:30:30\',\'color\'=>\'\'],
[\'value\'=>\'点击进入详情\',\'color\'=>\'\'],
];
$modelId = 1;
$touser = \'o9BuWjkDBvLGV_nch9wPU_-KRp7M\';
$url = \'http://www.cnblogs.com/followyou\';
$sends = Sendmsg( $modelId,$touser,$url,$miniPagepath=\'\',$miniAppid=\'\',$list);
var_dump($sends);
成功返回：
"errcode": "0",
"errmsg": "ok",
"msgid": "325381129559375872"
仅供参考，代码也就这样哈！