From ef66972437dce1d459409415add4f08f1c1629c8 Mon Sep 17 00:00:00 2001
From: phpcjl <phpcjl@gmail.com>
Date: 星期二, 03 十二月 2024 16:07:18 +0800
Subject: [PATCH] 1.分佣延迟队列

---
 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/AppUserServiceImpl.java |   39 ++++++++++++++++++++++++++++++++++++---
 1 files changed, 36 insertions(+), 3 deletions(-)

diff --git a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/AppUserServiceImpl.java b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/AppUserServiceImpl.java
index bfb01d7..535e9dd 100644
--- a/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/AppUserServiceImpl.java
+++ b/ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/service/impl/AppUserServiceImpl.java
@@ -18,14 +18,13 @@
 import com.ruoyi.system.api.domain.SysUser;
 import com.ruoyi.system.api.feignClient.SysUserClient;
 import com.ruoyi.system.api.model.LoginUser;
+import org.checkerframework.checker.units.qual.A;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /**
  * <p>
@@ -330,4 +329,38 @@
 		List<NearbyReferrerVo> list = this.baseMapper.getNearbyReferrer(cityCode, nearbyReferrer);
 		return list;
 	}
+
+	@Override
+	public List<AppUser> getUserAncestorList(Long id, List<AppUser> list) {
+		if (list == null) {
+			list = new ArrayList<>();
+		}
+
+		Set<Long> visitedIds = new HashSet<>();
+		Long currentId = id;
+
+		while (currentId != null && !visitedIds.contains(currentId)) {
+			AppUser appUser = getById(currentId);
+			if (appUser == null) {
+				break; // 如果用户不存在,终止循环
+			}
+
+			Long inviteUserId = appUser.getInviteUserId();
+			if (inviteUserId != null) {
+				AppUser invitedUser = getById(inviteUserId);
+				if (invitedUser != null) {
+					list.add(invitedUser);
+					visitedIds.add(currentId);
+					currentId = inviteUserId;
+				} else {
+					break; // 如果邀请用户不存在,终止循环
+				}
+			} else {
+				break; // 如果没有邀请用户,终止循环
+			}
+		}
+
+		return list;
+	}
+
 }

--
Gitblit v1.7.1