演出预告、推荐接口初步实现

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

@@ -2,6 +2,7 @@ package com.liquidnet.service.kylin.controller;
 
 
 import com.liquidnet.service.ResponseDto;
+import com.liquidnet.service.kylin.dto.vo.PerformanceVo;
 import com.liquidnet.service.kylin.service.impl.KylinPerformancesServiceImpl;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -13,6 +14,7 @@ import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.HashMap;
+import java.util.List;
 
 /**
  * <p>
@@ -51,4 +53,26 @@ public class KylinPerformancesController {
         }
     }
 
+    @GetMapping("recommendList")
+    @ApiOperation("推荐演出列表")
+    public ResponseDto<List<PerformanceVo>> recommendList() {
+        List<PerformanceVo> result = kylinPerformancesService.recommendList();
+        if (result.size() > 0) {
+            return ResponseDto.success(result);
+        } else {
+            return ResponseDto.failure("获取演出列表失败");
+        }
+    }
+
+    @GetMapping("noticeList")
+    @ApiOperation("演出预告列表")
+    public ResponseDto<List<PerformanceVo>> noticeList() {
+        List<PerformanceVo> result = kylinPerformancesService.noticeList();
+        if (result.size() > 0) {
+            return ResponseDto.success(result);
+        } else {
+            return ResponseDto.failure("获取演出列表失败");
+        }
+    }
+
 }

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

@@ -100,4 +100,32 @@ public class KylinPerformancesServiceImpl extends ServiceImpl<KylinPerformancesM
         return info;
     }
 
+    public List<PerformanceVo> recommendList() {
+        // 固定查询条件
+        LocalDateTime nowTime = LocalDateTime.now();
+        String nowTimeStr = nowTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+        Query query = Query.query(
+                Criteria.where("stopSellTime").gte(nowTimeStr).and("statusSell").is(1)
+        );
+
+        List<PerformanceVo> list = mongoTemplate.find(query, PerformanceVo.class, PerformanceVo.class.getSimpleName());
+
+        return list;
+    }
+
+    public List<PerformanceVo> noticeList() {
+        // 固定查询条件
+        LocalDateTime nowTime = LocalDateTime.now();
+        LocalDateTime threeDaysLater = nowTime.plusDays(3);
+        String nowTimeStr = nowTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+        String threeDaysLaterStr = threeDaysLater.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+        Query query = Query.query(
+                Criteria.where("sellTime").gte(nowTimeStr).lt(threeDaysLaterStr).and("statusSell").is(1)
+        );
+
+        List<PerformanceVo> list = mongoTemplate.find(query, PerformanceVo.class, PerformanceVo.class.getSimpleName());
+
+        return list;
+    }
+
 }