.gitignore

@@ -11,3 +11,9 @@
 # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
 hs_err_pid*
 
+DataFusion/.idea/misc.xml
+DataFusion/.idea/encodings.xml
+DataFusion/.idea/modules.xml
+DataFusion/DataFusion.iml
+DataFusion/.idea/inspectionProfiles/Project_Default.xml
+DataFusion/.idea/workspace.xml

DataFusion/res/log4j.properties

@@ -1,10 +1,24 @@
-log4j.rootLogger=WARN, stdout, file
-log4j.appender.stdout=org.apache.log4j.ConsoleAppender
-log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
-log4j.appender.stdout.layout.ConversionPattern=%n%-d{yyyy-MM-dd HH:mm:ss}%n[%p]-[Thread: %t]-[%C.%M()]: %m%n
+#log4j.rootLogger=WARN, stdout, file
+#log4j.appender.stdout=org.apache.log4j.ConsoleAppender
+#log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
+#log4j.appender.stdout.layout.ConversionPattern=%n%-d{yyyy-MM-dd HH:mm:ss}%n[%p]-[Thread: %t]-[%C.%M()]: %m%n
+#
+## Output to the File
+#log4j.appender.file=org.apache.log4j.FileAppender
+#log4j.appender.file.File=./jfinal_demo.log
+#log4j.appender.file.layout=org.apache.log4j.PatternLayout
+#log4j.appender.file.layout.ConversionPattern=%n%-d{yyyy-MM-dd HH:mm:ss}%n[%p]-[Thread: %t]-[%C.%M()]: %m%n
 
-# Output to the File
-log4j.appender.file=org.apache.log4j.FileAppender
-log4j.appender.file.File=./jfinal_demo.log
-log4j.appender.file.layout=org.apache.log4j.PatternLayout
-log4j.appender.file.layout.ConversionPattern=%n%-d{yyyy-MM-dd HH:mm:ss}%n[%p]-[Thread: %t]-[%C.%M()]: %m%n
+log4j.rootCategory=DEBUG, CONSOLE,LOGFILE
+
+log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
+log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
+log4j.appender.CONSOLE.layout.ConversionPattern=-%p-%d{yyyy/MM/dd HH:mm:ss,SSS}-%l-%L-%m%n
+
+log4j.appender.LOGFILE=org.apache.log4j.FileAppender
+log4j.appender.logFile.Threshold=ERROR
+#log4j.appender.logFile.ImmediateFlush=true
+#log4j.appender.LOGFILE.Append=true
+log4j.appender.LOGFILE.File=D:/loggs/mylog.log
+log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout
+log4j.appender.LOGFILE.layout.ConversionPattern=-%p-%d{yyyy/MM/dd HH:mm:ss,SSS}-%l-%L-%m%n

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

