From f324bb603d21841d5e276ce0d992d36ce6f0fa68 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Tue, 14 Jun 2022 16:05:45 +0800 Subject: [PATCH] rtc --- internal/push/logic/push_to_client.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/internal/push/logic/push_to_client.go b/internal/push/logic/push_to_client.go index adcd4b3ed..2664a39da 100644 --- a/internal/push/logic/push_to_client.go +++ b/internal/push/logic/push_to_client.go @@ -62,6 +62,10 @@ func MsgToUser(pushMsg *pbPush.PushMsgReq) { log.NewInfo(pushMsg.OperationID, "push_result", wsResult, "sendData", pushMsg.MsgData) successCount++ if isOfflinePush && pushMsg.PushToUserID != pushMsg.MsgData.SendID { + // save invitation info for offline push + if err := db.DB.HandleSignalInfo(pushMsg.OperationID, pushMsg.MsgData); err != nil { + log.NewError(pushMsg.OperationID, utils.GetSelfFuncName(), err.Error(), pushMsg.MsgData) + } for _, v := range wsResult { if v.ResultCode == 0 { if utils.IsContainInt32(v.RecvPlatFormID, pushTerminal) { @@ -123,11 +127,7 @@ func MsgToUser(pushMsg *pbPush.PushMsgReq) { if offlinePusher == nil { break } - // save invitation info for offline push - if err := db.DB.HandleSignalInfo(pushMsg.OperationID, pushMsg.MsgData); err != nil { - log.NewError(pushMsg.OperationID, utils.GetSelfFuncName(), err.Error(), pushMsg.MsgData) - continue - } + opts, err := GetOfflinePushOpts(pushMsg) if err != nil { log.NewError(pushMsg.OperationID, utils.GetSelfFuncName(), "GetOfflinePushOpts failed", pushMsg, err.Error())