/** * 搜索功能。 */ "use strict"; let ImDb = require('../mysql/db/im.db'); let DbUtil = require('../../util/db.util'); let log = require('../../util/log.js'); const DB_TABLES = require('../../include/commons').DB_TABLES; class ParticipantRepo { constructor() { } /** * 获取会话的成员列表 * * @param sessionId * @param handler */ static findParticipants(sessionId, handler) { let sql = "select participant_id, participant_role, last_fetch_time from participants where session_id = ? "; ImDb.execQuery({ "sql": sql, "args": [sessionId], "handler": handler }); } /** * 获取会话的成员列表 * * @param sessionId * @param handler */ static updateParticipant(sessionId, participant_id, role,handler) { let sql = "update participants set participant_role = ? where session_id = ? and participant_id = ?"; ImDb.execQuery({ "sql": sql, "args": [role, sessionId, participant_id], "handler": handler }); } /** * 获取P2P成员所在会话。将成员的ID排序后取哈希值即可。 * * @param userId * @param anotherUserId * @param handler */ static findSessionIdByParticipantIds(userId, anotherUserId, handler) { let sessionId = DbUtil.stringArrayHash([userId, anotherUserId]); handler(null, sessionId); } /** * 用户是否在指定Session中 * * @param sessionId * @param userId * @param handler */ static existsParticipant(sessionId, userId, handler) { let sql = "select case when count(*) > 0 then true else false end exist from participants w where w.session_id =? and w.participant_id = ? "; ImDb.execQuery({ "sql": sql, "args": [sessionId, userId], "handler": handler }); } /** * mysql成员创建 * * @param sessionId * @param users JSON * @param handler */ static saveParticipantsToMysql(sessionId, users, handler) { let sql = "insert into " + DB_TABLES.Participants + " (session_id,participant_id,participant_role) VALUES " let args = []; for (var j in users) { sql += "(?,?,?)"; let tokens = users[j].split(":"); args.push(sessionId); args.push(tokens[0]); args.push(tokens.length > 1 ? tokens[1] : '0'); if (j != users.length - 1) sql += ", "; } sql += " ON DUPLICATE KEY UPDATE participant_role = VALUES(participant_role)"; ImDb.execQuery({ "sql": sql, "args": args, "handler": handler }); } static deleteUserFromMysql(sessionId, userId) { let sql = "delete from " + DB_TABLES.Participants + " where user_id=? and session_id=? "; ImDb.execQuery({ "sql": sql, "args": [userId, sessionId], "handler": handler }); } static getPatientOpenid(code, handler) { var sql = "select openid from patients where code = ? "; ImDb.execQuery({ "sql": sql, "args": [code], "handler": handler }); } } module.exports = ParticipantRepo;