加日志 ，定位结构问题

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java

@@ -50,6 +50,8 @@ public class CorpusDccMqConsumer implements RocketMQListener<MessageExt>  {
 			String message = new String(messageExt.getBody());
 			log.info("dcc_mq接收到消息 : " + message);
 			AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class);
+			log.info("dcc_mq接收到消息转换对象 : " + aicorpusTelephone.toString());
+
 			//DCC场景
 			if(Objects.equals(aicorpusTelephone.getCategoryCode(), Constant.CHANNEL_DCC)){
 

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java

@@ -49,7 +49,7 @@ public class CorpusProcessKafkaProducer {
 	private final ObjectMapper objectMapper = new ObjectMapper();
 
 	// ai_corpus_Dcc_topic
-	@Value("${rocketmq.producer.corpus.dcctopic}")
+	@Value("${rocketmq.producer.corpus.dcctopic}") //=ai_corpus_Dcc_topic
 	private String dccMqTipic;
 
 	@Resource

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java

@@ -118,6 +118,8 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 
 
 			JSONObject jsonObject = JSONObject.parseObject(	aicorpusTelephone.getDisplay());
+
+			inputMap.put("chat",aicorpusTelephone.getDisplay());
 			JSONArray segments = jsonObject.getJSONArray("segments");
 
 			// 遍历 segments