diff --git a/mt/src/main/java/com/ccsens/mt/api/KCPlayerController.java b/mt/src/main/java/com/ccsens/mt/api/KCPlayerController.java index 068e7bc2..cd19b869 100644 --- a/mt/src/main/java/com/ccsens/mt/api/KCPlayerController.java +++ b/mt/src/main/java/com/ccsens/mt/api/KCPlayerController.java @@ -41,7 +41,7 @@ public class KCPlayerController { @ApiOperation(value = "云点播回调接口", notes = "上传时候后,云点播回调接口,保存视频的路径") @RequestMapping(value = "/receive", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"}) public JsonResponse receive(@RequestBody JSONObject jsonObject) { - log.info("接受文件上传通知:{}",jsonObject); + log.info("云点播回调接口:{}",jsonObject); kcPlayerService.saveVideoUrl(jsonObject); return JsonResponse.newInstance().ok(); } diff --git a/mt/src/main/java/com/ccsens/mt/service/KCPlayerService.java b/mt/src/main/java/com/ccsens/mt/service/KCPlayerService.java index ae222ba6..cafebab8 100644 --- a/mt/src/main/java/com/ccsens/mt/service/KCPlayerService.java +++ b/mt/src/main/java/com/ccsens/mt/service/KCPlayerService.java @@ -73,9 +73,11 @@ public class KCPlayerService implements IKCPlayerService{ JSONObject sourceInfo = mediaBasicInfo.getJSONObject("SourceInfo"); JSONObject sourceContext = sourceInfo.getJSONObject("SourceContext"); Long orderId = Long.parseLong(sourceContext.toString()); + log.info("获取场次id:{}",orderId); // TODO 获取视频路径 JSONObject mediaUrl = mediaBasicInfo.getJSONObject("MediaUrl"); String videoUrl = mediaUrl.toString(); + log.info("获取视频路径:{}",videoUrl); //通过场次id获取场次信息 CompeteStartOrder startOrder = startOrderMapper.selectByPrimaryKey(orderId); if(ObjectUtil.isNull(startOrder)){ @@ -85,9 +87,12 @@ public class KCPlayerService implements IKCPlayerService{ CompeteVideoExample competeVideoExample = new CompeteVideoExample(); competeVideoExample.createCriteria().andProjectIdEqualTo(startOrder.getProjectId()) .andPlayerIdEqualTo(startOrder.getPlayerId()); - if(competeVideoMapper.countByExample(competeVideoExample) > 0){ + long count = competeVideoMapper.countByExample(competeVideoExample); + log.info("查询以前上传的视频的记录:{}",count); + if(count > 0){ throw new BaseException(CodeEnum.ALREADY_UPLOAD_VIDEO); } + //将视频信息存入视频表 CompeteVideo competeVideo = new CompeteVideo(); competeVideo.setId(snowflake.nextId()); @@ -95,6 +100,7 @@ public class KCPlayerService implements IKCPlayerService{ competeVideo.setPlayerId(startOrder.getPlayerId()); competeVideo.setVideoUrl(videoUrl); competeVideo.setUploadTime(System.currentTimeMillis()); + log.info("添加上传视频记录:{}",count); competeVideoMapper.insertSelective(competeVideo); } }