|
|
@@ -7,6 +7,8 @@ import com.diagbot.dto.RuleConditionInitDTO;
|
|
|
import com.diagbot.dto.RuleDTO;
|
|
|
import com.diagbot.dto.RuleInitDTO;
|
|
|
import com.diagbot.enums.RedisEnum;
|
|
|
+import com.diagbot.exception.CommonErrorCode;
|
|
|
+import com.diagbot.exception.CommonException;
|
|
|
import com.diagbot.facade.KlRuleFacade;
|
|
|
import com.diagbot.util.BeanUtil;
|
|
|
import com.diagbot.util.EntityUtil;
|
|
|
@@ -18,6 +20,7 @@ import org.apache.commons.collections.MapUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
+import java.util.ArrayList;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
@@ -37,51 +40,75 @@ public class RuleAggregate {
|
|
|
public Map<String, RuleDTO> getAllRules(
|
|
|
@DataConsumer("getRuleInit") Map<String, List<RuleInitDTO>> ruleInits,
|
|
|
@DataConsumer("getRuleConditionInit") Map<Integer, Map<String, List<RuleConditionInitDTO>>> ruleConditionInits,
|
|
|
- @DataConsumer("getRuleBaseInit") Map<Integer, RuleBaseInitDTO> ruleBaseInits) {
|
|
|
- Map<String, RuleDTO> res = new HashMap();
|
|
|
- //结果判空第一层规则类型
|
|
|
- if (MapUtils.isNotEmpty(ruleInits)) {
|
|
|
- for (String ruleKey : ruleInits.keySet()) {
|
|
|
- RuleInitDTO ruleInitZeroDTO = ruleInits.get(ruleKey).get(0);
|
|
|
- RuleDTO ruleDTO = new RuleDTO();
|
|
|
- ruleDTO.setLibName(ruleInitZeroDTO.getLibName());
|
|
|
- ruleDTO.setLibType(ruleInitZeroDTO.getLibType());
|
|
|
- ruleDTO.setRuleType(ruleInitZeroDTO.getRuleType());
|
|
|
- for (RuleInitDTO ruleInitDTO : ruleInits.get(ruleKey)) {
|
|
|
- if (ruleInitDTO.getHasSubCond().equals(1)) {
|
|
|
- Map<String, List<RuleConditionInitDTO>> map = ruleConditionInits.get(ruleInitDTO.getRuleId());
|
|
|
- //结果判空第二层条件组别
|
|
|
- if (MapUtils.isNotEmpty(map)) {
|
|
|
- for (String key : map.keySet()) {
|
|
|
- RuleConditionDTO ruleConditionDTO = new RuleConditionDTO();
|
|
|
- ruleConditionDTO.setHasSubCond(ruleInitDTO.getHasSubCond());
|
|
|
- ruleConditionDTO.setRuleGroup(key);
|
|
|
- //结果判空第三层条件明细
|
|
|
- if (ListUtil.isNotEmpty(map.get(key))) {
|
|
|
- for (RuleConditionInitDTO ruleConditionInitDTO : map.get(key)) {
|
|
|
- ruleConditionDTO.setMsg(ruleConditionInitDTO.getMsg());
|
|
|
- RuleBaseDTO ruleBaseDTO = new RuleBaseDTO();
|
|
|
- BeanUtil.copyProperties(ruleBaseInits.get(ruleConditionInitDTO.getRuleBaseId()), ruleBaseDTO);
|
|
|
- ruleConditionDTO.getRuleBaseDTOList().add(ruleBaseDTO);
|
|
|
+ @DataConsumer("getRuleBaseInit") Map<Integer, List<RuleBaseInitDTO>> ruleBaseInits) {
|
|
|
+ try {
|
|
|
+ Map<String, RuleDTO> res = new HashMap();
|
|
|
+ //结果判空第一层规则类型
|
|
|
+ if (MapUtils.isNotEmpty(ruleInits)) {
|
|
|
+ for (String ruleKey : ruleInits.keySet()) {
|
|
|
+ RuleInitDTO ruleInitZeroDTO = ruleInits.get(ruleKey).get(0);
|
|
|
+ RuleDTO ruleDTO = new RuleDTO();
|
|
|
+ ruleDTO.setLibName(ruleInitZeroDTO.getLibName());
|
|
|
+ ruleDTO.setLibType(ruleInitZeroDTO.getLibType());
|
|
|
+ ruleDTO.setRuleType(ruleInitZeroDTO.getRuleType());
|
|
|
+ Map<String, Integer> ruleConditionMap = new HashMap<>();
|
|
|
+ for (RuleInitDTO ruleInitDTO : ruleInits.get(ruleKey)) {
|
|
|
+ if (ruleInitDTO.getHasSubCond().equals(1)) {
|
|
|
+ Map<String, List<RuleConditionInitDTO>> map = ruleConditionInits.get(ruleInitDTO.getRuleId());
|
|
|
+ //结果判空第二层条件组别
|
|
|
+ if (MapUtils.isNotEmpty(map)) {
|
|
|
+ for (String ruleGroup : map.keySet()) {
|
|
|
+ RuleConditionDTO ruleConditionDTO = new RuleConditionDTO();
|
|
|
+ ruleConditionDTO.setHasSubCond(ruleInitDTO.getHasSubCond());
|
|
|
+ ruleConditionDTO.setRuleGroup(ruleGroup);
|
|
|
+ //结果判空第三层条件明细
|
|
|
+ if (ListUtil.isNotEmpty(map.get(ruleGroup))) {
|
|
|
+ List<List<RuleBaseDTO>> ruleBaseList = new ArrayList<>();
|
|
|
+ for (RuleConditionInitDTO ruleConditionInitDTO : map.get(ruleGroup)) {
|
|
|
+ ruleConditionDTO.setMsg(ruleConditionInitDTO.getMsg());
|
|
|
+ List<RuleBaseInitDTO> ruleBaseInitDTOList = ruleBaseInits.get(ruleConditionInitDTO.getRuleBaseId());
|
|
|
+ if (ListUtil.isNotEmpty(ruleBaseInitDTOList)) {
|
|
|
+ List<RuleBaseDTO> ruleBaseDTOList = BeanUtil.listCopyTo(ruleBaseInitDTOList, RuleBaseDTO.class);
|
|
|
+ ruleBaseList.add(ruleBaseDTOList);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //笛卡尔积
|
|
|
+ List<List<RuleBaseDTO>> ruleBaseGroup = new ArrayList<>();
|
|
|
+ descartes(ruleBaseList, ruleBaseGroup, 0, new ArrayList<>());
|
|
|
+ for (List<RuleBaseDTO> ruleBaseDTOList : ruleBaseGroup) {
|
|
|
+ RuleConditionDTO ruleConditionDTO1 = new RuleConditionDTO();
|
|
|
+ ruleConditionDTO1.setHasSubCond(ruleConditionDTO.getHasSubCond());
|
|
|
+ ruleConditionDTO1.setRuleGroup(ruleConditionDTO.getRuleGroup());
|
|
|
+ ruleConditionDTO1.setMsg(ruleConditionDTO.getMsg());
|
|
|
+ ruleConditionDTO1.getRuleBaseDTOList().addAll(ruleBaseDTOList);
|
|
|
+ if (!ruleConditionMap.containsKey(ruleConditionDTO1.toString())) {
|
|
|
+ ruleDTO.getRuleConditionDTOList().add(ruleConditionDTO1);
|
|
|
+ ruleConditionMap.put(ruleConditionDTO1.toString(), 1);
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ RuleConditionDTO ruleConditionDTO = new RuleConditionDTO();
|
|
|
+ ruleConditionDTO.setHasSubCond(ruleInitDTO.getHasSubCond());
|
|
|
+ ruleConditionDTO.setMsg(ruleInitDTO.getMsg());
|
|
|
+ //无条件
|
|
|
+ ruleConditionDTO.setRuleGroup(ruleInitDTO.getRuleId() + "-1");
|
|
|
+ ruleConditionDTO.getRuleBaseDTOList().add(new RuleBaseDTO());
|
|
|
+ if (!ruleConditionMap.containsKey(ruleConditionDTO.toString())) {
|
|
|
ruleDTO.getRuleConditionDTOList().add(ruleConditionDTO);
|
|
|
+ ruleConditionMap.put(ruleConditionDTO.toString(), 1);
|
|
|
}
|
|
|
}
|
|
|
- } else {
|
|
|
- RuleConditionDTO ruleConditionDTO = new RuleConditionDTO();
|
|
|
- ruleConditionDTO.setHasSubCond(ruleInitDTO.getHasSubCond());
|
|
|
- ruleConditionDTO.setMsg(ruleInitDTO.getMsg());
|
|
|
- //无条件
|
|
|
- ruleConditionDTO.setRuleGroup(ruleInitDTO.getRuleId() + "-1");
|
|
|
- ruleConditionDTO.getRuleBaseDTOList().add(new RuleBaseDTO());
|
|
|
- ruleDTO.getRuleConditionDTOList().add(ruleConditionDTO);
|
|
|
}
|
|
|
+ res.put(RedisEnum.allRule.getName() + ruleDTO.getLibType() + "_" + ruleDTO.getLibName() + "_" + ruleDTO.getRuleType(), ruleDTO);
|
|
|
}
|
|
|
- res.put(RedisEnum.allRule.getName() + ruleDTO.getLibType() + "_" + ruleDTO.getLibName() + "_" + ruleDTO.getRuleType(), ruleDTO);
|
|
|
}
|
|
|
+ return res;
|
|
|
+ } catch (Exception e) {
|
|
|
+ throw new CommonException(CommonErrorCode.SERVER_IS_ERROR, "全部规则加载出错:" + e.getMessage());
|
|
|
}
|
|
|
- return res;
|
|
|
}
|
|
|
|
|
|
@DataProvider("getRuleInit")
|
|
|
@@ -90,21 +117,126 @@ public class RuleAggregate {
|
|
|
return EntityUtil.makeEntityListMap(list, "conceptGroup");
|
|
|
}
|
|
|
|
|
|
+ // @DataProvider("getRuleInit")
|
|
|
+ // public Map<String, List<RuleInitDTO>> getRuleInit(
|
|
|
+ // @DataConsumer("getRuleInitNotHaveClass") List<RuleInitDTO> ruleNotHaveClass,
|
|
|
+ // @DataConsumer("getRuleInitHaveClass") List<RuleInitDTO> ruleHaveClass) {
|
|
|
+ // List<RuleInitDTO> list = new ArrayList<>();
|
|
|
+ // if (ListUtil.isNotEmpty(ruleNotHaveClass)) {
|
|
|
+ // list.addAll(ruleNotHaveClass);
|
|
|
+ // }
|
|
|
+ // if (ListUtil.isNotEmpty(ruleHaveClass)) {
|
|
|
+ // list.addAll(ruleHaveClass);
|
|
|
+ // }
|
|
|
+ // return EntityUtil.makeEntityListMap(list, "conceptGroup");
|
|
|
+ // }
|
|
|
+
|
|
|
@DataProvider("getRuleConditionInit")
|
|
|
public Map<Integer, Map<String, List<RuleConditionInitDTO>>> getRuleConditionInit() {
|
|
|
List<RuleConditionInitDTO> list = klRuleFacade.getRuleConditionInitDTO();
|
|
|
Map<Integer, List<RuleConditionInitDTO>> map = EntityUtil.makeEntityListMap(list, "ruleId");
|
|
|
Map<Integer, Map<String, List<RuleConditionInitDTO>>> res = new HashMap<>();
|
|
|
- for (Integer key : map.keySet()) {
|
|
|
- res.put(key, EntityUtil.makeEntityListMap(map.get(key), "ruleGroup"));
|
|
|
+ for (Integer ruleId : map.keySet()) {
|
|
|
+ res.put(ruleId, EntityUtil.makeEntityListMap(map.get(ruleId), "ruleGroup"));
|
|
|
}
|
|
|
return res;
|
|
|
}
|
|
|
|
|
|
-
|
|
|
@DataProvider("getRuleBaseInit")
|
|
|
- public Map<Integer, RuleBaseInitDTO> getRuleBaseInit() {
|
|
|
- List<RuleBaseInitDTO> list = klRuleFacade.getRuleBaseInitDTO();
|
|
|
- return EntityUtil.makeEntityMap(list, "ruleBaseId");
|
|
|
+ public Map<Integer, List<RuleBaseInitDTO>> getRuleBaseInit(
|
|
|
+ @DataConsumer("getRuleBaseInitNotHaveClass") List<RuleBaseInitDTO> ruleBaseNotHaveClass,
|
|
|
+ @DataConsumer("getRuleBaseInitHaveClass") List<RuleBaseInitDTO> ruleBaseHaveClass) {
|
|
|
+ List<RuleBaseInitDTO> list = new ArrayList<>();
|
|
|
+ if (ListUtil.isNotEmpty(ruleBaseNotHaveClass)) {
|
|
|
+ list.addAll(ruleBaseNotHaveClass);
|
|
|
+ }
|
|
|
+ if (ListUtil.isNotEmpty(ruleBaseHaveClass)) {
|
|
|
+ list.addAll(ruleBaseHaveClass);
|
|
|
+ }
|
|
|
+ return EntityUtil.makeEntityListMap(list, "ruleBaseId");
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ @DataProvider("getRuleInitNotHaveClass")
|
|
|
+ public List<RuleInitDTO> getRuleInitNotHaveClass() {
|
|
|
+ return klRuleFacade.getRuleInitDTONotHaveClass();
|
|
|
+ }
|
|
|
+
|
|
|
+ @DataProvider("getRuleInitHaveClass")
|
|
|
+ public List<RuleInitDTO> getRuleInitHaveClass() {
|
|
|
+ return klRuleFacade.getRuleInitDTOHaveClass();
|
|
|
+ }
|
|
|
+
|
|
|
+ @DataProvider("getRuleBaseInitNotHaveClass")
|
|
|
+ public List<RuleBaseInitDTO> getRuleBaseInitNotHaveClass() {
|
|
|
+ return klRuleFacade.getRuleBaseInitDTONotHaveClass();
|
|
|
}
|
|
|
+
|
|
|
+ @DataProvider("getRuleBaseInitHaveClass")
|
|
|
+ public List<RuleBaseInitDTO> getRuleBaseInitHaveClass() {
|
|
|
+ return klRuleFacade.getRuleBaseInitDTOHaveClass();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Discription: 笛卡尔乘积算法
|
|
|
+ * 把一个List{[1,2],[A,B],[a,b]} 转化成
|
|
|
+ * List{[1,A,a],[1,A,b],[1,B,a],[1,B,b],[2,A,a],[2,A,b],[2,B,a],[2,B,b]} 数组输出
|
|
|
+ *
|
|
|
+ * @param dimensionValue 原List
|
|
|
+ * @param result 通过乘积转化后的数组
|
|
|
+ * @param layer 中间参数
|
|
|
+ * @param currentList 中间参数
|
|
|
+ */
|
|
|
+ public static <T> void descartes(List<List<T>> dimensionValue, List<List<T>> result, int layer, List<T> currentList) {
|
|
|
+ if (layer < dimensionValue.size() - 1) {
|
|
|
+ if (dimensionValue.get(layer).size() == 0) {
|
|
|
+ descartes(dimensionValue, result, layer + 1, currentList);
|
|
|
+ } else {
|
|
|
+ for (int i = 0; i < dimensionValue.get(layer).size(); i++) {
|
|
|
+ List<T> list = new ArrayList<T>(currentList);
|
|
|
+ list.add(dimensionValue.get(layer).get(i));
|
|
|
+ descartes(dimensionValue, result, layer + 1, list);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else if (layer == dimensionValue.size() - 1) {
|
|
|
+ if (dimensionValue.get(layer).size() == 0) {
|
|
|
+ result.add(currentList);
|
|
|
+ } else {
|
|
|
+ for (int i = 0; i < dimensionValue.get(layer).size(); i++) {
|
|
|
+ List<T> list = new ArrayList<T>(currentList);
|
|
|
+ list.add(dimensionValue.get(layer).get(i));
|
|
|
+ result.add(list);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public static void main(String[] args) {
|
|
|
+ List<List<RuleBaseDTO>> ruleBaseList = new ArrayList<>();
|
|
|
+ List<RuleBaseDTO> ruleBaseDTOListA = new ArrayList<>();
|
|
|
+ RuleBaseDTO baseDTOA = new RuleBaseDTO();
|
|
|
+ baseDTOA.setBaseLibName("A");
|
|
|
+ ruleBaseDTOListA.add(baseDTOA);
|
|
|
+ RuleBaseDTO baseDTOB = new RuleBaseDTO();
|
|
|
+ baseDTOB.setBaseLibName("B");
|
|
|
+ ruleBaseDTOListA.add(baseDTOB);
|
|
|
+ List<RuleBaseDTO> ruleBaseDTOListC = BeanUtil.listCopyTo(ruleBaseDTOListA, RuleBaseDTO.class);
|
|
|
+ ruleBaseList.add(ruleBaseDTOListC);
|
|
|
+ RuleBaseDTO baseDTOC = new RuleBaseDTO();
|
|
|
+ baseDTOC.setBaseLibName("C");
|
|
|
+ ruleBaseDTOListA.add(baseDTOC);
|
|
|
+ ruleBaseList.add(ruleBaseDTOListA);
|
|
|
+ List<RuleBaseDTO> ruleBaseDTOList1 = new ArrayList<>();
|
|
|
+ RuleBaseDTO baseDTO1 = new RuleBaseDTO();
|
|
|
+ baseDTO1.setBaseLibName("1");
|
|
|
+ ruleBaseDTOList1.add(baseDTO1);
|
|
|
+ RuleBaseDTO baseDTO2 = new RuleBaseDTO();
|
|
|
+ baseDTO2.setBaseLibName("2");
|
|
|
+ ruleBaseDTOList1.add(baseDTO2);
|
|
|
+ ruleBaseList.add(ruleBaseDTOList1);
|
|
|
+ List<List<RuleBaseDTO>> ruleBaseGroup = new ArrayList<>();
|
|
|
+ descartes(ruleBaseList, ruleBaseGroup, 0, new ArrayList<>());
|
|
|
+ System.out.println();
|
|
|
+ }
|
|
|
+
|
|
|
}
|
liuqq