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-17 17:51:03 +08:00
parent ada7546443
commit 67820e3db9
1 changed files with 2 additions and 4 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/service/impl/TmNameplateCorpusServiceImpl.java
View File

@@ -152,7 +152,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
inputMap.put("analysisScene", "3"); inputMap.put("analysisScene", "3");
inputMap.put("version", 2); inputMap.put("version", 2);
inputMap.put("businessType", BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode()); inputMap.put("businessType", BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode());
inputMap.put("chat", corpusChat);
diFyImageReq.setInputs(inputMap); diFyImageReq.setInputs(inputMap);
CorpusReportDTO corpusReportDTO = new CorpusReportDTO(); CorpusReportDTO corpusReportDTO = new CorpusReportDTO();
@@ -161,14 +161,13 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
corpusReportDTO.setCarModel(carModel); corpusReportDTO.setCarModel(carModel);
// 获取配置 // 获取配置
// 使用多线程并行执行两个业务场景 // 使用多线程并行执行两个业务场景
ExecutorService executorService = Executors.newFixedThreadPool(2); ExecutorService executorService = Executors.newFixedThreadPool(2);
log.info("第1个业务场景， 优先执行。 "); log.info("第1个业务场景， 优先执行。 ");
long startTime = System.currentTimeMillis(); long startTime = System.currentTimeMillis();
CompletableFuture<Void> summaryFuture = CompletableFuture.runAsync(() -> { CompletableFuture<Void> summaryFuture = CompletableFuture.runAsync(() -> {
//第一个业务场景 开始： 总结和分类业务场景 //第一个业务场景 开始： 总结和分类业务场景
JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode(), JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode(),
JSONObject.toJSONString(corpusReportDTO), null); JSONObject.toJSONString(corpusReportDTO), null);
log.info("runDify execDifyFlow ,铭牌语料 ，总结和分类业务，返回： {}", execDifyFlow); log.info("runDify execDifyFlow ,铭牌语料 ，总结和分类业务，返回： {}", execDifyFlow);
}, executorService); }, executorService);
@@ -217,7 +216,6 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
try { try {
log.info("铭牌sendNameplateLto toJSONString :{}", execDifyFlow); log.info("铭牌sendNameplateLto toJSONString :{}", execDifyFlow);
log.info("铭牌send mq 业务类型是：{},", businessType);
log.info("tmNameplateCorpus.tostrign:{}", tmNameplateCorpus.toString()); log.info("tmNameplateCorpus.tostrign:{}", tmNameplateCorpus.toString());
if (execDifyFlow.get("status").equals("succeeded")) { if (execDifyFlow.get("status").equals("succeeded")) {