From 942e15d6409dbe9260dce21a45730234de34b630 Mon Sep 17 00:00:00 2001
From: peng <peng.com>
Date: 星期二, 23 九月 2025 01:26:25 +0800
Subject: [PATCH] 解决es排序不会被构建到索引中去的问题

---
 framework/src/main/java/cn/lili/modules/goods/mapper/GoodsSkuMapper.java                |    2 +-
 framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java |    4 +++-
 framework/src/main/java/cn/lili/modules/goods/entity/dto/GoodsSkuDTO.java               |    3 +++
 3 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/framework/src/main/java/cn/lili/modules/goods/entity/dto/GoodsSkuDTO.java b/framework/src/main/java/cn/lili/modules/goods/entity/dto/GoodsSkuDTO.java
index 2d105d4..2f9d0e1 100644
--- a/framework/src/main/java/cn/lili/modules/goods/entity/dto/GoodsSkuDTO.java
+++ b/framework/src/main/java/cn/lili/modules/goods/entity/dto/GoodsSkuDTO.java
@@ -26,6 +26,9 @@
     @ApiModelProperty(value = "鍟嗗搧鍙傛暟json")
     private String params;
 
+    @ApiModelProperty(value = "鍟嗗搧鎺掑簭")
+    private Integer goodsSort;
+
 
     @ApiModelProperty(value = "棰勫敭缁撴潫鏃堕棿")
     @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd")
diff --git a/framework/src/main/java/cn/lili/modules/goods/mapper/GoodsSkuMapper.java b/framework/src/main/java/cn/lili/modules/goods/mapper/GoodsSkuMapper.java
index 189fa33..1f88f46 100644
--- a/framework/src/main/java/cn/lili/modules/goods/mapper/GoodsSkuMapper.java
+++ b/framework/src/main/java/cn/lili/modules/goods/mapper/GoodsSkuMapper.java
@@ -114,7 +114,7 @@
      * @param queryWrapper 鏌ヨ鏉′欢
      * @return 鍞悗VO鍒嗛〉
      */
-    @Select("SELECT *,g.params as params,g.pre_sale_end_date,g.pre_sale_begin_date FROM li_goods_sku gs inner join li_goods g on gs.goods_id = g.id ${ew.customSqlSegment}")
+    @Select("SELECT *,g.params as params,g.goods_sort as goodsSort,g.pre_sale_end_date,g.pre_sale_begin_date FROM li_goods_sku gs inner join li_goods g on gs.goods_id = g.id ${ew.customSqlSegment}")
     IPage<GoodsSkuDTO> queryByParams(IPage<GoodsSkuDTO> page, @Param(Constants.WRAPPER) Wrapper<GoodsSkuDTO> queryWrapper);
 
     @Select("SELECT id as sku_id, quantity, goods_id,simple_specs,sn,goods_name FROM li_goods_sku ${ew.customSqlSegment}")
diff --git a/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java b/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java
index 291efa1..72e92e0 100644
--- a/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java
@@ -45,6 +45,7 @@
 import cn.lili.modules.search.service.EsGoodsSearchService;
 import cn.lili.rocketmq.RocketmqSendCallbackBuilder;
 import cn.lili.rocketmq.tags.GoodsTagsEnum;
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -256,7 +257,8 @@
                         if (CollUtil.isNotEmpty(promotionGoods)) {
                             esGoodsIndex.setPromotionMapJson(JSONUtil.toJsonStr(promotionService.wrapperPromotionMapList(promotionGoods)));
                         }
-
+                        log.info("鏋勫缓鍑篹s鐨勭储寮曚俊鎭负{}", JSON.toJSONString(esGoodsIndex));
+                        esGoodsIndex.setGoodsSort(goodsSku.getGoodsSort());
                         esGoodsIndices.add(esGoodsIndex);
                         //搴撳瓨閿佹槸鍦╮edis鍋氱殑锛屾墍浠ョ敓鎴愮储寮曪紝鍚屾椂鏇存柊涓�涓媟edis涓殑搴撳瓨鏁伴噺
                         cache.put(GoodsSkuService.getStockCacheKey(goodsSku.getId()), goodsSku.getQuantity());

--
Gitblit v1.8.0