20201121v1.1

mt/src/main/java/com/ccsens/mt/api/KCPlayerController.java

@@ -30,9 +30,9 @@ public class KCPlayerController {
 
     @ApiOperation(value = "查看云点播签名", notes = "从redis获取云点播签名，有则返回，没有则调用工具类查询，存入redis并返回")
     @RequestMapping(value = "/get", method = RequestMethod.POST, produces = {"application/json;charset=UTF-8"})
-    public JsonResponse<String> getSignature() {
+    public JsonResponse<String> getSignature(Long id) {
         log.info("查看云点播签名");
-        String signature = kcPlayerService.getSignature();
+        String signature = kcPlayerService.getSignature(id);
         log.info("查看云点播签名：{}",signature);
         return JsonResponse.newInstance().ok(signature);
     }

mt/src/main/java/com/ccsens/mt/service/IKCPlayerService.java

@@ -1,5 +1,5 @@
 package com.ccsens.mt.service;
 
 public interface IKCPlayerService {
-    String getSignature();
+    String getSignature(Long id);
 }

mt/src/main/java/com/ccsens/mt/service/KCPlayerService.java

@@ -23,12 +23,13 @@ public class KCPlayerService implements IKCPlayerService{
     /**
      * 获取云点播签名
      * @return 返回签名
+     * @param id
      */
     @Override
-    public String getSignature() {
+    public String getSignature(Long id) {
         String signature;
         //查询redis
-        Object o = redisUtil.get(Constant.Redis.KC_PLAYER_SIGNATURE);
+        Object o = redisUtil.get(Constant.Redis.KC_PLAYER_SIGNATURE + id);
         if(ObjectUtil.isNotNull(o)){
             return (String) o;
         }
@@ -39,10 +40,10 @@ public class KCPlayerService implements IKCPlayerService{
         // 签名有效期：2天
         sign.setSignValidDuration(3600 * 24 * 2);
         try {
-            signature = sign.getUploadSignature();
+            signature = sign.getUploadSignature(id);
             log.info("获取云点播签名成功：{}",signature);
             //存入redis
-            redisUtil.set(Constant.Redis.KC_PLAYER_SIGNATURE,signature,3600 * 24);
+            redisUtil.set(Constant.Redis.KC_PLAYER_SIGNATURE + id,signature,3600 * 24);
         } catch (Exception e) {
             log.error("获取云点播签名失败",e);
             throw new BaseException(CodeEnum.SYS_ERROR);

mt/src/main/java/com/ccsens/mt/util/Constant.java

@@ -32,7 +32,7 @@ public class Constant {
         // 远程比赛参赛单位
         public final static String COMPETE_LEVEL = "compete_";
         //云点播签名
-        public final static String KC_PLAYER_SIGNATURE = "kc_player_signature";
+        public final static String KC_PLAYER_SIGNATURE = "kc_player_signature_";
     }
 
     public static final int VOTE_TOTAL = 2;

util/src/main/java/com/ccsens/util/KCPlayerSignature.java

@@ -29,7 +29,7 @@ public class KCPlayerSignature{
     }
 
     // 获取签名
-    public String getUploadSignature() throws Exception {
+    public String getUploadSignature(Long id) throws Exception {
         String strSign = "";
         String contextStr = "";
 
@@ -39,7 +39,7 @@ public class KCPlayerSignature{
         contextStr += "&currentTimeStamp=" + currentTime;
         contextStr += "&expireTime=" + endTime;
         contextStr += "&random=" + random;
-        contextStr += "&sourceContext=id";
+        contextStr += "&sourceContext=" + id;
 
 
         try {
@@ -94,7 +94,7 @@ public class KCPlayerSignature{
         sign.setSignValidDuration(3600 * 24 * 2);
 
         try {
-            String signature = sign.getUploadSignature();
+            String signature = sign.getUploadSignature(id);
             System.out.println("signature : " + signature);
         } catch (Exception e) {
             System.out.print("获取签名失败");