From 58e483d3552e45bd53b7faeac4103bdc6d095b2b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Wed, 2 Sep 2020 10:10:45 +0800
Subject: [PATCH] =?UTF-8?q?beta=E4=B8=8D=E5=88=A4=E6=96=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 controllers/event.go | 14 ++++++--------
 1 file changed, 6 insertions(+), 8 deletions(-)

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))
 		}
 	}