修改手动上传任务

ad-platform-services/ad-platform-source/src/main/java/com/baiye/module/service/impl/ClueServiceImpl.java

@@ -688,26 +688,28 @@ public class ClueServiceImpl implements ClueService {
             clueMiddle.setMemberId(dynamicTaskDto.getUserId());
             clueMiddle.setMemberStatus(DefaultNumberConstants.ONE_NUMBER);
         }
+
         clueMiddle.setClueId(save.getId());
         clueMiddle.setTaskId(taskId);
         clueMiddle.setOptimisticVersion(DefaultNumberConstants.ZERO_NUMBER);
         clueMiddle.setClueStage(DefaultNumberConstants.ZERO_NUMBER);
         clueMiddle.setClueStageTime(new Date());
         clueMiddle.setClueCallStatus(DefaultNumberConstants.ZERO_NUMBER);
-        clueMiddle.setClueType(DefaultNumberConstants.TWO_NUMBER);
         if (StringUtils.isNotBlank(remark)) {
             clueMiddle.setRemark(remark);
         }
-        clueMiddleRepository.save(clueMiddle);
-        //动态任务
-        if (dynamicTaskDto.getType() == FileConstant.FIVE_NUMBER) {
-            Integer taskNum = clueMiddleRepository.findTaskNum(taskId);
-            Task task = new Task();
-            task.setId(taskId);
-            task.setTotalNumber(taskNum);
-            task.setIsDistribution(1);
-            taskClient.updateTask(task, SecurityConstants.FROM_IN);
+
+        //查询任务信息
+        ResponseEntity<Task> response = taskClient.queryDetails(taskId, SecurityConstants.FROM_IN);
+        if (response.getStatusCode().value() != 200 || response.getBody() == null) {
+            throw new BadRequestException("查询错误");
         }
+        Task task = response.getBody();
+        task.setTotalNumber(task.getTotalNumber() + 1);
+        task.setIsDistribution(1);
+        taskClient.updateTask(task, SecurityConstants.FROM_IN);
+        clueMiddle.setClueType(task.getIsForm());
+        clueMiddleRepository.save(clueMiddle);
     }
 
     @Override