feat: 新版本的下载

gic-cloud-data-hook-service/src/main/java/com/gic/cloud/data/hook/service/impl/FlatQueryResultServiceImpl.java

@@ -661,7 +661,7 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
 	 * 执行 下载
 	 * @param interval
 	 */
-	private void runDealHiveFile(Integer interval) {
+	public void runDealHiveFile(Integer interval) {
 		distService.scheduleAtFixedRate(new Runnable() {
 			@Override
 			public void run() {
@@ -869,7 +869,7 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
 		}
 		List<String> xlsxFiles=new ArrayList<>();
 		AtomicInteger count=new AtomicInteger(0);
-		AtomicReference<XlsxFileInfo> currentFile=null;
+		AtomicReference<XlsxFileInfo> currentFile=new AtomicReference<>();
 		readCsvFile(condition.getTableId(),dirName,(cells,titles,firstFlag)->{
 			if (count.get()==0) {
 				XlsxFileInfo xlsxFileInfo = new XlsxFileInfo();

gic-cloud-data-hook-service/src/test/java/Test.java

+import com.gic.cloud.data.hook.service.impl.FlatQueryResultServiceImpl;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = {"classpath*:applicationContext-conf.xml"})
+public class Test {
+
+    @Autowired
+    private FlatQueryResultServiceImpl flatQueryResultService;
+
+    @org.junit.Test
+    public void test(){
+        flatQueryResultService.runDealHiveFile(3);
+    }
+}