update

client/client.go

@@ -100,7 +100,10 @@ func (r *Client) SetTradeNft() {
 			if m, ok := msg.(map[string][]byte); ok {
 				// 判断是否自己的通知
 				if p, ok := m[r.SessionID]; ok {
-					DispatchNftTrade(&p, r)
+					// 发送给客户端
+					if r.tradeWriteChan != nil {
+						r.tradeWriteChan <- p
+					}
 				}
 			}
 		}

client/msgRealQuote.go

@@ -48,14 +48,6 @@ func DispatchRealQuote(p *packet.MiQuotePacket, clinet *Client) {
 	}
 }
 
-// 分发通知
-func DispatchNftTrade(p *[]byte, clinet *Client) {
-	// 发送给客户端
-	if clinet.tradeWriteChan != nil {
-		clinet.tradeWriteChan <- *p
-	}
-}
-
 // parseWareInfo 从报文中解析出所有报价商品
 func parseWareInfo(p *packet.MiQuotePacket) []wareInfo {
 	ware := make([]wareInfo, 0)