Pārlūkot izejas kodu

增加打印数量同步

刘韬 2 gadi atpakaļ
vecāks
revīzija
5795b84cbb

+ 6 - 0
DataFusion/src/com/zskk/config/ZskkConfig.java

@@ -20,6 +20,7 @@ import com.zskk.service.ServiceFactory;
 import com.zskk.task.BindTask;
 import com.zskk.task.CheckTask;
 import com.zskk.task.DataTask;
+import com.zskk.task.PrintNumTask;
 import com.zskk.task.PrintTask;
 import com.zskk.task.UpdateTask;
 
@@ -114,6 +115,11 @@ public class ZskkConfig extends JFinalConfig {
 	    Cron4jPlugin prData = new Cron4jPlugin();
 	    prData.addTask("*/2 * * * *", new PrintTask());
 		me.add(prData);
+		
+		//统计打印数量
+	    Cron4jPlugin pnData = new Cron4jPlugin();
+	    pnData.addTask("*/50 * * * *", new PrintNumTask());
+		me.add(pnData);
 	}
 
 	@Override

+ 16 - 0
DataFusion/src/com/zskk/service/DataService.java

@@ -35,6 +35,9 @@ public class DataService {
 	private static String RETURN_BIND_URL = "https://risserver3.pacsonline.cn/butt/getBindInfo";
 
 	private static String SAVE_ANNEX_URL = "https://risserver3.pacsonline.cn/butt/saveAnnex";
+	
+	private static String SAVE_PRINT_URL = "https://risserver3.pacsonline.cn/butt/savePrint";
+
 
 	private static final OkHttpClient OKHTTP_CLIENT = new OkHttpClient();
 	
@@ -152,7 +155,20 @@ public class DataService {
 		file.delete();
 
 	}
+	
+	/**
+	 * 获取未出报告的检查列表
+	 * 
+	 * @param instutionId
+	 * @param number
+	 */
+	public void savePrint(Map<String, String> map) {
+		
+		String content = postWithParameters(SAVE_PRINT_URL, map);
 
+		
+	}
+	
 	public static String postWithParameters(String url, Map<String, String> map) {
 
 		FormBody.Builder formbody = new FormBody.Builder();

+ 1 - 1
DataFusion/src/com/zskk/task/DataTask.java

@@ -22,7 +22,7 @@ public class DataTask implements ITask {
 	public void run() {
 		// TODO Auto-generated method stub
 		DataService dService = ServiceFactory.getService(DataService.class);
-        JSONArray jsonArray = dService.getExamList(500);	
+        JSONArray jsonArray = dService.getExamList(300);	
         for (Object object : jsonArray) {
         	try {
 			JSONObject jsonObject = JSON.parseObject(object.toString());

+ 94 - 0
DataFusion/src/com/zskk/task/PrintNumTask.java

@@ -0,0 +1,94 @@
+package com.zskk.task;
+
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.jfinal.kit.PropKit;
+import com.jfinal.plugin.activerecord.Db;
+import com.jfinal.plugin.activerecord.Record;
+import com.jfinal.plugin.cron4j.ITask;
+import com.zskk.service.DataService;
+import com.zskk.service.ServiceFactory;
+import com.zskk.service.ThreadPoolService;
+
+public class PrintNumTask implements ITask {
+
+	@Override
+	public void run() {
+		// TODO Auto-generated method stub
+		DataService dService = ServiceFactory.getService(DataService.class);
+		List<Record> records = Db.use("print").find("select * from IMAGEVIEW where ADDTIME >? order by ADDTIME desc",parseStringToDate1());
+		for (Record record : records) {
+			try {
+				if (record == null) {
+					continue;
+				}
+				Map<String, String> annex_params = new HashMap<>();
+				annex_params.put("institution_id", PropKit.get("institution_id"));
+				annex_params.put("type", "2");
+				annex_params.put("code", record.getStr("CHECKID"));
+	      		dService.savePrint(annex_params);
+			} catch (Exception e) {
+				// TODO: handle exception
+				continue;
+			}
+
+		}
+
+	}
+
+	@Override
+	public void stop() {
+		// TODO Auto-generated method stub
+
+	}
+
+	/**
+	 * 日期字符串格式转换
+	 * @param dateStr
+	 * @return
+	 */
+	private String parseStringToDate(String dateStr) {
+		if (dateStr == null) {
+			return "";
+		}
+		SimpleDateFormat sdf= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+	    Date date = null;
+	    String timeString = null;
+		try {
+			date = sdf.parse(dateStr);
+			SimpleDateFormat sdf2= new SimpleDateFormat("yyyyMMdd");
+
+			timeString = sdf2.format(date);
+		} catch (ParseException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+        return timeString;
+	}
+	
+	/**
+	 * 日期字符串格式转换
+	 * 
+	 * @param dateStr
+	 * @return
+	 */
+	private String parseStringToDate1() {
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		Date date = new Date();
+		String timeString = null;
+		Long i = date.getTime();
+		Long j = i - 5400000;
+		Date newdate = new Date(j);
+		timeString = sdf.format(newdate);
+		return timeString;
+	}
+
+}