规则处理

src/main/java/com/diagbot/dto/BillNeoMaxDTO.java

@@ -13,8 +13,13 @@ import java.util.List;
 @Data
 public class BillNeoMaxDTO {
 
-    // 开单项目名称
-    private String name;
+    /****************扩展数据开始******************/
+    // 开单名称
+    private String orderName;
+
+    // 开单标准名称
+    private String orderStandName;
+    /****************扩展数据结束******************/
 
     // 禁忌性别
     private String gender;

src/main/java/com/diagbot/dto/WordCrfDTO.java

@@ -1,14 +1,21 @@
 package com.diagbot.dto;
 
+import com.diagbot.biz.push.entity.Item;
 import com.diagbot.biz.push.entity.Lis;
 import com.diagbot.biz.push.entity.Pacs;
-import com.diagbot.model.label.*;
+import com.diagbot.model.label.ChiefLabel;
+import com.diagbot.model.label.DiagLabel;
+import com.diagbot.model.label.FamilyLabel;
+import com.diagbot.model.label.MaritalLabel;
+import com.diagbot.model.label.MenstrualLabel;
+import com.diagbot.model.label.PastLabel;
+import com.diagbot.model.label.PersonalLabel;
+import com.diagbot.model.label.PresentLabel;
+import com.diagbot.model.label.VitalLabel;
 import lombok.Data;
 
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
 
 /**
  * crf 解析后各個模塊出參
@@ -24,8 +31,6 @@ public class WordCrfDTO {
     private Integer age;
     // 性别（1：男，2：女）
     private Integer sex;
-    // 标准词转换
-    Map<String, Map<String, String>> standConvertMap = new HashMap<>();
     // 化验项目和结果
     private List<Lis> lis = new ArrayList<>();
     // 辅检项目和结果
@@ -49,6 +54,16 @@ public class WordCrfDTO {
     // 诊断
     private DiagLabel diagLabel;
 
+    /*******************************************入参数据拷贝开始******************************/
+    // 当前化验开单项
+    private List<Lis> lisOrder = new ArrayList<>();
+    // 当前辅检开单项
+    private List<Pacs> pacsOrder = new ArrayList<>();
+    // 当前诊断开单项
+    private List<Item> diagOrder = new ArrayList<>();
+    // 当前药品开单项
+    private List<Item> drugOrder = new ArrayList<>();
+    /*******************************************入参数据拷贝结束******************************/
     // 化验
     // private LisLabel lisLabel;
     // 辅检

src/main/java/com/diagbot/entity/relationship/Medicine_AgeMin.java

@@ -1,27 +0,0 @@
-package com.diagbot.entity.relationship;
-
-import com.diagbot.entity.node.Medicine;
-import com.diagbot.entity.node.AgeMin;
-import lombok.Getter;
-import lombok.Setter;
-import org.neo4j.ogm.annotation.EndNode;
-import org.neo4j.ogm.annotation.RelationshipEntity;
-import org.neo4j.ogm.annotation.StartNode;
-
-/**
- * 关系-鉴别诊断
- *
- * @author Mark Huang
- */
-@Getter
-@Setter
-@RelationshipEntity(type="药品通用名禁忌年龄最小值")
-public class Medicine_AgeMin {
-
-    @StartNode
-    private Medicine medicine;
-
-    @EndNode
-    private AgeMin agemin;
-
-}

src/main/java/com/diagbot/entity/relationship/Medicine_Gender.java

@@ -1,27 +0,0 @@
-package com.diagbot.entity.relationship;
-
-import com.diagbot.entity.node.Medicine;
-import com.diagbot.entity.node.Gender;
-import lombok.Getter;
-import lombok.Setter;
-import org.neo4j.ogm.annotation.EndNode;
-import org.neo4j.ogm.annotation.RelationshipEntity;
-import org.neo4j.ogm.annotation.StartNode;
-
-/**
- * 关系-鉴别诊断
- *
- * @author Mark Huang
- */
-@Getter
-@Setter
-@RelationshipEntity(type="药品通用名禁忌性别")
-public class Medicine_Gender {
-
-    @StartNode
-    private Medicine medicine;
-
-    @EndNode
-    private Gender gender;
-
-}

src/main/java/com/diagbot/enums/StandConvertEnum.java

@@ -0,0 +1,57 @@
+package com.diagbot.enums;
+
+import com.diagbot.core.KeyedNamed;
+import lombok.Setter;
+
+/**
+ * @author zhoutg
+ * @Description: 标准词转换
+ * @date 2018年10月11日 下午3:33:22
+ */
+
+public enum StandConvertEnum implements KeyedNamed {
+
+    lis(1, "化验"),
+    pacs(2, "辅检"),
+    disease(3, "诊断"),
+    drug(4, "药品"),
+    clinical(5, "临床表现"),
+    operation(6, "手术");
+
+    @Setter
+    private int key;
+
+    @Setter
+    private String name;
+
+    StandConvertEnum(int key, String name) {
+        this.key = key;
+        this.name = name;
+    }
+
+    public static StandConvertEnum getEnum(int key) {
+        for (StandConvertEnum item : StandConvertEnum.values()) {
+            if (item.key == key) {
+                return item;
+            }
+        }
+        return null;
+    }
+
+    public static String getName(int key) {
+        StandConvertEnum item = getEnum(key);
+        return item != null ? item.name : null;
+    }
+
+    @Override
+    public int getKey() {
+        return key;
+    }
+
+    @Override
+    public String getName() {
+        return name;
+    }
+
+
+}

src/main/java/com/diagbot/facade/BillFacade.java

@@ -12,9 +12,7 @@ import com.diagbot.vo.IndicationPushVO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
 
 /**
  * @Description: 开单合理性facade
@@ -38,7 +36,7 @@ public class BillFacade {
      */
     public void billFac(IndicationPushVO indicationPushVO, WordCrfDTO wordCrfDTO, IndicationDTO res) {
         // 开单合理性图谱接口调用
-        BillNeoVO billNeoVO = fillBillNeo(indicationPushVO);
+        BillNeoVO billNeoVO = fillBillNeo(wordCrfDTO);
 
         List<BillNeoDTO> billNeoDTOList = neoFacade.getBillNeo(billNeoVO);
 
@@ -50,26 +48,26 @@ public class BillFacade {
     }
 
 
-    public BillNeoVO fillBillNeo(IndicationPushVO indicationPushVO) {
+    public BillNeoVO fillBillNeo(WordCrfDTO wordCrfDTO) {
         BillNeoVO billNeoVO = new BillNeoVO();
 
-        List<Item> items = indicationPushVO.getDrugOrder();
+        List<Item> items = wordCrfDTO.getDrugOrder();
 
         for (Item item : items) {
             billNeoVO.getDrugList().put(item.getName(), item.getUniqueName());
         }
 
-        List<Pacs> pacslist = indicationPushVO.getPacs();
+        List<Pacs> pacslist = wordCrfDTO.getPacsOrder();
         for (Pacs pacs : pacslist) {
             billNeoVO.getPacsList().put(pacs.getName(), pacs.getUniqueName());
         }
 
-        List<Lis> lislist = indicationPushVO.getLis();
+        List<Lis> lislist = wordCrfDTO.getLisOrder();
         for (Lis lis : lislist) {
             billNeoVO.getLisList().put(lis.getName(), lis.getUniqueName());
         }
 
-        List<Item> diags = indicationPushVO.getDiag();
+        List<Item> diags = wordCrfDTO.getDiagOrder();
         for (Item item : diags) {
             billNeoVO.getDiagList().put(item.getName(), item.getUniqueName());
         }

src/main/java/com/diagbot/facade/CommonFacade.java

@@ -2,6 +2,7 @@ package com.diagbot.facade;
 
 import com.diagbot.client.CRFServiceClient;
 import com.diagbot.dto.WordCrfDTO;
+import com.diagbot.enums.StandConvertEnum;
 import com.diagbot.model.ai.AIAnalyze;
 import com.diagbot.model.label.ChiefLabel;
 import com.diagbot.model.label.DiagLabel;
@@ -36,6 +37,9 @@ public class CommonFacade {
         wordCrfDTO.setSex(searchData.getSex());
         wordCrfDTO.setLis(searchData.getLis());
         wordCrfDTO.setPacs(searchData.getPacs());
+        wordCrfDTO.setLisOrder(searchData.getLisOrder());
+        wordCrfDTO.setPacsOrder(searchData.getPacsOrder());
+        wordCrfDTO.setDrugOrder(searchData.getDrugOrder());
         aiAnalyze.aiProcess(searchData, wordCrfDTO);
         return wordCrfDTO;
     }
@@ -66,10 +70,9 @@ public class CommonFacade {
     }
 
     //把图谱返回的标准词set到label中
-    public WordCrfDTO dataTypeSet(WordCrfDTO wordCrfDTO, Map<String, Map<String, String>> map){
+    public void dataTypeSet(WordCrfDTO wordCrfDTO, Map<Integer, Map<String, String>> map){
         ChiefLabel chiefLabel = wordCrfDTO.getChiefLabel();
-        CoreUtil.setPropertyList(chiefLabel.getClinicals(),map.get("clinicalList"));
-        return wordCrfDTO;
+        CoreUtil.setPropertyList(chiefLabel.getClinicals(),map.get(StandConvertEnum.clinical.getKey()));
     }
 
 }

src/main/java/com/diagbot/facade/IndicationFacade.java

@@ -39,9 +39,8 @@ public class IndicationFacade {
 
         // 标准词转换
         StandConvert standConvert = commonFacade.dataTypeGet(wordCrfDTO);
-        Map<String, Map<String, String>> standConvertMap = neoFacade.standConvert(standConvert);
-        wordCrfDTO = commonFacade.dataTypeSet(wordCrfDTO, standConvertMap);
-        wordCrfDTO.setStandConvertMap(standConvertMap);
+        Map<Integer, Map<String, String>> standConvertMap = neoFacade.standConvert(standConvert);
+        commonFacade.dataTypeSet(wordCrfDTO, standConvertMap);
 
         List<String> ruleTypeList = Arrays.asList(indicationPushVO.getRuleType().split(","));
 

src/main/java/com/diagbot/facade/NeoFacade.java

@@ -209,9 +209,9 @@ public class NeoFacade {
      *
      * @return  Map<String, Map<String, String>> -->Map<类型, Map<原始词, 标准词>>
      */
-    public Map<String, Map<String, String>> standConvert(StandConvert standConvert) {
+    public Map<Integer, Map<String, String>> standConvert(StandConvert standConvert) {
         // TODO 待处理业务
-        return null;
+        return new HashMap<>();
     }
 
 }

src/main/java/com/diagbot/facade/PushFacade.java

@@ -1,88 +1,79 @@
-package com.diagbot.facade;
-
-import com.diagbot.biz.push.entity.Item;
-import com.diagbot.dto.IndicationDTO;
-import com.diagbot.dto.BillNeoDTO;
-import com.diagbot.dto.WordCrfDTO;
-import com.diagbot.process.BillProcess;
-import com.diagbot.vo.BillNeoVO;
-import com.diagbot.vo.IndicationPushVO;
-import com.diagbot.vo.PushVO;
-import com.diagbot.vo.StandConvert;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import java.util.List;
-import java.util.Map;
-
-/**
- * @Description: 推送facade
- * @author: zhoutg
- * @time: 2018/8/6 9:11
- */
-@Component
-public class PushFacade {
-
-    @Autowired
-    NeoFacade neoFacade;
-    @Autowired
-    BillProcess billProcess;
-    @Autowired
-    CommonFacade commonFacade;
-
-    /**
-     * 开单合理性业务
-     * @param
-     * @return
-     */
-    public IndicationDTO billFac(IndicationPushVO indicationPushVO) {
-        // 模型处理数据 TODO
-        WordCrfDTO wordCrfDTO = commonFacade.crf_process(indicationPushVO);
-        StandConvert standConvert = commonFacade.dataTypeGet(wordCrfDTO);
-
-        // 标准词转换 TODO
-        Map<String, Map<String, String>> typeStand = neoFacade.standConvert(standConvert);
-        wordCrfDTO = commonFacade.dataTypeSet(wordCrfDTO, typeStand);
-
-        // 图谱接口调用
-        BillNeoVO billNeoVO = fillBillNeo(indicationPushVO);
-
-        List<BillNeoDTO> billNeoDTOs = neoFacade.getBillNeo(billNeoVO);
-
-        // 规则开发 TODO
-        neoFacade.getDrugCache();
-
-        // TODO
-        return null;
-    }
-
-    /**
-     * 推送业务
-     * @param
-     * @return
-     */
-    public IndicationDTO pushFac(PushVO pushVo) {
-        // 模型处理数据 TODO
-        WordCrfDTO wordCrfDTO = commonFacade.crf_process(pushVo);
-        StandConvert standConvert = commonFacade.dataTypeGet(wordCrfDTO);
-
-        // 标准词转换 TODO
-        Map<String, Map<String, String>> typeStand = neoFacade.standConvert(standConvert);
-        wordCrfDTO = commonFacade.dataTypeSet(wordCrfDTO, typeStand);
-
-        // TODO
-        return null;
-    }
-
-
-    public BillNeoVO fillBillNeo(IndicationPushVO indicationPushVO) {
-        BillNeoVO billNeoVO = new BillNeoVO();
-
-        List<Item> items = indicationPushVO.getDrug();
-        for (Item item : items) {
-            billNeoVO.getDrugList().put(item.getName(), item.getUniqueName());
-        }
-
-        return billNeoVO;
-    }
-}
+// package com.diagbot.facade;
+//
+// import com.diagbot.biz.push.entity.Item;
+// import com.diagbot.dto.IndicationDTO;
+// import com.diagbot.dto.BillNeoDTO;
+// import com.diagbot.dto.WordCrfDTO;
+// import com.diagbot.process.BillProcess;
+// import com.diagbot.vo.BillNeoVO;
+// import com.diagbot.vo.IndicationPushVO;
+// import com.diagbot.vo.PushVO;
+// import com.diagbot.vo.StandConvert;
+// import org.springframework.beans.factory.annotation.Autowired;
+// import org.springframework.stereotype.Component;
+//
+// import java.util.List;
+// import java.util.Map;
+//
+// /**
+//  * @Description: 推送facade
+//  * @author: zhoutg
+//  * @time: 2018/8/6 9:11
+//  */
+// @Component
+// public class PushFacade {
+//
+//     @Autowired
+//     NeoFacade neoFacade;
+//     @Autowired
+//     BillProcess billProcess;
+//     @Autowired
+//     CommonFacade commonFacade;
+//
+//     /**
+//      * 开单合理性业务
+//      * @param
+//      * @return
+//      */
+//     public IndicationDTO billFac(IndicationPushVO indicationPushVO) {
+//         // 模型处理数据 TODO
+//         WordCrfDTO wordCrfDTO = commonFacade.crf_process(indicationPushVO);
+//         StandConvert standConvert = commonFacade.dataTypeGet(wordCrfDTO);
+//
+//         // 标准词转换 TODO
+//         Map<Integer, Map<String, String>> typeStand = neoFacade.standConvert(standConvert);
+//         commonFacade.dataTypeSet(wordCrfDTO, typeStand);
+//
+//         // 图谱接口调用
+//         BillNeoVO billNeoVO = fillBillNeo(indicationPushVO);
+//
+//         List<BillNeoDTO> billNeoDTOs = neoFacade.getBillNeo(billNeoVO);
+//
+//         // 规则开发 TODO
+//         neoFacade.getDrugCache();
+//
+//         // TODO
+//         return null;
+//     }
+//
+//     /**
+//      * 推送业务
+//      * @param
+//      * @return
+//      */
+//     public IndicationDTO pushFac(PushVO pushVo) {
+//         return null;
+//     }
+//
+//
+//     public BillNeoVO fillBillNeo(IndicationPushVO indicationPushVO) {
+//         BillNeoVO billNeoVO = new BillNeoVO();
+//
+//         List<Item> items = indicationPushVO.getDrug();
+//         for (Item item : items) {
+//             billNeoVO.getDrugList().put(item.getName(), item.getUniqueName());
+//         }
+//
+//         return billNeoVO;
+//     }
+// }

src/main/java/com/diagbot/process/BillProcess.java

@@ -13,18 +13,14 @@ import com.diagbot.model.label.ChiefLabel;
 import com.diagbot.model.label.DiagLabel;
 import com.diagbot.model.label.PresentLabel;
 import com.diagbot.rule.AgeRule;
-import com.diagbot.rule.DiagRule;
 import com.diagbot.rule.SexRule;
 import com.diagbot.util.BeanUtil;
 import com.diagbot.util.CoreUtil;
 import com.diagbot.util.ListUtil;
 import org.springframework.stereotype.Component;
-
 import java.util.ArrayList;
 import java.util.List;
 
-// import java.math.BigDecimal;
-
 /**
  * @Description: 开单总入口
  * @author: zhoutg
@@ -45,7 +41,8 @@ public class BillProcess {
             } else if (billNeoDTO.getPacsBillNeoDTO() != null) {
                 BeanUtil.copyProperties(billNeoDTO.getPacsBillNeoDTO(), billNeoMaxDTO);
             }
-            billNeoMaxDTO.setName(billNeoDTO.getName());
+            billNeoMaxDTO.setOrderName(billNeoDTO.getName()); // 开单名称
+            billNeoMaxDTO.setOrderStandName(billNeoDTO.getStandname()); // 开单标准名称
             // 测试数据开始
             // billNeoMaxDTO.setGender("男");
             // billNeoMaxDTO.getAgeNeoDTO().setMax(new BigDecimal(30));
@@ -80,12 +77,12 @@ public class BillProcess {
         List<BillMsg> billMsgList = new ArrayList<>();
         for (BillNeoMaxDTO bill : billNeoMaxDTOList) {
             // 性别
-            BillMsg sexMsg = SexRule.compareSexWithBill(bill.getGender(), wordCrfDTO, bill.getName());
+            BillMsg sexMsg = SexRule.compareSexWithBill(bill.getGender(), wordCrfDTO, bill);
             CoreUtil.addBeanToList(billMsgList, sexMsg);
 
             // 诊断
-            BillMsg billMsg_disease = DiagRule.compareDiseaseWithBill(bill.getDisease(), diags, bill.getName());
-            CoreUtil.addBeanToList(billMsgList, billMsg_disease);
+            // BillMsg billMsg_disease = DiagRule.compareDiseaseWithBill(bill.getDisease(), diags, bill);
+            // CoreUtil.addBeanToList(billMsgList, billMsg_disease);
 
             // //化验
             // BillMsg lisMsg = LisPacsRule.compareLisPacsWithBill(drug.getLis(), lis, bill.getName());
@@ -100,7 +97,7 @@ public class BillProcess {
             // CoreUtil.addBeanToList(drugBill, clinicalMsg);
 
             // 年龄
-            BillMsg ageMsg = AgeRule.compareAgeWithBill(bill.getAgeNeoDTO(), wordCrfDTO, bill.getName());
+            BillMsg ageMsg = AgeRule.compareAgeWithBill(bill.getAgeNeoDTO(), wordCrfDTO, bill);
             CoreUtil.addBeanToList(billMsgList, ageMsg);
 
         }

src/main/java/com/diagbot/rule/AgeRule.java

@@ -1,12 +1,11 @@
 package com.diagbot.rule;
 
-import com.diagbot.dto.NodeNeoDTO;
 import com.diagbot.dto.BillMsg;
+import com.diagbot.dto.BillNeoMaxDTO;
+import com.diagbot.dto.NodeNeoDTO;
 import com.diagbot.dto.WordCrfDTO;
 import com.diagbot.util.CoreUtil;
 
-import java.math.BigDecimal;
-
 /**
  * @description: 年龄规则
  * @author: zhoutg
@@ -19,10 +18,10 @@ public class AgeRule {
      *
      * @param ageNeoDTO
      * @param wordCrfDTO
-     * @param name
+     * @param billNeoMaxDTO
      * @return
      */
-    public static BillMsg compareAgeWithBill(NodeNeoDTO ageNeoDTO, WordCrfDTO wordCrfDTO, String name) {
+    public static BillMsg compareAgeWithBill(NodeNeoDTO ageNeoDTO, WordCrfDTO wordCrfDTO, BillNeoMaxDTO billNeoMaxDTO) {
         Boolean flag = false;
         if (ageNeoDTO != null && wordCrfDTO.getAge() != null) {
             Integer age = wordCrfDTO.getAge();
@@ -40,7 +39,8 @@ public class AgeRule {
             }
         }
         if (flag) {
-            return CoreUtil.getCommonBillMsg(String.valueOf(wordCrfDTO.getAge() + "岁"), name);
+            return CoreUtil.getCommonBillMsg(billNeoMaxDTO.getOrderName(), billNeoMaxDTO.getOrderStandName(),
+                    String.valueOf(wordCrfDTO.getAge() + "岁"), String.valueOf(wordCrfDTO.getAge() + "岁"));
         }
         return null;
     }

src/main/java/com/diagbot/rule/SexRule.java

@@ -1,6 +1,7 @@
 package com.diagbot.rule;
 
 import com.diagbot.dto.BillMsg;
+import com.diagbot.dto.BillNeoMaxDTO;
 import com.diagbot.dto.WordCrfDTO;
 import com.diagbot.util.CoreUtil;
 import com.diagbot.util.StringUtil;
@@ -18,7 +19,7 @@ public class SexRule {
      * @param wordCrfDTO
      * @return
      */
-    public static BillMsg compareSexWithBill(String sex, WordCrfDTO wordCrfDTO, String name) {
+    public static BillMsg compareSexWithBill(String sex, WordCrfDTO wordCrfDTO, BillNeoMaxDTO billNeoMaxDTO) {
         if (StringUtil.isNotBlank(sex) && wordCrfDTO.getSex() != null) {
             String sexStr = "";
             if (1 == wordCrfDTO.getSex()) {
@@ -28,9 +29,11 @@ public class SexRule {
             }
             if (sex.equals(sexStr)) {
                 if ("男".equals(sexStr)) {
-                    return CoreUtil.getCommonBillMsg("男性", name);
+                    return CoreUtil.getCommonBillMsg(billNeoMaxDTO.getOrderName(), billNeoMaxDTO.getOrderStandName(),
+                            "男性", "男性");
                 } else if ("女".equals(sexStr)) {
-                    return CoreUtil.getCommonBillMsg("女性", name);
+                    return CoreUtil.getCommonBillMsg(billNeoMaxDTO.getOrderName(), billNeoMaxDTO.getOrderStandName(),
+                            "女性", "女性");
                 }
             }
         }

src/main/java/com/diagbot/util/CoreUtil.java

@@ -169,7 +169,6 @@ public class CoreUtil {
 
     }
 
-
     /**
      * 开单合理性通用提示信息
      *
@@ -184,6 +183,26 @@ public class CoreUtil {
         return billMsg;
     }
 
+    /**
+     * 开单合理性通用提示信息
+     *
+     * @param orderName 原开单项
+     * @param orderStandName 标准开单项
+     * @param compareName 匹配名称
+     * @param compareStandName 匹配标准名称
+     * @return
+     */
+    public static BillMsg getCommonBillMsg(String orderName, String orderStandName, String compareName, String compareStandName) {
+        BillMsg billMsg = new BillMsg();
+        String msg = String.format(compareName + ",不宜开%s", orderName);
+        billMsg.setMsg(msg);
+        billMsg.setCompareName(compareName);
+        billMsg.setCompareStandName(compareStandName);
+        billMsg.setOrderName(orderName);
+        billMsg.setOrderStandName(orderStandName);
+        return billMsg;
+    }
+
     /**
      * 开单合理性固定提示信息
      *

src/main/java/com/diagbot/web/CoreController.java

@@ -3,7 +3,6 @@ package com.diagbot.web;
 import com.diagbot.dto.IndicationDTO;
 import com.diagbot.dto.RespDTO;
 import com.diagbot.facade.IndicationFacade;
-import com.diagbot.facade.PushFacade;
 import com.diagbot.vo.IndicationPushVO;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -28,8 +27,8 @@ public class CoreController {
 
     @Autowired
     private IndicationFacade indicationFacade;
-    @Autowired
-    private PushFacade pushFacade;
+    // @Autowired
+    // private PushFacade pushFacade;
 
     @ApiOperation(value = "开单合理性API[zhoutg]", notes = "ruleType（1:危急值提醒，2：开单合理项，3：管理评估，4：不良反应，5：药物推荐，6：异常值）")
     @PostMapping("/indication")