Employee headcount data importer
[disclosr.git] / admin / importContractDashboardAgencies.php
blob:a/admin/importContractDashboardAgencies.php -> blob:b/admin/importContractDashboardAgencies.php
  <?php
   
  require_once '../include/common.inc.php';
  try {
  $server->create_db('disclosr-agencies');
  } catch (SetteeRestClientException $e) {
  setteErrorHandler($e);
  }
  $db = $server->get_db('disclosr-agencies');
  createAgencyDesignDoc();
  $conn = new PDO("pgsql:dbname=contractDashboard;user=postgres;password=snmc;host=localhost");
  $namesQ = 'select agency.abn, string_agg("agencyName",\'|\') as names from agency inner join agency_nametoabn on agency.abn::text = agency_nametoabn.abn group by agency.abn;';
  $abntonames = Array();
  foreach ($conn->query($namesQ) as $row) {
  $abntonames[$row['abn']] = explode("|", $row['names']);
  }
  $result = $conn->query("select * from agency");
  while ($agency = $result->fetch(PDO::FETCH_ASSOC)) {
  $agency['_id'] = md5($agency['abn']);
  $agency['otherNames'] = $abntonames[$agency['abn']];
  if (sizeof($abntonames[$agency['abn']]) == 1)
  $agency['name'] = $abntonames[$agency['abn']][0];
  $agency["lastScraped"] = "1/1/1970";
  $agency["scrapeDepth"] = 1;
  try {
  $doc = $db->save($agency);
  //print_r($doc);
  echo $agency['abn'] . " imported \n<br>";
  } catch (SetteeRestClientException $e) {
  setteErrorHandler($e);
  }
  }
  ?>