Browse Source

成员替换,创建会话,人员先删除后写入

8 years ago
parent
commit
0cd4c455fd

+ 2 - 1
src/server/models/sessions/participants.js

@ -211,7 +211,8 @@ class Participants extends RedisModel {
     */
    addUser(sessionId, user,role,handler) {
        let self = this;
        let users = [user+":"+role||0];
        if(!role)role = 0;
        let users = [user+":"+role];
        Participants.saveParticipantsToRedis(sessionId, users, new Date(), function (res) {
            if (res) {
                Participants.saveParticipantsToMysql(sessionId, users,function(err,res){

+ 11 - 1
src/server/models/sessions/sessions.js

@ -413,6 +413,14 @@ class Sessions extends RedisModel {
                                            } else {
                                                sessionName = res[0].name;
                                            }
                                            var bir = new Date().getTime();
                                            if(res.length!=0&&res[0].birthdate){
                                                bir = res[0].birthdate.getTime();
                                            }
                                            var sex = 1;
                                            if(res.length!=0&&res[0].sex){
                                                sex =   res[0].sex;
                                            }
                                            sessionList.push({
                                                id: sessionId,
@ -425,7 +433,9 @@ class Sessions extends RedisModel {
                                                sender_name: session.sender_name,
                                                unread_count: count,
                                                business_type: session.business_type,
                                                my_role: role
                                                my_role: role,
                                                sender_sex:sex,
                                                sender_birthday:bir,
                                            });
                                            index = (parseInt(index) + 1);

+ 1 - 1
src/server/repository/mysql/participant.repo.js

@ -124,7 +124,7 @@ class ParticipantRepo {
    }
    static findNameById(userId, handler) {
        let sql = "SELECT p.name FROM patients p WHERE p.id =? union SELECT d.name FROM doctors d WHERE d.id =?";
        let sql = "SELECT p.name,p.sex,p.birthdate FROM patients p WHERE p.id =? union SELECT d.name,d.sex,d.birthdate FROM doctors d WHERE d.id =?";
        ImDb.execQuery({
            "sql": sql,
            "args": [userId, userId],