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:
ZLI263
2025-09-16 22:03:21 +08:00
parent e5ea39b58e
commit 020a40d013
2 changed files with 7 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/job/QiWeiCorpusJob.java
View File

@@ -82,9 +82,9 @@ public class QiWeiCorpusJob {
// 执行业务逻辑
XxlJobHelper.log("dccCorpusFailRetry任务参数: {}", param);
List<AicorpusTelephoneDTO> corpusDtoList = tmTelephoneCorpusMapper.queryTelephoneCorpusBySourceIds( Arrays.asList(param.split(",")));
corpusDtoList.stream().forEach(item-> {
tmTelephoneCorpusService.runTelephoneCorpusDify(item);
});
corpusDtoList.stream().forEach(item->
tmTelephoneCorpusService.runTelephoneCorpusDify(item)
);
} catch (Exception e) {
log.error(PROCESS_MESSAGE_TASK_ERROR,e.getMessage());
throw new JobTaskException(PROCESS_MESSAGE_TASK_ERROR, e);

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

@@ -209,6 +209,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
String outputsFinal="outputs";
String aiAnalysisRequestIdFinal = "aiAnalysisRequestId";
@Override
public void sendNameplateLto(JSONObject execDifyFlow,String aiAnalysisRequestId, TmNameplateCorpus tmNameplateCorpus,String businessType) {
log.info("铭牌sendNameplateLto getCustomerFlowId:{}", tmNameplateCorpus.getCustomerFlowId());
@@ -237,7 +238,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
if(StringUtils.isNotEmpty(message)){
log.info("updateNameplate 回调 message: {}", message);
JSONObject analysisResp = JSONObject.parseObject(message);
String aiAnalysisRequestId = analysisResp.getString("aiAnalysisRequestId");
String aiAnalysisRequestId = analysisResp.getString(aiAnalysisRequestIdFinal);
String difyResponse = analysisResp.getString("difyResponse");
String customerFlowId = analysisResp.getString("customerFlowId");
@@ -247,10 +248,10 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
String businessType = outputs.getString("businessType");
if (aiAnalysisRequestId==null){
aiAnalysisRequestId = outputs.getString("aiAnalysisRequestId");
aiAnalysisRequestId = outputs.getString(aiAnalysisRequestIdFinal);
}
log.info("aiAnalysisRequestId is : ",analysisResp.getString("aiAnalysisRequestId"));
log.info("aiAnalysisRequestId is : ",analysisResp.getString(aiAnalysisRequestIdFinal));
log.info("businessType is : ", businessType);
if (aiAnalysisRequestId.indexOf(BusinessTypeEnum.CORPUS_PORTRAIT_NAMEPLATE.getCode())>=0){