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