提交chime社交相关

liquidnet-bus-api/liquidnet-service-chime-api/src/main/java/com/liquidnet/service/chime/dto/NewPageResult.java

+package com.liquidnet.service.chime.dto;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: NewPageResult
+ * @Package com.liquidnet.service.chime.dto
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/9/13 10:49
+ */
+
+public class NewPageResult<T> implements Serializable, Cloneable {
+    private static final long serialVersionUID = 8141034447809038759L;
+    /**
+     * 当前页数
+     */
+    private int currentPage = 1;
+    /**
+     * 每页记录数
+     */
+    private int pageSize = 10;
+
+    /**
+     * 总页数
+     */
+    private int pages;
+    /**
+     * 总记录数
+     */
+    private long total;
+
+    private boolean isOnline;
+    /**
+     * 分页数据
+     */
+    private List<T> list;
+
+    public NewPageResult() {
+    }
+
+    public int getPages() {
+        return pages;
+    }
+
+//	public NewPageResult<T> setTotalPages(int totalPages) {
+//		this.totalPages = totalPages;
+//		return this;
+//	}
+
+    public long getTotal() {
+        return total;
+    }
+
+    public NewPageResult<T> setTotal(long total, int pageSize) {
+        this.total = total;
+        if (total == -1L) {
+            this.pages = 1;
+        } else {
+            if (pageSize > 0) {
+                this.pages = (int) (total / pageSize + (total % pageSize == 0L ? 0 : 1));
+            } else {
+                this.pages = 0;
+            }
+        }
+        return this;
+    }
+
+    public List<T> getList() {
+        return list;
+    }
+
+    public NewPageResult<T> setList(List<T> list) {
+        this.list = list;
+        return this;
+    }
+
+    @Override
+    public NewPageResult<T> clone() {
+        try {
+            return (NewPageResult<T>) super.clone();
+        } catch (CloneNotSupportedException e) {
+            return new NewPageResult<>();
+        }
+    }
+
+    public static long getSerialVersionUID() {
+        return serialVersionUID;
+    }
+
+    public int getCurrentPage() {
+        return currentPage;
+    }
+
+    public NewPageResult<T> setCurrentPage(int currentPage) {
+        this.currentPage = currentPage;
+        return this;
+    }
+
+    public int getPageSize() {
+        return pageSize;
+    }
+
+    public NewPageResult<T> setPageSize(int pageSize) {
+        this.pageSize = pageSize;
+        return this;
+    }
+
+    public boolean isFirst()
+    {
+        return (this.currentPage == 1) || (this.total == 0);
+    }
+
+    public boolean isLast() {
+        return (this.total == 0) || (this.currentPage >= this.pages);
+    }
+
+    public boolean isHasNext()
+    {
+        return this.currentPage < this.pages;
+    }
+
+    public boolean isHasPrev() {
+        return this.currentPage > 1;
+    }
+    public Integer getNextPage()
+    {
+        if (this.currentPage >= this.pages) {
+            return Integer.valueOf(this.pages);
+        }
+        return Integer.valueOf(this.currentPage + 1);
+    }
+
+    public Integer getPrevPage() {
+        if (this.currentPage <= 1) {
+            return Integer.valueOf(1);
+        }
+        return Integer.valueOf(this.currentPage - 1);
+    }
+
+    public void setPages(int pages) {
+        this.pages = pages;
+    }
+
+    public void setTotal(long total) {
+        this.total = total;
+    }
+
+    public boolean getIsOnline() {
+        return isOnline;
+    }
+
+    public void setIsOnline(boolean online) {
+        isOnline = online;
+    }
+}
+

liquidnet-bus-api/liquidnet-service-chime-api/src/main/java/com/liquidnet/service/chime/service/IChimePerformanceService.java

 package com.liquidnet.service.chime.service;
 
-import com.liquidnet.service.base.PagedResult;
 import com.liquidnet.service.chime.dto.ChimeUserInfoDto;
 import com.liquidnet.service.chime.dto.ChimeUserListQueryReqDto;
+import com.liquidnet.service.chime.dto.NewPageResult;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
@@ -16,5 +16,5 @@ import com.liquidnet.service.chime.dto.ChimeUserListQueryReqDto;
 public interface IChimePerformanceService {
 //    PageInfo<ChimeUserInfoDto> getUserListByCon(ChimeUserListQueryReqDto reqDto);
 
-    PagedResult<ChimeUserInfoDto> getUserListByCon(ChimeUserListQueryReqDto reqDto);
+    NewPageResult<ChimeUserInfoDto> getUserListByCon(ChimeUserListQueryReqDto reqDto);
 }

liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/biz/ChimeUserBiz.java

@@ -100,4 +100,13 @@ public class ChimeUserBiz {
         }
         return performanceDtoList;
     }
