From 755a18f43e8ad357ee0bcc919430971a4d31e930 Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Thu, 27 Mar 2025 15:45:55 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0redis?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ai-analytic-center-biz/pom.xml                 |  5 +++++
 .../ai/analytic/center/config/RedisConfig.java | 18 ++++++++++++++++++
 .../impl/TmTelephoneCorpusServiceImpl.java     | 18 ++++++++++++++++--
 .../ai/analytic/center/utils/ConstantStr.java  |  2 ++
 4 files changed, 41 insertions(+), 2 deletions(-)
 create mode 100644 ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/RedisConfig.java

diff --git a/ai-analytic-center-biz/pom.xml b/ai-analytic-center-biz/pom.xml
index 2ab5bba..1613d00 100644
--- a/ai-analytic-center-biz/pom.xml
+++ b/ai-analytic-center-biz/pom.xml
@@ -226,6 +226,11 @@
 			<version>2.3.0</version>
 		</dependency>
 
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-redis</artifactId>
+		</dependency>
+
 	</dependencies>
 
 	<build>
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/RedisConfig.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/RedisConfig.java
new file mode 100644
index 0000000..8c513b7
--- /dev/null
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/RedisConfig.java
@@ -0,0 +1,18 @@
+package com.volvo.ai.analytic.center.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+
+@Configuration
+public class RedisConfig {
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
+        RedisTemplate<String, Object> template = new RedisTemplate<>();
+        template.setConnectionFactory(connectionFactory);
+
+        return template;
+    }
+}
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
index dc2726d..5a5367f 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
@@ -34,6 +34,7 @@ import org.apache.rocketmq.spring.core.RocketMQTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.cloud.context.config.annotation.RefreshScope;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.messaging.support.MessageBuilder;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -44,6 +45,7 @@ import java.time.format.DateTimeFormatter;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 
@@ -77,6 +79,9 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 	@Autowired
 	private AiAnalysisRequestLogsService aiAnalysisRequestLogsService;
 
+	@Resource
+	private RedisTemplate<String, Object> redisTemplate;
+
 	@Override
 	@Transactional
 	public void saveTelephoneCorpus(TmTelephoneCorpus tmTelephoneCorpus) {
@@ -117,9 +122,9 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 						String role = analysisInfo.getString("role");
 						String title="";
 						if(role.equals("AGENT")){
-							title="客服:";
+							title="顾问";
 						}else{
-							title="客户:";
+							title="客户";
 						}
 						// 拼接 role 和 text
 						String chat = title + ": " + text;
@@ -176,6 +181,12 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 
 	public String getCarModelList(){
 		try {
+			// 从 Redis 中获取缓存数据
+			String cachedModelNames = (String) redisTemplate.opsForValue().get(ConstantStr.CARMODELLIST_CACHEKEY);
+			if (cachedModelNames != null) {
+				log.info("从缓存中获取车型列表: {}", cachedModelNames);
+				return cachedModelNames;
+			}
 			long startTime = System.currentTimeMillis();
 			CarModelReqDTO carModelReqDTO = new CarModelReqDTO();
 			carModelReqDTO.setOnSale(10041001);
@@ -190,6 +201,9 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 						.collect(Collectors.joining(", ")); // 用逗号和空格拼接
 
 				log.info("拼接后的车型名称: {}", modelNames);
+				// 将结果存入 Redis，设置过期时间为 1 小时
+				redisTemplate.opsForValue().set(ConstantStr.CARMODELLIST_CACHEKEY, modelNames, 5, TimeUnit.DAYS);
+
 				return modelNames;
 			}
 		} catch (Exception e) {
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 6e7aec6..a200176 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
@@ -11,4 +11,6 @@ public class ConstantStr {
 
 	public static final String CHANNEL_DCC = "Channel_Dcc";
 	public static final String corpus_user = "corpush_user";
+
+	public static final String CARMODELLIST_CACHEKEY = "ai_carmodellist";
 }