|
@@ -1,5 +1,6 @@
|
|
|
package com.diagbot.facade;
|
|
|
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.diagbot.biz.push.entity.Item;
|
|
|
import com.diagbot.client.PushNewServiceClient;
|
|
|
import com.diagbot.dto.PushBaseDTO;
|
|
@@ -7,13 +8,17 @@ import com.diagbot.dto.PushDTO;
|
|
|
import com.diagbot.dto.PushNewDTO;
|
|
|
import com.diagbot.dto.PushPlanDTO;
|
|
|
import com.diagbot.dto.WordCrfDTO;
|
|
|
+import com.diagbot.entity.KlDisease;
|
|
|
import com.diagbot.enums.DiagnoseTypeEnum;
|
|
|
+import com.diagbot.enums.DiseaseTypeEnum;
|
|
|
+import com.diagbot.enums.IsDeleteEnum;
|
|
|
import com.diagbot.enums.RedisEnum;
|
|
|
import com.diagbot.exception.CommonErrorCode;
|
|
|
import com.diagbot.exception.CommonException;
|
|
|
import com.diagbot.model.entity.Diag;
|
|
|
import com.diagbot.process.PushProcess;
|
|
|
import com.diagbot.util.AgeUtil;
|
|
|
+import com.diagbot.util.BeanUtil;
|
|
|
import com.diagbot.util.CoreUtil;
|
|
|
import com.diagbot.util.ListUtil;
|
|
|
import com.diagbot.util.ParamUtil;
|
|
@@ -24,10 +29,12 @@ import com.diagbot.vo.PushPlanVO;
|
|
|
import com.diagbot.vo.PushVO;
|
|
|
import com.google.common.collect.Lists;
|
|
|
import io.github.lvyahui8.spring.facade.DataFacade;
|
|
|
+import org.apache.ibatis.jdbc.Null;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
+import java.util.ArrayList;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.Iterator;
|
|
|
import java.util.LinkedHashMap;
|
|
@@ -58,6 +65,8 @@ public class PushFacade {
|
|
|
RedisUtil redisUtil;
|
|
|
@Value("${PushNew.url}")
|
|
|
String pushUrl;
|
|
|
+ @Autowired
|
|
|
+ private KlDiseaseFacade klDiseaseFacade;
|
|
|
|
|
|
/**
|
|
|
* 推送fac(兼容新版和5.0)
|
|
@@ -116,8 +125,48 @@ public class PushFacade {
|
|
|
// 2021/2/22 同老楼确认专科也走5.0
|
|
|
pushDTO = this.pushFacIcss(pushVo);
|
|
|
}*/
|
|
|
+ PushDTO pushDTOcopy = new PushDTO();
|
|
|
+ BeanUtil.copyProperties(pushDTO, pushDTOcopy);
|
|
|
+ if (pushDTOcopy.getDis() != null && pushDTOcopy.getDis().size() > 0) {
|
|
|
+ Map<String, List<PushBaseDTO>> dis = pushDTOcopy.getDis();
|
|
|
+ List<PushBaseDTO> identifys = dis.get(DiseaseTypeEnum.identify.getName());
|
|
|
+ if (identifys != null && identifys.size() > 0) {
|
|
|
+ for (PushBaseDTO pushBaseDTO : identifys) {
|
|
|
+ KlDisease disease = klDiseaseFacade.getOne(new QueryWrapper<KlDisease>()
|
|
|
+ .eq("is_deleted", IsDeleteEnum.N.getKey())
|
|
|
+ .eq("guoname", pushBaseDTO.getName()));
|
|
|
+ if (disease != null) {
|
|
|
+ pushBaseDTO.setCode(disease.getGuocode());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ List<PushBaseDTO> possibleDiss = dis.get(DiseaseTypeEnum.possibleDis.getName());
|
|
|
+ if (possibleDiss != null && possibleDiss.size() > 0) {
|
|
|
+ for (PushBaseDTO pushBaseDTO : possibleDiss) {
|
|
|
+ KlDisease disease = klDiseaseFacade.getOne(new QueryWrapper<KlDisease>()
|
|
|
+ .eq("is_deleted", IsDeleteEnum.N.getKey())
|
|
|
+ .eq("guoname", pushBaseDTO.getName()));
|
|
|
+ if (disease != null) {
|
|
|
+ pushBaseDTO.setCode(disease.getGuocode());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
- return pushDTO;
|
|
|
+ List<PushBaseDTO> highriskDiss = dis.get(DiseaseTypeEnum.highriskDis.getName());
|
|
|
+ if (highriskDiss != null && highriskDiss.size() > 0) {
|
|
|
+ for (PushBaseDTO pushBaseDTO : highriskDiss) {
|
|
|
+ KlDisease disease = klDiseaseFacade.getOne(new QueryWrapper<KlDisease>()
|
|
|
+ .eq("is_deleted", IsDeleteEnum.N.getKey())
|
|
|
+ .eq("guoname", pushBaseDTO.getName()));
|
|
|
+ if (disease != null) {
|
|
|
+ pushBaseDTO.setCode(disease.getGuocode());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ return pushDTOcopy;
|
|
|
}
|
|
|
|
|
|
/**
|