多线程初始化后台数据

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

@@ -3,16 +3,13 @@ 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.apache.commons.lang.StringUtils;
 import org.jeecg.modules.medical.Constant;
 import org.jeecg.modules.medical.entity.DiagnoseItems;
-import org.jeecg.modules.medical.entity.Diagnoses;
 import org.jeecg.modules.medical.entity.MaterialItems;
 import org.jeecg.modules.medical.entity.MedicalInsuranceDrugs;
 import org.jeecg.modules.medical.entity.OperativeItems;
 import org.jeecg.modules.medical.entity.TreatmentItems;
 import org.jeecg.modules.medical.service.IDiagnoseItemsService;
-import org.jeecg.modules.medical.service.IDiagnosesService;
 import org.jeecg.modules.medical.service.IMaterialItemsService;
 import org.jeecg.modules.medical.service.IMedicalInsuranceDrugsService;
 import org.jeecg.modules.medical.service.IOperativeItemsService;
@@ -118,42 +115,42 @@ public class HisMedicalProjectCache {
     }
 
     @Async("commonTaskAsyncPool")
-    public void asyncSetDrugs(Integer pageIndex){
+    public void asyncSetDrugs(Integer pageIndex) {
         IPage page = new Page(pageIndex, 1000);
         List<MedicalInsuranceDrugs> medicalInsuranceDrugsList = medicalInsuranceDrugsService.lambdaQuery().isNotNull(MedicalInsuranceDrugs::getItemIdHosp).isNotNull(MedicalInsuranceDrugs::getMedicineCode).page(page).getRecords();
-        Map<String,String> itemIdHospAndCodeMap = new HashMap<>();
-        Map<String,String> medCodeAndNameMap = new HashMap<>();
+        Map<String, String> itemIdHospAndCodeMap = new HashMap<>();
+        Map<String, String> medCodeAndNameMap = new HashMap<>();
         try {
-        for (MedicalInsuranceDrugs medicalInsuranceDrugs : medicalInsuranceDrugsList) {
+            for (MedicalInsuranceDrugs medicalInsuranceDrugs : medicalInsuranceDrugsList) {
 
                 itemIdHospAndCodeMap.put(medicalInsuranceDrugs.getItemIdHosp(), medicalInsuranceDrugs.getMedicineCode());
                 medCodeAndNameMap.put(medicalInsuranceDrugs.getMedicineCode(), medicalInsuranceDrugs.getMedicineName());
 //                redisTemplate.opsForHash().put(Constant.HIS_MEDICAL_DICT_KEY, medicalInsuranceDrugs.getItemIdHosp(), medicalInsuranceDrugs.getMedicineCode());
 //                redisTemplate.opsForHash().put(Constant.MEDICAL_CODE_NAME_KEY, medicalInsuranceDrugs.getMedicineCode(), medicalInsuranceDrugs.getMedicineName());
 
-        }
-        redisTemplate.opsForHash().putAll(Constant.HIS_MEDICAL_DICT_KEY, itemIdHospAndCodeMap);
-        redisTemplate.opsForHash().putAll(Constant.MEDICAL_CODE_NAME_KEY, medCodeAndNameMap);
+            }
+            redisTemplate.opsForHash().putAll(Constant.HIS_MEDICAL_DICT_KEY, itemIdHospAndCodeMap);
+            redisTemplate.opsForHash().putAll(Constant.MEDICAL_CODE_NAME_KEY, medCodeAndNameMap);
         } catch (Exception e) {
             log.error(e.getMessage(), e);
         }
     }
 
     @Async("commonTaskAsyncPool")
-    public void asyncTreatmentItems(Integer pageIndex){
+    public void asyncTreatmentItems(Integer pageIndex) {
         IPage page = new Page(pageIndex, 1000);
         List<TreatmentItems> treatmentItemsList = treatmentItemsService.lambdaQuery().isNotNull(TreatmentItems::getItemIdHosp).isNotNull(TreatmentItems::getItemId).page(page).getRecords();
-        Map<String,String> itemIdHospAndCodeMap = new HashMap<>();
-        Map<String,String> medCodeAndNameMap = new HashMap<>();
+        Map<String, String> itemIdHospAndCodeMap = new HashMap<>();
+        Map<String, String> medCodeAndNameMap = new HashMap<>();
         try {
-        for (TreatmentItems treatmentItems : treatmentItemsList) {
+            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());
-            itemIdHospAndCodeMap.put(treatmentItems.getItemIdHosp(), treatmentItems.getItemId());
-            medCodeAndNameMap.put(treatmentItems.getItemId(), treatmentItems.getItemName());
+                itemIdHospAndCodeMap.put(treatmentItems.getItemIdHosp(), treatmentItems.getItemId());
+                medCodeAndNameMap.put(treatmentItems.getItemId(), treatmentItems.getItemName());
 
-        }
+            }
             redisTemplate.opsForHash().putAll(Constant.HIS_MEDICAL_DICT_KEY, itemIdHospAndCodeMap);
             redisTemplate.opsForHash().putAll(Constant.MEDICAL_CODE_NAME_KEY, medCodeAndNameMap);
         } catch (Exception e) {
@@ -162,20 +159,20 @@ public class HisMedicalProjectCache {
     }
 
     @Async("commonTaskAsyncPool")
-    public void asyncMaterialItems(Integer pageIndex){
+    public void asyncMaterialItems(Integer pageIndex) {
         IPage page = new Page(pageIndex, 1000);
         List<MaterialItems> materialItemsList = materialItemsService.lambdaQuery().isNotNull(MaterialItems::getItemIdHosp).isNotNull(MaterialItems::getItemId).page(page).getRecords();
 
-        Map<String,String> itemIdHospAndCodeMap = new HashMap<>();
-        Map<String,String> medCodeAndNameMap = new HashMap<>();
+        Map<String, String> itemIdHospAndCodeMap = new HashMap<>();
+        Map<String, String> medCodeAndNameMap = new HashMap<>();
         try {
-        for (MaterialItems materialItem : materialItemsList) {
+            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());
-            itemIdHospAndCodeMap.put(materialItem.getItemIdHosp(), materialItem.getItemId());
-            medCodeAndNameMap.put(materialItem.getItemId(), materialItem.getItemName());
-        }
+                itemIdHospAndCodeMap.put(materialItem.getItemIdHosp(), materialItem.getItemId());
+                medCodeAndNameMap.put(materialItem.getItemId(), materialItem.getItemName());
+            }
             redisTemplate.opsForHash().putAll(Constant.HIS_MEDICAL_DICT_KEY, itemIdHospAndCodeMap);
             redisTemplate.opsForHash().putAll(Constant.MEDICAL_CODE_NAME_KEY, medCodeAndNameMap);
         } catch (Exception e) {
@@ -184,20 +181,20 @@ public class HisMedicalProjectCache {
     }
 
     @Async("commonTaskAsyncPool")
-    public void asyncDiagnoseItems(Integer pageIndex){
+    public void asyncDiagnoseItems(Integer pageIndex) {
         IPage page = new Page(pageIndex, 1000);
         List<DiagnoseItems> diagnoseItemsList = diagnoseItemsService.lambdaQuery().isNotNull(DiagnoseItems::getDiagnoseCode).isNotNull(DiagnoseItems::getMedicalDiagnoseCode).page(page).getRecords();
-        Map<String,String> itemIdHospAndCodeMap = new HashMap<>();
-        Map<String,String> medCodeAndNameMap = new HashMap<>();
+        Map<String, String> itemIdHospAndCodeMap = new HashMap<>();
+        Map<String, String> medCodeAndNameMap = new HashMap<>();
         try {
-        for (DiagnoseItems diagnoseItems : diagnoseItemsList) {
+            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());
-            itemIdHospAndCodeMap.put(diagnoseItems.getDiagnoseCode(), diagnoseItems.getMedicalDiagnoseCode());
-            medCodeAndNameMap.put(diagnoseItems.getMedicalDiagnoseCode(), diagnoseItems.getMedicalDiagnoseName());
-        }
+                itemIdHospAndCodeMap.put(diagnoseItems.getDiagnoseCode(), diagnoseItems.getMedicalDiagnoseCode());
+                medCodeAndNameMap.put(diagnoseItems.getMedicalDiagnoseCode(), diagnoseItems.getMedicalDiagnoseName());
+            }
             redisTemplate.opsForHash().putAll(Constant.HIS_MEDICAL_DICT_KEY, itemIdHospAndCodeMap);
             redisTemplate.opsForHash().putAll(Constant.MEDICAL_CODE_NAME_KEY, medCodeAndNameMap);
         } catch (Exception e) {
@@ -206,21 +203,21 @@ public class HisMedicalProjectCache {
     }
 
     @Async("commonTaskAsyncPool")
-    public void asyncOperativeItems(Integer pageIndex){
+    public void asyncOperativeItems(Integer pageIndex) {
         IPage page = new Page(pageIndex, 1000);
         List<OperativeItems> operativeItemsList = operativeItemsService.lambdaQuery().isNotNull(OperativeItems::getOperativeCode).isNotNull(OperativeItems::getMedicalOperativeCode).page(page).getRecords();
-        Map<String,String> itemIdHospAndCodeMap = new HashMap<>();
-        Map<String,String> medCodeAndNameMap = new HashMap<>();
+        Map<String, String> itemIdHospAndCodeMap = new HashMap<>();
+        Map<String, String> medCodeAndNameMap = new HashMap<>();
         try {
-        for(OperativeItems operativeItem : operativeItemsList){
+            for (OperativeItems operativeItem : operativeItemsList) {
 
 
 //                redisTemplate.opsForHash().put(Constant.HIS_MEDICAL_DICT_KEY, operativeItem.getOperativeCode(), operativeItem.getMedicalOperativeCode());
 //                redisTemplate.opsForHash().put(Constant.MEDICAL_CODE_NAME_KEY, operativeItem.getMedicalOperativeCode(), operativeItem.getMedicalOperativeName());
-            itemIdHospAndCodeMap.put(operativeItem.getOperativeCode(), operativeItem.getMedicalOperativeCode());
-            medCodeAndNameMap.put(operativeItem.getMedicalOperativeCode(), operativeItem.getMedicalOperativeName());
+                itemIdHospAndCodeMap.put(operativeItem.getOperativeCode(), operativeItem.getMedicalOperativeCode());
+                medCodeAndNameMap.put(operativeItem.getMedicalOperativeCode(), operativeItem.getMedicalOperativeName());
 
-        }
+            }
             redisTemplate.opsForHash().putAll(Constant.HIS_MEDICAL_DICT_KEY, itemIdHospAndCodeMap);
             redisTemplate.opsForHash().putAll(Constant.MEDICAL_CODE_NAME_KEY, medCodeAndNameMap);
         } catch (Exception e) {