刘韬 3 年之前
父節點
當前提交
7a48be0e0e

+ 3 - 3
DataFusion/src/com/zskk/config/ZskkConfig.java

@@ -91,9 +91,9 @@ public class ZskkConfig extends JFinalConfig {
 		me.add(pifData);
 		
 		//更新患者信息
-	    Cron4jPlugin bdData = new Cron4jPlugin();
-	    bdData.addTask("*/10 * * * *", new BindTask());
-		me.add(bdData);
+//	    Cron4jPlugin bdData = new Cron4jPlugin();
+//	    bdData.addTask("*/10 * * * *", new BindTask());
+//		me.add(bdData);
 	}
 
 	@Override

+ 61 - 1
DataFusion/src/com/zskk/control/ViewController.java

@@ -8,6 +8,8 @@ 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;
 import com.jfinal.core.Controller;
 import com.jfinal.kit.PropKit;
 import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
@@ -75,7 +77,58 @@ public class ViewController extends Controller {
 		}
 	}
 	
-	
+	public void sd() {
+		DataService dService = ServiceFactory.getService(DataService.class);
+        JSONArray jsonArray = dService.getBindList(parseStringToDate(),parseStringToDate());
+        for (Object object : jsonArray) {
+        	try {
+			JSONObject jsonObject = JSON.parseObject(object.toString());
+			String source = "";
+			switch (jsonObject.getString("source")) {
+			case "1":
+				source="数字影像云公众号";
+				break;
+				
+			case "2":
+				source="集成链接";
+				break;
+				
+			case "3":
+				source="推送短信";
+				break;
+
+			default:
+				break;
+			}
+			Record recordei = Db.use("connected").findFirst("select * from examinfo where studyuid=?", jsonObject.getString("studyuid"));
+			Record recordrc = Db.use("connected").findFirst("select * from reportcheck where studyuid=?", jsonObject.getString("studyuid"));
+			Record recordri = Db.use("connected").findFirst("select * from reportinfo where studyuid=?", jsonObject.getString("studyuid"));
+			if (recordei==null || recordrc==null || recordri==null) {
+				continue;
+			}
+			recordei.set("ViewFlag", "1");
+			recordrc.set("ViewFlag", "1");
+			recordri.set("ViewFlag", "1");
+			
+			recordei.set("ViewTime", jsonObject.getString("createdAt"));
+			recordrc.set("ViewTime", jsonObject.getString("createdAt"));
+			recordri.set("ViewTime", jsonObject.getString("createdAt"));
+			
+			recordei.set("ViewName", jsonObject.getString("name") + "_"+ source);
+			recordrc.set("ViewName", jsonObject.getString("name") + "_"+ source);
+			recordri.set("ViewName", jsonObject.getString("name") + "_"+ source);
+			Db.use("connected").update("examinfo", recordei);
+			Db.use("connected").update("reportcheck", recordrc);
+			Db.use("connected").update("reportinfo", recordri);
+        	} catch (Exception e) {
+				// TODO: handle exception
+        		continue;
+			}
+        }
+		renderText("succeed");
+
+		
+	}
 	public void st() {
 		try {
 		
@@ -191,6 +244,13 @@ public class ViewController extends Controller {
 		}
         return date;
 	}
+	
+	private String parseStringToDate() {
+		SimpleDateFormat sdf= new SimpleDateFormat("yyyy-MM-dd");
+	    Date date = new Date();
+	    String timeString = sdf.format(date);
+	    return timeString;
+	}
 
 	public static void main(String[] args) {
         Map<String,String> paramsMap=new HashMap<String,String>();

+ 0 - 4
DataFusion/src/com/zskk/task/BindTask.java

@@ -1,10 +1,7 @@
 package com.zskk.task;
 
-import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.Date;
-import java.util.HashMap;
-import java.util.Map;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
@@ -13,7 +10,6 @@ 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 BindTask implements ITask {