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:
zren25
2025-05-28 15:41:12 +08:00
parent d7965e45b9
commit 654433b77e
1 changed files with 10 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -110,18 +110,16 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
for (int i = 1; i <= totalPages; i++) { for (int i = 1; i <= totalPages; i++) {
int offset = (i - 1) * pageSize; int offset = (i - 1) * pageSize;
List<TmNameplateCorpus> messageList = tmNameplateCorpusMapper.queryTmNameplateCorpusRetry(statTime, endTime, offset, pageSize, customerFlowIds, retry); List<TmNameplateCorpus> messageList = tmNameplateCorpusMapper.queryTmNameplateCorpusRetry(statTime, endTime, offset, pageSize, customerFlowIds, retry);
// 处理查询到的数据 for(TmNameplateCorpus tmNameplateCorpus :messageList){
// 使用 CompletableFuture 并行处理 CompletableFuture.runAsync(() -> {
CompletableFuture<?>[] futures = messageList.stream()
.map(item -> CompletableFuture.runAsync(() -> {
try { try {
processItem(item); processItem(tmNameplateCorpus);
} catch (Exception e) { } catch (Exception e) {
log.error("重跑铭牌语料失败: customerFlowId={}, AcceptUserId={}, 异常: {}", log.error("重跑铭牌语料失败: customerFlowId={}, AcceptUserId={}, 异常: {}",
item.getCustomerFlowId(), e.getMessage(), e); tmNameplateCorpus.getCustomerFlowId(), e.getMessage(), e);
}
}, executor);
} }
}, executor))
.toArray(CompletableFuture[]::new);
} }
log.info("重跑铭牌语料铭牌数据跑批结束 耗时：{}",System.currentTimeMillis()-startTime); log.info("重跑铭牌语料铭牌数据跑批结束 耗时：{}",System.currentTimeMillis()-startTime);
} }