1

DataFusion/res/config.properties

@@ -1,7 +1,7 @@
 #DB-ZhongShiKangKai and connected partners
-jdbcUrl_zskk  = jdbc:mysql://www.pacsonline.cn:3306/pacsonline?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false
-user_zskk 	  = pacs
-password_zskk = ZSKK@2017~!@#
+#jdbcUrl_zskk  = jdbc:mysql://www.pacsonline.cn:3306/pacsonline?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false
+#user_zskk 	  = pacs
+#password_zskk = ZSKK@2017~!@#
 
 jdbcUrl_connected  = jdbc:sqlserver://192.168.118.46:1433;DatabaseName=medexmemrs
 user_connected 	   = MDKS

DataFusion/src/com/zskk/config/ZskkConfig.java

@@ -1,22 +1,15 @@
 package com.zskk.config;
 
-import com.jfinal.config.Constants;
-import com.jfinal.config.Handlers;
-import com.jfinal.config.Interceptors;
-import com.jfinal.config.JFinalConfig;
-import com.jfinal.config.Plugins;
-import com.jfinal.config.Routes;
+import com.jfinal.config.*;
 import com.jfinal.kit.PropKit;
 import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
-import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
 import com.jfinal.plugin.activerecord.dialect.OracleDialect;
 import com.jfinal.plugin.activerecord.dialect.SqlServerDialect;
 import com.jfinal.plugin.cron4j.Cron4jPlugin;
 import com.jfinal.plugin.druid.DruidPlugin;
 import com.jfinal.template.Engine;
-import com.zskk.service.ServiceFactory;
 import com.zskk.control.ViewController;
-import com.zskk.model._MappingKit;
+import com.zskk.service.ServiceFactory;
 import com.zskk.task.DataTask;
 import com.zskk.task.UpdateTask;
 
