Employee headcount data importer
[disclosr.git] / admin / importAPSCEmployees.php
blob:a/admin/importAPSCEmployees.php -> blob:b/admin/importAPSCEmployees.php
--- a/admin/importAPSCEmployees.php
+++ b/admin/importAPSCEmployees.php
@@ -1,1 +1,55 @@
+<?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 
+?>
+