|
@@ -49,12 +49,17 @@ public class QCAnalysis {
|
|
throw new AIException("AI模型执行错误:" + e.getMessage());
|
|
throw new AIException("AI模型执行错误:" + e.getMessage());
|
|
}
|
|
}
|
|
long t3 = System.currentTimeMillis();
|
|
long t3 = System.currentTimeMillis();
|
|
- for (Map.Entry<String, Map<String, String>> entry : inputInfo.getInputCatalogueMap().entrySet()) {
|
|
|
|
- if (CatalogueUtil.qcCatalogueMap.get(entry.getKey()) == null) {
|
|
|
|
- continue;
|
|
|
|
|
|
+// for (Map.Entry<String, Map<String, String>> entry : inputInfo.getInputCatalogueMap().entrySet()) {
|
|
|
|
+// if (CatalogueUtil.qcCatalogueMap.get(entry.getKey()) == null) {
|
|
|
|
+// continue;
|
|
|
|
+// }
|
|
|
|
+// CatalogueUtil.qcCatalogueMap.get(entry.getKey()).execute(inputInfo, outputInfo);
|
|
|
|
+// }
|
|
|
|
+ inputInfo.getInputCatalogueMap().entrySet().parallelStream().forEach(entry -> {
|
|
|
|
+ if (CatalogueUtil.qcCatalogueMap.get(entry.getKey()) != null) {
|
|
|
|
+ CatalogueUtil.qcCatalogueMap.get(entry.getKey()).execute(inputInfo, outputInfo);
|
|
}
|
|
}
|
|
- CatalogueUtil.qcCatalogueMap.get(entry.getKey()).execute(inputInfo, outputInfo);
|
|
|
|
- }
|
|
|
|
|
|
+ });
|
|
long t4 = System.currentTimeMillis();
|
|
long t4 = System.currentTimeMillis();
|
|
|
|
|
|
log.error(queryVo.getBehospitalInfo().getBehospitalCode() + "-----" + "trans层 耗时:" + (t2 - t1));
|
|
log.error(queryVo.getBehospitalInfo().getBehospitalCode() + "-----" + "trans层 耗时:" + (t2 - t1));
|