【移动应用开发技术】php如何实现微信公众号模板消息群发功能

【移动应用开发技术】php如何实现微信公众号模板消息群发功能

<?php

//使用方法.直接在页面的逻辑中增加fahuo_wechat();即可.函数要事先引用.

function

fahuo_wechat($shopid){

if(_cfg("sendmobile")){

$thisdb

=

System::load_sys_class("model");

$access=

getAccessToken();//模板id

api等

$access_token=$access['access_token'];

$template_id

=

$access['template_id'];

$sql

=

"select

*

from

`@#_member_go_record`

where

`shopid`='$shopid'

and

status

=

'已付款,未发货,未完成'";

$row

=

$thisdb->GetList($sql);

$postUrl

=

"/cgi-bin/message/template/send?access_token=$access_token";

foreach($row

as

$k=>$v){

$uid=$v['uid'];

$member_band

=

$thisdb->GetOne("SELECT

b_code,b_data

FROM

`@#_member_band`

WHERE

`b_uid`

=

'$uid'

and

b_data!=''

");

//if(empty($member_band)){return

false;}

//return

$row

;

if(!empty($member_band['b_data'])){

$url=WEB_PATH."/mobile/user/buyDetail/".$shopid;

$mobile=$v['company_money'];

$data

=

array(

"touser"

=>

$member_band['b_code'],//一次只发一个人

"template_id"=>$template_id,

"url"=>$url,

//回调

"data"

=>

array(

'first'

=>array(

"value"=>"您好，".$v['username'].",您的牌局已组建成功。",

"color"=>"#888",

),

"keyword1"=>array(

"value"=>$v['shopname'],

"color"=>"#888",

),

//echo

date('Y-m-d

H:i:s',$itemlist[0]['q_end_time'])

"keyword2"=>array(

"value"=>date('Y-m-d

H:i:s',$v['time']),

"color"=>"#888",

),

"keyword3"=>array(

"value"=>"20分钟",

"color"=>"#888",

),

"keyword4"=>array(

"value"=>round($v['moneycount'])."金豆",

"color"=>"#888",

),

"keyword5"=>array(

"value"=>"待定",

"color"=>"#888",

),

"remark"=>array(

"value"=>"

点击查看详情",

"color"=>"#054ff7",

),

),

);

https_request($postUrl,json_encode($data),$mobile);//发货通知的内容.发给微信服务器

}

//发送的发货提示的字符串组合成功.准备发送.

}

}

}

//微信发货准备

function

getAccessToken()

{

//

access_token

应该全局存储与更新，以下代码以写入到文件中做示例

$path

=

G_CACHES.'access_token.json';

$data

=

json_decode(file_get_contents($path),true);

//print_r($data);exit;

if

($data['expire_time']

<

time())

{//过期时间小于当前时间,说明过期,需要更新

$appid=$data['appid'];

$appsecret=$data['appsecret'];

$url

=

"/cgi-bin/token?grant_type=client_credential&appid=$appid&secret=$appsecret";

$json=getCurl($url);

$data=

json_decode($json,true);

//print_r($res);exit;

$access_token

=

$data['access_token'];

if

($access_token)

{

$thisdb

=

System::load_sys_class("model");

$wechat=

$thisdb->GetOne("select

*

from

`@#_wechat_config`

where

id

=

1");//

获取appid

$data['expire_time']

=

time()

+

300;//5分钟更新一次.一天请求微信500多次,不超过2000次的限额就行.

//这里的300最好不要设置的过大.否则会经常提示令牌过期,没法发消息.官方说2小时过期.其实是骗人的.远远达不到.

$data['access_token']

=

$access_token;

$data['template_id']=$wechat['template_id'];

$data['appid']=$wechat['appid'];

$data['appsecret']=$wechat['appsecret'];

$fp

=

fopen($path,

"w");

fwrite($fp,

json_encode($data));

fclose($fp);

}

}

return

$data;

}

function

https_request($url,$data

=

null,$mobile=''){

$curl

=

curl_init();//初始化一个CURL会话

curl_setopt($curl,

CURLOPT_URL,

$url);//这是你想用PHP取回的URL地址。你也可以在用curl_init()函数初始化时设置这个选项

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);

//传递一个作为HTTP

“POST”操作的所有数据的字符串。

}

curl_setopt($curl,

CURLOPT_RETURNTRANSFER,

1);

//讲curl_exec()获取的信息以文件流的形式返回，而不是直接输出。

$output

=

curl_exec($curl);

if(!strstr($output,":0"))

//如果微信发信后的回执中不包含:0,说明一定是没发送成功.所以要把不成功的放在日志中.方便找原因.

{

$path2

=

G_CACHES.'access_token2.json';//access_token2.json为日志保存目录,请对应修改.

file_put_contents($path2,

$output,FILE_APPEND);//FILE_APPEND表示用追加的方式保存日志

}

if(strstr($output,"40003")&&$mobile)//如果是40003说明,,客户没关注我们,发信息提醒他.

{

_sendmobile($mobile,'请关注我们的公