im.doctor/src/server/repository/doctor.repo.js

/**
 * 医生模型。医生真实数据存在于家庭医生平台数据库，即医生的ID，姓名，年龄等详细内容。而IM平台的user表只包含用户当前的在线状态，
 * 即用户的准实时状态，token等内容，不包含用户具体的详细信息。
 */
"use strict";

var log = require('../util/log');
var imRepo = require("./mysql/im.db.js");
var wlyyRepo = require("./mysql/wlyy.db.js");

class DoctorRepo {
    constructor() {
    }

    static update() {

    }

    static findOne(code, handler) {
        wlyyRepo.execQuery({
            "sql": "select code, name from doctors where code = ? ",
            "args": [code],
            "handler": handler
        });
    };

    /**
     * 判断用户是否存在。数据从家庭医生平台获取，而不是IM库的user表。
     *
     * @param user
     * @param handler
     */
    static isExist(user, handler) {
        wlyyRepo.execQuery({
            "sql": "SELECT count(*) from wlyy_doctor WHERE code=?",
            "args": [user],
            "handler": handler
        });
    };

    static getUserStatus(userId, handler) {
        imRepo.execQuery({
            "sql": "SELECT platform,token,client_id,is_online,status from user WHERE user_id = ?",
            "args": [userId],
            "handler": handler
        });
    };

    static login(userId, token, client_id, platform, handler) {
        imRepo.execQuery({
            "sql": "INSERT INTO user (user_id,token,client_id,platform,is_online,status) VALUES (?,?,?,?,1,1) ON" +
            " DUPLICATE KEY UPDATE token=?,client_id=?,platform=?,is_online=1,status=1",
            "args": [userId, token, client_id, platform, token, client_id, platform],
            "handler": handler
        });
    };

    static logout(userId, handler) {
        imRepo.execQuery({
            "sql": "UPDATE user SET is_online='0',status='0' WHERE user_id=?",
            "args": [userId],
            "handler": handler
        });
    };

    static deleteToken(token, handler) {
        imRepo.execQuery({
            "sql": "DELETE FROM user WHERE token=?",
            "args": [token],
            "handler": handler
        });
    };

    static updateStatus(userId, status, handler) {
        imRepo.execQuery({
            "sql": "UPDATE user SET status=? WHERE user_id=?",
            "args": [status, userId],
            "handler": handler
        });
    };
}

module.exports = DoctorRepo;