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

(cherry picked from commit ade5ef3ebab0351af8673a48d6d88805e5b1c87a)

deploy.sh

@@ -83,13 +83,13 @@ deploy_jar() {
 # 部署 fs-admin
 deploy_jar "$LOCAL_FS_ADMIN_JAR" "fs-admin"
 
-deploy_jar "$LOCAL_FS_API_JAR" "fs-api"
+#deploy_jar "$LOCAL_FS_API_JAR" "fs-api"
 
 # 部署 fs-company
-deploy_jar "$LOCAL_FS_COMPANY_JAR" "fs-company"
+#deploy_jar "$LOCAL_FS_COMPANY_JAR" "fs-company"
 
 # 部署 fs-user-app
-deploy_jar "$LOCAL_FS_USER_APP_JAR" "fs-user-app"
+#deploy_jar "$LOCAL_FS_USER_APP_JAR" "fs-user-app"
 
 echo "Deployment completed."
 

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) {

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

@@ -0,0 +1,33 @@
+package com.fs.fssync.sink.impl;
+
+import com.fs.fssync.sink.AbstractCdcSinkStrategy;
+import com.fs.store.domain.FsStoreProduct;
+import com.fs.store.domain.FsStoreProductAttrValue;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.io.Serializable;
+
+@Slf4j
+@Component
+public class FsStoreProductAttrValueSinkStrategy extends AbstractCdcSinkStrategy<FsStoreProductAttrValue> implements Serializable {
+    @Override
+    public boolean canHandle(String table) {
+        return "fs_store_product_attr_value".equals(table);
+    }
+
+    @Override
+    public Class<FsStoreProductAttrValue> getEntityClass() {
+        return FsStoreProductAttrValue.class;
+    }
+
+    @Override
+    public String getKeyPrefix() {
+        return "fs:store:product:attr:value:";
+    }
+
+    @Override
+    protected String getIdField() {
+        return "id";
+    }
+}

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

@@ -0,0 +1,32 @@
+package com.fs.fssync.sink.impl;
+
+import com.fs.fssync.sink.AbstractCdcSinkStrategy;
+import com.fs.store.domain.FsStoreProduct;
+import com.fs.store.domain.FsStoreProductPackage;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.io.Serializable;
+@Slf4j
+@Component
+public class FsStoreProductPackageSinkStrategy extends AbstractCdcSinkStrategy<FsStoreProductPackage> implements Serializable {
+    @Override
+    public boolean canHandle(String table) {
+        return "fs_store_product_package".equals(table);
+    }
+
+    @Override
+    public Class<FsStoreProductPackage> getEntityClass() {
+        return FsStoreProductPackage.class;
+    }
+
+    @Override
+    public String getKeyPrefix() {
+        return "fs:store:product:package:";
+    }
+
+    @Override
+    protected String getIdField() {
+        return "packageId";
+    }
+}

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);