Dlp-Gyjd/dlp-entrustment
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

更新

Browse Source
This commit is contained in:
杨海航
2024-11-25 15:43:02 +08:00
parent 5f697ceb21
commit 8eaf860142
1 changed files with 10 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/java/digital/laboratory/platform/entrustment/service/impl/EntrustmentServiceImpl.java
View File

@@ -31,7 +31,6 @@ import digital.laboratory.platform.common.feign.RemoteWord2PDFService;
import digital.laboratory.platform.common.mybatis.security.service.DLPUser;
import digital.laboratory.platform.common.oss.service.OssFile;
import digital.laboratory.platform.common.security.util.SecurityUtils;
import digital.laboratory.platform.entrustment.config.GlobalThreadPool;
import digital.laboratory.platform.entrustment.constant.EntrustMarkConstants;
import digital.laboratory.platform.entrustment.convert.DrugLiteConvert;
import digital.laboratory.platform.entrustment.dto.EntrustmentDTO;
@@ -79,7 +78,6 @@ import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Function;
import java.util.function.Predicate;
@@ -2966,7 +2964,7 @@ public class EntrustmentServiceImpl extends ServiceImpl<EntrustmentMapper, Entru
Integer entrustmentIdentificationMaterialQuantity = 0;
Integer acceptanceIdentificationMaterialQuantity = 0;
Integer sewageJobIdentificationMaterialQuantity = 0;
Integer hairJobIdentificationMaterialQuantity = 0;
//查询这个账户（机构）下的所有委托中的所有已受理检材的数量
@@ -2978,17 +2976,15 @@ public class EntrustmentServiceImpl extends ServiceImpl<EntrustmentMapper, Entru
}
markersVOS.add(new MarkersVO("案件委托检材", entrustmentIdentificationMaterialQuantity, "", "EntrustmentCreate"));
CompletableFuture.runAsync(() -> {
Integer sewageJobIdentificationMaterialQuantity = 0;
R<Integer> imQuantity = remoteSewageJobService.getIMQuantity(dlpUser.getOrgId());
if (imQuantity.getCode() == CommonConstants.SUCCESS) {
sewageJobIdentificationMaterialQuantity = imQuantity.getData();
} else {
log.error("查询这个账户（机构）下面所送检且已受理的所有污水检材的数量 失败！失败原因：{}", imQuantity.getMsg());
sewageJobIdentificationMaterialQuantity = 0;
}
markersVOS.add(new MarkersVO("污水送检检材", sewageJobIdentificationMaterialQuantity, "", "SewageJobGet"));
}, GlobalThreadPool.getInstance());
R<Integer> imQuantity = remoteSewageJobService.getIMQuantity(dlpUser.getOrgId());
if (imQuantity.getCode() == CommonConstants.SUCCESS) {
sewageJobIdentificationMaterialQuantity = imQuantity.getData();
} else {
log.error("查询这个账户（机构）下面所送检且已受理的所有污水检材的数量 失败！失败原因：{}", imQuantity.getMsg());
sewageJobIdentificationMaterialQuantity = 0;
}
markersVOS.add(new MarkersVO("污水送检检材", sewageJobIdentificationMaterialQuantity, "", "SewageJobGet"));
try {
R<Integer> sampleQuantity = remoteHairJobService.getSampleQuantity(orgId, 2);