diff --git a/scripts/normalize.php b/scripts/normalize.php
index 912def4..aeb6869 100755
--- a/scripts/normalize.php
+++ b/scripts/normalize.php
@@ -1,127 +1,163 @@
 #!/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']) {
-            $speed = 0;
-            if ($d) $speed = number_format($CDRS->status['cdr_to_normalize']/$d, 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 normalize: %6d new, %6d done, %6d minutes, %6.1f price, %d seconds, %s cps\n",
-                $CDRS->status['cdr_to_normalize'],
+                "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
+                $speed,
+                $cps
             );
+
             loggerAndPrint($log);
+            syslog(LOG_NOTICE, $log);
+            $logfile = fopen($stats_file,'a');
+            if ($logfile === false) {
+                loggerAndPrint(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']) {
-                $e = time();
-                $d = $e - $b;
-
-                $speed = 0;
-                if ($d) $speed = number_format($CDRS->status['cdr_to_normalize']/$d, 0, "", "");
-                $log = sprintf(
-                    " %d CDRs, %d normalized in %s s @ %s cps\n",
-                    $CDRS->status['cdr_to_normalize'],
-                    $CDRS->status['normalized'],
-                    $d,
-                    $speed
-                );
-                loggerAndPrint($log);
+            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) {
+                loggerAndPrint(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();