#!/usr/bin/php
<?php
if (isset($_SERVER['REMOTE_ADDR'])) die('Direct access not permitted');
//
// Usage: $argv[0] {virtmeternum} {meternumlisttoadd|0} {meternumlisttosub|0}{energy|power|cost|fixedcost|energycost} {F1|F2|F3|F23|0} [--plain]
//
// eg:
//      virtmeter 14 9,11 8 energy 0    -> met14 = met9+met11-met8
//      virtmeter 15 12 0 energy F1     -> met15 = met12 (only if F1)
//      virtmeter 16 12 0 energy F23    -> met16 = met12 (only if F23)
//

// --------- DEFAULT COST PARAMETERS ---------------------------------------------------

$POTENZA = 6; // KW

// ---- $fileTariffa format ------
// DVAL,QS,QP,F1PE,F23PE,S1,S1PE,S2,S2PE,S3,S3PE,S4,S4PE,ACCISA,IVA
// 20151001,44.5340,16.4109,0.06730,0.06186,1800,0.127502,2640,0.144632,4440,0.184452,99999999,0.227122,0.0227,0.10
// ...
//------------------------

// Optional external Tariffa filename
$filenameTariffa = dirname(__FILE__) . '/' . 'tariffa.csv';

// If $filenameTariffa does not exist, following values will be used

// Quota servizi (/anno)
$QS = 44.5340;
// Quota energia (*Kw/anno)
$QP = 16.4109;
// Prezzo Energia
$F1PE  = 0.06730; $F23PE = 0.06186;
// Scaglioni e Prezzo Scaglioni 
$S1 = 1800;       $S2 = 2640;       $S3 = 4440;       $S4 = 9999999;
$S1PE = 0.127502; $S2PE = 0.144632; $S3PE = 0.184452; $S4PE = 0.227122;

// Soglie pagamento Accise per tariffa D2
$SAE = 1800;    // Soglia Accisa esente/anno in Kw
$SAT = 2640;    // Soglia Accisa calcolata in quotaparte/anno in Kw
// Per l'eccedente $SAP l'accisa si paga per tutti i Kw

// Percentuali Iva e Accisa
$ACCISA = 0.0227; $IVA=0.10;

// -----------------------------------------------------------------------------

$version = '0.2.6.1';

$shortopts  = '';
$shortopts .= 'P:';     // Contractual Power (khw)
//$shortopts .= 'v';    // Version
//$shortopts .= 'F:';   // Fascia

$longopts  = array(
    'onlydiff',         // Output only difference from latest output
    'plain',            // Plain output (only value)
    'plantpower:',      // Contractual Power (khw)
    'tariffa:',         // Use specified 'tariffe/<tariffa>.csv' file for tariffa
    'debug',           // Output debug info for internal computations
);

$options = getopt($shortopts, $longopts);
$debugflag=0;
if (isset($options['debug'])) {
        $debugflag = 1; 
        var_dump($options);
}


// Remove options from $argv array
$pruneargv = array();
foreach ($options as $option => $value) {
  foreach ($argv as $key => $chunk) {
    $regex = '/^'. (isset($option[1]) ? '--' : '-') . $option . '/';
    if ($chunk == $value && $argv[$key-1][0] == '-' || preg_match($regex, $chunk)) {
      array_push($pruneargv, $key);
    }
  }
}
while ($key = array_pop($pruneargv)) unset($argv[$key]);
$argv = array_merge( $argv );
if ($debugflag) var_dump($argv);

if (isset($options['P']))          $POTENZA = $options['P'];    
if (isset($options['plantpower'])) $POTENZA = $options['plantpower'];    

if (isset($options['tariffa'])) $filenameTariffa = dirname(__FILE__) . '/tariffe/' . $options['tariffa'] . '.csv';

// No file edit needed below: just pass the right parameters to the script
$argvMetnum     =1;
$argvMetnumToAdd=2;
$argvMetnumToSub=3;
$argvEnergyPower=4;
$argvFascia     =5;

$metnumtoadd  = array();
$metnumtosub  = array();

$calltime = time();

if (!isset($argv[$argvMetnum]))      $argv[$argvMetnum]=null;
if (!isset($argv[$argvMetnumToAdd])) $argv[$argvMetnumToAdd]=null;
if (!isset($argv[$argvMetnumToSub])) $argv[$argvMetnumToSub]=null;
if (!isset($argv[$argvEnergyPower])) $argv[$argvEnergyPower]=null;
if (!isset($argv[$argvFascia]))      $argv[$argvFascia]=null;

