|
@@ -1,5 +1,9 @@
|
|
package com.yonge.cooleshow.admin.controller.open;
|
|
package com.yonge.cooleshow.admin.controller.open;
|
|
|
|
|
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
|
+import com.yonge.cooleshow.api.feign.dto.RoomMember;
|
|
|
|
+import com.yonge.cooleshow.biz.dal.enums.ClientEnum;
|
|
|
|
+import com.yonge.cooleshow.biz.dal.service.ImGroupService;
|
|
import com.yonge.cooleshow.biz.dal.service.ImLiveBroadcastRoomMemberService;
|
|
import com.yonge.cooleshow.biz.dal.service.ImLiveBroadcastRoomMemberService;
|
|
import com.yonge.cooleshow.biz.dal.service.LiveRoomService;
|
|
import com.yonge.cooleshow.biz.dal.service.LiveRoomService;
|
|
import com.yonge.cooleshow.biz.dal.wrapper.liveroom.ImLiveBroadcastRoomMemberWrapper;
|
|
import com.yonge.cooleshow.biz.dal.wrapper.liveroom.ImLiveBroadcastRoomMemberWrapper;
|
|
@@ -12,6 +16,7 @@ import io.swagger.annotations.ApiImplicitParams;
|
|
import io.swagger.annotations.ApiOperation;
|
|
import io.swagger.annotations.ApiOperation;
|
|
import io.swagger.annotations.ApiParam;
|
|
import io.swagger.annotations.ApiParam;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
+import org.apache.commons.collections.CollectionUtils;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.web.bind.annotation.*;
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
|
|
|
@@ -29,6 +34,9 @@ public class OpenLiveController extends BaseController {
|
|
@Autowired
|
|
@Autowired
|
|
private ImLiveBroadcastRoomMemberService imLiveBroadcastRoomMemberService;
|
|
private ImLiveBroadcastRoomMemberService imLiveBroadcastRoomMemberService;
|
|
|
|
|
|
|
|
+ @Autowired
|
|
|
|
+ private ImGroupService imGroupService;
|
|
|
|
+
|
|
@ApiOperation("查询房间人数")
|
|
@ApiOperation("查询房间人数")
|
|
@GetMapping("/queryRoomInfo")
|
|
@GetMapping("/queryRoomInfo")
|
|
public HttpResponseResult<ImLiveBroadcastRoomMemberWrapper.RoomMemberNumDto> queryRoomInfo(@ApiParam(value = "房间uid", required = true) String roomUid) {
|
|
public HttpResponseResult<ImLiveBroadcastRoomMemberWrapper.RoomMemberNumDto> queryRoomInfo(@ApiParam(value = "房间uid", required = true) String roomUid) {
|
|
@@ -46,9 +54,17 @@ public class OpenLiveController extends BaseController {
|
|
@ApiImplicitParam(name = "rows", dataType = "Integer", value = "每页数量"),
|
|
@ApiImplicitParam(name = "rows", dataType = "Integer", value = "每页数量"),
|
|
})
|
|
})
|
|
@PostMapping("/queryRoomMember")
|
|
@PostMapping("/queryRoomMember")
|
|
- public HttpResponseResult<List<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember>> queryRoomMember(@RequestBody Map<String, Object> param) {
|
|
|
|
|
|
+ public HttpResponseResult<List<RoomMember>> queryRoomMember(@RequestBody Map<String, Object> param) {
|
|
param.put("page",1);
|
|
param.put("page",1);
|
|
param.put("rows",-1);
|
|
param.put("rows",-1);
|
|
- return succeed(imLiveBroadcastRoomMemberService.queryRoomMember(param).getRows());
|
|
|
|
|
|
+ List<ImLiveBroadcastRoomMemberWrapper.ImLiveBroadcastRoomMember> rows = imLiveBroadcastRoomMemberService.queryRoomMember(param).getRows();
|
|
|
|
+ if (CollectionUtils.isNotEmpty(rows)) {
|
|
|
|
+ List<RoomMember> roomMembers = JSON.parseArray(JSON.toJSONString(rows), RoomMember.class);
|
|
|
|
+ for (RoomMember roomMember : roomMembers) {
|
|
|
|
+ roomMember.setImUserId(imGroupService.getImUserId(roomMember.getStudentId(), ClientEnum.STUDENT));
|
|
|
|
+ }
|
|
|
|
+ return succeed(roomMembers);
|
|
|
|
+ }
|
|
|
|
+ return succeed();
|
|
}
|
|
}
|
|
}
|
|
}
|