'商品es初始化索引问题'

2021-12-20 14:56:17 +08:00 · 2021-12-20 14:56:17 +08:00 · 23b3e72579
commit 23b3e72579
parent e8f44ef6f2
1 changed files with 3 additions and 0 deletions
--- a/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java
@ -291,6 +291,9 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements
    @Override
    public void initIndex(List<EsGoodsIndex> goodsIndexList) {
        if (goodsIndexList == null || goodsIndexList.isEmpty()) {
+            //初始化标识
+            cache.put(CachePrefix.INIT_INDEX_PROCESS.getPrefix(), null);
+            cache.put(CachePrefix.INIT_INDEX_FLAG.getPrefix(), false);
            return;
        }
        //索引名称拼接