修改回调取值
This commit is contained in:
@@ -43,7 +43,7 @@ public class CorpushIsLikeConsumer implements RocketMQListener<MessageExt>{
|
|||||||
if(execDifyFlow.containsKey("aiAnalysisRequestType")){
|
if(execDifyFlow.containsKey("aiAnalysisRequestType")){
|
||||||
aiAnalysisRequestType = execDifyFlow.getString("aiAnalysisRequestType");
|
aiAnalysisRequestType = execDifyFlow.getString("aiAnalysisRequestType");
|
||||||
}
|
}
|
||||||
if(StringUtils.isEmpty(aiAnalysisRequestType) && execDifyFlow.containsKey("isLike")){
|
if(StringUtils.isEmpty(aiAnalysisRequestType) ){
|
||||||
aiAnalysisRequestType= analysisRecordId.substring(0,analysisRecordId.indexOf("-"));
|
aiAnalysisRequestType= analysisRecordId.substring(0,analysisRecordId.indexOf("-"));
|
||||||
}
|
}
|
||||||
tmAnalysisResultService.saveTmCorpusReport(TmAnalysisResult.builder()
|
tmAnalysisResultService.saveTmCorpusReport(TmAnalysisResult.builder()
|
||||||
@@ -53,7 +53,7 @@ public class CorpushIsLikeConsumer implements RocketMQListener<MessageExt>{
|
|||||||
.updateTime(new Date())
|
.updateTime(new Date())
|
||||||
.build());
|
.build());
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
log.info(" 电话语料处理保存报告异常processItem:{} ", e);
|
log.info(" corpushIsLikeConsumer AI结果回传处理异常:{} ", e);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user