首页本地演出

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

@@ -34,7 +34,7 @@ public class KylinBannersController {
     private KylinBannersServiceImpl kylinBannersServiceImpl;
 
     @GetMapping("")
-    @ApiOperation(value = "banner列表")
+    @ApiOperation("banner列表")
     public ResponseDto<List<BannersVo>> blist(
             @RequestParam(value = "position") String position,
             @RequestParam(value = "provinceCode", defaultValue = "") String provinceCode

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

 package com.liquidnet.service.kylin.controller;
 
 
+import com.liquidnet.service.ResponseDto;
+import com.liquidnet.service.kylin.dto.param.PerformanceCreateParam;
+import com.liquidnet.service.kylin.service.impl.KylinPerformancesServiceImpl;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.HashMap;
+import java.util.List;
+
 /**
  * <p>
  * 演出 前端控制器
  * </p>
  *
- * @author liquidnet
- * @since 2021-05-05
+ * @author jiangxiulong
+ * @since 2021-05-11
  */
+@Api(tags = "前端-演出")
 @RestController
-@RequestMapping("kylin/user/performance")
+@RequestMapping("performance")
 public class KylinPerformancesController {
 
+    @Autowired
+    private KylinPerformancesServiceImpl kylinPerformancesService;
+
+    @GetMapping("localList")
+    @ApiOperation("本地演出列表")
+    public ResponseDto<HashMap<String, Object>> localList(
+            @RequestParam(value = "title", defaultValue = "") String title, //演出名称
+            @RequestParam(value = "cityId", defaultValue = "") String cityId, //省份id
+            @RequestParam(value = "type", defaultValue = "") Integer type, //演出类型
+            @RequestParam(value = "page", defaultValue = "1") Integer page,
+            @RequestParam(value = "size", defaultValue = "10") Integer size,
+
+            // 排序
+            @RequestParam(value = "SortType", defaultValue = "1") Integer SortType // 1时间正序 2时间倒序
+    ) {
+        HashMap<String, Object> result = kylinPerformancesService.localList(title, cityId, type, page, size, SortType);
+        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/controller/admin/KylinBannersAdminController.java

@@ -10,12 +10,10 @@ import com.liquidnet.service.kylin.entity.KylinBanners;
 import com.liquidnet.service.kylin.service.impl.admin.KylinBannersServiceImpl;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
-import net.bytebuddy.implementation.bytecode.constant.DefaultValue;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
-import javax.validation.groups.Default;
 import java.util.List;
 
 /**
@@ -36,7 +34,7 @@ public class KylinBannersAdminController {
     private KylinBannersServiceImpl kylinBannersServiceImpl;
 
     @PostMapping("")
-    @ApiOperation(value = "创建banner")
+    @ApiOperation("创建banner")
     public ResponseDto<Object> create(@RequestBody @Validated BannersParam bannersParam) {
         Boolean res = kylinBannersServiceImpl.create(bannersParam);
         if (res) {
@@ -47,7 +45,7 @@ public class KylinBannersAdminController {
     }
 
     @PutMapping("")
-    @ApiOperation(value = "修改banner")
+    @ApiOperation("修改banner")
     public ResponseDto<Object> update(@RequestBody BannersParam bannersParam) {
         boolean res = kylinBannersServiceImpl.update(bannersParam);
         if (res) {
@@ -58,7 +56,7 @@ public class KylinBannersAdminController {
     }
 
     @GetMapping("{bannersId}")
-    @ApiOperation(value = "banner详情")
+    @ApiOperation("banner详情")
     public ResponseDto<KylinBanners> detail(@PathVariable("bannersId") String bannersId) {
         KylinBanners result = null;
         result = kylinBannersServiceImpl.detail(bannersId);
@@ -70,7 +68,7 @@ public class KylinBannersAdminController {
     }
 
     @GetMapping("list")
-    @ApiOperation(value = "banner列表")
+    @ApiOperation("banner列表")
     public ResponseDto<PagerVo<BannerDetailsListDao>> bannerList(
             @RequestParam(value = "bannersName", defaultValue = "") String bannersName,
             @RequestParam(value = "isOnline", defaultValue = "1") Integer isOnline,
@@ -99,7 +97,7 @@ public class KylinBannersAdminController {
     }
 
     @DeleteMapping("{bannersId}")
-    @ApiOperation(value = "删除banner")
+    @ApiOperation("删除banner")
     public ResponseDto<Object> delete(@PathVariable("bannersId") String bannersId) {
         boolean result = kylinBannersServiceImpl.delete(bannersId);
         if (result) {

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

 package com.liquidnet.service.kylin.service.impl;
 
+import com.liquidnet.service.kylin.dto.param.PerformanceCreateParam;
+import com.liquidnet.service.kylin.dto.vo.PerformanceVo;
 import com.liquidnet.service.kylin.entity.KylinPerformances;
 import com.liquidnet.service.kylin.mapper.KylinPerformancesMapper;
 import com.liquidnet.service.kylin.service.IKylinPerformancesService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.mongodb.BasicDBObject;
+import org.bson.Document;
+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.BasicQuery;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
+import javax.validation.constraints.Null;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.HashMap;
+import java.util.List;
+import java.util.regex.Pattern;
+
 /**
  * <p>
- * 演出 服务实现类
+ * 前端 演出 服务实现类
  * </p>
  *
- * @author liquidnet
- * @since 2021-05-05
+ * @author jiangxiulong
+ * @since 2021-05-11
  */
 @Service
 public class KylinPerformancesServiceImpl extends ServiceImpl<KylinPerformancesMapper, KylinPerformances> implements IKylinPerformancesService {
 
+    @Autowired
+    private MongoTemplate mongoTemplate;
+
+    public HashMap<String, Object> localList(String title, String cityId, Integer type, Integer page, Integer size, Integer SortType) {
+        HashMap<String,Object> info = new HashMap<>();
+
+        // 排序 分页
+        Sort sortName = null; // 默认开票越早的在上面
+        if (SortType != null) {
+            switch (SortType) {
+                case 1:
+                    sortName = Sort.by(Sort.Direction.ASC, "sellTime");
+                    break;
+                case 2:
+                    sortName = Sort.by(Sort.Direction.DESC, "sellTime");
+                    break;
+                default:
+                    sortName = Sort.by(Sort.Direction.ASC, "sellTime");
+                    break;
+            }
+        }
+        Pageable pageable = PageRequest.of(page - 1, size, sortName);
+
+        //条件
+        Document queryObject = new Document();
+
+        if (!title.isEmpty()) {
+            queryObject.put("title", Pattern.compile(title, Pattern.CASE_INSENSITIVE));
+        }
+        if (!cityId.isEmpty()) {
+            queryObject.put("cityId", cityId);
+        }
+        if (type != null) {
+            queryObject.put("type", type);
+        }
+
+        // 固定查询条件
+        Query query = new BasicQuery(queryObject);
+        LocalDateTime nowTime = LocalDateTime.now();
+        String nowTimeStr = nowTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+        query.addCriteria(Criteria.where("stopSellTime").gte(nowTimeStr));
+        query.addCriteria(Criteria.where("statusSell").is(1));
+
+        // 要查询的字段
+        /*Document fieldsObject = new Document();
+        Query query = new BasicQuery(queryObject, fieldsObject);
+        fieldsObject.put("performancesId", true);*/
+
+        // 查询总数
+        long count = mongoTemplate.count(query, PerformanceVo.class, PerformanceVo.class.getSimpleName());
+
+        query.with(pageable);
+
+        List<PerformanceVo> list = mongoTemplate.find(query, PerformanceVo.class, PerformanceVo.class.getSimpleName());
+
+        // 组合数据
+        info.put("total",count);
+        info.put("data", list);
+
+        return info;
+    }
+
 }