| <?php | <?php |
| include_once('include/common.inc.php'); | include_once('../include/common.inc.php'); |
| include_header(); | include_header(); |
| $db = $server->get_db('disclosr-agencies'); | $db = $server->get_db('disclosr-agencies'); |
| $docs = Array(); | $docs = Array(); |
| try { | try { |
| $rows = $db->get_view("app", "byABN")->rows; | $rows = $db->get_view("app", "byABN")->rows; |
| //print_r($rows); | //print_r($rows); |
| foreach ($rows as $row) { | foreach ($rows as $row) { |
| $docs["a" . $row->key] = $row->value; | $docs["a" . $row->key] = $row->value; |
| } | } |
| } catch (SetteeRestClientException $e) { | } catch (SetteeRestClientException $e) { |
| setteErrorHandler($e); | setteErrorHandler($e); |
| } | } |
| //print_r($docs); | //print_r($docs); |
| $row = 1; | $row = 1; |
| if (($handle = fopen("cacfma.csv", "r")) !== FALSE) { | if (($handle = fopen("cacfma.csv", "r")) !== FALSE) { |
| while (($data = fgetcsv($handle, 1000, ",")) !== FALSE) { | while (($data = fgetcsv($handle, 1000, ",")) !== FALSE) { |
| $row++; | $row++; |
| echo $data[0] . " " . str_replace("?", "", $data[1]) . "<br />\n"; | echo $data[0] . " " . str_replace("?", "", $data[1]) . "<br />\n"; |
| $name = $data[0]; | $name = $data[0]; |
| $abn = trim(str_replace("?", "", $data[1])); | $abn = trim(str_replace("?", "", $data[1])); |
| $aabn = "a".$abn; | $aabn = "a".$abn; |
| if (isset($docs[$aabn])) { | if (isset($docs[$aabn])) { |
| echo "Existing agency ABN detected<br>"; | echo "Existing agency ABN detected<br>"; |
| if (!in_array($name, object_to_array($docs[$aabn]->otherNames)) && $name != $docs[$aabn]->name) { | if (!in_array($name, object_to_array($docs[$aabn]->otherNames)) && $name != $docs[$aabn]->name) { |
| $docs[$aabn]->otherNames[] = $name; | $docs[$aabn]->otherNames[] = $name; |
| try { | try { |
| $docs[$aabn] = $db->save($docs[$aabn]); | $docs[$aabn] = $db->save($docs[$aabn]); |
| //print_r($doc); | //print_r($doc); |
| echo $abn . " additional names imported \n<br>"; | echo $abn . " additional names imported \n<br>"; |
| } catch (SetteeRestClientException $e) { | } catch (SetteeRestClientException $e) { |
| setteErrorHandler($e); | setteErrorHandler($e); |
| } | } |
| } | } |
| } else { | } else { |
| echo "New agency ABN detected<br>"; | echo "New agency ABN detected<br>"; |
| $agency['_id'] = md5($aabn); | $agency['_id'] = md5($aabn); |
| $agency['name'] = $name; | $agency['name'] = $name; |
| $agency["abn"] = $abn; | $agency["abn"] = $abn; |
| try { | try { |
| $doc = $db->save($agency); | $doc = $db->save($agency); |
| print_r($doc); | print_r($doc); |
| echo $abn . " imported \n<br>"; | echo $abn . " imported \n<br>"; |
| } catch (SetteeRestClientException $e) { | } catch (SetteeRestClientException $e) { |
| setteErrorHandler($e); | setteErrorHandler($e); |
| } | } |
| } | } |
| echo "<hr>"; | echo "<hr>"; |
| } | } |
| fclose($handle); | fclose($handle); |
| } | } |
| include_footer(); | include_footer(); |
| ?> | ?> |