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 89e258d37..01165b29b 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
@@ -743,7 +743,7 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements
     }
 
     private void executeCleanInvalidPromotions() {
-        for (int i = 1; ; i++) {
+        for (int i = 0; ; i++) {
             org.springframework.data.domain.Page<EsGoodsIndex> all = goodsIndexRepository.findAll(PageRequest.of(i, 1000));
             if (all.isEmpty()) {
                 break;
@@ -758,6 +758,9 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements
                         BasePromotions promotion = promotionJson.toBean(BasePromotions.class);
                         return promotion.getEndTime() != null && promotion.getEndTime().getTime() < DateUtil.date().getTime();
                     });
+
+                    // 更新回 goodsIndex 对象
+                    goodsIndex.setPromotionMapJson(JSONUtil.toJsonStr(promotionMap));
                 }
             }
             goodsIndexRepository.saveAll(all);