+
+    /**
+     * 根据演出id判断是否在场
+     * @param performanceId
+     * @return
+     */
+    public boolean userIsOnline(String performanceId){
+        return true;
+    }
 }

liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/controller/ChimePerformanceController.java

@@ -4,11 +4,11 @@ import com.alibaba.fastjson.JSON;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.commons.lang.util.StringUtil;
-import com.liquidnet.service.base.PagedResult;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.chime.biz.ChimeUserBiz;
 import com.liquidnet.service.chime.dto.ChimeUserInfoDto;
 import com.liquidnet.service.chime.dto.ChimeUserListQueryReqDto;
+import com.liquidnet.service.chime.dto.NewPageResult;
 import com.liquidnet.service.chime.dto.PerformanceDto;
 import com.liquidnet.service.chime.service.IChimePerformanceService;
 import com.liquidnet.service.chime.service.IChimeUserService;
@@ -146,7 +146,7 @@ public class ChimePerformanceController {
             @ApiImplicitParam(type = "query", dataType = "String", name = "orderBy", value = "排序字段 时间timeStart"),
             @ApiImplicitParam(type = "query", dataType = "String", name = "sort", value = "排序方式[DESC ASC]"),
     })
-    public ResponseDto<PagedResult<ChimeUserInfoDto>> getUserListByCon(
+    public ResponseDto<NewPageResult<ChimeUserInfoDto>> getUserListByCon(
             @RequestParam(defaultValue = "") String performanceId,
             @RequestParam(defaultValue = "") String sex,
             @RequestParam(defaultValue = "1") int pageNum,
@@ -164,11 +164,14 @@ public class ChimePerformanceController {
         reqDto.setSex(sex);
         reqDto.setTags(tags);
 //        PageInfo<ChimeUserInfoDto> pageInfo = chimePerformanceService.getUserListByCon(reqDto);
-        PagedResult<ChimeUserInfoDto> pageInfo = chimePerformanceService.getUserListByCon(reqDto);
+        NewPageResult<ChimeUserInfoDto> pageInfo = chimePerformanceService.getUserListByCon(reqDto);
 
         //切换场次
         chimeUserService.switchPerformanceId(performanceId);
 
+        //根据演出id判断当前用户是否在场
+        boolean isOnline = chimeUserBiz.userIsOnline(performanceId);
+        pageInfo.setIsOnline(isOnline);
         return ResponseDto.success(pageInfo);
     }
 }

liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/service/impl/ChimePerformanceServiceImpl.java

@@ -6,6 +6,7 @@ import com.liquidnet.service.base.PagedResult;
 import com.liquidnet.service.chime.dto.ChimeUserInfoDto;
 import com.liquidnet.service.chime.dto.ChimeUserListQueryReqDto;
 import com.liquidnet.service.chime.dto.ChimeUserTagDto;
+import com.liquidnet.service.chime.dto.NewPageResult;
 import com.liquidnet.service.chime.service.IChimePerformanceService;
 import com.liquidnet.service.chime.utils.ObjectUtil;
 import com.liquidnet.service.chime.vo.mongo.ChimeUserInfoVo;
@@ -46,8 +47,8 @@ public class ChimePerformanceServiceImpl implements IChimePerformanceService{
      * @return
      */
     @Override
-    public PagedResult<ChimeUserInfoDto> getUserListByCon(ChimeUserListQueryReqDto reqDto) {
-        PagedResult<ChimeUserInfoDto> pagedResult = ObjectUtil.getChimeUserInfoDtoPagedResult();
+    public NewPageResult<ChimeUserInfoDto> getUserListByCon(ChimeUserListQueryReqDto reqDto) {
+        NewPageResult<ChimeUserInfoDto> pagedResult = ObjectUtil.getChimeUserInfoDtoPagedResult();
         try {
             int pageNum = reqDto.getPageNum() - 1;
             int pageSize = reqDto.getPageSize();

liquidnet-bus-service/liquidnet-service-chime/liquidnet-service-chime-impl/src/main/java/com/liquidnet/service/chime/utils/ObjectUtil.java

@@ -2,11 +2,12 @@ package com.liquidnet.service.chime.utils;
 
 import com.liquidnet.service.base.PagedResult;
 import com.liquidnet.service.chime.dto.ChimeUserInfoDto;
+import com.liquidnet.service.chime.dto.NewPageResult;
 
 public class ObjectUtil {
-    private static final PagedResult<ChimeUserInfoDto>  chimeUserInfoDtoPagedResult = new PagedResult<>();
+    private static final NewPageResult<ChimeUserInfoDto>  chimeUserInfoDtoPagedResult = new NewPageResult<>();
 
-    public static PagedResult<ChimeUserInfoDto> getChimeUserInfoDtoPagedResult() {
+    public static NewPageResult<ChimeUserInfoDto> getChimeUserInfoDtoPagedResult() {
         return chimeUserInfoDtoPagedResult.clone();
     }
 }