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 21:59:20 +08:00
parent b9d12b8542
commit e5ea39b58e
2 changed files with 7 additions and 7 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

@@ -105,9 +105,9 @@ public class QiWeiCorpusJob {
// 执行业务逻辑 // 执行业务逻辑
XxlJobHelper.log("dccCorpusFailRetry任务参数: {}", param); XxlJobHelper.log("dccCorpusFailRetry任务参数: {}", 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->
corpusPortraitService.portraitDcc(item); corpusPortraitService.portraitDcc(item)
}); );
} catch (Exception e) { } catch (Exception e) {
log.error(PROCESS_MESSAGE_TASK_ERROR,e.getMessage()); log.error(PROCESS_MESSAGE_TASK_ERROR,e.getMessage());
throw new JobTaskException(PROCESS_MESSAGE_TASK_ERROR, e); throw new JobTaskException(PROCESS_MESSAGE_TASK_ERROR, e);

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

@@ -208,12 +208,12 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
String outputsFinal="outputs";
@Override @Override
public void sendNameplateLto(JSONObject execDifyFlow,String aiAnalysisRequestId, TmNameplateCorpus tmNameplateCorpus,String businessType) { public void sendNameplateLto(JSONObject execDifyFlow,String aiAnalysisRequestId, TmNameplateCorpus tmNameplateCorpus,String businessType) {
log.info("铭牌sendNameplateLto getCustomerFlowId:{}", tmNameplateCorpus.getCustomerFlowId()); log.info("铭牌sendNameplateLto getCustomerFlowId:{}", tmNameplateCorpus.getCustomerFlowId());
if (null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")) { if (null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")) {
String text = execDifyFlow.getString("outputs"); String text = execDifyFlow.getString(outputsFinal);
// 发送MQ // 发送MQ
log.info("铭牌send mq 业务类型是：{}, Json 是：{}", businessType, text); log.info("铭牌send mq 业务类型是：{}, Json 是：{}", businessType, text);
if (BusinessTypeEnum.CORPUS_PORTRAIT_NAMEPLATE.getCode().equals(businessType)) {// 客户画像 if (BusinessTypeEnum.CORPUS_PORTRAIT_NAMEPLATE.getCode().equals(businessType)) {// 客户画像
@@ -241,7 +241,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
String difyResponse = analysisResp.getString("difyResponse"); String difyResponse = analysisResp.getString("difyResponse");
String customerFlowId = analysisResp.getString("customerFlowId"); String customerFlowId = analysisResp.getString("customerFlowId");
String text = analysisResp.getString("outputs"); String text = analysisResp.getString(outputsFinal);
JSONObject outputs = JSONObject.parseObject(text); JSONObject outputs = JSONObject.parseObject(text);
String businessId = outputs.getString("businessId"); String businessId = outputs.getString("businessId");
String businessType = outputs.getString("businessType"); String businessType = outputs.getString("businessType");
@@ -269,7 +269,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
aiAnalysisRequestLogs.setDifyResponse(difyResponse); aiAnalysisRequestLogs.setDifyResponse(difyResponse);
JSONObject difyJson = JSONObject.parseObject(difyResponse); JSONObject difyJson = JSONObject.parseObject(difyResponse);
aiAnalysisRequestLogs.setBusinessResponse(difyJson.getString("outputs")); aiAnalysisRequestLogs.setBusinessResponse(difyJson.getString(outputsFinal));
aiAnalysisRequestLogs.setAiAnalysisRequestType(businessType); aiAnalysisRequestLogs.setAiAnalysisRequestType(businessType);
aiAnalysisRequestLogsService.saveOrUpdateAiAnalysisRequestLogs(aiAnalysisRequestLogs); aiAnalysisRequestLogsService.saveOrUpdateAiAnalysisRequestLogs(aiAnalysisRequestLogs);
log.info("333333333333"); log.info("333333333333");