"use strict";

var config;
var db;

function init(options) {
    config = options.config;
    db = options.db;
}

function _getByMessageid(messageid, cb) {
    let dbConnection = db.connection();
    if (!dbConnection) {
        cb("db is not connected");
        return;
    }

    let query = "SELECT * FROM T_TRANS WHERE 1=1";
    let filter = {"MESSAGEID": messageid};

    let queryWithFilter = db.composeQueryWithFilter(query, filter);

    dbConnection.execute(queryWithFilter.query, queryWithFilter.values, function(err, res) {
        if (err) {
            cb(err, null);
            return;
        }

        let retval = db.createResultObject(res);

        if (retval && retval.length > 0) {
            cb(null, retval[0]);
        }
        else {
            cb(null, null);
        }
    });
}

function getByMessageid(req, res, next) {
    _getByMessageid(req.params.messageid, function(err, result) {
        if (err) {
            res.send(err.message);
            return;
        }

        res.send(result);
    });
}

function _getLastHourSalesPerChipInfo(cb, hour) {
    if (!hour) {
        hour = 1;
    }

    let dbConnection = db.connection();
    if (!dbConnection) {
        cb("db is not connected");
        return;
    }

    let query = "select CHIP_INFO, COUNT(1) as TRX, sum(PRICE) as AMOUNT, max(TIME_START) as LAST_TS from T_TRANS where TIME_START >= sysdate - :hour / 24 and CHIP_INFO is not null and (TRANS_STAT = '200' or TRANS_STAT = '1200') group by CHIP_INFO";
    dbConnection.execute(query, [hour], function(err, res) {
        if (err) {
            cb(err, null);
            return;
        }

        let retval = db.createResultObject(res);

        if (retval && retval.length > 0) {
            cb(null, retval);
        }
        else {
            cb(null, null);
        }
    });
}

function getLastHourSalesPerChipInfo(req, res, next) {
    _getLastHourSalesPerChipInfo(function(err, result) {
        if (err) {
            res.send(err.message);
            return;
        }

        res.send(result);
    });

}


exports.init = init;
exports.getByMessageid = getByMessageid
exports.getLastHourSalesPerChipInfo = getLastHourSalesPerChipInfo;