700字范文,内容丰富有趣,生活中的好帮手!
700字范文 > 微信小程序 实现模板消息群发 发送给指定用户

微信小程序 实现模板消息群发 发送给指定用户

时间:2023-10-23 16:17:16

相关推荐

微信小程序 实现模板消息群发 发送给指定用户

1. 需求

最近在做一款拼课类小程序,大概需求就是分享课程页面给好友,好友参与达到一定数量后则拼课成功。

好友参与后会给分享者发送一条模板消息参与人数满足后(拼课成功)会给分享者发送一条模板消息管理后台可以群发模板消息(给所有用户发消息)

按理说很平常的需求,微信公众号里边应该很容易实现,但是想在小程序里边实现这么个功能却有点蛋疼了。

2. 分析

为什么小程序实现起来比较费劲呢,那就要说下小程序发送模板消息的机制了,先看文档怎么说:

划重点,本人交互,也就是说这个模板消息,必须由用户手动来触发,你想后台定时给用户推个消息,洗洗睡吧你。

再来看下面:

这个重点你们自己划吧,发模板消息必须满足这两种情况中的一种,支付就不说了,用户付款后可以推送几条消息,重点是这个表单提交

意思就是我想给用户发个模板消息,第一要搞个表单,第二要让用户来提交这个表单(获取formId),而且这个模板消息还只能发给提交表单的用户本人,你想发给别的用户,呵呵。

献给我们伟大的TX

3. 原理

好了,说多了都是气,既然这样设计,也是有一定道理,但是道理都是讲给守规矩的人听的,至于不守规矩的,喂!说的就是你。

通过上面的分析我们知道,想发送一个基本的模板消息需要以下步骤:

构建一个form表单设置表单的report-submit属性为true(用来获取formId发送模板消息)用户提交表单,把openid和formId一块提交给后台(其实真正开发中一般不会提交openid,因为在用户登录或者访问小程序时候通常会把openid和当前用户在数据库中做个同步)后台调用POST https://api./cgi-bin/message/wxopen/template/send?access_token=ACCESS_TOKEN来发送模板消息

模板消息接口POST https://api./cgi-bin/message/wxopen/template/send?access_token=ACCESS_TOKEN有这么几个参数 :

其中touser(openid)form_id是重点,这两个参数的结合是用来确认和效验模板接收者的,因为用户提交表单微信会生成一个专属的formId,这个formId标识着用户的一个操作。所以可以这样来理解,要想发送一个模板消息给特定用户,那么必须要有该用户的有效formId(7天内有效)和openid,一旦我们有了用户大量的formId,你说我发个模板消息那还不跟玩的一样。

所以问题就来了

1. 我如何来收集用户的formId?

这个还没有什么特别有效的办法,因为微信不会给提供相关api,而且只有提交表单才能得到formId,所以只能让用户去主动的触发表单来生成formId,我们要做的就是修改原有的页面,把页面上高强度的交互都用form和button组件来替换,只是在外层套一个form组件而已,里边用button来触发操作(记得修改样式),比如:

像这些交互元素都可以外层套上form组件,用户点击后触发表单提交事件,得到formId,我们把formId和用户openid发送给后台特定接口,后台要做的就是把formId和openid存储下来,至于存数据库、文件、缓存、redis都行,主要是要把openid和formId关系对应好,而且每个formId都有一个过期时间。我是用laravel的redis缓存来存储,毕竟这块是一个高频的io操作。具体实现方式在后面。

2. 搞了一堆用户的formId后,我该怎么来用呢?

其实这个问题是多余的,就像给你了一个女朋友,你却不知道该干啥一样。当然是上...

前面已经说的很清楚了,想要给目标用户发模板消息需要formId和openid,当后台有一个发送模板消息事件被触发时,只需要获取目标用户的openid(这个你们自己数据库肯定有对应的啦),然后根据openid从数据库(或其他存储引擎)拉取一个有效的formId,请求POST https://api./cgi-bin/message/wxopen/template/send?access_token=ACCESS_TOKEN即可,完事了,记得删掉这个formId奥。

4. 实现

前面扯了一堆概念,下面我们来把这个功能具体的实现一遍吧,我这里后台用的是php laravel,原理都一样。

小程序端业务

我这只写一个例子,一看就明白

