刘韬 4 年之前
父節點
當前提交
6cf4c2b24f
共有 2 個文件被更改,包括 9 次插入3 次删除
  1. 1 1
      DataFusion/src/com/zskk/config/ZskkConfig.java
  2. 8 2
      DataFusion/src/com/zskk/task/UpdateTask.java

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

@@ -97,7 +97,7 @@ public class ZskkConfig extends JFinalConfig {
 		me.add(cpData);
 
 		Cron4jPlugin inData = new Cron4jPlugin();
-		inData.addTask("*/1 * * * *", new InsertTask());
+		inData.addTask("*/3 * * * *", new InsertTask());
 		me.add(inData);
 
 		Cron4jPlugin urlData = new Cron4jPlugin();

+ 8 - 2
DataFusion/src/com/zskk/task/UpdateTask.java

@@ -24,8 +24,12 @@ public class UpdateTask implements ITask {
 	@Override
 	public void run() {
 		// TODO Auto-generated method stub
-		List<Record> record = Db.use("connected").find("select * from v_webpacs_image where rownum <50 and IMAGEDATE>to_date('"+parseStringToDate()+"','yyyy-mm-dd hh24:mi:ss') order by IMAGEDATE desc");
-		for (Record record2 : record) {
+		Record record = Db.use("connectedtemp").findFirst("select * from study where status=1 order by createAt");
+		if (record == null) {
+			return;
+		}
+		List<Record> recordList = Db.use("connected").find("select FILEPATH from v_webpacs_image where STUDYID=?",record.getStr("studyid"));
+		for (Record record2 : recordList) {
 			Request request = new Request.Builder()
 			        .url("http://"+record2.getStr("FILEPATH").replace("\\\\", "/"))
 			        .build();
@@ -62,6 +66,8 @@ public class UpdateTask implements ITask {
 				e.printStackTrace();
 			}
 		}
+		record.set("status", 3);
+		Db.use("connectedtemp").update("study", record);
 
 	}