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

定位不推lto。加日志

Browse Source
This commit is contained in:
ZLI263
2025-09-19 20:30:56 +08:00
parent 0a73b49a90
commit 4f687e346a
2 changed files with 5 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/impl/DiFyServiceImpl.java
View File

@@ -91,7 +91,7 @@ public class DiFyServiceImpl implements DiFyService{
.aiAnalysisRequestType(businessType) .aiAnalysisRequestType(businessType)
.build()); .build());
log.info("给dify平台的数据 ,type: {}, 参数：{}",businessType,map); log.info("给dify平台的数据 ,type: {}, 参数：{}",businessType,diFyReq);
JSONObject difyResult = diFyFeign.runWorkflows("Bearer "+diFyReq.getFlowId(),map); JSONObject difyResult = diFyFeign.runWorkflows("Bearer "+diFyReq.getFlowId(),map);
JSONObject data = difyResult.getJSONObject("data"); JSONObject data = difyResult.getJSONObject("data");
log.debug("execDifyFlow dify response aiID:{} , data:{}",aiAnalysisRequestId,data); log.debug("execDifyFlow dify response aiID:{} , data:{}",aiAnalysisRequestId,data);

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

@@ -121,7 +121,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
Map<String, Object> inputMap = new HashMap(); Map<String, Object> inputMap = new HashMap();
DiFyReq diFyImageReq = new DiFyReq(); DiFyReq diFyImageReq = new DiFyReq();
diFyImageReq.setUser(ConstantStr.corpus_user); diFyImageReq.setUser(ConstantStr.corpus_user);
diFyImageReq.setFlowId(telephoneToken);
JSONObject jsonObject = JSONObject.parseObject( aicorpusTelephone.getDisplay()); JSONObject jsonObject = JSONObject.parseObject( aicorpusTelephone.getDisplay());
@@ -170,6 +170,8 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
log.info("铭牌语料可用许可授权数，总结和分类场景={}", semaphore.availablePermits()); log.info("铭牌语料可用许可授权数，总结和分类场景={}", semaphore.availablePermits());
// 获取许可 - 如果没有可用许可会阻塞等待 // 获取许可 - 如果没有可用许可会阻塞等待
semaphore.acquire(); semaphore.acquire();
diFyImageReq.setFlowId(telephoneToken);
log.info("铭牌语料telephoneToken：", telephoneToken);
JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(), JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(),
JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId()); JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
@@ -242,7 +244,6 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
ltoMap.put("communicateDate", communicateDate); ltoMap.put("communicateDate", communicateDate);
ltoMap.put("analysisResult", resultStrOne); ltoMap.put("analysisResult", resultStrOne);
ltoMap.put("analysisDetail", resultStrTwo); ltoMap.put("analysisDetail", resultStrTwo);
// 发送MQ // 发送MQ
if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像 if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像
log.info("send mq 电话语料场景，客户画像需求， {}",ltoMap); log.info("send mq 电话语料场景，客户画像需求， {}",ltoMap);
@@ -251,7 +252,6 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
log.info("send mq 电话语料场景，总结需求， {}",ltoMap); log.info("send mq 电话语料场景，总结需求， {}",ltoMap);
sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(ltoMap)); sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(ltoMap));
} }
try { try {
if(StringUtils.isNotEmpty(aiAnalysisRequestIdDB)){ if(StringUtils.isNotEmpty(aiAnalysisRequestIdDB)){
AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors(); AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors();
@@ -268,7 +268,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
log.info("dcc语料 parseDfiyResult 非正常状态"); log.info("dcc语料 parseDfiyResult 非正常状态");
} }
}catch (Exception e){ }catch (Exception e){
log.error("dcc语料 parseDfiyResult 异常，businessType: {} execDifyFlow: {}", businessType,execDifyFlow, e); log.error("dcc语料 parseDfiyResult 异常，businessType: {} error: {}", businessType, e);
} }