From c566d1092805d4ad67b6337be71b23280ce7d850 Mon Sep 17 00:00:00 2001 From: starthomas610 Date: Mon, 17 Jun 2024 10:29:09 -0400 Subject: [PATCH] commit source history importify page of milestone 2 --- .../userarea/importify/cancel_import_his.php | 51 ++ .../userarea/importify/history_importify.php | 346 ++++++++++++ .../userarea/importify/import_auto_script.php | 495 ++++++++++-------- .../importify/importify_bg_script.php | 256 +++++++++ .../userarea/importify/importifydashboard.php | 4 +- 5 files changed, 927 insertions(+), 225 deletions(-) create mode 100644 public/userarea/importify/cancel_import_his.php create mode 100644 public/userarea/importify/history_importify.php create mode 100644 public/userarea/importify/importify_bg_script.php diff --git a/public/userarea/importify/cancel_import_his.php b/public/userarea/importify/cancel_import_his.php new file mode 100644 index 0000000..e08cea0 --- /dev/null +++ b/public/userarea/importify/cancel_import_his.php @@ -0,0 +1,51 @@ + +setQuery("SELECT * FROM template_import_his WHERE idImportHis='$his_id'"); +$his_query->execute(); + +$his_info = $his_query->Results; +$importcode = ""; +if (count($his_info) > 0) { + $importcode = $his_info[0]['importcode']; + + $deleteQuery = new WA_MySQLi_Query($repnew); + $deleteQuery->Action = "delete"; + $deleteQuery->Table = "`result_project`"; + + $deleteQuery->addFilter("importcode", "=", "s", "" . $importcode . ""); + $deleteQuery->execute(); + + + $deleteQuery = new WA_MySQLi_Query($repnew); + $deleteQuery->Action = "delete"; + $deleteQuery->Table = "`parts`"; + + $deleteQuery->addFilter("importcode", "=", "s", "" . $importcode . ""); + $deleteQuery->execute(); + + + $deleteQuery = new WA_MySQLi_Query($repnew); + $deleteQuery->Action = "delete"; + $deleteQuery->Table = "`reports`"; + + $deleteQuery->addFilter("importcode", "=", "s", "" . $importcode . ""); + $deleteQuery->execute(); + + + $deleteQuery = new WA_MySQLi_Query($repnew); + $deleteQuery->Action = "delete"; + $deleteQuery->Table = "`products`"; + + $deleteQuery->addFilter("importcode", "=", "s", "" . $importcode . ""); + $deleteQuery->execute(); + + $deleteQuery = new WA_MySQLi_Query($repnew); + $deleteQuery->Action = "delete"; + $deleteQuery->Table = "`template_import_his`"; + + $deleteQuery->addFilter("idImportHis", "=", "i", "" . $his_id . ""); + $deleteQuery->execute(); +} +die("success"); diff --git a/public/userarea/importify/history_importify.php b/public/userarea/importify/history_importify.php new file mode 100644 index 0000000..e2c76e7 --- /dev/null +++ b/public/userarea/importify/history_importify.php @@ -0,0 +1,346 @@ + +setQuery("SELECT * FROM template_import_his where user_id=$user_id"); +$importify_his->execute(); + +$arr_his = $importify_his->Results; +?> + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
+
+
+
+
+ +
+
+
+
+
+ + +
+ + + + + +
+ +
+ + + +
+ +
+ +
+
+
+
+ +
+

Importify

+
+
+
+ + +
+
+
+
+
Importify: History Import
+ + +

