commit

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

@@ -19,18 +19,18 @@ import okhttp3.Response;
 
 public class InsertTask implements ITask {
 
-    private static final OkHttpClient OKHTTP_CLIENT = new OkHttpClient();
+	private static final OkHttpClient OKHTTP_CLIENT = new OkHttpClient();
 
 	@Override
 	public void run() {
 		// TODO Auto-generated method stub
-		List<Record> record = Db.use("connected").find("select * from v_webpacs_study where STUDY_DATE>to_date('"+parseStringToDate()+"','yyyy-mm-dd hh24:mi:ss') and MODALITY!='US' and MODALITY!='XA' order by STUDY_DATE desc");
+		List<Record> record = Db.use("connected").find("select * from v_webpacs_study where STUDY_DATE>to_date('" + parseStringToDate()+ "','yyyy-mm-dd hh24:mi:ss') and MODALITY!='US' and MODALITY!='XA' order by STUDY_DATE desc");
 		for (Record record2 : record) {
-		String studyidstr = Db.use("connectedtemp").queryStr("select studyid from study where studyid = ?", record2.getStr("STUDYID"));
-		if (studyidstr.isBlank()) {
-			Record studyinfo = new Record().set("studyid", record2.getStr("STUDYID")).set("status", "1").set("createAt", new Date());
-			Db.use("connectedtemp").save("study", studyinfo);
-		}
+			Record studyidstr = Db.use("connectedtemp").findFirst("select * from study where studyid = ?",record2.getStr("STUDYID"));
+			if (studyidstr == null) {
+				Record studyinfo = new Record().set("studyid", record2.getStr("STUDYID")).set("status", "1").set("createAt", new Date());
+				Db.use("connectedtemp").save("study", studyinfo);
+			}
 		}
 	}
 
@@ -42,15 +42,16 @@ public class InsertTask implements ITask {
 
 	/**
 	 * 日期字符串格式转换
+	 * 
 	 * @param dateStr
 	 * @return
 	 */
 	private String parseStringToDate() {
-		SimpleDateFormat sdf= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-	    Date date = new Date();
-	    long dInteger =date.getTime()-7200000;
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		Date date = new Date();
+		long dInteger = date.getTime() - 7200000;
 		String daString = sdf.format(new Date(dInteger));
-	    return daString;
-		
+		return daString;
+
 	}
 }