add videoId params

content-understanding-core/src/main/java/com/tzld/piaoquan/content/understanding/service/impl/ContentServiceImpl.java

@@ -164,7 +164,8 @@ public class ContentServiceImpl implements ContentService {
         for (ContentDTO contentDTO : contentDTOList) {
             TaskResultDTO taskResultDTO = new TaskResultDTO();
             BeanUtils.copyProperties(contentDTO, taskResultDTO);
-            String taskId = pipelineService.executeTask(contentDTO);
+//            String taskId = pipelineService.executeTask(contentDTO);
+            String taskId = pipelineService.submitTask(contentDTO);
             taskResultDTO.setTaskId(taskId);
             taskResultDTOS.add(taskResultDTO);
         }

content-understanding-core/src/main/java/com/tzld/piaoquan/content/understanding/service/impl/PipelineServiceImpl.java

@@ -167,6 +167,7 @@ public class PipelineServiceImpl implements PipelineService {
     public String submitTask(ContentDTO contentDTO) {
         // 1.数据准备
         Long pipelineId = contentDTO.getPipelineId();
+        Long videoId = contentDTO.getVideoId();
         String content = contentDTO.getContent();
         // 1.新增任务
         String taskId = UUID.randomUUID().toString().replace("-", "") + System.currentTimeMillis();
@@ -180,6 +181,7 @@ public class PipelineServiceImpl implements PipelineService {
         }
         PipelineTaskMessageDTO messageDTO = new PipelineTaskMessageDTO();
         messageDTO.setTaskId(taskId);
+        messageDTO.setVideoId(videoId);
         messageDTO.setExtMap(contentDTO.getExtMap());
         try {
             MessageId messageId = contentUnderstandingPipelineTaskProducer.syncSendNormalMessage(messageDTO);