redis key 演出

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/constant/KylinRedisConst.java

@@ -3,6 +3,8 @@ package com.liquidnet.service.kylin.constant;
 public class KylinRedisConst {
     public static final String FIELDS = "kylin:fields:id";
     public static final String PERFORMANCES = "kylin:performances:id:";
+    public static final String PERFORMANCES_LIST_CITYNAME = "kylin:performances:cityName:";
+    public static final String PERFORMANCES_LIST_RECOMMEND = "kylin:performances:recommend:";
     public static final String PERFORMANCES_RECOMMEND = "kylin:performances:recommend:id:";
     public static final String PERFORMANCES_INVENTORY = "kylin:performances_inventory:ticket:id:";
     public static final String SURPLUS_GENERAL = "surplusGeneral";

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/utils/DataUtils.java

@@ -2,6 +2,7 @@ package com.liquidnet.service.kylin.utils;
 
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.liquidnet.common.cache.redis.util.RedisUtil;
+import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.dto.vo.*;
@@ -18,6 +19,7 @@ import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Component;
 
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -463,4 +465,59 @@ public class DataUtils {
         redisUtil.del(KylinRedisConst.ORDER_ENTITIES + orderEntitiesId);
     }
 
+    /**
+     * 获取演出列表redis
+     *
+     * @param cityName
+     */
+    public List<KylinPerformanceVo> getPerformancesListOfcityName(String cityName) {
+        String redisKey = KylinRedisConst.PERFORMANCES.concat(cityName);
+        if (!redisUtil.hasKey(redisKey)) {
+            // 固定查询条件
+            Query query = new Query();
+            LocalDateTime nowTime = LocalDateTime.now();
+            String nowTimeStr = DateUtil.Formatter.yyyyMMddHHmmss.format(nowTime);
+            query.addCriteria(Criteria.where("timeEnd").gte(nowTimeStr));
+            // 不要查询的字段
+            query.fields().exclude("details");
+            query.fields().exclude("noticeImage");
+            query.fields().exclude("ticketTimeList");
+            List<KylinPerformanceVo> performancesList = mongoTemplate.find(query, KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
+            redisUtil.set(redisKey, performancesList);
+        }
+        return (List<KylinPerformanceVo>) redisUtil.get(redisKey);
+    }
+
+    /**
+     * 获取推荐演出列表redis
+     */
+    public List<KylinPerformanceVo> getPerformancesListIsRecommend() {
+        String redisKey = KylinRedisConst.PERFORMANCES_LIST_RECOMMEND;
+        if (!redisUtil.hasKey(redisKey)) {
+            // 固定条件
+            Query query = new Query();
+            LocalDateTime nowTime = LocalDateTime.now();
+            String nowTimeStr = DateUtil.Formatter.yyyyMMddHHmmss.format(nowTime);
+            query.addCriteria(Criteria.where("timeEnd").gte(nowTimeStr));
+            // 不要查询的字段
+            query.fields().exclude("details");
+            query.fields().exclude("noticeImage");
+            query.fields().exclude("ticketTimeList");
+            // 推荐
+            query.addCriteria(Criteria.where("isRecommend").is(1));
+            List<KylinPerformanceVo> recommendList = mongoTemplate.find(query, KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
+            redisUtil.set(redisKey, recommendList);
+        }
+        return (List<KylinPerformanceVo>) redisUtil.get(redisKey);
+    }
+
+    /**
+     * 删除演出列表redis
+     *
+     * @param cityName
+     */
+    public void delPerformancesListOfcityName(String cityName) {
+        redisUtil.del(KylinRedisConst.ORDER_ENTITIES.concat(cityName));
+    }
+
 }