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

dcc重构代码

Browse Source
This commit is contained in:
ZLI263
2025-09-22 20:31:19 +08:00
parent f497a90e32
commit 2a34323c51
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
View File

@@ -30,8 +30,8 @@ import java.util.Objects;
@Component @Component
@RefreshScope @RefreshScope
@RestController @RestController
@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}", @RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}",//ai_corpus_Dcc_topic_group
topic = "${rocketmq.consumer.corpus.dcctopic}", topic = "${rocketmq.consumer.corpus.dcctopic}", //ai_corpus_Dcc_topic
instanceName = "CorpusDccMqConsumer1", instanceName = "CorpusDccMqConsumer1",
consumeThreadNumber = 40, consumeThreadNumber = 40,
enableMsgTrace = true) enableMsgTrace = true)
@@ -52,7 +52,7 @@ public class CorpusDccMqConsumer implements RocketMQListener<MessageExt> {
AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class); AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class);
//DCC场景 //DCC场景
if(Objects.equals(aicorpusTelephone.getCategoryCode(), Constant.CHANNEL_DCC)){ if(Objects.equals(aicorpusTelephone.getCategoryCode(), Constant.CHANNEL_DCC)){
tmTelephoneCorpusService.runTelephoneCorpusDify(aicorpusTelephone); tmTelephoneCorpusService.runTelephoneCorpusDify(aicorpusTelephone);
} }
//channel_4in1场景 //channel_4in1场景
if(Objects.equals(aicorpusTelephone.getCategoryCode(), Constant.CHANNEL_4IN1)){ if(Objects.equals(aicorpusTelephone.getCategoryCode(), Constant.CHANNEL_4IN1)){

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) {

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

@@ -181,7 +181,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
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());
log.info("dcc总结场景,总结和分类 runDify execDifyFlow 返回 ： {}", execDifyFlow); log.info("dcc总结场景,总结和分类 runDify execDifyFlow ： {}", execDifyFlow);
parseDfiyResult(execDifyFlow, aicorpusTelephone.getSourceId(), formattedDateStartTime, aicorpusTelephone.getAiAnalysisRequestId(), parseDfiyResult(execDifyFlow, aicorpusTelephone.getSourceId(), formattedDateStartTime, aicorpusTelephone.getAiAnalysisRequestId(),
BusinessTypeEnum.SMART_ASSISTANT.getCode()); BusinessTypeEnum.SMART_ASSISTANT.getCode());
} catch (Exception e) { } catch (Exception e) {
@@ -202,7 +202,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
diFyImageReq.setInputs(inputMap); diFyImageReq.setInputs(inputMap);
diFyImageReq.setFlowId(oneTokenPortrait); diFyImageReq.setFlowId(oneTokenPortrait);
log.info("dcc总结场景,客户画像runDify execDifyFlow 返回 ： {}", oneTokenPortrait); log.info("dcc总结场景,客户画像runDify execDifyFlow ： {}", oneTokenPortrait);
JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode(), JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode(),
JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId()); JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());