刘韬 2 年之前
父节点
当前提交
f7fffa9ec9
共有 2 个文件被更改,包括 5 次插入3 次删除
  1. 4 3
      DataFusion/src/com/zskk/task/CMoveTask.java
  2. 1 0
      DataFusion/src/com/zskk/task/ReCMoveTask.java

+ 4 - 3
DataFusion/src/com/zskk/task/CMoveTask.java

@@ -32,10 +32,11 @@ public class CMoveTask implements ITask {
 			if (flag <= 5) {
 				//状态4:下载中
 				studyidfind.set("status", 4);
+				studyidfind.set("updateAt", parseStringToDateTime());
 				Db.use("local").update("study", studyidfind);
 				
-				ThreadPoolService tService = ServiceFactory.getService(ThreadPoolService.class);
-				tService.execute(() -> {
+//				ThreadPoolService tService = ServiceFactory.getService(ThreadPoolService.class);
+//				tService.execute(() -> {
 					String execCmd = ExecUtil.execCmd("/zskk_system/other/cmove.sh " + studyidfind.getStr("studyuid"));
 					if (execCmd.contains("Connection refused")) {
 						//状态2:错误
@@ -49,7 +50,7 @@ public class CMoveTask implements ITask {
 						Db.use("local").update("study", studyidfind);
 					}
 					
-				});	
+//				});	
 				}
 			
 			

+ 1 - 0
DataFusion/src/com/zskk/task/ReCMoveTask.java

@@ -32,6 +32,7 @@ public class ReCMoveTask implements ITask {
 			if (flag <= 5) {
 				//状态4:下载中
 				studyidfind.set("status", 4);
+				studyidfind.set("updateAt", parseStringToDateTime());
 				Db.use("local").update("study", studyidfind);
 				String execCmd = ExecUtil.execCmd("/zskk_system/other/cmove.sh " + studyidfind.getStr("studyuid"));
 				if (execCmd.contains("Connection refused")) {