lyhzzz 2 years ago
parent
commit
fda8b8c4e0

+ 14 - 6
src/main/java/com/fdkankan/tk/controller/RoomController.java

@@ -122,12 +122,7 @@ public class RoomController extends BaseController{
         return ResultData.ok();
     }
 
-    //火调解散房间
-    @GetMapping("/dissolveTheRoom")
-    public ResultData dissolveTheRoom(@RequestParam(required = false) String roomId){
-        roomService.dissolveTheRoom(roomId);
-        return ResultData.ok();
-    }
+
 
     /**
      * 分享房间
@@ -160,5 +155,18 @@ public class RoomController extends BaseController{
         return ResultData.ok(flag);
     }
 
+    //火调解散房间
+    @GetMapping("/dissolveTheRoom")
+    public ResultData dissolveTheRoom(@RequestParam(required = false) String roomId){
+        roomService.dissolveTheRoom(roomId);
+        return ResultData.ok();
+    }
+
+    //火调开启房间
+    @GetMapping("/openTheRoom")
+    public ResultData openTheRoom(@RequestParam(required = false) String roomId){
+        roomService.openTheRoom(roomId);
+        return ResultData.ok();
+    }
 }
 

+ 2 - 0
src/main/java/com/fdkankan/tk/service/IRoomService.java

@@ -53,4 +53,6 @@ public interface IRoomService extends IService<Room> {
     void hostLeaveRoom(String roomId, Integer roomUserId);
 
     void dissolveTheRoom(String roomId);
+
+    void openTheRoom(String roomId);
 }

+ 10 - 1
src/main/java/com/fdkankan/tk/service/impl/RoomServiceImpl.java

@@ -476,6 +476,15 @@ public class RoomServiceImpl extends ServiceImpl<IRoomMapper, Room> implements I
 
     @Override
     public void dissolveTheRoom(String roomId) {
+        this.changRoomStatus(roomId,2);
+    }
+
+    @Override
+    public void openTheRoom(String roomId) {
+        this.changRoomStatus(roomId,1);
+    }
+
+    private void changRoomStatus(String roomId,Integer status ){
         Room room = this.getById(roomId);
         if(room == null){
             throw new BusinessException(ResultCode.ROOM_MISS);
@@ -485,7 +494,7 @@ public class RoomServiceImpl extends ServiceImpl<IRoomMapper, Room> implements I
         }
         LambdaUpdateWrapper<Room> wrapper = new LambdaUpdateWrapper<>();
         wrapper.eq(Room::getRoomId,room.getRoomId());
-        wrapper.set(Room::getRoomStatus,2);
+        wrapper.set(Room::getRoomStatus,status);
         this.update(wrapper);
     }
 }