commit

DataFusion/src/com/zskk/config/ZskkConfig.java

@@ -18,6 +18,7 @@ import com.jfinal.template.Engine;
 import com.zskk.control.ViewController;
 import com.zskk.service.ServiceFactory;
 import com.zskk.task.DataTask;
+import com.zskk.task.DownloadTask;
 import com.zskk.task.InfoTask;
 import com.zskk.task.UpdateTask;
 
@@ -94,9 +95,13 @@ public class ZskkConfig extends JFinalConfig {
 		upData.addTask("*/2 * * * *", new UpdateTask());
 		me.add(upData);
 		
-//		Cron4jPlugin ifData = new Cron4jPlugin();
-//		ifData.addTask("*/5 * * * *", new InfoTask());
-//		me.add(ifData);
+		Cron4jPlugin ifData = new Cron4jPlugin();
+		ifData.addTask("*/5 * * * *", new InfoTask());
+		me.add(ifData);
+		
+		Cron4jPlugin dwData = new Cron4jPlugin();
+		dwData.addTask("*/1 * * * *", new DownloadTask());
+		me.add(dwData);
 	}
 
 	@Override

DataFusion/src/com/zskk/service/DataService.java

@@ -161,7 +161,7 @@ public class DataService {
 			return contentString;
 	}
     
-    public static void downloadFtpFile(String remoteFileName, String fileName) {
+    public void downloadFtpFile(String remoteFileName, String fileName) {
         FTPClient ftpClient = new FTPClient();
         int reply;
         try {

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

@@ -20,9 +20,19 @@ public class DownloadTask implements ITask {
 	@Override
 	public void run() {
 		// TODO Auto-generated method stub
+		DataService dService = ServiceFactory.getService(DataService.class);
 		Record recordfind = Db.use("local").findFirst("select * from study order by createAt desc");
-		
-
+		JSONArray array = dService.getImage(recordfind.getStr("accessionNumber"));
+		recordfind.set("status", 4);
+		recordfind.set("imageNum", array.size());
+		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);
+		Db.use("local").update("study",recordfind);
 	}
 
 	@Override