optimize mq message

content-understanding-core/src/main/java/com/tzld/piaoquan/content/understanding/rocketmq/consumer/ContentUnderstandingPipelineTaskConsumer.java

@@ -76,6 +76,12 @@ public class ContentUnderstandingPipelineTaskConsumer implements RocketMQListene
                 return ConsumeResult.SUCCESS;
             }
             CuTask cuTask = list.get(0);
+            if (Objects.equals(cuTask.getTaskStatus(), TaskStatusEnum.SUCCESS.getValue())
+                    || Objects.equals(cuTask.getTaskStatus(), TaskStatusEnum.FAILURE.getValue())) {
+                //已完成的任务 消费掉消息
+                log.info("finish task consume taskId = {} videoId = {}", taskId, videoId);
+                return ConsumeResult.SUCCESS;
+            }
             Long pipelineId = cuTask.getPipelineId();
             String input = cuTask.getInput();
             if (input == null || input.isEmpty()) {