商家过期或关店 自动下架商品

ruoyi-shop/src/main/java/com/ruoyi/shop/product/service/IProductService.java

@@ -1,14 +1,14 @@
 package com.ruoyi.shop.product.service;
 
+import com.ruoyi.common.core.domain.PageQuery;
+import com.ruoyi.common.core.page.TableDataInfo;
 import com.ruoyi.shop.product.domain.Product;
 import com.ruoyi.shop.product.domain.bo.ProductAuditBo;
 import com.ruoyi.shop.product.domain.bo.ProductBatchBo;
+import com.ruoyi.shop.product.domain.bo.ProductBo;
 import com.ruoyi.shop.product.domain.bo.ProductViewUpdate;
 import com.ruoyi.shop.product.domain.vo.ProductCountVo;
 import com.ruoyi.shop.product.domain.vo.ProductVo;
-import com.ruoyi.shop.product.domain.bo.ProductBo;
-import com.ruoyi.common.core.page.TableDataInfo;
-import com.ruoyi.common.core.domain.PageQuery;
 
 import java.math.BigDecimal;
 import java.util.Collection;
@@ -163,17 +163,4 @@ public interface IProductService {
      */
     Product getByBusinessIdAndId(Long businessId, Long productId);
 
-    /**
-     *
-     * 获取商家上架产品
-     * @return Product
-     */
-    List<Long> queryShelvedProductIdsByBusinessId(Long businessId);
-
-    /**
-     *
-     * 获取商家下架产品
-     * @return Product
-     */
-    void downShelfProduct(Long businessId, List<Long> productIds);
 }

ruoyi-shop/src/main/java/com/ruoyi/shop/product/service/impl/ProductInnerApiImpl.java

@@ -3,24 +3,27 @@ package com.ruoyi.shop.product.service.impl;
 import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.ruoyi.common.enums.AuditStatus;
 import com.ruoyi.shop.config.domain.ShopSaleConfig;
 import com.ruoyi.shop.config.service.IShopSaleConfigService;
 import com.ruoyi.shop.product.IProductInnerApi;
 import com.ruoyi.shop.product.domain.Product;
 import com.ruoyi.shop.product.mapper.ProductMapper;
-import com.ruoyi.shop.product.service.IProductService;
+import com.ruoyi.shop.usershoppingcart.domain.UserShoppingCart;
+import com.ruoyi.shop.usershoppingcart.enums.CartEffectiveStatus;
+import com.ruoyi.shop.usershoppingcart.mapper.UserShoppingCartMapper;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
+import java.util.stream.Collectors;
 
 @RequiredArgsConstructor
 @Service
 public class ProductInnerApiImpl implements IProductInnerApi {
 
     private final ProductMapper baseMapper;
-    private final IProductService productService;
-
+    private final UserShoppingCartMapper userShoppingCartMapper;
     private final IShopSaleConfigService shopSaleConfigService;
 
     @Override
@@ -52,12 +55,26 @@ public class ProductInnerApiImpl implements IProductInnerApi {
 
     @Override
     public List<Long> queryShelvedProductIdsByBusinessId(Long businessId) {
-        return productService.queryShelvedProductIdsByBusinessId(businessId);
+        return baseMapper.selectList(new LambdaQueryWrapper<Product>()
+            .select(Product::getProductId)
+            .eq(Product::getBusinessId, businessId)
+            .eq(Product::getShelvedStatus, true)
+            .eq(Product::getAuditStatus, AuditStatus.AUDIT_PASS)
+        ).stream().map(Product::getProductId).collect(Collectors.toList());
     }
 
     @Override
     public void downShelfProduct(Long businessId, List<Long> productIds) {
-        productService.downShelfProduct(businessId, productIds);
+        baseMapper.update(null, new LambdaUpdateWrapper<Product>()
+            .set(Product::getShelvedStatus, false)
+            .in(Product::getProductId, productIds)
+        );
+        userShoppingCartMapper.update(null, new LambdaUpdateWrapper<UserShoppingCart>()
+            .eq(UserShoppingCart::getBusinessId, businessId)
+            .in(UserShoppingCart::getProductId, productIds)
+            .eq(UserShoppingCart::getEffectiveStatus, CartEffectiveStatus.NORMAL)
+            .set(UserShoppingCart::getEffectiveStatus, CartEffectiveStatus.UNDER_CARRIAGE)
+        );
     }
 
 

ruoyi-shop/src/main/java/com/ruoyi/shop/product/service/impl/ProductServiceImpl.java

@@ -593,29 +593,4 @@ public class ProductServiceImpl implements IProductService {
         return product;
     }
 
-    @Override
-    public List<Long> queryShelvedProductIdsByBusinessId(Long businessId) {
-        return baseMapper.selectList(new LambdaQueryWrapper<Product>()
-            .select(Product::getProductId)
-            .eq(Product::getBusinessId, businessId)
-            .eq(Product::getShelvedStatus, true)
-            .eq(Product::getAuditStatus, AuditStatus.AUDIT_PASS)
-        ).stream().map(Product::getProductId).collect(Collectors.toList());
-    }
-
-    @Override
-    public void downShelfProduct(Long businessId, List<Long> productIds) {
-        baseMapper.update(null, new LambdaUpdateWrapper<Product>()
-            .set(Product::getShelvedStatus, false)
-            .in(Product::getProductId, productIds)
-        );
-        userShoppingCartMapper.update(null, new LambdaUpdateWrapper<UserShoppingCart>()
-            .eq(UserShoppingCart::getBusinessId, businessId)
-            .in(UserShoppingCart::getProductId, productIds)
-            .eq(UserShoppingCart::getEffectiveStatus, CartEffectiveStatus.NORMAL)
-            .set(UserShoppingCart::getEffectiveStatus, CartEffectiveStatus.UNDER_CARRIAGE)
-        );
-    }
-
-
 }