@ -120,6 +120,7 @@ server.on('error', function (error) {
server.on('listening', function onListening() {
let addr = server.address();
let bind = typeof addr === 'string' ? 'pipe ' + addr : 'port ' + addr.port;
log.info('bind'+bind);
});
let socketHandler = new SocketHandler(io);
@ -125,7 +125,7 @@ class SessionRepo {
static findAllByTypes(userId, type, handler) {
let sql = "select session_id from " + DB_TABLES.Participants + " w where w.participant_id = ? group by w.session_id";
let sessionSQL = "select id, name, type, create_date, last_sender_id, last_sender_name, last_content_type, last_content, last_message_time from "
+ DB_TABLES.Sessions + " s where s.id in(" + sql + ") AND s.STATUS = 0 ";
+ DB_TABLES.Sessions + " s where s.id in(" + sql + ") AND s.status = 0 ";
log.info("获取用户全部会话: sql :" + sessionSQL);
if(type){
sessionSQL +=" and type in("+type+") ";