import Window from '../core/Window'
import DBService from '../db/DBService'
import logger from '../logger/Logger'
import Object from '../model/Object'
import DateUtil from '../util/DateUtil'
import BaseEvent from '../core/BaseEvent'

// 监听每天计算用户流量事件
export default class DailyUserUsedFlowEvent extends BaseEvent {

    async callback(window: Window) {
        let begin = window.getBegin()
        let date = DateUtil.getDate(begin)
        let result = window.getResult()
        let data: string[][] = []

        for (const country in result) {
            let flows = result[country]

            for (const userName in flows) {
                const flow = flows[userName]
                let { tx, rx, duration } = flow
                
                data.push([date, country, userName, tx, rx, duration])
            }
        }

        if (data.length !=0) {
            let sql = "INSERT INTO daily_user_used_flow(date, country, userName, tx, rx, duration) VALUES ?"
            let dbService = new DBService()
            let { err } = await dbService.insert(sql, [data])
            
            if (err) {
                logger.info(err)
            } else {
                logger.info(`插入每天用户使用流量 ${data.length}`)
            }
        }
    }
}