【优化】产品接口

src/main/java/com/corewing/app/common/page/PageContext.java

@@ -1,23 +1,134 @@
 package com.corewing.app.common.page;
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import java.util.HashMap;
+import java.util.Map;
 
 public class PageContext {
-    private static final ThreadLocal<Page<?>> PAGE_HOLDER = new ThreadLocal<>();
+    private static final ThreadLocal<PagePool> PAGE_POOL_HOLDER = new ThreadLocal<>();
 
-    // 设置分页对象
-    public static void setPage(Page<?> page) {
-        PAGE_HOLDER.set(page);
+    private static class PagePool {
+        private final Map<String, Page<?>> pool = new HashMap<>();
+        private int counter = 0;
+
+        public synchronized String generateKey() {
+            return "page_" + (counter++);
         }
 
-    // 泛型方法：获取指定类型的分页对象（消除警告）
-    @SuppressWarnings("unchecked")
+        public Page<?> get(String key) {
+            return pool.get(key);
+        }
+
+        public void put(String key, Page<?> page) {
+            pool.put(key, page);
+        }
+
+        public void remove(String key) {
+            pool.remove(key);
+        }
+
+        public void clear() {
+            pool.clear();
+            counter = 0;
+        }
+
+        public boolean isEmpty() {
+            return pool.isEmpty();
+        }
+    }
+
+    /**
+     * 获取一个新的 Page 对象（带唯一key）
+     * 适合单个查询场景
+     */
     public static <T> Page<T> getPage(Class<T> clazz) {
-        return (Page<T>) PAGE_HOLDER.get();
+        PagePool pool = getPagePool();
+        String key = pool.generateKey();
+        Page<T> page = new Page<>();
+        pool.put(key, page);
+        return page;
     }
 
-    // 清除线程变量
+    /**
+     * 获取带有默认分页参数的 Page 对象
+     */
+    public static <T> Page<T> getPage(Class<T> clazz, Integer current, Integer size) {
+        int pageNum = current != null && current > 0 ? current : 1;
+        int pageSize = size != null && size > 0 ? size : 10;
+
+        PagePool pool = getPagePool();
+        String key = pool.generateKey();
+        Page<T> page = new Page<>(pageNum, pageSize);
+        pool.put(key, page);
+        return page;
+    }
+
+    /**
+     * 注册一个 Page 对象到池中（供 PageInterceptor 使用）
+     */
+    public static <T> void registerPage(Page<T> page) {
+        PagePool pool = getPagePool();
+        String key = pool.generateKey();
+        pool.put(key, page);
+    }
+
+    /**
+     * 获取默认的 Page 对象（第一个注册的）
+     * 保持向后兼容性
+     */
+    @SuppressWarnings("unchecked")
+    public static <T> Page<T> getDefaultPage(Class<T> clazz) {
+        PagePool pool = PAGE_POOL_HOLDER.get();
+        if (pool == null || pool.isEmpty()) {
+            return null;
+        }
+
+        // 返回第一个 Page 对象
+        return (Page<T>) pool.pool.values().stream().findFirst().orElse(null);
+    }
+
+    /**
+     * 通过 key 获取 Page 对象
+     */
+    @SuppressWarnings("unchecked")
+    public static <T> Page<T> getPageByKey(String key) {
+        PagePool pool = PAGE_POOL_HOLDER.get();
+        if (pool == null) {
+            return null;
+        }
+        return (Page<T>) pool.get(key);
+    }
+
+    /**
+     * 获取 PagePool
+     */
+    private static PagePool getPagePool() {
+        PagePool pool = PAGE_POOL_HOLDER.get();
+        if (pool == null) {
+            pool = new PagePool();
+            PAGE_POOL_HOLDER.set(pool);
+        }
+        return pool;
+    }
+
+    /**
+     * 清除指定 key 的 Page 对象
+     */
+    public static void clearPage(String key) {
+        PagePool pool = PAGE_POOL_HOLDER.get();
+        if (pool != null) {
+            pool.remove(key);
+        }
+    }
+
+    /**
+     * 清除所有
+     */
     public static void clear() {
-        PAGE_HOLDER.remove();
+        PagePool pool = PAGE_POOL_HOLDER.get();
+        if (pool != null) {
+            pool.clear();
+        }
+        PAGE_POOL_HOLDER.remove();
     }
 }

src/main/java/com/corewing/app/common/page/PageInterceptor.java

@@ -8,6 +8,9 @@ import javax.servlet.http.HttpServletResponse;
 
 public class PageInterceptor implements HandlerInterceptor {
 
+    // 默认的 Page key，用于获取默认分页参数
+    public static final String DEFAULT_PAGE_KEY = "default_page";
+
     @Override
     public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
         // 默认分页参数
@@ -39,9 +42,16 @@ public class PageInterceptor implements HandlerInterceptor {
             }
         }
 
-        // 创建 MyBatis-Plus 的 Page 对象并存储到 ThreadLocal
+        // 创建 MyBatis-Plus 的 Page 对象并注册到 PagePool
         Page<?> page = new Page<>(pageNum, pageSize);
-        PageContext.setPage(page);
+        PageContext.registerPage(page);
+
+        // 将分页参数存储到 request 属性中，方便其他地方使用
+        request.setAttribute("pageNum", pageNum);
+        request.setAttribute("pageSize", pageSize);
+        request.setAttribute("pageCurrent", pageNum); // 兼容 current 参数名
+        request.setAttribute("pageSize", pageSize);
+
         return true;
     }
 

