LAPTOP-5NTQJPUS\LT 1 year ago
parent
commit
110bc3755a
2 changed files with 18 additions and 18 deletions
  1. 1 1
      DataFusion/res/config.properties
  2. 17 17
      DataFusion/src/com/zskk/task/DownloadTask.java

+ 1 - 1
DataFusion/res/config.properties

@@ -4,7 +4,7 @@ jdbcUrl_connected  = jdbc:oracle:thin:@172.18.0.29:1521/RIS
 user_connected 	   = ZLGD_YJP
 password_connected = ZLGD_YJP123
 #DB-local
-jdbcUrl_local  = jdbc:mysql://127.0.0.1:3306/pacsonline?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull
+jdbcUrl_local  = jdbc:mysql://127.0.0.1:3306/pacsonline?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&serverTimezone=Asia/Shanghai
 user_local 	   = zskk
 password_local = Zskk_2022
 #DATE-FTP

+ 17 - 17
DataFusion/src/com/zskk/task/DownloadTask.java

@@ -19,24 +19,24 @@ public class DownloadTask implements ITask {
 		// TODO Auto-generated method stub
 		DataService dService = ServiceFactory.getService(DataService.class);
 		Record recordfind = Db.use("local").findFirst("select * from study where status=1 order by createAt asc");
-//		JSONArray array = dService.getImage(recordfind.getStr("accessionNumber"));
-//		if (array==null) {
-//			recordfind.set("status", 2);
-//			Db.use("local").update("study",recordfind);
-//			return;
-//		}
-		recordfind.set("status", 5);
-//		recordfind.set("imageNum", array.size());
+		JSONArray array = dService.getImage(recordfind.getStr("accessionNumber"));
+		if (array==null) {
+			recordfind.set("status", 2);
+			Db.use("local").update("study",recordfind);
+			return;
+		}
+		recordfind.set("status", 4);
+		recordfind.set("imageNum", array.size());
 		recordfind.set("updateAt", getDateStr());
-//		Db.use("local").update("study",recordfind);
-//		for (Object object : array) {
-//			JSONObject jsonObject = JSON.parseObject(object.toString());
-//			String[] strings = jsonObject.getString("Path").split("\\\\");
-//			dService.downloadFtpFile(jsonObject.getString("Path"), strings[1]);
-//		}
-//		recordfind.set("status", 3);
-//		recordfind.set("updateAt", getDateStr());
-//		Db.use("local").update("study",recordfind);
+		Db.use("local").update("study",recordfind);
+		for (Object object : array) {
+			JSONObject jsonObject = JSON.parseObject(object.toString());
+			String[] strings = jsonObject.getString("Path").split("\\\\");
+			dService.downloadFtpFile(jsonObject.getString("Path"), strings[1]);
+		}
+		recordfind.set("status", 3);
+		recordfind.set("updateAt", getDateStr());
+		Db.use("local").update("study",recordfind);
 	}
 
 	@Override