#!/usr/bin/env php
<?php
set_time_limit(0);

require '/etc/cdrtool/global.inc';
require 'cdr_generic.php';
require 'rating.php';
// Function to handle SIGINT (CTRL+C)

function signalHandler($signal) {
    if ($signal === SIGINT) {
        echo "\nCTRL+C detected! Exiting gracefully...\n";
    }
}

// Check if pcntl extension is available
if (!function_exists('pcntl_signal')) {
    die("pcntl_signal() is not available. Make sure the PCNTL extension is enabled.\n");
}

// Define signal constant (for clarity)
define('SIGINT', 2);

// Register the signal handler
pcntl_signal(SIGINT, 'signalHandler');
echo "Press CTRL+C to exit...\n";

// override logger for rating engine
changeLoggerChannel('normalization');

$lockFile = "/var/lock/CDRTool_normalize.lock";
$logDir = "/var/log/cdrtool";
$stats_file = sprintf("%s/normalize.txt", $logDir);

if (!is_dir($logDir)) {
    mkdir($logDir, 0777, true); // Create directory with full permissions
}

if ($argv[1]) {
    if (preg_match("/^\d{4}\d{2}$/", $argv[1], $m)) {
        $table = 'radacct'.$argv[1];
    } else {
        die("Error: Month must be in YYYYMM format\n");
    }
}

if ($f = fopen($lockFile, "w")) {
    if (flock($f, LOCK_EX + LOCK_NB, $w)) {
        if ($w) {
            criticalAndPrint("Another CDRTool normalization is in progress. Aborting.\n");
            exit(2);
        }
    } else {
        criticalAndPrint("Another CDRTool normalization is in progress. Aborting.\n");
        exit(1);
    }
} else {
    $log = sprintf("Error: Cannot open lock file %s for writing\n", $lockFile);
    criticalAndPrint($log);
    exit(2);
}

foreach ($DATASOURCES as $k => $v) {
    if (strlen($v["normalizedField"] and !$v["skipNormalize"])) {
        $b = time();
        $class_name = $v["class"];

        unset($CDRS);
        $CDRS = new $class_name($k);


        if (is_array($CDRS->db_class)) {
            $db_class = $CDRS->db_class[0];
        } else {
            $db_class = $CDRS->db_class;
        }

        if ($table) $CDRS->table = $table;

        $log = sprintf("Normalize datasource %s, database %s, table %s\n", $k, $db_class, $CDRS->table);
        loggerAndPrint($log);

        $CDRS->NormalizeCDRS();

        $e = time();
        $d = $e - $b;
        $cps = 0;
        $speed = 0;
 
        if ($CDRS->status['cdr_to_normalize']) {
            if ($d) $speed = number_format($CDRS->status['normalized']/$d, 0, "", "");
            $d2 = abs(strtotime($CDRS->status['newest_date']) - strtotime($CDRS->status['oldest_date']));
            
            if ($d2) $cps = $CDRS->status['normalized']/$d2;

            $log = sprintf(
                "CDR normalized: %6d calls, %6d minutes, %6.1f price, in %3d seconds @ %5d nps, %5d cps\n",
                $CDRS->status['normalized'],
                $CDRS->status['duration']/60,
                $CDRS->status['price'],
                $d,
                $speed,
                $cps
            );

            loggerAndPrint($log);
            $logfile = fopen($stats_file, 'a');
            if ($logfile === false) {
                warningAndPrint(sprintf("Failed to open stats file %s", $stats_file));
            } else {
                fwrite($logfile, sprintf("%s %s", date("Y-m-d H:i:s"), $log));
                fclose($logfile);
            }
        }

        if (!$table && preg_match("/^(\w+)\d{6}$/", $CDRS->table, $m)) {
            $lastMonthTable=$m[1].date('Ym', mktime(0, 0, 0, date("m")-1, "01", date("Y")));

            $log = sprintf("Normalize datasource %s, database %s, table %s\n", $k, $db_class, $lastMonthTable);
            loggerAndPrint($log);

            $b = time();

            $CDRS->table = $lastMonthTable;
            $CDRS->NormalizeCDRS();

            if (!$CDRS->status['cdr_to_normalize']) {
                return;
            }

            $e = time();
            $d = $e - $b;
            $cps = 0;
            $speed = 0;

            if ($d) $speed = number_format($CDRS->status['normalized']/$d, 0, "", "");
            $d2 = abs(strtotime($CDRS->status['newest_date']) - strtotime($CDRS->status['oldest_date']));
            if ($d2) $cps = $CDRS->status['normalized']/$d2;

            $log = sprintf(
                "CDR normalized: %6d calls, %6d minutes, %6.1f price, in %3d seconds @ %5d nps, %5d cps\n",
                $CDRS->status['normalized'],
                $CDRS->status['duration']/60,
                $CDRS->status['price'],
                $d,
                $speed,
                $cps
            );

            loggerAndPrint($log);
            $logfile = fopen($stats_file, 'a');
            if ($logfile === false) {
                warningAndPrint(sprintf("Failed to open stats file %s", $stats_file));
            } else {
                fwrite($logfile, sprintf("%s %s", date("Y-m-d H:i:s"), $log));
                fclose($logfile);
            }
        }
    }
}

keepAliveRatingEngine();