格式化返回结果

ai-analytic-center-biz/pom.xml

@@ -227,6 +227,12 @@
 		</dependency>
 
 
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-text</artifactId>
+			<version>1.9</version> <!-- 请根据需要选择合适的版本 -->
+		</dependency>
+
 	</dependencies>
 
 	<build>

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

@@ -2,9 +2,6 @@ package com.volvo.ai.analytic.center.service;
 
 import com.volvo.ai.analytic.center.dto.req.FourInOneRequestDTO;
 
-import java.util.List;
-import java.util.Map;
-
 /**
  * @description 电话语料表-同步表
  * @author BEJSON
@@ -18,5 +15,4 @@ public interface IntelligentCustomerService{
 
 	void sendMq( String message);
 
-	Map<String, List<String>> queryTcIntelligentCustomer();
 }

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

@@ -1,7 +1,6 @@
 package com.volvo.ai.analytic.center.service.impl;
 
 import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.volvo.ai.analytic.center.constant.Constant;
 import com.volvo.ai.analytic.center.dto.req.DiFyReq;
 import com.volvo.ai.analytic.center.dto.req.FourInOneRequestDTO;
@@ -9,9 +8,7 @@ import com.volvo.ai.analytic.center.dto.req.RunMaskingRuleInput;
 import com.volvo.ai.analytic.center.entity.AiAnalysisErrors;
 import com.volvo.ai.analytic.center.entity.AiAnalysisRequestLogs;
 import com.volvo.ai.analytic.center.entity.DataMaskingRule;
-import com.volvo.ai.analytic.center.entity.TcIntelligentCustomer;
 import com.volvo.ai.analytic.center.enums.BusinessTypeEnum;
-import com.volvo.ai.analytic.center.enums.IntelligentCustomerTypeEnum;
 import com.volvo.ai.analytic.center.feign.RemoteCarModelClient;
 import com.volvo.ai.analytic.center.mapper.AiAnalysisErrorsMapper;
 import com.volvo.ai.analytic.center.mapper.TcIntelligentCustomerMapper;
@@ -19,6 +16,7 @@ import com.volvo.ai.analytic.center.service.*;
 import com.volvo.ai.analytic.center.utils.AiAnalysisUtils;
 import com.volvo.ai.analytic.center.utils.ConstantStr;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringEscapeUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.rocketmq.client.producer.SendCallback;
 import org.apache.rocketmq.client.producer.SendResult;
@@ -34,7 +32,6 @@ import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.stream.Collectors;
 
 
 /**
@@ -110,7 +107,7 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic
 				try {
 					JSONObject outputsJson = execDifyFlow.getJSONObject("outputs");
 					// 发送MQ
-					String message = JSONObject.toJSONString(outputsJson);
+					String message = StringEscapeUtils.unescapeJava(JSONObject.toJSONString(outputsJson));
 					log.info("send mq  {}",message);
 					sendMq(message);
 
@@ -146,7 +143,7 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic
 	}
 
 	// 咨询类【201】/投诉类【202】/投诉类型【203】 过滤
-	private String fourInOneMqServiceFilter(String customerType,String customerValue){
+	/** private String fourInOneMqServiceFilter(String customerType,String customerValue){
 		if(tcIntelligentCustomer.isEmpty()){
 			queryTcIntelligentCustomer();
 		}
@@ -178,6 +175,6 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic
 				));
 		return tcIntelligentCustomer;
 	}
-
+**/
 
 }