1111

src/server/endpoints/v2/demo.endpoint.js

@@ -7,7 +7,7 @@ let http = require('http');
let configFile = require('../../include/commons').CONFIG_FILE;
let config = require('../../resources/config/' + configFile);
let ImDb = require('../../repository/mysql/db/im.db');
let WlyySDK = require("../../util/wlyy.sdk");
let WechatSDK = require("../../util/wechat.sdk");
let log = require('../../util/log.js');
let clientCache = require('../../models/socket.io/client.cache').clientCache();
const SOCKET_TYPES = require('../../include/commons').SOCKET_TYPES;
@@ -28,4 +28,34 @@ router.post("/", function (req, response) {
    }
});
/**
 * 测试微信模板推送
 */
router.get(APIv2.Demo.sendWXTemplate, function (req, res) {
    let openid = req.query.openid;
    let name = req.query.name;
    let patient = req.query.patient;
    if (!openid) {
        throw {httpStatus: 406, message: 'Missing openid.'};
    }
    // 发送模板消息
    WechatSDK.sendTemplateMessage({
        touser: openid,
        name: name,
        patient: patient,
        template_id: config.wechatConfig.template.consultTemplate,
        url: 'www.baidu.com' ,
        data: {
            first: {value: 'ceshi', color: "#000000"}
            , remark: {value: "", color: "#000000"}
            , keyword1: {value: '测试1', color: "#000000"}
            , keyword2: {value: '测试2', color: "#000000"}
            , keyword3: {value: '测试3', color: "#000000"}
        }
    }, function (err, res) {
        err ? log.error(err) : log.info(res);
    });
});
module.exports = router;

src/server/include/endpoints.js

@@ -73,7 +73,8 @@ const APIv2 = {
        Base: '/api/v2/search'                                          // 搜索，下一版本的语法使用ElasticSearch
    },
    Demo:{
        Base:'/api/v2/demo'
        Base:'/api/v2/demo',
        sendWXTemplate: '/sendWXTemplate'                               // 获取会话
    }
};

src/server/resources/config/config.test.js

@@ -28,8 +28,8 @@ let innerRedisConfig = {
};
// 三师后台
let wlyyServerConfig = {
    host: '172.26.0.104',
    port: 8080,
    host: '172.26.0.118',
    port: 8081,
    model:"/wlyy"
};

src/server/util/wechat.sdk.js

@@ -7,7 +7,7 @@
"use strict";
let WechatTokenRepo = require('../repository/mysql/wechat.token.repo.js');
let WlyySDK = require("./wlyy.sdk");
let configFile = require('../include/commons').CONFIG_FILE;
let config = require('../resources/config/' + configFile);
let log = require('./log');
@@ -24,10 +24,14 @@ class WechatSDK {
    static sendTemplateMessage(message, handler) {
        async.waterfall([
            function (callback) {
                WechatSDK.getAccessToken(function (err, res) {
                    if (err) return handler(err, null);
                    callback(null, res);
                //改成从i健康获取
                WlyySDK.request('', '', '', '', '/im_new/getWXAccessToken', 'get', function (err, res) {
                    res =  JSON.parse(res)
                    if (res.status == 200) {
                        callback(null, res.data);
                    }else{
                        return handler(err, null);
                    }
                });
            },
            function (accessToken, callback) {