会话相关修改

src/server/endpoints/chats.endpoint.js

@@ -69,7 +69,7 @@ router.post(APIv1.Chats.SM, function (req, res) {
router.get(APIv1.Chats.TEST,function(req,res){
    let test = req.query.test;
    //http://192.168.131.107:3008/api/v1/chats/test?test=1&page=0&pagesize=10&user=3121&sessionId=testsessionmsg1
    if(test==1){
    if(test==1){//获取会话消息列表
        let page = req.query.page;
        let pagesize = req.query.pagesize;
        let user = req.query.user;
@@ -79,7 +79,7 @@ router.get(APIv1.Chats.TEST,function(req,res){
        sessions.getSessionMessages(sessionId,user,page,pagesize);
    }
    //http://192.168.131.107:3008/api/v1/chats/test?test=2&page=0&pagesize=10&user=3121
    if(test==2){
    if(test==2){//获取用户会话
        let sessions = new Sessions();
        let page = req.query.page;
        let pagesize = req.query.pagesize;
@@ -87,15 +87,38 @@ router.get(APIv1.Chats.TEST,function(req,res){
        controllerUtil.regModelEventHandler(sessions, res);
        sessions.getUserSessions(user,page,pagesize);
    }
    //
    //http://192.168.131.107:3008/api/v1/chats/test?test=3&sessionId=132312312&users=10,2,3&name=3121&sessionType=2
    if(test==3){
        let sessions = new Sessions();
        controllerUtil.regModelEventHandler(sessions, res);
        let sessionId = req.query.sessionId;
        let users = req.query.users;
        let name = req.query.name;
        let sessionType = req.query.sessionType;
        sessions.createSessions(sessionId,name,sessionType,users);
    }
    if(test==4){
        let sessions = new Sessions();
        controllerUtil.regModelEventHandler(sessions, res);
        let sessionId = req.query.sessionId;
        let message ={};
        message.contentType =1;
        message.timestamp=new Date();
        message.content ="test send message";
        message.senderId="10";
        message.senderName="test1";
        sessions.saveMessageBySession(message,sessionId);
    }
    //http://192.168.131.107:3008/api/v1/chats/test?test=5&page=0&pagesize=10&user=3121&sessionId=testsessionmsg1
    if(test==5){
        let sessions = new Sessions();
        controllerUtil.regModelEventHandler(sessions, res);
        let sessionId = req.query.sessionId;
        let user = req.query.user;
        let page = req.query.page;
        let pagesize = req.query.pagesize;
        sessions.getSessionMessages(sessionId,user,page,pagesize);
    }
})

src/server/models/sessions/participants.js

@@ -34,8 +34,30 @@ class Participants extends RedisModel {
     */
    getParticipantsBySessionId(sessionId){
    }
    /**
     * 判断成员是否存在这个讨论组中
     * @param sessionId
     * @param userId
     */
    existsUser(sessionId,userId,handler){
      let  participant_key =  super.makeRedisKey(RedisKey.Participants,sessionId);
      return redis.zrangeAsync(participant_key,0,-1).then(function(res){
          let exists = false
          for(var j in res){
              var value = res[j];
              if(value==userId){
                  exists  = true;
                  break;
              }
          }
          handler(exists);
      })
    }
    /**
     * 根据医生和患者
     * @param patient
@@ -57,6 +79,14 @@ class Participants extends RedisModel {
        });
    }
    /**
     * 将成员写入redis
     * @param session_id 会话ID
     * @param users 用户集合
     * @param createDate 创建日期
     * @param handler 回调
     */
    createParticipantsToRedis(session_id,users,createDate,handler){
        let participants_key =  super.makeRedisKey(RedisKey.Participants,session_id);
        for(var j in users){

src/server/models/sessions/sessions.js

@@ -51,7 +51,6 @@ class Sessions extends RedisModel {
                    calllist(res[j],j,res.length);
                }
            }
            function calllist(session,j,_len){
                let session_key =_super(RedisKeys.Session,session);
                redis.hgetallAsync(session_key).then(function(res){
@@ -113,33 +112,40 @@ class Sessions extends RedisModel {
        let self = this;
        let message_timestamp_key = super.makeRedisKey(RedisKeys.MessagesTimestamp,sessionId);
        let message_key = super.makeRedisKey(RedisKeys.Messages,sessionId);
        let participants = super.makeRedisKey(RedisKeys.Participants,sessionId);
        let participants_key = super.makeRedisKey(RedisKeys.Participants,sessionId);
        if(page>0){
            page = page*pagesize;
            pagesize = pagesize+page;
        }
        //倒序取出最后N条消息
        redis.zrevrangeAsync(message_timestamp_key,page,pagesize).then(function(res){
            //取出消息实体
            if(res.length==0){
                modelUtil.emitData(self.eventEmitter,{"status":200,"data":[]});
                return;
            }
            redis.hmgetAsync(message_key,res).then(function(messages) {
                console.log(messages)
                //将取到的消息返回给前端
                modelUtil.emitData(self.eventEmitter,{"status":200,"data":messages});
            }).then(function(){
                //更新患者最后一次获取消息的日期
                redis.zaddAsync(participants, (new Date().getTime()),user).then(function(res){
                    console.log(res);
        let participants = new Participants();
        participants.existsUser(sessionId,user,function(res){
            if(!res){
                modelUtil.emitData(self.eventEmitter,{"status":-1,"msg":"用户不在此会话中！"});
            }else{
                //倒序取出最后N条消息
                redis.zrevrangeAsync(message_timestamp_key,page,pagesize).then(function(res){
                    //取出消息实体
                    if(res.length==0){
                        modelUtil.emitData(self.eventEmitter,{"status":200,"data":[]});
                        return;
                    }
                    redis.hmgetAsync(message_key,res).then(function(messages) {
                        console.log(messages)
                        //将取到的消息返回给前端
                        modelUtil.emitData(self.eventEmitter,{"status":200,"data":messages});
                    }).then(function(){
                        //更新患者最后一次获取消息的日期
                        redis.zaddAsync(participants_key, (new Date().getTime()),user).then(function(res){
                            console.log(res);
                        }).catch(function(res){
                            throw res;
                        })
                    })
                }).catch(function(res){
                    throw res;
                    modelUtil.emitData(self.eventEmitter,{"status":-1,"msg":res});
                })
            })
        }).catch(function(res){
            modelUtil.emitData(self.eventEmitter,{"status":-1,"msg":res});
        })
            }
         })
    }
    /**
     * 更新最后一条消息
@@ -169,32 +175,40 @@ class Sessions extends RedisModel {
    saveMessageBySession(message,sessionId) {
        let self = this;
        let messages = new Messages();
        let participants = new Participants();
        let session_key = super.makeRedisKey(RedisKeys.Session,sessionId);
        let message_id = mongoose.Types.ObjectId().toString();
        let session_type = 0;
        let name = "";
        let messages = new Messages();
        redis.hmgetAsync(session_key, ["type","name"]).then(function(res){
            session_type = res[0];
            name  = res[1];
            if(!session_type||!name){
                log.error("session is error for key "+session_key);
                throw "session is not found";
        participants.existsUser(sessionId,messages.senderId,function(res){
            //校验发送成员是都在讨论组
            if(res){
                redis.hmgetAsync(session_key, ["type","name"]).then(function(res){
                    session_type = res[0];
                    name  = res[1];
                    if(!session_type||!name){
                        log.error("session is error for key "+session_key);
                        throw "session is not found";
                    }
                }).then(function(res){
                    //更新消息相关
                    return  messages.saveMessageForRedis(message_id,sessionId,message);
                }).then(function (res) {
                    //更新session的最后一条聊天记录
                    return self.updateLastContent(session_key,session_type,name,message);
                }).then(function (res) {
                    //操作mysql数据库
                    messages.saveMessageForMysql(message,session_type,message_id,sessionId);
                    //返回数据给前端。
                    modelUtil.emitData(self.eventEmitter, {"status":200,"msg":"发送成功！"});
                    //消息推送
                }).catch(function (res) {
                    modelUtil.emitData(self.eventEmitter,{"status":-1,"msg":res});
                })
            }else{
                modelUtil.emitData(self.eventEmitter,{"status":-1,"msg":"用户不在此会话当中！"});
            }
        }).then(function(res){
            //更新消息相关
            return  messages.saveMessageForRedis(message_id,sessionId,message);
        }).then(function (res) {
            //更新session的最后一条聊天记录
            return self.updateLastContent(session_key,session_type,name,message);
        }).then(function (res) {
            //操作mysql数据库
            messages.saveMessageForMysql(message,session_type,message_id,sessionId);
            //返回数据给前端。
            modelUtil.emitData(self.eventEmitter, {"status":200,"msg":"发送成功！"});
            //消息推送
        }).catch(function (res) {
            modelUtil.emitData(self.eventEmitter,{"status":-1,"msg":res});
        })
    }