im.doctor/src/doctor/models/search.js

/**
 * 患者、讨论组搜索。
 *
 * 注意：此模型效率堪忧，但为了实现先这样做。更稳妥的方案是使用Solr或Elastic Search
 * 为数据提供索引功能，JS使用搜索接口搜索之后再取得对象的ID进行获取，提高效率。
 * 后续开发都希望看到这段注释，实现此方案。
 *
 * author: Sand
 * since: 2016.11.20
 */
"use strict";

let BaseModel = require('./base.model');
let searchRepo = require('../repository/search.repo');
let modelUtil = require("../util/modelUtil");
let objectUtil = require('../util/objectUtil');

class Search extends BaseModel{
    constructor() {
        super();
    }

    /**
     * 搜索患者相关的数据，包括患者信息与相关的私信记录。关键词不支持空格拆分。
     */
    searchAboutPatient(userId, userRole, keyword) {
        let self = this;
        searchRepo.searchPatients(userId, userRole, keyword, function (err, patients) {
            if (err) {
                modelUtil.emitDbError(self.eventEmitter, "Search patient on basic information failed", err);
                return;
            }

            let data = {patients: [], chats: []};
            for (let i = 0; i < patients.length; ++i) {
                let patient = patients[i];
                data.patients.push({
                    code: patient.code,
                    name: patient.name,
                    sex: patient.sex,
                    birthday: objectUtil.timestampToLong(patient.birthday),
                    avatar: patient.photo === null ? "" : patient.photo
                });
            }

            searchRepo.searchPatientPM(userId, keyword, function (err, chats) {
                if (err) {
                    modelUtil.emitDbError(self.eventEmitter, "Search patient on private messages failed", err);
                    return;
                }

                let lastPatientCode = '';
                let lastPatient = {code: '', name: '', sex: '', avatar: '', messages: []};
                for (let i = 0; i < chats.length; ++i) {
                    let chat = chats[i];
                    if (lastPatientCode !== chat.code) {
                        lastPatientCode = chat.code;
                        lastPatient.code = chat.code;
                        lastPatient.name = chat.name;
                        lastPatient.sex = chat.sex;
                        lastPatient.birthday = objectUtil.timestampToLong(patient.birthday);
                        lastPatient.avatar = chat.photo === null ? "" : chat.photo;

                        data.chats.push(lastPatient);
                    }

                    lastPatient.messages.push({
                        id: chat.msg_id,
                        content: chat.content
                    });
                }

                modelUtil.emitData(self.eventEmitter, data);
            });
        });
    }

    /**
     * 搜索医生相关的数据，包括医生信息与相关的聊天记录，包括私信与群信。
     */
    searchAboutDoctor() {
        let self = this;

        searchRepo.searchDoctors(userId, keyword, function (err, doctors) {
            if (err) {
                modelUtil.emitDbError(self.eventEmitter, "Search doctor on basic information failed", err);
                return;
            }

            let data = {doctors: [], groups: [], chats: {doctors: [], groups: []}};
            for (let i = 0; i < doctors.length; ++i) {
                let doctor = doctors[i];
                data.doctors.push({
                    code: doctor.code,
                    name: doctor.name,
                    sex: doctor.sex,
                    avatar: doctor.photo === null ? "" : doctor.photo
                });
            }

            // 搜索讨论组名称及成员名称
            searchRepo.searchGroups(userId, keyword, function (err, groups) {
                if (err) {
                    modelUtil.emitDbError(self.eventEmitter, "Search talk group failed", err);
                    return;
                }

                let lastGroupCode = '';
                let lastGroup = null;
                for (let i = 0; i < groups.length; ++i) {
                    let group = groups[i];
                    if (lastGroupCode !== group.code) {
                        lastGroupCode = group.code;
                        lastGroup = {
                            code: group.code,
                            name: group.name,
                            type: GROUP_TYPE.DiscussionGroup,
                            members: []
                        };

                        data.groups.push(lastGroup);
                    }

                    lastGroup.members.push({
                        code: group.member_code,
                        name: group.member_name
                    });
                }

                // 搜索医生间的私信
                searchRepo.searchDoctorMessages(userId, keyword, function (err, messages) {
                    if (err) {
                        modelUtil.emitDbError(self.eventEmitter, "Search doctor private messages failed", err);
                        return;
                    }

                    let lastDoctor;
                    let lastDoctorCode = '';
                    for (let i = 0; i < messages.length; ++i) {
                        let message = messages[i];
                        if (lastDoctorCode !== message.code) {
                            lastDoctorCode = message.code;
                            lastDoctor = {
                                code: message.code,
                                name: message.name,
                                photo: message.photo === null ? "" : message.photo,
                                messages: []
                            };

                            data.chats.doctors.push(lastDoctor);
                        }

                        lastDoctor.messages.push({
                            id: message.msg_id,
                            content: message.content
                        });
                    }

                    // 搜索医生间的讨论组消息
                    searchRepo.searchGroupMessages(userId, keyword, function (err, messages) {
                        if (err) {
                            modelUtil.emitDbError(self.eventEmitter, "Search doctor group messages failed", err);
                            return;
                        }

                        // g.code, g.name, gm.msg_id, gm.content
                        let lastGroup;
                        let lastGroupCode = '';
                        for (let i = 0; i < messages.length; ++i) {
                            let message = messages[i];
                            if (lastGroupCode !== message.code) {
                                lastGroupCode = message.code;
                                lastGroup = {
                                    code: message.code,
                                    name: message.name,
                                    messages: []
                                };

                                data.chats.groups.push(lastGroup);
                            }

                            lastGroup.messages.push({
                                id: message.msg_id,
                                content: message.content
                            });
                        }

                        modelUtil.emitData(self.eventEmitter, data);
                    });
                });
            });
        });
    }
}