function isFesta($tsTime) {
  $feste=Array(101, 106, 425, 501, 602, 815, 1101, 1208, 1225, 1226);

  // Pasqua è sempre domenica, controllo Pasquetta
  if (date('Y-m-d', strtotime('+1 day', easter_date())) == date('Y-m-d', $tsTime)) return (true);

  // Controllo le altre feste
  $data100 = (date('n', $tsTime) * 100) + date('d', $tsTime);
  foreach ($feste as $festa) {
    if ($festa == $data100) return (true);
  }
  return false;
}

// Fascia tariffaria (F1, F2, F3)
//
// Le fasce orarie sono:
// F1 (ore di punta):    dalle ore 8.00 alle ore 19.00 dal lunedì al venerdì
// F2 (ore intermedie):  dalle ore 7.00 alle ore 8.00 e dalle ore 19.00 alle
//                       ore 23.00 dal lunedì al venerdì e dalle ore 7.00 alle
//                       ore 23.00 del sabato;
// F3 (ore fuori punta): dalle ore 00.00 alle ore 7.00 e dalle ore 23.00 alle
//                       ore 24.00 dal lunedì al sabato e tutte le ore della
//                       domenica e dei giorni:
//                              1 e 6 gennaio;
//                              lunedì dell'Angelo;
//                              25 aprile;
//                              1 maggio;
//                              2 giugno;
//                              15 agosto;
//                              1 novembre;
//                              8, 25 e 26 dicembre.
//
function fascia($tsTime) {
  $giorno = date("w",$tsTime); // 0 (dom) -> 6 (sab)
  $ora    = date('Hi', $tsTime); // 23:35 -> 2335

  // Il confronto orario tiene conto del ritardo di metern ad acquisire il dato
  // e considera un possibile ritardo di misura fino a 60 secondi rispetto alle
  // ore "intere". Le letture al termine della fascia oraria vengono
  // considerate appartenenti alla fascia oraria precedente.
  // La prima lettura nella nuova fascia oraria avviene dopo 5 minuti, quindi
  // risulta sempre nell'intervallo temporale di spettanza ed il suo incremento
  // viene aggiunto naturalmente alla fascia oraria corretta.

  // Festivo o domenica -> Fascia F3
  if (isfesta($tsTime) || $giorno == 0)
      return 'F3';

  // "23:00:00" > "07:00:00" -> Fascia F3
  // c'è un cambio data e l'ordine dei numeri è inverso -> !
  if (!($ora <= "2300" && $ora > "0700"))
      return 'F3';

  // Sabato "07:00:00" > "23:00:00" -> Fascia F2
  if ($giorno == 6 && $ora > "0700" && $ora <= "2300")
      return 'F2';

  // Feriali "07:00:00" > "08:00:00", "19:00:00" > "23:00:00" -> Fascia F2
  if ($ora > "0700" && $ora <= "0800" ||
      $ora > "1900" && $ora <= "2300" )
      return 'F2';

  // Tutto il resto F1
  return 'F1';
}

function isFascia($tsTime, $F) {
  $result = fascia($tsTime);
  if ($F=='0')       return TRUE;
  if ($result == $F) return TRUE;
  if ($F=='F23' && ($result=='F2' || $result=='F3')) return TRUE;
  return FALSE;
}