@@ -65,16 +58,16 @@ public class ZskkConfig extends JFinalConfig {
 	@Override
 	public void configPlugin(Plugins me) {
 		// 配置数据库连接池插件
-		DruidPlugin druidPluginZskk = createZskkDruidPlugin();
-		me.add(druidPluginZskk);
+		//DruidPlugin druidPluginZskk = createZskkDruidPlugin();
+		//me.add(druidPluginZskk);
 
 		// 配置ActiveRecord插件
-		ActiveRecordPlugin arpZskk = new ActiveRecordPlugin("zskk", druidPluginZskk);
-		arpZskk.setDialect(new MysqlDialect());
+		//ActiveRecordPlugin arpZskk = new ActiveRecordPlugin("zskk", druidPluginZskk);
+		//arpZskk.setDialect(new MysqlDialect());
 
 		 //所有映射在 MappingKit 中自动化搞定
-		_MappingKit.mapping(arpZskk);
-		me.add(arpZskk);
+		//_MappingKit.mapping(arpZskk);
+		//me.add(arpZskk);
 
 		// 配置数据库连接池插件
 		DruidPlugin druidPluginConnected = createConnectedDruidPlugin();
@@ -101,6 +94,12 @@ public class ZskkConfig extends JFinalConfig {
 		Cron4jPlugin cp2 = new Cron4jPlugin();
 		cp2.addTask("*/13 * * * *", new UpdateTask());
 		me.add(cp2);
+//		Cron4jPlugin cpData = new Cron4jPlugin();
+//		cpData.addTask("*/3 * * * *", new DataService());
+//		me.add(cpData);
+//		Cron4jPlugin cp2 = new Cron4jPlugin();
+//		cp2.addTask("*/2 * * * *", new DataService2());
+//		me.add(cp2);
 	}
 
 	@Override

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

@@ -0,0 +1,327 @@
+package com.zskk.service;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.jfinal.plugin.cron4j.ITask;
+import com.zskk.model.Exams;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.apache.log4j.Logger;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.PrintWriter;
+import java.nio.charset.Charset;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class DataService2 implements ITask {
+    static Logger logger = Logger.getLogger(DataService.class);
+    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 final OkHttpClient OKHTTP_CLIENT = new OkHttpClient();
+
+    private static CloseableHttpClient httpClient;
+
+    static {
+        PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
+        cm.setMaxTotal(100);
+        cm.setDefaultMaxPerRoute(20);
+        cm.setDefaultMaxPerRoute(50);
+        httpClient = HttpClients.custom().setConnectionManager(cm).build();
+    }
+
+
+
+    /**
+     * 获取未出报告的检查列表
+     * @param instutionId
+     * @param number
+     */
+    public static JSONArray getExamList(String instutionId, Integer number) {
+        Map<String,String> map = new HashMap<String,String>();
+        map.put("institution_id", instutionId);
+        map.put("num", number.toString());
+        String content = postWithParameters(GET_EXAM_URL, map);
+        JSONObject jsonObject = JSON.parseObject(content);
+        if (!jsonObject.getString("msg").equals("success")) {
+            return null;
+        }
+        JSONArray jsonArray = JSON.parseArray(jsonObject.getString("data"));
+        return jsonArray;
+
+    }
+
+    /**
+     * 写入报告
+     * @param instutionId
+     * @param number
+     */
+    public void saveReport(String instutionId, Integer number) {
+        Map <String,String> map = new HashMap<String,String>();
+        postWithParameters(SAVE_REPORT_URL, map);
+
+    }
+    /**
+     * 发送POST请求
+     *
+     * @param url        目的地址
+     * @param parameters 请求参数，Map类型。
+     * @return 远程响应结果
+     */
+    public static String postWithParameters(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();
+                //System.out.println(temp_params);
+                params = temp_params.substring(0, temp_params.length() - 1);
+                System.out.println(params);
+            }
+            //params = java.net.URLEncoder.encode(params, "UTF-8");
+            // 创建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()); // 用PrintWriter进行包装
+            // out.println(params);
+            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;
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                if (out != null) {
+                    out.close();
+                }
+                if (in != null) {
+                    in.close();
+                }
+            } catch (IOException ex) {
+                ex.printStackTrace();
+            }
+        }
+        return result;
+    }
+
+
+    public static String post(String url, String jsonString) {
+        CloseableHttpResponse response = null;
+        BufferedReader in = null;
+        String result = "";
+        try {
+            HttpPost httpPost = new HttpPost(url);
+            RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(30000).setConnectionRequestTimeout(30000).setSocketTimeout(30000).build();
+            httpPost.setConfig(requestConfig);
+            httpPost.setConfig(requestConfig);
+            httpPost.addHeader("Content-type", "application/json; charset=utf-8");
+            httpPost.setHeader("Accept", "application/json");
+            httpPost.setEntity(new StringEntity(jsonString, Charset.forName("UTF-8")));
+            response = httpClient.execute(httpPost);
+            in = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
+            StringBuffer sb = new StringBuffer("");
+            String line = "";
+            String NL = System.getProperty("line.separator");
+            while ((line = in.readLine()) != null) {
+                sb.append(line + NL);
+            }
+            in.close();
+            result = sb.toString();
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                if (null != response) {
+                    response.close();
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return result;
+    }
+
+    @Override
+    public void run() {
+        JSONArray examList = getExamList("51000001", 2);
+        List<Exams> exams = JSONObject.parseArray(examList.toJSONString(), Exams.class);
+        for (Exams exams2 : exams) {
+            logger.info(exams2.getId());
+            System.out.println(exams2.getId());
+            String id = exams2.getId();
+            Map<String, String> params = new HashMap<>();
+            //  params.put("institution_id",exams2.getId());
+            //exams表
+            params.put("exam_id", "cnb506yaldqwzkmm");
+            //报告医生姓名
+            params.put("report_doctor_name", "11");
+//            //报告时间
+            params.put("report_datetime", "2018-05-08 15:13:19");
+//            //审核医生姓名
+            params.put("review_doctor_name", "2");
+//            //审核时间
+            params.put("review_datetime", "2018-05-08 15:13:19");
+//            //确认医生姓名
+            params.put("confirm_doctor_name", "3");
+//            //确认时间
+            params.put("confirm_datetime", "2018-05-08 15:13:19");
+////            if (record.getStr("impression") == null && record.getStr("description") == null) {
+////                continue;
+////            }
+//            //意见建议
+            params.put("impression", "         44444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444 44444444444 ,444444444444444444444444444444444444444444444444444444444444444444");
+//            //影像所见
+            params.put("description", "              54444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444");
+//            //exams表
+//            //申请科室
+            params.put("application_department", "6");
+//            //申请医生
+            params.put("application_doctor", "7");
+//            //临床诊断
+            params.put("clin_diag", "8");
+//            //patient_infos表
+//            //患者姓名
+            params.put("name", "9");
+//            //患者手机号
+            params.put("phone", "10");
+//            //患者身份证号
+            params.put("card_num", "11");
+            params.put("report_result", "1");
+            String post = post(SAVE_REPORT_URL, JSON.toJSONString(params));
+            logger.error(post);
+            //System.out.println(post);
+        }
+    }
+
+    @Override
+    public void stop() {
+
+    }
+
+  /*  public static String postWithParameters(String url, Map<String, String> map) {
+
+        FormBody.Builder formbody = new FormBody.Builder();
+
+        for (Map.Entry<String, String> entry : map.entrySet()) {
+            formbody.add(entry.getKey(), entry.getValue());
+        }
+        RequestBody requestBody = formbody.build();
+
+        Request request = new Request.Builder()
+                .url(url)
+                .post(requestBody)
+                .build();
+
+        try (Response response = OKHTTP_CLIENT.newCall(request).execute()) {
+            if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);
+            String content = response.body().string();
+            System.out.println(content);
+            return content;
+        } catch (IOException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+            return null;
+        }
+    }*/
+
+    /*public static void main(String[] args) {
+
+        JSONArray examList = getExamList("51000001", 2);
+        List<Exams> exams = JSONObject.parseArray(examList.toJSONString(), Exams.class);
+        for (Exams exams2 : exams) {
+            logger.info(exams2.getId());
+            System.out.println(exams2.getId());
+            String id = exams2.getId();
+        Map<String, String> params = new HashMap<>();
+          //  params.put("institution_id",exams2.getId());
+        //exams表
+        params.put("exam_id","cnb506yaldqwzkmm");
+        //报告医生姓名
+        params.put("report_doctor_name","11");
+//            //报告时间
+        params.put("report_datetime","2018-05-08 15:13:19");
+//            //审核医生姓名
+        params.put("review_doctor_name","2");
+//            //审核时间
+        params.put("review_datetime","2018-05-08 15:13:19");
+//            //确认医生姓名
+        params.put("confirm_doctor_name","3");
+//            //确认时间
+        params.put("confirm_datetime","2018-05-08 15:13:19");
+////            if (record.getStr("impression") == null && record.getStr("description") == null) {
+////                continue;
+////            }
+//            //意见建议
+        params.put("impression","         44444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444 44444444444 ,444444444444444444444444444444444444444444444444444444444444444444");
+//            //影像所见
+        params.put("description","              54444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444444");
+//            //exams表
+//            //申请科室
+        params.put("application_department","6");
+//            //申请医生
+        params.put("application_doctor","7");
+//            //临床诊断
+        params.put("clin_diag","8");
+//            //patient_infos表
+//            //患者姓名
+        params.put("name","9");
+//            //患者手机号
+        params.put("phone","10");
+//            //患者身份证号
+        params.put("card_num","11");
+        params.put("report_result","1");
+        String post = post(SAVE_REPORT_URL, JSON.toJSONString(params));
+            logger.error(post);
+        //System.out.println(post);
+        }
+    }*/
+}

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

@@ -102,9 +102,11 @@ public class DataTask implements ITask {
 				params.put("card_num",record.getStr("idcard"));
 				params.put("report_result","1");
 				String logs = post(SAVE_REPORT_URL, JSON.toJSONString(params));
+				String s = JSON.toJSONString(params);
+				logger.info(s);
 				logger.error(logs);
 
-				/*report.setImpression(record.getStr("impression"));
+			   /* report.setImpression(record.getStr("impression"));
 				report.setDescription(record.getStr("description"));
 				report.setExamId(exams2.getId());
 				report.setCreatedAt(new Date());
@@ -129,7 +131,7 @@ public class DataTask implements ITask {
 		} catch (Exception e) {
 			// TODO: handle exception
 		}
-		
+
 	}
 
 
@@ -137,15 +139,15 @@ public class DataTask implements ITask {
 	@Override
 	public void stop() {
 		// TODO Auto-generated method stub
-		
+
 	}
-	
+
 	private String creatId() {
 		UUID id=UUID.randomUUID();
         String[] idd = id.toString().split("-");
         return idd[0]+idd[1]+idd[2];
 	}
-	
+
 	private String getDoctorIdByName(String name) {
 		if (name == null) {
 			return null;
@@ -156,7 +158,7 @@ public class DataTask implements ITask {
 		}
 		return doctors.getId();
 	}
-	
+
 	private Date parseStringToDate(String dateStr) {
 		if (dateStr == null) {
 			return new Date();

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

@@ -103,6 +103,8 @@ public class UpdateTask implements ITask {
 							params.put("card_num",record.getStr("IDCARD"));
 							params.put("report_result","1");
 							String post = post(SAVE_REPORT_URL, JSON.toJSONString(params));
+							String s = JSON.toJSONString(params);
+							logger.info(s);
 							logger.error(post);
 						/*report.setImpression(record.getStr("IMPRESSION"));
 						report.setDescription(record.getStr("DESCRIPTION"));
@@ -141,13 +143,13 @@ public class UpdateTask implements ITask {
 		// TODO Auto-generated method stub
 
 	}
-	
+
 	private String creatId() {
 		UUID id=UUID.randomUUID();
         String[] idd = id.toString().split("-");
         return idd[0]+idd[1]+idd[2];
 	}
-	
+
 	private String getDoctorIdByName(String name) {
 		if (name == null) {
 			return null;
@@ -158,7 +160,7 @@ public class UpdateTask implements ITask {
 		}
 		return doctors.getId();
 	}
-	
+
 	private Date parseStringToDate(String dateStr) {
 		if (dateStr == null) {
 			return new Date();