房间数据时长

src/main/java/com/fdkankan/tk/entity/RoomVisitLog.java

@@ -59,6 +59,13 @@ public class RoomVisitLog implements Serializable {
     @TableField("out_room_time")
     private Date outRoomTime;
 
+
+    /**
+     * 是否主持人 0否 ，1是
+     */
+    @TableField("is_host")
+    private Integer isHost;
+
     @TableField("tb_status")
     @TableLogic
     private Integer tbStatus;

src/main/java/com/fdkankan/tk/service/IRoomVisitLogService.java

@@ -17,7 +17,7 @@ import java.util.List;
  */
 public interface IRoomVisitLogService extends IService<RoomVisitLog> {
 
-    void addLog(String roomId, Integer roomUserId,  String userId,Integer type);
+    void addLog(String roomId, Integer roomUserId,  String userId,Integer type,Integer isHost);
 
     void stopRoom(String roomId,Integer roomUserId);
 

src/main/java/com/fdkankan/tk/service/impl/RoomServiceImpl.java

@@ -344,7 +344,7 @@ public class RoomServiceImpl extends ServiceImpl<IRoomMapper, Room> implements I
             if(type == 0 ){
                 room.setRoomViewCount(room.getRoomViewCount() + 1);
             }
-            roomVisitLogService.addLog(roomId,roomUserId,userId,type);
+            roomVisitLogService.addLog(roomId,roomUserId,userId,type,0);
             room.setUpdateTime(null);
             this.updateById(room);
             return;
@@ -367,11 +367,11 @@ public class RoomServiceImpl extends ServiceImpl<IRoomMapper, Room> implements I
             room.setRoomViewCount(room.getRoomViewCount() + 1);
             room.setHostStatus(1);
             room.setRoomStatus(1);
-            roomVisitLogService.addLog(roomId,roomUserId,userId,type);
+            roomVisitLogService.addLog(roomId,roomUserId,userId,type,1);
         }
         if(type == 1 ){   //离开房间
             room.setHostStatus(0);
-            roomVisitLogService.addLog(roomId,roomUserId,userId,type);
+            roomVisitLogService.addLog(roomId,roomUserId,userId,type,1);
             this.hostLeaveRoom(roomId,roomUserId);
         }
         room.setLastLookTime(DateUtil.formatDateTime(new Date()));

src/main/java/com/fdkankan/tk/service/impl/RoomVisitLogServiceImpl.java

@@ -23,13 +23,14 @@ import org.springframework.stereotype.Service;
 public class RoomVisitLogServiceImpl extends ServiceImpl<IRoomVisitLogMapper, RoomVisitLog> implements IRoomVisitLogService {
 
     @Override
-    public void addLog(String roomId,Integer roomUserId,  String userId,Integer type) {
+    public void addLog(String roomId,Integer roomUserId,  String userId,Integer type,Integer isHost) {
         RoomVisitLog roomVisitLog  =  this.getByLiveIdAndUserId(roomId,roomUserId,userId,type);
         if(roomVisitLog == null){
             roomVisitLog = new RoomVisitLog();
             roomVisitLog.setRoomId(roomId);
             roomVisitLog.setRoomUserId(roomUserId);
             roomVisitLog.setVisitUserId(userId);
+            roomVisitLog.setIsHost(isHost);
             roomVisitLog.setInRoomTime(new Date());
         }
         if(type == 1){
@@ -104,6 +105,7 @@ public class RoomVisitLogServiceImpl extends ServiceImpl<IRoomVisitLogMapper, Ro
     public List<RoomVisitLog> getByRoomId(String roomId) {
         LambdaQueryWrapper<RoomVisitLog> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(RoomVisitLog::getRoomId,roomId);
+        wrapper.eq(RoomVisitLog::getIsHost,1);
         return this.list(wrapper);
     }