|
@@ -34,7 +34,7 @@ public class AssemblePushAggregate {
|
|
|
@InvokeParameter("pushDTO") PushDTO data,
|
|
|
@InvokeParameter("hospitalId") Long hospitalId,
|
|
|
@DataConsumer("retLis") List<PushBaseDTO> retLis,
|
|
|
- @DataConsumer("retPacs") List<PushBaseDTO> retPacs,
|
|
|
+ @DataConsumer("retPacs") Map<String, List<PushBaseDTO>> retPacs,
|
|
|
@DataConsumer("retDiagMap") Map<String, List<PushBaseDTO>> retDiagMap,
|
|
|
@DataConsumer("retOperation") List<PushBaseDTO> retOperation,
|
|
|
@DataConsumer("retDrug") List<PushBaseDTO> retDrug,
|
|
@@ -46,7 +46,7 @@ public class AssemblePushAggregate {
|
|
|
data.setLis(retLis);
|
|
|
}
|
|
|
//检查
|
|
|
- if (ListUtil.isNotEmpty(retPacs)) {
|
|
|
+ if (MapUtils.isNotEmpty(retPacs)) {
|
|
|
data.setPacs(retPacs);
|
|
|
}
|
|
|
//诊断
|
|
@@ -105,31 +105,36 @@ public class AssemblePushAggregate {
|
|
|
}
|
|
|
|
|
|
@DataProvider("retPacs")
|
|
|
- public List<PushBaseDTO> retPacs(@InvokeParameter("pushDTO") PushDTO data,
|
|
|
+ public Map<String,List<PushBaseDTO>> retPacs(@InvokeParameter("pushDTO") PushDTO data,
|
|
|
@InvokeParameter("hospitalId") Long hospitalId) {
|
|
|
//检查
|
|
|
- List<PushBaseDTO> retPacs = new ArrayList<>();
|
|
|
- if (ListUtil.isNotEmpty(data.getPacs())) {
|
|
|
- retPacs = data.getPacs();
|
|
|
- List<String> uniqueNameList = retPacs.stream()
|
|
|
- .map(i -> i.getName())
|
|
|
- .collect(Collectors.toList());
|
|
|
- Map<String, Map<String, Map<String, List<String>>>> uniqueNameMap
|
|
|
- = mappingConfigFacade.groupByUniqueNameWithName(uniqueNameList, ConceptTypeEnum.Pacs.getKey(), hospitalId, StatusEnum.Enable.getKey());
|
|
|
+ Map<String,List<PushBaseDTO>> retMapPacs = new HashMap<>();
|
|
|
+ for(Map.Entry<String,List<PushBaseDTO>> entry : retMapPacs.entrySet()){
|
|
|
+ List<PushBaseDTO> retPacs = new ArrayList<>();
|
|
|
+ if (MapUtils.isNotEmpty(data.getPacs())) {
|
|
|
+ retPacs = entry.getValue();
|
|
|
+ List<String> uniqueNameList = retPacs.stream()
|
|
|
+ .map(i -> i.getName())
|
|
|
+ .collect(Collectors.toList());
|
|
|
+ Map<String, Map<String, Map<String, List<String>>>> uniqueNameMap
|
|
|
+ = mappingConfigFacade.groupByUniqueNameWithName(uniqueNameList, ConceptTypeEnum.Pacs.getKey(), hospitalId, StatusEnum.Enable.getKey());
|
|
|
|
|
|
- if (uniqueNameMap != null && uniqueNameMap.size() > 0) {
|
|
|
- retPacs.forEach(item -> {
|
|
|
- if (uniqueNameMap.get(item.getName()) != null) {
|
|
|
- item.setHisNameList(uniqueNameMap.get(item.getName())
|
|
|
- .values().stream()
|
|
|
- .map(i -> i.keySet())
|
|
|
- .flatMap(Collection::stream)
|
|
|
- .collect(Collectors.toList()));
|
|
|
- }
|
|
|
- });
|
|
|
+ if (uniqueNameMap != null && uniqueNameMap.size() > 0) {
|
|
|
+ retPacs.forEach(item -> {
|
|
|
+ if (uniqueNameMap.get(item.getName()) != null) {
|
|
|
+ item.setHisNameList(uniqueNameMap.get(item.getName())
|
|
|
+ .values().stream()
|
|
|
+ .map(i -> i.keySet())
|
|
|
+ .flatMap(Collection::stream)
|
|
|
+ .collect(Collectors.toList()));
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
}
|
|
|
+ retMapPacs.put(entry.getKey(), retPacs);
|
|
|
}
|
|
|
- return retPacs;
|
|
|
+
|
|
|
+ return retMapPacs;
|
|
|
}
|
|
|
|
|
|
@DataProvider("retDiagMap")
|