// wxml// reprt-submit属性记得写上<form bindsubmit="clickFormView" report-submit="true" class="form-view"><button form-type="submit" class="form-view-button"><view>这里边才是我们正常的界面代码</view></button></form>

// js// 这块都可以封装的,毕竟很多交互的地方都需要clickFormView(event) {let formId = event.detail.formId;// 忽略开发者工具里边的formIdif (formId && formId !== 'the formId is a mock one') {wx.request({method: 'POST',url: '/api/collectFormId', // 该接口只用来收集formIddata: { formId: formId } // 只传了一个formId,因为openid和当前用户通常会事先在后台做一个关联,看具体业务了});}// 然后可以干其他事了,比如跳转页面,其他业务逻辑 // TODO}

有些时候用户操作频繁,可能会导致服务器收到大量请求,所以可以优化下,把formId先存到一个全局变量里边(数组),当达到一定数量后统一发给后台来保存。这块可以灵活运用。

服务端实现

服务端的实现也就两个功能,收集发送

假设我们现在有这么一个类FormIdCollection,可以收集(save)和获取(get)某个openid的formId,那我们给前台暴露的api只需要简单的调用下就可以了,至于发消息,也只需要get一个formId,即可。

// 实例化一个对象// $openid为目标用户openid// $config是一个数组,微信小程序相关配置[app_id, secret]$collection = new FormIdCollection($openid, $config);// 收集一个formId$collecton->save($formId);//获取一个可用formId$collection->get();// 发送模板消息// $data为模板消息相关参数 template_id等$collecton->send($data);

下面是FormIdCollection类的一个具体实现,基于laravel(说实话,挺好用的),另外引入了一个微信开发包overtrue/wechat(这里主要是用来发模板消息、有点大材小用了),/

<?phpuse Illuminate\Support\Facades\Cache;use EasyWeChat\Factory;class FormIdCollection{private $openid;private $config;private $cache;private $cacheKey;public function __construct($openid, $config = []) {$this->openid = $openid;$this->config = $config;$this->cache = Cache::store('redis'); // 用redis作为缓存驱动,记得要配置redis环境奥$this->cacheKey = $this->getCacheKey(); // 每个openid对应一个key}/*** 获取缓存key* */public function getCacheKey() {return 'mini_program_form_id_'.$this->openid;}/*** 发送模板消息* * @param $data 模板消息参数*/public function send($data){$mina = Factory::miniProgram(['app_id' => $this->config['app_id'],'secret' => $this->config['secret'],]);// 获取一个可用的formId,然后删除掉$formId = $this->get(true);if (!$formId) {throw new \Exception('no formId');} else {$data['touser'] = $this->openid;$data['form_id'] = $formId;// 用overtrue/wechat包来发送模板消息$res = $mina->template_message->send($data);return $res;}}/*** 存储formId* * @param $formId*/public function save($formId) {$formIds = $this->gets();$formIds->push(['form_id' => $formId,'expire' => time() + 60 * 7 * 24 // formId过期时间]);// 存储到redis缓存中$this->cache->forever($this->cacheKey, $formIds->toArray());}/*** 获取某个未过期的formId** @param $delete 获取之后是否立即删除*/public function get($delete = false) {$formIds = $this->gets();if (!$formIds->count()) {return false;}// 筛选一个有效的formId,优先获取快过期的$formId = $formIds->where('expire', '>=', time())->sortBy('expire')->first()['form_id'];if ($delete && $formId) {$this->delete($formId);}return $formId;}/*** 获取formId集合* * @return \Illuminate\Support\Collection*/public function gets() {$formIds = $this->cache->get($this->cacheKey);return collect($formIds ? $formIds : []);}/*** 删除某个formId* * @param $formId*/public function delete($formId) {$formIds = $this->gets();$formIds = $formIds->filter(function($item) use($formId) {return $item['form_id'] != $formId;});$this->cache->forever($this->cacheKey, $formIds->toArray());}/*** 清理所有已过期的formId* */public function clearExpireFormIds() {$formIds = $this->gets();$time = time();$formIds = $formIds->filter(function($item) use($time) {return $item['expire'] > $time;});$this->cache->forever($this->cacheKey, $formIds->toArray());}}

我已经封装了一个laravel扩展包,感兴趣的朋友可以上github上看下/laravuel/laravel-wfc。

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。