Merge branch 'pt' of https://dd.tall.wiki/gitea/ccsens_wiki/ccsenscloud into pt

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();
     }

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);
     }
 }