From 82f0f5e82cf0ff88af237ba5929dff7a2bdc4d46 Mon Sep 17 00:00:00 2001 From: lyfO_o <764716047@qq.com> Date: 星期一, 21 六月 2021 14:52:52 +0800 Subject: [PATCH] 申购导入和导入模板 --- src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java | 123 +++++++++++++++++++++++++++++++++++++++- 1 files changed, 118 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java b/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java index 4da1d67..dd9d9fc 100644 --- a/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java +++ b/src/main/java/com/nanometer/smartlab/service/OpeApplyServiceImpl.java @@ -1,12 +1,11 @@ package com.nanometer.smartlab.service; import com.nanometer.smartlab.dao.OpeApplyDao; -import com.nanometer.smartlab.entity.OpeApply; -import com.nanometer.smartlab.entity.OpeApplyReserve; -import com.nanometer.smartlab.entity.OpeOrder; -import com.nanometer.smartlab.entity.SysUser; +import com.nanometer.smartlab.dao.SysReagentDao; +import com.nanometer.smartlab.entity.*; import com.nanometer.smartlab.entity.enumtype.ApplyStatus; import com.nanometer.smartlab.entity.enumtype.SeeFlag; +import com.nanometer.smartlab.entity.enumtype.ValidFlag; import com.nanometer.smartlab.exception.AlarmCode; import com.nanometer.smartlab.exception.AlarmException; import com.nanometer.smartlab.exception.BusinessException; @@ -15,6 +14,13 @@ import com.nanometer.smartlab.util.MessageUtil; import org.apache.commons.lang.StringUtils; import org.apache.log4j.Logger; +import org.apache.poi.hssf.usermodel.HSSFWorkbook; +import org.apache.poi.ss.usermodel.Row; +import org.apache.poi.ss.usermodel.Sheet; +import org.apache.poi.ss.usermodel.Workbook; +import org.apache.poi.xssf.usermodel.XSSFWorkbook; +import org.primefaces.event.FileUploadEvent; +import org.primefaces.model.UploadedFile; import org.springframework.context.annotation.Lazy; import org.springframework.dao.DataAccessException; import org.springframework.dao.DataIntegrityViolationException; @@ -25,6 +31,8 @@ import org.springframework.util.CollectionUtils; import javax.annotation.Resource; +import java.io.IOException; +import java.io.InputStream; import java.math.BigDecimal; import java.sql.Timestamp; import java.util.ArrayList; @@ -51,7 +59,11 @@ @Lazy @Resource OpeWarehouseReserveService opeWarehouseReserveService; - + @Lazy + @Resource + SysReagentService sysReagentService; + @Resource + SysSequenceService sysSequenceService; @Resource private SysUserService sysUserService; @@ -733,4 +745,105 @@ } + @Override + @Transactional + public void importApply(FileUploadEvent event,SysUser user) { + + try { + + UploadedFile file = event.getFile(); + InputStream is = file.getInputstream(); + boolean isExcel2003 = true; + if (file.getFileName().matches("^.+\\.(?i)(xlsx)$")) { + isExcel2003 = false; + } + Workbook wb = null; + if (isExcel2003) { + wb = new HSSFWorkbook(is); + } else { + wb = new XSSFWorkbook(is); + } + Sheet sheet = wb.getSheetAt(0); + int totalRows = sheet.getPhysicalNumberOfRows(); + ArrayList<OpeApply> adds = new ArrayList<>(); + Row row = null; + int totalCells = 0; + for (int i = 1; i < totalRows; i++) { + List<String> valuesList = new ArrayList<String>(); + row = sheet.getRow(i); + + totalCells = row.getPhysicalNumberOfCells(); + + for (int t = 0; t < totalCells; t++) { + String cellInfo = ""; + + if (row.getCell(t) != null) { + if (row.getCell(t).getCellTypeEnum().toString().equals("NUMERIC")) { + cellInfo = String.valueOf(row.getCell(t).getNumericCellValue()); + }else{ + cellInfo = row.getCell(t).getStringCellValue(); + } + } + valuesList.add(cellInfo); + } + + Map<String,Object> detail = new HashMap<>(); + detail.put("name", valuesList.get(0)); + detail.put("cas", valuesList.get(1)); + detail.put("product_sn", valuesList.get(2)); + detail.put("main_metering", valuesList.get(3)); + detail.put("reagent_unit", valuesList.get(4)); + detail.put("reagent_character", valuesList.get(5)); + detail.put("product_home", valuesList.get(6)); + SysReagent sysReagent = sysReagentService.getReagentByDetail(detail); + if (sysReagent == null) throw new BusinessException(ExceptionEnumCode.PARAM_NO_EXIST, i+"行:试剂不存在或者有多条,导入失败"); + + //申购数量 + Integer num = new Double(valuesList.get(7)).intValue(); + if (num < 1) throw new BusinessException(ExceptionEnumCode.PARAM_NO_EXIST, i+"行:试剂申购数量不合法,导入失败"); + //课题组 + String objective = valuesList.get(8); + //选择的审批人姓名 + String approveUserName = valuesList.get(9); + //根据姓名获取用户信息的id + SysUser approveUser = sysUserService.getUserByName(approveUserName); + if (approveUser == null) throw new BusinessException(ExceptionEnumCode.PARAM_NO_EXIST, i+"行:审批人不存在或者审批人姓名存在重复,导入失败"); + + OpeApply opeApply = new OpeApply(); + opeApply.setId(IDUtils.uuid()); + opeApply.setValidFlag(ValidFlag.VALID); + opeApply.setStatus(ApplyStatus.PENDING_APPROVAL); + opeApply.setApplyCode(sysSequenceService.getApplyCode()); + //设置试剂id + opeApply.setReagent(sysReagent); + //价格 + opeApply.setApplyPrice(sysReagent.getPrice()); + //申购数量 + opeApply.setNum(num); + //申购人 + opeApply.setApplyUserId(user.getId()); + //选择的审批人 + opeApply.setApproveUserId(approveUser.getId()); + //选择的课题组信息 + opeApply.setObjective(objective); + + adds.add(opeApply); + + } + + if (adds.size() > 0) { + opeApplyDao.insertOpeApplyList(adds); + } + + + + + + + } catch (IOException e) { + e.printStackTrace(); + } + + } + } -- Gitblit v1.9.2