|
|
@@ -1,10 +1,13 @@
|
|
|
package org.jeecg.modules.medical.ruleengine.plugin;
|
|
|
|
|
|
+import cn.hutool.core.collection.CollectionUtil;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.jeecg.common.util.dynamic.db.DynamicDBUtil;
|
|
|
import org.jeecg.modules.medical.Constant;
|
|
|
+import org.jeecg.modules.medical.entity.EventAttr;
|
|
|
import org.jeecg.modules.medical.entity.FactorAttrRela;
|
|
|
import org.jeecg.modules.medical.entity.FactorEnchance;
|
|
|
+import org.jeecg.modules.medical.ruleengine.FactorEnchangeFactory;
|
|
|
import org.jeecg.modules.medical.ruleengine.PluginInterface;
|
|
|
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
@@ -19,7 +22,18 @@ public class AfterStaticisPlugin implements PluginInterface {
|
|
|
@Override
|
|
|
public void plugin(Map<String, Object> localMap, Map<Integer, List<FactorAttrRela>> ioTypeMap, FactorEnchance factorEnchance, Integer medicalInsRuleInfoId) {
|
|
|
NamedParameterJdbcTemplate namedParameterJdbcTemplate = DynamicDBUtil.getNamedParameterJdbcTemplate(Constant.LOCAL_MYSQL);
|
|
|
- int updateCount = namedParameterJdbcTemplate.update(factorEnchance.getEnhanceValue(), localMap);
|
|
|
+ List<FactorAttrRela> factorAttrRelaList = ioTypeMap.get(Constant.INPUT);
|
|
|
+ if(CollectionUtil.isEmpty(factorAttrRelaList)){
|
|
|
+ log.error("要素提取:{} 未配置入参", factorEnchance);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ String ehName = FactorEnchangeFactory.getParamName(factorAttrRelaList.get(0).getEventAttrId());
|
|
|
+ Object paramSql = localMap.get(ehName);
|
|
|
+ if(null == paramSql){
|
|
|
+ log.error("要素提取:{} 插件未获取到sql配置", factorEnchance);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ int updateCount = namedParameterJdbcTemplate.update(paramSql.toString(), localMap);
|
|
|
if (updateCount <= 0) {
|
|
|
log.error("要素提取:{} 执行插件sql失败", factorEnchance);
|
|
|
}
|