src/main/java/com/corewing/app/entity/BizProduct.java

@@ -25,8 +25,12 @@ public class BizProduct extends CommonEntity {
 
     private String hotStatus;
 
+    private String showType;
+
     private String content;
 
+    private String tag;
+
     private String detailUrl;
 
     private BigDecimal amount;
@@ -42,6 +46,4 @@ public class BizProduct extends CommonEntity {
     @TableField(exist = false)
     private String categoryId;
 
-
-
 }

src/main/java/com/corewing/app/entity/BizProductCategory.java

@@ -8,6 +8,8 @@ import com.corewing.app.common.base.CommonEntity;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 
+import java.util.List;
+
 @EqualsAndHashCode(callSuper = true)
 @Data
 @TableName("biz_product_category")
@@ -34,5 +36,4 @@ public class BizProductCategory extends CommonEntity {
 
     @TableField(exist = false)
     Page<BizProduct> productPage;
-
 }

src/main/java/com/corewing/app/mapper/BizProductCategoryMapper.java

@@ -11,5 +11,5 @@ import java.util.List;
 @Mapper
 public interface BizProductCategoryMapper extends BaseMapper<BizProductCategory> {
 
-    List<BizProductCategory> list(@Param("productCategoryRequest") ProductCategoryRequest productCategoryRequest);
+
 }

src/main/java/com/corewing/app/service/impl/BizProductCategroyServiceImpl.java

@@ -1,5 +1,7 @@
 package com.corewing.app.service.impl;
 
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.corewing.app.dto.website.ProductCategoryRequest;
@@ -25,13 +27,17 @@ public class BizProductCategroyServiceImpl extends ServiceImpl<BizProductCategor
 
     @Override
     public List<BizProductCategory> list(ProductCategoryRequest productCategoryRequest) {
-        List<BizProductCategory> bizProductCategory = bizProductCategoryMapper.list(productCategoryRequest);
-        bizProductCategory.forEach(item -> {
-            ProductPageRequest query = new ProductPageRequest();
-            query.setCategoryId(item.getId());
-            Page<BizProduct> page = bizProductService.page(query);
+        LambdaQueryWrapper<BizProductCategory> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.like(StrUtil.isNotBlank(productCategoryRequest.getSearchKey()), BizProductCategory::getCategoryTitle, productCategoryRequest.getSearchKey());
+        List<BizProductCategory> bizProductCategories = bizProductCategoryMapper.selectList(queryWrapper);
+
+        bizProductCategories.forEach(item -> {
+            ProductPageRequest  productPageRequest = new ProductPageRequest();
+            productPageRequest.setCategoryId(item.getId());
+            Page<BizProduct> page = bizProductService.page(productPageRequest);
             item.setProductPage(page);
         });
-        return bizProductCategory;
+
+        return bizProductCategories;
     }
 }

src/main/java/com/corewing/app/service/impl/BizProductServiceImpl.java

@@ -4,7 +4,6 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.corewing.app.common.page.PageContext;
 import com.corewing.app.dto.website.ProductPageRequest;
-import com.corewing.app.entity.AppModel;
 import com.corewing.app.entity.BizProduct;
 import com.corewing.app.mapper.BizProductMapper;
 import com.corewing.app.service.BizProductService;

src/main/resources/mapper/BizProductCategoryMapper.xml

@@ -9,15 +9,6 @@
         FROM biz_product_category pc
     </sql>
 
-    <!-- 分页查询 -->
-    <select id="list" resultType="com.corewing.app.entity.BizProductCategory">
-        <include refid="selectVOSql"/>
-        <where>
-            <if test="productCategoryRequest.searchKey != null and productCategoryRequest.searchKey != ''">
-               and pc.category_title like CONCAT('%', #{productCategoryRequest.searchKey}, '%')
-            </if>
-        </where>
-    </select>
 
 
 </mapper>

src/main/resources/mapper/BizProductMapper.xml

@@ -21,6 +21,7 @@
             <if test="productPageRequest.searchKey != null and productPageRequest.searchKey != ''">
                and p.title like CONCAT('%', #{productPageRequest.searchKey}, '%')
             </if>
+            and delete_flag = 'NOT_DELETE'
         </where>
     </select>