增加oss上传功能

DataFusion/.classpath

@@ -25,5 +25,6 @@
 	<classpathentry kind="lib" path="WebRoot/WEB-INF/lib/okio-2.2.2.jar"/>
 	<classpathentry kind="lib" path="WebRoot/WEB-INF/lib/sqljdbc42.jar"/>
 	<classpathentry kind="lib" path="WebRoot/WEB-INF/lib/jfinal-4.8-bin-with-src.jar"/>
+	<classpathentry kind="lib" path="WebRoot/WEB-INF/lib/inspur-cloud-oss-sdk-1.1.8.jar"/>
 	<classpathentry kind="output" path="WebRoot/WEB-INF/classes"/>
 </classpath>

DataFusion/res/config.properties

@@ -4,4 +4,9 @@ jdbcUrl_connected  = jdbc:oracle:thin:@1.255.255.222:1521:Orcl
 user_connected 	   = PDM
 password_connected = PDMPWD
 #DATA-Parms
-institution_id     = 74400013
+institution_id     = 74400013
+#OSS
+oss_endpoint       = oss.cn-north-3.inspurcloudoss.com
+oss_accessKey      = ZGEzOTY3YWQtNWI1OC00Y2MxLWJmNTgtZWVhN2M0ZjI5NTI4
+oss_secretKey      = YTc1NDQwZjItOWQ1OS00N2E3LTg4YmQtZjNjNjgzNzRjODQ5
+oss_bucketName     = annex

DataFusion/src/com/zskk/control/ViewController.java

@@ -1,5 +1,6 @@
 package com.zskk.control;
 
+import java.io.File;
 import java.io.IOException;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
@@ -9,6 +10,7 @@ import java.util.List;
 import java.util.Map;
 
 import com.alibaba.fastjson.JSON;
+import com.inspurcloud.oss.client.impl.OSSClientImpl;
 import com.jfinal.core.Controller;
 import com.jfinal.kit.PropKit;
 import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
@@ -53,6 +55,10 @@ public class ViewController extends Controller {
 		}
 	}
 	
+	public void testDown() {
+		
+	}
+	
 	public static DruidPlugin createConnectedDruidPlugin() {
 
 		return new DruidPlugin(PropKit.get("jdbcUrl_connected"), PropKit.get("user_connected"),PropKit.get("password_connected").trim());
@@ -106,11 +112,13 @@ public class ViewController extends Controller {
 	}
 
 	public static void main(String[] args) {
-        Map<String,String> paramsMap=new HashMap<String,String>();
-        paramsMap.put("institution_id", "44100001");
-
-		String contentString = doPost("https://risserver3.pacsonline.cn/butt/getExam/butt/getExam", paramsMap);
-		System.out.println(contentString);
-
+//        Map<String,String> paramsMap=new HashMap<String,String>();
+//        paramsMap.put("institution_id", "44100001");
+//
+//		String contentString = doPost("https://risserver3.pacsonline.cn/butt/getExam/butt/getExam", paramsMap);
+//		System.out.println(contentString);
+//		ZGEzOTY3YWQtNWI1OC00Y2MxLWJmNTgtZWVhN2M0ZjI5NTI4
+//		YTc1NDQwZjItOWQ1OS00N2E3LTg4YmQtZjNjNjgzNzRjODQ5
+		
 	}
 }

DataFusion/src/com/zskk/service/DataService.java

@@ -1,12 +1,20 @@
 package com.zskk.service;
 
+import java.io.File;
 import java.io.IOException;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.nio.file.StandardOpenOption;
 import java.util.HashMap;
 import java.util.Map;
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.inspurcloud.oss.client.impl.OSSClientImpl;
 import com.jfinal.kit.PropKit;
 
 import okhttp3.FormBody;
@@ -20,9 +28,14 @@ public class DataService {
     private static String GET_EXAM_URL = "https://risserver3.pacsonline.cn/butt/getExam";
     
     private static String SAVE_REPORT_URL = "https://risserver3.pacsonline.cn/butt/saveReport";
+    
+    private static String SAVE_ANNEX_URL = "https://risserver3.pacsonline.cn/butt/saveAnnex";
 	
     private static final OkHttpClient OKHTTP_CLIENT = new OkHttpClient();
     
+    private static final OSSClientImpl OSS_CLIENT = new OSSClientImpl(PropKit.get("oss_endpoint"), PropKit.get("oss_accessKey"), PropKit.get("oss_secretKey"));
+
+    
     /**
      * 获取未出报告的检查列表
      * @param instutionId
@@ -52,6 +65,18 @@ public class DataService {
 		
 	}
     
+    /**
+     * 保存附件
+     * @param instutionId
+     * @param number
+     */
+    public void saveAnnex(String filePath) {
+		Map<String, String> map = new HashMap<>();
+
+		postWithParameters(SAVE_ANNEX_URL, map);
+		
+	}
+    
     public static String postWithParameters(String url, Map<String, String> map) {
     	
     	FormBody.Builder formbody = new FormBody.Builder();
@@ -77,11 +102,60 @@ public class DataService {
 			}	
 	}
     
+    public static String getWithUrl(String url) {
+    	
+    	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);
+    	      byte[] bytes = response.body().bytes();
+              //本地文件夹目录（下载位置）
+              String folder = "/home/zskk/";
+              //切割出图片名称==》PCtm_d9c8750bed0b3c7d089fa7d55720d6cf.png
+              String filename = "";
+              
+              Path filePath = Paths.get(folder + filename);
+                  //不存在文件 => 创建
+              Files.write(filePath, bytes, StandardOpenOption.CREATE);
+
+    	      System.out.println(response.body().string());
+    	    	return filename;
+
+    	    } catch (IOException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+		    	return "";
+
+			}
+	}
+    
     public static void main(String[] args) {
-    	Map <String,String> map = new HashMap<String,String>();
-    	map.put("institution_id", "47600001");
-    	map.put("num", "10");
-		postWithParameters(GET_EXAM_URL, map);
+//    	Map <String,String> map = new HashMap<String,String>();
+//    	map.put("institution_id", "47600001");
+//    	map.put("num", "10");
+//		postWithParameters(GET_EXAM_URL, map);
+    	System.out.print(GET_EXAM_URL);
+		String bucketName = "annex";
+		String key = "111/a.pdf";
+		File file = new File("/Users/liutao/Desktop/1-销售部标准化操作手册（SOP）v1.0版-销售服务流程-中世康恺20220304.pdf");
+		URI abvUri =null;
+		try {
+			 abvUri =new URI("https://annex.oss.cn-north-3.inspurcloudoss.com/111/a.pdf");
+				File file2 = new File(abvUri);
+//				OSSClientImpl ossClient = new OSSClientImpl(endpoint, accessKey, secretKey);
+
+				//简单文件上传
+				OSS_CLIENT.putObject(bucketName, key, file);
+		} catch (URISyntaxException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		
+//创建OSSClient实例
+		
+//		Boolean aBoolean = ossClient.doesObjectExist(bucketName, key);
+//		System.out.print(aBoolean);
 	}
 
 }

DataFusion/src/com/zskk/task/DataTask.java

@@ -73,6 +73,7 @@ public class DataTask implements ITask {
 			tService.execute(() -> {
 				dService.saveReport(params);
 			});	
+			dService.saveAnnex(record.getStr("PDF"));
         }
 	}