admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

json格式化处理

Browse Source
This commit is contained in:
zren25
2025-04-11 16:16:22 +08:00
parent 304a26daab
commit 4cbfc1f097
2 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -13,6 +13,6 @@ public interface IntelligentCustomerService{
void fourInOneMqService(FourInOneRequestDTO fourInOneRequestDTO); void fourInOneMqService(FourInOneRequestDTO fourInOneRequestDTO);
void sendMq( String message); void sendMq( Object message);
} }

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

@@ -106,11 +106,9 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic
if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){ if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){
try { try {
JSONObject outputsJson = execDifyFlow.getJSONObject("outputs"); JSONObject outputsJson = execDifyFlow.getJSONObject("outputs");
// 发送MQ String message = JSONObject.toJSONString(outputsJson);
String message = StringEscapeUtils.unescapeJava(JSONObject.toJSONString(outputsJson));
log.info("send mq {}",message); log.info("send mq {}",message);
sendMq(message); sendMq(message);
if(StringUtils.isNotEmpty(fourInOneRequestDTO.getAiAnalysisRequestId())){ if(StringUtils.isNotEmpty(fourInOneRequestDTO.getAiAnalysisRequestId())){
AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors(); AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors();
aiAnalysisErrors.setAiAnalysisRequestId(aiAnalysisRequestId); aiAnalysisErrors.setAiAnalysisRequestId(aiAnalysisRequestId);
@@ -128,7 +126,7 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic
@Override @Override
public void sendMq(String message) { public void sendMq(Object message) {
rocketMqTemplate.asyncSend(topic, MessageBuilder.withPayload(message).build(), rocketMqTemplate.asyncSend(topic, MessageBuilder.withPayload(message).build(),
new SendCallback() { new SendCallback() {
@Override @Override