+
+ + + + + + + + + + + + + + + + + + + + + +
NoDate/TimeImportCodeStatusAction
+ + + + + + + + + +
+
+
+
+
+
+ + + +
+ +
+ +
+ + + +
+ + +
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/public/userarea/importify/import_auto_script.php b/public/userarea/importify/import_auto_script.php index b09f196..68e44a7 100644 --- a/public/userarea/importify/import_auto_script.php +++ b/public/userarea/importify/import_auto_script.php @@ -4,6 +4,31 @@ require '../../vendor/autoload.php'; use PhpOffice\PhpSpreadsheet\IOFactory; use PhpOffice\PhpSpreadsheet\Reader\IReader; +function post_async($url, array $params) +{ + foreach ($params as $key => &$val) { + if (is_array($val)) $val = implode(',', $val); + $post_params[] = $key.'='.urlencode($val); + } + $post_string = implode('&', $post_params); + + $parts=parse_url($url); + + $fp = fsockopen($parts['host'], + isset($parts['port'])?$parts['port']:80, + $errno, $errstr, 30); + + $out = "POST ".$parts['path']." HTTP/1.1\r\n"; + $out.= "Host: ".$parts['host']."\r\n"; + $out.= "Content-Type: application/x-www-form-urlencoded\r\n"; + $out.= "Content-Length: ".strlen($post_string)."\r\n"; + $out.= "Connection: Close\r\n\r\n"; + if (isset($post_string)) $out.= $post_string; + + fwrite($fp, $out); + fclose($fp); +} + if(isset($_FILES['f_csv'])) { $file = $_FILES['f_csv']['tmp_name']; $template_id = $_POST['template_id']; @@ -42,6 +67,7 @@ if(isset($_FILES['f_csv'])) { //separate by Sample Code (PO#) - product $idx_sample_code_po = array_search("Sample Code (PO#)", $arr_excel_columns); + $arr_total_products = array(); $tmp_arr_child_products = array(); $tmp_sample_code_po = ""; @@ -67,235 +93,258 @@ if(isset($_FILES['f_csv'])) { //define importcode (timestamp) $importcode = time(); + //insert import his + $InsertQuery = new WA_MySQLi_Query($repnew); + $InsertQuery->Action = "insert"; + $InsertQuery->Table = "`template_import_his`"; + $InsertQuery->bindColumn("created_at", "s", date("Y-m-d H:i:s"), "WA_DEFAULT"); + $InsertQuery->bindColumn("user_id", "i", "" . $_SESSION['iduserlogin'], "WA_DEFAULT"); + $InsertQuery->bindColumn("importcode", "s", "" .$importcode, "WA_DEFAULT"); + $InsertQuery->bindColumn("f_status", "i", "0", "WA_DEFAULT"); + $InsertQuery->saveInSession(""); + $InsertQuery->execute(); + +// post_async("localhost:80/0_claudio/reportify_new/public/userarea/importify/importify_bg_script.php", [ +// 'importcode' => $importcode +// ]); + + + post_async($_SERVER['SERVER_NAME'].":".$_SERVER['SERVER_PORT'].$_SERVER['REQUEST_URI']."/../importify_bg_script.php", [ + 'arr_project' => json_encode($arr_total_products), + 'arr_excel_columns' => json_encode($arr_excel_columns), + 'arr_associate' => json_encode($arr_associate), + 'importcode' => $importcode + ]); + //insert to products table - foreach($arr_total_products as $product) { - //check exist product item - $sample_code_po = $product[0][$idx_sample_code_po]; - $product_query = new WA_MySQLi_RS("getquery", $repnew, 0); - $product_query->setQuery("SELECT * FROM products WHERE products_refnumber='$sample_code_po'"); - $product_query->execute(); - - $product_info = $product_query->Results; - $idproducts = ""; - - if(count($product_info) > 0) { - $idproducts = $product_info[0]['idproducts']; - } else { // have to insert new - $arr_product_need_idx = array(); - for($i=0; $iAction = "insert"; - $InsertQuery->Table = "`products`"; - $InsertQuery->bindColumn("products_refnumber", "s", $product[0][$idx_sample_code_po], "WA_DEFAULT"); - $InsertQuery->bindColumn("importcode", "i", "" . $importcode. "", "WA_DEFAULT"); - for($i=0; $ibindColumn($arr_product_need_idx[$i][0], "s", $product[0][$arr_product_need_idx[$i][1]], "WA_DEFAULT"); - } - $InsertQuery->saveInSession(""); - $InsertQuery->execute(); - - $product_query = new WA_MySQLi_RS("getquery", $repnew, 0); - $product_query->setQuery("SELECT * FROM products WHERE products_refnumber='$sample_code_po'"); - $product_query->execute(); - - $product_info = $product_query->Results; - if(count($product_info) > 0) { - $idproducts = $product_info[0]['idproducts']; - } - } - if($idproducts == "") { - die("server_error"); - } - - - //----------- report table ------------------ - //separate reports table data - $idx_report_no_po = array_search("Report no.", $arr_excel_columns); - - $arr_total_reports = array(); - $tmp_arr_child_reports = array(); - $tmp_report_no = ""; - for($i=0; $i 0) { - array_push($arr_total_reports, $tmp_arr_child_reports); - } - } - $tmp_report_no = $product[$i][$idx_report_no_po]; - $tmp_arr_child_reports = array(); - array_push($tmp_arr_child_reports, $product[$i]); - } - } - if(count($tmp_arr_child_reports) > 0) { - array_push($arr_total_reports, $tmp_arr_child_reports); - } - - //insert to reports table - foreach($arr_total_reports as $report) { - //check exist reports item - $report_no = $report[0][$idx_report_no_po]; - $report_query = new WA_MySQLi_RS("getquery", $repnew, 0); - $report_query->setQuery("SELECT * FROM reports WHERE reportsNumberLab='$report_no' and idproducts='$idproducts'"); - $report_query->execute(); - - $report_info = $report_query->Results; - $idreports = ""; - - if (count($report_info) > 0) { - $idreports = $report_info[0]['idreports']; - } else { // have to insert new - $arr_report_need_idx = array(); - for ($i = 0; $i < count($arr_associate); $i++) { - if ($arr_associate[$i]['table_name'] == "reports") { - array_push($arr_report_need_idx, array($arr_associate[$i]['column_name'], array_search($arr_associate[$i]['headerfile'], $arr_excel_columns))); - } - } - - $InsertQuery = new WA_MySQLi_Query($repnew); - $InsertQuery->Action = "insert"; - $InsertQuery->Table = "`reports`"; - $InsertQuery->bindColumn("reportsNumberLab", "s", $report[0][$idx_report_no_po]."", "WA_DEFAULT"); - $InsertQuery->bindColumn("idproducts", "i", "" . $idproducts."", "WA_DEFAULT"); - $InsertQuery->bindColumn("importcode", "i", "" . $importcode . "", "WA_DEFAULT"); - for ($i = 0; $i < count($arr_report_need_idx); $i++) { - $InsertQuery->bindColumn($arr_report_need_idx[$i][0], "s", $report[0][$arr_report_need_idx[$i][1]], "WA_DEFAULT"); - } - $InsertQuery->saveInSession(""); - $InsertQuery->execute(); - - $report_query = new WA_MySQLi_RS("getquery", $repnew, 0); - $report_query->setQuery("SELECT * FROM reports WHERE reportsNumberLab='$report_no' and idproducts='$idproducts'"); - $report_query->execute(); - - $report_info = $report_query->Results; - if (count($report_info) > 0) { - $idreports = $report_info[0]['idreports']; - } - } - if ($idreports == "") { - die("server_error"); - } - - //----------- parts table ------------------ - //separate parts table data - $idx_part_no_po = array_search("Part No.", $arr_excel_columns); - - $arr_total_parts = array(); - $tmp_arr_child_parts = array(); - $tmp_part_no = ""; - for($i=0; $i 0) { - array_push($arr_total_parts, $tmp_arr_child_parts); - } - } - $tmp_part_no = $report[$i][$idx_part_no_po]; - $tmp_arr_child_parts = array(); - array_push($tmp_arr_child_parts, $report[$i]); - } - } - if(count($tmp_arr_child_parts) > 0) { - array_push($arr_total_parts, $tmp_arr_child_parts); - } - - //insert to parts table - foreach($arr_total_parts as $part) { - //check exist parts item - $part_no = $part[0][$idx_part_no_po]; - $part_query = new WA_MySQLi_RS("getquery", $repnew, 0); - $part_query->setQuery("SELECT * FROM parts WHERE partsCode='$part_no' and idreports='$idreports' and idproducts='$idproducts'"); - $part_query->execute(); - - $part_info = $part_query->Results; - $idparts = ""; - - if (count($part_info) > 0) { - $idparts = $part_info[0]['idParts']; - } else { // have to insert new - $arr_part_need_idx = array(); - for ($i = 0; $i < count($arr_associate); $i++) { - if ($arr_associate[$i]['table_name'] == "parts") { - array_push($arr_part_need_idx, array($arr_associate[$i]['column_name'], array_search($arr_associate[$i]['headerfile'], $arr_excel_columns))); - } - } - - $InsertQuery = new WA_MySQLi_Query($repnew); - $InsertQuery->Action = "insert"; - $InsertQuery->Table = "`parts`"; - $InsertQuery->bindColumn("partsCode", "s", $part[0][$idx_part_no_po] . "", "WA_DEFAULT"); - $InsertQuery->bindColumn("idproducts", "i", "" . $idproducts . "", "WA_DEFAULT"); - $InsertQuery->bindColumn("idreports", "i", "" . $idreports . "", "WA_DEFAULT"); - $InsertQuery->bindColumn("importcode", "i", "" . $importcode . "", "WA_DEFAULT"); - for ($i = 0; $i < count($arr_part_need_idx); $i++) { - $InsertQuery->bindColumn($arr_part_need_idx[$i][0], "s", $part[0][$arr_part_need_idx[$i][1]], "WA_DEFAULT"); - } - $InsertQuery->saveInSession(""); - $InsertQuery->execute(); - - $part_query = new WA_MySQLi_RS("getquery", $repnew, 0); - $part_query->setQuery("SELECT * FROM parts WHERE partsCode='$part_no' and idreports='$idreports' and idproducts='$idproducts'"); - $part_query->execute(); - - $part_info = $part_query->Results; - if (count($part_info) > 0) { - $idparts = $part_info[0]['idParts']; - } - } - if ($idparts == "") { - die("server_error"); - } - - //----------- result_project table ------------------ - foreach($part as $result_project) { - //check exist result_project item -// $result_project_query = new WA_MySQLi_RS("getquery", $repnew, 0); -// $sql_result_project_query = "SELECT * FROM result_project WHERE idPart='$idparts' and idreports='$idreports' and idproducts='$idproducts'"; +// foreach($arr_total_products as $product) { +// //check exist product item +// $sample_code_po = $product[0][$idx_sample_code_po]; +// $product_query = new WA_MySQLi_RS("getquery", $repnew, 0); +// $product_query->setQuery("SELECT * FROM products WHERE products_refnumber='$sample_code_po'"); +// $product_query->execute(); // - $arr_result_project_need_idx = array(); - for ($i = 0; $i < count($arr_associate); $i++) { - if ($arr_associate[$i]['table_name'] == "result_project") { - array_push($arr_result_project_need_idx, array($arr_associate[$i]['column_name'], array_search($arr_associate[$i]['headerfile'], $arr_excel_columns))); - } - } +// $product_info = $product_query->Results; +// $idproducts = ""; // -// foreach($arr_result_project_need_idx as $q) { -// $sql_result_project_query .= " and ".$q[0]."='".$q[0]."'"; +// if(count($product_info) > 0) { +// $idproducts = $product_info[0]['idproducts']; +// } else { // have to insert new +// $arr_product_need_idx = array(); +// for($i=0; $iAction = "insert"; +// $InsertQuery->Table = "`products`"; +// $InsertQuery->bindColumn("products_refnumber", "s", $product[0][$idx_sample_code_po], "WA_DEFAULT"); +// $InsertQuery->bindColumn("importcode", "i", "" . $importcode. "", "WA_DEFAULT"); +// for($i=0; $ibindColumn($arr_product_need_idx[$i][0], "s", $product[0][$arr_product_need_idx[$i][1]], "WA_DEFAULT"); +// } +// $InsertQuery->saveInSession(""); +// $InsertQuery->execute(); +// +// $product_query = new WA_MySQLi_RS("getquery", $repnew, 0); +// $product_query->setQuery("SELECT * FROM products WHERE products_refnumber='$sample_code_po'"); +// $product_query->execute(); +// +// $product_info = $product_query->Results; +// if(count($product_info) > 0) { +// $idproducts = $product_info[0]['idproducts']; +// } +// } +// if($idproducts == "") { +// die("server_error"); +// } +// +// +// //----------- report table ------------------ +// //separate reports table data +// $idx_report_no_po = array_search("Report no.", $arr_excel_columns); +// +// $arr_total_reports = array(); +// $tmp_arr_child_reports = array(); +// $tmp_report_no = ""; +// for($i=0; $i 0) { +// array_push($arr_total_reports, $tmp_arr_child_reports); +// } +// } +// $tmp_report_no = $product[$i][$idx_report_no_po]; +// $tmp_arr_child_reports = array(); +// array_push($tmp_arr_child_reports, $product[$i]); +// } +// } +// if(count($tmp_arr_child_reports) > 0) { +// array_push($arr_total_reports, $tmp_arr_child_reports); +// } +// +// //insert to reports table +// foreach($arr_total_reports as $report) { +// //check exist reports item +// $report_no = $report[0][$idx_report_no_po]; +// $report_query = new WA_MySQLi_RS("getquery", $repnew, 0); +// $report_query->setQuery("SELECT * FROM reports WHERE reportsNumberLab='$report_no' and idproducts='$idproducts'"); +// $report_query->execute(); +// +// $report_info = $report_query->Results; +// $idreports = ""; +// +// if (count($report_info) > 0) { +// $idreports = $report_info[0]['idreports']; +// } else { // have to insert new +// $arr_report_need_idx = array(); +// for ($i = 0; $i < count($arr_associate); $i++) { +// if ($arr_associate[$i]['table_name'] == "reports") { +// array_push($arr_report_need_idx, array($arr_associate[$i]['column_name'], array_search($arr_associate[$i]['headerfile'], $arr_excel_columns))); +// } +// } +// +// $InsertQuery = new WA_MySQLi_Query($repnew); +// $InsertQuery->Action = "insert"; +// $InsertQuery->Table = "`reports`"; +// $InsertQuery->bindColumn("reportsNumberLab", "s", $report[0][$idx_report_no_po]."", "WA_DEFAULT"); +// $InsertQuery->bindColumn("idproducts", "i", "" . $idproducts."", "WA_DEFAULT"); +// $InsertQuery->bindColumn("importcode", "i", "" . $importcode . "", "WA_DEFAULT"); +// for ($i = 0; $i < count($arr_report_need_idx); $i++) { +// $InsertQuery->bindColumn($arr_report_need_idx[$i][0], "s", $report[0][$arr_report_need_idx[$i][1]], "WA_DEFAULT"); +// } +// $InsertQuery->saveInSession(""); +// $InsertQuery->execute(); +// +// $report_query = new WA_MySQLi_RS("getquery", $repnew, 0); +// $report_query->setQuery("SELECT * FROM reports WHERE reportsNumberLab='$report_no' and idproducts='$idproducts'"); +// $report_query->execute(); +// +// $report_info = $report_query->Results; +// if (count($report_info) > 0) { +// $idreports = $report_info[0]['idreports']; +// } +// } +// if ($idreports == "") { +// die("server_error"); +// } +// +// //----------- parts table ------------------ +// //separate parts table data +// $idx_part_no_po = array_search("Part No.", $arr_excel_columns); +// +// $arr_total_parts = array(); +// $tmp_arr_child_parts = array(); +// $tmp_part_no = ""; +// for($i=0; $i 0) { +// array_push($arr_total_parts, $tmp_arr_child_parts); +// } +// } +// $tmp_part_no = $report[$i][$idx_part_no_po]; +// $tmp_arr_child_parts = array(); +// array_push($tmp_arr_child_parts, $report[$i]); +// } +// } +// if(count($tmp_arr_child_parts) > 0) { +// array_push($arr_total_parts, $tmp_arr_child_parts); +// } +// +// //insert to parts table +// foreach($arr_total_parts as $part) { +// //check exist parts item +// $part_no = $part[0][$idx_part_no_po]; +// $part_query = new WA_MySQLi_RS("getquery", $repnew, 0); +// $part_query->setQuery("SELECT * FROM parts WHERE partsCode='$part_no' and idreports='$idreports' and idproducts='$idproducts'"); +// $part_query->execute(); +// +// $part_info = $part_query->Results; +// $idparts = ""; +// +// if (count($part_info) > 0) { +// $idparts = $part_info[0]['idParts']; +// } else { // have to insert new +// $arr_part_need_idx = array(); +// for ($i = 0; $i < count($arr_associate); $i++) { +// if ($arr_associate[$i]['table_name'] == "parts") { +// array_push($arr_part_need_idx, array($arr_associate[$i]['column_name'], array_search($arr_associate[$i]['headerfile'], $arr_excel_columns))); +// } // } // -// $result_project_query->setQuery($sql_result_project_query); -// $result_project_query->execute(); -// -// $result_project_info = $result_project_query->Results; -// -// if (count($result_project_info) == 0) { - $InsertQuery = new WA_MySQLi_Query($repnew); - $InsertQuery->Action = "insert"; - $InsertQuery->Table = "`result_project`"; - $InsertQuery->bindColumn("idPart", "s", $idparts . "", "WA_DEFAULT"); - $InsertQuery->bindColumn("idproducts", "i", "" . $idproducts . "", "WA_DEFAULT"); - $InsertQuery->bindColumn("idreports", "i", "" . $idreports . "", "WA_DEFAULT"); - $InsertQuery->bindColumn("importcode", "i", "" . $importcode . "", "WA_DEFAULT"); - for ($i = 0; $i < count($arr_result_project_need_idx); $i++) { - $InsertQuery->bindColumn($arr_result_project_need_idx[$i][0], "s", $result_project[$arr_result_project_need_idx[$i][1]], "WA_DEFAULT"); - } - $InsertQuery->saveInSession(""); - $InsertQuery->execute(); +// $InsertQuery = new WA_MySQLi_Query($repnew); +// $InsertQuery->Action = "insert"; +// $InsertQuery->Table = "`parts`"; +// $InsertQuery->bindColumn("partsCode", "s", $part[0][$idx_part_no_po] . "", "WA_DEFAULT"); +// $InsertQuery->bindColumn("idproducts", "i", "" . $idproducts . "", "WA_DEFAULT"); +// $InsertQuery->bindColumn("idreports", "i", "" . $idreports . "", "WA_DEFAULT"); +// $InsertQuery->bindColumn("importcode", "i", "" . $importcode . "", "WA_DEFAULT"); +// for ($i = 0; $i < count($arr_part_need_idx); $i++) { +// $InsertQuery->bindColumn($arr_part_need_idx[$i][0], "s", $part[0][$arr_part_need_idx[$i][1]], "WA_DEFAULT"); // } - } - } - } - } +// $InsertQuery->saveInSession(""); +// $InsertQuery->execute(); +// +// $part_query = new WA_MySQLi_RS("getquery", $repnew, 0); +// $part_query->setQuery("SELECT * FROM parts WHERE partsCode='$part_no' and idreports='$idreports' and idproducts='$idproducts'"); +// $part_query->execute(); +// +// $part_info = $part_query->Results; +// if (count($part_info) > 0) { +// $idparts = $part_info[0]['idParts']; +// } +// } +// if ($idparts == "") { +// die("server_error"); +// } +// +// //----------- result_project table ------------------ +// foreach($part as $result_project) { +// //check exist result_project item +//// $result_project_query = new WA_MySQLi_RS("getquery", $repnew, 0); +//// $sql_result_project_query = "SELECT * FROM result_project WHERE idPart='$idparts' and idreports='$idreports' and idproducts='$idproducts'"; +//// +// $arr_result_project_need_idx = array(); +// for ($i = 0; $i < count($arr_associate); $i++) { +// if ($arr_associate[$i]['table_name'] == "result_project") { +// array_push($arr_result_project_need_idx, array($arr_associate[$i]['column_name'], array_search($arr_associate[$i]['headerfile'], $arr_excel_columns))); +// } +// } +//// +//// foreach($arr_result_project_need_idx as $q) { +//// $sql_result_project_query .= " and ".$q[0]."='".$q[0]."'"; +//// } +//// +//// $result_project_query->setQuery($sql_result_project_query); +//// $result_project_query->execute(); +//// +//// $result_project_info = $result_project_query->Results; +//// +//// if (count($result_project_info) == 0) { +// $InsertQuery = new WA_MySQLi_Query($repnew); +// $InsertQuery->Action = "insert"; +// $InsertQuery->Table = "`result_project`"; +// $InsertQuery->bindColumn("idPart", "s", $idparts . "", "WA_DEFAULT"); +// $InsertQuery->bindColumn("idproducts", "i", "" . $idproducts . "", "WA_DEFAULT"); +// $InsertQuery->bindColumn("idreports", "i", "" . $idreports . "", "WA_DEFAULT"); +// $InsertQuery->bindColumn("importcode", "i", "" . $importcode . "", "WA_DEFAULT"); +// for ($i = 0; $i < count($arr_result_project_need_idx); $i++) { +// $InsertQuery->bindColumn($arr_result_project_need_idx[$i][0], "s", $result_project[$arr_result_project_need_idx[$i][1]], "WA_DEFAULT"); +// } +// $InsertQuery->saveInSession(""); +// $InsertQuery->execute(); +//// } +// } +// } +// } +// } die('success'); } else { diff --git a/public/userarea/importify/importify_bg_script.php b/public/userarea/importify/importify_bg_script.php new file mode 100644 index 0000000..cb3cad5 --- /dev/null +++ b/public/userarea/importify/importify_bg_script.php @@ -0,0 +1,256 @@ + + + + + +setQuery("SELECT * FROM products WHERE products_refnumber='$sample_code_po'"); + $product_query->execute(); + + $product_info = $product_query->Results; + $idproducts = ""; + + if(count($product_info) > 0) { + $idproducts = $product_info[0]['idproducts']; + + } else { // have to insert new + $arr_product_need_idx = array(); + for($i=0; $itable_name == "products") { + array_push($arr_product_need_idx, array($arr_associate[$i]->column_name, array_search($arr_associate[$i]->headerfile, $arr_excel_columns))); + } + } + + $InsertQuery = new WA_MySQLi_Query($repnew); + $InsertQuery->Action = "insert"; + $InsertQuery->Table = "`products`"; + $InsertQuery->bindColumn("products_refnumber", "s", $product[0][$idx_sample_code_po], "WA_DEFAULT"); + $InsertQuery->bindColumn("importcode", "i", "" . $importcode. "", "WA_DEFAULT"); + for($i=0; $ibindColumn($arr_product_need_idx[$i][0], "s", $product[0][$arr_product_need_idx[$i][1]], "WA_DEFAULT"); + } + $InsertQuery->saveInSession(""); + $InsertQuery->execute(); + + $product_query = new WA_MySQLi_RS("getquery", $repnew, 0); + $product_query->setQuery("SELECT * FROM products WHERE products_refnumber='$sample_code_po'"); + $product_query->execute(); + + $product_info = $product_query->Results; + + if(count($product_info) > 0) { + $idproducts = $product_info[0]['idproducts']; + } + } + $idx++; + + if($idproducts == "") { + die("server_error"); + } + + //----------- report table ------------------ + //separate reports table data + $idx_report_no_po = array_search("Report no.", $arr_excel_columns); + + $arr_total_reports = array(); + $tmp_arr_child_reports = array(); + $tmp_report_no = ""; + for($i=0; $i 0) { + array_push($arr_total_reports, $tmp_arr_child_reports); + } + } + $tmp_report_no = $product[$i][$idx_report_no_po]; + $tmp_arr_child_reports = array(); + array_push($tmp_arr_child_reports, $product[$i]); + } + } + if(count($tmp_arr_child_reports) > 0) { + array_push($arr_total_reports, $tmp_arr_child_reports); + } + + //insert to reports table + foreach($arr_total_reports as $report) { + //check exist reports item + $report_no = $report[0][$idx_report_no_po]; + $report_query = new WA_MySQLi_RS("getquery", $repnew, 0); + $report_query->setQuery("SELECT * FROM reports WHERE reportsNumberLab='$report_no' and idproducts='$idproducts'"); + $report_query->execute(); + + $report_info = $report_query->Results; + $idreports = ""; + + if (count($report_info) > 0) { + $idreports = $report_info[0]['idreports']; + } else { // have to insert new + $arr_report_need_idx = array(); + for ($i = 0; $i < count($arr_associate); $i++) { + if ($arr_associate[$i]->table_name == "reports") { + array_push($arr_report_need_idx, array($arr_associate[$i]->column_name, array_search($arr_associate[$i]->headerfile, $arr_excel_columns))); + } + } + + $InsertQuery = new WA_MySQLi_Query($repnew); + $InsertQuery->Action = "insert"; + $InsertQuery->Table = "`reports`"; + $InsertQuery->bindColumn("reportsNumberLab", "s", $report[0][$idx_report_no_po]."", "WA_DEFAULT"); + $InsertQuery->bindColumn("idproducts", "i", "" . $idproducts."", "WA_DEFAULT"); + $InsertQuery->bindColumn("importcode", "i", "" . $importcode . "", "WA_DEFAULT"); + for ($i = 0; $i < count($arr_report_need_idx); $i++) { + $InsertQuery->bindColumn($arr_report_need_idx[$i][0], "s", $report[0][$arr_report_need_idx[$i][1]], "WA_DEFAULT"); + } + $InsertQuery->saveInSession(""); + $InsertQuery->execute(); + + $report_query = new WA_MySQLi_RS("getquery", $repnew, 0); + $report_query->setQuery("SELECT * FROM reports WHERE reportsNumberLab='$report_no' and idproducts='$idproducts'"); + $report_query->execute(); + + $report_info = $report_query->Results; + if (count($report_info) > 0) { + $idreports = $report_info[0]['idreports']; + } + } + if ($idreports == "") { + die("server_error"); + } + + //----------- parts table ------------------ + //separate parts table data + $idx_part_no_po = array_search("Part No.", $arr_excel_columns); + + $arr_total_parts = array(); + $tmp_arr_child_parts = array(); + $tmp_part_no = ""; + for($i=0; $i 0) { + array_push($arr_total_parts, $tmp_arr_child_parts); + } + } + $tmp_part_no = $report[$i][$idx_part_no_po]; + $tmp_arr_child_parts = array(); + array_push($tmp_arr_child_parts, $report[$i]); + } + } + if(count($tmp_arr_child_parts) > 0) { + array_push($arr_total_parts, $tmp_arr_child_parts); + } + + //insert to parts table + foreach($arr_total_parts as $part) { + //check exist parts item + $part_no = $part[0][$idx_part_no_po]; + $part_query = new WA_MySQLi_RS("getquery", $repnew, 0); + $part_query->setQuery("SELECT * FROM parts WHERE partsCode='$part_no' and idreports='$idreports' and idproducts='$idproducts'"); + $part_query->execute(); + + $part_info = $part_query->Results; + $idparts = ""; + + if (count($part_info) > 0) { + $idparts = $part_info[0]['idParts']; + } else { // have to insert new + $arr_part_need_idx = array(); + for ($i = 0; $i < count($arr_associate); $i++) { + if ($arr_associate[$i]->table_name == "parts") { + array_push($arr_part_need_idx, array($arr_associate[$i]->column_name, array_search($arr_associate[$i]->headerfile, $arr_excel_columns))); + } + } + + $InsertQuery = new WA_MySQLi_Query($repnew); + $InsertQuery->Action = "insert"; + $InsertQuery->Table = "`parts`"; + $InsertQuery->bindColumn("partsCode", "s", $part[0][$idx_part_no_po] . "", "WA_DEFAULT"); + $InsertQuery->bindColumn("idproducts", "i", "" . $idproducts . "", "WA_DEFAULT"); + $InsertQuery->bindColumn("idreports", "i", "" . $idreports . "", "WA_DEFAULT"); + $InsertQuery->bindColumn("importcode", "i", "" . $importcode . "", "WA_DEFAULT"); + for ($i = 0; $i < count($arr_part_need_idx); $i++) { + $InsertQuery->bindColumn($arr_part_need_idx[$i][0], "s", $part[0][$arr_part_need_idx[$i][1]], "WA_DEFAULT"); + } + $InsertQuery->saveInSession(""); + $InsertQuery->execute(); + + $part_query = new WA_MySQLi_RS("getquery", $repnew, 0); + $part_query->setQuery("SELECT * FROM parts WHERE partsCode='$part_no' and idreports='$idreports' and idproducts='$idproducts'"); + $part_query->execute(); + + $part_info = $part_query->Results; + if (count($part_info) > 0) { + $idparts = $part_info[0]['idParts']; + } + } + if ($idparts == "") { + die("server_error"); + } + + //----------- result_project table ------------------ + foreach($part as $result_project) { + //check exist result_project item +// $result_project_query = new WA_MySQLi_RS("getquery", $repnew, 0); +// $sql_result_project_query = "SELECT * FROM result_project WHERE idPart='$idparts' and idreports='$idreports' and idproducts='$idproducts'"; +// + $arr_result_project_need_idx = array(); + for ($i = 0; $i < count($arr_associate); $i++) { + if ($arr_associate[$i]->table_name == "result_project") { + array_push($arr_result_project_need_idx, array($arr_associate[$i]->column_name, array_search($arr_associate[$i]->headerfile, $arr_excel_columns))); + } + } +// +// foreach($arr_result_project_need_idx as $q) { +// $sql_result_project_query .= " and ".$q[0]."='".$q[0]."'"; +// } +// +// $result_project_query->setQuery($sql_result_project_query); +// $result_project_query->execute(); +// +// $result_project_info = $result_project_query->Results; +// +// if (count($result_project_info) == 0) { + $InsertQuery = new WA_MySQLi_Query($repnew); + $InsertQuery->Action = "insert"; + $InsertQuery->Table = "`result_project`"; + $InsertQuery->bindColumn("idPart", "s", $idparts . "", "WA_DEFAULT"); + $InsertQuery->bindColumn("idproducts", "i", "" . $idproducts . "", "WA_DEFAULT"); + $InsertQuery->bindColumn("idreports", "i", "" . $idreports . "", "WA_DEFAULT"); + $InsertQuery->bindColumn("importcode", "i", "" . $importcode . "", "WA_DEFAULT"); + for ($i = 0; $i < count($arr_result_project_need_idx); $i++) { + $InsertQuery->bindColumn($arr_result_project_need_idx[$i][0], "s", $result_project[$arr_result_project_need_idx[$i][1]], "WA_DEFAULT"); + } + $InsertQuery->saveInSession(""); + $InsertQuery->execute(); +// } + } + } + } +} + +$UpdateQuery = new WA_MySQLi_Query($repnew); +$UpdateQuery->Action = "update"; +$UpdateQuery->Table = "`template_import_his`"; +$UpdateQuery->bindColumn("f_status", "i", "1", "WA_DEFAULT"); +$UpdateQuery->addFilter("importcode", "=", "s", "".$importcode . ""); +$UpdateQuery->execute(); diff --git a/public/userarea/importify/importifydashboard.php b/public/userarea/importify/importifydashboard.php index 41fa32e..b92fe75 100644 --- a/public/userarea/importify/importifydashboard.php +++ b/public/userarea/importify/importifydashboard.php @@ -131,7 +131,7 @@
Importify:
Insert new template Import File - + @@ -260,7 +260,7 @@ success: function(data) { $('#ajax_preloader').fadeOut(); if(data.indexOf("success") > -1) { - showSuccessPopup("Your operation succeeded!"); + showSuccessPopup("Your operation requested!"); }else if(data.indexOf("none_define_column_error") > -1) { showWarningPopup("The Associate Columns did not define yet!"); } else if(data.indexOf("invalid_excel_data_format_error") > -1) {