diff --git a/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java b/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java
index 8661814d..8ed979cb 100644
--- a/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java
+++ b/consumer/src/main/java/cn/lili/listener/GoodsMessageListener.java
@@ -382,7 +382,11 @@ public class GoodsMessageListener implements RocketMQListener<MessageExt> {
         List<EsGoodsIndex> esGoodsIndices = new ArrayList<>();
         for (GoodsSku goodsSku : goodsSkuList) {
             EsGoodsIndex goodsIndex = this.settingUpGoodsIndexData(goods, goodsSku);
-            goodsIndex.setSkuSource(skuSource--);
+            skuSource--;
+            if (skuSource <= 0) {
+                skuSource = 1;
+            }
+            goodsIndex.setSkuSource(skuSource);
             log.info("goodsSku：{}", goodsSku);
             log.info("生成商品索引 {}", goodsIndex);
             esGoodsIndices.add(goodsIndex);
diff --git a/framework/src/main/java/cn/lili/modules/member/serviceimpl/FootprintServiceImpl.java b/framework/src/main/java/cn/lili/modules/member/serviceimpl/FootprintServiceImpl.java
index b9239f6e..b8110c7c 100644
--- a/framework/src/main/java/cn/lili/modules/member/serviceimpl/FootprintServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/member/serviceimpl/FootprintServiceImpl.java
@@ -88,6 +88,9 @@ public class FootprintServiceImpl extends ServiceImpl<FootprintMapper, FootPrint
                     .mapToObj(i -> {
                         if (goodsSkuByIdFromCache.get(i) == null) {
                             EsGoodsIndex esGoodsIndex = new EsGoodsIndex();
+                            FootPrint footPrint = footPrintPages.getRecords().get(i);
+                            esGoodsIndex.setGoodsId(footPrint.getGoodsId());
+                            esGoodsIndex.setId(footPrint.getSkuId());
                             esGoodsIndex.setReleaseTime(footPrintPages.getRecords().get(i).getCreateTime().getTime());
                             return esGoodsIndex;
                         }
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 6a77c8e5..32359149 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
@@ -235,6 +235,9 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements
                         if (count >= 1) {
                             skuSource -= count;
                         }
+                        if (skuSource <= 0) {
+                            skuSource = 1;
+                        }
                         esGoodsIndex.setSkuSource(skuSource);