From 0192432809eac63717052301274d3c2f80a9647a Mon Sep 17 00:00:00 2001 From: qiuyt Date: Tue, 14 Jan 2025 10:47:23 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5=E4=B8=8B=E8=BD=BD=E5=9F=BA?= =?UTF-8?q?=E7=A1=80=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../glxp/api/service/sync/HeartService.java | 20 +++++++++++++------ 1 file changed, 14 insertions(+), 6 deletions(-) diff --git a/src/main/java/com/glxp/api/service/sync/HeartService.java b/src/main/java/com/glxp/api/service/sync/HeartService.java index 417daedc4..cfc97c9eb 100644 --- a/src/main/java/com/glxp/api/service/sync/HeartService.java +++ b/src/main/java/com/glxp/api/service/sync/HeartService.java @@ -1874,12 +1874,20 @@ public class HeartService { }); } if (CollectionUtil.isNotEmpty(productsList)) { - BasicProductsEntity basicProductsEntity = productsList.get(0); - List basicProductsEntities = basicProductsDao.selectList(new LambdaQueryWrapper().eq(BasicProductsEntity::getUuid, basicProductsEntity.getUuid())); - if (CollectionUtil.isNotEmpty(basicProductsEntities)){ - for (BasicProductsEntity basicProductsEntity1 : basicProductsEntities){ - if (basicProductsEntity1.getNameCode() == null){ - basicProductsDao.deleteById(basicProductsEntity1); + //过来500 条 数据 过滤掉uuid一样的 100个产品 + List uniqueUuidProducts = productsList.stream() + .collect(Collectors.groupingBy(BasicProductsEntity::getUuid)) + .values() + .stream() + .map(list -> list.get(0)) + .collect(Collectors.toList()); + for (BasicProductsEntity basicProductsEntity : uniqueUuidProducts){ + List basicProductsEntities = basicProductsDao.selectList(new LambdaQueryWrapper().eq(BasicProductsEntity::getUuid, basicProductsEntity.getUuid())); + if (CollectionUtil.isNotEmpty(basicProductsEntities)){ + for (BasicProductsEntity basicProductsEntity1 : basicProductsEntities){ + if (basicProductsEntity1.getNameCode() == null){ + basicProductsDao.deleteById(basicProductsEntity1); + } } } }