发送模板消息

libs/template-message.js

@@ -0,0 +1,57 @@
+#!/usr/bin/env node
+// -*- coding:utf-8 -*-
+// File          : template-message.js
+// Author        : bss
+// Project       : wechat_alerter
+// Description   : 发送模板消息
+// 
+
+
+var request = require('request');
+
+var TEMPLATE_URL_PREFIX = 'https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=';
+
+
+/**
+ * 发送模板消息
+ * @param message 消息本体
+ * @param accessToken ACCESS_TOKEN
+ * @param templateId 模板ID
+ * @param user 要推送的用户
+ */
+function sendTemplateMessage(message, accessToken, templateId, user) {
+
+  var url = TEMPLATE_URL_PREFIX + accessToken;
+
+  var json = {
+    "touser": user,
+    "template_id": templateId,
+    "topcolor": "#FF0000",
+    "data": {
+      "Message": {
+        "value": message,
+        "color": "#000000"
+      }
+    }
+  };
+
+  var options = {
+    url: url,
+    method: 'POST',
+    json: true,
+    body: json
+  };
+
+  request(options, function(error, response, data) {
+    try {
+      if (data.errcode != 0) {
+        console.log(data);
+      }
+    } catch (err) {
+      console.log(err);
+    }
+  });
+}
+
+
+exports.sendTemplateMessage = sendTemplateMessage;

server.js

@@ -11,6 +11,7 @@
 var validationServer = require('./libs/validation-server');
 var accessTokenMgr = require('./libs/access-token');
 var alertServer = require('./libs/alert-server');
+var templateMessageMgr = require('./libs/template-message');
 
 // configs
 var config = require('./conf/config');
@@ -30,5 +31,8 @@ accessTokenMgr.AccessToken(ACCESS_TOKEN_URI, function(newAccessToken) {
 
 // 接收消息
 alertServer.serve(config.clientPort, config.clientToken, function(message) {
+    config.users.forEach(function(user) {
+        templateMessageMgr.sendTemplateMessage(message, accessToken, config.templateId, user);
+    });
     console.log(message);
 });