<?php
include_once ("../lib/common.inc.php");
function processFile($fpath, $tablename)
{
        global $conn;
        $row = 1;
        $handle = fopen($fpath, "r");
        //"t" mode string translates windows line breaks to unix
        $datamapping0711 = array(
                "Agency" => "agencyName",
                "Parent CN ID" => "parentCN",
                "CN ID" => "CNID",
                "Publish Date" => "publishDate",
                "Amendment Date" => "amendDate",
                "Status" => "",
                "StartDate" => "contractStart",
                "EndDate" => "contractEnd",
                "Value" => "value",
                "Description" => "description",
                "Agency Ref Id" => "agencyID",
                "Category" => "category",
                "Procurement Method" => "procurementMethod",
                "ATM ID" => "atmID",
                "SON ID" => "SONID",
                "Confidentiality - Contract" => "confidentialityContract",
                "Confidentiality - Contract Reason(s)" => "confidentialityContractReason",
                "Confidentiality - Outputs" => "confidentialityOutputs",
                "Confidentiality - Outputs Reason(s)" => "confidentialityOutputsReason",
                "Consultancy" => "consultancy",
                "Consultancy Reason(s)" => "consultancyReason",
                "Amendment Reason" => "amendmentReason",
                "Supplier Name" => "supplierName",
                "Supplier Address" => "supplierAddress",
                "Supplier City" => "supplierCity",
                "Supplier Postcode" => "supplierPostcode",
                "Supplier Country" => "supplierCountry",
                "Supplier ABNExempt" => "supplierABNExempt",
                "Supplier ABN" => "supplierABN",
                "Agency Branch" => "contactBranch",
                "Agency Divison" => "contactDivision",
                "Agency Postcode" => "contactPostcode",
                "" => ""
        );
        $headers;
        $contractNoticeFields = array(
                "importFile",
                "agencyName",
                "parentCN",
                "CNID",
                "publishDate",
                "amendDate",
                "contractStart",
                "contractEnd",
                "value",
                "description",
                "agencyID",
                "category",
                "procurementMethod",
                "atmID",
                "SONID",
                "confidentialityContract",
                "confidentialityContractReason",
                "confidentialityOutputs",
                "confidentialityOutputsReason",
                "consultancy",
                "consultancyReason",
                "amendmentReason",
                "supplierName",
                "supplierAddress",
                "supplierCity",
                "supplierPostcode",
                "supplierCountry",
                "supplierABNExempt",
                "supplierABN",
                "contactBranch",
                "contactDivision",
                "contactPostcode"
        );
        $agencyFields = array(
                "agencyName"
        );
        $supplierFields = array(
                "supplierName",
                "supplierAddress",
                "supplierCity",
                "supplierPostcode",
                "supplierCountry",
                "supplierABNExempt",
                "supplierABN"
        );
        if ($tablename == "contractnotice") {
                $contractNoticeInsertQ = 'INSERT INTO contractnotice ("' . implode('" , "', $contractNoticeFields) . '") VALUES ( ';
                foreach ($contractNoticeFields as $key => $f) {
                        $contractNoticeInsertQ.= ($key == 0 ? "" : ", ") . "?";
                }
                $contractNoticeInsertQ.= ");";
                $contractNoticeInsertQ = $conn->prepare($contractNoticeInsertQ);
        }
        else if ($tablename == "supplierdetails") {
                $supplierInsertQ = 'INSERT INTO supplierdetails ("' . implode('" , "', $supplierFields) . '") VALUES ( ';
                foreach ($supplierFields as $key => $f) {
                        $supplierInsertQ.= ($key == 0 ? "" : ", ") . "?";
                }
                $supplierInsertQ.= ");";
                $supplierInsertQ = $conn->prepare($supplierInsertQ);
        }
        else if ($tablename == "agency") {
                $agencyInsertQ = 'INSERT INTO agency ("' . implode('" , "', $agencyFields) . '") VALUES ( ';
                foreach ($agencyFields as $key => $f) {
                        $agencyInsertQ.= ($key == 0 ? "" : ", ") . "?";
                }
                $agencyInsertQ.= ");";
                $agencyInsertQ = $conn->prepare($agencyInsertQ);
        }
        while (($data = fgetcsv($handle, 1000, "\t")) !== false) {
                $num = count($data);
                if ($row == 3) {
                        $headers = $data;
                }
                elseif ($row > 3) {
                        if ($num > count($datamapping0711)) {
                                die("<font color=red>Error in data import; data mapping fields out of bounds or changed</font><br>" . $fname . print_r($data));
                        }
                        $contractNoticeInsert = Array();
                        $supplierInsert = Array();
                        $agencyInsert = Array();
                        $contractNoticeInsert[] = $fpath;
                        $keys = array_keys($datamapping0711);
                        for ($c = 0; $c < $num; $c++) {
                                $data[$c] = trim($data[$c], "=");
                                $data[$c] = trim($data[$c], "\"");
                                if ($tablename == "contractnotice") {
                                        if (in_array(($datamapping0711[$headers[$c]]) , $contractNoticeFields)) {
                                                if (($datamapping0711[$headers[$c]]) == "parentCN" || ($datamapping0711[$headers[$c]]) == "CNID") {
                                                        $data[$c] = substr($data[$c], 2); // take off the "CN" prefix
                                                        $data[$c] = str_replace("-A", "00", $data[$c]); // make amendments really big numbers
                                                        if (!is_numeric($data[$c]) && $data[$c] != "") die($data[$c] . " is not numeric");
                                                        if ($data[$c] > 0) {
                                                                $contractNoticeInsert[] = $data[$c];
                                                        }
                                                        else {
                                                                $contractNoticeInsert[] = 0;
                                                        }
                                                }
                                                elseif (($datamapping0711[$headers[$c]]) == "supplierABN") {
                                                        if ($data[$c] > 0) {
                                                                $contractNoticeInsert[] = $data[$c];
                                                        }
                                                        else {
                                                                $contractNoticeInsert[] = null;
                                                        }
                                                }
                                                elseif (($datamapping0711[$headers[$c]]) == "amendDate" || ($datamapping0711[$headers[$c]]) == "publishDate" || ($datamapping0711[$headers[$c]]) == "contractStart" || ($datamapping0711[$headers[$c]]) == "contractEnd") {
                                                        $contractNoticeInsert[] = date('Y-m-d H:i:s', strtotime($data[$c]));
                                                }
                                                else {
                                                        if (strstr("\" =", $data[$c] > 0)) {
                                                                die("Invalid Description field" . $contractNoticeInsert);
                                                        }
$colvalue =  preg_replace( '/[^[:print:]]/', '',utf8_encode( $data[$c]));
 
                                                        $contractNoticeInsert[] = $colvalue;
                                                }
                                        }
                                }
                                else if ($tablename == "supplierdetails") {
                                        if (in_array(($datamapping0711[$headers[$c]]) , $supplierFields)) {
                                                if (($datamapping0711[$headers[$c]]) == "supplierABN") {
                                                        if ($data[$c] > 0) {
                                                                $contractNoticeInsert[] = $data[$c];
                                                        }
                                                        else {
                                                                $contractNoticeInsert[] = 0;
                                                        }
                                                }
                                                else {
                                                        $supplierInsert[] = $data[$c];
                                                }
                                        }
                                }