From 2a9ddc35faf761058582cabc3c175f25540c2942 Mon Sep 17 00:00:00 2001 From: OathK1per Date: Fri, 2 Sep 2022 17:39:15 +0800 Subject: [PATCH] =?UTF-8?q?=E6=89=B9=E9=87=8F=E5=AF=BC=E5=85=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/backend/ProjectController.java | 48 ++++++ .../work/model/ProcurementTypeRepository.java | 4 + .../work/service/ProjectBudgetService.java | 159 +++++++++++++++++- .../templates/admin/project_budget_edit.ftl | 5 +- 4 files changed, 212 insertions(+), 4 deletions(-) diff --git a/src/main/java/cn/palmte/work/controller/backend/ProjectController.java b/src/main/java/cn/palmte/work/controller/backend/ProjectController.java index c41670d..293a50c 100644 --- a/src/main/java/cn/palmte/work/controller/backend/ProjectController.java +++ b/src/main/java/cn/palmte/work/controller/backend/ProjectController.java @@ -5,6 +5,8 @@ import cn.palmte.work.model.*; import cn.palmte.work.pojo.ActHisTask; import cn.palmte.work.service.*; import cn.palmte.work.utils.*; +import cn.palmte.work.utils.excel.ExcelLogs; +import cn.palmte.work.utils.excel.ExcelUtil; import cn.palmte.work.utils.excel.ExportExcelUtils; import cn.palmte.work.utils.excel.ExportUtils; import com.alibaba.fastjson.JSON; @@ -13,6 +15,9 @@ import com.alibaba.fastjson.JSONObject; import org.activiti.engine.HistoryService; import org.activiti.engine.history.HistoricProcessInstance; import org.activiti.engine.task.Task; +import org.apache.poi.EncryptedDocumentException; +import org.apache.poi.openxml4j.exceptions.InvalidFormatException; +import org.apache.poi.poifs.filesystem.OfficeXmlFileException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -22,6 +27,7 @@ import org.springframework.stereotype.Controller; import org.springframework.validation.BindingResult; import org.springframework.web.bind.WebDataBinder; import org.springframework.web.bind.annotation.*; +import org.springframework.web.multipart.MultipartFile; import top.jfunc.common.db.bean.Page; import top.jfunc.common.utils.CollectionUtil; @@ -1017,6 +1023,27 @@ public class ProjectController extends BaseController { exportUtils.write(response.getOutputStream()); } + /** + * 数据导入 + */ + @RequestMapping(value = "/batchIncomeImport") + @ResponseBody + public String batchIncomeImport(MultipartFile file, Integer id) { + try { + ExcelLogs logs = new ExcelLogs(); + Collection maps = ExcelUtil.importExcel(Map.class, file.getInputStream(), + "yyyy/MM/dd HH:mm:ss", logs, 0); + synchronized (this) { + return JSON.toJSONString(projectBudgetService.checkIncome(maps, id)); + } + } catch (OfficeXmlFileException | EncryptedDocumentException | InvalidFormatException e) { + logger.error("", e); + return JSON.toJSONString(ResponseMsg.buildFailedMsg("格式错误，请上传excel 2003/2007格式文件")); + } catch (Exception e) { + return JSON.toJSONString(ResponseMsg.buildFailedMsg("导入数据失败,请联系管理员")); + } + } + /** * 支出模板下载 @@ -1029,4 +1056,25 @@ public class ProjectController extends BaseController { ExportUtils exportUtils = new ExportUtils(headers); exportUtils.write(response.getOutputStream()); } + + /** + * 数据导入 + */ + @RequestMapping(value = "/batchCostImport") + @ResponseBody + public String batchCostImport(MultipartFile file, Integer id) { + try { + ExcelLogs logs = new ExcelLogs(); + Collection maps = ExcelUtil.importExcel(Map.class, file.getInputStream(), + "yyyy/MM/dd HH:mm:ss", logs, 0); + synchronized (this) { + return JSON.toJSONString(projectBudgetService.checkCost(maps, id)); + } + } catch (OfficeXmlFileException | EncryptedDocumentException | InvalidFormatException e) { + logger.error("", e); + return JSON.toJSONString(ResponseMsg.buildFailedMsg("格式错误，请上传excel 2003/2007格式文件")); + } catch (Exception e) { + return JSON.toJSONString(ResponseMsg.buildFailedMsg("导入数据失败,请联系管理员")); + } + } } diff --git a/src/main/java/cn/palmte/work/model/ProcurementTypeRepository.java b/src/main/java/cn/palmte/work/model/ProcurementTypeRepository.java index 3cb35d3..89c80e0 100644 --- a/src/main/java/cn/palmte/work/model/ProcurementTypeRepository.java +++ b/src/main/java/cn/palmte/work/model/ProcurementTypeRepository.java @@ -1,9 +1,13 @@ package cn.palmte.work.model; import org.springframework.data.jpa.repository.JpaRepository; +import org.springframework.data.jpa.repository.Query; import java.util.List; public interface ProcurementTypeRepository extends JpaRepository { List findAllByEnabledEqualsAndIsDeletedEquals(int enable,int deleted); + + @Query(value = "select * from procurement_type where name = ?1 and enabled = 1 and is_deleted = 0 limit 1", nativeQuery = true) + ProcurementType findByName(String category); } diff --git a/src/main/java/cn/palmte/work/service/ProjectBudgetService.java b/src/main/java/cn/palmte/work/service/ProjectBudgetService.java index 4e5adc3..fbd2fb0 100644 --- a/src/main/java/cn/palmte/work/service/ProjectBudgetService.java +++ b/src/main/java/cn/palmte/work/service/ProjectBudgetService.java @@ -2,6 +2,10 @@ package cn.palmte.work.service; import cn.palmte.work.bean.*; import cn.palmte.work.model.*; +import cn.palmte.work.utils.DateKit; +import cn.palmte.work.utils.StrKit; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; @@ -9,8 +13,7 @@ import org.springframework.transaction.annotation.Transactional; import top.jfunc.common.utils.CollectionUtil; import java.math.BigDecimal; -import java.util.ArrayList; -import java.util.List; +import java.util.*; import java.util.stream.Collectors; /** @@ -19,6 +22,7 @@ import java.util.stream.Collectors; */ @Service public class ProjectBudgetService { + private static final Logger logger = LoggerFactory.getLogger(ProjectBudgetService.class); @Autowired private ProjectBudgetIncomeRepository projectBudgetIncomeRepository; @Autowired @@ -55,6 +59,8 @@ public class ProjectBudgetService { private ProjectRepository projectRepository; @Autowired private SysConfigService sysConfigService; + @Autowired + private ProcurementTypeRepository procurementTypeRepository; @Value("#{'${fourcal.fixedprojectmanagedetails}'.split('\\|')}") private String[] fixedProjectManageDetails; @@ -942,4 +948,153 @@ public class ProjectBudgetService { //资金计划明细 clearBudgetPlanDetail(p); } + + @Transactional(rollbackFor = Exception.class) + public ResponseMsg checkIncome(Collection excelMap, Integer id) { + int successCount = 0; + int errorCount = 0; + List errorList = new ArrayList<>(); + List incomeDetailTempList = new ArrayList<>(); + for (Map m : excelMap) { + try { + saveIncomeTemp(m, id, incomeDetailTempList); + } catch (Exception e) { + logger.error("", e); + errorCount++; + if (!e.getMessage().isEmpty()) { + errorList.add(e.getMessage()); + } + } + } + projectBudgetIncomeDetailTempRepository.save(incomeDetailTempList); + final ResponseMsg msg = ResponseMsg.buildSuccessMsg(String.format("成功：%d, 失败：%d", successCount, errorCount)); + msg.setData(errorList); + return msg; + } + + private void saveIncomeTemp(Map m, Integer id, List incomeDetailTempList) { + ProjectBudgetIncomeDetailTemp temp = new ProjectBudgetIncomeDetailTemp(); + String key; + Object o1; + temp.setProjectId(id); + key = "类别"; + o1 = m.get(key); + String type = (String) o1; + if ("设备类".equals(type)) { + temp.setType(1); + } else if ("工程类".equals(type)) { + temp.setType(2); + } else if ("服务类".equals(type)) { + temp.setType(3); + } + key = "名称"; + o1 = m.get(key); + temp.setName((String) o1); + key = "单位"; + o1 = m.get(key); + temp.setUnit((String) o1); + key = "数量"; + o1 = m.get(key); + temp.setAmount(Integer.parseInt((String) o1)); + key = "单价"; + o1 = m.get(key); + temp.setPrice(new BigDecimal((String) o1)); + key = "税率(%)"; + o1 = m.get(key); + temp.setTaxRate(new BigDecimal((String) o1)); + incomeDetailTempList.add(temp); + } + + @Transactional(rollbackFor = Exception.class) + public ResponseMsg checkCost(Collection excelMap, Integer id) { + int successCount = 0; + int errorCount = 0; + List errorList = new ArrayList<>(); + List costDetailTempList = new ArrayList<>(); + for (Map m : excelMap) { + try { + saveCostTemp(m, id, costDetailTempList); + } catch (Exception e) { + logger.error("", e); + errorCount++; + if (!e.getMessage().isEmpty()) { + errorList.add(e.getMessage()); + } + } + } + projectBudgetCostDetailTempRepository.save(costDetailTempList); + final ResponseMsg msg = ResponseMsg.buildSuccessMsg(String.format("成功：%d, 失败：%d", successCount, errorCount)); + msg.setData(errorList); + return msg; + } + + private void saveCostTemp(Map m, Integer id, List costDetailTempList) { + ProjectBudgetCostDetailTemp temp = new ProjectBudgetCostDetailTemp(); + String key; + Object o1; + temp.setProjectId(id); + key = "大类"; + o1 = m.get(key); + String type = (String) o1; + if ("设备".equals(type)) { + temp.setType(1); + } else if ("施工".equals(type)) { + temp.setType(2); + } else if ("服务".equals(type)) { + temp.setType(3); + } else if ("其他".equals(type)) { + temp.setType(4); + } + key = "类别"; + o1 = m.get(key); + String category = (String) o1; + ProcurementType procurementType = procurementTypeRepository.findByName(category); + if (procurementType != null && procurementType.getType() == temp.getType()) { + temp.setCategory(procurementType.getId()); + } + key = "名称"; + o1 = m.get(key); + temp.setName((String) o1); + key = "单位"; + o1 = m.get(key); + temp.setUnit((String) o1); + key = "数量"; + o1 = m.get(key); + temp.setAmount(Integer.parseInt((String) o1)); + key = "单价"; + o1 = m.get(key); + temp.setPrice(new BigDecimal((String) o1)); + key = "税率(%)"; + o1 = m.get(key); + temp.setTaxRate(new BigDecimal((String) o1)); + key = "签约方"; + o1 = m.get(key); + temp.setContractParty((String) o1); + key = "是否垫资"; + o1 = m.get(key); + String isUnderwritten = (String) o1; + if ("是".equals(isUnderwritten)) { + temp.setIsUnderwritten(1); + } else if ("否".equals(isUnderwritten)) { + temp.setIsUnderwritten(2); + } else { + temp.setIsUnderwritten(0); + } + key = "预估垫资金额(元)"; + o1 = m.get(key); + temp.setUnderwrittenAmount(new BigDecimal((String) o1)); + key = "支出时间"; + o1 = m.get(key); + temp.setPayTime(DateKit.getDate((String) o1, DateKit.DATE_FORMAT)); + key = "支出金额(元)"; + o1 = m.get(key); + temp.setPayAmount(new BigDecimal((String) o1)); + key = "付款方式"; + o1 = m.get(key); + temp.setPayWay((String) o1); + key = "备注"; + o1 = m.get(key); + temp.setRemark((String) o1); + costDetailTempList.add(temp); + } } diff --git a/src/main/resources/templates/admin/project_budget_edit.ftl b/src/main/resources/templates/admin/project_budget_edit.ftl index 50b25c1..8151d9b 100644 --- a/src/main/resources/templates/admin/project_budget_edit.ftl +++ b/src/main/resources/templates/admin/project_budget_edit.ftl @@ -631,7 +631,7 @@ 批量导入 - +