更新患者信息匹配

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

@@ -74,13 +74,20 @@ public class ZskkConfig extends JFinalConfig {
 		arpConnected.setDialect(new SqlServerDialect());
 		me.add(arpConnected);
 
+		//匹配报告
 		Cron4jPlugin cpData = new Cron4jPlugin();
 		cpData.addTask("*/5 * * * *", new DataTask());
 		me.add(cpData);
 		
+		//更新审核后报告
 		Cron4jPlugin upData = new Cron4jPlugin();
 		upData.addTask("*/15 * * * *", new CheckTask());
 		me.add(upData);
+		
+		//更新患者信息
+		Cron4jPlugin pifData = new Cron4jPlugin();
+		pifData.addTask("*/1 * * * *", new UpdateTask());
+		me.add(pifData);
 	}
 
 	@Override

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

@@ -22,6 +22,8 @@ public class DataService {
     private static String SAVE_REPORT_URL = "https://risserver3.pacsonline.cn/butt/saveReport";
     
     private static String GET_CONFIRM_EXAM_URL = "https://risserver3.pacsonline.cn/butt/getConfirmExam";
+    
+    private static String UPDATE_PATIENT_URL = "https://risserver3.pacsonline.cn/butt/saveExam";
 	
     private static final OkHttpClient OKHTTP_CLIENT = new OkHttpClient();
     
@@ -68,6 +70,16 @@ public class DataService {
 		
 	}
     
+    /**
+     * 更新患者信息
+     * 
+     * @param instutionId
+     * @param number
+     */
+     public void updatePatientInfo(Map<String, String> map) {
+     postWithParameters(UPDATE_PATIENT_URL, map);
+     }
+    
     public static String postWithParameters(String url, Map<String, String> map) {
     	
     	FormBody.Builder formbody = new FormBody.Builder();

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

@@ -1,9 +1,7 @@
 package com.zskk.task;
 
 import java.util.HashMap;
-import java.util.List;
 import java.util.Map;
-
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
@@ -20,7 +18,7 @@ public class UpdateTask implements ITask {
 	public void run() {
 		// TODO Auto-generated method stub
 		DataService dService = ServiceFactory.getService(DataService.class);
-        JSONArray jsonArray = dService.getExamListConfirmed(20);
+        JSONArray jsonArray = dService.getExamListConfirmed(10);
         for (Object object : jsonArray) {
         	try {
 			JSONObject jsonObject = JSON.parseObject(object.toString());
@@ -68,7 +66,7 @@ public class UpdateTask implements ITask {
 			params.put("hopitalized_no", "");
 			ThreadPoolService tService = ServiceFactory.getService(ThreadPoolService.class);
 			tService.execute(() -> {
-				dService.(params);
+				dService.updatePatientInfo(params);
 			});	
         	} catch (Exception e) {
 				// TODO: handle exception