✨ config

cas-common/pom.xml

@@ -228,6 +228,11 @@
             <artifactId>easy-es-boot-starter</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.ehcache</groupId>
+            <artifactId>ehcache</artifactId>
+            <version>3.9.9</version>
+        </dependency>
     </dependencies>
 
 </project>

cas-system/src/main/java/com/inscloudtech/bankStatementAnalysis/helper/EsIndexHelper.java

@@ -429,27 +429,16 @@ public class EsIndexHelper {
     }
 
     public void delFDBIndex(String caseId) {
-        if (fdbStatementMapper.existsIndex(Constants.ES_INDEX_NAME_FDB_STATEMENT)) {
         fdbStatementMapper.deleteIndex(Constants.ES_INDEX_NAME_FDB_STATEMENT);
-//            queryCenterService.deleteData(Constants.ES_INDEX_NAME_FDB_STATEMENT,caseId);
-        }else {
-            fdbStatementMapper.createIndex();
-        }
-
-        if (fdbPrivateAccountOpeningInfoMapper.existsIndex(Constants.ES_INDEX_NAME_FDB_OPENING_ACCOUNT_PRIVATE)) {
         fdbPrivateAccountOpeningInfoMapper.deleteIndex(Constants.ES_INDEX_NAME_FDB_OPENING_ACCOUNT_PRIVATE);
-//            queryCenterService.deleteData(Constants.ES_INDEX_NAME_FDB_OPENING_ACCOUNT_PRIVATE,caseId);
-        }else {
-            fdbPrivateAccountOpeningInfoMapper.createIndex();
+        fdbPublicAccountOpeningInfoMapper.deleteIndex(Constants.ES_INDEX_NAME_FDB_OPENING_ACCOUNT_PUBLIC);
     }
 
-        if (fdbPublicAccountOpeningInfoMapper.existsIndex(Constants.ES_INDEX_NAME_FDB_OPENING_ACCOUNT_PUBLIC)) {
-            fdbPublicAccountOpeningInfoMapper.deleteIndex(Constants.ES_INDEX_NAME_FDB_OPENING_ACCOUNT_PUBLIC);
-//            queryCenterService.deleteData(Constants.ES_INDEX_NAME_FDB_OPENING_ACCOUNT_PUBLIC,caseId);
-        }else {
+    public void createFDBIndex(String caseId) {
+        fdbStatementMapper.createIndex();
+        fdbPrivateAccountOpeningInfoMapper.createIndex();
         fdbPublicAccountOpeningInfoMapper.createIndex();
     }
-    }
 
 
     public void createCCBIndex() {

cas-system/src/main/java/com/inscloudtech/datacenter/service/impl/BankServiceImpl.java

@@ -1717,13 +1717,13 @@ public class BankServiceImpl implements BankService {
                 case Constants.BANK_IMPORT_MODEL_BANK_FDB: // 富滇银行
                     try {
                         esIndexHelper.delFDBIndex(caseId);
+                        esIndexHelper.createFDBIndex(caseId);
                         fdbDataAnalysisHelper.importData(file,caseId);
                         fdbDataAnalysisHelper.analyzeData(caseId);
                     } finally {
                         // 清除ES中的数据
                         esIndexHelper.delFDBIndex(caseId);
                         RedisUtils.incrAtomicValue(completeKey);
-                        long finish = System.currentTimeMillis();
                     }
                     break;
                 case Constants.BANK_IMPORT_MODEL_BOC_BANK: // 中国银行
@@ -1736,7 +1736,6 @@ public class BankServiceImpl implements BankService {
                     } finally {
                         esIndexHelper.delBOCIndex(caseId);
                         RedisUtils.incrAtomicValue(completeKey);
-                        long finish = System.currentTimeMillis();
                     }
                     break;
                 case Constants.BANK_IMPORT_MODEL_CITIC_BANK: // 中信银行
@@ -1750,7 +1749,7 @@ public class BankServiceImpl implements BankService {
                     } finally {
                         esIndexHelper.delCITICIndex(caseId);
                         RedisUtils.incrAtomicValue(completeKey);
-                        long finish = System.currentTimeMillis();
+
                     }
                     break;
                 case Constants.BANK_IMPORT_MODEL_MERCHANTS_BANK: // 招商银行