加日志定位发mq的问题

This commit is contained in:
ZLI263
2025-09-17 13:37:54 +08:00
parent 7ede4bd352
commit 6138acc035

View File

@@ -281,7 +281,9 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
queryWrapper.eq(TmNameplateCorpus::getCustomerFlowId, customerFlowId); queryWrapper.eq(TmNameplateCorpus::getCustomerFlowId, customerFlowId);
List<TmNameplateCorpus> tmNameplateCorpusList = tmNameplateCorpusMapper.selectList(queryWrapper); List<TmNameplateCorpus> tmNameplateCorpusList = tmNameplateCorpusMapper.selectList(queryWrapper);
if (CollectionUtils.isNotEmpty(tmNameplateCorpusList)) { //这是补偿机制 if (CollectionUtils.isNotEmpty(tmNameplateCorpusList)) { //这是补偿机制
log.info("66666666666666"); log.info("66666666666666,customerFlowId={}", customerFlowId);
log.info("tmNameplateCorpusList:{}", tmNameplateCorpusList.toString());
sendNameplateLto(difyJson, aiAnalysisRequestId, tmNameplateCorpusList.get(0), businessType); sendNameplateLto(difyJson, aiAnalysisRequestId, tmNameplateCorpusList.get(0), businessType);
LambdaQueryWrapper<AiAnalysisErrors> errorQueryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<AiAnalysisErrors> errorQueryWrapper = new LambdaQueryWrapper<>();
errorQueryWrapper.eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisRequestId); errorQueryWrapper.eq(AiAnalysisErrors::getAiAnalysisRequestId, aiAnalysisRequestId);
@@ -297,7 +299,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
return ResultMsg.ok(); return ResultMsg.ok();
} }
} catch (Exception e) { } catch (Exception e) {
log.error("updateNameplate error {}", e); log.error("updateNameplate error {}", e.getMessage());
} }