1

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

@@ -1,327 +1,305 @@
 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");
+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("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);
-        }
-    }*/
+//            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);
+//        }
+//    }*/
 }