修改回调类型处理

This commit is contained in:
zren25
2025-04-09 14:31:15 +08:00
parent 2323f96393
commit 843738d5f2

View File

@@ -39,12 +39,10 @@ public class CorpushIsLikeConsumer implements RocketMQListener<MessageExt>{
log.info(" 回调的aiAnalysisRequestId 为空:{} ", execDifyFlow);
return;
}
String aiAnalysisRequestType = "";
if(execDifyFlow.containsKey("aiAnalysisRequestType")){
aiAnalysisRequestType = execDifyFlow.getString("aiAnalysisRequestType");
}
String aiAnalysisRequestType = analysisRecordId.substring(0,analysisRecordId.indexOf("-"));;
if(StringUtils.isEmpty(aiAnalysisRequestType) ){
aiAnalysisRequestType= analysisRecordId.substring(0,analysisRecordId.indexOf("-"));
log.info(" 回调的aiAnalysisRequestType为空:{} ", aiAnalysisRequestType);
return;
}
//   "isLike": "1" // 1点赞2点踩
tmAnalysisResultService.saveTmCorpusReport(TmAnalysisResult.builder()