From 291b1cee4f2d434890b4de3fd29e6ce3b4cd8ae9 Mon Sep 17 00:00:00 2001
From: sk <123456@qq.com>
Date: Thu, 27 Jun 2024 18:23:39 +0800
Subject: [PATCH] =?UTF-8?q?=E9=82=80=E8=AF=B7=E4=BB=BB=E5=8A=A1=E8=B7=A8?=
 =?UTF-8?q?=E5=91=A8=E7=A7=AF=E5=88=86=E9=87=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 dbproxy/mq/c_invite.go | 33 +++++++++++++++------------------
 1 file changed, 15 insertions(+), 18 deletions(-)

diff --git a/dbproxy/mq/c_invite.go b/dbproxy/mq/c_invite.go
index b6bae94..5090fdb 100644
--- a/dbproxy/mq/c_invite.go
+++ b/dbproxy/mq/c_invite.go
@@ -97,24 +97,21 @@ func init() {
 				logger.Logger.Errorf("EvtInvite reset 1 error:%v snid:%v", err, log.SnId)
 				return err
 			}
-			// 父节点积分是否跨周重置
-			// 一级
-			err = reset(log.InviteSnId)
-			if err != nil {
-				logger.Logger.Errorf("EvtInvite reset 2 error:%v snid:%v", err, log.InviteSnId)
-				return err
-			}
-			// 二级
-			ppsnid, err := svc.GetPSnId(log.Platform, log.InviteSnId)
-			if err != nil {
-				logger.Logger.Errorf("EvtInvite GetPSnId 1 error:%v snid:%v", err, log.InviteSnId)
-				return err
-			}
-			if ppsnid > 0 {
-				err = reset(ppsnid)
-				if err != nil {
-					logger.Logger.Errorf("EvtInvite reset 3 error:%v snid:%v", err, ppsnid)
-					return err
+			tmpSnid := log.SnId
+			for i := 0; i < 5; i++ {
+				if tmpSnid > 0 {
+					err = reset(tmpSnid)
+					if err != nil {
+						logger.Logger.Errorf("EvtInvite reset %v error:%v snid:%v", i, err, tmpSnid)
+						return err
+					}
+				}
+				if tmpSnid > 0 {
+					tmpSnid, err = svc.GetPSnId(log.Platform, tmpSnid)
+					if err != nil {
+						logger.Logger.Errorf("EvtInvite GetPSnId %v error:%v snid:%v", i, err, tmpSnid)
+						return err
+					}
 				}
 			}