job

controllers/event_controller.go

@@ -134,10 +134,10 @@ func (c *EventController) TestWebsocket() {
 			//接受消息 业务逻辑
 			msgMap[s.GroupID] = s
 			broadcast <- msgMap
-			go func() {
+			utils.CallFuncAsync(func() {
 				dao.WrapAddIDCULDEntity(s, "")
 				dao.CreateEntity(db, s)
-			}()
+			})
 		}
 	}
 }