购物车后台

muyu-modules/muyu-product/muyu-product-cache/src/main/java/com/muyu/product/cache/datasource/impl/ProjectInfoDataRemoteImpl.java

@@ -5,6 +5,7 @@ import com.muyu.product.cache.datasource.ProjectInfoData;
 import com.muyu.product.domain.ProjectInfo;
 import com.muyu.product.remote.RemoteProjectInfoService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Service;
 
 /**

muyu-modules/muyu-product/muyu-product-cache/src/main/java/com/muyu/product/cache/datasource/impl/ProjectSkuDataRemoteImpl.java

@@ -5,6 +5,7 @@ import com.muyu.product.cache.datasource.ProjectSkuData;
 import com.muyu.product.domain.ProjectSkuInfo;
 import com.muyu.product.remote.RemoteProjectSkuService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Service;
 
 import java.util.HashMap;

muyu-modules/muyu-product/muyu-product-cache/src/main/java/com/muyu/product/cache/datasource/impl/ProjectSkuStockDataRemoteImpl.java

@@ -11,24 +11,23 @@ import org.springframework.stereotype.Service;
 import java.util.Objects;
 
 /**
- * ProjectSkuStockDataImpl
+ * @author DongZl
- *
+ * @description: sku库存实现类
- * @author DeKangLiu
+ * @Date 2024-4-2 上午 10:53
- * on 2024/4/8
  */
 @Service
 public class ProjectSkuStockDataRemoteImpl implements ProjectSkuStockData {
 
     @Autowired
     private RemoteProjectSkuService remoteProjectSkuService;
+
     @Override
     public Long getData (SkuStockKey key) {
-        Result<ProjectSkuInfo> result =
+        Result<ProjectSkuInfo> result
-                remoteProjectSkuService.getInfoByProjectIdAndSku(key.getProjectId(), key.getSku());
+                = remoteProjectSkuService.getInfoByProjectIdAndSku(key.getProjectId(), key.getSku());
-
         if (Result.isSuccess(result)){
             ProjectSkuInfo projectSkuInfo = result.getData();
-            if (Objects.isNull(projectSkuInfo)){
+            if (!Objects.isNull(projectSkuInfo)){
                 return projectSkuInfo.getStock();
             }
         }

muyu-modules/muyu-product/muyu-product-cache/src/main/java/com/muyu/product/cache/datasource/impl/RuleCacheDataRemoteImpl.java

@@ -9,6 +9,7 @@ import com.muyu.product.domain.RuleInfo;
 import com.muyu.product.remote.RemoteRuleAttrService;
 import com.muyu.product.remote.RemoteRuleService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Service;
 
 import java.util.List;

muyu-modules/muyu-product/muyu-product-remote/src/main/java/com/muyu/product/remote/RemoteProjectInfoService.java

@@ -9,10 +9,9 @@ import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 
 /**
- * RemoteProjectInfoService
+ * @author DongZl
- *
+ * @description: 规格远程调用业务层
- * @author DeKangLiu
+ * @Date 2024-4-7 上午 10:58
- * on 2024/4/8
  */
 @FeignClient(
         contextId = "remoteProjectInfoService",
@@ -21,10 +20,10 @@ import org.springframework.web.bind.annotation.PathVariable;
         path = "/info"
 )
 public interface RemoteProjectInfoService {
-
     /**
      * 获取商品信息详细信息
      */
     @GetMapping(value = "/{id}")
     public Result<ProjectInfo> getInfo(@PathVariable("id") Long id) ;
+
 }

muyu-modules/muyu-product/muyu-product-remote/src/main/java/com/muyu/product/remote/RemoteProjectSkuService.java

@@ -32,7 +32,11 @@ public interface RemoteProjectSkuService {
     @GetMapping("/info/{projectId}/{projectSku}")
     public Result<ProjectSkuInfo> getInfoByProjectIdAndSku(@PathVariable("projectId") Long projectId,
                                                            @PathVariable("projectSku") String projectSku);
-
+    /**
+     * 通过商品ID和SKU获取SKU信息
+     * @param projectId 商品ID
+     * @return 商品SKU信息
+     */
     @GetMapping("/list/{projectId}")
     public Result<List<ProjectSkuInfo>> listByProjectId(@PathVariable("projectId") Long projectId);
 }

muyu-modules/muyu-product/muyu-product-remote/src/main/java/com/muyu/product/remote/RemoteRuleAttrService.java

@@ -4,7 +4,6 @@ import com.muyu.common.core.constant.ServiceNameConstants;
 import com.muyu.common.core.domain.Result;
 import com.muyu.product.domain.RuleAttrInfo;
 import com.muyu.product.remote.factory.RemoteRuleAttrFactory;
-import com.muyu.product.remote.factory.RemoteRuleFactory;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -12,10 +11,9 @@ import org.springframework.web.bind.annotation.PathVariable;
 import java.util.List;
 
 /**
- * RemoteRuleAttrService
+ * @author DongZl
- *
+ * @description: 规格信息远程调用业务层
- * @author DeKangLiu
+ * @Date 2024-4-7 上午 10:58
- * on 2024/4/8
  */
 @FeignClient(
         contextId = "remoteRuleAttrService",
@@ -24,6 +22,9 @@ import java.util.List;
         path = "/ruleAttr"
 )
 public interface RemoteRuleAttrService {
+    /**
+     * 获取规格详情详细信息
+     */
     @GetMapping(value = "/list/ruleId/{ruleId}")
     public Result<List<RuleAttrInfo>> getInfoByRuleId(@PathVariable("ruleId") Long id);
 }

muyu-modules/muyu-product/muyu-product-remote/src/main/java/com/muyu/product/remote/RemoteRuleService.java

@@ -3,17 +3,15 @@ package com.muyu.product.remote;
 import com.muyu.common.core.constant.ServiceNameConstants;
 import com.muyu.common.core.domain.Result;
 import com.muyu.product.domain.RuleInfo;
-import com.muyu.product.remote.factory.RemoteRuleAttrFactory;
 import com.muyu.product.remote.factory.RemoteRuleFactory;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 
 /**
- * RemoteRuleService
+ * @author DongZl
- *
+ * @description: 规格远程调用业务层
- * @author DeKangLiu
+ * @Date 2024-4-7 上午 10:58
- * on 2024/4/8
  */
 @FeignClient(
         contextId = "remoteRuleService",
@@ -22,8 +20,9 @@ import org.springframework.web.bind.annotation.PathVariable;
         path = "/rule"
 )
 public interface RemoteRuleService {
-
+    /**
-    @GetMapping("/{id}")
+     * 获取商品规格详细信息
+     */
+    @GetMapping(value = "/{id}")
     public Result<RuleInfo> getInfo(@PathVariable("id") Long id);
-
 }

muyu-modules/muyu-product/muyu-product-remote/src/main/java/com/muyu/product/remote/factory/RemoteProjectInfoFactory.java

@@ -6,16 +6,20 @@ import com.muyu.product.remote.RemoteProjectInfoService;
 import org.springframework.cloud.openfeign.FallbackFactory;
 
 /**
- * RemoteProjectInfoFactory
+ * @author DongZl
- *
+ * @description: 规格远程调熔断器
- * @author DeKangLiu
+ * @Date 2024-4-7 上午 10:59
- * on 2024/4/8
  */
 public class RemoteProjectInfoFactory implements FallbackFactory<RemoteProjectInfoService> {
     @Override
     public RemoteProjectInfoService create (Throwable cause) {
         return new RemoteProjectInfoService() {
 
+            /**
+             * 获取商品规格详细信息
+             *
+             * @param id
+             */
             @Override
             public Result<ProjectInfo> getInfo (Long id) {
                 return Result.error(cause.getMessage());

muyu-modules/muyu-product/muyu-product-remote/src/main/java/com/muyu/product/remote/factory/RemoteProjectSkuFactory.java

@@ -21,6 +21,13 @@ public class RemoteProjectSkuFactory implements FallbackFactory<RemoteProjectSku
                 return Result.error(cause.getMessage());
             }
 
+            /**
+             * 通过商品ID和SKU获取SKU信息
+             *
+             * @param projectId 商品ID
+             *
+             * @return 商品SKU信息
+             */
             @Override
             public Result<List<ProjectSkuInfo>> listByProjectId (Long projectId) {
                 return Result.error(cause.getMessage());

muyu-modules/muyu-product/muyu-product-remote/src/main/java/com/muyu/product/remote/factory/RemoteRuleAttrFactory.java

@@ -1,10 +1,31 @@
 package com.muyu.product.remote.factory;
 
+import com.muyu.common.core.domain.Result;
+import com.muyu.product.domain.RuleAttrInfo;
+import com.muyu.product.remote.RemoteRuleAttrService;
+import org.springframework.cloud.openfeign.FallbackFactory;
+
+import java.util.List;
+
 /**
- * RemoteRuleAttrFactory
+ * @author DongZl
- *
+ * @description: 规格详情远程调熔断器
- * @author DeKangLiu
+ * @Date 2024-4-7 上午 10:59
- * on 2024/4/8
  */
-public class RemoteRuleAttrFactory {
+public class RemoteRuleAttrFactory implements FallbackFactory<RemoteRuleAttrService> {
+    @Override
+    public RemoteRuleAttrService create (Throwable cause) {
+        return new RemoteRuleAttrService() {
+
+            /**
+             * 获取规格详情详细信息
+             *
+             * @param id
+             */
+            @Override
+            public Result<List<RuleAttrInfo>> getInfoByRuleId (Long id) {
+                return Result.error(cause.getMessage());
+            }
+        };
+    }
 }

muyu-modules/muyu-product/muyu-product-remote/src/main/java/com/muyu/product/remote/factory/RemoteRuleFactory.java

@@ -1,10 +1,29 @@
 package com.muyu.product.remote.factory;
 
+import com.muyu.common.core.domain.Result;
+import com.muyu.product.domain.RuleInfo;
+import com.muyu.product.remote.RemoteRuleService;
+import org.springframework.cloud.openfeign.FallbackFactory;
+
 /**
- * RemoteRuleFactory
+ * @author DongZl
- *
+ * @description: 规格远程调熔断器
- * @author DeKangLiu
+ * @Date 2024-4-7 上午 10:59
- * on 2024/4/8
  */
-public class RemoteRuleFactory {
+public class RemoteRuleFactory implements FallbackFactory<RemoteRuleService> {
+    @Override
+    public RemoteRuleService create (Throwable cause) {
+        return new RemoteRuleService() {
+
+            /**
+             * 获取商品规格详细信息
+             *
+             * @param id
+             */
+            @Override
+            public Result<RuleInfo> getInfo (Long id) {
+                return Result.error(cause.getMessage());
+            }
+        };
+    }
 }

muyu-modules/muyu-product/muyu-product-remote/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports

@@ -1,4 +1,4 @@
 com.muyu.product.remote.factory.RemoteProjectSkuFactory
-com.muyu.product.remote.factory.RemoteProjectInfoFactory
 com.muyu.product.remote.factory.RemoteRuleAttrFactory
 com.muyu.product.remote.factory.RemoteRuleFactory
+com.muyu.product.remote.factory.RemoteProjectInfoFactory

muyu-modules/muyu-product/muyu-product-server/src/main/java/com/muyu/product/cache/impl/ProjectInfoDataImpl.java

@@ -4,16 +4,18 @@ import com.muyu.product.cache.datasource.ProjectInfoData;
 import com.muyu.product.domain.ProjectInfo;
 import com.muyu.product.service.ProjectInfoService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Service;
 
 /**
- * 缓存数据获取 ProjectInfoDataImpl
+ * @author DongZl
- *
+ * @description: 缓存数据获取
- * @author LeYang
+ * @Date 2024-3-27 下午 03:37
- * on 2024/3/27
  */
 @Service
+@Primary
 public class ProjectInfoDataImpl implements ProjectInfoData {
+
     @Autowired
     private ProjectInfoService projectInfoService;
 

muyu-modules/muyu-product/muyu-product-server/src/main/java/com/muyu/product/cache/impl/ProjectSkuDataImpl.java

@@ -5,6 +5,7 @@ import com.muyu.product.cache.datasource.ProjectSkuData;
 import com.muyu.product.domain.ProjectSkuInfo;
 import com.muyu.product.service.ProjectSkuInfoService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
@@ -12,26 +13,42 @@ import java.util.Map;
 import java.util.stream.Collectors;
 
 /**
- * ProjectSkuDataImpl
+ * @author DongZl
- *
+ * @description: 商品SKU实现类
- * @author DeKangLiu
+ * @Date 2024-4-1 上午 11:38
- * on 2024/4/1
  */
 @Service
+@Primary
 public class ProjectSkuDataImpl implements ProjectSkuData {
+
     @Autowired
     private ProjectSkuInfoService projectSkuInfoService;
+
+    /**
+     * 通过键获取所有的hash数据
+     * @param projectId 商品ID
+     * @return
+     */
     @Override
     public Map<String, ProjectSkuInfo> getData (Long projectId) {
         LambdaQueryWrapper<ProjectSkuInfo> queryWrapper = new LambdaQueryWrapper<>();
         queryWrapper.eq(ProjectSkuInfo::getProjectId, projectId);
         List<ProjectSkuInfo> projectSkuInfoList = projectSkuInfoService.list(queryWrapper);
-
+        return projectSkuInfoList.stream()
-        return projectSkuInfoList.stream().collect(Collectors.toMap(ProjectSkuInfo::getSku,projectSkuInfo -> projectSkuInfo));
+                .collect(Collectors.toMap(ProjectSkuInfo::getSku, projectSkuInfo -> projectSkuInfo));
     }
 
+    /**
+     * 通过缓存键和hash键获取hash值
+     * @param projectId  商品ID
+     * @param projectSku 商品SKU
+     * @return hash值
+     */
     @Override
     public ProjectSkuInfo getData (Long projectId, String projectSku) {
-        return null;
+        LambdaQueryWrapper<ProjectSkuInfo> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(ProjectSkuInfo::getProjectId, projectId);
+        queryWrapper.eq(ProjectSkuInfo::getSku, projectSku);
+        return projectSkuInfoService.getOne(queryWrapper);
     }
 }

muyu-modules/muyu-product/muyu-product-server/src/main/java/com/muyu/product/cache/impl/ProjectSkuStockDataImpl.java

@@ -1,21 +1,22 @@
 package com.muyu.product.cache.impl;
 
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.muyu.product.cache.datasource.ProjectSkuStockData;
 import com.muyu.product.cache.key.SkuStockKey;
 import com.muyu.product.domain.ProjectSkuInfo;
 import com.muyu.product.service.ProjectSkuInfoService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Service;
 
 /**
- * sku库存实体类 ProjectSkuStockDataImpl
+ * @author DongZl
- *
+ * @description: sku库存实现类
- * @author DeKangLiu
+ * @Date 2024-4-2 上午 10:53
- * on 2024/4/2
  */
 @Service
+@Primary
 public class ProjectSkuStockDataImpl implements ProjectSkuStockData {
+
     @Autowired
     private ProjectSkuInfoService projectSkuInfoService;
 

muyu-modules/muyu-product/muyu-product-server/src/main/java/com/muyu/product/controller/ProjectSkuInfoController.java

@@ -51,6 +51,16 @@ public class ProjectSkuInfoController extends BaseController {
         return getDataTable(list);
     }
 
+    /**
+     * 通过商品ID获取SKU集合
+     * @param projectId 商品ID
+     * @return 商品SKU集合
+     */
+    @GetMapping("/list/{projectId}")
+    public Result<List<ProjectSkuInfo>> listByProjectId(@PathVariable("projectId") Long projectId){
+        return Result.success(projectSkuInfoService.listByProjectId(projectId));
+    }
+
     /**
      * 导出商品SKU列表
      */

muyu-modules/muyu-product/muyu-product-server/src/main/java/com/muyu/product/service/ProjectSkuInfoService.java

@@ -20,4 +20,6 @@ public interface ProjectSkuInfoService extends IService<ProjectSkuInfo> {
     public List<ProjectSkuInfo> list(ProjectSkuInfo projectSkuInfo);
 
     ProjectSkuInfo getInfoByProjectIdAndSku(Long projectId, String projectSku);
+
+    List<ProjectSkuInfo> listByProjectId(Long projectId);
 }

muyu-modules/muyu-product/muyu-product-server/src/main/java/com/muyu/product/service/impl/ProjectSkuInfoServiceImpl.java

@@ -66,4 +66,12 @@ public class ProjectSkuInfoServiceImpl extends ServiceImpl<ProjectSkuInfoMapper,
         queryWrapper.eq(ProjectSkuInfo::getSku,projectSku);
         return this.getOne(queryWrapper);
     }
+
+    @Override
+    public List<ProjectSkuInfo> listByProjectId(Long projectId) {
+        LambdaQueryWrapper<ProjectSkuInfo> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(ProjectSkuInfo::getProjectId,projectId);
+
+        return this.list(queryWrapper);
+    }
 }

muyu-modules/muyu-shop-cart/muyu-shop-cart-server/src/main/java/com/muyu/shop/cart/cache/impl/ProjectInfoDataImpl.java

@@ -1,25 +0,0 @@
-package com.muyu.shop.cart.cache.impl;
-
-import com.muyu.product.cache.datasource.ProjectInfoData;
-import com.muyu.product.domain.ProjectInfo;
-import org.springframework.stereotype.Service;
-
-/**
- * ProjectInfoDataImpl
- *
- * @author DeKangLiu
- * on 2024/4/7
- */
-@Service
-public class ProjectInfoDataImpl implements ProjectInfoData {
-
-    /**
-     * 从数据库 获取数据
-     * @param key ID
-     * @return 缓存对象
-     */
-    @Override
-    public ProjectInfo getData(Long key) {
-        return new ProjectInfo();
-    }
-}

muyu-modules/muyu-shop-cart/muyu-shop-cart-server/src/main/java/com/muyu/shop/cart/cache/impl/ProjectSkuDataImpl.java

@@ -1,41 +0,0 @@
-package com.muyu.shop.cart.cache.impl;
-
-import com.muyu.product.cache.datasource.ProjectInfoData;
-import com.muyu.product.cache.datasource.ProjectSkuData;
-import com.muyu.product.domain.ProjectInfo;
-import com.muyu.product.domain.ProjectSkuInfo;
-import org.springframework.stereotype.Service;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * ProjectSkuDataImpl
- *
- * @author DeKangLiu
- * on 2024/4/7
- */
-@Service
-public class ProjectSkuDataImpl implements ProjectSkuData {
-
-    /**
-     * 通过键获取所有的hash数据
-     * @param projectId 商品ID
-     * @return
-     */
-    @Override
-    public Map<String, ProjectSkuInfo> getData (Long projectId) {
-        return new HashMap<>();
-    }
-
-    /**
-     * 通过缓存键和hash键获取hash值
-     * @param projectId  商品ID
-     * @param projectSku 商品SKU
-     * @return hash值
-     */
-    @Override
-    public ProjectSkuInfo getData (Long projectId, String projectSku) {
-        return new ProjectSkuInfo();
-    }
-}

muyu-modules/muyu-shop-cart/muyu-shop-cart-server/src/main/java/com/muyu/shop/cart/cache/impl/ProjectSkuStockDataRemoteImpl.java

@@ -1,37 +0,0 @@
-package com.muyu.shop.cart.cache.impl;
-
-import com.muyu.common.core.domain.Result;
-import com.muyu.product.cache.datasource.ProjectSkuStockData;
-import com.muyu.product.cache.key.SkuStockKey;
-import com.muyu.product.domain.ProjectSkuInfo;
-import com.muyu.product.remote.RemoteProjectSkuService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-import java.util.Objects;
-
-/**
- * ProjectSkuStockDataRemoteImpl
- *
- * @author DeKangLiu
- * on 2024/4/7
- */
-@Service
-public class ProjectSkuStockDataRemoteImpl implements ProjectSkuStockData{
-
-    @Autowired
-    private RemoteProjectSkuService remoteProjectSkuService;
-
-    @Override
-    public Long getData(SkuStockKey key) {
-        Result<ProjectSkuInfo> result
-                = remoteProjectSkuService.getInfoByProjectIdAndSku(key.getProjectId(), key.getSku());
-        if (Result.isSuccess(result)){
-            ProjectSkuInfo projectSkuInfo = result.getData();
-            if (!Objects.isNull(projectSkuInfo)){
-                return projectSkuInfo.getStock();
-            }
-        }
-        return 0L;
-    }
-}