<?php |
<?php |
|
|
require_once 'common.inc.php'; |
require_once 'common.inc.php'; |
try { |
try { |
$server->create_db('disclosr-agencies'); |
$server->create_db('disclosr-agencies'); |
} catch (SetteeRestClientException $e) { |
} catch (SetteeRestClientException $e) { |
setteErrorHandler($e); |
setteErrorHandler($e); |
} |
} |
$db = $server->get_db('disclosr-agencies'); |
$db = $server->get_db('disclosr-agencies'); |
createAgencyDesignDoc(); |
createAgencyDesignDoc(); |
$conn = new PDO("pgsql:dbname=contractDashboard;user=postgres;password=snmc;host=localhost"); |
$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;'; |
$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(); |
$abntonames = Array(); |
foreach ($conn->query($namesQ) as $row) { |
foreach ($conn->query($namesQ) as $row) { |
$abntonames[$row['abn']] = explode(",", $row['names']); |
$abntonames[$row['abn']] = explode("|", $row['names']); |
} |
} |
$result = $conn->query("select * from agency"); |
$result = $conn->query("select * from agency"); |
while ($agency = $result->fetch(PDO::FETCH_ASSOC)) { |
while ($agency = $result->fetch(PDO::FETCH_ASSOC)) { |
$agency['_id'] = md5($agency['abn']); |
$agency['_id'] = md5($agency['abn']); |
$agency['otherNames'] = $abntonames[$agency['abn']]; |
$agency['otherNames'] = $abntonames[$agency['abn']]; |
if (sizeof($abntonames[$agency['abn']]) == 1) |
if (sizeof($abntonames[$agency['abn']]) == 1) |
$agency['name'] = $abntonames[$agency['abn']][0]; |
$agency['name'] = $abntonames[$agency['abn']][0]; |
$agency["lastScraped"] = "1/1/1970"; |
$agency["lastScraped"] = "1/1/1970"; |
$agency["scrapeDepth"] = 1; |
$agency["scrapeDepth"] = 1; |
try { |
try { |
$doc = $db->save($agency); |
$doc = $db->save($agency); |
//print_r($doc); |
//print_r($doc); |
echo $agency['abn'] . " imported \n<br>"; |
echo $agency['abn'] . " imported \n<br>"; |
} catch (SetteeRestClientException $e) { |
} catch (SetteeRestClientException $e) { |
setteErrorHandler($e); |
setteErrorHandler($e); |
} |
} |
} |
} |
?> |
?> |
|
|