insertExcel.php 5.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148
  1. <?php
  2. require '../../../vendor/autoload.php';
  3. include("../sql.php");
  4. use PhpOffice\PhpSpreadsheet\Spreadsheet;
  5. use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
  6. $type = array();
  7. $i = 0;
  8. while (isset($_POST["type{$i}"])) {
  9. $type[$i] = $_POST["type{$i}"];
  10. $i++;
  11. }
  12. $ajax = array();
  13. $connectionInfo = array("Database" => "$dbname", "UID" => "$username", "PWD" => "$password", "CharacterSet" => "UTF-8");
  14. $conn = sqlsrv_connect($hostname, $connectionInfo);
  15. if ($conn === false) {
  16. die(print_r(sqlsrv_errors(), true));
  17. }
  18. $Category_List = [];
  19. if (isset($_POST['file'])) {
  20. $file = $_POST['file'];
  21. $project_id = $_POST['projectId'];
  22. $project_name = $_POST['projectName'];
  23. $category_id = $_POST['categoryId'];
  24. } else {
  25. header("Location: ../../../Upload.php#error");
  26. }
  27. $filename = "uploads/{$file}";
  28. $importinfo = array();
  29. $extension = pathinfo($file,PATHINFO_EXTENSION);
  30. if ('csv' == $extension) {
  31. $reader = new \PhpOffice\PhpSpreadsheet\Reader\Csv();
  32. } else if ('xls' == $extension) {
  33. $reader = new \PhpOffice\PhpSpreadsheet\Reader\Xls();
  34. } else
  35. $reader = new \PhpOffice\PhpSpreadsheet\Reader\Xlsx();
  36. $reader->setReadDataOnly(true);
  37. $reader->setReadEmptyCells(false);
  38. $spreadsheet = $reader->load($filename);
  39. $sheetCount = $spreadsheet->getSheetCount();
  40. $all = $spreadsheet->getSheetNames();
  41. $sql = "DELETE FROM [Blueprint] WHERE [project_id] = ?";
  42. $stmt = sqlsrv_query($conn, $sql, array($project_id));
  43. $sql = "DELETE FROM [File_table] WHERE [project_id] = ?";
  44. $stmt = sqlsrv_query($conn, $sql, array($project_id));
  45. $sql = "IF NOT EXISTS (SELECT [project_id] FROM [Project_Table] WHERE [project_id] = '{$project_id}')
  46. BEGIN
  47. INSERT INTO [dbo].[Project_Table] ([project_id],[project_name],[category_id])
  48. VALUES
  49. (?,?,?)
  50. END";
  51. $stmt = sqlsrv_query($conn, $sql, array($project_id,$project_name,$category_id));
  52. $sql = "SELECT [category_list] FROM [Category_List] WHERE [list_id] = (SELECT [list_id] FROM [Construction_Category] WHERE [category_id] = '{$category_id}');";
  53. $fetchResult = sqlsrv_query($conn, $sql);
  54. while ($row = sqlsrv_fetch_array($fetchResult)) {
  55. $category_list = explode(",", $row[0]);
  56. }
  57. for ($s = 0; $s < $sheetCount; $s++) {
  58. if ($type[$s] != 'cancel') {
  59. // if (str_contains($all[$s], "_")) {
  60. // $Category = explode("_", $all[$s])[1];
  61. // } else if (str_contains($all[$s], ".")) {
  62. // $Category = explode(".", $all[$s])[1];
  63. // } else if (str_contains($all[$s], "-")) {
  64. // $Category = explode("-", $all[$s])[1];
  65. // } else {
  66. // $Category = $all[$s];
  67. // }
  68. // $sql = "DECLARE @filetype_id INT;
  69. // IF NOT EXISTS (SELECT [type_id] FROM [File_Category] WHERE [type_name] = '{$Category}')
  70. // BEGIN
  71. // SET @filetype_id = (SELECT [filetype_id] FROM [21000X].[dbo].[File_Type_Table] WHERE [filetype_name] = '{$type[$s]}')
  72. // INSERT INTO [File_Category] ([type_name],[filetype_id]) VALUES ('{$Category}',@filetype_id);
  73. // END";
  74. // $fetchResult = sqlsrv_query($conn, $sql);
  75. // $sql = "SELECT [type_id] FROM [File_Category] WHERE [type_name] = '{$Category}';";
  76. $type_id = $category_list[$s-1];
  77. // array_push($Category_List, $type_id);
  78. $sheet = $spreadsheet->getSheet($s);
  79. $cellCollection = $sheet->getCellCollection();
  80. $column = $cellCollection->getHighestRowAndColumn();
  81. for ($i = 2; $i <= $column['row']; $i++) { //行
  82. $row = array($project_id, $type_id);
  83. for ($j = 'A'; $j <= $column['column']; $j++) { //列
  84. $key = $j . $i;
  85. $value = $sheet->getCell($key)->getValue();
  86. array_push($row, $value);
  87. }
  88. if ($type[$s] == '[Blueprint]') {
  89. $sql = "INSERT INTO [Blueprint]
  90. ([project_id]
  91. ,[type_id]
  92. ,[SN]
  93. ,[blueprint_id]
  94. ,[original_name]
  95. ,[keyword]
  96. ,[notes]
  97. ,[filename])
  98. VALUES
  99. (?,?,?,?,?,?,?,?)";
  100. } else if ($type[$s] == '[File_Table]') {
  101. $sql = "INSERT INTO [File_Table]
  102. ([project_id]
  103. ,[type_id]
  104. ,[SN]
  105. ,[original_name]
  106. ,[filename]
  107. ,[keyword])
  108. VALUES
  109. (?,?,?,?,?,?)";
  110. array_push($row, '');
  111. }
  112. $stmt = sqlsrv_query($conn, $sql, $row);
  113. // echo "<br>";
  114. }
  115. // echo "<br>";
  116. // echo "<br>";
  117. }
  118. }
  119. // $Category_List_s = implode(",", $Category_List);
  120. // $sql = "IF NOT EXISTS (SELECT [list_id] FROM [Category_List] WHERE [category_list] = '{$Category_List_s}')
  121. // BEGIN
  122. // INSERT INTO [Category_List] ([category_list])
  123. // VALUES ('{$Category_List_s}')
  124. // END";
  125. // $fetchResult = sqlsrv_query($conn, $sql);
  126. sqlsrv_close($conn);
  127. header("Location: ../../../Upload.php?status=success");