diff --git a/ruoyi-websocket-boot/src/main/java/com/ruoyi/job/RoomCheckJobService.java b/ruoyi-websocket-boot/src/main/java/com/ruoyi/job/RoomCheckJobService.java index ced4ef3c..b32e3c1f 100644 --- a/ruoyi-websocket-boot/src/main/java/com/ruoyi/job/RoomCheckJobService.java +++ b/ruoyi-websocket-boot/src/main/java/com/ruoyi/job/RoomCheckJobService.java @@ -138,6 +138,9 @@ public class RoomCheckJobService { userCallService.update(Wrappers.lambdaUpdate(UserCall.class) .eq(UserCall::getId,roomId) .set(UserCall::getStatus, RoomStatusEnums.STATUS_TIMEOUT_CANCEL.getCode())); + List keys = roomCtxCache.getSessionKeysByRoomId(roomId); + WsR hangUp = WsRMsgGen.hangup("接听超时", roomId, HangUpEnums.TIMEOUT.getCode()); + RoomWebSocketUtil.sendSendMessage(keys, hangUp); SettleResp settleResp = settleService.processOn(roomId); nextCreateJob = settleResp.isNextRun(); }