diff --git a/src/main/java/digital/laboratory/platform/entrustment/controller/EntrustMaterialCheckoutResultController.java b/src/main/java/digital/laboratory/platform/entrustment/controller/EntrustMaterialCheckoutResultController.java index 1c25ce6..1e1a6da 100644 --- a/src/main/java/digital/laboratory/platform/entrustment/controller/EntrustMaterialCheckoutResultController.java +++ b/src/main/java/digital/laboratory/platform/entrustment/controller/EntrustMaterialCheckoutResultController.java @@ -16,10 +16,12 @@ import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; + import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; import javax.validation.Valid; import java.io.IOException; +import java.time.LocalDateTime; import java.util.List; /** @@ -85,20 +87,26 @@ public class EntrustMaterialCheckoutResultController { @ApiOperation("查询所有检出检材的毒品种类清单，并按名称进行排序") @GetMapping("/getResultType") - public R getResultType(Integer year, String orgId){ - return R.ok(entrustMaterialCheckoutResultService.getResultType(year, orgId),"查询成功!"); + public R getResultType(Integer year, String orgId) { + return R.ok(entrustMaterialCheckoutResultService.getResultType(year, orgId), "查询成功!"); } @ApiOperation("查询所有毒品的检出率") @GetMapping("/getDetectionRate") - public R getDetectionRateByMaterial(Integer year, String orgId){ - return R.ok(entrustMaterialCheckoutResultService.getDetectionRateByMaterial(year, orgId),"查询成功!"); + public R getDetectionRateByMaterial(Integer year, String orgId) { + return R.ok(entrustMaterialCheckoutResultService.getDetectionRateByMaterial(year, orgId), "查询成功!"); } @ApiOperation("根据毒品名称来查询所有检出该毒品的检材列表") @GetMapping("/getMaterialByDetection") - public R getMaterialByDetection(String drugName, Integer year, Page page){ - return R.ok(entrustMaterialCheckoutResultService.getMaterialByDetection(drugName,year,page)); + public R getMaterialByDetection(String drugName, Integer year, Page page) { + return R.ok(entrustMaterialCheckoutResultService.getMaterialByDetection(drugName, year, page)); + } + + @ApiOperation("导出Excel") + @GetMapping("/getExcelByResult") + public void getResultData(HttpServletResponse response, Integer entrustType, String oldResult, LocalDateTime startTime, LocalDateTime endTime) throws IOException { + entrustMaterialCheckoutResultService.getExcelByResult(response, entrustType, oldResult, startTime, endTime); } } diff --git a/src/main/java/digital/laboratory/platform/entrustment/controller/EntrustmentController.java b/src/main/java/digital/laboratory/platform/entrustment/controller/EntrustmentController.java index bb33a43..65437d9 100644 --- a/src/main/java/digital/laboratory/platform/entrustment/controller/EntrustmentController.java +++ b/src/main/java/digital/laboratory/platform/entrustment/controller/EntrustmentController.java @@ -16,6 +16,7 @@ import digital.laboratory.platform.common.core.util.R; import digital.laboratory.platform.common.log.annotation.SysLog; import digital.laboratory.platform.common.mybatis.security.service.DLPUser; import digital.laboratory.platform.common.oss.service.OssFile; +import digital.laboratory.platform.common.security.annotation.Inner; import digital.laboratory.platform.common.security.util.SecurityUtils; import digital.laboratory.platform.entrustment.dto.EntrustmentDTO; import digital.laboratory.platform.entrustment.entity.CaseEvent; @@ -2387,4 +2388,11 @@ public class EntrustmentController { return R.ok(entrustmentService.getDelivererList(dlpUser), "数据查询成功!"); } + + @GetMapping("/getById") + @Inner(value = false) + public R getEntrustById(String id) { + Entrustment entrustment = entrustmentService.getById(id); + return R.ok(entrustment); + } } diff --git a/src/main/java/digital/laboratory/platform/entrustment/service/EntrustMaterialCheckoutResultService.java b/src/main/java/digital/laboratory/platform/entrustment/service/EntrustMaterialCheckoutResultService.java index 4d550e4..2f8f57f 100644 --- a/src/main/java/digital/laboratory/platform/entrustment/service/EntrustMaterialCheckoutResultService.java +++ b/src/main/java/digital/laboratory/platform/entrustment/service/EntrustMaterialCheckoutResultService.java @@ -12,6 +12,7 @@ import digital.laboratory.platform.entrustment.vo.EntrustmentIdentificationMater import javax.servlet.http.HttpServletResponse; import java.io.IOException; +import java.time.LocalDateTime; import java.util.List; /** @@ -69,4 +70,8 @@ public interface EntrustMaterialCheckoutResultService extends IService getResultData(Integer entrustType, String oldResult, LocalDateTime startTime, LocalDateTime endTime); + + void getExcelByResult(HttpServletResponse response, Integer entrustType, String oldResult, LocalDateTime startTime, LocalDateTime endTime) throws IOException; } diff --git a/src/main/java/digital/laboratory/platform/entrustment/service/impl/EntrustMaterialCheckoutResultServiceImpl.java b/src/main/java/digital/laboratory/platform/entrustment/service/impl/EntrustMaterialCheckoutResultServiceImpl.java index ae9abcb..7d84cb3 100644 --- a/src/main/java/digital/laboratory/platform/entrustment/service/impl/EntrustMaterialCheckoutResultServiceImpl.java +++ b/src/main/java/digital/laboratory/platform/entrustment/service/impl/EntrustMaterialCheckoutResultServiceImpl.java @@ -2,7 +2,10 @@ package digital.laboratory.platform.entrustment.service.impl; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.StrUtil; +import cn.hutool.log.Log; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -29,6 +32,7 @@ import digital.laboratory.platform.sys.entity.Area; import digital.laboratory.platform.sys.entity.DrugLite; import org.apache.poi.ss.usermodel.*; import org.apache.poi.xssf.usermodel.XSSFWorkbook; +import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import javax.annotation.Resource; @@ -43,13 +47,13 @@ import java.util.function.Function; import java.util.stream.Collectors; /** -* @author ChenJiangBao -* @description 针对表【b_entrust_material_checkout_result(委托检材--检出定性定量结果信息)】的数据库操作Service实现 -* @createDate 2024-12-30 16:16:25 -*/ + * @author ChenJiangBao + * @description 针对表【b_entrust_material_checkout_result(委托检材--检出定性定量结果信息)】的数据库操作Service实现 + * @createDate 2024-12-30 16:16:25 + */ @Service public class EntrustMaterialCheckoutResultServiceImpl extends ServiceImpl - implements EntrustMaterialCheckoutResultService { + implements EntrustMaterialCheckoutResultService { @Resource private EntrustmentService entrustmentService; @@ -106,6 +110,7 @@ public class EntrustMaterialCheckoutResultServiceImpl extends ServiceImpl entrustIds, HttpServletResponse response) throws IOException { @@ -196,6 +201,7 @@ public class EntrustMaterialCheckoutResultServiceImpl extends ServiceImpl(query.getCurrent(), query.getSize()), Wrappers.query() - .eq(StrUtil.isNotBlank(query.getEntrustId()), "emr.entrust_id", query.getEntrustId()) + .eq(StrUtil.isNotBlank(query.getEntrustId()), "emr.entrust_id", query.getEntrustId()) .orderByAsc("em.order_no") ); } @@ -231,15 +237,15 @@ public class EntrustMaterialCheckoutResultServiceImpl extends ServiceImpl + * 此方法用于将给定的checkoutResultExcelDTOS列表数据写入Excel文件，并输出到HttpServletResponse对象中。 + * 方法首先创建一个新的XSSFWorkbook对象作为Excel工作簿，并为其创建一个名为当前日期时间的工作表。 + * 接着，根据buildExcelHead方法返回的表头信息构建Excel的表头行。 + * 然后，遍历checkoutResultExcelDTOS列表，将每个元素的数据写入Excel的对应行中。 + * 最后，使用response.getOutputStream()获取输出流，将构建好的Excel工作簿写入该输出流中，实现文件的下载。 */ private void buildExcel(HttpServletResponse response, List checkoutResultExcelDTOS) throws IOException { Workbook workbook = new XSSFWorkbook(); @@ -301,9 +307,9 @@ public class EntrustMaterialCheckoutResultServiceImpl extends ServiceImpl fetchCheckoutResultExcelDTOList(List entrustList, Map> materialMap, Map checkoutResultMap) { @@ -385,10 +391,10 @@ public class EntrustMaterialCheckoutResultServiceImpl extends ServiceImpl list = this.list(Wrappers.lambdaQuery() - .in(CollUtil.isNotEmpty(entrustIdList), EntrustMaterialCheckoutResult::getEntrustId, entrustIdList) - .ne(EntrustMaterialCheckoutResult::getQualitativeResult, "") // 排除空字符串 - .isNotNull(EntrustMaterialCheckoutResult::getQualitativeResult) // 排除空值 - .ge(EntrustMaterialCheckoutResult::getCreateTime, startTime)); // 创建时间大于等于起始时间 + .in(CollUtil.isNotEmpty(entrustIdList), EntrustMaterialCheckoutResult::getEntrustId, entrustIdList) + .ne(EntrustMaterialCheckoutResult::getQualitativeResult, "") // 排除空字符串 + .isNotNull(EntrustMaterialCheckoutResult::getQualitativeResult) // 排除空值 + .ge(EntrustMaterialCheckoutResult::getCreateTime, startTime)); // 创建时间大于等于起始时间 // 用于存储去重后的毒品类型列表 ArrayList typeList = new ArrayList<>(); @@ -452,9 +458,9 @@ public class EntrustMaterialCheckoutResultServiceImpl extends ServiceImpl materialList = entrustmentIdentificationMaterialService.list(Wrappers.lambdaQuery() - .in(CollUtil.isNotEmpty(entrustIdList), EntrustmentIdentificationMaterial::getEntrustmentId, entrustIdList) - .ge(EntrustmentIdentificationMaterial::getAcceptTime, startTime) - .eq(EntrustmentIdentificationMaterial::getAcceptPassed, 1)); + .in(CollUtil.isNotEmpty(entrustIdList), EntrustmentIdentificationMaterial::getEntrustmentId, entrustIdList) + .ge(EntrustmentIdentificationMaterial::getAcceptTime, startTime) + .eq(EntrustmentIdentificationMaterial::getAcceptPassed, 1)); // 如果查询结果为空，直接返回 null @@ -481,17 +487,17 @@ public class EntrustMaterialCheckoutResultServiceImpl extends ServiceImpl getMaterialByDetection(String drugName, Integer year, Page page){ + public IPage getMaterialByDetection(String drugName, Integer year, Page page) { List list = this.list(Wrappers.lambdaQuery() .like(EntrustMaterialCheckoutResult::getQualitativeResult, drugName)); @@ -511,6 +517,484 @@ public class EntrustMaterialCheckoutResultServiceImpl extends ServiceImpl getResultData(Integer entrustType, String oldResult, LocalDateTime startTime, LocalDateTime endTime) { + + LambdaQueryWrapper qw = new LambdaQueryWrapper<>(); + + if (startTime != null && endTime != null) { + qw.ge(startTime != null, EntrustMaterialCheckoutResult::getCreateTime, startTime) + .le(endTime != null, EntrustMaterialCheckoutResult::getCreateTime, endTime); + } else { + qw.ge(EntrustMaterialCheckoutResult::getCreateTime, this.getStartTime(null)); + } + // 查询所有符合时间条件的检测结果 + List resultList = this.list(qw + .isNotNull(EntrustMaterialCheckoutResult::getQualitativeResult) + .ne(EntrustMaterialCheckoutResult::getQualitativeResult, "")); + + // 如果没有查询到数据，则直接返回空列表 + if (CollUtil.isEmpty(resultList)) { + return Collections.emptyList(); + } + + // 按委托 ID 进行分组 + Map> resultMap = resultList.stream() + .collect(Collectors.groupingBy(EntrustMaterialCheckoutResult::getEntrustId)); + + // 获取所有的委托 ID + Set entrustIdList = resultMap.keySet(); + + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + + if (StringUtils.isNotBlank(oldResult)) { + if (oldResult.equals("委托")) { + String types[] = {"首次鉴定", "补充鉴定", "重新鉴定"}; + wrapper.in(Entrustment::getOldIdentificationResult, types); + } else { + wrapper.eq(Entrustment::getOldIdentificationResult, oldResult); + } + } + // 批量查询符合条件的委托信息，避免多次查询数据库 + List entrustmentList = entrustmentService.list(wrapper + .in(Entrustment::getId, entrustIdList) + .eq(entrustType != null, Entrustment::getEntrustmentType, entrustType)); + + if (CollUtil.isEmpty(entrustmentList)) { + return Collections.emptyList(); + } + + // 获取所有符合条件的委托 ID + Set filteredEntrustIds = entrustmentList.stream() + .map(Entrustment::getId) + .collect(Collectors.toSet()); + + // 获取所有符合条件的委托map + Map entrustMap = entrustmentList.stream() + .collect(Collectors.toMap(Entrustment::getId, Function.identity())); + + // 过滤出符合条件的检测结果 + List newResultList = resultList.stream() + .filter(result -> filteredEntrustIds.contains(result.getEntrustId())) + .collect(Collectors.toList()); + + // 提取所有 resultId 批量查询 EntrustmentIdentificationMaterial，避免循环查询数据库 + Set resultIds = newResultList.stream() + .map(EntrustMaterialCheckoutResult::getId) + .collect(Collectors.toSet()); + + // 批量查询所有相关的材料信息 + List materialList = entrustmentIdentificationMaterialService.list(Wrappers + .lambdaQuery() + .in(EntrustmentIdentificationMaterial::getId, resultIds) + .last("ORDER BY " + + "CAST(SUBSTRING_INDEX(accept_no, '-', 1) AS UNSIGNED) ASC, " + // 年份排序 + "CAST(SUBSTRING_INDEX(SUBSTRING_INDEX(accept_no, '-', -2), '-', 1) AS UNSIGNED) ASC, " + // 流水号排序 + "CAST(SUBSTRING_INDEX(accept_no, '-', -1) AS UNSIGNED) ASC")); // 子流水号排序 + + + // 将材料信息转换为 Map 以便快速查找 + Map materialMap = materialList.stream() + .collect(Collectors.toMap(EntrustmentIdentificationMaterial::getId, Function.identity())); + + // 构建返回的 VO 对象列表 + List voList = newResultList.stream() + .map(result -> { + EntrustmentIdentificationMaterial material = materialMap.get(result.getId()); + if (material == null) { + return null; + } + EntrustmentIdentificationMaterialVO vo = new EntrustmentIdentificationMaterialVO(); + BeanUtils.copyProperties(material, vo); + vo.setDrugLites(DrugLiteConvert.getDrugLites(result.getQualitativeResult())); + Entrustment entrust = entrustMap.get(vo.getEntrustmentId()); + String oldIdentificationResult = entrust.getOldIdentificationResult(); + if (oldIdentificationResult.equals("首次鉴定") || oldIdentificationResult.equals("补充鉴定") || oldIdentificationResult.equals("重新鉴定")) { + vo.setOldIdentificationResult("委托"); + } else { + vo.setOldIdentificationResult(oldIdentificationResult); + } + vo.setOrgName(entrust.getClientOrgName()); + return vo; + }) + .filter(Objects::nonNull) // 过滤掉可能为空的数据 + .collect(Collectors.toList()); + + // 按 acceptNo 进行排序 + voList.sort(Comparator.comparing((EntrustmentIdentificationMaterial m) -> { + String[] parts = m.getAcceptNo().split("-"); + return new int[]{Integer.parseInt(parts[0]), Integer.parseInt(parts[1]), Integer.parseInt(parts[2])}; + }, Comparator.comparingInt((int[] arr) -> arr[0]) // 按年份排序 + .thenComparingInt(arr -> arr[1]) // 按流水号排序 + .thenComparingInt(arr -> arr[2]))); // 按子流水号排序 + return voList; + } + + + public Map> getResultDataMap( + Integer entrustType, String oldResult, LocalDateTime startTime, LocalDateTime endTime) { + + try { + // 1. 构建查询条件 + LambdaQueryWrapper qw = new LambdaQueryWrapper<>(); + + // 时间过滤条件 + if (startTime != null && endTime != null) { + qw.ge(Entrustment::getAcceptTime, startTime).le(Entrustment::getCreateTime, endTime); + } else { + qw.ge(Entrustment::getAcceptTime, this.getStartTime(null)); + } + + if (StringUtils.isNotBlank(oldResult)) { + if (oldResult.equals("委托")) { + String types[] = {"首次鉴定", "补充鉴定", "重新鉴定"}; + qw.in(Entrustment::getOldIdentificationResult, types); + } else { + qw.eq(Entrustment::getOldIdentificationResult, oldResult); + } + } + // 2. 查询委托数据 + List entrusts = entrustmentService.list(qw + .eq(Entrustment::getEntrustmentType, entrustType) + .ge(Entrustment::getStatus, EntrustmentStatusConstants.ENTRUSTMENT_STATUS_ACCEPTED.getStatus())); + + if (entrusts.isEmpty()) { + return Collections.emptyMap(); + } + + // 将 Entrustment 转换为 Map，以 ID 为 Key，减少后续查询数据库的次数 + Map entrustMap = entrusts.stream() + .collect(Collectors.toMap(Entrustment::getId, Function.identity())); + + Set entrustIdList = entrustMap.keySet(); + + // 3. 查询符合条件的检验结果 + List newResultList = this.list(Wrappers.lambdaQuery() + .in(EntrustMaterialCheckoutResult::getEntrustId, entrustIdList) + .isNotNull(EntrustMaterialCheckoutResult::getQualitativeResult) + .ne(EntrustMaterialCheckoutResult::getQualitativeResult, "")); + + if (newResultList.isEmpty()) { + return Collections.emptyMap(); + } + + // 4. 提取所有涉及的毒品名称（去重） + Set drugNames = new HashSet<>(); + for (EntrustMaterialCheckoutResult result : newResultList) { + List drugLites = DrugLiteConvert.getDrugLites(result.getQualitativeResult()); + for (DrugLite drugLite : drugLites) { + drugNames.add(drugLite.getName()); + } + } + + // 5. 处理不同毒品名称的数据 + Map> resultMap = new HashMap<>(); + + for (String drugName : drugNames) { + // 5.1 查询所有含有该毒品的检验结果 + List resultList = this.list(Wrappers.lambdaQuery() + .like(EntrustMaterialCheckoutResult::getQualitativeResult, drugName) + .in(EntrustMaterialCheckoutResult::getEntrustId, entrustIdList)); + + if (resultList.isEmpty()) { + continue; + } + + // 转换为 Map，方便后续查找 + Map checkoutResultMap = resultList.stream() + .collect(Collectors.toMap(EntrustMaterialCheckoutResult::getId, Function.identity())); + + // 5.2 获取相关的鉴定材料 + Set materialIdSet = checkoutResultMap.keySet(); + List materialList = entrustmentIdentificationMaterialService.list(Wrappers.lambdaQuery() + .in(EntrustmentIdentificationMaterial::getId, materialIdSet)); + + if (materialList.isEmpty()) { + continue; + } + + // 5.3 组装 VO 数据 + List voList = new ArrayList<>(); + for (EntrustmentIdentificationMaterial material : materialList) { + Entrustment entrust = entrustMap.get(material.getEntrustmentId()); + if (entrust == null) continue; + + EntrustmentIdentificationMaterialVO vo = new EntrustmentIdentificationMaterialVO(); + BeanUtils.copyProperties(material, vo); + vo.setOrgName(entrust.getClientOrgName()); + String oldIdentificationResult = entrust.getOldIdentificationResult(); + if (oldIdentificationResult.equals("首次鉴定") || oldIdentificationResult.equals("补充鉴定") || oldIdentificationResult.equals("重新鉴定")) { + vo.setOldIdentificationResult("委托"); + } else { + vo.setOldIdentificationResult(oldIdentificationResult); + } + EntrustMaterialCheckoutResult checkoutResult = checkoutResultMap.get(vo.getId()); + if (checkoutResult != null) { + vo.setDrugLites(DrugLiteConvert.getDrugLites(checkoutResult.getQualitativeResult())); + } + + voList.add(vo); + } + + // 5.4 按受理编号排序 + voList.sort(Comparator.comparing(EntrustmentIdentificationMaterialVO::getAcceptNo, (a, b) -> { + try { + String[] partsA = a.split("-"); + String[] partsB = b.split("-"); + if (partsA.length != 3 || partsB.length != 3) return 0; + + int yearA = Integer.parseInt(partsA[0]), serialA = Integer.parseInt(partsA[1]), subSerialA = Integer.parseInt(partsA[2]); + int yearB = Integer.parseInt(partsB[0]), serialB = Integer.parseInt(partsB[1]), subSerialB = Integer.parseInt(partsB[2]); + + return Comparator.comparingInt((int[] arr) -> arr[0]) + .thenComparingInt(arr -> arr[1]) + .thenComparingInt(arr -> arr[2]) + .compare(new int[]{yearA, serialA, subSerialA}, new int[]{yearB, serialB, subSerialB}); + } catch (Exception e) { + return 0; // 防止解析错误导致异常 + } + })); + + resultMap.put(drugName, voList); + } + + return resultMap; + + } catch (Exception e) { + log.error("获取结果数据失败: ", e); + return Collections.emptyMap(); + } + } + + @Override + public void getExcelByResult(HttpServletResponse response, Integer entrustType, String oldResult, LocalDateTime + startTime, LocalDateTime endTime) throws IOException { + List resultData = this.getResultData(entrustType, oldResult, startTime, endTime); + Map> resultDataMap = this.getResultDataMap(entrustType, oldResult, startTime, endTime); + if (resultData.isEmpty() || resultDataMap.isEmpty()) { + throw new RuntimeException("没有符合条件的数据!"); + } + Workbook workbook = new XSSFWorkbook(); + Sheet sheet = null; + if (entrustType == 0) { + sheet = workbook.createSheet("常规毒品"); + } else { + if (StringUtils.isNotBlank(oldResult)) { + sheet = workbook.createSheet("生物样本-" + oldResult); + } else { + sheet = workbook.createSheet("生物样本"); + + } + } + String[] InVivoHeadList = new String[]{"检材类型", "检材编号", "检材名称", "检材性状", "检材质量", "年龄", "性别", "委托单位", "受理日期", "检出结果"}; + String[] InVitroHeadList = new String[]{"检材类型", "检材编号", "检材名称", "检材性状", "检材质量", "委托单位", "受理日期", "检出结果"}; + String[] headList; + if (entrustType == 0) { + headList = InVitroHeadList; + } else { + headList = InVivoHeadList; + } + + Row row = sheet.createRow(0); + for (int i = 0; i < headList.length; i++) { + Cell cell = row.createCell(i); + cell.setCellValue(headList[i]); + } + for (int i = 0; i < resultData.size(); i++) { + EntrustmentIdentificationMaterialVO vo = resultData.get(i); + Row contentRow = sheet.createRow(i + 1); + contentRow.createCell(0).setCellValue(vo.getOldIdentificationResult()); + contentRow.createCell(1).setCellValue(vo.getAcceptNo()); + contentRow.createCell(2).setCellValue(vo.getName()); + contentRow.createCell(3).setCellValue(vo.getFormName()); + contentRow.createCell(4).setCellValue(vo.getQuantity() + vo.getUnit()); + if (entrustType == 1) { + contentRow.createCell(5).setCellValue(vo.getMaterialAge()); + contentRow.createCell(6).setCellValue(vo.getBiologyGender()); + contentRow.createCell(7).setCellValue(vo.getOrgName()); + contentRow.createCell(8).setCellValue(vo.getAcceptTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); + List drugLites = vo.getDrugLites(); + if (CollUtil.isNotEmpty(drugLites)) { + StringBuilder drugName = new StringBuilder(); + for (DrugLite drugLite : drugLites) { + drugName.append(drugLite.getName()).append(","); + } + contentRow.createCell(9).setCellValue(drugName.substring(0, drugName.length() - 1)); + } else { + contentRow.createCell(9).setCellValue(""); + } + } else { + contentRow.createCell(5).setCellValue(vo.getOrgName()); + contentRow.createCell(6).setCellValue(vo.getAcceptTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); + List drugLites = vo.getDrugLites(); + if (CollUtil.isNotEmpty(drugLites)) { + StringBuilder drugName = new StringBuilder(); + for (DrugLite drugLite : drugLites) { + drugName.append(drugLite.getName()).append(","); + } + contentRow.createCell(7).setCellValue(drugName.substring(0, drugName.length() - 1)); + } else { + contentRow.createCell(7).setCellValue(""); + } + } + } + + Sheet statisticsSheet = workbook.createSheet("统计"); + + Row statisticsSheetRow = statisticsSheet.createRow(0); + + String[] statisticsHeadList = new String[]{"化合物种类", "类型", "检出数量", "总数量", "检出率"}; + + for (int i = 0; i < statisticsHeadList.length; i++) { + Cell cell = statisticsSheetRow.createCell(i); + cell.setCellValue(statisticsHeadList[i]); + } + Set drugSet = resultDataMap.keySet(); + + int materialSize = 0; + + for (String s : drugSet) { + materialSize += resultDataMap.get(s).size(); + } + + Map sizeMap = this.getSizeMap(entrustType, oldResult, startTime, endTime); + + System.out.println(sizeMap); + + for (String drugName : drugSet) { + List materialVOList = resultDataMap.get(drugName); + if (StringUtils.isNotBlank(oldResult)) { + Row sheetRow = statisticsSheet.createRow(statisticsSheet.getLastRowNum() + 1); + sheetRow.createCell(0).setCellValue(drugName); + sheetRow.createCell(1).setCellValue(oldResult); + sheetRow.createCell(2).setCellValue(materialVOList.size()); + sheetRow.createCell(3).setCellValue(sizeMap.get(oldResult)); + sheetRow.createCell(4).setCellValue(String.format("%.2f", materialVOList.size() * 1.0 / sizeMap.get(oldResult) * 100) + "%"); + } else { + Map> map = materialVOList.stream().collect(Collectors.groupingBy(EntrustmentIdentificationMaterialVO::getOldIdentificationResult)); + Set keySet = map.keySet(); + for (String key : keySet) { + System.out.println(key); + int size = map.get(key).size(); + Row sheetRow = statisticsSheet.createRow(statisticsSheet.getLastRowNum() + 1); + sheetRow.createCell(0).setCellValue(drugName); + sheetRow.createCell(1).setCellValue(key); + sheetRow.createCell(2).setCellValue(size); + sheetRow.createCell(3).setCellValue(Integer.valueOf(sizeMap.get(key))); + sheetRow.createCell(4).setCellValue(String.format("%.2f", size * 1.0 / sizeMap.get(key) * 100) + "%"); + } + } + + } + + for (String drugName : drugSet) { + List materialVOList = resultDataMap.get(drugName); + String title = drugName.replaceAll("[^\\u4e00-\\u9fa5a-zA-Z0-9]", ""); + sheet = workbook.createSheet(title); + Row row0 = sheet.createRow(0); + for (int i = 0; i < headList.length; i++) { + Cell cell = row0.createCell(i); + cell.setCellValue(headList[i]); + } + + for (int i = 0; i < materialVOList.size(); i++) { + EntrustmentIdentificationMaterialVO vo = materialVOList.get(i); + Row contentRow = sheet.createRow(i + 1); + contentRow.createCell(0).setCellValue(vo.getOldIdentificationResult()); + contentRow.createCell(1).setCellValue(vo.getAcceptNo()); + contentRow.createCell(2).setCellValue(vo.getName()); + contentRow.createCell(3).setCellValue(vo.getFormName()); + contentRow.createCell(4).setCellValue(vo.getQuantity() + vo.getUnit()); + if (entrustType == 1) { + contentRow.createCell(5).setCellValue(vo.getMaterialAge()); + contentRow.createCell(6).setCellValue(vo.getBiologyGender()); + contentRow.createCell(7).setCellValue(vo.getOrgName()); + contentRow.createCell(8).setCellValue(vo.getAcceptTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); + contentRow.createCell(9).setCellValue(drugName); + } else { + contentRow.createCell(5).setCellValue(vo.getOrgName()); + contentRow.createCell(6).setCellValue(vo.getAcceptTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); + contentRow.createCell(7).setCellValue(drugName); + } + } + } + workbook.write(response.getOutputStream()); + } + + public Map getSizeMap(Integer entrustType, String oldResult, LocalDateTime startTime, LocalDateTime endTime) { + // 构造查询条件，查询 EntrustmentIdentificationMaterial 数据 + LambdaQueryWrapper qw = new LambdaQueryWrapper<>(); + LocalDateTime queryStartTime = Optional.ofNullable(startTime).orElseGet(() -> this.getStartTime(null)); + + if (endTime != null) { + qw.between(EntrustmentIdentificationMaterial::getAcceptTime, queryStartTime, endTime); + } else { + qw.ge(EntrustmentIdentificationMaterial::getAcceptTime, queryStartTime); + } + + // 统计各类委托的数量 + int entrustSize = 0; + int preliminaryScreeningSize = 0; + int myanmarRelatedSize = 0; + int voluntaryRehabilitationSize = 0; + + // 构造查询条件，查询 Entrustment 数据 + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + if (endTime != null) { + wrapper.between(Entrustment::getAcceptTime, queryStartTime, endTime); + } else { + wrapper.ge(Entrustment::getAcceptTime, queryStartTime); + } + + // 查询符合条件的 Entrustment 记录 + List entrusts = entrustmentService.list(wrapper + .eq(Entrustment::getEntrustmentType, entrustType) + .eq(Entrustment::getStatus, EntrustmentStatusConstants.ENTRUSTMENT_STATUS_ACCEPTED.getStatus()) + ); + + // 按照 oldIdentificationResult 进行分组 + Map> entrustMap = entrusts.stream() + .collect(Collectors.groupingBy(Entrustment::getOldIdentificationResult)); + + // 遍历分组数据，计算各类 EntrustmentIdentificationMaterial 的数量 + for (Map.Entry> entry : entrustMap.entrySet()) { + String oldIdentificationResult = entry.getKey(); + List entrustList = entry.getValue(); + + // 获取 Entrustment ID 列表 + List entIdList = entrustList.stream() + .map(Entrustment::getId) + .collect(Collectors.toList()); + + // 查询与这些 Entrustment 关联的 EntrustmentIdentificationMaterial 数量 + int size = entrustmentIdentificationMaterialService.list(Wrappers.lambdaQuery() + .in(EntrustmentIdentificationMaterial::getEntrustmentId, entIdList)).size(); + + // 根据 oldIdentificationResult 分类累加数量 + switch (oldIdentificationResult) { + case "初筛": + preliminaryScreeningSize += size; + break; + case "涉缅人员": + myanmarRelatedSize += size; + break; + case "自愿戒治人员": + voluntaryRehabilitationSize += size; + break; + default: + entrustSize += size; + break; + } + } + + // 组装返回结果 + Map sizeMap = new HashMap<>(); + sizeMap.put("委托", entrustSize); + sizeMap.put("初筛", preliminaryScreeningSize); + sizeMap.put("涉缅人员", myanmarRelatedSize); + sizeMap.put("自愿戒治人员", voluntaryRehabilitationSize); + + return sizeMap; + } } diff --git a/src/main/java/digital/laboratory/platform/entrustment/vo/EntrustmentIdentificationMaterialVO.java b/src/main/java/digital/laboratory/platform/entrustment/vo/EntrustmentIdentificationMaterialVO.java index c344610..75ec3e4 100644 --- a/src/main/java/digital/laboratory/platform/entrustment/vo/EntrustmentIdentificationMaterialVO.java +++ b/src/main/java/digital/laboratory/platform/entrustment/vo/EntrustmentIdentificationMaterialVO.java @@ -1,12 +1,17 @@ package digital.laboratory.platform.entrustment.vo; import digital.laboratory.platform.entrustment.entity.EntrustmentIdentificationMaterial; +import digital.laboratory.platform.sys.entity.DrugLite; import lombok.Data; +import java.util.List; + @Data public class EntrustmentIdentificationMaterialVO extends EntrustmentIdentificationMaterial { - String formName; // 检材性状 - String sample1Type; // 样本1的类型:A/B, 根据盒子的 sampleType 而得 - String sample2Type; // 样本2的类型:A/B, 根据盒子的 sampleType 而得 - + String formName; // 检材性状 + String sample1Type; // 样本1的类型:A/B, 根据盒子的 sampleType 而得 + String sample2Type; // 样本2的类型:A/B, 根据盒子的 sampleType 而得 + List drugLites; + String oldIdentificationResult; + String orgName;// 原鉴定情况 用来区分是初筛还是委托 或者其他。。。 }