diff --git a/controllers/event.go b/controllers/event.go
index 968846e59..ce8349a14 100644
--- a/controllers/event.go
+++ b/controllers/event.go
@@ -32,7 +32,7 @@ type EventController struct {
 var clients = make(map[string][]*websocket.Conn)
 
 //广播频道(通道)
-var broadcast = make(chan map[string][]*model.ImMessageRecord)
+var broadcast = make(chan map[string]*model.ImMessageRecord)
 
 // 配置升级程序(升级为websocket)
 var upgrader = websocket.Upgrader{}
@@ -131,7 +131,7 @@ func (c *EventController) TestWebsocket() {
 	defer ws.Close()
 	var (
 		vendorOrderID = c.GetString("vendorOrderID")
-		msgMap        = make(map[string][]*model.ImMessageRecord)
+		msgMap        = make(map[string]*model.ImMessageRecord)
 	)
 	//将当前客户端放入map中
 	clients[vendorOrderID] = append(clients[vendorOrderID], ws)
@@ -150,7 +150,7 @@ func (c *EventController) TestWebsocket() {
 
 	c.EnableRender = false //Beego不启用渲染
 
-	var s []*model.ImMessageRecord
+	var s *model.ImMessageRecord
 	for {
 		//接收客户端的消息
 		err := ws.ReadJSON(&s)
@@ -170,12 +170,10 @@ func (c *EventController) TestWebsocket() {
 			break //结束循环
 		} else {
 			//接受消息 业务逻辑
-			msgMap[vendorOrderID] = append(msgMap[vendorOrderID], s...)
+			msgMap[vendorOrderID] = s
 			broadcast <- msgMap
-			for _, v := range s {
-				dao.WrapAddIDCULDEntity(v, "")
-				dao.CreateEntity(db, v)
-			}
+			dao.WrapAddIDCULDEntity(s, "")
+			dao.CreateEntity(db, s)
 			// fmt.Println("接受到从页面上反馈回来的信息 ", utils.Format4Output(s, false))
 		}
 	}