LAPTOP-5NTQJPUS\LT 1 year ago
parent
commit
81b80d0a7e

+ 2 - 1
DataFusion/res/config.properties

@@ -17,4 +17,5 @@ oss_accessKey = 94LX6HHDAV6AS4830IH8
 oss_secretKey = h3WBubtjzRIMGIi6K3VWBT05LvdXiuNlSifSHKG5
 oss_bucketName = annex
 oss_endpoint = https://eos.jinan-4.cmecloud.cn
-region = jinan4
+region = jinan4
+oss_localPath = /home/zskk/REPORT_FILE

+ 34 - 1
DataFusion/src/com/zskk/control/ViewController.java

@@ -1,9 +1,12 @@
 package com.zskk.control;
 
+import java.io.BufferedOutputStream;
 import java.io.BufferedReader;
 import java.io.File;
 import java.io.FileInputStream;
+import java.io.FileOutputStream;
 import java.io.IOException;
+import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.text.SimpleDateFormat;
 import java.util.Date;
@@ -153,7 +156,37 @@ public class ViewController extends Controller {
 				renderText(e.toString());
 			}	
 	}
-		
+	public static String getFileWithUrl(String url, String filename) {
+
+		Request request = new Request.Builder().url(url).build();
+		try (Response response = OKHTTP_CLIENT.newCall(request).execute()) {
+			if (!response.isSuccessful())
+				throw new IOException("Unexpected code " + response);
+			InputStream inputStream = response.body().source().inputStream();
+			// 本地文件夹目录(下载位置)
+			String folder = PropKit.get("oss_localPath");
+			// 下载文件保存位置
+			String savepath = folder + "/" + filename;
+			BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(new FileOutputStream(new File(savepath)));
+			byte[] data = new byte[1024];
+			int len;
+			int available = inputStream.available();
+			while ((len = inputStream.read(data)) != -1) {
+				bufferedOutputStream.write(data, 0, len);
+			}
+			bufferedOutputStream.flush();
+			bufferedOutputStream.close();
+			inputStream.close();
+
+			return savepath;
+
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			return "";
+
+		}
+	}	
 		/**
 		 * 日期字符串格式转换年月日时分秒
 		 *