浏览代码

fix analyse

supeng 7 小时之前
父节点
当前提交
ecb2453218

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

@@ -108,28 +108,27 @@ public class ContentServiceImpl implements ContentService {
         }
         param.setPipelineId(videoAnalysePipelineId);
         pipelineService.execute(param);
-        try {
-
-        } catch (Exception e) {
-
-        }
-        Long videoId = param.getVideoId();
-        String content = param.getContent();
-        SubmitTasksParam submitTasksParam = new SubmitTasksParam();
-        List<ContentDTO> contentDTOList = new ArrayList<>();
-        ContentDTO contentDTO = new ContentDTO();
-        contentDTO.setVideoId(videoId);
-        contentDTO.setContentType(ContentTypeEnum.VIDEO.getValue());
-        contentDTO.setContent(content);
-        contentDTO.setPipelineId(videoAnalysePipelineId);
-        Map<String, Object> extMap = new HashMap<>();
-        extMap.put("pipelineId", videoAnalysePipelineId);
-        extMap.put("type", "");
-        extMap.put("video_url", content);
-        contentDTO.setExtMap(extMap);
-        contentDTOList.add(contentDTO);
-        submitTasksParam.setContents(contentDTOList);
-        TaskResultVO taskResultVO = submitTasks(submitTasksParam);
+//        try {
+//            Long videoId = param.getVideoId();
+//            String content = param.getContent();
+//            SubmitTasksParam submitTasksParam = new SubmitTasksParam();
+//            List<ContentDTO> contentDTOList = new ArrayList<>();
+//            ContentDTO contentDTO = new ContentDTO();
+//            contentDTO.setVideoId(videoId);
+//            contentDTO.setContentType(ContentTypeEnum.VIDEO.getValue());
+//            contentDTO.setContent(content);
+//            contentDTO.setPipelineId(videoAnalysePipelineId);
+//            Map<String, Object> extMap = new HashMap<>();
+//            extMap.put("pipelineId", videoAnalysePipelineId);
+//            extMap.put("type", "");
+//            extMap.put("video_url", content);
+//            contentDTO.setExtMap(extMap);
+//            contentDTOList.add(contentDTO);
+//            submitTasksParam.setContents(contentDTOList);
+//            submitTasks(submitTasksParam);
+//        } catch (Exception e) {
+//            log.error(analyse, e);
+//        }
     }
 
     @Override