降级查询

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/GoblinFrontServiceImpl.java

@@ -109,12 +109,9 @@ public class GoblinFrontServiceImpl implements GoblinFrontService {
 
     @Override
     public GoblinFrontHotWord getHotWord() {
-        if(!redisUtil.hasKey(GoblinRedisConst.FRONT_HOTWORD)){
-            return null;
-        }
+        List<GoblinFrontHotWord> list=goblinRedisUtils.getHotWord();
        // int index= (int) redisUtil.get(GoblinRedisConst.FRONT_HOTWORD_INDEX);
         //获得value
-        List<GoblinFrontHotWord> list= (List<GoblinFrontHotWord>) redisUtil.get(GoblinRedisConst.FRONT_HOTWORD);
        /* index++;
         String hotWord="";
         redisUtil.set(GoblinRedisConst.FRONT_HOTWORD_INDEX,index);

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/util/GoblinMongoUtils.java

@@ -10,6 +10,7 @@ import com.liquidnet.service.goblin.dto.manage.vo.GoblinMgtCategorySpecVo;
 import com.liquidnet.service.goblin.dto.manage.vo.GoblinStoreMgtGoodsListVo;
 import com.liquidnet.service.goblin.dto.vo.*;
 import com.liquidnet.service.goblin.entity.GoblinFrontBanner;
+import com.liquidnet.service.goblin.entity.GoblinFrontHotWord;
 import com.mongodb.BasicDBObject;
 import com.mongodb.client.model.UpdateOneModel;
 import com.mongodb.client.model.WriteModel;
@@ -896,4 +897,9 @@ public class GoblinMongoUtils {
                 GoblinFrontBanner.class, GoblinFrontBanner.class.getSimpleName());
     }
 
+    public List<GoblinFrontHotWord> getHotWord() {
+        Query query = Query.query(Criteria.where("delTag").is(0));
+        return mongoTemplate.find(query,
+                GoblinFrontHotWord.class, GoblinFrontHotWord.class.getSimpleName());
+    }
 }

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/util/GoblinRedisUtils.java

@@ -9,6 +9,7 @@ import com.liquidnet.service.goblin.constant.GoblinRedisConst;
 import com.liquidnet.service.goblin.dto.manage.vo.GoblinMgtCategorySpecVo;
 import com.liquidnet.service.goblin.dto.vo.*;
 import com.liquidnet.service.goblin.entity.GoblinFrontBanner;
+import com.liquidnet.service.goblin.entity.GoblinFrontHotWord;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
@@ -884,6 +885,15 @@ public class GoblinRedisUtils {
         }
         return vo;
     }
+    // 热词降级
+    public   List<GoblinFrontHotWord> getHotWord() {
+        List<GoblinFrontHotWord> vo= (List<GoblinFrontHotWord>) redisUtil.get(GoblinRedisConst.FRONT_HOTWORD);
+        if (null == vo ) {
+            //降级
+            return goblinMongoUtils.getHotWord();
+        }
+        return vo;
+    }
 
 
 }