/** * 用户集合。管理Redis中的用户列表。 * * author: Sand * since: 12/13/2016 */ "use strict"; let RedisKeys = require('../../include/commons').REDIS_KEYS; let BaseModel = require('../base.model'); let DoctorRepo = require('../../repository/mysql/doctor.repo'); let PatientRepo = require('../../repository/mysql/patient.repo'); let RedisClient = require('../../repository/redis/redis.client'); let redisConn = RedisClient.redisClient().connection; let log = require('../../util/log'); let async = require('async'); var imDb = require('../../repository/mysql/db/im.db'); class Users extends BaseModel { constructor() { super(); this._key = RedisKeys.Users; } getUser(userId) { } isPatientId(userId) { return async.waterfall([ function (callback) { var sql = "select case count(*) > 0 then true else false is_patient end c from patients where code = ?"; imDb.execQuery({ "sql": sql, "args": [userId], "handler": function (err, res) { callback(err, res); } }); return false; }, function (res, callback) { callback(null, res.is_patient); } ], function (err, res) { if (err) { log.error("User id probe failed: ", err); return false; } return res; }); } } module.exports = Users;