admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加请求用户名称

Browse Source
This commit is contained in:
mliu71
2025-07-21 17:35:44 +08:00
parent 43f6debfec
commit 6e2fa38fd3
2 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusQuestionConsumer.java
View File

@@ -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());
}

3
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/utils/ConstantStr.java
View File

@@ -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";