派生自 projectDept/qhighschool
src/main/java/com/qxueyou/scc/controller/VideoLiveController.java
@@ -1,12 +1,23 @@ package com.qxueyou.scc.controller; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.TimeUnit; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.hankcs.hanlp.corpus.tag.Nature; import com.qxueyou.scc.base.dao.CommonDAO; import com.qxueyou.scc.config.IpUtils; import com.qxueyou.scc.sdk.MTCloud; import com.qxueyou.scc.teach.live.model.AccessLog; import com.qxueyou.scc.teach.live.utils.RedisCache; import io.swagger.models.auth.In; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.HttpRequest; import org.springframework.web.bind.annotation.*; import com.qxueyou.scc.admin.classes.model.ClsClass; @@ -24,9 +35,16 @@ import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import springfox.documentation.spring.web.json.Json; import javax.servlet.http.HttpServletRequest; import static com.hankcs.hanlp.corpus.tag.Nature.r; import static com.hankcs.hanlp.corpus.tag.Nature.s; @Api(tags="直播管理接口") @RestController @Slf4j @CrossOrigin(origins="*",maxAge=3600) @RequestMapping(value = "/admin/videoLive") public class VideoLiveController { @@ -46,7 +64,12 @@ @Autowired MediaLiveDAO dao; @Autowired CommonDAO commonDAO; @Autowired private RedisCache redisCache; /** * 获取直播列表 * @@ -60,11 +83,11 @@ */ @ApiOperation(value = "获取创建人的直播列表") @GetMapping(value = "list") public Result list(String keyword, Integer pageNum, Integer pageSize) { public Result list(String keyword,String portalStatus, Integer pageNum, Integer pageSize) { List<MediaVideoLive> data = liveService.listOfMine(keyword, pageNum, pageSize); List<MediaVideoLive> data = liveService.listOfMine(keyword,portalStatus, pageNum, pageSize); int count = liveService.listCountOfMine(keyword); return new Result(true, "success", CollectionUtils.newObjectMap("videoLiveCount", count, "videoLiveLst",QBeanUtils.listBean2ListMap(data, CollectionUtils.newStringMap( "creator","creator", @@ -78,10 +101,20 @@ "status","status", "pushUrl","rtmpPushUrl", "hlsPullUrl","hlsPullUrl", "previewImgUrl","previewImgUrl" "previewImgUrl","previewImgUrl", "courseId","courseId", "portalStatus","portalStatus" )))); } @ApiOperation(value = "获取已结束直播列表") @GetMapping(value = "listvideo") public Result listvideo() { List<MediaVideoLive> data = liveService.listvideo("9"); return new Result(true, "success", CollectionUtils.newObjectMap("listVideo",data)); } /** * 新增直播/更新直播 * @@ -106,14 +139,101 @@ @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(","))); String subjectName,String definition,String imgPath, long startTime,long endTime, boolean isPlayBack, String classIds,String portalStatus) throws Exception { MTCloud client = new MTCloud(); HashMap<Object,Object> options = new HashMap<Object,Object>(); options.put("barrage", 1); options.put("isPublic", 1); options.put("robotNumber", 1); options.put("robotType", 1); options.put("pptDisplay", 1); options.put("modetype", 6); //将long类型转换为String类型 SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String startTime1 = simpleDateFormat.format(new Date(startTime)); String endTime1 = simpleDateFormat.format(new Date(endTime)); System.out.println(startTime1+"------"+endTime1); //调用第三方直播接口 String s = client.courseAdd(name, ClientUtils.getUserId(), startTime1, endTime1, ClientUtils.getUserName(), "222", options); //json转换拿到courseId JSONObject jsonObject = JSON.parseObject(s); JSONObject data = jsonObject.getJSONObject("data"); if(jsonObject.getString("code").equals("0")) { String course_id = (String) data.get("course_id"); liveService.add(name, content,teacherId,teacherName,subjectId,subjectName,definition,imgPath, new Date(startTime), new Date(endTime),Integer.parseInt(course_id), isPlayBack, StringUtils.isEmpty(classIds)?null:CollectionUtils.newList(String.class,classIds.split(",")),portalStatus); return new Result(true, "成功", s); } return new Result(false,jsonObject.getString("msg")); } @ApiOperation(value = "开启直播") @GetMapping(value = "OpenLive") public Result OpenLive(Integer courseId, String logId, HttpServletRequest request) throws Exception { MTCloud client = new MTCloud(); String redisUrl = redisCache.getCacheObject("ZCR" + courseId); AccessLog accessLog = new AccessLog(); if (StringUtils.isEmpty(logId)) { String ip = IpUtils.getIpAddr(request); String cityInfo = null; try { cityInfo = IpUtils.getCityInfo(ip); } catch (Exception e) { log.error("获取ip归属地信息失败！"); } accessLog.setCourseId(courseId.toString()); accessLog.setEnterTime(new Date()); accessLog.setType("videoLive"); accessLog.setName(ClientUtils.getUserName()); accessLog.setIp(ip); accessLog.setIpAttribution(cityInfo); accessLog.setCreateTime(new Date()); accessLog.setUpdateTime(new Date()); //访问留痕 commonDAO.save(accessLog); } if (StringUtils.isEmpty(redisUrl)) { HashMap<Object, Object> options = new HashMap<Object, Object>(); options.put("ssl", false); String res = client.courseLogin(ClientUtils.getUserId(), MTCloud.ACCOUNT_TYPE_THIRD, options); JSONObject jsonObject = JSON.parseObject(res); if (jsonObject.getString("code").equals("0")) { JSONObject data = jsonObject.getJSONObject("data"); String protocol = (String) data.get("url"); redisCache.setCacheObject("ZCR" + courseId, protocol, 1, TimeUnit.DAYS); return new Result(true,"suc", CollectionUtils.newObjectMap("url", protocol, "log", accessLog.getLogId())); } } return new Result(true,"suc",CollectionUtils.newObjectMap("url", redisUrl, "log", accessLog.getLogId())); } @ApiOperation(value = "修改直播状态") @GetMapping(value = "updateLive") public Result updateLive(Integer courseId) { MediaVideoLive revamp = liveService.revamp(courseId); revamp.setStatus(MediaVideoLive.STATUS_LIVE_STOP); commonDAO.update(revamp); return new Result(true,"关闭成功"); } @ApiOperation(value = "在线时长") @GetMapping(value = "onlineCommunication") public Result onlineCommunication(String courseId,Integer page, Integer size) throws Exception { MTCloud client = new MTCloud(); HashMap<Object,Object> options = new HashMap<Object, Object>(); options.put("ssl", false); String res = client.courseVisitorList(courseId,page,size,options); return new Result(true,"开启成功",res); } // @ApiOperation(value = "查看详情") // @GetMapping(value = "detailLive") // public Result detailLive(String liveId) { // commonDAO.find // return new Result(true,"开启成功",res); // } /** * 查询直播详情 * @@ -200,13 +320,13 @@ /** * 删除/多个以逗号隔开 * * @param videoLiveId * @param videoLiveIds * @return */ @ApiOperation(value = "删除创建的直播") @PostMapping(value = "delete") public Result delete(String videoLiveIds) { return liveService.delete(videoLiveIds.split(",")); public Result delete(String videoLiveIds,String courseIds) throws Exception { return liveService.delete(videoLiveIds.split(","),courseIds.split(",")); } @@ -246,7 +366,7 @@ /** * 直播结束 * * @param videoLiveId * @param videoLiveIds * 直播id */ @ApiOperation(value = "直播结束") @@ -300,7 +420,8 @@ "status","status", "pushUrl","rtmpPushUrl", "hlsPullUrl","hlsPullUrl", "previewImgUrl","previewImgUrl" "previewImgUrl","previewImgUrl", "courseId","courseId" )))); }
