/**
 * Created by ysj on 2017/12/4.
 */
"use strict";

let log = require('../../util/log');
let ImDb = require('../oracle/db/im.db');

const DB_TABLES = require('../../include/commons').DB_TABLES;

class SignFamilyRepo{
    constructor(){

    }

    /**
     * 获取单个MessageNoticeSetting对象
     *
     * @param session_id
     * @param handler
     */
    static findDoctor(session_id, handler) {
        let sql = "SELECT S.DOCTOR,S.DOCTOR_HEALTH FROM "+DB_TABLES.Participants+" P,"+DB_TABLES.SignFamily+" S WHERE P.SESSION_ID = ? AND P.PARTICIPANT_ID = S.PATIENT AND S.`STATUS`>0";
        ImDb.execQuery({
            "sql": sql,
            "args": [session_id],
            "handler": handler || function (err, res) {
                if(err) log.error(err);
            }
        });
    }

    /**
     * 判断医生在会话中是否是健管师
     * @param session_id
     * @param doctor
     * @param handler
     */
    static isHealthDoctor(session_id,doctor, handler) {
        let sql = "SELECT S.DOCTOR_HEALTH FROM "+DB_TABLES.Participants+" P,"+DB_TABLES.SignFamily+" S WHERE P.SESSION_ID = ? AND P.PARTICIPANT_ID = S.PATIENT AND S.DOCTOR_HEALTH=? AND S.`STATUS`>0";
        ImDb.execQuery({
            "sql": sql,
            "args": [session_id,doctor],
            "handler": handler || function (err, res) {
                if(err) log.error(err);
            }
        });
    }
}

module.exports = SignFamilyRepo;