feat: 正在处理的

gic-cloud-data-hook-api/src/main/java/com/gic/cloud/data/hook/api/service/IDownloadTaskService.java

@@ -69,4 +69,6 @@ public interface IDownloadTaskService {
 	DownloadProcessDTO getDownloadProcess();
 
 	void checkTaskStatus(String param);
+
+	public List<DownloadTask> getDownloadTaskOfBuilding(String queryDataSource);
 }

gic-cloud-data-hook-service/src/main/java/com/gic/cloud/data/hook/service/impl/FlatQueryResultServiceImpl.java

@@ -609,12 +609,12 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
 //				}
 //			}
 			//之前正在处理的队列需要重新处理
-			List<DownloadRecord> list = this.downloadTaskService.listUnDownloadTask(QueryDataSource.FLAT_QUERY);
-//			List<DownloadTask> tasks = DownloadTaskServiceImpl.getInstance().getDownloadTaskOfBuilding(QueryDataSource.FLAT_QUERY);
-			logger.info("初始化任务：{}",JSONObject.toJSONString(list));
-			for (DownloadRecord task : list) {
-				FlatQueryTaskCondition condition = JSON.parseObject(task.getDownloadCondition(), FlatQueryTaskCondition.class);
-				DownloadTask downloadTask = DownloadTaskServiceImpl.getInstance().getDownloadTaskById(condition.getTaskId());
+//			List<DownloadRecord> list = this.downloadTaskService.listUnDownloadTask(QueryDataSource.FLAT_QUERY);
+			List<DownloadTask> tasks = DownloadTaskServiceImpl.getInstance().getDownloadTaskOfBuilding(QueryDataSource.FLAT_QUERY);
+			logger.info("初始化任务：{}",JSONObject.toJSONString(tasks));
+			for (DownloadTask task : tasks) {
+//				FlatQueryTaskCondition condition = JSON.parseObject(task.getDownloadCondition(), FlatQueryTaskCondition.class);
+//				DownloadTask downloadTask = DownloadTaskServiceImpl.getInstance().getDownloadTaskById(condition.getTaskId());
 				String key=LOCK_KEY+":"+task.getId();
 				Object cache = RedisUtil.getCache(key);
 				if (cache!=null) {
@@ -622,9 +622,9 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
 				}
 				delFileOrDirByTaskId(task.getId());
 				//重新处理
-				downloadTask.setStatus(DownloadTaskStatus.WAITING);
-				downloadTask.setDownloadTime(new Date());
-				DownloadTaskServiceImpl.getInstance().updateDownloadTask(downloadTask);
+				task.setStatus(DownloadTaskStatus.WAITING);
+				task.setDownloadTime(new Date());
+				DownloadTaskServiceImpl.getInstance().updateDownloadTask(task);
 
 			}
 		}catch (Exception e){