socket响应问题处理

src/doctor/models/patient.js

@@ -72,7 +72,7 @@ class Patient extends BaseModel {
            }
            // 结束网络连接，后续操作继续执行
            pmRepo.findOneMessage(result.insertId, function (err, msg) {
            pmRepo.findOnePatientMessage(result.insertId, function (err, msg) {
                if (err) {
                    modelUtil.emitDbError(self.eventEmitter, 'Save private message success, but return last message failed', err);
                    return;
@@ -88,8 +88,9 @@ class Patient extends BaseModel {
                    self.sendConsultWechatReplyTempMsg(message);
                    return;
                }
                patientClient.socketServer.sockets.emit('message', message);
                let row = msg[0];
                row.timestamp = objectUtil.timestampToLong(row.timestamp);
                patientClient.socketServer.sockets.emit('message', row);
            });
            // 更新自身的聊天统计信息
@@ -120,7 +121,7 @@ class Patient extends BaseModel {
            return;
        }
        patientClient.socketServer.sockets.emit('message', message);
        patientClient.socketServer.sockets.emit('message',groupRepo.getOnGroupMsg(message.msgId));
    };
    /**

src/doctor/repository/group.repo.js

@@ -9,6 +9,14 @@
var wlyyRepo = require("./database/wlyy.db.js");
var GROUP_TYPE = require('../include/commons').GROUP_TYPE;
exports.getOnGroupMsg=function(msgid,handler){
    wlyyRepo.execQuery({
        "sql": " select g.*,d.`name`,d.photo from msg_group g,wlyy.wlyy_doctor d where g.msg_id=? and g.from_uid=d.code;",
        "args": [msgid],
        "handler": handler
    });
}
/**
 * 判断是否为团队成员。
 *

src/doctor/repository/private.msg.repo.js

@@ -27,6 +27,15 @@ exports.findOneMessage = function (messageId, handler) {
  });
};
exports.findOnePatientMessage = function (messageId,handler) {
    imRepo.execQuery({
        "sql": "SELECT m.*,d.name,d.photo FROM msg_p2p m, wlyy.wlyy_doctor d, wlyy.wlyy_patient p WHERE m.from_uid = d. CODE AND m.to_uid = p. CODE AND m.msg_id =?",
        "args": [messageId],
        "handler": handler
    });
};
/**
 * 查找所有消息。
 *