if (    $argv[$argvMetnum] != NULL && $argv[$argvMetnumToAdd] != NULL
    &&  $argv[$argvMetnumToSub] != NULL && $argv[$argvEnergyPower] != NULL
    && ($argv[$argvEnergyPower]=='energy' || $argv[$argvEnergyPower]=='power' ||
         $argv[$argvEnergyPower]=='cost' ||
         $argv[$argvEnergyPower]=='energycost' ||
         $argv[$argvEnergyPower]=='fixedcost')
     && ($argv[$argvFascia]=='F1' || $argv[$argvFascia]=='F2'  ||
         $argv[$argvFascia]=='F3' || $argv[$argvFascia]=='F23' ||
         $argv[$argvFascia]=='0')) {

    $metnum = $argv[$argvMetnum];          // Virtual Meter Number
    $fascia = $argv[$argvFascia];

    // Get Meter Numbers to Add into an Array of int
    $metnumtoadd = json_decode('[' . $argv[$argvMetnumToAdd] . ']', true);
    // Get Meter Numbers to Sub into an Array of int
    $metnumtosub = json_decode('[' . $argv[$argvMetnumToSub] . ']', true);

    $val=0.0;
    $toadd=0.0;
    $tosub=0.0;

    $addnumlist = array();
    $subnumlist = array();

    define('checkaccess', TRUE);
    include(__DIR__ . '/../config/config_main.php');
    include(__DIR__ . '/../scripts/memory.php');

    // Read MeterN meters types and config
    for ($i = 1; $i <= $NUMMETER; $i++) {
        if (file_exists(__DIR__ . "/../config/config_met$i.php")) {
          include(__DIR__ . "/../config/config_met$i.php");
          if (in_array ( $i, $metnumtoadd, true) && !${"SKIPMONITORING$i"}) $addnumlist[] = $i;
          if (in_array ( $i, $metnumtosub, true) && !${"SKIPMONITORING$i"}) $subnumlist[] = $i;
        }
    }

    if ($argv[$argvEnergyPower] == 'power' && isFascia($calltime, $fascia)) {

	// Read MeterN Livememory
	@$shmid = shmop_open($LIVEMEMORY, 'a', 0, 0);
	if (!empty($shmid)) {
            $data = shmop_read($shmid, 0, 0);
            shmop_close($shmid);
            $memarray = json_decode($data, true);
        }

        $cnt = count($addnumlist);
        for ($i = 0; $i < $cnt; $i++)
	    if (isset($memarray["${'METNAME'.$addnumlist[$i]}$addnumlist[$i]"]))
                $toadd += $memarray["${'METNAME'.$addnumlist[$i]}$addnumlist[$i]"];

        $cnt = count($subnumlist);
        for ($i = 0; $i < $cnt; $i++)
	    if (isset($memarray["${'METNAME'.$subnumlist[$i]}$subnumlist[$i]"]))
	        $tosub += $memarray["${'METNAME'.$subnumlist[$i]}$subnumlist[$i]"];

    } elseif ($argv[$argvEnergyPower] == 'energy'
           || $argv[$argvEnergyPower] == 'cost' 
           || $argv[$argvEnergyPower] == 'energycost' 
           || $argv[$argvEnergyPower] == 'fixedcost' 
           ) {

	// Read MeterN Memory
	@$shmid = shmop_open($MEMORY, 'a', 0, 0);
	if (!empty($shmid)) {
          $data = shmop_read($shmid, 0, 0);
           shmop_close($shmid);
          $memarray = json_decode($data, true);
        }

        if (isFascia($calltime, $fascia)) {
          $cnt = count($addnumlist);
          for ($i = 0; $i < $cnt; $i++) if (isset($memarray["Diffcounter$addnumlist[$i]"])) $toadd += $memarray["Diffcounter$addnumlist[$i]"];

          $cnt = count($subnumlist);
          for ($i = 0; $i < $cnt; $i++) if (isset($memarray["Diffcounter$subnumlist[$i]"])) $tosub += $memarray["Diffcounter$subnumlist[$i]"];
        }
    }

    $ID = ${"ID$metnum"};

    // Computations
    $val = $toadd - $tosub;
    // Remove check for tolerance compatibility
    //if ($val  < 0) $val=0;

    // Output
    settype($val, 'float');

    if ($argv[$argvEnergyPower] == 'energy') {
        if (!isset($options["onlydiff"]))
	       $val+= isset($memarray['Totalcounter'.$metnum]) ? $memarray['Totalcounter'.$metnum] : 0;
	$val = round($val, ${'PRECI' . $metnum});
	if (isset($options['plain'])) $str = utf8_decode("$val");
        else $str = utf8_decode("$ID($val*${'UNIT'.$metnum})");
    } elseif ($argv[$argvEnergyPower]=='cost'
           || $argv[$argvEnergyPower]=='energycost' 
           || $argv[$argvEnergyPower]=='fixedcost' ) {

        // Struttura file tariffa.csv
        //
        // DVAL,QS,QP,F1PE,F23PE,S1,S1PE,S2,S2PE,S3,S3PE,S4,S4PE,ACCISA,IVA
        // 20151001,44.5340,16.4109,0.06730,0.06186,1800,0.127502,2640,0.144632,4440,0.184452,99999999,0.227122,0.0227,0.10
        //
        // Se esiste un file tariffa.csv, lo leggo e sovrascrivo i prezzi
        // di default
        //
        if(file_exists($filenameTariffa) && is_readable($filenameTariffa)) {
            $arrayFromCSV =  array_map('str_getcsv', file($filenameTariffa));
            $_header = array_shift($arrayFromCSV);
            //if ($debugflag) var_dump($_header);
            array_multisort($arrayFromCSV, SORT_DESC);
            //if ($debugflag) var_dump($arrayFromCSV);
            // Ricavo la tariffa in vigore
            for ($i=0; $i<count($arrayFromCSV); $i++) {
              //echo date('Ymd') . ' vs ' . $arrayFromCSV[$i][0], PHP_EOL;
              if (date('Ymd') >= $arrayFromCSV[$i][0]) {
                    $_data = $arrayFromCSV[$i];
                    $data=array_combine($_header,$_data);
                    break;
              }
            }
            // Leggo i dati per il calcolo
            foreach ($data as $key => $value) {
              ${$key} = $value;
            }
        }
        if ($debugflag) var_dump($data);

        // Divisori vari
        $yeardays = date("z", strtotime( date('Y') . '-12-31')) + 1;
        $year5min = $yeardays * 24 * 12;
        //$min5in1h = 12;	// 5min in 1h

        // Riporto comunque i costi fissi se sono in fascia
        if (isFascia($calltime, $fascia)) {
          // Quote fisse
          $QUOTASERVIZI5 = $QS / $year5min;
          $QUOTAPOTENZA5 = $QP * $POTENZA / $year5min;
          if ($debugflag) echo "Servizi=$QUOTASERVIZI5, QuotaPotenza=$QUOTAPOTENZA5", PHP_EOL;
  
          // A)  Costi fissi pro quota 5 minuti
          $COSTOFISSO5 = $QUOTASERVIZI5 + $QUOTAPOTENZA5 ;
          if ($debugflag) echo "CostoFisso5, quota fissa (Servizi + Quotapotenza di $POTENZA Kw)= $COSTOFISSO5", PHP_EOL;
        } else {
          $COSTOFISSO5 = 0;
        }
        
        if ($val != 0) {  
          $CONSUMO5 = $val / 1000;        // Delta consumo in kwh
          // calcolo bolletta (frazione di 5minuti)
  
          // Soglia proquota in kwh per 5 minuti
          $PRO5SCAGLIONE1 = $S1 / $year5min;
          $PRO5SCAGLIONE2 = $S2 / $year5min;
          $PRO5SCAGLIONE3 = $S3 / $year5min;
          $PRO5SCAGLIONE4 = $S4 / $year5min;
          if ($debugflag) echo "SogliaPro5Scaglione1=$PRO5SCAGLIONE1, SogliaPro5Scaglione2=$PRO5SCAGLIONE2, SogliaPro5Scaglione3=$PRO5SCAGLIONE3", PHP_EOL;

          // B) Quota energia per 5 minuti secondo fascia di tariffa richiesta
          if (fascia($calltime) == 'F1') $QE5 = $CONSUMO5 * $F1PE;
          else $QE5 = $CONSUMO5 * $F23PE;
          if ($debugflag)
                echo "QE5, Quota energia di base (CONSUMO5 * FXPE) = ($CONSUMO5 * FXPE) = $QE5", PHP_EOL;
  
          // C) Calcolo scaglioni
          $COSTO5S1 = ($CONSUMO5 > $PRO5SCAGLIONE1 ? 
                       $PRO5SCAGLIONE1 : $CONSUMO5) * $S1PE ;	// Costo Energia Scaglione1
          if ($debugflag) echo "Costo5s1, quota energia, S1 ($CONSUMO5) ($PRO5SCAGLIONE1 * $S1PE): $COSTO5S1", PHP_EOL;
          $COSTO5S2 = ($CONSUMO5 > $PRO5SCAGLIONE2 ? $PRO5SCAGLIONE2 - $PRO5SCAGLIONE1 :
                       ($CONSUMO5 > $PRO5SCAGLIONE1 ? $CONSUMO5 - $PRO5SCAGLIONE1 : 0))
                       * $S2PE ;	// Costo Energia Scaglione2
          if ($debugflag) echo "Costo5s2, quota energia, S2: $COSTO5S2", PHP_EOL;
          $COSTO5S3 = ($CONSUMO5 > $PRO5SCAGLIONE3 ? $PRO5SCAGLIONE3 - $PRO5SCAGLIONE2 : 
                       ($CONSUMO5 > $PRO5SCAGLIONE2 ? $CONSUMO5 - $PRO5SCAGLIONE2 : 0))
  		     * $S3PE ;	// Costo Energia Scaglione3
          if ($debugflag) echo "Costo5s3, quota energia, S3: $COSTO5S3", PHP_EOL;
          $COSTO5S4 = ($CONSUMO5 > $PRO5SCAGLIONE3 ?
                       $CONSUMO5 - $PRO5SCAGLIONE3 : 0 ) * $S4PE ;  // Costo Energia Scaglione4
          if ($debugflag) echo "Costo5s4, quota energia, S4: $COSTO5S4", PHP_EOL;
  
          $COSTOENERGIA5 = $QE5 + $COSTO5S1 + $COSTO5S2 + $COSTO5S3 + $COSTO5S4;
          if ($debugflag)
                echo "Costo Energia 5 ($CONSUMO5 kw * 5minuti), senza accise e senza iva= $QE5 + $COSTO5S1 + $COSTO5S2 + $COSTO5S3 + $COSTO5S4 = $COSTOENERGIA5", PHP_EOL;

          // D) Calcolo accise
          if (isset($options['tariffa']) && $options['tariffa'] == 'D2') {
              // Soglie proquota in kwh per 5 minuti
              $PRO5ACCISAESENTE = $SAE / $year5min;
              $PRO5ACCISAFULL   = $SAT / $year5min;

              if ($debugflag) echo "Calcolo Accisa tipo D2", PHP_EOL;
              if ($debugflag) echo "Soglia Esenzione: $PRO5ACCISAESENTE; Consumo ($CONSUMO5 - $PRO5ACCISAESENTE) * $ACCISA = " . ($CONSUMO5 - $PRO5ACCISAESENTE) * $ACCISA, PHP_EOL;
              
              // C) Calcolo esenzioni accise
              if ($CONSUMO5 > $PRO5ACCISAESENTE && $CONSUMO5 <= $PRO5ACCISAFULL) { 
                    $ACCISE5 = ($CONSUMO5 - $PRO5ACCISAESENTE) * $ACCISA;
                    if ($debugflag) echo "Accisa: ($CONSUMO5 - $PRO5ACCISAESENTE) * $ACCISA = $ACCISE5", PHP_EOL;
              } else if ($CONSUMO5 > $PRO5ACCISAFULL) {
                    $ACCISE5 = $CONSUMO5 * $ACCISA;
                    if ($debugflag) echo "Accisa full D2 = $ACCISE5", PHP_EOL;
              }          
          } else {
              $ACCISE5 = $CONSUMO5 * $ACCISA;
              if ($debugflag) echo "Accisa full non D2 = $ACCISE5", PHP_EOL;
              if ($debugflag) echo "Accise su $CONSUMO5 kw = $ACCISE5", PHP_EOL;
          }
          
        } else {
          $COSTOENERGIA5 = 0;
          $ACCISE5 = 0;
        }
        
        //------ Totali ------          
        switch ($argv[$argvEnergyPower]) {
              case 'cost':
                      $TOTALE5_NOIVA = $COSTOFISSO5 + $COSTOENERGIA5 + $ACCISE5;
                      break; 
              case 'energycost':
                      $TOTALE5_NOIVA = $COSTOENERGIA5 + $ACCISE5;
                      break;
              case 'fixedcost':
                      $TOTALE5_NOIVA = $COSTOFISSO5;
                      break;
        }
              
        $TOTALE_IVA = $TOTALE5_NOIVA * $IVA;
        if ($debugflag) echo "IVA su $TOTALE5_NOIVA = $TOTALE_IVA", PHP_EOL;
        $TOTALE5 = $TOTALE5_NOIVA + $TOTALE_IVA;
        if ($debugflag) echo "Totale generale = $TOTALE5", PHP_EOL;

        $val = $TOTALE5;

        // Aggiorno il valore del contatore virtuale
        if (!isset($options["onlydiff"]))
	       $val+= isset($memarray['Totalcounter'.$metnum]) ? $memarray['Totalcounter'.$metnum] : 0;
	$val = round($val, ${'PRECI' . $metnum});

	if (isset($options["plain"])) $str = utf8_decode("$val");
        else $str = utf8_decode("$ID($val*${'UNIT'.$metnum})");

    } else {
	$val = round($val, ${'PRECI' . $metnum});
	if (isset($options["plain"])) $str = utf8_decode("$val");
	else $str = utf8_decode("$ID($val*${'LIVEUNIT'.$metnum})");
    }
    echo "$str\n";

} else {
    die("virtmet v$version\n"
        . "Usage: $argv[0] [options] {virtmeternum} {meternumlisttoadd|0} {meternumlisttosub|0} {<value>} {<fascia>}\n"
        . "\nWhere:\n"
        . "\t<value> \t\t\t{energy|power|cost|energycost|fixedcost}\n"
        . "\t<fascia>\t\t\t{F1|F2|F3|F23|0}\n"
        . "\nOptions:\n"
        . "\t--plain\n"
        . "\t--debug\n"
        . "\t--onlydiff\n"
        . "\t--tariffa=<tname>\t\tWhere <tname> will point to 'tariffe/<tname>.csv' filename\n" 
        . "\t-P, --plantpower <ppower>\tWhere <ppower> is plant contractual power in kwh\n" 
        );
        
  // Euro (€) char test
}
?>