diff --git a/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/OceanEngineSync.java b/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/OceanEngineSync.java index 664daf0f..d17d0dc2 100644 --- a/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/OceanEngineSync.java +++ b/ad-platform-services/ad-platform-source/src/main/java/com/baiye/task/OceanEngineSync.java @@ -165,14 +165,6 @@ public class OceanEngineSync { clueMiddle.setClueType(DefaultNumberConstants.THREE_NUMBER); 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.setLocalClueId(save.getId()); oceanEngineClueId.setOceanEngineClueId(clueId); @@ -180,6 +172,13 @@ public class OceanEngineSync { oceanEngineClueId.setStatus(0); 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); }