代码修改

src/server/repository/mysql/session.repo.js

@@ -31,6 +31,28 @@ class SessionRepo {
        });
    }
    /**
     * 获取置顶的消息
     * @param userId
     * @param handler
     */
    static getUserStickSessionsFromMysql(userId,handler){
        let sql ="select session_id from participants w where w.participaint_id = ? group by w.session_id";
        let sessionsql = "select s.id,s.name,s.type,s.create_date from session s,sticky_sessions ss  where s.id = ss.session_id s.id in("+sql+")";
        ImDb.execQuery({
            "sql": sessionsql,
            "args": [userId],
            "handler": function (err, res) {
                if(err) {
                    log.error("sql:"+sessionsql+"data:userId："+userId);
                }else{
                    log.info("getMysqlUserSessions success by userId :"+userId);
                }
                handler(err,res);
            }
        });
    }
    /**
     * 获取session单个对象
     * @param sessionId