|
@@ -128,7 +128,7 @@ func (m *WsChat) Handle(ws *ghttp.WebSocket, msg []byte) {
|
|
|
Item: Answer_ChatGPT,
|
|
Item: Answer_ChatGPT,
|
|
|
CreateTime: time.Now().Format(date.Date_Full_Layout),
|
|
CreateTime: time.Now().Format(date.Date_Full_Layout),
|
|
|
})
|
|
})
|
|
|
- _ = ws.WriteJSON(g.Map{"error_code": 0, "error_msg": "", "data": g.Map{"id": encrypt.SE.Encode2Hex(fmt.Sprintf("%d", replyId)), "reply": lastData.Response, "isEnd": lastData.Finished}})
|
|
|
|
|
|
|
+ _ = ws.WriteJSON(g.Map{"error_code": 0, "error_msg": "", "data": g.Map{"id": encrypt.SE.Encode2Hex(fmt.Sprintf("%d", replyId)), "reply": lastData.Response, "isEnd": true}})
|
|
|
break
|
|
break
|
|
|
}
|
|
}
|
|
|
if _, data := parseEventStream(line); data != nil {
|
|
if _, data := parseEventStream(line); data != nil {
|
