package com.zt.life.util;
|
|
import com.zt.common.servlet.Result;
|
import com.zt.core.sys.dto.DictItemDto;
|
import com.zt.core.sys.model.SysDept;
|
import com.zt.life.core.model.Product;
|
import com.zt.life.dto.ImportErrDto;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.poi.ss.usermodel.Cell;
|
import org.apache.poi.ss.usermodel.Row;
|
import org.apache.poi.ss.usermodel.Sheet;
|
import org.apache.poi.ss.util.CellRangeAddress;
|
|
import java.text.DateFormat;
|
import java.text.ParsePosition;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
import java.util.regex.Pattern;
|
import java.util.stream.Collectors;
|
|
import static org.mapstruct.ap.internal.util.Strings.isEmpty;
|
|
public class ImportUtil {
|
|
/**
|
* 获取当前单元格有几行
|
* @param cell
|
* @param sheet
|
* @return
|
*/
|
public static int getMergeRowNum(Cell cell, Sheet sheet) {
|
int mergeSize = 1;
|
List<CellRangeAddress> mergedRegions = sheet.getMergedRegions();
|
for (CellRangeAddress cellRangeAddress : mergedRegions) {
|
if (cellRangeAddress.isInRange(cell)) {
|
mergeSize = cellRangeAddress.getLastRow() - cellRangeAddress.getFirstRow() + 1;
|
break;
|
}
|
}
|
return mergeSize;
|
}
|
|
/**
|
* 判断对象是否为空
|
*
|
* @param obj
|
* @return
|
*/
|
public static String ObjectFormat(Object obj) {
|
return obj == null ? "" : obj.toString();
|
}
|
|
// 将所有的值转换为String类型
|
public static String getCellValue(Row row, Integer i, String Pattern) {
|
Cell cell = row.getCell(i);
|
String cellStr = "";
|
cellStr = getCellValue(Pattern, cell, cellStr);
|
return cellStr;
|
}
|
|
public static String getCellValue(String Pattern, Cell cell, String cellStr) {
|
if (cell != null) {
|
switch (cell.getCellType()) {
|
case BLANK:// 空值
|
cellStr = "";
|
break;
|
case NUMERIC:// 数字
|
if (org.apache.poi.ss.usermodel.DateUtil.isCellDateFormatted(cell)) {// 时间
|
DateFormat format = new SimpleDateFormat(Pattern);
|
Date date = cell.getDateCellValue();
|
cellStr = format.format(date);
|
break;
|
} else {
|
cellStr = String.valueOf(cell.getNumericCellValue());
|
if (cellStr.split("\\.").length == 2) {// 去.0
|
String[] ss = cellStr.split("\\.");
|
if (ss[1].equals("0")) {
|
cellStr = ss[0] + "";
|
}
|
}
|
}
|
break;
|
default:
|
cellStr = cell.getStringCellValue();
|
break;
|
}
|
}
|
return cellStr;
|
}
|
|
/**
|
* 导入成功显示提示信息
|
*
|
* @param result
|
* @param importResults
|
* @param str
|
*/
|
public static void importResult(Result<List<ImportErrDto>> result, List<Map<String, Object>> importResults, StringBuilder str) {
|
if (importResults.size() == 1) { // 导入成功
|
String sum = importResults.get(0).get("sum").toString();
|
String suc = importResults.get(0).get("suc").toString();
|
String err = importResults.get(0).get("err").toString();
|
str.append("共导入").append(sum).append("条数据,").append(" 成功").append(suc).append("条数据,").append(" 失败").append(err).append("条数据");
|
result.setMsg(str.toString());
|
}
|
}
|
|
public static void ImportErrResult(Result<List<ImportErrDto>> result, List<Map<String, Object>> importResults, StringBuilder str) {
|
if (importResults.size() == 2) { //导入有错误
|
String sum = importResults.get(0).get("sum").toString();
|
String suc = importResults.get(0).get("suc").toString();
|
String err = importResults.get(0).get("err").toString();
|
str.append("共导入").append(sum).append("条数据,").append(" 成功").append(suc).append("条数据,").append(" 失败").append(err).append("条数据");
|
Map<String, Object> stringObjectMap = importResults.get(1);
|
List<ImportErrDto> errList = new ArrayList<>();
|
for (String key : stringObjectMap.keySet()) {
|
ImportErrMessage value = (ImportErrMessage) stringObjectMap.get(key);
|
errList.add(new ImportErrDto(value.getSheetName(), key, value.getLineNumber()));
|
}
|
if (errList.size() > 0) {
|
for (ImportErrDto importErrDto : errList) {
|
importErrDto.setLineNumber(importErrDto.getLineNumber().substring(0, importErrDto.getLineNumber().length() - 1));
|
}
|
}
|
result.setMsg(str.toString());
|
result.setCode(501);
|
result.setData(errList);
|
}
|
}
|
|
/**
|
* 计修项目清单导入成功
|
*
|
* @param result
|
* @param importResults
|
* @param str
|
*/
|
public static void importResultProjectList(Result<List<ImportErrDto>> result, List<Map<String, Object>> importResults, StringBuilder str) {
|
if (importResults.size() == 2) {
|
String sum = importResults.get(0).get("sum").toString();
|
String suc = importResults.get(0).get("suc").toString();
|
String err = importResults.get(0).get("err").toString();
|
String jsum = importResults.get(1).get("jsum").toString();
|
String jsuc = importResults.get(1).get("jsuc").toString();
|
String jerr = importResults.get(1).get("jerr").toString();
|
str.append("项目清单: 共导入").append(sum).append("条数据,").append(" 成功").append(suc).append("条数据,").append(" 失败").append(err).append("条数据\n");
|
str.append("检验内容: 共导入").append(jsum).append("条数据,").append(" 成功").append(jsuc).append("条数据,").append(" 失败").append(jerr).append("条数据");
|
result.setMsg(str.toString());
|
}
|
}
|
|
/**
|
* 计修项目清单导入成功
|
*
|
* @param result
|
* @param importResults
|
* @param str
|
*/
|
public static void importResultThreeProjectList(Result<List<ImportErrDto>> result, List<Map<String, Object>> importResults, StringBuilder str) {
|
if (importResults.size() == 3) {
|
String sum = importResults.get(0).get("sum").toString();
|
String suc = importResults.get(0).get("suc").toString();
|
String err = importResults.get(0).get("err").toString();
|
String jsum = importResults.get(1).get("jsum").toString();
|
String jsuc = importResults.get(1).get("jsuc").toString();
|
String jerr = importResults.get(1).get("jerr").toString();
|
String csum = importResults.get(2).get("csum").toString();
|
String csuc = importResults.get(2).get("csuc").toString();
|
String cerr = importResults.get(2).get("cerr").toString();
|
str.append("项目清单: 共导入").append(sum).append("条数据,").append(" 成功").append(suc).append("条数据,").append(" 失败").append(err).append("条数据\n");
|
str.append("检验内容: 共导入").append(jsum).append("条数据,").append(" 成功").append(jsuc).append("条数据,").append(" 失败").append(jerr).append("条数据\n");
|
str.append("拆检范围: 共导入").append(csum).append("条数据,").append(" 成功").append(csuc).append("条数据,").append(" 失败").append(cerr).append("条数据");
|
result.setMsg(str.toString());
|
}
|
}
|
|
public static void ImportErrResultThreeProjectList(Result<List<ImportErrDto>> result, List<Map<String, Object>> importResults, StringBuilder str) {
|
if (importResults.size() == 4) { //导入有错误
|
String sum = importResults.get(0).get("sum").toString();
|
String suc = importResults.get(0).get("suc").toString();
|
String err = importResults.get(0).get("err").toString();
|
String jsum = importResults.get(1).get("jsum").toString();
|
String jsuc = importResults.get(1).get("jsuc").toString();
|
String jerr = importResults.get(1).get("jerr").toString();
|
String csum = importResults.get(2).get("csum").toString();
|
String csuc = importResults.get(2).get("csuc").toString();
|
String cerr = importResults.get(2).get("cerr").toString();
|
str.append("项目清单: 共导入").append(sum).append("条数据,").append(" 成功").append(suc).append("条数据,").append(" 失败").append(err).append("条数据\n");
|
str.append("检验内容: 共导入").append(jsum).append("条数据,").append(" 成功").append(jsuc).append("条数据,").append(" 失败").append(jerr).append("条数据\n");
|
str.append("拆检范围: 共导入").append(csum).append("条数据,").append(" 成功").append(csuc).append("条数据,").append(" 失败").append(cerr).append("条数据");
|
Map<String, Object> stringObjectMap = importResults.get(3);
|
List<ImportErrDto> errList = new ArrayList<>();
|
for (String key : stringObjectMap.keySet()) {
|
ImportErrMessage value = (ImportErrMessage) stringObjectMap.get(key);
|
errList.add(new ImportErrDto(value.getSheetName(), key, value.getLineNumber()));
|
}
|
if (errList.size() > 0) {
|
for (ImportErrDto importErrDto : errList) {
|
importErrDto.setLineNumber(importErrDto.getLineNumber().substring(0, importErrDto.getLineNumber().length() - 1));
|
}
|
}
|
result.setMsg(str.toString());
|
result.setCode(501);
|
Collections.sort(errList);
|
result.setData(errList);
|
}
|
}
|
|
public static void ImportErrResultProjectList(Result<List<ImportErrDto>> result, List<Map<String, Object>> importResults, StringBuilder str) {
|
if (importResults.size() == 3) { //导入有错误
|
String sum = importResults.get(0).get("sum").toString();
|
String suc = importResults.get(0).get("suc").toString();
|
String err = importResults.get(0).get("err").toString();
|
String jsum = importResults.get(1).get("jsum").toString();
|
String jsuc = importResults.get(1).get("jsuc").toString();
|
String jerr = importResults.get(1).get("jerr").toString();
|
str.append("项目清单: 共导入").append(sum).append("条数据,").append(" 成功").append(suc).append("条数据,").append(" 失败").append(err).append("条数据\n");
|
str.append("检验内容: 共导入").append(jsum).append("条数据,").append(" 成功").append(jsuc).append("条数据,").append(" 失败").append(jerr).append("条数据");
|
Map<String, Object> stringObjectMap = importResults.get(2);
|
List<ImportErrDto> errList = new ArrayList<>();
|
for (String key : stringObjectMap.keySet()) {
|
ImportErrMessage value = (ImportErrMessage) stringObjectMap.get(key);
|
errList.add(new ImportErrDto(value.getSheetName(), key, value.getLineNumber()));
|
}
|
if (errList.size() > 0) {
|
for (ImportErrDto importErrDto : errList) {
|
importErrDto.setLineNumber(importErrDto.getLineNumber().substring(0, importErrDto.getLineNumber().length() - 1));
|
}
|
}
|
result.setMsg(str.toString());
|
result.setCode(501);
|
Collections.sort(errList);
|
result.setData(errList);
|
}
|
}
|
|
/**
|
* 导入异常处理
|
* @param errMap
|
* @param errSting
|
* @param sheetName
|
* @param row
|
*/
|
public static void updateErrMap(Map<String, Object> errMap, String errSting, String sheetName, int row) {
|
if (!errMap.containsKey(errSting)) {
|
errMap.put(errSting, new ImportErrMessage(sheetName, row + "、"));
|
} else {
|
ImportErrMessage importErrMessage1 = (ImportErrMessage) errMap.get(errSting);
|
importErrMessage1.setLineNumber(importErrMessage1.getLineNumber() + row + "、");
|
}
|
}
|
|
|
/*
|
* 判断是否为整数
|
* @param str 传入的字符串
|
* @return 是整数返回true,否则返回false
|
*/
|
public static boolean isInteger(String str) {
|
Pattern pattern = Pattern.compile("^[-\\+]?[\\d]*$");
|
return pattern.matcher(str).matches();
|
}
|
|
|
/**
|
* 通过字典显示值获取value
|
*
|
* @param tempList 字典项集合
|
* @param dLabel 字典显示值
|
* @return
|
*/
|
public static String getDictValue(List<DictItemDto> tempList, String dLabel) {
|
|
String tempstr = "";
|
for (DictItemDto dd : tempList) {
|
if (dd.getDictLabel().equals(dLabel)) {
|
tempstr = dd.getDictValue();
|
break;
|
}
|
}
|
return tempstr;
|
}
|
|
/**
|
* 通过维修级别的数值返回维系类别
|
* @param maintainLevel
|
* @param maintainLevelName
|
* @return
|
*/
|
public static String getMaintainLevelName(Integer maintainLevel, String maintainLevelName) {
|
if (maintainLevel != null) {
|
switch (maintainLevel) {
|
case 1:
|
maintainLevelName = "wj";
|
break;
|
case 2:
|
maintainLevelName = "xx";
|
break;
|
case 3:
|
maintainLevelName = "zx";
|
break;
|
default:
|
maintainLevelName = "";
|
break;
|
}
|
}
|
return maintainLevelName;
|
}
|
|
/**
|
* 通过字符串id获取id数组
|
* @param ids
|
* @return
|
*/
|
public static List<Long> idsFormatList(String ids) {
|
List<Long> idList = new ArrayList<>();
|
if (!StringUtils.isEmpty(ids)) {
|
String strids[] = ids.split(",");
|
for (String strtemp : strids) {
|
if (strtemp == null || strtemp.isEmpty()) {
|
continue;
|
}
|
idList.add(Long.parseLong(strtemp));
|
}
|
}
|
return idList;
|
}
|
|
public static String queryMaintainUnit(List<SysDept> sysDepts, String mainTainUnit, String dwNames) {
|
if (null != mainTainUnit) {
|
String[] dwIdList = mainTainUnit.split(",");
|
dwNames = getMaintainUnit(sysDepts, dwIdList, dwNames);
|
if (dwNames != null && dwNames.length() > 0) {
|
dwNames = dwNames.substring(0, dwNames.length() - 1);
|
}
|
}
|
return dwNames;
|
}
|
|
public static String getMaintainUnit(List<SysDept> sysDepts, String[] dwIdList, String dwNames) {
|
for (String temp : dwIdList) {
|
if (temp.matches("[0-9]+")) {
|
Optional<SysDept> sds = sysDepts.stream().filter(item -> item.getId().equals(Long.parseLong(temp))).findFirst();
|
if (sds.isPresent()) {
|
dwNames += sds.get().getName() + ",";
|
}
|
}
|
}
|
return dwNames;
|
}
|
|
|
/**
|
* 通过字典value获取指点显示
|
*
|
* @param templist 字典项集合
|
* @param dictid 字典value
|
* @return
|
*/
|
public static String getDictName(List<DictItemDto> templist, String dictid) {
|
|
String tempstr = "";
|
for (DictItemDto dd : templist) {
|
if (dd.getDictValue().equals(dictid)) {
|
tempstr = dd.getDictLabel();
|
break;
|
}
|
}
|
return tempstr;
|
}
|
|
/**
|
* 判断时间格式是否正确
|
*
|
* @param value
|
* @param format
|
* @return
|
*/
|
public static boolean isDate(String value, String format) {
|
|
SimpleDateFormat sdf = null;
|
ParsePosition pos = new ParsePosition(0);//指定从所传字符串的首位开始解析
|
|
if (value == null || isEmpty(format)) {
|
return false;
|
}
|
try {
|
sdf = new SimpleDateFormat(format);
|
sdf.setLenient(false);
|
Date date = sdf.parse(value, pos);
|
if (date == null) {
|
return false;
|
} else {
|
//更为严谨的日期,如2011-03-024认为是不合法的
|
if (pos.getIndex() > sdf.format(date).length()) {
|
return false;
|
}
|
return true;
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
return false;
|
}
|
}
|
|
|
public static Long getProductID(List<Product> allProduct, String[] productNames) {
|
Long result = null;
|
List<Product> myproducts = allProduct;
|
for (String temp : productNames) {
|
if (temp.isEmpty()) {
|
continue;
|
}
|
Optional<Product> myop = myproducts.stream().filter(item -> item.getName().equals(temp)).findFirst();
|
if (myop != null && myop.isPresent()) {
|
result = myop.get().getId();
|
myproducts = allProduct.stream().filter(item -> item.getParentProductId().equals(myop.get().getId())).collect(Collectors.toList());
|
if (myproducts.size() > 0) {
|
continue;
|
} else {
|
break;
|
}
|
}
|
}
|
if (myproducts != null && myproducts.size() > 0) {
|
return myproducts.get(0).getId();
|
} else {
|
return result;
|
}
|
}
|
|
}
|
