/**
 * 统计。
 */
"use strict";

let BaseModel = require('./base.model');
let statsRepo = require("../repository/mysql/stats.msg.repo.js");
let log = require("../util/log.js");
let modelUtil = require('../util/model.util');

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

    /**
     * 获取应用角标数，基于消息数量。
     * @param userId
     */
    getBadgeNumber(userId){
        let self = this;
        statsRepo.getBadgeNumber(userId, function (err, result) {
            if (err) {
                modelUtil.emitError(self.eventEmitter, "Get badge number failed: ", err);
                return;
            }

            let data = {userId: userId, badge: result};
            modelUtil.emitOK(self.eventEmitter, data);
        });
    }
}

module.exports = StatsMessage;