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

API入参调整

Browse Source
This commit is contained in:
mliu71
2025-07-21 17:50:39 +08:00
parent 43f6debfec
commit f617cebcb3
2 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
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.alibaba.fastjson.JSONObject;
import com.volvo.ai.analytic.center.constant.Constant; import com.volvo.ai.analytic.center.constant.Constant;
import com.volvo.ai.analytic.center.feign.DiFyFeign; import com.volvo.ai.analytic.center.feign.DiFyFeign;
import com.volvo.ai.analytic.center.utils.ConstantStr;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener; import org.apache.rocketmq.spring.core.RocketMQListener;
@@ -12,6 +13,7 @@ import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.Map; import java.util.Map;
@Slf4j @Slf4j
@@ -34,7 +36,13 @@ public class CorpusQuestionConsumer implements RocketMQListener<Map<String, Obje
inputMap.put("businessType", Constant.CHANNEL_4IN1); inputMap.put("businessType", Constant.CHANNEL_4IN1);
log.info("corpusQuestionConsumer {}", JSON.toJSONString(inputMap)); log.info("corpusQuestionConsumer {}", JSON.toJSONString(inputMap));
log.info("corpusQuestionToken {}", corpusQuestionToken); log.info("corpusQuestionToken {}", corpusQuestionToken);
JSONObject difyResult = diFyFeign.runWorkflows("Bearer " + corpusQuestionToken, inputMap);
log.info("difyResult {}", difyResult.toJSONString()); Map<String, Object> requestMap = new HashMap<>();
requestMap.put("inputs", inputMap);
requestMap.put("user", ConstantStr.CORPUS_QUESTION_USER);
requestMap.put("response_mode","blocking");
JSONObject difyResult = diFyFeign.runWorkflows("Bearer " + corpusQuestionToken, requestMap);
log.info("dify corpusQuestionResult {}", 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 CHANNEL_DCC = "Channel_Dcc";
public static final String corpus_user = "corpush_user"; 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 CARMODELLIST_CACHEKEY = "ai_carmodellist";
public static final String INTELLIGENT_CUSTOMER_4IN1 = "INTELLIGENT_CUSTOMER_4IN1"; public static final String INTELLIGENT_CUSTOMER_4IN1 = "INTELLIGENT_CUSTOMER_4IN1";