测试接口
This commit is contained in:
@@ -140,7 +140,7 @@ func (c *EventController) TestWebsocket() {
|
|||||||
|
|
||||||
c.EnableRender = false //Beego不启用渲染
|
c.EnableRender = false //Beego不启用渲染
|
||||||
|
|
||||||
var s model.ImMessageRecord
|
var s []*model.ImMessageRecord
|
||||||
for {
|
for {
|
||||||
//接收客户端的消息
|
//接收客户端的消息
|
||||||
err := ws.ReadJSON(&s)
|
err := ws.ReadJSON(&s)
|
||||||
@@ -150,9 +150,7 @@ func (c *EventController) TestWebsocket() {
|
|||||||
break //结束循环
|
break //结束循环
|
||||||
} else {
|
} else {
|
||||||
//接受消息 业务逻辑
|
//接受消息 业务逻辑
|
||||||
broadcast <- []*model.ImMessageRecord{
|
broadcast <- s
|
||||||
&s,
|
|
||||||
}
|
|
||||||
db := dao.GetDB()
|
db := dao.GetDB()
|
||||||
dao.WrapAddIDCULDEntity(&s, "")
|
dao.WrapAddIDCULDEntity(&s, "")
|
||||||
dao.CreateEntity(db, &s)
|
dao.CreateEntity(db, &s)
|
||||||
|
|||||||
Reference in New Issue
Block a user