From 6368120a1bc7a45958c9331cb05d3285efd07088 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Fri, 10 Jan 2025 18:22:49 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8B=89=E6=96=B0=E5=A5=96=E5=8A=B1=E5=8E=BB?= =?UTF-8?q?=E9=99=A4=E4=B8=8E=E9=82=80=E8=AF=B7=E4=BA=BA=E8=BA=AB=E4=BB=BD?= =?UTF-8?q?=E4=BF=A1=E6=81=AF=E7=9B=B8=E5=90=8C=E7=9A=84=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/sqx/modules/job/task/TempOrdersTask.java | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) 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 843dcb6e..84bd22da 100644 --- a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java +++ b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java @@ -3,6 +3,7 @@ package com.sqx.modules.job.task; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; import cn.hutool.core.thread.ThreadUtil; +import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; @@ -264,9 +265,15 @@ public class TempOrdersTask { int count = 0; if (!byUserIdList.isEmpty()) { List list = userInfoService.list(new LambdaQueryWrapper().in(UserInfo::getUserId, byUserIdList).isNotNull(UserInfo::getAccountNo).select(UserInfo::getCertNo)); - System.out.println(list.stream().map(UserInfo::getCertNo).collect(Collectors.toSet())); - count = userInfoService.list(new LambdaQueryWrapper().in(UserInfo::getUserId, byUserIdList).isNotNull(UserInfo::getAccountNo).select(UserInfo::getCertNo)) - .stream().map(UserInfo::getCertNo).collect(Collectors.toSet()).size(); + logger.info("邀请用户实名信息: {}", list.stream().map(UserInfo::getCertNo).collect(Collectors.toSet())); + UserInfo userInfo = userInfoService.getOne(new LambdaQueryWrapper().eq(UserInfo::getUserId, user.getUserId()).select(UserInfo::getCertNo)); + Set collect = userInfoService.list(new LambdaQueryWrapper().in(UserInfo::getUserId, byUserIdList).isNotNull(UserInfo::getAccountNo).select(UserInfo::getCertNo)) + .stream().map(UserInfo::getCertNo).collect(Collectors.toSet()); + // 去除与本人身份信息相同的用户 + if (!collect.isEmpty() && userInfo != null && StrUtil.isNotBlank(userInfo.getCertNo())) { + collect.remove(userInfo.getCertNo()); + } + count = collect.size(); } else { return; }