Employee headcount data importer
[disclosr.git] / admin / importAPSCEmployees.php
blob:a/admin/importAPSCEmployees.php -> blob:b/admin/importAPSCEmployees.php
  <?php
   
  require_once '../include/common.inc.php';
   
  $db = $server->get_db('disclosr-agencies');
  $rows = $db->get_view("app", "byName")->rows;
  $nametoid = Array();
  $sums = Array();
  foreach ($rows as $row) {
  $nametoid[trim($row->key)] = $row->value;
  }
  $employeeCSVs = Array("2002-2003" => "0203apsemployees.csv",
  "2003-2004" => "0304apsemployees.csv",
  "2004-2005" => "0405apsemployees.csv",
  "2005-2006" => "0506apsemployees.csv",
  "2006-2007" => "0607apsemployees.csv",
  "2007-2008" => "0708apsemployees.csv",
  "2008-2009" => "0809apsemployees.csv",
  "2009-2010" => "0910apsemployees.csv",
  "2010-2011" => "1011apsemployees.csv"
  );
  foreach ($employeeCSVs as $timePeriod => $employeeCSV) {
  echo $employeeCSV . "<br>" . PHP_EOL;
  $row = 1;
  if (($handle = fopen($employeeCSV, "r")) !== FALSE) {
  while (($data = fgetcsv($handle, 1000, ",")) !== FALSE) {
  //print_r($data);
  $name = trim($data[0]);
  if (isset($nametoid[$name])) {
  $id = $nametoid[$name];
  //echo $id . "<br>" . PHP_EOL;
  @$sums[$id][$timePeriod] += $data[1];
  } else {
  echo "<br>ERROR NAME MISSING FROM ID LIST<br><bR>" . PHP_EOL;
   
  die();
   
  }
  }
  fclose($handle);
  }
  }
  foreach ($sums as $id => $sum) {
  echo $id. "<br>" . PHP_EOL;
  $doc = $db->get($id);
  // print_r($doc);
  if (isset($doc->statistics)) $doc->statistics = Array();
  foreach ($sum as $timePeriod => $value) {
  $doc->statistics["employees"][$timePeriod] = Array("value"=>$value, "source"=>"http://apsc.gov.au/stateoftheservice/");
  }
  $db->save($doc);
  }
  // employees: timeperiod, source = apsc state of service, value
  ?>