|
@ -49,26 +49,24 @@ class Sessions extends RedisModel {
|
|
|
//创建session到mysql
|
|
|
self.createSessionToMysql(sessionId, name, type, participantArray, messageId, function (err, res) {
|
|
|
if (err) {
|
|
|
logger.error(err);
|
|
|
} else {
|
|
|
logger.info("create session to mysql success :" + JSON.stringify(res));
|
|
|
}
|
|
|
});
|
|
|
|
|
|
//创建session到redis
|
|
|
self.createSessionToRedis(sessionId, name, type, participantArray, messageId, function (err, res) {
|
|
|
if (err) {
|
|
|
if (handler) {
|
|
|
handler(err, null);
|
|
|
return;
|
|
|
}
|
|
|
ModelUtil.emitError(self.eventEmitter, {message: err, status: -1}, null);
|
|
|
} else {
|
|
|
if (handler) {
|
|
|
handler(null, res);
|
|
|
return;
|
|
|
}
|
|
|
ModelUtil.emitOK(self.eventEmitter, {status: 200, data: res});
|
|
|
//创建session到redis
|
|
|
self.createSessionToRedis(sessionId, name, type, participantArray, messageId, function (err, res) {
|
|
|
if (err) {
|
|
|
if (handler) {
|
|
|
handler(err, null);
|
|
|
return;
|
|
|
}
|
|
|
ModelUtil.emitError(self.eventEmitter, {message: err, status: -1}, null);
|
|
|
} else {
|
|
|
if (handler) {
|
|
|
handler(null, res);
|
|
|
return;
|
|
|
}
|
|
|
ModelUtil.emitOK(self.eventEmitter, {status: 200, data: res});
|
|
|
}
|
|
|
});
|
|
|
}
|
|
|
});
|
|
|
}
|