commit

DataFusion/src/com/zskk/control/ViewController.java

@@ -79,69 +79,51 @@ public class ViewController extends Controller {
 	
 	public void sd() {
 		try {
-			
-		
-		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;
+			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=?", "1.3.12.2.1107.2022030107137468");
-			Record recordrc = Db.use("connected").findFirst("select * from reportcheck where studyuid=?", "1.3.12.2.1107.2022022602139365");
-			Record recordri = Db.use("connected").findFirst("select * from reportinfo where studyuid=?", jsonObject.getString("studyuid"));
-			if (recordei==null && recordrc==null && recordri==null) {
-				continue;
-			}
-//			if (recordei!=null) {
-//				recordei.set("ViewFlag", "1");
-//				recordei.set("ViewTime", jsonObject.getString("createdAt"));
-//				recordei.set("ViewName", jsonObject.getString("name") + "_"+ source);
-//				Db.use("connected").update("examinfo", "studyuid", recordei);
-//
-//
-//			}
-			if (recordrc!=null) {
-				recordrc.set("ViewFlag", "1");
-				recordrc.set("ViewTime", jsonObject.getString("createdAt"));
-				recordrc.set("ViewName", jsonObject.getString("name") + "_"+ source);
-				Db.use("connected").update("update reportcheck set ViewFlag='2' where studyuid='1.3.12.2.1107.2022022602139365'");
-
-
-			}
-//			if (recordri!=null) {
-//				recordri.set("ViewFlag", "1");
-//				recordri.set("ViewTime", jsonObject.getString("createdAt"));
-//				recordri.set("ViewName", jsonObject.getString("name") + "_"+ source);
-//				Db.use("connected").update("reportinfo", recordri);
-//			}
-			
-			
+				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;
+				}
+				if (recordei!=null) {
+					Db.use("connected").update("update examinfo set ViewFlag='1',ViewTime=?,ViewName=? where studyuid=?",jsonObject.getString("createdAt"),jsonObject.getString("name") + "_"+ source,jsonObject.getString("studyuid"));
+				}
+				if (recordrc!=null) {
+					Db.use("connected").update("update reportcheck set ViewFlag='1',ViewTime=?,ViewName=? where studyuid=?",jsonObject.getString("createdAt"),jsonObject.getString("name") + "_"+ source,jsonObject.getString("studyuid"));
+				}
+				if (recordri!=null) {
+				
+					Db.use("connected").update("update reportinfo set ViewFlag='1',ViewTime=?,ViewName=? where studyuid=?",jsonObject.getString("createdAt"),jsonObject.getString("name") + "_"+ source,jsonObject.getString("studyuid"));
+				}
+	        	} catch (Exception e) {
+					// TODO: handle exception
+	        		continue;
+				}
+	        }
     		renderText("succeed");
 
-        	} catch (Exception e) {
-				// TODO: handle exception
-//        		continue;
-        		renderText(e.toString());
-
-			}
-        }
 		} catch (Exception e) {
 			// TODO: handle exception
     		renderText(e.toString());

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

@@ -44,20 +44,16 @@ public class BindTask implements ITask {
 			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"));
+			if (recordei!=null) {
+				Db.use("connected").update("update examinfo set ViewFlag='1',ViewTime=?,ViewName=? where studyuid=?",jsonObject.getString("createdAt"),jsonObject.getString("name") + "_"+ source,jsonObject.getString("studyuid"));
+			}
+			if (recordrc!=null) {
+				Db.use("connected").update("update reportcheck set ViewFlag='1',ViewTime=?,ViewName=? where studyuid=?",jsonObject.getString("createdAt"),jsonObject.getString("name") + "_"+ source,jsonObject.getString("studyuid"));
+			}
+			if (recordri!=null) {
 			
-			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);
+				Db.use("connected").update("update reportinfo set ViewFlag='1',ViewTime=?,ViewName=? where studyuid=?",jsonObject.getString("createdAt"),jsonObject.getString("name") + "_"+ source,jsonObject.getString("studyuid"));
+			}
         	} catch (Exception e) {
 				// TODO: handle exception
         		continue;