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

加回铭牌解析

Browse Source
This commit is contained in:
ZLI263
2025-09-23 11:12:29 +08:00
parent 22efe8a413
commit 4028257652
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/mq/NameplateKafkaConsumer.java
View File

@@ -62,7 +62,7 @@ public class NameplateKafkaConsumer {
return; return;
} }
// 临时去掉 tmNameplateCorpus.getData().forEach(nameplate -> tmNameplateCorpusService.processItem(nameplate)); tmNameplateCorpus.getData().forEach(nameplate -> tmNameplateCorpusService.processItem(nameplate));
log.info("nameplateKafkaConsumeracknowledge：{}",partitionId, offset); log.info("nameplateKafkaConsumeracknowledge：{}",partitionId, offset);
// 手动提交 offset // 手动提交 offset
} catch (Exception e) { } catch (Exception e) {

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

@@ -223,11 +223,11 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
corpusReportDTO.setAnalysisScene(1l); corpusReportDTO.setAnalysisScene(1l);
// 获取配置 // 获取配置
JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT_QIWEI.getCode(), JSONObject.toJSONString(corpusReportDTO),null); JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT_QIWEI.getCode(), JSONObject.toJSONString(corpusReportDTO),null);
log.info("runDify execDifyFlow {}", execDifyFlow); log.info("runDify execDifyFlow send mq 企微 {}", execDifyFlow);
if (null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")) { if (null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")) {
JSONObject text = execDifyFlow.getJSONObject("outputs"); JSONObject text = execDifyFlow.getJSONObject("outputs");
// 发送MQ // 发送MQ
log.info("send mq {}", text); log.info("send mq 企微 {}", text);
tmTelephoneCorpusService.sendMq( CategoryEnum.ENTERPRISE_WECHAT.getCode(), text.toJSONString()); tmTelephoneCorpusService.sendMq( CategoryEnum.ENTERPRISE_WECHAT.getCode(), text.toJSONString());
try { try {
@@ -262,10 +262,10 @@ public class TmOdsVdqwMessagearchivingServiceImpl extends ServiceImpl<TmOdsVdqwM
diFyImageReq2.setInputs(inputMap2); diFyImageReq2.setInputs(inputMap2);
// 创建新的DiFyReq对象以避免线程安全问题 // 创建新的DiFyReq对象以避免线程安全问题
diFyImageReq2.setFlowId(oneTokenPortrait); diFyImageReq2.setFlowId(oneTokenPortrait);
log.info("runDify execDifyFlow ,客户画像场景 ，token-{} , 对象： {}", oneTokenPortrait, diFyImageReq2); log.info("runDify execDifyFlow ,企微客户画像场景 ，token-{} , 对象： {}", oneTokenPortrait, diFyImageReq2);
JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq2, BusinessTypeEnum.CORPUS_PORTRAIT_QIWEI.getCode(), JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq2, BusinessTypeEnum.CORPUS_PORTRAIT_QIWEI.getCode(),
JSONObject.toJSONString(corpusReportDTO), null); JSONObject.toJSONString(corpusReportDTO), null);
log.info("runDify execDifyFlow ,客户画像场景 ，返回-{} ", execDifyFlowForPortrait); log.info("runDify execDifyFlow ,企微客户画像场景 ，返回-{} ", execDifyFlowForPortrait);
JSONObject text = execDifyFlowForPortrait.getJSONObject("outputs"); JSONObject text = execDifyFlowForPortrait.getJSONObject("outputs");
// 发送MQ // 发送MQ