package com.qxueyou.scc.controller;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import com.qxueyou.scc.admin.classes.model.ClsClass;
|
import com.qxueyou.scc.admin.classes.service.IClassService;
|
import com.qxueyou.scc.admin.teacher.service.ITeacherService;
|
import com.qxueyou.scc.base.model.Result;
|
import com.qxueyou.scc.base.util.ClientUtils;
|
import com.qxueyou.scc.base.util.CollectionUtils;
|
import com.qxueyou.scc.base.util.QBeanUtils;
|
import com.qxueyou.scc.teach.live.dao.MediaLiveDAO;
|
import com.qxueyou.scc.teach.live.model.MediaVideoLive;
|
import com.qxueyou.scc.teach.live.model.MediaVideoLiveReplay;
|
import com.qxueyou.scc.teach.live.service.IMediaLiveService;
|
import com.qxueyou.scc.teach.live.service.IMediaVideoLivePlayBackService;
|
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
|
@Api(tags="直播管理接口")
|
@RestController
|
@CrossOrigin(origins="*",maxAge=3600)
|
@RequestMapping(value = "/admin/videoLive")
|
public class VideoLiveController {
|
|
// 分页查询中，默认记录条数和页数
|
private static final int DEFAULT_PAGE_SIZE = 10;
|
private static final int DEFAULT_PAGE_NUM = 1;
|
|
@Autowired
|
IMediaLiveService liveService;
|
|
@Autowired
|
IMediaVideoLivePlayBackService mediaVideoLivePlayBackService;
|
|
@Autowired
|
IClassService classService;
|
|
@Autowired
|
MediaLiveDAO dao;
|
|
/**
|
* 获取直播列表
|
*
|
* @param keyword
|
* 搜索关键字
|
* @param pageNum
|
* 页码
|
* @param pageSize
|
* 页数
|
* @return
|
*/
|
@ApiOperation(value = "获取创建人的直播列表")
|
@GetMapping(value = "list")
|
public Result list(String keyword, Integer pageNum, Integer pageSize) {
|
|
List<MediaVideoLive> data = liveService.listOfMine(keyword, pageNum, pageSize);
|
int count = liveService.listCountOfMine(keyword);
|
|
return new Result(true, "success", CollectionUtils.newObjectMap("videoLiveCount", count,
|
"videoLiveLst",QBeanUtils.listBean2ListMap(data, CollectionUtils.newStringMap(
|
"creator","creator",
|
"startTime","startTime",
|
"endTime","endTime",
|
"updateTime","lastUpdateTime",
|
"videoLiveId","videoLiveId",
|
"name","name",
|
"subjectId","subjectId",
|
"subjectName","subjectName",
|
"status","status",
|
"pushUrl","rtmpPushUrl",
|
"hlsPullUrl","hlsPullUrl",
|
"previewImgUrl","previewImgUrl"
|
))));
|
}
|
|
/**
|
* 新增直播/更新直播
|
*
|
* @param videoLiveId
|
* 直播id（更新的时候才需要传）
|
* @param name
|
* 直播名称
|
* @param content
|
* 直播介绍
|
* @param imgPath
|
* 图片地址
|
* @param startTime
|
* 开始时间
|
* @param endTime
|
* 结束时间
|
* @param isPlayBack
|
* 是否回放
|
* @param classIds
|
* 班级id
|
* @return
|
*/
|
@ApiOperation(value = "创建编辑直播")
|
@PostMapping(value = "addOrUpdate")
|
public Result addOrUpdate(String videoLiveId, String name, String content,String teacherId,String teacherName,String subjectId,
|
String subjectName,String definition,String imgPath, long startTime,long endTime, boolean isPlayBack, String classIds) {
|
if(StringUtils.isEmpty(videoLiveId)) {
|
return liveService.add(name, content,teacherId,teacherName,subjectId,subjectName,definition,imgPath, new Date(startTime), new Date(endTime), isPlayBack, StringUtils.isEmpty(classIds)?null:CollectionUtils.newList(String.class,classIds.split(",")));
|
}else {
|
return liveService.update(videoLiveId,name, content,teacherId,teacherName,subjectId,subjectName,definition,imgPath, new Date(startTime), new Date(endTime), isPlayBack, StringUtils.isEmpty(classIds)?null:CollectionUtils.newList(String.class,classIds.split(",")));
|
}
|
}
|
|
/**
|
* 查询直播详情
|
*
|
* @param videoLiveId
|
* 直播id
|
* @return
|
*/
|
@ApiOperation(value = "获取直播详情")
|
@GetMapping(value = "queryDetail")
|
public Result detail(String videoLiveId) {
|
List<String> lstClassIds = null;
|
List<Map<String,Object>> lstClassIdNames = null;
|
|
MediaVideoLive live = liveService.read(videoLiveId);
|
List<ClsClass> lstClassses = live.getClasses();
|
|
if(lstClassses!=null){
|
lstClassIds = new ArrayList<String>(lstClassses.size());
|
lstClassIdNames = new ArrayList<Map<String,Object>>(lstClassses.size());
|
|
for(ClsClass cls: lstClassses){
|
lstClassIds.add(cls.getClassId());
|
lstClassIdNames.add(CollectionUtils.newObjectMap("classId",cls.getClassId(),"className",cls.getName()));
|
}
|
}
|
|
return new Result(true, "success",
|
CollectionUtils.newObjectMap(
|
"videoLiveId",live.getVideoLiveId(),
|
"name", live.getName(),
|
"content", live.getRemark(),
|
"imgPath", live.getPreviewImgUrl(),
|
"isplayBack",1,
|
"startTime", live.getStartTime(),
|
"endTime", live.getEndTime(),
|
"rtmpPushUrl", live.getPushUrl(),
|
"hlsPullUrl", live.getHlsPullUrl(),
|
"chatroomId", dao.getChatRoomId(videoLiveId),
|
"watchTimes",live.getWatchTimes(),
|
"praiseTimes",live.getPraiseTimes(),
|
"definition",live.getDefinition(),
|
"subjectId",live.getSubjectId(),
|
"subjectName",live.getSubjectName(),
|
"status",live.getStatus(),
|
"teacherId",live.getAnchorId(),
|
"teacherName",live.getAnchor(),
|
"classIds",lstClassIds ,
|
"classes", lstClassIdNames));
|
}
|
|
/**
|
* 发布/多个以逗号隔开
|
*
|
* @param videoLiveIds
|
* 直播ids
|
* @return
|
*/
|
@ApiOperation(value = "发布直播")
|
@PostMapping(value = "release")
|
public Result release(String videoLiveIds) {
|
for(String liveId:videoLiveIds.split(",")) {
|
liveService.doIssue(liveId);
|
}
|
return Result.SUCCESS;
|
}
|
|
/**
|
* 取消发布/多个以逗号隔开
|
*
|
* @param videoLiveIds
|
* 直播ids
|
* @return
|
*/
|
@ApiOperation(value = "取消发布直播")
|
@PostMapping(value = "cancel")
|
public Result cance(String videoLiveIds) {
|
|
for(String liveId:videoLiveIds.split(",")) {
|
liveService.doCancel(liveId);
|
}
|
return Result.SUCCESS;
|
}
|
|
/**
|
* 删除/多个以逗号隔开
|
*
|
* @param videoLiveId
|
* @return
|
*/
|
@ApiOperation(value = "删除创建的直播")
|
@PostMapping(value = "delete")
|
public Result delete(String videoLiveIds) {
|
return liveService.delete(videoLiveIds.split(","));
|
}
|
|
|
/**
|
* 直播开始
|
*
|
* @param videoLiveIds
|
* 直播id
|
*/
|
@ApiOperation(value = "直播开始")
|
@PostMapping(value = "start")
|
public Result start(String videoLiveIds) {
|
|
for(String liveId:videoLiveIds.split(",")) {
|
liveService.doStart(liveId);
|
}
|
return Result.SUCCESS;
|
}
|
|
|
/**
|
* 直播暂停
|
*
|
* @param videoLiveIds
|
* 直播id
|
*/
|
@ApiOperation(value = "直播暂停")
|
@PostMapping(value = "pause")
|
public Result pause(String videoLiveIds) {
|
|
for(String liveId:videoLiveIds.split(",")) {
|
liveService.doPause(liveId);
|
}
|
return Result.SUCCESS;
|
}
|
|
/**
|
* 直播结束
|
*
|
* @param videoLiveId
|
* 直播id
|
*/
|
@ApiOperation(value = "直播结束")
|
@PostMapping(value = "stop")
|
public Result stop(String videoLiveIds) {
|
|
for(String liveId:videoLiveIds.split(",")) {
|
liveService.doStop(liveId);
|
}
|
return Result.SUCCESS;
|
}
|
|
|
|
/**
|
* 直播点赞
|
*
|
* @param videoLiveId
|
* 直播id
|
*/
|
@ApiOperation(value = "直播点赞")
|
@PostMapping(value = "praise")
|
public Result praise(String videoLiveId) {
|
return liveService.doPraise(videoLiveId);
|
}
|
|
@ApiOperation(value = "学生端根据班级，课程过滤直播列表")
|
@GetMapping(value = "student/list")
|
public Result list(String keyword,String classIds,String subjectId,Short status,Integer pageNum, Integer pageSize) {
|
pageSize = pageSize != null && pageSize > 0 ? pageSize : DEFAULT_PAGE_SIZE;
|
pageNum = pageNum != null && pageNum > 0 ? pageNum : DEFAULT_PAGE_NUM;
|
|
String [] arrClassIds = null;
|
if(StringUtils.isNotEmpty(classIds) || StringUtils.isNotBlank(ClientUtils.getClassId())){
|
arrClassIds = StringUtils.isEmpty(classIds)?new String[]{ClientUtils.getClassId()}:classIds.split(",");
|
}
|
|
int count = liveService.listCount(keyword==null?"":keyword.trim() , arrClassIds , subjectId , status);
|
List<MediaVideoLive> data = liveService.list(keyword==null?"":keyword.trim(),StringUtils.isEmpty(classIds)?new String[]{ClientUtils.getClassId()}:classIds.split(","),subjectId,status, pageNum, pageSize);
|
|
return new Result(true, "success", CollectionUtils.newObjectMap("videoLiveCount", count,
|
"videoLiveLst",QBeanUtils.listBean2ListMap(data, CollectionUtils.newStringMap(
|
"creator","creator",
|
"startTime","startTime",
|
"endTime","endTime",
|
"updateTime","lastUpdateTime",
|
"videoLiveId","videoLiveId",
|
"name","name",
|
"subjectId","subjectId",
|
"subjectName","subjectName",
|
"status","status",
|
"pushUrl","rtmpPushUrl",
|
"hlsPullUrl","hlsPullUrl",
|
"previewImgUrl","previewImgUrl"
|
))));
|
}
|
|
@ApiOperation(value = "直播回放列表")
|
@GetMapping(value = "replay/list")
|
public Result listReplay(String videoLiveId) {
|
|
List<MediaVideoLiveReplay> data = mediaVideoLivePlayBackService.queryVideoLiveReplay(videoLiveId);
|
|
return new Result(true, "success", CollectionUtils.newObjectMap(
|
"replayList",QBeanUtils.listBean2ListMap(data, CollectionUtils.newStringMap(
|
"name","replayName",
|
"creator","creator",
|
"beginTime","beginTime",
|
"endTime","endTime",
|
"updateTime","updateTime",
|
"duration","duration",
|
"initialSize","initialSize",
|
"url","url",
|
"videoLiveId","videoLiveId",
|
"status","status",
|
"liveReplayId","liveReplayId"
|
))));
|
}
|
|
@ApiOperation(value = "测试直播回放")
|
@GetMapping(value = "replay/test")
|
public Result testReplay(String liveId) {
|
mediaVideoLivePlayBackService.testPlayBack(liveId);
|
return new Result(true);
|
}
|
|
}
|
