im.doctor/src/server/endpoints/v2/message.endpoint.js

/**
 * 独立的发送消息接口
 */
"use strict";

let express = require('express');
let router = express.Router();

let ObjectUtil = require('../../util/object.util');
let ControllerUtil = require('../../util/controller.util');
let APIv2 = require('../../include/endpoints').APIv2;
let MODEL_EVENTS = require('../../include/commons').MODEL_EVENTS;
let Messages = require('../../models/messages/messages');

/**
 * 发送消息
 */
router.post(APIv2.Message.Send, function (req, res) {
    let payload = req.body;
    let testing = ObjectUtil.fieldsCheck(payload, "sender_id", "sender_name", "content_type", "content");
    if (!testing.pass) {
        throw {httpStatus: 406, message: testing.message}
    }
    // 消息的发送时间由服务端决定
    payload.timestamp = new Date((new Date().getTime()));

    let messages = new Messages();
    ControllerUtil.regModelEventHandler(messages, res);

    messages.sendMessage(payload);
});

router.get(APIv2.Message.DataMessage, function (req, res) {
    let sessionId = req.query.sessionId;
    let messages = new Messages();
    ControllerUtil.regModelEventHandler(messages, res);

    messages.dataMessage(sessionId);
});

router.post(APIv2.Message.CleanMessageToRedis, function (req, res) {
    let payload = req.body;
    let session_id_str= payload.sessionIdsStr;
    let messages = new Messages();
    ControllerUtil.regModelEventHandler(messages, res);

    //messages.dataMessage(session_id);
    messages.cleanMessageToReids(session_id_str);
});

module.exports = router;