getcustatus.prg

<?php
// vim: tabstop=2 expandtab syn=php

//for each cu in the cuadmin table 
//return results in the form:  (read straight from the database table)
//  {
//    "cruisecu":{"livebatch":"L","offlinestat":""},
//    "scrubcu":{"livebatch":"B","offlinestat":"N"}
//  } 
 
require_once 'logging.i';
require_once 'hcuEnv.i';

$logger = new ColorStandardLogger('getcustatus');

// * SETUP WORKING ENVIRONMENT
// require_once(dirname(__FILE__) . '/../../shared/library/hcuEnv.i');
// require_once(dirname(__FILE__) . '/../../shared/library/hcuCommon.i');

$env = LoadSystemEnv('version');
if ($env['devmode']) {
  $env['logger']->warning("Showing /getcustatus info - DEVMODE.");
}

$HB_ENV = LoadSystemEnv("banking");
$db = $HB_ENV['db'];

$connect_to = sprintf('host=%s port=%d dbname=%s', $db['host'],
                      $db['port'], $db['dbname']);
if (!is_null($db['user'])) {
    $connect_to .= ' user=' . $db['user'];
}
if (!is_null($db['connect_timeout'])) {
    $connect_to .= ' connect_timeout=' . $db['connect_timeout'];
}
if (!is_null($db['password'])) {
    $connect_to .= ' password=' . $db['password'];
}
$r = pg_connect($connect_to);

if (!$r) {
    throw new Exception('DB connect error');
}
if (pg_connection_status($r) !== PGSQL_CONNECTION_OK) {
    throw new Exception('DB status error');
}
if (!pg_ping($r)) {
    throw new Exception('DB ping error');
}


//custatus from cuadmin table
$result = pg_query($r, "select user_name, livebatch, offlinestat from cuadmin order by user_name");

$fields = [ "name", "livebatch", "offlinestat" ];

while ($row = pg_fetch_row($result)) {
  $row[0] = trim($row[0]);
  $name = $row[0]; 
  //echo "echo name= ", $name, "<br>";
  $entry = array();
  // $entry = $res[$name];       //get the existing values for this cu
  //echo "existing entry", json_encode($entry), "<br>";
  for( $i=1; $i<count($fields); $i++) {     //skip the name field in result
    $entry[$fields[$i]] = trim($row[$i]);    //match the values to field names
  };
  $res[$name] = $entry;       //replace with updated values
};

echo json_encode($res);               //output everything
   
?>