From 5cb2df28d75e64397d72dc909ea3c278c21ce083 Mon Sep 17 00:00:00 2001 From: bynt Date: Wed, 26 Jul 2023 09:25:39 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BB=A3=E7=A0=81=E9=80=BB?= =?UTF-8?q?=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/baiye/task/OceanEngineSync.java | 15 +++++++-------- 1 file changed, 7 insertions(+), 8 deletions(-) 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); }