commit

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

@@ -16,20 +16,20 @@ public class CMoveTask implements ITask {
 	@Override
 	public void run() {
 		// TODO Auto-generated method stub
-		List<Record> count = Db.use("local").find("select * from study where status =4");
-		//同时下载的队列
-		Integer flag = count.size();
-		if (flag >= 5) {
-			return;
-		}
+//		List<Record> count = Db.use("local").find("select * from study where status =4");
+//		//同时下载的队列
+//		Integer flag = count.size();
+//		if (flag >= 5) {
+//			return;
+//		}
 		//延迟10分钟获取影像，并且查找状态为待CMOVE和错误状态的检查
 		List<Record> studyidfinds = Db.use("local").find("select * from study where status =1 or status =2 and createAt<? order by createAt asc limit 1",parseStringToDate());
 		if (studyidfinds == null) {
 			return;
 		}
 		for (Record studyidfind : studyidfinds) {
-			flag++;
-			if (flag <= 5) {
+//			flag++;
+//			if (flag <= 5) {
 				//状态4：下载中
 				studyidfind.set("status", 4);
 				studyidfind.set("updateAt", parseStringToDateTime());
@@ -51,7 +51,7 @@ public class CMoveTask implements ITask {
 					}
 					
 //				});	
-				}
+//				}
 			
 			
 		}
@@ -62,8 +62,8 @@ public class CMoveTask implements ITask {
 					return;
 				}
 				for (Record studyidfind : studyidfindsde) {
-					flag++;
-					if (flag <= 5) {
+//					flag++;
+//					if (flag <= 5) {
 						//状态4：下载中
 						studyidfind.set("status", 4);
 						studyidfind.set("updateAt", parseStringToDateTime());
@@ -85,7 +85,7 @@ public class CMoveTask implements ITask {
 							}
 							
 //						});	
-						}
+//						}
 					
 					
 				}

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

@@ -16,20 +16,20 @@ public class ReCMoveTask implements ITask {
 	@Override
 	public void run() {
 		// TODO Auto-generated method stub
-		List<Record> count = Db.use("local").find("select * from study where status =4");
-		//同时下载的队列
-		Integer flag = count.size();
-		if (flag >= 5) {
-			return;
-		}
+//		List<Record> count = Db.use("local").find("select * from study where status =4");
+//		//同时下载的队列
+//		Integer flag = count.size();
+//		if (flag >= 5) {
+//			return;
+//		}
 		//2小时到2天内的检查重新获取
 		List<Record> studyidfinds = Db.use("local").find("select * from study where status =3 and createAt between ? and ? and (modalities like '%CT%' or modalities like '%MR%' or modalities like '%DX%') order by createAt asc", parseStringToDateTo(), parseStringToDateFrom());
 		if (studyidfinds == null) {
 			return;
 		}
 		for (Record studyidfind : studyidfinds) {
-			flag++;
-			if (flag <= 5) {
+//			flag++;
+//			if (flag <= 5) {
 				//状态4：下载中
 				studyidfind.set("status", 4);
 				studyidfind.set("updateAt", parseStringToDateTime());
@@ -46,7 +46,7 @@ public class ReCMoveTask implements ITask {
 					studyidfind.set("updateAt", parseStringToDateTime());
 					Db.use("local").update("study", studyidfind);
 				}				
-				}
+//				}
 					
 		}