From 646c39792bbe650b4dcced449ce09f467ca27f0b Mon Sep 17 00:00:00 2001 From: RockYang Date: Sat, 22 Apr 2023 22:11:27 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B3=A8=E9=87=8A=E6=B5=8B=E8=AF=95=E4=BB=A3?= =?UTF-8?q?=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/chat_handler.go | 24 ++++++++++++------------ 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/server/chat_handler.go b/server/chat_handler.go index 1ebb7bed..e84da722 100644 --- a/server/chat_handler.go +++ b/server/chat_handler.go @@ -63,18 +63,18 @@ func (s *Server) ChatHandle(c *gin.Context) { return } logger.Info("Receive a message: ", string(message)) - replyMessage(client, "当前 TOKEN 无效，请使用合法的 TOKEN 登录！", false) - replyMessage(client, "![](images/wx.png)", false) - //ctx, cancel := context.WithCancel(context.Background()) - //s.ReqCancelFunc[sessionId] = cancel - //// 回复消息 - //err = s.sendMessage(ctx, session, chatRole, string(message), client, false) - //if err != nil { - // logger.Error(err) - //} else { - // replyChunkMessage(client, types.WsMessage{Type: types.WsEnd, IsHelloMsg: false}) - // logger.Info("回答完毕: " + string(message)) - //} + //replyMessage(client, "当前 TOKEN 无效，请使用合法的 TOKEN 登录！", false) + //replyMessage(client, "![](images/wx.png)", false) + ctx, cancel := context.WithCancel(context.Background()) + s.ReqCancelFunc[sessionId] = cancel + // 回复消息 + err = s.sendMessage(ctx, session, chatRole, string(message), client, false) + if err != nil { + logger.Error(err) + } else { + replyChunkMessage(client, types.WsMessage{Type: types.WsEnd, IsHelloMsg: false}) + logger.Info("回答完毕: " + string(message)) + } } }()