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

sonar

Browse Source
This commit is contained in:
zren25
2025-03-26 19:50:39 +08:00
parent b40b763c15
commit 5e06114292
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/QiWeiCorpusJob.java
View File

@@ -55,9 +55,9 @@ public class QiWeiCorpusJob {
return ResultMsg.ok(); return ResultMsg.ok();
} }
@XxlJob("DccCorpusFailRetry") @XxlJob("dccCorpusFailRetry")
@PostMapping("dccCorpusFailRetry") @PostMapping("dccCorpusFailRetry")
public ResultMsg DccCorpusFailRetry(@RequestBody String paramJson) { public ResultMsg dccCorpusFailRetry(@RequestBody String paramJson) {
try { try {
// 获取任务参数 // 获取任务参数
String param = XxlJobHelper.getJobParam(); String param = XxlJobHelper.getJobParam();
@@ -67,9 +67,7 @@ public class QiWeiCorpusJob {
// 执行业务逻辑 // 执行业务逻辑
XxlJobHelper.log("任务参数: {}", param); XxlJobHelper.log("任务参数: {}", param);
List<AicorpusTelephoneDTO> corpusDtoList = tmTelephoneCorpusMapper.queryTelephoneCorpusBySourceIds( Arrays.asList(param.split(","))); List<AicorpusTelephoneDTO> corpusDtoList = tmTelephoneCorpusMapper.queryTelephoneCorpusBySourceIds( Arrays.asList(param.split(",")));
corpusDtoList.stream().forEach(item->{ corpusDtoList.stream().forEach(item-> tmTelephoneCorpusService.runTelephoneCorpusDify(item));
tmTelephoneCorpusService.runTelephoneCorpusDify(item);
});
} catch (Exception e) { } catch (Exception e) {
log.error("processMessageByTask 定时任务补偿处理消息异常",e.getMessage()); log.error("processMessageByTask 定时任务补偿处理消息异常",e.getMessage());
throw new RuntimeException(e); throw new RuntimeException(e);