后端：尝试引入 ES 服务

product/product-service-api/src/main/java/cn/iocoder/mall/product/api/ProductSpuService.java

@@ -13,6 +13,15 @@ public interface ProductSpuService {
 
     CommonResult<ProductSpuDetailBO> getProductSpuDetail(Integer id);
 
+    /**
+     * 增量获得商品列表，按照 lastId 递增获得
+     *
+     * @param lastId 最后查询的编号
+     * @param limit 大小
+     * @return 商品列表
+     */
+    CommonResult<List<ProductSpuDetailBO>> getProductSpuDetailListForSync(Integer lastId, Integer limit);
+
     CommonResult<ProductSpuPageBO> getProductSpuPage(ProductSpuPageDTO productSpuPageDTO);
 
     CommonResult<List<ProductSpuBO>> getProductSpuList(Collection<Integer> ids);

product/product-service-api/src/main/java/cn/iocoder/mall/product/api/bo/ProductSpuDetailBO.java

@@ -35,6 +35,10 @@ public class ProductSpuDetailBO implements Serializable {
      * 分类编号
      */
     private Integer cid;
+    /**
+     * 分类名
+     */
+    private String categoryName;
     /**
      * 商品主图地址
      *

product/product-service-impl/src/main/java/cn/iocoder/mall/product/convert/ProductSpuConvert.java

@@ -5,6 +5,7 @@ import cn.iocoder.mall.product.api.bo.*;
 import cn.iocoder.mall.product.api.dto.ProductSkuAddOrUpdateDTO;
 import cn.iocoder.mall.product.api.dto.ProductSpuAddDTO;
 import cn.iocoder.mall.product.api.dto.ProductSpuUpdateDTO;
+import cn.iocoder.mall.product.dataobject.ProductCategoryDO;
 import cn.iocoder.mall.product.dataobject.ProductSkuDO;
 import cn.iocoder.mall.product.dataobject.ProductSpuDO;
 import org.mapstruct.Mapper;
@@ -76,7 +77,8 @@ public interface ProductSpuConvert {
     ProductSkuBO convert4(ProductSkuDO sku);
 
     @Mappings({}) // TODO 芋艿，后续细看下 mapstruct 的 API ，优化这块
-    default ProductSpuDetailBO convert2(ProductSpuDO spu, List<ProductSkuDO> skus, List<ProductAttrAndValuePairBO> productAttrDetailBOs) {
+    default ProductSpuDetailBO convert2(ProductSpuDO spu, List<ProductSkuDO> skus, List<ProductAttrAndValuePairBO> productAttrDetailBOs,
+                                        ProductCategoryDO category) {
         // 创建并转换 ProductSpuDetailBO 对象
         ProductSpuDetailBO spuDetail = this.convert2(spu).setPicUrls(StringUtil.split(spu.getPicUrls(), ","));
         // 创建 ProductAttrDetailBO 的映射。其中，KEY 为 ProductAttrDetailBO.attrValueId ，即规格值的编号
@@ -93,6 +95,8 @@ public interface ProductSpuConvert {
             List<String> attrs = StringUtil.split(sku.getAttrs(), ",");
             attrs.forEach(attr -> skuDetail.getAttrs().add(productAttrDetailBOMap.get(Integer.valueOf(attr))));
         });
+        // 设置分类名
+        spuDetail.setCategoryName(category.getName());
         // 返回
         return spuDetail;
     }

product/product-service-impl/src/main/java/cn/iocoder/mall/product/dao/ProductSpuMapper.java

@@ -14,6 +14,16 @@ public interface ProductSpuMapper {
 
     List<ProductSpuDO> selectByIds(@Param("ids") Collection<Integer> ids);
 
+    /**
+     * 获得大于 id 的商品编号数组
+     *
+     * @param id 商品编号
+     * @param limit 数量
+     * @return 商品编号数组
+     */
+    List<Integer> selectIdListByIdGt(@Param("id") Integer id,
+                                     @Param("limit") Integer limit);
+
     void insert(ProductSpuDO productSpuDO);
 
     void update(ProductSpuDO productSpuDO);
@@ -29,4 +39,4 @@ public interface ProductSpuMapper {
                                   @Param("cid") Integer cid,
                                   @Param("visible") Boolean visible);
 
-}
+}

product/product-service-impl/src/main/java/cn/iocoder/mall/product/service/ProductCategoryServiceImpl.java

@@ -123,6 +123,10 @@ public class ProductCategoryServiceImpl implements ProductCategoryService {
         return CommonResult.success(true);
     }
 
