[feature] 修改数据更新模式为直连数据库

acq-vomp/src/main/java/com/zjty/fp/acq/vomp/task/VompTasks.java

 package com.zjty.fp.acq.vomp.task;
 
-import com.zjty.fp.acq.vomp.subject.service.updater.impl.VompDataDbUpdater;
-import com.zjty.fp.acq.vomp.subject.service.updater.impl.VompDataRdUpdater;
-import com.zjty.fp.acq.vomp.subject.service.updater.impl.VompFetcherImpl;
-import com.zjty.fp.acq.vomp.subject.service.updater.impl.VompMapUpdater;
+import com.zjty.fp.acq.vomp.subject.service.updater.VompFetcher;
+import com.zjty.fp.acq.vomp.subject.service.updater.impl.*;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -19,29 +17,39 @@ import org.springframework.stereotype.Component;
 @Component
 @Slf4j
 public class VompTasks {
+    /**
+     * 采集工具类 将数据以文件形式保存
+     */
     @Autowired
-    VompFetcherImpl vompFetcher;
+    VompFetcher vompFetcher;
+
+    /**
+     * 以直连数据库模式更新文件的工具类
+     */
     @Autowired
-    VompDataRdUpdater dataUpdater;
+    VompDataDbUpdater dataDbUpdater;
+    /**
+     * 以从FTP下载文件并读取的模式更新文件的工具类
+     */
     @Autowired
-    VompMapUpdater mapUpdater;
-
-
+    VompDataDlUpdater dataDlUpdater;
     /**
-     * 60分钟执行一次 采集
+     * 以读取文件模式更新文件的工具类
      */
-    @Scheduled(initialDelay = 4000, fixedRate = 60000 * 60)
-    public void fetchData() {
-        vompFetcher.fetchData();
-    }
-
+    @Autowired
+    VompDataRdUpdater dataRdUpdater;
+    /**
+     * 更新缓存数据的工具类
+     */
+    @Autowired
+    VompMapUpdater mapUpdater;
 
     /**
      * 60分钟执行一次 读取
      */
-//    @Scheduled(initialDelay = 4000, fixedRate = 60000 * 60)
+    @Scheduled(initialDelay = 4000, fixedRate = 60000 * 60)
     public void updateData() {
-        dataUpdater.updateData();
+        dataDbUpdater.updateData();
         mapUpdater.updateData();
     }