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-04-25 16:12:00 +08:00
parent 96c75d3444
commit 81b8a69942
3 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/NameplateCorpusJob.java
View File

@@ -54,7 +54,6 @@ public class NameplateCorpusJob {
tmNameplateCorpusService.runNameplateCorpusDify(param); tmNameplateCorpusService.runNameplateCorpusDify(param);
} catch (Exception e) { } catch (Exception e) {
log.error("nameplateCorpusTask 定时任务补偿处理消息异常",e.getMessage()); log.error("nameplateCorpusTask 定时任务补偿处理消息异常",e.getMessage());
throw new RuntimeException(e);
} }
return ResultMsg.ok(); return ResultMsg.ok();
} }
@@ -79,7 +78,6 @@ public class NameplateCorpusJob {
tmNameplateCorpusService.runNameplateCorpusDifyRetry(param); tmNameplateCorpusService.runNameplateCorpusDifyRetry(param);
} catch (Exception e) { } catch (Exception e) {
log.error("nameplateCorpusTaskFailRetry 定时任务补偿处理消息异常",e.getMessage()); log.error("nameplateCorpusTaskFailRetry 定时任务补偿处理消息异常",e.getMessage());
throw new RuntimeException(e);
} }
return ResultMsg.ok(); return ResultMsg.ok();
} }

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

@@ -86,16 +86,15 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
LocalDate today = LocalDate.now(); LocalDate today = LocalDate.now();
// 获取前一天日期 // 获取前一天日期
LocalDate yesterday = today.minusDays(1); LocalDate yesterday = today.minusDays(1);
boolean retry = false;
// 格式化输出 // 格式化输出
String formattedDate = yesterday.toString(); // 默认格式为 yyyy-MM-dd String formattedDate = yesterday.toString(); // 默认格式为 yyyy-MM-dd
String statTime = formattedDate.concat(" 00:00:00"); String statTime = formattedDate.concat(" 00:00:00");
String endTime = formattedDate.concat(" 23:59:59"); String endTime = formattedDate.concat(" 23:59:59");
if (StringUtils.isNotBlank(paramJson)) { if (StringUtils.isNotBlank(paramJson)) {
JSONObject paramJsonObj = JSONObject.parseObject(paramJson); JSONObject paramJsonObj = JSONObject.parseObject(paramJson);
if (null != paramJsonObj && paramJsonObj.containsKey("statTime") && paramJsonObj.containsKey("endTime")) { if (null != paramJsonObj && paramJsonObj.containsKey(ConstantStr.statTime) && paramJsonObj.containsKey(ConstantStr.endTime)) {
statTime = paramJsonObj.getString("statTime"); statTime = paramJsonObj.getString(ConstantStr.statTime);
endTime = paramJsonObj.getString("endTime"); endTime = paramJsonObj.getString(ConstantStr.endTime);
} }
} }
@@ -146,11 +145,11 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
String endTime = formattedDate.concat(" 23:59:59"); String endTime = formattedDate.concat(" 23:59:59");
if (StringUtils.isNotBlank(paramJson)) { if (StringUtils.isNotBlank(paramJson)) {
JSONObject paramJsonObj = JSONObject.parseObject(paramJson); JSONObject paramJsonObj = JSONObject.parseObject(paramJson);
if (null != paramJsonObj && paramJsonObj.containsKey("statTime") && paramJsonObj.containsKey("endTime")) { if (null != paramJsonObj && paramJsonObj.containsKey(ConstantStr.statTime) && paramJsonObj.containsKey(ConstantStr.endTime)) {
statTime = paramJsonObj.getString("statTime"); statTime = paramJsonObj.getString(ConstantStr.statTime);
endTime = paramJsonObj.getString("endTime"); endTime = paramJsonObj.getString(ConstantStr.endTime);
retry = paramJsonObj.getBoolean("retry"); retry = paramJsonObj.getBoolean("retry");
String customerFlowId = paramJsonObj.getString("customerFlowIds"); String customerFlowId = paramJsonObj.getString(ConstantStr.customerFlowIds);
customerFlowIds = Arrays.asList(customerFlowId.split(",")); customerFlowIds = Arrays.asList(customerFlowId.split(","));
} }
} }
@@ -235,7 +234,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
return; return;
} }
Map<String, String> ltoMap = new HashMap<>(); Map<String, String> ltoMap = new HashMap<>();
ltoMap.put("analysisRecordId", execDifyFlow.getString("aiAnalysisRequestId")); ltoMap.put("analysisRecordId", execDifyFlow.getString(ConstantStr.aiAnalysisRequestId));
ltoMap.put("analysisScene", "3"); ltoMap.put("analysisScene", "3");
ltoMap.put("customerFlowId", tmNameplateCorpus.getCustomerFlowId()); ltoMap.put("customerFlowId", tmNameplateCorpus.getCustomerFlowId());
ltoMap.put("analysisResult", resultStrOne); ltoMap.put("analysisResult", resultStrOne);

4
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/utils/ConstantStr.java
View File

@@ -16,5 +16,9 @@ public class ConstantStr {
public static final String INTELLIGENT_CUSTOMER_4IN1 = "INTELLIGENT_CUSTOMER_4IN1"; public static final String INTELLIGENT_CUSTOMER_4IN1 = "INTELLIGENT_CUSTOMER_4IN1";
public static final String statTime = "statTime";
public static final String endTime = "endTime";
public static final String customerFlowIds = "customerFlowIds";
public static final String aiAnalysisRequestId = "aiAnalysisRequestId";
} }