From beb2648726b79268968f3d4e319eeb70490268ba Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Fri, 10 Jan 2025 15:42:53 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=BB=E5=8A=A1=E4=B8=AD?=
 =?UTF-8?q?=E5=BF=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../modules/app/entity/InviteAchievement.java |  4 ++
 .../service/impl/TaskCenterServiceImpl.java   | 41 ++++++++++++++++---
 2 files changed, 39 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/sqx/modules/app/entity/InviteAchievement.java b/src/main/java/com/sqx/modules/app/entity/InviteAchievement.java
index 672f3d5f..59f0ee6c 100644
--- a/src/main/java/com/sqx/modules/app/entity/InviteAchievement.java
+++ b/src/main/java/com/sqx/modules/app/entity/InviteAchievement.java
@@ -50,6 +50,10 @@ public class InviteAchievement implements Serializable {
      * 是否首次达标
      */
     private Integer state;
+    /**
+     * 一次性任务领取记录 默认为空 存储为 taskId,taskId
+     */
+    private String tasks;
 
     /**
      * 创建时间
diff --git a/src/main/java/com/sqx/modules/taskCenter/service/impl/TaskCenterServiceImpl.java b/src/main/java/com/sqx/modules/taskCenter/service/impl/TaskCenterServiceImpl.java
index 72417894..218c85e2 100644
--- a/src/main/java/com/sqx/modules/taskCenter/service/impl/TaskCenterServiceImpl.java
+++ b/src/main/java/com/sqx/modules/taskCenter/service/impl/TaskCenterServiceImpl.java
@@ -2,7 +2,9 @@ package com.sqx.modules.taskCenter.service.impl;
 
 import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.date.DateUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.sqx.common.utils.DateUtils;
 import com.sqx.common.utils.RedisKeys;
@@ -168,23 +170,35 @@ public class TaskCenterServiceImpl extends ServiceImpl<TaskCenterDao, TaskCenter
                 case 3:
                     if (s.getId().equals(1L)) {
                         InviteAchievement inviteAchievement = inviteAchievementService.getByUserId(userId);
+                        if (inviteAchievement != null && StringUtils.isNotBlank(inviteAchievement.getTasks())) {
+                            String[] split = inviteAchievement.getTasks().split(",");
+                            boolean isOver = false;
+                            for (String element : split) {
+                                if ("1".equals(element.trim())) {
+                                    isOver = true;
+                                    break;
+                                }
+                            }
+                            if (isOver) {
+                                continue;
+                            }
+                        }
                         Integer sumOrderNum = 0;
                         if (inviteAchievement != null) {
                             sumOrderNum = inviteAchievement.getCount();
                         }
-
                         if (sumOrderNum != null && sumOrderNum < s.getNumber()) {
                             s.setDiscNumber(sumOrderNum);
                             s.setNumber(s.getNumber());
                         } else {
                             UserInfo userInfo = userInfoService.getByUserId(userId);
-                            if (userInfo != null || StringUtils.isNotBlank(userInfo.getCertNo()) || StringUtils.isNotBlank(userInfo.getCertName())) {
+                            if (userInfo != null && StringUtils.isNotBlank(userInfo.getCertNo()) && StringUtils.isNotBlank(userInfo.getCertName())) {
                                 List<UserInfo> users = userInfoService.getUsersByNameAndCertNo(userInfo.getCertName(), userInfo.getCertNo());
                                 Set<Long> courseIds = users.stream().map(UserInfo::getUserId).collect(Collectors.toSet());
-                                if (recordService.countTaskNum(courseIds, s.getId(), null) > 0){
+                                if (recordService.countTaskNum(courseIds, s.getId(), null) > 0) {
                                     continue;
                                 }
-                            }else if (recordService.countTaskNum(userId, s.getId(), null) > 0){
+                            } else if (recordService.countTaskNum(userId, s.getId(), null) > 0) {
                                 s.setDiscNumber(0);
                                 s.setNumber(null);
                                 s.setJumpType(0);
@@ -205,6 +219,7 @@ public class TaskCenterServiceImpl extends ServiceImpl<TaskCenterDao, TaskCenter
         if (!taskCenter.getShows().equals(1)) {
             return Result.error("领取失败");
         }
+        InviteAchievement inviteAchievement = inviteAchievementService.getByUserId(userId);
         if (taskCenter.getType().equals(2)) {
             Integer dayOrderNum = ordersService.countOrderNum(userId, DateUtil.today() + " 00:00:00");
             if (taskCenter.getNumber().equals(1)) {
@@ -228,8 +243,15 @@ public class TaskCenterServiceImpl extends ServiceImpl<TaskCenterDao, TaskCenter
                 signRecordService.save(signRecord);
             }
         } else if (taskCenter.getType().equals(3) && taskCenter.getId().equals(1L)) {
-            InviteAchievement inviteAchievement = inviteAchievementService.getByUserId(userId);
             Integer sumOrderNum = 0;
+            if (inviteAchievement != null && StringUtils.isNotBlank(inviteAchievement.getTasks())) {
+                String[] split = inviteAchievement.getTasks().split(",");
+                for (String element : split) {
+                    if ("1".equals(element.trim())) {
+                        return Result.error("不可重复领取");
+                    }
+                }
+            }
             if (inviteAchievement != null) {
                 sumOrderNum = inviteAchievement.getCount();
             }
@@ -243,7 +265,8 @@ public class TaskCenterServiceImpl extends ServiceImpl<TaskCenterDao, TaskCenter
                 }
                 List<UserInfo> users = userInfoService.getUsersByNameAndCertNo(userInfo.getCertName(), userInfo.getCertNo());
                 Set<Long> courseIds = users.stream().map(UserInfo::getUserId).collect(Collectors.toSet());
-                if (recordService.countTaskNum(courseIds, taskCenter.getId(), null) > 0) return Result.error("同一实名算一个新用户，不可重复领取");
+                if (recordService.countTaskNum(courseIds, taskCenter.getId(), null) > 0)
+                    return Result.error("同一实名算一个新用户，不可重复领取");
             }
         }
         List<TaskCenterRecord> records = new ArrayList<>();
@@ -286,6 +309,12 @@ public class TaskCenterServiceImpl extends ServiceImpl<TaskCenterDao, TaskCenter
             records.add(record);
         }
         recordService.saveBatch(records);
+        if (inviteAchievement != null && id.equals(1L)) {
+            inviteAchievementService.update(new LambdaUpdateWrapper<InviteAchievement>()
+                    .eq(InviteAchievement::getUserId, inviteAchievement.getUserId())
+                    .eq(InviteAchievement::getId, inviteAchievement.getId())
+                    .set(InviteAchievement::getTasks, StringUtils.isBlank(inviteAchievement.getTasks()) ? "1" : inviteAchievement.getTasks() + ",1"));
+        }
         return Result.success();
     }