一、思路分析
1、我們要做導入,實際上也就是先文件上傳,然后讀取文件的數據。
2、我們要有一個導入的模板,因為我們導入的Excel列要和我們的數據字段匹配上,所以我們要給它來一個規定,也就是模板。
3、按照我們公司的套路,是做了一個導入信息的臨時表,用來存導入文件中的信息。每當導入的時候,我們先把表信息清空,再拿到數據放進來,然后我們對導入的數據進行檢查,最后才全部導入。
這樣做的目的是防止導入的數據和列沒有對上卻也直接導到了庫里面,要真這樣了就很尷尬。我們做了三個按鈕,一個導入,一個確認導入,一個導入模板下載。
4、捋一下過程:
點擊批量導入按鈕,跳轉到導入頁面。
點擊模板下載。(事先寫好一個模板.xls文件,此按鈕放置下載鏈接)
在模板中錄入數據。
點擊導入按鈕,跳出文件上傳模態框。
選擇文件,上傳文件。
上傳成功后調用后台方法,讀取文件內容。
把內容生成表格,顯示到導入頁面。
觀察數據有沒有出錯。
點擊確認導入,調用后台方法,執行導入操作。
回調函數,導入成功/導入失敗 的提示。
二、代碼分析
1、前端js代碼:
1 var actionPath = contextPath + "/alumni-import"; 2 3 $(function() { 4 //加載數據 5 loadData(); 6 //上傳文件 7 uploadFile({ 8 subfix: ['xls'], 9 subfixTip: "請選擇Excel的xls文件!", 10 successCall: function(data, status, a) { 11 $('[name=attachementPath]').val(data.fileName); 12 $.post(actionPath + "!importExcel", { "f_id": data.f_id }, function(data) { 13 if (data.success) { 14 alertify.alert(data.message); 15 $("#myModal-import").modal("hide"); 16 loadData(); 17 } else { 18 alertify.alert(data.message); 19 } 20 21 }, "json"); 22 } 23 }); 24 //導入 25 $("#btn-import").click(function() { 26 var html = template("importTpl"); 27 $("#import-body").html(html); 28 $("#myModal-import").modal(); 29 }); 30 //確認導入 31 $("#btn-sure").click(function() { 32 var type = $("#indentity-type").val(); 33 alertify.confirm("確定要全部導入嗎?", function(e) { 34 if (!e) { return; } else { 35 $.post("/alumni-import!saveReal?type=" + type, function(data) { 36 alertify.alert("導入成功!", function() { 37 location.href = "/alumni!hrefPage"; 38 }); 39 }, "json"); 40 } 41 }); 42 }); 43 });50 51 function loadData() { 52 var options = { 53 url: actionPath + "!page" 54 }; 55 loadPaginationData(options); 56 }
2、后台功能代碼
前端有四個請求,一個初始化頁面數據加載,當然,一開始是沒有數據的;一個導入文件上傳;一個確認導入;一個導入完成后頁面跳轉回要信息頁面(信息頁面有一個批量導入跳轉到這的導入頁面)。
第一個后最后一個就不講了。講一下第二個和第三個。
①第二個
1 //上傳文件后調用 2 public void importExcel() { 3 try { 4 //清空臨時表的數據 5 baseAlumniImportSrv.deleteAll(); 6 //讀取文件 7 File file = gridFsDao.readFile(f_id); 8 //把文件信息給臨時表 9 int count = excelXYSrv.importExcel(file); 10 //清空上傳的文件 11 file.delete(); 12 sendSuccessMsg(count, "上傳成功" + count + "條數據"); 13 } catch (IOException e) { 14 LOGGER.error(e); 15 sendFailMsg(null, "上傳失敗"); 16 } 17 }
1 @Override //使用MongoDB GridFS,具體詳解請各自初學者自行百度,注釋寫不下去了,我也不會,心態爆炸~~~ 2 public File readFile(String f_id) { 3 //拿到文件 4 GridFSDBFile gridFSFile = mongoGridFs.findOne(new Query(Criteria.where(F_ID).is(f_id))); 5 if (gridFSFile == null) { 6 return null; 7 } 8 String fileName = gridFSFile.getFilename(); 9 String extension = fileName.substring(fileName.lastIndexOf("."), fileName.length()); 10 InputStream ins = gridFSFile.getInputStream(); 11 String tmpFile = UUID.randomUUID().toString() + extension; 12 File file = new File(tmpFile); 13 14 try { 15 OutputStream os = new FileOutputStream(file); 16 int bytesRead = 0; 17 byte[] buffer = new byte[8192]; 18 while ((bytesRead = ins.read(buffer, 0, 8192)) != -1) { 19 os.write(buffer, 0, bytesRead); 20 } 21 os.close(); 22 ins.close(); 23 } catch (IOException e) { 24 e.printStackTrace(); 25 } 26 27 return file; 28 29 }
1 /** 2 * @param excelFile 3 * 從excel中讀取數據,並存儲到數據庫臨時表中 4 * @return 5 * @throws IOException 6 */ 7 @Override 8 public int importExcel(File excelFile) throws IOException { 9 List<List<Object>> datas = ExcelImportUtil.readExcel(excelFile); 10 int count = 0; 11 for (int i = 1; i < datas.size(); i++) { 12 BaseAlumniImport entity = this.convert2Entity(datas.get(i)); 13 this.baseAlumniImportSrv.save(entity); 14 count++; 15 } 16 return count; 17 }
②第三個
1 public void saveReal() { 2 int count = 0; 3 List<BaseAlumniImport> importList = this.baseAlumniImportSrv.findAll(); 4 for (int i = 0; i < importList.size(); i += 10) { 5 List<BaseAlumniImport> newlist = new ArrayList<>(); 6 if ((i + 10) < importList.size()) { 7 newlist = importList.subList(i, i + 10); 8 } else { 9 newlist = importList.subList(i, importList.size()); 10 } 11 count += excelXYSrv.saveReal(newlist, this.type); 12 } 13 sendSuccessMsg(count, "導入成功" + importList.size() + "條數據"); 14 }
1 @Override 2 public int saveReal(List<BaseAlumniImport> importList, String type) { 3 int count = 0; 4 String alumniIdentityName = dicSrv.findById(DicAlumniIdentity.class, Integer.parseInt(type)).getValue(); 5 for (BaseAlumniImport inst : importList) { 6 LOGGER.info(inst.getId()); 7 BaseAlumni v = this.importExportSrv.convert(inst); 8 v.setId(IdKit.uuid()); 9 v.setCreateTime(new Date()); 10 v.setLastUpdate(new Date()); 11 this.baseAlumnidDao.save(v); 12 this.baseAlumniImportSrv.deleteById(inst.getId()); 13 count++; 14 } 15 return count; 16 }
1 @Override 2 public int saveReal(List<BaseAlumniImport> importList, String type) { 3 int count = 0; 4 String alumniIdentityName = dicSrv.findById(DicAlumniIdentity.class, Integer.parseInt(type)).getValue(); 5 for (BaseAlumniImport inst : importList) { 6 LOGGER.info(inst.getId()); 7 BaseAlumni v = this.importExportSrv.convert(inst); 8 v.setId(IdKit.uuid()); 9 v.setCreateTime(new Date()); 10 v.setLastUpdate(new Date()); 11 this.baseAlumnidDao.save(v); 12 this.baseAlumniImportSrv.deleteById(inst.getId()); 13 count++; 14 } 15 return count; 16 }
沒啥好講的……會的應該都能看懂,看不懂的我也不會……
三、結果圖
導入成功~