From 0bd2c0008823ae428749e51a632a8795a399ccb0 Mon Sep 17 00:00:00 2001
From: Gordon <1432970085@qq.com>
Date: Wed, 15 Mar 2023 18:36:44 +0800
Subject: [PATCH] push message update

---
 internal/msg_gateway/gate/relay_rpc_server.go | 17 ++++++-----------
 1 file changed, 6 insertions(+), 11 deletions(-)

diff --git a/internal/msg_gateway/gate/relay_rpc_server.go b/internal/msg_gateway/gate/relay_rpc_server.go
index bc27d5f19..676e2a100 100644
--- a/internal/msg_gateway/gate/relay_rpc_server.go
+++ b/internal/msg_gateway/gate/relay_rpc_server.go
@@ -259,17 +259,12 @@ func (r *RPCServer) SuperGroupBackgroundOnlinePush(_ context.Context, req *pbRel
 						RecvID:         v,
 						RecvPlatFormID: int32(platform),
 					}
-					if !userConn.IsBackground {
-						resultCode := sendMsgBatchToUser(userConn, replyBytes.Bytes(), req, platform, v)
-						if resultCode == 0 && utils.IsContainInt(platform, r.pushTerminal) {
-							tempT.OnlinePush = true
-							promePkg.PromeInc(promePkg.MsgOnlinePushSuccessCounter)
-							log.Info(req.OperationID, "PushSuperMsgToUser is success By Ws", "args", req.String(), "recvPlatForm", constant.PlatformIDToName(platform), "recvID", v)
-							temp.ResultCode = resultCode
-							resp = append(resp, temp)
-						}
-					} else {
-						temp.ResultCode = -2
+					resultCode := sendMsgBatchToUser(userConn, replyBytes.Bytes(), req, platform, v)
+					if resultCode == 0 && utils.IsContainInt(platform, r.pushTerminal) {
+						tempT.OnlinePush = true
+						promePkg.PromeInc(promePkg.MsgOnlinePushSuccessCounter)
+						log.Info(req.OperationID, "PushSuperMsgToUser is success By Ws", "args", req.String(), "recvPlatForm", constant.PlatformIDToName(platform), "recvID", v)
+						temp.ResultCode = resultCode
 						resp = append(resp, temp)
 					}
 				}