| <?php | <?php |
| require_once 'common.inc.php'; | require_once 'common.inc.php'; |
| try { | |
| $server->create_db('disclosr-agencies'); | |
| } catch (SetteeRestClientException $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['otherNames'] = $abntonames[$agency['abn']]; | $agency['otherNames'] = $abntonames[$agency['abn']]; |
| if (sizeof($abntonames[$agency['abn']]) == 1) $agency['name'] = $abntonames[$agency['abn']][0]; | if (sizeof($abntonames[$agency['abn']]) == 1) |
| $agency["lastScraped"] = "1/1/1970"; | $agency['name'] = $abntonames[$agency['abn']][0]; |
| $agency["scrapeDepth"] = 1; | $agency["lastScraped"] = "1/1/1970"; |
| $doc = $db->save($agency); | $agency["scrapeDepth"] = 1; |
| print_r($doc); | try { |
| } | $doc = $db->save($agency); |
| //print_r($doc); | |
| echo $agency['abn'] . " imported \n<br>"; | |
| } catch (SetteeRestClientException $e) { | |
| setteErrorHandler($e); | |
| } | |
| } | |
| ?> | ?> |