im.doctor/src/server/repository/mysql/message.repo.js

/**
 * 消息库。
 */
"use strict";

let configFile = require('../../include/commons').CONFIG_FILE;
let config = require('../../resources/config/' + configFile);

let ImDb = require('../mysql/db/im.db');
let log = require('../../util/log.js');

const DB_TABLES = require('../../include/commons').DB_TABLES;

class MessageRepo {
    constructor() {
    }

    /**
     * 分页获取消息
     *
     * @param sessionId
     * @param page
     * @param size
     * @param handler
     */
    static findBySessionId(sessionId, page, size, handler) {
        if (page <= 0) {
            page = 1;
        }

        let session = new Sessions();
        session.getSessions(sessionId, function (err, res) {
            if (!err) {
                if (res.length == 0) {
                    log.warn("Session is not found!");

                    handler(null, null);
                    return;
                }

                let type = res[0].type;
                let MessageTable = "";
                if (type == 1) {
                    MessageTable = DB_TABLES.MucMessages;
                } else if (type == 2) {
                    MessageTable = DB_TABLES.P2pMessages;
                } else {
                    MessageTable = DB_TABLES.GroupMessages;
                }

                let sql = "select id, session_id, sender_id, sender_name, content_type, content, timestamp from " + MessageTable + " w where w.session_id = ? limit ?, ?";
                ImDb.execQuery({
                    "sql": sessionsql,
                    "args": [sessionId, page, size],
                    "handler": function (err, res) {
                        if (err) {
                            log.error("sql:" + sql + "data:sessionId：" + sessionId);
                        } else {
                            log.info("getMessagesBySession success by sessionId :" + sessionId);
                        }
                        handler(err, res);
                    }
                })
            }
        })
    }

    /**
     * 保存消息
     *
     * @param messages 消息对象
     * @param sessionType 会话类型，1表示MUC会话，2表示P2P，3表示群会话，4表示临时讨论组
     * @param messageId
     * @param sessionId
     */
    static save(messages, sessionType, messageId, sessionId) {
        var sql = "INSERT INTO " + DB_TABLES.sesstionTypeToTableName(sessionType) +
            " (id, session_id, sender_id, sender_name,content_type, content, timestamp) VALUES (?,?,?,?,?,?,?)";
        ImDb.execQuery({
            "sql": sql,
            "args": [messageId, sessionId, messages.senderId, messages.senderName, messages.contentType, messages.content, messages.timestamp],
            "handler": function (err, res) {
                if (err) {
                    log.error("sql:" + sql + ",error:" + err + ",data:" + JSON.stringify(messages) + ",messageid:" + messageId + ",sessionId:" + sessionId);
                } else {
                    log.info("save message to mysql is success by session :" + sessionId);
                }
            }
        });

    }

}

module.exports = MessageRepo;