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