add log

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

@@ -78,6 +78,10 @@ public class ContentUnderstandingPipelineTaskConsumer implements RocketMQListene
             String taskId = messageDTO.getTaskId();
             Long videoId = messageDTO.getVideoId();
             Map<String, Object> extMap = messageDTO.getExtMap();
+            if (extMap == null) {
+                extMap = new HashMap<>();
+            }
+            extMap.put("messageId", messageId.toString());
             CuTaskExample example = new CuTaskExample();
             example.createCriteria().andTaskIdEqualTo(taskId).andTaskStatusEqualTo(TaskStatusEnum.SUBMIT.getValue());
             List<CuTask> list = cuTaskMapper.selectByExample(example);