错误代码修正

src/server/endpoints/v2/session.endpoint.js

@@ -214,10 +214,8 @@ router.post(APIv2.Sessions.Messages, function (req, res) {
    if (!testing.pass) {
        throw {httpStatus: 406, message: testing.message}
    }
    let sessions = new Sessions();
    ControllerUtil.regModelEventHandler(sessions, res);
    payload.timestamp = new Date();
    sessions.saveMessageBySession(req.params.session_id, payload);
});

src/server/models/client/app.client.js

@@ -105,11 +105,12 @@ class AppClient extends RedisModel {
                session_type: sessionType,
                topic_id: '' || message.topic_id,
                from: '' || message.sender_id,
                data: message.content
                data: message.content,
                business_type:message.business_type||1
            };
            if (userStatus.platform == PLATFORMS.iOS) {
                pusher.pushToSingleViaAPN(tipMessage, customData, message.contentType, userStatus.token, function (err, res) {
                pusher.pushToSingleViaAPN(tipMessage, customData,message.contentType, userStatus.token, function (err, res) {
                    if (err) {
                        ModelUtil.logError("Send notification via APN failed", err);
                    }

src/server/models/messages/messages.js

@@ -100,7 +100,8 @@ class Messages extends RedisModel {
            sender_name: message.sender_name,
            timestamp: message.timestamp.getTime(),
            content_type: message.content_type,
            content: message.content
            content: message.content,
            business_type:message.business_type||1
        };
        redis.multi()
@@ -141,6 +142,7 @@ class Messages extends RedisModel {
            "create_date", message.timestamp.getTime(),
            "last_content", message.content,
            "last_content_type", message.content_type,
            "business_type",message.business_type||1,
            "sender_id", message.sender_id,
            "sender_name", message.sender_name
        );

src/server/models/sessions/sessions.js

@@ -493,9 +493,7 @@ class Sessions extends RedisModel {
        let participants = new Participants();
        let sessionKey = RedisModel.makeRedisKey(REDIS_KEYS.Session, sessionId);
        let messageId = mongoose.Types.ObjectId().toString();
        message.id = messageId;
        // 检查会话中是否存在此成员
        participants.existsParticipant(sessionId, message.sender_id, function (err, res) {
            if (err) {

src/server/repository/mysql/message.repo.js

@@ -73,10 +73,10 @@ class MessageRepo {
     */
    static save(message, sessionType, messageId, sessionId, handler) {
        var sql = "INSERT INTO " + DB_TABLES.sessionTypeToTableName(sessionType) +
            " (id, session_id, sender_id, sender_name,content_type, content, timestamp) VALUES (?,?,?,?,?,?,?)";
            " (id, session_id, sender_id, sender_name,content_type, content, timestamp,business_type) VALUES (?,?,?,?,?,?,?,?)";
        ImDb.execQuery({
            "sql": sql,
            "args": [messageId, sessionId, message.sender_id, message.sender_name, message.content_type, message.content, message.timestamp],
            "args": [messageId, sessionId, message.sender_id, message.sender_name, message.content_type, message.content, message.timestamp,message.business_type||1],
            "handler": handler || function (err, res) {
                log.info(res);
            }