|
|
@@ -144,37 +144,37 @@ public class RuleEngine {
|
|
|
try {
|
|
|
|
|
|
MemeryPageUtil.batchDeal(medicalInsRuleInfoIdList, 1000, pageDataList -> {
|
|
|
- List<MedicalInsRuleProject> medicalInsRuleProjectList = medicalInsRuleProjectService.lambdaQuery().in(MedicalInsRuleProject::getMedicineInsRuleInfoId, pageDataList).list();
|
|
|
+ List<MedicalInsRuleProject> medicalInsRuleProjectList = medicalInsRuleProjectService.lambdaQuery().in(MedicalInsRuleProject::getMedicalInsRuleInfoId, pageDataList).list();
|
|
|
if (CollectionUtil.isNotEmpty(medicalInsRuleProjectList)) {
|
|
|
MedicalInsRuleProject medicalInsRuleProject = null;
|
|
|
for (int index = 0; index < medicalInsRuleProjectList.size(); index++) {
|
|
|
medicalInsRuleProject = medicalInsRuleProjectList.get(index);
|
|
|
if (StringUtils.isNotBlank(medicalInsRuleProject.getProjectCode())) {
|
|
|
if (itemCodeAndRuleIdMap.containsKey(medicalInsRuleProject.getProjectCode())) {
|
|
|
- itemCodeAndRuleIdMap.get(medicalInsRuleProject.getProjectCode()).add(medicalInsRuleProject.getMedicineInsRuleInfoId());
|
|
|
+ itemCodeAndRuleIdMap.get(medicalInsRuleProject.getProjectCode()).add(medicalInsRuleProject.getMedicalInsRuleInfoId());
|
|
|
} else {
|
|
|
Set<Integer> ruleIdSet = new HashSet<>();
|
|
|
- ruleIdSet.add(medicalInsRuleProject.getMedicineInsRuleInfoId());
|
|
|
+ ruleIdSet.add(medicalInsRuleProject.getMedicalInsRuleInfoId());
|
|
|
itemCodeAndRuleIdMap.put(medicalInsRuleProject.getProjectCode(), ruleIdSet);
|
|
|
}
|
|
|
}
|
|
|
if (StringUtils.isNotBlank(medicalInsRuleProject.getCorrelationProjectCode())) {
|
|
|
if (itemCodeAndRuleIdMap.containsKey(medicalInsRuleProject.getCorrelationProjectCode())) {
|
|
|
- itemCodeAndRuleIdMap.get(medicalInsRuleProject.getCorrelationProjectCode()).add(medicalInsRuleProject.getMedicineInsRuleInfoId());
|
|
|
+ itemCodeAndRuleIdMap.get(medicalInsRuleProject.getCorrelationProjectCode()).add(medicalInsRuleProject.getMedicalInsRuleInfoId());
|
|
|
} else {
|
|
|
Set<Integer> ruleIdSet = new HashSet<>();
|
|
|
- ruleIdSet.add(medicalInsRuleProject.getMedicineInsRuleInfoId());
|
|
|
+ ruleIdSet.add(medicalInsRuleProject.getMedicalInsRuleInfoId());
|
|
|
itemCodeAndRuleIdMap.put(medicalInsRuleProject.getCorrelationProjectCode(), ruleIdSet);
|
|
|
}
|
|
|
}
|
|
|
- List<MedicalInsRuleProjectDiagnose> medicalInsRuleProjectDiagnoseList = medicalInsRuleProjectDiagnoseService.lambdaQuery().eq(MedicalInsRuleProjectDiagnose::getMedicineInsRuleInfoId, medicalInsRuleProject.getMedicineInsRuleInfoId()).list();
|
|
|
+ List<MedicalInsRuleProjectDiagnose> medicalInsRuleProjectDiagnoseList = medicalInsRuleProjectDiagnoseService.lambdaQuery().eq(MedicalInsRuleProjectDiagnose::getMedicineInsRuleInfoId, medicalInsRuleProject.getMedicalInsRuleInfoId()).list();
|
|
|
if (CollectionUtil.isNotEmpty(medicalInsRuleProjectDiagnoseList)) {
|
|
|
for (MedicalInsRuleProjectDiagnose medicalInsRuleProjectDiagnose : medicalInsRuleProjectDiagnoseList) {
|
|
|
if (itemCodeAndRuleIdMap.containsKey(medicalInsRuleProjectDiagnose.getMedicalDiagnoseCode())) {
|
|
|
- itemCodeAndRuleIdMap.get(medicalInsRuleProjectDiagnose.getMedicalDiagnoseCode()).add(medicalInsRuleProject.getMedicineInsRuleInfoId());
|
|
|
+ itemCodeAndRuleIdMap.get(medicalInsRuleProjectDiagnose.getMedicalDiagnoseCode()).add(medicalInsRuleProject.getMedicalInsRuleInfoId());
|
|
|
} else {
|
|
|
Set<Integer> ruleIdSet = new HashSet<>();
|
|
|
- ruleIdSet.add(medicalInsRuleProject.getMedicineInsRuleInfoId());
|
|
|
+ ruleIdSet.add(medicalInsRuleProject.getMedicalInsRuleInfoId());
|
|
|
itemCodeAndRuleIdMap.put(medicalInsRuleProjectDiagnose.getMedicalDiagnoseCode(), ruleIdSet);
|
|
|
}
|
|
|
}
|
|
|
@@ -201,10 +201,10 @@ public class RuleEngine {
|
|
|
*/
|
|
|
public void setMIDProjectCodeToRedis(MedicalInsRuleProject medicalInsRuleProject) {
|
|
|
redisTemplate.opsForHash().put(Constant.MEDICAL_RULE_CACHE_KEY + "_" + Constant.TREATMEN_TYPE_MID_INCIDENT_WARNING,
|
|
|
- medicalInsRuleProject.getProjectCode(), medicalInsRuleProject.getMedicineInsRuleInfoId());
|
|
|
+ medicalInsRuleProject.getProjectCode(), medicalInsRuleProject.getMedicalInsRuleInfoId());
|
|
|
if (StringUtils.isNotBlank(medicalInsRuleProject.getCorrelationProjectCode())) {
|
|
|
redisTemplate.opsForHash().put(Constant.MEDICAL_RULE_CACHE_KEY + "_" + Constant.TREATMEN_TYPE_MID_INCIDENT_WARNING,
|
|
|
- medicalInsRuleProject.getCorrelationProjectCode(), medicalInsRuleProject.getMedicineInsRuleInfoId());
|
|
|
+ medicalInsRuleProject.getCorrelationProjectCode(), medicalInsRuleProject.getMedicalInsRuleInfoId());
|
|
|
}
|
|
|
}
|
|
|
|