|
@@ -2,14 +2,16 @@ package com.diagbot.facade;
|
|
|
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
-import com.diagbot.client.AIServiceClient;
|
|
|
-import com.diagbot.client.HighRiskServiceClient;
|
|
|
+import com.diagbot.client.BigDataServiceClient;
|
|
|
+import com.diagbot.client.GraphServiceClient;
|
|
|
+import com.diagbot.client.TranServiceClient;
|
|
|
import com.diagbot.client.bean.FeatureRate;
|
|
|
import com.diagbot.client.bean.GdbResponse;
|
|
|
import com.diagbot.client.bean.Response;
|
|
|
import com.diagbot.client.bean.ResponseData;
|
|
|
import com.diagbot.client.bean.SearchData;
|
|
|
import com.diagbot.dto.PushDTO;
|
|
|
+import com.diagbot.dto.PushEMRDTO;
|
|
|
import com.diagbot.dto.PushKYJDTO;
|
|
|
import com.diagbot.dto.QuestionDTO;
|
|
|
import com.diagbot.entity.DeptInfo;
|
|
@@ -24,7 +26,10 @@ import com.diagbot.exception.CommonException;
|
|
|
import com.diagbot.util.BeanUtil;
|
|
|
import com.diagbot.util.EntityUtil;
|
|
|
import com.diagbot.util.FastJsonUtils;
|
|
|
+import com.diagbot.util.ListUtil;
|
|
|
import com.diagbot.util.StringUtil;
|
|
|
+import com.diagbot.vo.EMRPushVO;
|
|
|
+import com.diagbot.vo.HosCodeVO;
|
|
|
import com.diagbot.vo.LisKYJVO;
|
|
|
import com.diagbot.vo.LisResult;
|
|
|
import com.diagbot.vo.LisResultVO;
|
|
@@ -52,7 +57,7 @@ import java.util.stream.Collectors;
|
|
|
@Component
|
|
|
public class PushFacade {
|
|
|
@Autowired
|
|
|
- private AIServiceClient aiServiceClient;
|
|
|
+ private BigDataServiceClient bigDataServiceClient;
|
|
|
@Autowired
|
|
|
private QuestionFacade questionFacade;
|
|
|
@Autowired
|
|
@@ -62,9 +67,11 @@ public class PushFacade {
|
|
|
@Autowired
|
|
|
private TreatmentFacade treatmentFacade;
|
|
|
@Autowired
|
|
|
- private HighRiskServiceClient highRiskServiceClient;
|
|
|
+ private GraphServiceClient graphServiceClient;
|
|
|
@Autowired
|
|
|
private LisMappingFacade lisMappingFacade;
|
|
|
+ @Autowired
|
|
|
+ private TranServiceClient tranServiceClient;
|
|
|
|
|
|
/**
|
|
|
* 推理接口
|
|
@@ -97,7 +104,7 @@ public class PushFacade {
|
|
|
|
|
|
//化验项映射,转公表
|
|
|
if (pushVO.getLis().size() > 0) {
|
|
|
- Map<String, Map<String, String>> lisConfigMap = lisMappingFacade.getLisMapping();
|
|
|
+ Map<String, Map<String, String>> lisConfigMap = lisMappingFacade.getLisMapping_NotEmptyItemName();
|
|
|
for (LisResultVO lisResultVO : pushVO.getLis()) {
|
|
|
//source=0 icss页面数据,source=1 外部导入数据
|
|
|
if (!lisResultVO.getSource().equals(LisSourceEnum.Inner.getKey())) {
|
|
@@ -118,7 +125,7 @@ public class PushFacade {
|
|
|
searchData.setSysCode("1");
|
|
|
searchData.setLength(10);
|
|
|
|
|
|
- Response<ResponseData> res = aiServiceClient.bayesPageData(searchData);
|
|
|
+ Response<ResponseData> res = bigDataServiceClient.bayesPageData(searchData);
|
|
|
if (null == res || null == res.getData()) {
|
|
|
throw new CommonException(CommonErrorCode.SERVER_IS_ERROR, "AI没有返回结果");
|
|
|
}
|
|
@@ -195,7 +202,7 @@ public class PushFacade {
|
|
|
highRiskMap.put("disease", String.join(",", diseaseNameList));
|
|
|
SearchData searchData = new SearchData();
|
|
|
searchData.setDiag(String.join(",", diseaseNameList));
|
|
|
- Response<GdbResponse> graphRes = highRiskServiceClient.highRiskPageData(searchData);
|
|
|
+ Response<GdbResponse> graphRes = graphServiceClient.highRiskPageData(searchData);
|
|
|
if (graphRes != null) {
|
|
|
Map<String, String> graphResult = graphRes.getData().getResult();
|
|
|
if (graphResult.size() > 0) {
|
|
@@ -444,27 +451,91 @@ public class PushFacade {
|
|
|
vitalDTO.add(questionDTO);
|
|
|
}
|
|
|
}
|
|
|
- /*if (deptVitalList.size() > 0) {
|
|
|
- Map<Long, DeptVital> deptVitalMap = EntityUtil.makeEntityMap(deptVitalList, "vitalId");
|
|
|
- //排序
|
|
|
- QueryWrapper<VitalOrder> vitalOrderQueryWrapper = new QueryWrapper<>();
|
|
|
- vitalOrderQueryWrapper.eq("is_deleted", IsDeleteEnum.N.getKey()).
|
|
|
- in("question_id", deptVitalMap.keySet()).
|
|
|
- orderByAsc("order_no");
|
|
|
- List<VitalOrder> vitalOrderList = vitalOrderFacade.list(vitalOrderQueryWrapper);
|
|
|
- Map<Long, VitalOrder> vitalOrderMap = EntityUtil.makeEntityMap(vitalOrderList, "questionId");
|
|
|
- //标签列表
|
|
|
- for (Map.Entry<Long, VitalOrder> entry : vitalOrderMap.entrySet()) {
|
|
|
- QuestionVO questionVO = new QuestionVO();
|
|
|
- questionVO.setAge(pushVO.getAge());
|
|
|
- questionVO.setSexType(pushVO.getSex());
|
|
|
- questionVO.setId(entry.getKey());
|
|
|
- QuestionDTO questionDTO = questionFacade.getById(questionVO);
|
|
|
- if (questionDTO != null) {
|
|
|
- vitalDTO.add(questionDTO);
|
|
|
+ return vitalDTO;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 电子病历评级-数据服务模式推理
|
|
|
+ *
|
|
|
+ * @param emrPushVO
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public PushEMRDTO pushEMR(EMRPushVO emrPushVO) {
|
|
|
+ Boolean isDocking = tranServiceClient.isDocking().data;
|
|
|
+ PushEMRDTO pushEMRDTO = new PushEMRDTO();
|
|
|
+ HosCodeVO hosCodeVO = new HosCodeVO();
|
|
|
+ hosCodeVO.setHosCode(emrPushVO.getHosCode());
|
|
|
+ PushVO pushVO = new PushVO();
|
|
|
+ BeanUtil.copyProperties(emrPushVO, pushVO);
|
|
|
+ //化验项转公表内容,参数处理
|
|
|
+ if (ListUtil.isNotEmpty(pushVO.getLis())) {
|
|
|
+ Map<String, Map<String, String>> lisConfigMap = new LinkedHashMap<>();
|
|
|
+ Map<String, String> lisConfigMap_emptyItemName = new LinkedHashMap<>();
|
|
|
+ if (isDocking) {
|
|
|
+ lisConfigMap = tranServiceClient.getLisConfigByHosCode_NotEmptyItemName(hosCodeVO).data;
|
|
|
+ lisConfigMap_emptyItemName = tranServiceClient.getLisConfigByHosCode_EmptyItemName(hosCodeVO).data;
|
|
|
+ } else {
|
|
|
+ lisConfigMap = lisMappingFacade.getLisMapping_NotEmptyItemName();
|
|
|
+ lisConfigMap_emptyItemName = lisMappingFacade.getLisConfig_EmptyItemName();
|
|
|
+ }
|
|
|
+ List<LisResultVO> lisResultVOList = pushVO.getLis();
|
|
|
+ for (LisResultVO lisResultVO : lisResultVOList) {
|
|
|
+ if (StringUtil.isNotBlank(lisResultVO.getName())) {
|
|
|
+ if (StringUtil.isNotBlank(lisResultVO.getDetailName())) {
|
|
|
+ lisResultVO.setUniqueName(lisConfigMap.get(lisResultVO.getName()).get(lisResultVO.getDetailName()));
|
|
|
+ } else {
|
|
|
+ lisResultVO.setUniqueName(lisConfigMap_emptyItemName.get(lisResultVO.getName()));
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
- }*/
|
|
|
- return vitalDTO;
|
|
|
+ pushVO.setLis(lisResultVOList);
|
|
|
+ }
|
|
|
+ ResponseData data = pushAI(pushVO);
|
|
|
+ String featureType = pushVO.getFeatureType();
|
|
|
+ String[] featureTypes = featureType.split(",|,");
|
|
|
+ Set<String> featureTypeSet = new HashSet(Arrays.asList(featureTypes));
|
|
|
+
|
|
|
+ if (featureTypeSet.contains(String.valueOf(QuestionTypeEnum.Lis.getKey()))) {
|
|
|
+ List<FeatureRate> labs = data.getLabs();
|
|
|
+ if (labs.size() > 0) {
|
|
|
+ List<String> lisList = labs.stream().map(lab -> lab.getFeatureName()).collect(Collectors.toList());
|
|
|
+ pushEMRDTO.setLisList(lisList);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (featureTypeSet.contains(String.valueOf(QuestionTypeEnum.Pacs.getKey()))) {
|
|
|
+ List<FeatureRate> pacsFeatures = data.getPacs();
|
|
|
+ if (pacsFeatures.size() > 0) {
|
|
|
+ List<String> pacsList = pacsFeatures.stream().map(pacs -> pacs.getFeatureName()).collect(Collectors.toList());
|
|
|
+ pushEMRDTO.setPacsList(pacsList);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (featureTypeSet.contains(String.valueOf(QuestionTypeEnum.Disease.getKey()))) {
|
|
|
+ List<FeatureRate> dis = data.getDis();
|
|
|
+ Map<String, List<String>> retDisMap = new LinkedHashMap<>();
|
|
|
+ Map<String, String> disMap = tranServiceClient.getDiseaseIcdByHosCode(hosCodeVO).data;
|
|
|
+
|
|
|
+ //诊断分类
|
|
|
+ for (FeatureRate featureRate : dis) {
|
|
|
+ if (StringUtil.isBlank(featureRate.getDesc())) {
|
|
|
+ featureRate.setDesc("{\"可能诊断\":\"\"}");
|
|
|
+ }
|
|
|
+ Map<String, Object> descMap = FastJsonUtils.getJsonToMap(featureRate.getDesc());
|
|
|
+ for (String disClass : descMap.keySet()) {
|
|
|
+ List<String> retDisList = Lists.newLinkedList();
|
|
|
+ if (retDisMap.get(disClass) != null) {
|
|
|
+ retDisList = retDisMap.get(disClass);
|
|
|
+ }
|
|
|
+ if (isDocking) {
|
|
|
+ //对接模式转icd10名称
|
|
|
+ retDisList.add(disMap.get(featureRate.getFeatureName()));
|
|
|
+ } else {
|
|
|
+ retDisList.add(featureRate.getFeatureName());
|
|
|
+ }
|
|
|
+ retDisMap.put(disClass, retDisList);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ pushEMRDTO.setDis(retDisMap);
|
|
|
+ }
|
|
|
+ return pushEMRDTO;
|
|
|
}
|
|
|
}
|