|
|
@ -148,7 +148,7 @@ func (ws *WServer) pullMsgBySeqListResp(conn *UserConn, m *Req, pb *sdk_ws.PullM
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
func (ws *WServer) sendMsgReq(conn *UserConn, m *Req) {
|
|
|
|
func (ws *WServer) sendMsgReq(conn *UserConn, m *Req) {
|
|
|
|
sendMsgCount++
|
|
|
|
sendMsgAllCount++
|
|
|
|
log.NewInfo(m.OperationID, "Ws call success to sendMsgReq start", m.MsgIncr, m.ReqIdentifier, m.SendID, m.Data)
|
|
|
|
log.NewInfo(m.OperationID, "Ws call success to sendMsgReq start", m.MsgIncr, m.ReqIdentifier, m.SendID, m.Data)
|
|
|
|
nReply := new(pbChat.SendMsgResp)
|
|
|
|
nReply := new(pbChat.SendMsgResp)
|
|
|
|
isPass, errCode, errMsg, pData := ws.argsValidate(m, constant.WSSendMsg)
|
|
|
|
isPass, errCode, errMsg, pData := ws.argsValidate(m, constant.WSSendMsg)
|
|
|
|