update

edu-im/edu-im-server/src/main/java/com/keao/edu/im/mec/im/IMHelper.java

@@ -282,6 +282,7 @@ public class IMHelper {
             log.error("直播视频录制失败：body : {},resultInfo : {} 准备重试",body,resultInfo);
             int i = 1;
             while (i<=3){
+                redisTemplate.delete("sessionId:" + roomId);
                 Thread.sleep(3000l);
                 List<RoomMember> members = roomMemberDao.findByRidAndMsidFlag(roomId,true);
                 if (members == null || members.size() == 0) {
@@ -415,10 +416,10 @@ public class IMHelper {
         if (StringUtils.isEmpty(roomId)) {
             throw new IllegalArgumentException("Paramer 'roomId' is required");
         }
-//        String sessionId = redisTemplate.opsForValue().get("sessionId:" + roomId);
-//        if(StringUtils.isNotEmpty(sessionId)){
-//            return sessionId;
-//        }
+        String sessionId = redisTemplate.opsForValue().get("sessionId:" + roomId);
+        if(StringUtils.isNotEmpty(sessionId)){
+            return sessionId;
+        }
         JSONObject jsonObject = new JSONObject();
         jsonObject.put("roomId",roomId);
 
@@ -430,9 +431,8 @@ public class IMHelper {
             JSONObject resultObject = JSONObject.parseObject(returnResult);
             String code = resultObject.get("code").toString();
             if("200".equals(code)){
-                return resultObject.get("sessionId").toString();
-//                sessionId = resultObject.get("sessionId").toString();
-//                redisTemplate.opsForValue().set("sessionId:" + roomId,sessionId);
+                sessionId = resultObject.get("sessionId").toString();
+                redisTemplate.opsForValue().set("sessionId:" + roomId,sessionId);
             }else {
                 log.error("获取sessionId失败 returnResult:{}",returnResult);
                 throw new BizException("获取sessionId失败");
@@ -440,7 +440,7 @@ public class IMHelper {
         } catch (Exception e) {
             e.printStackTrace();
         }
-        return null;
+        return sessionId;
     }