From d81ce26d07cc79379661064d943a6acddc94ab29 Mon Sep 17 00:00:00 2001 From: 龚焕茏 <2842157468@qq.com> Date: 星期五, 09 八月 2024 16:14:07 +0800 Subject: [PATCH] feat:通过Websocket根据教师会议命令执行操作 --- src/main/java/com/ycl/jxkg/enums/WebsocketCommendEnum.java | 3 +++ src/main/java/com/ycl/jxkg/server/WebsocketServer.java | 12 ++++++++---- 2 files changed, 11 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/ycl/jxkg/enums/WebsocketCommendEnum.java b/src/main/java/com/ycl/jxkg/enums/WebsocketCommendEnum.java index 131d74b..eb0f78e 100644 --- a/src/main/java/com/ycl/jxkg/enums/WebsocketCommendEnum.java +++ b/src/main/java/com/ycl/jxkg/enums/WebsocketCommendEnum.java @@ -15,6 +15,9 @@ DELAYED("delayed", "寤堕暱鑰冭瘯鏃堕棿"), FORCE_SUBMIT("forceSubmit", "寮哄埗鎻愪氦"), RECORD_STUDY_TIME("recordStudyTime", "璁板綍瀛︿範鏃堕棿"), + OPEN_CAMERA("openCamera", "鎵撳紑鎽勫儚澶�"), + MUTE("mute", "闈欓煶"), + KICK_OUT("kickOut", "韪㈠嚭"), ; private final String command; diff --git a/src/main/java/com/ycl/jxkg/server/WebsocketServer.java b/src/main/java/com/ycl/jxkg/server/WebsocketServer.java index 6c94322..a5f35a7 100644 --- a/src/main/java/com/ycl/jxkg/server/WebsocketServer.java +++ b/src/main/java/com/ycl/jxkg/server/WebsocketServer.java @@ -1,17 +1,15 @@ package com.ycl.jxkg.server; +import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; -import com.google.gson.JsonObject; -import com.ycl.jxkg.domain.entity.Message; import com.ycl.jxkg.domain.query.WebSocketQuery; +import com.ycl.jxkg.domain.vo.WebsocketDataVO; import com.ycl.jxkg.enums.WebsocketCommendEnum; import com.ycl.jxkg.service.EducationResourceService; import lombok.extern.slf4j.Slf4j; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.ApplicationContext; import org.springframework.stereotype.Component; -import javax.servlet.http.HttpSession; import javax.websocket.OnClose; import javax.websocket.OnMessage; import javax.websocket.OnOpen; @@ -80,6 +78,12 @@ EducationResourceService educationResourceService = applicationContext.getBean(EducationResourceService.class); educationResourceService.recordTime(userId); } + // 浼氳鎿嶄綔 + if (WebsocketCommendEnum.MUTE.getCommand().equals(command) || WebsocketCommendEnum.OPEN_CAMERA.getCommand().equals(command) || WebsocketCommendEnum.KICK_OUT.getCommand().equals(command)) { + WebsocketDataVO websocketDataVO = new WebsocketDataVO(); + websocketDataVO.setCommend(command); + sendOneMessage(userId, JSON.toJSONString(websocketDataVO)); + } log.info("銆怶ebSocket娑堟伅銆戞敹鍒板鎴风娑堟伅锛�" + message); } -- Gitblit v1.8.0