From 6e2fa38fd333020efa49e9b5a47c9105b11a907d Mon Sep 17 00:00:00 2001
From: mliu71 <min.liu.3@volvocars.com>
Date: Mon, 21 Jul 2025 17:35:44 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=AF=B7=E6=B1=82=E7=94=A8?=
 =?UTF-8?q?=E6=88=B7=E5=90=8D=E7=A7=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../volvo/ai/analytic/center/mq/CorpusQuestionConsumer.java    | 3 +++
 .../java/com/volvo/ai/analytic/center/utils/ConstantStr.java   | 3 +++
 2 files changed, 6 insertions(+)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusQuestionConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusQuestionConsumer.java
index c41bf2a..acf7b91 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusQuestionConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusQuestionConsumer.java
@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.volvo.ai.analytic.center.constant.Constant;
 import com.volvo.ai.analytic.center.feign.DiFyFeign;
+import com.volvo.ai.analytic.center.utils.ConstantStr;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
@@ -34,6 +35,8 @@ public class CorpusQuestionConsumer implements RocketMQListener<Map<String, Obje
         inputMap.put("businessType", Constant.CHANNEL_4IN1);
         log.info("corpusQuestionConsumer {}", JSON.toJSONString(inputMap));
         log.info("corpusQuestionToken {}", corpusQuestionToken);
+        inputMap.put("user", ConstantStr.CORPUS_QUESTION_USER);
+
         JSONObject difyResult = diFyFeign.runWorkflows("Bearer " + corpusQuestionToken, inputMap);
         log.info("difyResult {}", difyResult.toJSONString());
     }
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/utils/ConstantStr.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/utils/ConstantStr.java
index bb9c3cc..b5d0f55 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/utils/ConstantStr.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/utils/ConstantStr.java
@@ -12,6 +12,9 @@ public class ConstantStr {
 	public static final String CHANNEL_DCC = "Channel_Dcc";
 	public static final String corpus_user = "corpush_user";
 
+	public static final String CORPUS_QUESTION_USER = "corpush_question_user";
+
+
 	public static final String CARMODELLIST_CACHEKEY = "ai_carmodellist";
 
 	public static final String INTELLIGENT_CUSTOMER_4IN1 = "INTELLIGENT_CUSTOMER_4IN1";