增加cmove定时任务

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

@@ -17,7 +17,7 @@ import com.jfinal.template.Engine;
 import com.zskk.control.ViewController;
 import com.zskk.service.ServiceFactory;
 import com.zskk.task.CFindTask;
-import com.zskk.task.CGetTask;
+import com.zskk.task.CMoveTask;
 import com.zskk.task.DataTask;
 import com.zskk.task.UpdateTask;
 
@@ -89,14 +89,18 @@ public class ZskkConfig extends JFinalConfig {
 //		Cron4jPlugin cpData = new Cron4jPlugin();
 //		cpData.addTask("*/5 * * * *", new DataTask());
 //		me.add(cpData);
-//		
+		
 		Cron4jPlugin inData = new Cron4jPlugin();
 		inData.addTask("5 2 * * *", new UpdateTask());
 		me.add(inData);
-//		
+		
 		Cron4jPlugin cgData = new Cron4jPlugin();
 		cgData.addTask("50 1 * * *", new CFindTask());
 		me.add(cgData);
+		
+		Cron4jPlugin mvData = new Cron4jPlugin();
+		mvData.addTask("*/3 * * * *", new CMoveTask());
+		me.add(mvData);
 	}
 
 	@Override

DataFusion/src/com/zskk/task/CGetTask.java → DataFusion/src/com/zskk/task/CMoveTask.java

@@ -7,20 +7,20 @@ import com.jfinal.plugin.activerecord.Record;
 import com.jfinal.plugin.cron4j.ITask;
 import com.zskk.tools.ExecUtil;
 
-public class CGetTask implements ITask {
+public class CMoveTask implements ITask {
 
 	@Override
 	public void run() {
 		// TODO Auto-generated method stub
-		Record studyidfind = Db.use("local").findFirst("select * from study where status =1 or status =4 order by createAt asc");
+		Record studyidfind = Db.use("local").findFirst("select * from study where status =1 or status =2 order by createAt asc");
 		if (studyidfind == null) {
 			return;
 		}
-		studyidfind.set("status", 2);
+		studyidfind.set("status", 4);
 		Db.use("local").update("study", studyidfind);
-		String execCmd = ExecUtil.execCmd("/zskk_system/other/cget.sh " + studyidfind.getStr("studyuid"));
+		String execCmd = ExecUtil.execCmd("/zskk_system/other/cmove.sh " + studyidfind.getStr("studyuid"));
 		if (execCmd.contains("Connection refused")) {
-			studyidfind.set("status", 4);
+			studyidfind.set("status", 2);
 			Db.use("local").update("study", studyidfind);
 			return;
 		}