Commit c427ecab authored by lvcunle's avatar lvcunle

edit 空值预处理

parent 4eae87e8
Pipeline #1026 failed with stages
...@@ -9,12 +9,14 @@ import java.io.File; ...@@ -9,12 +9,14 @@ import java.io.File;
*/ */
public interface IssuesListDetailServer { public interface IssuesListDetailServer {
/** /**
* * excel导入 * excel导入
* *
* @param excel excel文件 * @param excel excel文件
* @param projectId 项目id * @param projectId 项目id
* @param userId 当前登录人id * @param userId 当前登录人id
* @param projectName 项目名称
* @param tenantId 租户id
* @return * @return
*/ */
Result<String> importExcel(File excel, String projectId, String userId); Result<String> importExcel(File excel, String projectId, String userId, String projectName, String tenantId);
} }
...@@ -12,7 +12,6 @@ import com.yundong.third.entity.IssuesListDetailExcel; ...@@ -12,7 +12,6 @@ import com.yundong.third.entity.IssuesListDetailExcel;
import com.yundong.third.mapper.IssuesListDeatilMapper; import com.yundong.third.mapper.IssuesListDeatilMapper;
import com.yundong.third.server.IssuesListDetailServer; import com.yundong.third.server.IssuesListDetailServer;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.math.NumberUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
...@@ -31,14 +30,16 @@ public class IssuesListDetailServerImpl implements IssuesListDetailServer { ...@@ -31,14 +30,16 @@ public class IssuesListDetailServerImpl implements IssuesListDetailServer {
/** /**
* excel导入 * excel导入
* *
* @param excel excel文件 * @param excel excel文件
* @param projectId 项目id * @param projectId 项目id
* @param userId 当前登录人id * @param userId 当前登录人id
* @param projectName 项目名称
* @param tenantId 租户id
* @return * @return
*/ */
@YdcGateway(name = "monitorCounter-issuesList", url = "third/monitor/issuesListDetail/importExcel.json") @YdcGateway(name = "monitorCounter-issuesList", url = "third/monitor/issuesListDetail/importExcel.json")
@Override @Override
public Result<String> importExcel(File excel, String projectId, String userId) { public Result<String> importExcel(File excel, String projectId, String userId, String projectName, String tenantId) {
if (excel == null) { if (excel == null) {
return Result.fail("文件不能为空"); return Result.fail("文件不能为空");
} }
...@@ -50,19 +51,25 @@ public class IssuesListDetailServerImpl implements IssuesListDetailServer { ...@@ -50,19 +51,25 @@ public class IssuesListDetailServerImpl implements IssuesListDetailServer {
ExcelListener excelListener = new ExcelListener(); ExcelListener excelListener = new ExcelListener();
EasyExcelFactory.read(excel, IssuesListDetailExcel.class, excelListener).excelType(ExcelTypeEnum.XLSX).sheet().doRead(); EasyExcelFactory.read(excel, IssuesListDetailExcel.class, excelListener).excelType(ExcelTypeEnum.XLSX).sheet().doRead();
List<IssuesListDetail> successData = excelListener.getSuccessData(); List<IssuesListDetail> successData = excelListener.getSuccessData();
if (successData.size() == 0) {
return Result.success("导入成功,条数:0条");
}
//查询 //查询
List<IssuesListDetail> issuesListDetails = issuesListDeatilMapper.selectList( List<IssuesListDetail> issuesListDetails = issuesListDeatilMapper.selectList(
new LambdaQueryWrapper<IssuesListDetail>() new LambdaQueryWrapper<IssuesListDetail>()
.eq(IssuesListDetail::getIsDeleted, 0) .eq(IssuesListDetail::getIsDeleted, 0)
.eq(IssuesListDetail::getPROJECTID, projectId)); .eq(IssuesListDetail::getPROJECTID, projectId));
String projectName = issuesListDetails.get(NumberUtils.INTEGER_ZERO).getPROJECTNAME();
String tenantId = issuesListDetails.get(NumberUtils.INTEGER_ZERO).getTenantId();
//过滤 //过滤
List<IssuesListDetail> importDataList = successData.stream() List<IssuesListDetail> importDataList;
.filter(item1 -> issuesListDetails.stream().noneMatch(item2 -> item2.getDISCOVERYTIME().equals(item1.getDISCOVERYTIME()) if (issuesListDetails.size() != 0) {
&& item2.getDESCRIBETEXT().equals(item1.getDESCRIBETEXT()))) importDataList = successData.stream()
.collect(Collectors.toList()); .filter(item1 -> issuesListDetails.stream().noneMatch(item2 -> item2.getDISCOVERYTIME().equals(item1.getDISCOVERYTIME())
&& item2.getDESCRIBETEXT().equals(item1.getDESCRIBETEXT())))
.collect(Collectors.toList());
} else {
importDataList = successData;
}
//赋值导入 //赋值导入
Date date = new Date(System.currentTimeMillis()); Date date = new Date(System.currentTimeMillis());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment