diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java index 1ed0cb0..18dc11c 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java @@ -64,7 +64,7 @@ public class DiFyServiceImpl implements DiFyService{ // 保存请求日志 aiAnalysisRequestLogsMapper.insert(AiAnalysisRequestLogs.builder() .aiAnalysisRequestId(aiAnalysisRequestId) - .businessRequest("") + .businessRequest(JSONObject.toJSONString("")) .difyAgentKey(diFyReq.getFlowId()) .difyRequest(JSON.toJSONString(diFyReq)) .aiAnalysisRequestType(businessType) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java index 68d88ef..3bba793 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java @@ -85,7 +85,6 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl ltoMap = new HashMap(); + String resultStrOne = FlowResultSplitUtil.flowOutputTextSplit(text, "任务1", "任务2"); + String resultStrTwo =FlowResultSplitUtil.flowOutputTextSplit(text, "任务2", null); + Map ltoMap = new HashMap(); ltoMap.put("analysisRecordId", aicorpusTelephone.getSourceId()); ltoMap.put("analysisScene", "2"); // ltoMap.put("unionId", aicorpusTelephone.getSourceId()); ltoMap.put("recordId", aicorpusTelephone.getSourceId()); - ltoMap.put("communicateDate", jsonObject.get("start_time")); + ltoMap.put("communicateDate", jsonObject.getString("start_time")); ltoMap.put("analysisResult", resultStrOne); ltoMap.put("analysisDetail", resultStrTwo); // 发送MQ @@ -128,21 +127,25 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl> cardModelResult= remoteCarModelClient.queryCarModelList(carModelReqDTO); - log.info("queryCarModelList 导出查询耗时开始时间:{}",System.currentTimeMillis()-startTime); - if (BizEnum.SUCCESS.getCode().toString().equals(cardModelResult.getReturnCode()) && CollectionUtils.isNotEmpty(cardModelResult.getData())) { - List carModelRespDTOList = cardModelResult.getData(); - // 拼接 modelName - String modelNames = carModelRespDTOList.stream() - .map(CarModelRespDTO::getModelName) // 提取 modelName - .collect(Collectors.joining(", ")); // 用逗号和空格拼接 + try { + long startTime = System.currentTimeMillis(); + CarModelReqDTO carModelReqDTO = new CarModelReqDTO(); + carModelReqDTO.setOnSale(10041001); + carModelReqDTO.setIsValid(10041001); + ResultDTO> cardModelResult= remoteCarModelClient.queryCarModelList(carModelReqDTO); + log.info("queryCarModelList 导出查询耗时开始时间:{}",System.currentTimeMillis()-startTime); + if (BizEnum.SUCCESS.getCode().toString().equals(cardModelResult.getReturnCode()) && CollectionUtils.isNotEmpty(cardModelResult.getData())) { + List carModelRespDTOList = cardModelResult.getData(); + // 拼接 modelName + String modelNames = carModelRespDTOList.stream() + .map(CarModelRespDTO::getModelName) // 提取 modelName + .collect(Collectors.joining(", ")); // 用逗号和空格拼接 - log.info("拼接后的车型名称: {}", modelNames); - return modelNames; + log.info("拼接后的车型名称: {}", modelNames); + return modelNames; + } + } catch (Exception e) { + log.error("getCarModelList Exception: {}", e); } return "C40 RECHARGE、EM90、EX30、S60、S90、V60、V90、XC40、XC40 RECHARGE、XC60、XC90"; }