From a8444e34e6280c8e7b81546e19b75b455fe25a9e Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Fri, 10 Jan 2025 17:12:25 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E7=BA=A7=E4=B8=BA=E5=AE=98=E6=96=B9?=
 =?UTF-8?q?=20=E4=BC=98=E5=8C=96=E6=89=A7=E8=A1=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../sqx/modules/invite/service/impl/InviteServiceImpl.java | 3 +++
 src/main/java/com/sqx/modules/job/task/TempOrdersTask.java | 7 ++++---
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java b/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java
index 5ffde3f7..abf82f0d 100644
--- a/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java
+++ b/src/main/java/com/sqx/modules/invite/service/impl/InviteServiceImpl.java
@@ -276,6 +276,9 @@ public class InviteServiceImpl extends ServiceImpl<InviteDao, Invite> implements
 
     @Override
     public Map<String, Object> updateInvite(UserEntity userEntity, String format, Long userId, BigDecimal price) {
+        if(userEntity.getUserId().equals(1L)){
+            return new HashMap<>();
+        }
         Map<String, Object> result = new HashMap<>();
         if (userEntity != null && userId != null && price != null) {
             Invite invite1 = inviteDao.selectInviteByUser(userEntity.getUserId(), userId, 1);
diff --git a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java
index 937c1818..843dcb6e 100644
--- a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java
+++ b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java
@@ -164,7 +164,7 @@ public class TempOrdersTask {
         UserEntity user = userService.selectUserById(order.getUserId());
         UserEntity byUser = userService.queryByInvitationCodeOrUserId(user.getInviterUserId(), user.getInviterCode());
 //        UserEntity byUser = userService.queryByInvitationCode(user.getInviterCode());
-        if (byUser != null && !byUser.getUserId().equals(1L)) {
+        if (byUser != null) {
             InviteAchievement inviteAchievement = inviteAchievementService.getByUserId(user.getUserId());
             if (inviteAchievement == null) {
                 inviteAchievement = new InviteAchievement();
@@ -177,6 +177,8 @@ public class TempOrdersTask {
             } else {
                 inviteAchievementService.incrCount(inviteAchievement.getId(), inviteAchievement.getUserId(), 1);
             }
+        }
+        if (byUser != null && !byUser.getUserId().equals(1L)) {
             ThreadUtil.execAsync(() -> {
                 ThreadUtil.sleep(1000);
                 activities(user, byUser);
@@ -186,7 +188,6 @@ public class TempOrdersTask {
                 inviteService.updateInvite(byUser, DateUtil.now(), user.getUserId(), order.getPayMoney());
             });
         }
-
         //增加剧集支付次数
         ThreadUtil.execAsync(() -> {
             courseService.incrWeekPayCount(order.getCourseId());
@@ -266,7 +267,7 @@ public class TempOrdersTask {
             System.out.println(list.stream().map(UserInfo::getCertNo).collect(Collectors.toSet()));
             count = userInfoService.list(new LambdaQueryWrapper<UserInfo>().in(UserInfo::getUserId, byUserIdList).isNotNull(UserInfo::getAccountNo).select(UserInfo::getCertNo))
                     .stream().map(UserInfo::getCertNo).collect(Collectors.toSet()).size();
-        }else {
+        } else {
             return;
         }
         logger.info("邀请达标人员: {}", count);