From 11729f20ce79d36d903de6e65ab7b23cea59ef3a Mon Sep 17 00:00:00 2001 From: lichong <18518571399@163.com> Date: Wed, 31 Jul 2024 17:39:13 +0800 Subject: [PATCH] 125444 --- api/main.py | 64 ++++++++++++++++++++++------------- front/src/api/teacher.js | 8 +++++ front/src/component/table.vue | 62 +++++++++++++++++++++++---------- front/src/views/student.vue | 13 +++++-- front/src/views/teacher.vue | 57 ++++++++++++++++++++++++++++++- 5 files changed, 158 insertions(+), 46 deletions(-) diff --git a/api/main.py b/api/main.py index 55654c9..d3ac95a 100644 --- a/api/main.py +++ b/api/main.py @@ -86,15 +86,13 @@ def handle_video_frame(message): _, img_data = base64_str.split(",") img_data = base64.b64decode(img_data) # 将字节流转换为PIL图像对象 - # 将字节数据转换为NumPy数组 + # 将字节数据转换为NumPy数组 np_data = np.frombuffer(img_data, dtype=np.uint8) # 使用cv2.imdecode将数组解码为图像 image = cv2.imdecode(np_data, cv2.IMREAD_COLOR) checkVedioResult(message, image) - socketio.emit( - "teacherVideo" + message["userId"], message, to=adminSid - ) + socketio.emit("teacherVideo" + message["userId"], message, to=adminSid) def checkVedioResult(message, image): @@ -105,7 +103,7 @@ def checkVedioResult(message, image): global class_name global clients global adminSid - det_results = det_model(image,conf=0.5, iou=0.25) + det_results = det_model(image, conf=0.5, iou=0.25) type = "" for r in det_results: if len(r) == 0: @@ -133,20 +131,14 @@ def checkVedioResult(message, image): for item in clients: if item["id"] == message["userId"]: sid = item["sid"] - socketio.emit( - "studentMsg" + message["userId"], message, to=sid - ) + socketio.emit("studentMsg" + message["userId"], message, to=sid) # print(97444, type) zuobiItem = { "userId": message["userId"], "msg": message["data"], "type": type, - "create_at": time.strftime( - "%Y-%m-%d %H:%M:%S", time.localtime(time.time()) - ), - "update_at": time.strftime( - "%Y-%m-%d %H:%M:%S", time.localtime(time.time()) - ), + "create_at": time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time())), + "update_at": time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time())), "isExit": 1, } addzuobi(zuobiItem) @@ -158,9 +150,7 @@ def handle_talk(message): global adminSid # print(f"Received video frame from {message['userId']}") message["type"] = "talk" - socketio.emit( - "teacherTalk" + message["userId"], message, to=adminSid - ) + socketio.emit("teacherTalk" + message["userId"], message, to=adminSid) zuobiItem = { "userId": message["userId"], "msg": message["data"], @@ -177,9 +167,7 @@ def handle_msg(message): # 说话实时传输给老师 global adminSid # print(f"Received video frame from {message['userId']}") - socketio.emit( - "teacherMsg" + message["userId"], message, to=adminSid - ) + socketio.emit("teacherMsg" + message["userId"], message, to=adminSid) zuobiItem = { "userId": message["userId"], "msg": message["data"], @@ -198,9 +186,7 @@ def handle_answer_msg(message): if item["id"] == message["userId"]: sid = item["sid"] message["type"] = "answer" - socketio.emit( - "studentMsg" + message["userId"], message, to=sid - ) + socketio.emit("studentMsg" + message["userId"], message, to=sid) zuobiItem = { "userId": message["userId"], "msg": message["data"], @@ -498,7 +484,37 @@ def getzuobi(): } +# 警告学生 +@app.route("/jinggao", methods=["post"]) +def jinggao(): + resData = request.data + # 获取到POST过来的数据，转为json形式 + userJson = json.loads(resData) + studentId = userJson["studentId"] + sid = "" + for item in clients: + if item["id"] == studentId: + sid = item["sid"] + message = {"type": "jinggao", "data": "请遵守考试规则"} + socketio.emit("studentMsg" + studentId, message, to=sid) + zuobiItem = { + "userId": studentId, + "msg": message["data"], + "type": "jinggao", + "create_at": time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time())), + "update_at": time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(time.time())), + "isExit": 1, + } + addzuobi(zuobiItem) + return { + "code": 200, + "msg": "警告成功", + "list": [], + "hasError": False, + } + + if __name__ == "__main__": initData() # app.run(debug=True) - socketio.run(app, host='0.0.0.0', port=5000, debug=True) + socketio.run(app, host="0.0.0.0", port=5000, debug=True) diff --git a/front/src/api/teacher.js b/front/src/api/teacher.js index 46af355..a0be994 100644 --- a/front/src/api/teacher.js +++ b/front/src/api/teacher.js @@ -58,4 +58,12 @@ export function getzuobi(data = {}) { method: "POST", data: { id: localStorage.getItem("userId"), ...data }, }); +} +//警告学生 +export function jinggao(data = {}) { + return _axios({ + url: `/v1/jinggao`, + method: "POST", + data: { id: localStorage.getItem("userId"), ...data }, + }); } \ No newline at end of file diff --git a/front/src/component/table.vue b/front/src/component/table.vue index d0df75b..9cd52c2 100644 --- a/front/src/component/table.vue +++ b/front/src/component/table.vue @@ -38,23 +38,43 @@ - + @@ -63,7 +83,7 @@ import _ from "lodash" export default { name: "app", - emits: ["detailInfo", "editInfo"], + emits: ["detailInfo", "editInfo", "updateMima", "jingaoxuesheng", "showzuobi"], props: { refName: { typeof: String, @@ -100,7 +120,13 @@ export default { }, updateMima(item) { this.$emit("updateMima", item); - } + }, + jingaoxuesheng(item) { + this.$emit("jingaoxuesheng", item); + }, + showzuobi(item) { + this.$emit("showzuobi", item); + }, }, watch: {}, computed: {}, diff --git a/front/src/views/student.vue b/front/src/views/student.vue index d2d1365..7bdf98b 100644 --- a/front/src/views/student.vue +++ b/front/src/views/student.vue @@ -200,7 +200,7 @@ export default { }, async initWebSocket() { this.socket = io('http://127.0.0.1:5000', - { + { secure: true, rejectUnauthorized: false, // 由于自签名证书，可能需要设置此选项 query: { id: this.userId, isAdmin: "0" } @@ -211,7 +211,7 @@ export default { }); console.log(78444, `studentMsg${this.userId}`) this.socket.on(`studentMsg${this.userId}`, (data) => { - console.log(78875454477, data) + console.log(777, data) let msg = _.get(data, ['data'], "") let answer = _.split(msg, "@@@") let type = _.get(data, ['type'], "") @@ -220,13 +220,20 @@ export default { message: `老师回答：${answer[1]}`, type: "success", }); + } else if (type === "jinggao") { + ElMessage({ + message: `${msg}`, + type: "error", + duration: 0, + showClose: true, + }); } else { if (type !== 'normal') { ElMessage({ message: `请不要${type}`, type: "error", }); - }else{ + } else { ElMessage({ message: `${type}`, type: "success", diff --git a/front/src/views/teacher.vue b/front/src/views/teacher.vue index 8697b8d..ffb4905 100644 --- a/front/src/views/teacher.vue +++ b/front/src/views/teacher.vue @@ -14,7 +14,8 @@
+ @detailInfo="detailInfo" @editInfo="editInfo" @updateMima="updateMima" @jingaoxuesheng="jingaoxuesheng" + @showzuobi="showzuobi"> + +
+ + + + + + + +
+ +