@@ -1,21 +1,14 @@
 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.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;
 
 public class ZskkConfig extends JFinalConfig {
@@ -58,16 +51,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();

DataFusion/src/com/zskk/service/DataService.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 DataService 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", "cnb5070nvccjeoqu");
+            //报告医生姓名
+            params.put("report_doctor_name", "盛季平");
+//            //报告时间
+            params.put("report_datetime", "2020-02-26 11:48:31");
+//            //审核医生姓名
+            params.put("review_doctor_name", "盛季平");
+//            //审核时间
+            params.put("review_datetime", "2020-02-26 11:48:31");
+//            //确认医生姓名
+            params.put("confirm_doctor_name", "盛季平");
+//            //确认时间
+            params.put("confirm_datetime", "2020-02-26 11:48:31");
+////            if (record.getStr("impression") == null && record.getStr("description") == null) {
+////                continue;
+////            }
+//            //意见建议
+            params.put("impression", "考虑右胫骨远端陈旧骨折，并创伤性关节，请结合临床。");
+//            //影像所见
+            params.put("description", "　　右侧胫骨远端略膨大、变形，边缘毛糙、增生硬化；右踝关节间隙变窄，周围可见多个不规则结节状骨性密度影；右踝关节周围软组织肿胀。");
+//            //exams表
+//            //申请科室
+            params.put("application_department", "骨科三区病房");
+//            //申请医生
+            params.put("application_doctor", "何炜");
+//            //临床诊断
+            params.put("clin_diag", "null");
+//            //patient_infos表
+//            //患者姓名
+            params.put("name", "刘日昇");
+//            //患者手机号
+            params.put("phone", "13650842393");
+//            //患者身份证号
+            params.put("card_num", "440125197208070312");
+            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

@@ -1,41 +1,142 @@
 package com.zskk.task;
 
-import java.text.ParseException;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.List;
-import java.util.UUID;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
 import com.jfinal.plugin.activerecord.Db;
 import com.jfinal.plugin.activerecord.Record;
 import com.jfinal.plugin.cron4j.ITask;
-import com.zskk.service.ServiceFactory;
 import com.zskk.model.Doctors;
 import com.zskk.model.Exams;
-import com.zskk.model.PatientInfos;
-import com.zskk.model.Report;
-import com.zskk.model.Studies;
-import com.zskk.service.WeixinService;
+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.nio.charset.Charset;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.*;
 
 public class DataTask implements ITask {
+	Logger logger = Logger.getLogger(UpdateTask.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();
+	}
 	@Override
 	public void run() {
 		// TODO Auto-generated method stub
 		try {
-			List<Exams> exams = Exams.dao.use("zskk").find("SELECT * FROM pacsonline.exams where exam_status=3 and institution_id=33600001 order by createdAt desc limit 50");
+			//List<Exams> exams = Exams.dao.use("zskk").find("SELECT * FROM pacsonline.exams where exam_status=3 and institution_id=33600001 order by createdAt desc limit 50");
+			JSONArray examList = getExamList("33600001", 30);
+			List<Exams> exams = JSONObject.parseArray(examList.toJSONString(), Exams.class);
 			for (Exams exams2 : exams) {
-				Studies studies = Studies.dao.use("zskk").findById(exams2.getStudyId());
-				Record record = Db.use("connected").findFirst("select * from reportinfo where studyuid=?",studies.getStudyuid());
+				//Studies studies = Studies.dao.use("zskk").findById(exams2.getStudyId());
+				Record record = Db.use("connected").findFirst("select * from reportinfo where studyuid=?",exams2.getStudyUid());
 				if (record == null) {
 					continue;
 				}
-				Report report = new Report().use("zskk");
+				logger.info(record.getStr("reportdoctor")+"&"+record.getStr("reportdate")+"&");
+				logger.info(record.getStr("reviewdoctor")+"&"+record.getStr("reportdate")+"&");
+				//logger.info(record.getStr("REVIEWDOCTOR")+"&"+record.getStr("REPORTDATE")+"&");
+				logger.info(record.getStr("impression")+"&"+record.getStr("description")+"&");
+				logger.info(record.getStr("department")+"&"+record.getStr("clinicaldoctor")+"&");
+				logger.info(record.getStr("diagnosis")+"&"+record.getStr("patientname")+"&");
+				logger.info(record.getStr("phone")+"&"+record.getStr("idcard")+"&");
+				/*Report report = new Report().use("zskk");
 				report.setId(creatId());
-				report.setReportDatetime(parseStringToDate(record.getStr("reportdate")));
+				report.setReportDatetime(parseStringToDate(record.getStr("reportdate")));*/
+				if (record.getStr("impression") == null && record.getStr("description") == null) {
+					continue;
+				}
+				Map<String, String> params = new HashMap<>();
+				//exams表
+				params.put("exam_id",exams2.getId());
+				//报告医生姓名
+				params.put("report_doctor_name",record.getStr("reportdoctor"));
+				//报告时间
+				params.put("report_datetime",record.getStr("reportdate"));
+				//审核医生姓名
+				params.put("review_doctor_name",record.getStr("reviewdoctor"));
+				//审核时间
+				params.put("review_datetime",record.getStr("reportdate"));
+				//确认医生姓名
+				params.put("confirm_doctor_name",record.getStr("reviewdoctor"));
+				//确认时间
+				params.put("confirm_datetime",record.getStr("reportdate"));
 				if (record.getStr("impression") == null && record.getStr("description") == null) {
 					continue;
 				}
-				report.setImpression(record.getStr("impression"));
+				//意见建议
+				params.put("impression",record.getStr("impression"));
+				//影像所见
+				params.put("description",record.getStr("description"));
+				//exams表
+				//申请科室
+				if (record.getStr("department")==null){
+					params.put("application_department","");
+				}else {
+					params.put("application_department",record.getStr("department"));
+				}
+				//params.put("application_department",record.getStr("department"));
+				//申请医生
+				if (record.getStr("clinicaldoctor")==null){
+					params.put("application_doctor","");
+				}else {
+					params.put("application_doctor",record.getStr("clinicaldoctor"));
+				}
+				//params.put("application_doctor",record.getStr("clinicaldoctor"));
+				//临床诊断
+				if (record.getStr("diagnosis")==null){
+					params.put("clin_diag","");
+				}else {
+					params.put("clin_diag",record.getStr("diagnosis"));
+				}
+
+				//patient_infos表
+				//患者姓名
+				params.put("name",record.getStr("patientname"));
+				//患者手机号
+				if (record.getStr("phone")==null){
+					params.put("phone","");
+				}else {
+					params.put("phone",record.getStr("phone"));
+				}
+
+				//params.put("phone","");
+				//患者身份证号
+				if (record.getStr("idcard")==null){
+					params.put("card_num","");
+				}else {
+					params.put("card_num",record.getStr("idcard"));
+				}
+				//params.put("card_num",);
+				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.setDescription(record.getStr("description"));
 				report.setExamId(exams2.getId());
 				report.setCreatedAt(new Date());
@@ -55,7 +156,7 @@ public class DataTask implements ITask {
 				exams2.setExamStatus(9);
 				exams2.update();
 				WeixinService wService = ServiceFactory.getService(WeixinService.class);
-				wService.requestWeixinQrcode(report.getId());;
+				wService.requestWeixinQrcode(report.getId());;*/
 			}
 		} catch (Exception e) {
 			// TODO: handle exception
@@ -69,6 +170,59 @@ public class DataTask implements ITask {
 		// TODO Auto-generated method stub
 		
 	}
+	/**
+	 * 获取未出报告的检查列表
+	 * @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 = post(GET_EXAM_URL, JSON.toJSONString(map));
+		JSONObject jsonObject = JSON.parseObject(content);
+		if (!jsonObject.getString("msg").equals("success")) {
+			return null;
+		}
+		JSONArray jsonArray = JSON.parseArray(jsonObject.getString("data"));
+		return jsonArray;
+
+	}
+	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;
+	}
 	
 	private String creatId() {
 		UUID id=UUID.randomUUID();