修改代码逻辑

master
bynt 1 year ago
parent 15bf7a9b95
commit 5cb2df28d7

@ -165,14 +165,6 @@ public class OceanEngineSync {
clueMiddle.setClueType(DefaultNumberConstants.THREE_NUMBER); clueMiddle.setClueType(DefaultNumberConstants.THREE_NUMBER);
clueMiddleRepository.save(clueMiddle); clueMiddleRepository.save(clueMiddle);
//动态任务
Integer taskNum = clueMiddleRepository.findTaskNum(taskId);
Task task = new Task();
task.setId(taskId);
task.setTotalNumber(taskNum);
task.setIsDistribution(1);
taskClient.updateTask(task);
OceanEngineClueId oceanEngineClueId = new OceanEngineClueId(); OceanEngineClueId oceanEngineClueId = new OceanEngineClueId();
oceanEngineClueId.setLocalClueId(save.getId()); oceanEngineClueId.setLocalClueId(save.getId());
oceanEngineClueId.setOceanEngineClueId(clueId); oceanEngineClueId.setOceanEngineClueId(clueId);
@ -180,6 +172,13 @@ public class OceanEngineSync {
oceanEngineClueId.setStatus(0); oceanEngineClueId.setStatus(0);
oceanEngineClueIdRepository.save(oceanEngineClueId); oceanEngineClueIdRepository.save(oceanEngineClueId);
} }
//动态任务
Integer taskNum = clueMiddleRepository.findTaskNum(taskId);
Task task = new Task();
task.setId(taskId);
task.setTotalNumber(taskNum);
task.setIsDistribution(1);
taskClient.updateTask(task);
oceanEngineSourceRepository.saveAll(oceanEngineSources); oceanEngineSourceRepository.saveAll(oceanEngineSources);
} }

Loading…
Cancel
Save