commit

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

@@ -14,6 +14,7 @@ import com.jfinal.plugin.activerecord.dialect.SqlServerDialect;
 import com.jfinal.plugin.druid.DruidPlugin;
 import com.jfinal.plugin.redis.RedisPlugin;
 import com.zskk.model.*;
+import com.zskk.service.ThreadPoolService;
 
 import okhttp3.FormBody;
 import okhttp3.OkHttpClient;
@@ -213,9 +214,9 @@ public class ViewController extends Controller {
 		}
 	}
 	
-	 public static  String getSign(Map<String, String> param, String key) {
-	        return DigestUtils.md5Hex(Ksort(param) + key);
-	    }
+	public static String getSign(Map<String, String> param, String key) {
+		return DigestUtils.md5Hex(Ksort(param) + key);
+	}
 	 
 	public static String getSecondTimestamp(Date date) {
         if (null == date) {
@@ -273,139 +274,197 @@ public class ViewController extends Controller {
 	}
 	
 	public static String sendPost(String url, Map<String, String> parameters) {
-        String result = "";// 返回的结果
-        BufferedReader in = null;// 读取响应输入流
-        PrintWriter out = null;
-        StringBuffer sb = new StringBuffer();// 处理请求参数
-        String params = "";// 编码之后的参数
-        try {
-            // 编码请求参数
-            if (parameters.size() == 1) {
-                for (String name : parameters.keySet()) {
-                    sb.append(name).append("=").append(
-                            java.net.URLEncoder.encode(parameters.get(name),
-                                    "UTF-8"));
-                }
-                params = sb.toString();
-            } else {
-                for (String name : parameters.keySet()) {
-                    sb.append(name).append("=").append(
-                            java.net.URLEncoder.encode(parameters.get(name),
-                                    "UTF-8")).append("&");
-                }
-                String temp_params = sb.toString();
-                params = temp_params.substring(0, temp_params.length() - 1);
-            }
-            // 创建URL对象
-            java.net.URL connURL = new java.net.URL(url);
-            // 打开URL连接
-            java.net.HttpURLConnection httpConn = (java.net.HttpURLConnection) connURL
-                    .openConnection();
-            // 设置通用属性
-            httpConn.setRequestProperty("Accept", "*/*");
-            httpConn.setRequestProperty("Connection", "Keep-Alive");
-            httpConn.setRequestProperty("User-Agent",
-                    "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.1)");
-            // 设置POST方式
-            httpConn.setDoInput(true);
-            httpConn.setDoOutput(true);
-            // 获取HttpURLConnection对象对应的输出流
-            out = new PrintWriter(httpConn.getOutputStream());
-            // 发送请求参数
-            out.write(params);
-            // flush输出流的缓冲
-            out.flush();
-            // 定义BufferedReader输入流来读取URL的响应，设置编码方式
-            in = new BufferedReader(new InputStreamReader(httpConn
-                    .getInputStream(), "UTF-8"));
-            String line;
-            // 读取返回的内容
-            while ((line = in.readLine()) != null) {
-                result += line;
-            }
-            System.out.println(result);
-            return result;
-        } catch (Exception e) {
-            e.printStackTrace();
-        } finally {
-            try {
-                if (out != null) {
-                    out.close();
-                }
-                if (in != null) {
-                    in.close();
-                }
-            } catch (IOException ex) {
-                ex.printStackTrace();
-            }
-        }
-        return result;
-    }
+		String result = "";// 返回的结果
+		BufferedReader in = null;// 读取响应输入流
+		PrintWriter out = null;
+		StringBuffer sb = new StringBuffer();// 处理请求参数
+		String params = "";// 编码之后的参数
+		try {
+			// 编码请求参数
+			if (parameters.size() == 1) {
+				for (String name : parameters.keySet()) {
+					sb.append(name).append("=").append(java.net.URLEncoder.encode(parameters.get(name), "UTF-8"));
+				}
+				params = sb.toString();
+			} else {
+				for (String name : parameters.keySet()) {
+					sb.append(name).append("=").append(java.net.URLEncoder.encode(parameters.get(name), "UTF-8"))
+							.append("&");
+				}
+				String temp_params = sb.toString();
+				params = temp_params.substring(0, temp_params.length() - 1);
+			}
+			// 创建URL对象
+			java.net.URL connURL = new java.net.URL(url);
+			// 打开URL连接
+			java.net.HttpURLConnection httpConn = (java.net.HttpURLConnection) connURL.openConnection();
+			// 设置通用属性
+			httpConn.setRequestProperty("Accept", "*/*");
+			httpConn.setRequestProperty("Connection", "Keep-Alive");
+			httpConn.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.1)");
+			// 设置POST方式
+			httpConn.setDoInput(true);
+			httpConn.setDoOutput(true);
+			// 获取HttpURLConnection对象对应的输出流
+			out = new PrintWriter(httpConn.getOutputStream());
+			// 发送请求参数
+			out.write(params);
+			// flush输出流的缓冲
+			out.flush();
+			// 定义BufferedReader输入流来读取URL的响应，设置编码方式
+			in = new BufferedReader(new InputStreamReader(httpConn.getInputStream(), "UTF-8"));
+			String line;
+			// 读取返回的内容
+			while ((line = in.readLine()) != null) {
+				result += line;
+			}
+			System.out.println(result);
+		} catch (Exception e) {
+			e.printStackTrace();
+		} finally {
+			try {
+				if (out != null) {
+					out.close();
+				}
+				if (in != null) {
+					in.close();
+				}
+			} catch (IOException ex) {
+				ex.printStackTrace();
+			}
+		}
+		return result;
+	}
 
 	private static void post(String url, Map<String, String> map) throws IOException {
-		RequestBody formBody = new FormBody.Builder()
-		        .add("timestamp", String.valueOf(getSecondTimestamp(new Date())))
-		        .add("signature", Ksort(map))
-		        .add("data", JSON.toJSONString(map))
-		        .build();
+		RequestBody formBody = new FormBody.Builder().add("timestamp", String.valueOf(getSecondTimestamp(new Date())))
+				.add("signature", Ksort(map)).add("data", JSON.toJSONString(map)).build();
 
-		 System.out.println(String.valueOf(getSecondTimestamp(new Date())));
-	      System.out.println(Ksort(map));
-	      System.out.println(JSON.toJSONString(map));
-		    Request request = new Request.Builder()
-		        .url("http://39.106.136.96/pacs/zskk/writePatientReport")
-		        .post(formBody)
-		        .build();
+		Request request = new Request.Builder().url("http://test99.yunyikang.cn/pacs/zskk/saveWritePatientReport").post(formBody)
+				.build();
 
-		    try (Response response = OKHTTP_CLIENT.newCall(request).execute()) {
-		      if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);
+		try (Response response = OKHTTP_CLIENT.newCall(request).execute()) {
+			if (!response.isSuccessful())
+				throw new IOException("Unexpected code " + response);
 
-		      System.out.println(response.body().string());
+			System.out.println(response.body().string());
 //			  return response.body().string();
-//
-		    }
-	  }  
-	public static String Ksort(Map<String, String> map){
+
+		}
+	}
+	public static String Ksort(Map<String, String> map) {
 		String sb = "";
 		String[] key = new String[map.size()];
 		int index = 0;
 		for (String k : map.keySet()) {
-		key[index] = k;
-		index++;
+			key[index] = k;
+			index++;
 		}
 		Arrays.sort(key);
 
 		for (String s : key) {
-		sb += s + "=" + map.get(s) + "&";
+			sb += s + "=" + map.get(s) + "&";
 		}
 		sb = sb.substring(0, sb.length() - 1);
-		System.out.println("***"+sb);
-
 		try {
-		sb = URLEncoder.encode(sb, "UTF-8");
+			sb = URLEncoder.encode(sb, "UTF-8");
 		} catch (UnsupportedEncodingException e) {
-		e.printStackTrace();
-		}// 使用常见的UTF-8编码
+			e.printStackTrace();
+		} // 使用常见的UTF-8编码
 		sb = sb.replace("%3D", "=").replace("%26", "&");
-
-		System.out.println("**"+sb);
-		String resultString = HashKit.md5(sb+"YgpxjVeIx0yoK6Atz413IAj7hU9dygH4");
+		String resultString = HashKit.md5(sb + "YgpxjVeIx0yoK6Atz413IAj7hU9dygH4");
 		return resultString;
 	}
 	
-	public static  String returnSecondTimestamp(String data) throws ParseException {
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+	public static String returnSecondTimestamp(String data) throws ParseException {
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 
-        return String.valueOf(sdf.parse(data).getTime()/1000);
-    }
+		return String.valueOf(sdf.parse(data).getTime() / 1000);
+	}
 	public static void main(String[] args) {
+		// 传云医康 数据
+		Map<String, String> data = new HashMap<String, String>();
+		// 获取data数据
+		// 医院id
+		data.put("hospital_id", "13000003");
+		// 影像所见
+		data.put("description", "测试更新描述");
+		// 意见建议
+		data.put("impression", "测试更新印象");
+		// 检查id
+		data.put("exam_id", "116df635fe153209");
+		data.put("study_id", "116df635fde8f635");
+		// 患者id
+		data.put("patient_id", "116df635fdcfa46d");
+		// 患者姓名
+		data.put("patient_name", "张三");
+		// 患者性别
+		data.put("patient_sex", "M");
+		// 身份证号
+		data.put("card_num", "");
+		// 手机号
+		data.put("phone", "");
+		// 患者生日
+		data.put("birthday", "19820815");
+		// 患者检查时年龄
+		data.put("patient_age", "57Y");
+		// 阴阳性 1阴性 2阳性
+		data.put("report_result", "1");
+		// 报告时间 10位时间戳
 		try {
-			String ssString = returnSecondTimestamp("1955-03-17 00:00:00");
-			System.out.println(ssString);
-		} catch (ParseException e) {
+			data.put("report_datetime", returnSecondTimestamp("2020-07-22 00:00:00"));
+		} catch (ParseException e1) {
 			// TODO Auto-generated catch block
-			e.printStackTrace();
+			e1.printStackTrace();
+		}
+		// 报告医生id
+		data.put("report_doctor_id", "李四");
+		// 报告医生姓名
+		data.put("report_doctor_name", "李四");
+		// 审核时间
+		try {
+			data.put("review_datetime", returnSecondTimestamp("2020-07-22 00:00:00"));
+		} catch (ParseException e1) {
+			// TODO Auto-generated catch block
+			e1.printStackTrace();
 		}
-//			testTask();
+		// 审核医生id
+		data.put("review_doctor_id", "王五");
+		// 审核姓名
+		data.put("review_doctor_name", "王五️");
+		// 确认时间
+		try {
+			data.put("confirm_datetime", returnSecondTimestamp("2020-07-22 00:00:00"));
+		} catch (ParseException e1) {
+			// TODO Auto-generated catch block
+			e1.printStackTrace();
+		}
+		// 确认医生id
+		data.put("confirm_doctor_id", "王五");
+		// 确认医生姓名
+		data.put("confirm_doctor_name", "王五");
+		data.put("patient_no", "");
+
+
+		ThreadPoolService tService = new com.zskk.service.ThreadPoolService();
+		tService.execute(() -> {
+			String dadaString = JSON.toJSONString(data);
+			dadaString = dadaString.replace("\\r\\n", "");
+			dadaString = dadaString.replace("*", "X");
+			dadaString = dadaString.replace("<p>", "");
+			dadaString = dadaString.replace("<br/>", "");
+			dadaString = dadaString.replace("<p>", "");
+			dadaString = dadaString.replace("/", "-");
+			dadaString = dadaString.replace("&nbsp; ", "");
+
+
+			Map maps = (Map) JSON.parse(dadaString);
+			try {
+				post(null, maps);
+			} catch (IOException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+		});
 	}
 }