Method OnDataHandle

http/websocket/websocket/server.go:304–360

(curSession *session.Session, bysMsg []byte, r *http.Request)

	return true
}
func (self *WsServer) OnDataHandle(curSession *session.Session, bysMsg []byte, r *http.Request) bool {

	var req = make(map[string]interface{})

	if err := json.Unmarshal(bysMsg, &req); err != nil {
		resp := rest.ResponsePack(Err.ILLEGAL_DATAFORMAT)
		curSession.Send(marshalResp(resp))
		log.Infof("websocket OnDataHandle:", err)
		return false
	}
	actionName, ok := req["Action"].(string)
	if !ok {
		resp := rest.ResponsePack(Err.INVALID_METHOD)
		curSession.Send(marshalResp(resp))
		return false
	}
	action, ok := self.ActionMap[actionName]
	if !ok {
		resp := rest.ResponsePack(Err.INVALID_METHOD)
		curSession.Send(marshalResp(resp))
		return false
	}
	if !self.IsValidMsg(req) {
		resp := rest.ResponsePack(Err.INVALID_PARAMS)
		curSession.Send(marshalResp(resp))
		return true
	}
	if height, ok := req["Height"].(float64); ok {
		req["Height"] = strconv.FormatInt(int64(height), 10)
	}
	if raw, ok := req["Raw"].(float64); ok {
		req["Raw"] = strconv.FormatInt(int64(raw), 10)
	}
	req["SessionId"] = curSession.GetSessionId()
	resp := action.handler(req)
	resp["Action"] = actionName
	resp["Id"] = req["Id"]
	if action.pushFlag {
		if error, _ := resp["Error"].(int64); ok && error == 0 {
			if txHash, ok := resp["Result"].(string); ok && len(txHash) == common.UINT256_SIZE*2 {
				//delete timeover txhashs
				txhashs := curSession.RemoveTimeoverTxHashes()
				self.Lock()
				defer self.Unlock()
				for _, v := range txhashs {
					delete(self.TxHashMap, v.TxHash)
				}
				//add new txhash
				self.TxHashMap[txHash] = curSession.GetSessionId()
				curSession.AppendTxHash(txHash)
			}
		}
	}
	curSession.Send(marshalResp(resp))

	return true
}
func (self *WsServer) InsertTxHashMap(txhash string, sessionid string) {