缓存配置优化

jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/medical/ruleengine/projectcache/HisMedicalProjectCache.java

@@ -2,6 +2,7 @@ package org.jeecg.modules.medical.ruleengine.projectcache;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import lombok.extern.slf4j.Slf4j;
 import org.jeecg.modules.medical.Constant;
 import org.jeecg.modules.medical.entity.DiagnoseItems;
 import org.jeecg.modules.medical.entity.MaterialItems;
@@ -22,6 +23,7 @@ import java.util.List;
 /**
  * 医保和医院项目编码映射
  */
+@Slf4j
 @Component
 public class HisMedicalProjectCache {
     @Autowired
@@ -36,10 +38,10 @@ public class HisMedicalProjectCache {
     IDiagnosesService diagnosesService;
 
     @PostConstruct
-    public void initHisMedicalProjectCache(){
+    public void initHisMedicalProjectCache() {
         long count = medicalInsuranceDrugsService.count();
 
-        if(count>0) {
+        if (count > 0) {
             long pageNum = count / 1000;
             long modNum = count % 1000;
             if (modNum > 0) {
@@ -49,13 +51,17 @@ public class HisMedicalProjectCache {
                 IPage page = new Page(i, 1000);
                 List<MedicalInsuranceDrugs> medicalInsuranceDrugsList = medicalInsuranceDrugsService.page(page).getRecords();
                 for (MedicalInsuranceDrugs medicalInsuranceDrugs : medicalInsuranceDrugsList) {
-                    redisTemplate.opsForHash().put(Constant.HIS_MEDICAL_DICT_KEY, medicalInsuranceDrugs.getItemIdHosp(), medicalInsuranceDrugs.getMedicineCode());
-                    redisTemplate.opsForHash().put(Constant.MEDICAL_CODE_NAME_KEY, medicalInsuranceDrugs.getMedicineCode(), medicalInsuranceDrugs.getMedicineName());
+                    try {
+                        redisTemplate.opsForHash().put(Constant.HIS_MEDICAL_DICT_KEY, medicalInsuranceDrugs.getItemIdHosp(), medicalInsuranceDrugs.getMedicineCode());
+                        redisTemplate.opsForHash().put(Constant.MEDICAL_CODE_NAME_KEY, medicalInsuranceDrugs.getMedicineCode(), medicalInsuranceDrugs.getMedicineName());
+                    } catch (Exception e) {
+                        log.error(e.getMessage(), e);
+                    }
                 }
             }
         }
         count = treatmentItemsService.count();
-        if(count>0) {
+        if (count > 0) {
             long pageNum = count / 1000;
             long modNum = count % 1000;
             if (modNum > 0) {
@@ -65,14 +71,19 @@ public class HisMedicalProjectCache {
                 IPage page = new Page(i, 1000);
                 List<TreatmentItems> treatmentItemsList = treatmentItemsService.page(page).getRecords();
                 for (TreatmentItems treatmentItems : treatmentItemsList) {
-                    redisTemplate.opsForHash().put(Constant.HIS_MEDICAL_DICT_KEY, treatmentItems.getItemIdHosp(), treatmentItems.getItemId());
-                    redisTemplate.opsForHash().put(Constant.MEDICAL_CODE_NAME_KEY, treatmentItems.getItemId(), treatmentItems.getItemName());
+                    try {
+                        redisTemplate.opsForHash().put(Constant.HIS_MEDICAL_DICT_KEY, treatmentItems.getItemIdHosp(), treatmentItems.getItemId());
+                        redisTemplate.opsForHash().put(Constant.MEDICAL_CODE_NAME_KEY, treatmentItems.getItemId(), treatmentItems.getItemName());
+                    } catch (Exception e) {
+                        log.error(e.getMessage(), e);
+                    }
                 }
+
             }
         }
 
         count = materialItemsService.count();
-        if(count>0) {
+        if (count > 0) {
             long pageNum = count / 1000;
             long modNum = count % 1000;
             if (modNum > 0) {
@@ -82,15 +93,19 @@ public class HisMedicalProjectCache {
                 IPage page = new Page(i, 1000);
                 List<MaterialItems> materialItemsList = materialItemsService.page(page).getRecords();
                 for (MaterialItems materialItem : materialItemsList) {
-                    redisTemplate.opsForHash().put(Constant.HIS_MEDICAL_DICT_KEY, materialItem.getItemIdHosp(), materialItem.getItemId());
-                    redisTemplate.opsForHash().put(Constant.MEDICAL_CODE_NAME_KEY, materialItem.getItemId(), materialItem.getItemName());
+                    try {
+                        redisTemplate.opsForHash().put(Constant.HIS_MEDICAL_DICT_KEY, materialItem.getItemIdHosp(), materialItem.getItemId());
+                        redisTemplate.opsForHash().put(Constant.MEDICAL_CODE_NAME_KEY, materialItem.getItemId(), materialItem.getItemName());
+                    } catch (Exception e) {
+                        log.error(e.getMessage(), e);
+                    }
                 }
             }
         }
 
 
         count = diagnosesService.count();
-        if(count>0) {
+        if (count > 0) {
             long pageNum = count / 1000;
             long modNum = count % 1000;
             if (modNum > 0) {
@@ -100,8 +115,12 @@ public class HisMedicalProjectCache {
                 IPage page = new Page(i, 1000);
                 List<DiagnoseItems> diagnoseItemsList = diagnosesService.page(page).getRecords();
                 for (DiagnoseItems diagnoseItems : diagnoseItemsList) {
-                    redisTemplate.opsForHash().put(Constant.HIS_MEDICAL_DICT_KEY, diagnoseItems.getDiagnoseCode(), diagnoseItems.getMedicalDiagnoseCode());
-                    redisTemplate.opsForHash().put(Constant.MEDICAL_CODE_NAME_KEY, diagnoseItems.getMedicalDiagnoseCode(), diagnoseItems.getMedicalDiagnoseName());
+                    try {
+                        redisTemplate.opsForHash().put(Constant.HIS_MEDICAL_DICT_KEY, diagnoseItems.getDiagnoseCode(), diagnoseItems.getMedicalDiagnoseCode());
+                        redisTemplate.opsForHash().put(Constant.MEDICAL_CODE_NAME_KEY, diagnoseItems.getMedicalDiagnoseCode(), diagnoseItems.getMedicalDiagnoseName());
+                    } catch (Exception e) {
+                        log.error(e.getMessage(), e);
+                    }
                 }
             }
         }