Bladeren bron

后台同步数据处理

0027005599 2 jaren geleden
bovenliggende
commit
320c27a6ff

+ 9 - 0
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/job/XCFYDatav_master_admission_billJob.java

@@ -58,6 +58,15 @@ public class XCFYDatav_master_admission_billJob implements Job {
                             dataMap.put("YB_ADMISSION_DISEASE_NAME", ybDiagCode[1]);
                         }
                     }
+
+                    String disDiagCode = dataMap.getOrDefault("DISCHARGE_DISEASE_ID_MAIN", "").toString();
+                    if(StringUtils.isNotBlank(disDiagCode)){
+                        String[] ybDiagCode = CommonUtil.getMedicalCodeAndName(disDiagCode);
+                        if (null != ybDiagCode) {
+                            dataMap.put("YB_DISCHARGE_DISEASE_ID_MAIN", ybDiagCode[0]);
+                            dataMap.put("YB_DISCHARGE_DISEASE_NAME_MAIN", ybDiagCode[1]);
+                        }
+                    }
                     dataMap.put("CREATE_BY", "auto");
                     dataMap.put("CREATE_TIME", new Date());
                 }

+ 8 - 0
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/system/controller/SysDictController.java

@@ -20,6 +20,8 @@ import org.jeecg.common.system.vo.DictQuery;
 import org.jeecg.common.system.vo.LoginUser;
 import org.jeecg.common.util.*;
 import org.jeecg.config.mybatis.MybatisPlusSaasConfig;
+import org.jeecg.modules.medical.ruleengine.FactorEnchangeFactory;
+import org.jeecg.modules.medical.ruleengine.RuleEngine;
 import org.jeecg.modules.medical.ruleengine.projectcache.HisMedicalProjectCache;
 import org.jeecg.modules.system.entity.SysDict;
 import org.jeecg.modules.system.entity.SysDictItem;
@@ -74,6 +76,10 @@ public class SysDictController {
 	private RedisUtil redisUtil;
 	@Autowired
 	private  HisMedicalProjectCache hisMedicalProjectCache;
+	@Autowired
+	private RuleEngine ruleEngine;
+	@Autowired
+	private FactorEnchangeFactory factorEnchangeFactory;
 
 	@RequestMapping(value = "/list", method = RequestMethod.GET)
 	public Result<IPage<SysDict>> queryPageList(SysDict sysDict,@RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
@@ -495,6 +501,8 @@ public class SysDictController {
 	public Result<?> refleshHisCache() {
 		Result<?> result = new Result<SysDict>();
 		hisMedicalProjectCache.initHisMedicalProjectCache();
+		ruleEngine.initMedicalInsRule();
+		factorEnchangeFactory.init();
 		return result;
 	}