演出系统推荐

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

@@ -6,6 +6,7 @@ public class KylinRedisConst {
     public static final String PERFORMANCES_LIST_CITYNAME = "kylin:performances:cityName:";
     public static final String PERFORMANCES_LIST_ALL = "kylin:performances:cityName*";
     public static final String PERFORMANCES_LIST_RECOMMEND = "kylin:performances:recommend";
+    public static final String PERFORMANCES_LIST_SYSTEM_RECOMMEND = "kylin:performances:systemRecommend";
     public static final String PERFORMANCES_ROADLIST = "kylin:performances:roadShowId:";
     public static final String PERFORMANCES_RECOMMEND = "kylin:performances:recommend:id:";
     public static final String PERFORMANCES_INVENTORY = "kylin:performances_inventory:ticket:id:";

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

@@ -94,8 +94,8 @@ public class KylinPerformancesServiceImpl extends ServiceImpl<KylinPerformancesM
         // 推荐
         int is_native = 1;
         int recommend = performancesListNew.size();
-        if (recommend < 2) {
-            List<KylinPerformanceVo> performancesListRecommend = dataUtils.getPerformancesListIsRecommend();
+        if (recommend <= 2) {
+            List<KylinPerformanceVo> performancesListRecommend = dataUtils.getPerformancesListIsSystemRecommend();
             if (performancesListRecommend.size() > 0) {
                 is_native = 0;
                 performancesListNew.addAll(performancesListRecommend);

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

@@ -13,6 +13,8 @@ import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderListVo;
 import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.KylinBuyNoticeMapper;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.query.Criteria;
@@ -554,6 +556,32 @@ public class DataUtils {
         return (List<KylinPerformanceVo>) redisUtil.get(redisKey);
     }
 
+    /**
+     * 获取系统推荐演出列表redis
+     */
+    public List<KylinPerformanceVo> getPerformancesListIsSystemRecommend() {
+        String redisKey = KylinRedisConst.PERFORMANCES_LIST_SYSTEM_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));
+            // 排序
+            Sort sortName = Sort.by(Sort.Direction.ASC, "timeStart");
+            Pageable pageable = PageRequest.of(0, 8, sortName);
+            query.with(pageable);
+            // 不要查询的字段
+            query.fields().exclude("details");
+            query.fields().exclude("noticeImage");
+            query.fields().exclude("ticketTimeList");
+            // 推荐
+            List<KylinPerformanceVo> systemRecommendList = mongoTemplate.find(query, KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
+            redisUtil.set(redisKey, systemRecommendList);
+        }
+        return (List<KylinPerformanceVo>) redisUtil.get(redisKey);
+    }
+
     /**
      * 删除演出列表redis
      */