";
flush();
$row = 1;
$success = 0;
$dupes = 0;
$handle = fopen($fpath, "r");
//"t" mode string translates windows line breaks to unix
$datamapping0507 = array(
"Agency" => "agencyName",
"CN ID" => "CNID",
"Publish Date" => "publishDate",
"Contract Start Date" => "contractStart",
"Contract End Date" => "contractEnd",
"Value (AUD)" => "value",
"Title" => "description",
"Category" => "category",
"ATM ID" => "atmID",
"Supplier Name" => "supplierName",
"LastUpdated" => "amendDate",
"" => ""
);
$headers;
$contractNoticeFields = array(
"importFile",
"CNID",
"description",
"agencyName",
"publishDate",
"category",
"contractStart",
"contractEnd",
"value",
"atmID",
"supplierName",
"amendDate"
);
if ($tablename == "contractnotice") {
$contractNoticeInsertQ = 'INSERT INTO contractnotice ("' . implode('" , "', $contractNoticeFields) . '") VALUES ( ';
foreach ($contractNoticeFields as $key => $f) {
$contractNoticeInsertQ.= ($key == 0 ? "" : ", ") . "?";
}
$contractNoticeInsertQ.= ");";
$contractNoticeInsertQ = $conn->prepare($contractNoticeInsertQ);
}
while (($data = fgetcsv($handle, 1000, "\t")) !== false) {
$num = count($data);
if ($row == 3) {
$headers = $data;
}
elseif ($row > 3) {
if ($num > count($datamapping0507)) {
die("Error in data import; data mapping fields out of bounds or changed
" . $fname . "data:" .$num. print_r($data ,true). "mapping:" . count($datamapping0507). print_r($datamapping0507 ,true));
}
$contractNoticeInsert = Array();
$contractNoticeInsert[] = $fpath;
$keys = array_keys($datamapping0507);
for ($c = 0; $c < $num; $c++) {
$data[$c] = trim($data[$c], "=");
$data[$c] = trim($data[$c], "\"");
if ($tablename == "contractnotice") {
if (in_array(($datamapping0507[$headers[$c]]) , $contractNoticeFields)) {
if (($datamapping0507[$headers[$c]]) == "parentCN" || ($datamapping0507[$headers[$c]]) == "CNID") {
$data[$c] = substr($data[$c], 2); // take off the "CN" prefix
if (!is_numeric($data[$c]) && $data[$c] != "") die($data[$c] . " is not numeric");
if ($data[$c] > 0) {
$contractNoticeInsert[] = $data[$c];
}
else {
$contractNoticeInsert[] = 0;
}
}
elseif (($datamapping0507[$headers[$c]]) == "supplierABN") {
if ($data[$c] > 0) {
$contractNoticeInsert[] = $data[$c];
}
else {
$contractNoticeInsert[] = null;
}
}
elseif (($datamapping0507[$headers[$c]]) == "amendDate" || ($datamapping0507[$headers[$c]]) == "publishDate" || ($datamapping0507[$headers[$c]]) == "contractStart" || ($datamapping0507[$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;
}
}
}
}
flush();
if ($tablename == "contractnotice") {
$contractNoticeInsertQ->execute($contractNoticeInsert);
$errors = $conn->errorInfo();
if ($errors[1] == 7 && strpos($errors[2], "duplicate key")) {
$dupes++;
}
elseif ($errors[1] == 0) {
$success++;
}
else {
foreach ($contractNoticeFields as $key => $cnf) {
echo var_dump($contractNoticeInsert[$key]) . $cnf . "
";
}
echo $data[2] . " failed CN insert.
" . print_r($errors, true) . "
row $row
\n";
}
}
flush();
//echo "