Skip to content

G
gic-cloud
Commit f805df8f by fudahua
Options

Merge branch 'feature-2023-04' into 'developer' 

Feature 2023 04

See merge request !90
parents 4d7c6321 fffca064
Showing with 5 additions and 0 deletions
gic-cloud-data-hook-api/src/main/java/com/gic/cloud/data/hook/api/service/IDownloadTaskService.java
...@@ -69,4 +69,6 @@ public interface IDownloadTaskService { ...@@ -69,4 +69,6 @@ public interface IDownloadTaskService {
DownloadProcessDTO getDownloadProcess(); DownloadProcessDTO getDownloadProcess();
void checkTaskStatus(String param); 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,9 +609,12 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService { ...@@ -609,9 +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); List<DownloadTask> tasks = DownloadTaskServiceImpl.getInstance().getDownloadTaskOfBuilding(QueryDataSource.FLAT_QUERY);
logger.info("初始化任务：{}",JSONObject.toJSONString(tasks)); logger.info("初始化任务：{}",JSONObject.toJSONString(tasks));
for (DownloadTask task : 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(); String key=LOCK_KEY+":"+task.getId();
Object cache = RedisUtil.getCache(key); Object cache = RedisUtil.getCache(key);
if (cache!=null) { if (cache!=null) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment