微信小程序开发实现消息推送

微信小程序的消息推送简单的说就是发送一条微信通知给用户，用户点开消息可以查看消息内容，可以链接进入到小程序的指定页面。

微信小程序消息推送需要用户触发动作才能发送消息，比如用户提交订单、支付成功。一次只能发一条，当然可以通过某种方法发送多条，小的就不在这里赘述了。下面就介绍一下如何推送消息。

一、准备工作

首先，在微信公众平台开通消息推送功能，并添加消息模板。可以从模板库选择模板也可以创建一个模板，模板添加之后，模板id我们接下来要用的。

发送模板消息需要用到accesstoken、formid和openid。accesstoken获取及更新可以看我的上一篇文章；formid就是消息模板id，openid我们最好在获取用户信息或用户登录时储存到全局变量里。

二、获取formid

 在需要触发消息推送的页面添加提交表单的事件。目的是得到formid，formid是消息推送时必须的参数。

<form name='pushmsgfm' report-submit='true' bindsubmit='getformid'> 
 <button form-type="submit" class="zan-btn zan-btn--large zan-btn--danger paybutton">立即支付</button>
</form> 

以上代码中“getformid”是提交表单时触发的事件。

getformid: function (e) {
this.setdata({
formid: e.detail.formid }) }

以上方法是获取formid。

三、配置消息模板参数，并传给后台

var config = require('../config.js')
var app = getapp();
function pushmsg(formid, access_token){
 var openid = app.globaldata.userinfo.openid;
 var messagedemo = {
 touser: openid,//openid
 template_id: 'pjtleqq-uef49r5jr88s27hbzbdobijr6qfiwjwikpg',//模板消息id， 
 page: 'pages/index/index',//点击详情时跳转的主页
 form_id: formid,//formid
 data: {//下面的keyword*是设置的模板消息的关键词变量 
 
 "keyword1": {
 "value": "keyword1",
 "color": "#4a4a4a"
 },
 "keyword2": {
 "value": "keyword2",
 "color": "#9b9b9b"
 },
 "keyword3": {
 "value": "keyword3",
 "color": "red"
 }
 },
 color: 'red',//颜色
 emphasis_keyword: 'keyword3.data'//需要着重显示的关键词
 }
 wx.request({
 url: config.service.sendmsgurl,
 data: { value: messagedemo, access_token: access_token},
 method: 'post',
 success: function (res) {
 console.log("push msg");
 console.log(res);
 },
 fail: function (err) { 
 console.log("push err")
 console.log(err);
 }
 });
}
module.exports = { pushmsg: pushmsg }

四、推送消息

const request = require('../tools/ih_request');
var conf = require('../config.js')
module.exports = async (ctx, next) => {
 var body = ctx.request.body.value
await request.postjson({
 url: 'https://api.weixin.qq.com/cgi-bin/message/wxopen/template/send?access_token=' + ctx.request.body.access_token,
 body: body,
 success: function (res) {
 ctx.body = {
 result: res
 }
 console.log('res=',res);
 },
 error: function (err) {
 ctx.body = {
 result: err
 }
 console.log(err);
 }
});}

ih_request.js

const request = require('request');
var ih_request = {};
module.exports = ih_request;
ih_request.postjson = async function (option) {
 var res = await request({
 url: option.url,
 method: 'post',
 headers: {
 'content-type': 'application/json'
 },
 body: json.stringify(option.body),
 }, function (err, res, body) {
 res ? option.success(body) : option.error(res.msg);
 console.log('msgresult=', body);
 });
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。