33 lines
851 B
Go
33 lines
851 B
Go
|
package system
|
|||
|
|
|
|||
|
|
import (
|
|||
|
|
"encoding/json"
|
|||
|
|
"github.com/gin-gonic/gin"
|
|||
|
|
"net/http"
|
|||
|
|
"toutoukan/model/systemmodel"
|
|||
|
|
"toutoukan/socket"
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
func SendMsg(c *gin.Context) {
|
|||
|
|
var req systemmodel.MsgSend
|
|||
|
|
if err := c.ShouldBindJSON(&req); err != nil {
|
|||
|
|
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
|
|||
|
|
}
|
|||
|
|
// 1. 将Msg结构体序列化为JSON字符串
|
|||
|
|
msgJson, err := json.Marshal(req.Msg)
|
|||
|
|
if err != nil {
|
|||
|
|
c.JSON(http.StatusInternalServerError, gin.H{"error": "消息序列化失败：" + err.Error()})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 2. 将JSON字符串转换为[]byte，传给SendToUser
|
|||
|
|
err = socket.SendToUser(req.Username, msgJson)
|
|||
|
|
if err != nil {
|
|||
|
|
c.JSON(http.StatusBadRequest, gin.H{"error": "发送消息失败：" + err.Error()})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 发送成功的响应
|
|||
|
|
c.JSON(http.StatusOK, gin.H{"code": 200, "message": "消息发送成功"})
|
|||
|
|
}
|