LAPTOP-5NTQJPUS\LT 1 年之前
父节点
当前提交
442a4d2225
共有 2 个文件被更改,包括 6 次插入6 次删除
  1. 3 3
      DataFusion/src/com/zskk/config/ZskkConfig.java
  2. 3 3
      DataFusion/src/com/zskk/task/CheckTask.java

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

@@ -107,9 +107,9 @@ public class ZskkConfig extends JFinalConfig {
 		urlData.addTask("*/1 * * * *", new UpdateTask());
 		urlData.addTask("*/1 * * * *", new UpdateTask());
 		me.add(urlData);
 		me.add(urlData);
 		
 		
-//		Cron4jPlugin ckData = new Cron4jPlugin();
-//		ckData.addTask("*/5 * * * *", new CheckTask());
-//		me.add(ckData);
+		Cron4jPlugin ckData = new Cron4jPlugin();
+		ckData.addTask("*/5 * * * *", new CheckTask());
+		me.add(ckData);
 	}
 	}
 
 
 	@Override
 	@Override

+ 3 - 3
DataFusion/src/com/zskk/task/CheckTask.java

@@ -30,7 +30,7 @@ public class CheckTask implements ITask {
 		}
 		}
 		for (Record record3 : record) {
 		for (Record record3 : record) {
 			int i = record3.getInt("imageNum");
 			int i = record3.getInt("imageNum");
-			List<Record> recordList = Db.use("connected").find("select * from v_webpacs_image where STUDYID=?",record3.getStr("studyid"));
+			List<Record> recordList = Db.use("connected").find("select * from tjpacs.V_ZSKK_WEBPACS_IMAGE where STUDYID=?",record3.getStr("studyid"));
 			if (recordList.size()<=i) {
 			if (recordList.size()<=i) {
 				continue;
 				continue;
 			}else {
 			}else {
@@ -38,10 +38,10 @@ public class CheckTask implements ITask {
 				Db.use("connectedtemp").update("study", record3);
 				Db.use("connectedtemp").update("study", record3);
 				for (Record record2 : recordList) {
 				for (Record record2 : recordList) {
 					Request request = new Request.Builder()
 					Request request = new Request.Builder()
-					        .url("http://"+record2.getStr("FILEPATH").replace("\\\\", "/"))
+							.url(record2.getStr("HTTP_URL"))
 					        .build();
 					        .build();
 
 
-					String fileName = record2.getStr("IMAGE_UID");
+					String fileName = record2.getStr("INSUID");
 
 
 					try (Response response = OKHTTP_CLIENT.newCall(request).execute()) {
 					try (Response response = OKHTTP_CLIENT.newCall(request).execute()) {
 						if (!response.isSuccessful())
 						if (!response.isSuccessful())