Browse Source

feat: 获取套餐详情接口优化

xdd 2 weeks ago
parent
commit
ade5ef3eba

+ 2 - 1
fs-service-system/src/main/java/com/fs/store/cache/impl/FsStoreProductAttrValueCacheServiceImpl.java

@@ -3,6 +3,7 @@ package com.fs.store.cache.impl;
 import com.fs.store.cache.IFsStoreProductAttrValueCacheService;
 import com.fs.store.domain.FsStoreProductAttrValue;
 import com.fs.store.domain.FsStoreProductPackage;
+import com.fs.store.service.IFsStoreProductAttrValueService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.redis.core.RedisTemplate;
@@ -13,7 +14,7 @@ import org.springframework.stereotype.Service;
 @RequiredArgsConstructor
 public class FsStoreProductAttrValueCacheServiceImpl implements IFsStoreProductAttrValueCacheService {
     private final RedisTemplate<String,Object> redisTemplate;
-    private final IFsStoreProductAttrValueCacheService productAttrValueCacheService;
+    private final IFsStoreProductAttrValueService productAttrValueCacheService;
     @Override
     public FsStoreProductAttrValue selectFsStoreProductAttrValueById(Long id) {
         if(id == null) {

+ 5 - 0
fs-sync/src/main/java/com/fs/fssync/sink/impl/FsStoreProductAttrValueSinkStrategy.java

@@ -25,4 +25,9 @@ public class FsStoreProductAttrValueSinkStrategy extends AbstractCdcSinkStrategy
     public String getKeyPrefix() {
         return "fs:store:product:attr:value:";
     }
+
+    @Override
+    protected String getIdField() {
+        return "id";
+    }
 }

+ 5 - 0
fs-sync/src/main/java/com/fs/fssync/sink/impl/FsStoreProductPackageSinkStrategy.java

@@ -24,4 +24,9 @@ public class FsStoreProductPackageSinkStrategy extends AbstractCdcSinkStrategy<F
     public String getKeyPrefix() {
         return "fs:store:product:package:";
     }
+
+    @Override
+    protected String getIdField() {
+        return "packageId";
+    }
 }

+ 4 - 4
fs-user-app/src/main/java/com/fs/core/config/RedisConfig.java

@@ -13,8 +13,8 @@ import org.springframework.data.redis.serializer.StringRedisSerializer;
 
 /**
  * redis配置
- * 
- 
+ *
+
  */
 @Configuration
 @EnableCaching
@@ -22,9 +22,9 @@ public class RedisConfig extends CachingConfigurerSupport
 {
     @Bean
     @SuppressWarnings(value = { "unchecked", "rawtypes" })
-    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory)
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory)
     {
-        RedisTemplate<Object, Object> template = new RedisTemplate<>();
+        RedisTemplate<String, Object> template = new RedisTemplate<>();
         template.setConnectionFactory(connectionFactory);
 
         FastJson2JsonRedisSerializer serializer = new FastJson2JsonRedisSerializer(Object.class);