邀请任务跨周积分重置

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
+					}
 				}
 			}