修改房间销毁逻辑增加用户是否在线的查询

修改监听融云用户状态变更逻辑，增加主播退出时判断是否真的退出逻辑

mec-biz/src/main/java/com/ym/mec/biz/service/impl/ImLiveBroadcastRoomServiceImpl.java

@@ -103,6 +103,8 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
     public static final String LIVE_USER_STATE_TIME = "IM:LIVE_USER_STATE_TIME:" + USER_ID;
     //当前房间主讲人心跳
     public static final String LIVE_ROOM_SPEAKER_HEART_BEAT = "IM:LIVE_ROOM_SPEAKER_HEART_BEAT:" + ROOM_UID;
+    //主讲人最近一次加入房间的clientIp
+    public static final String LIVE_SPEAKER_LAST_CLIENT_IP = "IM:LIVE_SPEAKER_LAST_CLIENT_IP:" + USER_ID;
     //房间点赞数
     public static final String LIVE_ROOM_LIKE = "IM:LIVE_ROOM_LIKE:" + ROOM_UID;
     //计算人员观看时长锁
@@ -200,14 +202,17 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
         param.put("tenantId", TenantContextHolder.getTenantId());
         //查询该人员分部  及 分部下包含的学校(合作单位)
         SysUser sysUser = getSysUser();
+        //分部
+        String organIds = null;
         //如果是超管就查询当前机构所有的直播间
         if (sysUser.getTenantId() == -1 || sysUser.getIsSuperAdmin()) {
             param.put("allRoom", 1);
         } else {
             Employee employee = employeeService.get(sysUser.getId());
             if (Objects.nonNull(employee) && Objects.nonNull(employee.getOrganIdList())) {
-                param.put("organIds", employee.getOrganIdList());
-                String schoolIds = baseMapper.querySchoolIds(employee.getOrganIdList());
+                organIds = employee.getOrganIdList();
+                param.put("organIds", organIds);
+                String schoolIds = baseMapper.querySchoolIds(organIds);
                 if (StringUtils.isNotBlank(schoolIds)) {
                     param.put("schoolIds", schoolIds);
                 }
@@ -440,6 +445,11 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
         RBucket<RoomSpeakerInfo> speakerCache = redissonClient.getBucket(LIVE_SPEAKER_INFO.replace(USER_ID, room.getSpeakerId().toString()));
         if (speakerCache.isExists()) {
             RoomSpeakerInfo speakerInfo = speakerCache.get();
+            //查询用户是否在线
+            if (imFeignService.checkOnline(speakerInfo.getSpeakerId().toString())) {
+                log.info("roomDestroy destroyExpiredLiveRoom  is online >>>> roomId:{} speakerId:{}", room.getId(), speakerInfo.getSpeakerId());
+                return;
+            }
             //校验房间心跳是否过期没续租
             RBucket<Date> lastRoomHeartbeatCache = redissonClient.getBucket(LIVE_ROOM_SPEAKER_HEART_BEAT.replace(ROOM_UID, room.getRoomUid()));
             if (lastRoomHeartbeatCache.isExists()) {
@@ -449,6 +459,7 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
                 Date lastRoomDateExpired = DateUtil.addMinutes(lastDate, expiredMinute);
                 //当前时间 小于 房间心跳过期时间 则不销毁
                 if (now.getTime() <= lastRoomDateExpired.getTime()) {
+                    log.info("roomDestroy destroyExpiredLiveRoom  last room heartbeat  >>>> roomId:{} speakerId:{}", room.getId(), speakerInfo.getSpeakerId());
                     return;
                 }
             }
@@ -761,13 +772,33 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
             return false;
         }
         RoomSpeakerInfo speakerInfo = speakerCache.get();
+        //最后一次进入房间的clientIp
+        RBucket<String> lastClientIp = redissonClient.getBucket(LIVE_SPEAKER_LAST_CLIENT_IP.replace(USER_ID, userid));
         //主讲人进入房间
         if (user.getStatus().equals("0")) {
             speakerInfo.setJoinRoomTime(now);
             log.info("opsRoom>>>> join speakerCache {}", JSONObject.toJSONString(speakerInfo));
             speakerCache.set(speakerInfo);
+            //将本次进入房间的clientIp添加到主讲人最后一次clientIp缓存中
+            if (StringUtils.isNotBlank(user.getClientIp())) {
+                lastClientIp.set(user.getClientIp());
+            }
             return true;
         }
+        //校验本次退出直播间的clientIp 是不是上次进入房间的clientIp
+        if (StringUtils.isNotBlank(user.getClientIp())) {
+            if (lastClientIp.isExists()) {
+                //如果是上次进入房间的clientIp和本次退出房间的clientIp不相同，则直接忽略
+                if (!user.getClientIp().equals(lastClientIp.get())) {
+                    return true;
+                }
+            }
+        }
+        //经过上面的判断得知clientIp相同，在继续校验主讲人是否在线，如果在线则不允许退出
+        if (imFeignService.checkOnline(userid)) {
+            return true;
+        }
+
         //主讲人退出房间关闭录像
         closeLive(speakerInfo);
         speakerInfo.setExitRoomTime(now);
@@ -965,7 +996,7 @@ public class ImLiveBroadcastRoomServiceImpl extends ServiceImpl<ImLiveBroadcastR
                 if (onlineUserInfoExists && onlineUserInfo.containsKey(id)) {
                     if (type.equals(1)) {
                         //开启直播后对当前在房间的用户写入观看时间
-                        userInfo.setDynamicLookTime(new Date());
+                        userInfo.setDynamicLookTime(now);
                     } else if (type.equals(2)) {
                         userInfo.setTotalViewTime(getLookMinutes(userInfo.getDynamicLookTime(), now, userInfo.getTotalViewTime()));
                         userInfo.setDynamicLookTime(null);

mec-client-api/src/main/java/com/ym/mec/im/ImFeignService.java

@@ -188,4 +188,14 @@ public interface ImFeignService {
     @PostMapping(value = "/liveRoom/userExistInRoom")
     boolean userExistInRoom(@RequestParam("chatroomId") String chatroomId, @RequestParam("userId") String userId);
 
+    /**
+     * 查询用户是否在线
+     * 注意：断网时，用户状态返回可能不准确
+     *
+     * @param userId 要查询的用户 ID（必传）
+     * @return 在线状态，true 在线，false 不在线
+     */
+    @PostMapping(value = "/liveRoom/checkOnline")
+    boolean checkOnline(@RequestParam("userId") String userId);
+
 }

mec-client-api/src/main/java/com/ym/mec/im/fallback/ImFeignServiceFallback.java

@@ -24,6 +24,7 @@ public class ImFeignServiceFallback implements ImFeignService {
     public Object groupCreate(GroupModel groupModel) {
         return null;
     }
+
     @Override
     public Object groupUpdate(GroupModel groupModel) {
         return null;
@@ -109,4 +110,9 @@ public class ImFeignServiceFallback implements ImFeignService {
         return false;
     }
 
+    @Override
+    public boolean checkOnline(String userId) {
+        return false;
+    }
+
 }

mec-im/src/main/java/com/ym/controller/LiveRoomController.java

@@ -69,4 +69,9 @@ public class LiveRoomController {
         return liveRoomService.userExistInRoom(chatroomId, userId);
     }
 
+    @ApiOperation("查询用户是否在聊天室")
+    @RequestMapping(value = "/checkOnline")
+    public boolean checkOnline(String userId) {
+        return liveRoomService.checkOnline(userId);
+    }
 }

mec-im/src/main/java/com/ym/mec/im/IMHelper.java

@@ -6,6 +6,7 @@ import com.ym.mec.common.entity.BaseMessage;
 import com.ym.mec.common.exception.BizException;
 import com.ym.pojo.IMApiResultInfo;
 import com.ym.pojo.IMTokenInfo;
+import com.ym.pojo.IMUserOnlineInfo;
 import io.rong.util.GsonUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
@@ -473,4 +474,20 @@ public class IMHelper {
         return (IMApiResultInfo) GsonUtil.fromJson(httpHelper.returnResult(conn), IMApiResultInfo.class);
     }
 
+    /**
+     * 查询用户是否在线
+     * 注意：断网时，用户状态返回可能不准确
+     *
+     * @param userId 要查询的用户 ID（必传）
+     */
+    public IMUserOnlineInfo checkOnline(String userId) throws Exception {
+        String body = "&userId=" + URLEncoder.encode(userId, UTF8);
+        if (body.indexOf("&") == 0) {
+            body = body.substring(1);
+        }
+        HttpURLConnection conn = httpHelper.createIMPostHttpConnection("/user/checkOnline.json", "application/x-www-form-urlencoded");
+        httpHelper.setBodyParameter(body, conn);
+        return (IMUserOnlineInfo) GsonUtil.fromJson(httpHelper.returnResult(conn), IMUserOnlineInfo.class);
+    }
+
 }

mec-im/src/main/java/com/ym/pojo/IMApiResultInfo.java

@@ -13,6 +13,8 @@ public class IMApiResultInfo {
     String errorMessage;
     //人员是否存在 true 存在  false 不存在
     Boolean isInChrm;
+    //在线状态，1为在线，0为不在线。
+    String status;
 
     public boolean isSuccess() {
         return code == 200;

mec-im/src/main/java/com/ym/pojo/IMUserOnlineInfo.java

@@ -0,0 +1,15 @@
+package com.ym.pojo;
+
+import lombok.Data;
+
+@Data
+public class IMUserOnlineInfo {
+    // 返回码，200 为正常。
+    Integer code;
+    //在线状态，1为在线，0为不在线。
+    String status;
+
+    public boolean isSuccess() {
+        return code == 200;
+    }
+}

mec-im/src/main/java/com/ym/service/Impl/LiveRoomServiceImpl.java

@@ -9,6 +9,7 @@ import com.ym.mec.common.entity.ImRoomMessage;
 import com.ym.mec.common.exception.BizException;
 import com.ym.mec.im.IMHelper;
 import com.ym.pojo.IMApiResultInfo;
+import com.ym.pojo.IMUserOnlineInfo;
 import com.ym.pojo.RecordConfig;
 import com.ym.pojo.RecordNotify;
 import com.ym.service.LiveRoomService;
@@ -121,17 +122,14 @@ public class LiveRoomServiceImpl implements LiveRoomService {
             log.error("直播视频录制失败：resultInfo : {} ", returnResult);
         }
         String recordId = resultObject.getString("recordId");
-        ImLiveRoomVideo video = imLiveRoomVideoService.getOne(new QueryWrapper<ImLiveRoomVideo>()
-                .eq("room_uid_", roomId)
-                .eq("record_id_", recordId)
-                .eq("type", 0));
+        ImLiveRoomVideo video = imLiveRoomVideoService.getOne(new QueryWrapper<ImLiveRoomVideo>().eq("room_uid_", roomId).eq("record_id_", recordId).eq("type", 0));
         if (Objects.nonNull(video)) {
             return;
         }
-        imLiveRoomVideoService.save(initImLiveRoomVideo(roomId, recordId,new Date()));
+        imLiveRoomVideoService.save(initImLiveRoomVideo(roomId, recordId, new Date()));
     }
 
-    private ImLiveRoomVideo initImLiveRoomVideo(String roomId, String recordId,Date now) {
+    private ImLiveRoomVideo initImLiveRoomVideo(String roomId, String recordId, Date now) {
         ImLiveRoomVideo video = new ImLiveRoomVideo();
         video.setRoomUid(roomId);
         video.setRecordId(recordId);
@@ -163,8 +161,8 @@ public class LiveRoomServiceImpl implements LiveRoomService {
                 try {
                     Date now = new Date();
                     //获取最后一次录制视频
-                    ImLiveRoomVideo video = imLiveRoomVideoService.getDao().getLastRecord(roomId,recordNotify.getRecordId());
-                    if(Objects.isNull(video)){
+                    ImLiveRoomVideo video = imLiveRoomVideoService.getDao().getLastRecord(roomId, recordNotify.getRecordId());
+                    if (Objects.isNull(video)) {
                         log.error("获取录制视频失败：roomId : {} ,recordId:{}", roomId, recordNotify.getRecordId());
                         return;
                     }
@@ -177,7 +175,7 @@ public class LiveRoomServiceImpl implements LiveRoomService {
                         imLiveRoomVideo.setType(2);
                         imLiveRoomVideoService.save(imLiveRoomVideo);
                         return;
-                    }else {
+                    } else {
                         video.setEndTime(now);
                         video.setType(2);
                         video.setUrl(fileUrl);
@@ -216,6 +214,29 @@ public class LiveRoomServiceImpl implements LiveRoomService {
         return resultInfo.isSuccess() && resultInfo.getIsInChrm();
     }
 
+    /**
+     * 查询用户是否在线
+     * 注意：断网时，用户状态返回可能不准确
+     *
+     * @param userId 要查询的用户 ID（必传）
+     * @return true 在线，false 不在线
+     */
+    public boolean checkOnline(String userId) {
+        log.info("checkOnline userId : {}", userId);
+        IMUserOnlineInfo resultInfo;
+        try {
+            resultInfo = imHelper.checkOnline(userId);
+        } catch (Exception e) {
+            return false;
+        }
+        if (!resultInfo.isSuccess()) {
+            log.error("checkOnline userId : {}", userId);
+            return false;
+        }
+        log.info("checkOnline userId : {}  resultInfo code:{} status: {}", userId, resultInfo.getCode(), resultInfo.getStatus());
+        return Objects.equals("1", resultInfo.getStatus());
+    }
+
     public String getRoomSessionId(String roomId) {
         RBucket<String> bucket = redissonClient.getBucket("sessionId:" + roomId);
         if (bucket.isExists()) {

mec-im/src/main/java/com/ym/service/LiveRoomService.java

@@ -45,4 +45,6 @@ public interface LiveRoomService {
 
     boolean userExistInRoom(String chatroomId, String userId);
 
+    boolean checkOnline(String userId);
+
 }