im.doctor/src/server/models/sessions/topics.js

/**
 * 议题模型。
 */
"use strict";

let RedisClient = require('../../repository/redis/redis.client.js');
let TopicsRepo = require('../../repository/mysql/topics.repo');
let RedisModel = require('./../redis.model.js');
let ModelUtil = require('../../util/model.util');
let Participants = require("./participants");
let Sessions = require("./sessions");

let log = require('../../util/log.js');
let redis = RedisClient.redisClient().connection;
let configFile = require('../../include/commons').CONFIG_FILE;
let config = require('../../resources/config/' + configFile);

const REDIS_KEYS = require('../../include/commons').REDIS_KEYS;
const TOPIC_STATUS = require('../../include/commons').TOPIC_STATUS;
const SESSION_TYPES = require('../../include/commons').SESSION_TYPES;

class Topics extends RedisModel {
    constructor() {
        super();
    }

    /**
     * 根据topicId获取对应的消息
     * @param topicId
     * @param page
     * @param size
     */
    getTopicMessages(topicId) {
        let self = this;
        let topic_key = RedisModel.makeRedisKey(REDIS_KEYS.Topic, topicId);
        let _super = RedisModel.makeRedisKey;
        redis.hgetallAsync(topic_key).then(function (topic) {
            let message_time_key = _super(REDIS_KEYS.MessagesByTimestamp, topic.session_id);
            let message_key = _super(REDIS_KEYS.Messages, topic.session_id);

            //倒序取出所有的消息ID
            let create_time = topic.create_time;
            let end_time = topic.end_time;
            if (!end_time) {
                end_time = new Date().getTime();
            }

            redis.zrevrangebyscoreAsync(message_time_key, end_time, create_time).then(function (messages) {
                //取出消息实例
                redis.hmgetAsync(message_key, messages).then(function (res) {
                    ModelUtil.emitOK(self.eventEmitter, res);
                });
            })
        })
    }

    /**
     *
     * @param topicName 发起议题的名称
     * @param topicId
     * @param users 发起议题的患者{"userId1:role", "userId2:role"}
     * @param messages 发送的消息对象{description:"",title:"",img:"",senderId:"",senderName:""}图片多个用逗号隔开
     */
    createTopics(topicName, topicId,sessionId,users, messages) {
        let self = this;
        
        //MUC模式中sessionID就是患者ID
        let topics_key = RedisModel.makeRedisKey(REDIS_KEYS.Topics, sessionId);
        let topic_key = RedisModel.makeRedisKey(REDIS_KEYS.Topic, topicId);
        let sessions = new Sessions();
        let participants = new Participants();
        
        //从数据库中获取sessionId
        let date = new Date();
        var pars=[];
        redis.zaddAsync(topics_key, date.getTime(), topicId).then(function (res) {
            redis.hmsetAsync(topic_key, "name", topicName, "end_by", "", "session_id", sessionId, "create_time", date.getTime(), "end_time", "", "description", messages.description, "status", TOPIC_STATUS.NEW).then(function (res) {
                sessions.getSessions(sessionId, function (err, res) {
                    //已经存在对应的会话更新全科为旁听
                    if (res && res.length > 0) {
                        for(var j in users){
                           participants.updateUser(sessionId, j, users[j]);
                        }
                        callbegin();
                    } else {//不存在创建SESSION
                        for(var j in users){
                            pars.push(j+":"+users[j]);
                        }
                        sessions.createSession(sessionId, messages.senderName, SESSION_TYPES.MUC, pars, function (res) {
                            if (res) {
                                callbegin();
                            }
                        });
                    }
                })
            })
        }).catch();
        
        /**
         * 开始消息发送
         */
        function callbegin() {
            let msg = {};
            msg.sender_id = messages.senderId;
            msg.sender_name = messages.senderName;
            msg.content_type = 6;
            msg.content = "开始咨询"
            msg.timestamp = date;
            sessions.saveMessageByTopic(msg, sessionId, function (err, msgId) {
                if (err) {
                    ModelUtil.emitOK(self.eventEmitter, err);
                } else {
                    self.saveTopicsToSql(topicName, topicId, sessionId, msgId, date,messages.description,TOPIC_STATUS.NEW);
                    callBeginMsg(msgId);
                }
            })
        }

        /**
         * 发送求助内容
         */
        function callBeginMsg(startMsgId) {
            let msg = {};
            msg.sender_id = messages.senderId;
            msg.sender_name = messages.senderName;
            msg.content_type = 1;
            msg.content = messages.description;
            msg.timestamp = new Date();
            sessions.saveMessageByTopic(msg,  sessionId, function (err, msgId) {
                log.info("begin send" + messages.description);
            });
            
            if (messages.img) {
                let imgs = messages.img.split(",");
                for (var j in imgs) {
                    let msgimg = {};
                    msgimg.sender_id = messages.senderId;
                    msgimg.sender_name = messages.senderName;
                    msgimg.content_type = 2;
                    msgimg.content = imgs[j];
                    msgimg.timestamp = new Date();
                    sessions.saveMessageByTopic(msgimg, sessionId, function (err, msgId) {
                        log.info("begin send" + imgs[j]);
                    })
                }
            }
            ModelUtil.emitOK(self.eventEmitter, {"id":startMsgId});
        }
    }

    saveTopicsToSql(topicName, topicId, sessionId, messageId, date,description) {
        TopicsRepo.saveTopic(topicName, topicId, sessionId, messageId, date,description);
    }

    /**
     * 结束议题
     * @param topicId
     * @param endUser
     */
    endTopic(topicId, endUser, endUserName) {
        let endDate = new Date();
        let self = this;
        let topic_key = RedisModel.makeRedisKey(REDIS_KEYS.Topic, topicId);
        redis.hmsetAsync(topic_key, "end_time", endDate.getTime(), "end_by", endUser,"status",TOPIC_STATUS.FINISHED).then(function (res) {
            redis.hgetallAsync(topic_key).then(function (topic) {
                callEnd(topic.session_id);
            })
        });
        
        /**
         * 结束消息发送
         */
        function callEnd(sessionId) {
            let msg = {};
            msg.sender_id = endUser;
            msg.sender_name = endUserName;
            msg.content_type = 7;
            msg.content = endUserName + "结束了咨询"
            msg.timestamp = new Date();
            let sessions = new Sessions();
            sessions.saveMessageByTopic(msg, sessionId, function (err, msgId) {
                if (err) {
                    ModelUtil.emitOK(self.eventEmitter, err);
                } else {
                    ModelUtil.emitOK(self.eventEmitter,  {"id":msgId});
                    TopicsRepo.endTopic(topicId, endUser, msg.date, msgId);
                }
            })
        }
    }

    updateTopic(topicId,valueJson){
        let self = this;
        let topic_key = RedisModel.makeRedisKey(REDIS_KEYS.Topic, topicId);
        var dataArray = [];
        for(var j in valueJson){
            dataArray.push(j);
            dataArray.push(valueJson[j]);
        }
        redis.hmsetAsync(topic_key, dataArray).then(function (res) {
            TopicsRepo.updateTopis(topicId,valueJson);
        });
    }
}

// Expose class
module.exports = Topics;