加日志,发送mq之前

This commit is contained in:
ZLI263
2025-09-17 11:43:14 +08:00
parent 9031a352bc
commit 6e98fa3550

View File

@@ -213,6 +213,8 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
@Override
public void sendNameplateLto(JSONObject execDifyFlow,String aiAnalysisRequestId, TmNameplateCorpus tmNameplateCorpus,String businessType) {
log.info("铭牌sendNameplateLto getCustomerFlowId:{}", tmNameplateCorpus.getCustomerFlowId());
log.info("铭牌sendNameplateLto text contnt :{}", execDifyFlow.toString());
if (null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")) {
String text = execDifyFlow.getString(outputsFinal);
// 发送MQ
@@ -248,7 +250,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
AiAnalysisRequestLogs aiAnalysisRequestLogs = new AiAnalysisRequestLogs();
JSONObject difyJson =null;
if (StringUtils.isEmpty(customerFlowId)){ // 客户画像场景
log.info(" customerFlowId 为空,客户画像场景");
log.info("customerFlowId 为空,客户画像场景");
String text = analysisResp.getString(outputsFinal);
JSONObject outputs = JSONObject.parseObject(text);
customerFlowId = outputs.getString("businessId");