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

Merge remote-tracking branch 'origin/uat' into uat

Browse Source
This commit is contained in:
lxu75
2025-03-07 16:45:37 +08:00
parent 5b316d34b1 5287eae30a
commit 6738b8debe
2 changed files with 23 additions and 20 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/impl/DiFyServiceImpl.java
View File

@@ -65,7 +65,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)

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

@@ -85,7 +85,6 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
// 拼接 role 和 text
String chat = role + ": " + text;
System.out.println(chat);
inputMap.put("chat",chat);
});
@@ -98,14 +97,14 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){
String text = execDifyFlow.getJSONObject("outputs").getString("text");
String resultStrOne = FlowResultSplitUtil.flowOutputTextSplit(text, "### 任务1", "### 任务2");
String resultStrTwo =FlowResultSplitUtil.flowOutputTextSplit(text, "### 任务2", null);
Map<String, Object> ltoMap = new HashMap();
String resultStrOne = FlowResultSplitUtil.flowOutputTextSplit(text, "任务1", "任务2");
String resultStrTwo =FlowResultSplitUtil.flowOutputTextSplit(text, "任务2", null);
Map<String, String> 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<TmTelephoneCorpusM
}
private String getCarModelList(){
long startTime = System.currentTimeMillis();
CarModelReqDTO carModelReqDTO = new CarModelReqDTO();
carModelReqDTO.setOnSale(10041001);
carModelReqDTO.setIsValid(10041001);
ResultDTO<List<CarModelRespDTO>> cardModelResult= remoteCarModelClient.queryCarModelList(carModelReqDTO);
log.info("queryCarModelList 导出查询耗时开始时间：{}",System.currentTimeMillis()-startTime);
if (BizEnum.SUCCESS.getCode().toString().equals(cardModelResult.getReturnCode()) && CollectionUtils.isNotEmpty(cardModelResult.getData())) {
List<CarModelRespDTO> 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<List<CarModelRespDTO>> cardModelResult= remoteCarModelClient.queryCarModelList(carModelReqDTO);
log.info("queryCarModelList 导出查询耗时开始时间：{}",System.currentTimeMillis()-startTime);
if (BizEnum.SUCCESS.getCode().toString().equals(cardModelResult.getReturnCode()) && CollectionUtils.isNotEmpty(cardModelResult.getData())) {
List<CarModelRespDTO> 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";
}