+    public ProductCategoryDO getProductCategory(Integer productCategoryId) {
+        return productCategoryMapper.selectById(productCategoryId);
+    }
+
     public CommonResult<ProductCategoryDO> validProductCategory(Integer productCategoryId) {
         // 校验分类是否存在
         ProductCategoryDO productCategory = productCategoryMapper.selectById(productCategoryId);
@@ -142,4 +146,4 @@ public class ProductCategoryServiceImpl implements ProductCategoryService {
                 || ProductCategoryConstants.STATUS_DISABLE.equals(status);
     }
 
-}
+}

product/product-service-impl/src/main/java/cn/iocoder/mall/product/service/ProductSpuServiceImpl.java

@@ -22,6 +22,7 @@ import cn.iocoder.mall.product.dataobject.ProductSpuDO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.Assert;
 
 import java.util.*;
 import java.util.stream.Collectors;
@@ -54,6 +55,9 @@ public class ProductSpuServiceImpl implements ProductSpuService {
         if (spu == null) {
             return ServiceExceptionUtil.error(ProductErrorCodeEnum.PRODUCT_SPU_NOT_EXISTS.getCode());
         }
+        // 获得商品分类分类
+        ProductCategoryDO category = productCategoryService.getProductCategory(spu.getCid());
+        Assert.notNull(category, String.format("分类编号(%d) 对应", spu.getCid()));
         // 获得商品 sku 数组
         List<ProductSkuDO> skus = productSkuMapper.selectListBySpuIdAndStatus(id, ProductSpuConstants.SKU_STATUS_ENABLE);
         // 获得规格
@@ -62,7 +66,20 @@ public class ProductSpuServiceImpl implements ProductSpuService {
         CommonResult<List<ProductAttrAndValuePairBO>> validAttrResult = productAttrService.validProductAttrAndValue(productAttrValueIds,
                 false); // 读取规格时，不考虑规格是否被禁用
         // 返回成功
-        return CommonResult.success(ProductSpuConvert.INSTANCE.convert2(spu, skus, validAttrResult.getData()));
+        return CommonResult.success(ProductSpuConvert.INSTANCE.convert2(spu, skus, validAttrResult.getData(), category));
+    }
+
+    @Override
+    public CommonResult<List<ProductSpuDetailBO>> getProductSpuDetailListForSync(Integer lastId, Integer limit) {
+        // TODO 芋艿，这里目前是一个一个进行计算，后续需要优化下
+        // 查询下一批商品编号集合
+        List<Integer> spuIds = productSpuMapper.selectIdListByIdGt(lastId, limit);
+        if (spuIds.isEmpty()) {
+            return CommonResult.success(Collections.emptyList());
+        }
+        // 查询每个商品明细
+        List<ProductSpuDetailBO> spus = spuIds.stream().map(id -> getProductSpuDetail(id).getData()).collect(Collectors.toList()); // TODO 芋艿，此处相当于是 N 个查询，后续要优化。
+        return CommonResult.success(spus);
     }
 
     @SuppressWarnings("Duplicates")
@@ -108,7 +125,8 @@ public class ProductSpuServiceImpl implements ProductSpuService {
         }
         productSkuMapper.insertList(skus);
         // 返回成功
-        return CommonResult.success(ProductSpuConvert.INSTANCE.convert2(spu, skus, validAttrResult.getData()));
+        return CommonResult.success(ProductSpuConvert.INSTANCE.convert2(spu, skus, validAttrResult.getData(),
+                validCategoryResult.getData()));
     }
 
     @SuppressWarnings("Duplicates")

product/product-service-impl/src/main/resources/mapper/ProductSpuMapper.xml

@@ -27,6 +27,20 @@
         AND deleted = 0
     </select>
 
+    <select id="selectIdListByIdGt" parameterType="Integer" resultType="Integer">
+        SELECT
+            <include refid="FIELDS" />
+        FROM product_spu
+        <where>
+            <if test="id != null">
+                id >= #{id}
+            </if>
+        </where>
+        AND deleted = 0
+        ORDER BY id ASC
+        LIMIT #{limit}
+    </select>
+
     <insert id="insert" parameterType="ProductSpuDO" useGeneratedKeys="true" keyColumn="id" keyProperty="id">
         INSERT INTO product_spu (
             name, sell_point, description, cid, pic_urls,
@@ -114,4 +128,4 @@
         </where>
     </select>
 
-</mapper>
+</mapper>