|
|
@@ -399,8 +399,8 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
|
|
|
}
|
|
|
//查询到用户数据
|
|
|
RoomUserInfoCache userInfo = roomTotalUser.get(userId);
|
|
|
- //用户是在房间的状态 并且 突然离线 - 那么融云会发送用户离线消息-此刻就发送退出房间消息给主讲人
|
|
|
- if (userInfo.getState() == 0 && user.getStatus().equals("1")) {
|
|
|
+ //用户突然离线 - 那么融云会发送用户离线消息-此刻就发送退出房间消息给主讲人
|
|
|
+ if (user.getStatus().equals("1")) {
|
|
|
ImRoomMessage message = new ImRoomMessage();
|
|
|
message.setFromUserId(userId.toString());
|
|
|
message.setContent(userId.toString());
|
|
|
@@ -409,10 +409,10 @@ public class LiveRoomServiceImpl extends ServiceImpl<LiveRoomDao, LiveRoom> impl
|
|
|
try {
|
|
|
publishRoomMessage(message);
|
|
|
} catch (Exception e) {
|
|
|
- log.error("opsRoom>>>> looker error {}", e.getMessage());
|
|
|
- log.error("opsRoom>>>> looker error sendMessage {} : leave : {}", message, JSONObject.toJSONString(userInfo));
|
|
|
+ log.error("opsRoom>>>> looker leave error {}", e.getMessage());
|
|
|
+ log.error("opsRoom>>>> looker leave error sendMessage {} : userInfo : {}", message, JSONObject.toJSONString(userInfo));
|
|
|
}
|
|
|
- log.info("opsRoom>>>> looker leave : {}", JSONObject.toJSONString(userInfo));
|
|
|
+ log.info("opsRoom>>>> looker leave userInfo : {}", JSONObject.toJSONString(userInfo));
|
|
|
}
|
|
|
//记录退出时间 并写入缓存
|
|
|
userInfo.setLastOutTime(now);
|
hgw