From 446951bd119f27959c9574c456e53c56f86b1c9b Mon Sep 17 00:00:00 2001 From: puhui999 Date: Fri, 28 Jul 2023 16:30:38 +0800 Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=E5=B0=81=E8=A3=85=E5=87=BD?= =?UTF-8?q?=E6=95=B0=20convertCDUMap=20=E4=BD=9C=E7=94=A8=EF=BC=9A?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=88=92=E5=88=86=E4=B8=BA=E9=9C=80=E8=A6=81?= =?UTF-8?q?=E6=96=B0=E5=A2=9E=E7=9A=84=E3=80=81=E8=BF=98=E6=98=AF=E5=88=A0?= =?UTF-8?q?=E9=99=A4=E7=9A=84=E3=80=81=E8=BF=98=E6=98=AF=E6=9B=B4=E6=96=B0?= =?UTF-8?q?=E7=9A=84=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 4 +- .../util/collection/CollectionUtils.java | 36 +++++++++++++ .../CombinationActivityServiceImpl.java | 53 ++++++++++--------- .../SeckillActivityServiceImpl.java | 4 +- .../module/promotion/util/PromotionUtils.java | 10 +++- yudao-server/pom.xml | 40 +++++++------- 6 files changed, 96 insertions(+), 51 deletions(-) diff --git a/pom.xml b/pom.xml index d221cb4f43..813c1d4bb9 100644 --- a/pom.xml +++ b/pom.xml @@ -16,11 +16,11 @@ yudao-module-member yudao-module-system yudao-module-infra - + yudao-module-pay - + yudao-module-mall yudao-example diff --git a/yudao-framework/yudao-common/src/main/java/cn/iocoder/yudao/framework/common/util/collection/CollectionUtils.java b/yudao-framework/yudao-common/src/main/java/cn/iocoder/yudao/framework/common/util/collection/CollectionUtils.java index d57fb21b93..eb6645212a 100644 --- a/yudao-framework/yudao-common/src/main/java/cn/iocoder/yudao/framework/common/util/collection/CollectionUtils.java +++ b/yudao-framework/yudao-common/src/main/java/cn/iocoder/yudao/framework/common/util/collection/CollectionUtils.java @@ -2,6 +2,7 @@ package cn.iocoder.yudao.framework.common.util.collection; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollectionUtil; +import cn.hutool.core.map.MapUtil; import com.google.common.collect.ImmutableMap; import java.util.*; @@ -149,6 +150,41 @@ public class CollectionUtils { return builder.build(); } + /** + * 数据划分为需要新增的、还是删除的、还是更新的。 + * + * @param list1 需要处理的数据的相关编号列表 + * @param list2 数据库中存在的数据的相关编号列表 + * @param func 比较出哪些记录是新增，还是修改，还是删除 + * @return 包含需要新增、修改、删除的数据 Map 对象 + */ + public static Map> convertCDUMap(Collection list1, Collection list2, + Function>, Map>> func) { + HashMap> mapData = MapUtil.newHashMap(3); + if (CollUtil.isEmpty(list1)) { + return func.apply(mapData); + } + if (CollUtil.isEmpty(list2)) { + return func.apply(mapData); + } + // 后台存在的前端不存在的 + List d = CollectionUtils.filterList(list2, item -> !list1.contains(item)); + if (CollUtil.isNotEmpty(d)) { + mapData.put("delete", d); + } + // 前端存在的后端不存在的 + List c = CollectionUtils.filterList(list1, item -> !list2.contains(item)); + if (CollUtil.isNotEmpty(c)) { + mapData.put("create", c); + } + // 更新已存在的 + List u = CollectionUtils.filterList(list1, list2::contains); + if (CollUtil.isNotEmpty(u)) { + mapData.put("update", u); + } + return func.apply(mapData); + } + public static boolean containsAny(Collection source, Collection candidates) { return org.springframework.util.CollectionUtils.containsAny(source, candidates); } diff --git a/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/combination/CombinationActivityServiceImpl.java b/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/combination/CombinationActivityServiceImpl.java index 0742fd314a..da1220eb48 100644 --- a/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/combination/CombinationActivityServiceImpl.java +++ b/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/combination/CombinationActivityServiceImpl.java @@ -2,10 +2,12 @@ package cn.iocoder.yudao.module.promotion.service.combination; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollectionUtil; +import cn.hutool.core.map.MapUtil; import cn.hutool.core.util.ObjectUtil; import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum; import cn.iocoder.yudao.framework.common.pojo.PageResult; import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils; +import cn.iocoder.yudao.framework.common.util.collection.MapUtils; import cn.iocoder.yudao.module.product.api.sku.ProductSkuApi; import cn.iocoder.yudao.module.product.api.sku.dto.ProductSkuRespDTO; import cn.iocoder.yudao.module.product.api.spu.ProductSpuApi; @@ -31,9 +33,7 @@ import org.springframework.validation.annotation.Validated; import javax.annotation.Resource; import java.time.LocalDateTime; -import java.util.Collection; -import java.util.List; -import java.util.Set; +import java.util.*; import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception; import static cn.iocoder.yudao.module.product.enums.ErrorCodeConstants.SPU_NOT_EXISTS; @@ -67,7 +67,7 @@ public class CombinationActivityServiceImpl implements CombinationActivityServic // 获取所选 spu下的所有 sku List skus = productSkuApi.getSkuListBySpuId(CollectionUtil.newArrayList(createReqVO.getSpuId())); // 校验商品 sku 是否存在 - validateProductSkuExistence(skus, createReqVO.getProducts(), CombinationProductCreateReqVO::getSkuId); + validateProductSkuExistence(createReqVO.getProducts(), skus, CombinationProductCreateReqVO::getSkuId); // TODO 艿艿 有个小问题：现在有活动时间和限制时长，活动时间的结束时间早于设置的限制时间怎么算状态比如： // 活动时间 2023-08-05 15:00:00 - 2023-08-05 15:20:00 限制时长 2小时，那么活动时间结束就结束还是加时到满两小时 @@ -119,7 +119,7 @@ public class CombinationActivityServiceImpl implements CombinationActivityServic // 获取所选 spu下的所有 sku List skus = productSkuApi.getSkuListBySpuId(CollectionUtil.newArrayList(updateReqVO.getSpuId())); // 校验商品 sku 是否存在 - validateProductSkuExistence(skus, updateReqVO.getProducts(), CombinationProductUpdateReqVO::getSkuId); + validateProductSkuExistence(updateReqVO.getProducts(), skus, CombinationProductUpdateReqVO::getSkuId); // 更新 CombinationActivityDO updateObj = CombinationActivityConvert.INSTANCE.convert(updateReqVO); @@ -130,7 +130,6 @@ public class CombinationActivityServiceImpl implements CombinationActivityServic /** * 更新秒杀商品 - * TODO 更新商品要不要封装成通用方法 * * @param updateObj DO * @param products 商品配置 @@ -141,25 +140,28 @@ public class CombinationActivityServiceImpl implements CombinationActivityServic Set convertSet = CollectionUtils.convertSet(combinationProductDOs, CombinationProductDO::getSkuId); // 前端传过来的活动商品 Set convertSet1 = CollectionUtils.convertSet(products, CombinationProductUpdateReqVO::getSkuId); - // 删除后台存在的前端不存在的商品 - List d = CollectionUtils.filterList(convertSet, item -> !convertSet1.contains(item)); - if (CollUtil.isNotEmpty(d)) { - combinationProductMapper.deleteBatchIds(d); - } - // 前端存在的后端不存在的商品 - List c = CollectionUtils.filterList(convertSet1, item -> !convertSet.contains(item)); - if (CollUtil.isNotEmpty(c)) { - List vos = CollectionUtils.filterList(products, item -> c.contains(item.getSkuId())); - List productDOs = CombinationActivityConvert.INSTANCE.convertList(updateObj, vos); - combinationProductMapper.insertBatch(productDOs); - } - // 更新已存在的商品 - List u = CollectionUtils.filterList(convertSet1, convertSet::contains); - if (CollUtil.isNotEmpty(u)) { - List vos = CollectionUtils.filterList(products, item -> u.contains(item.getSkuId())); - List productDOs = CombinationActivityConvert.INSTANCE.convertList1(updateObj, vos, combinationProductDOs); - combinationProductMapper.updateBatch(productDOs); - } + // 分化数据 + Map> data = CollectionUtils.convertCDUMap(convertSet1, convertSet, mapData -> { + HashMap> cdu = MapUtil.newHashMap(3); + MapUtils.findAndThen(mapData, "create", list -> { + cdu.put("create", CombinationActivityConvert.INSTANCE.convertList(updateObj, + CollectionUtils.filterList(products, item -> list.contains(item.getSkuId())))); + }); + MapUtils.findAndThen(mapData, "delete", list -> { + cdu.put("create", CollectionUtils.filterList(combinationProductDOs, item -> list.contains(item.getSkuId()))); + }); + MapUtils.findAndThen(mapData, "update", list -> { + cdu.put("update", CombinationActivityConvert.INSTANCE.convertList1(updateObj, + CollectionUtils.filterList(products, item -> list.contains(item.getSkuId())), combinationProductDOs)); + }); + return cdu; + }); + + // 执行增删改 + MapUtils.findAndThen(data, "create", item -> combinationProductMapper.insertBatch(item)); + MapUtils.findAndThen(data, "delete", item -> combinationProductMapper.deleteBatchIds( + CollectionUtils.convertSet(item, CombinationProductDO::getId))); + MapUtils.findAndThen(data, "update", item -> combinationProductMapper.updateBatch(item)); } @Override @@ -274,6 +276,7 @@ public class CombinationActivityServiceImpl implements CombinationActivityServic } // TODO @puhui999：status 传入进来搞哈； + /** * APP 端获取开团记录 * diff --git a/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/seckill/seckillactivity/SeckillActivityServiceImpl.java b/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/seckill/seckillactivity/SeckillActivityServiceImpl.java index 9538019f4c..aa0c887264 100644 --- a/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/seckill/seckillactivity/SeckillActivityServiceImpl.java +++ b/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/service/seckill/seckillactivity/SeckillActivityServiceImpl.java @@ -64,7 +64,7 @@ public class SeckillActivityServiceImpl implements SeckillActivityService { List skus = productSkuApi.getSkuListBySpuId(CollUtil.newArrayList(createReqVO.getSpuId())); // 校验商品 sku 是否存在 // TODO @puhui999：直接校验 sku 数量，是不是就完事啦，不需要校验的特别严谨哈； - validateProductSkuExistence(skus, createReqVO.getProducts(), SeckillProductCreateReqVO::getSkuId); + validateProductSkuExistence(createReqVO.getProducts(), skus, SeckillProductCreateReqVO::getSkuId); // 插入秒杀活动 SeckillActivityDO activity = SeckillActivityConvert.INSTANCE.convert(createReqVO) @@ -122,7 +122,7 @@ public class SeckillActivityServiceImpl implements SeckillActivityService { // 获取所选 spu下的所有 sku List skus = productSkuApi.getSkuListBySpuId(CollUtil.newArrayList(updateReqVO.getSpuId())); // 校验商品 sku 是否存在 - validateProductSkuExistence(skus, updateReqVO.getProducts(), SeckillProductUpdateReqVO::getSkuId); + validateProductSkuExistence(updateReqVO.getProducts(), skus, SeckillProductUpdateReqVO::getSkuId); // 更新活动 SeckillActivityDO updateObj = SeckillActivityConvert.INSTANCE.convert(updateReqVO) diff --git a/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/util/PromotionUtils.java b/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/util/PromotionUtils.java index f1cd18816c..4c16c78366 100644 --- a/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/util/PromotionUtils.java +++ b/yudao-module-mall/yudao-module-promotion-biz/src/main/java/cn/iocoder/yudao/module/promotion/util/PromotionUtils.java @@ -31,8 +31,14 @@ public class PromotionUtils { return LocalDateTimeUtils.beforeNow(endTime) ? CommonStatusEnum.DISABLE.getStatus() : CommonStatusEnum.ENABLE.getStatus(); } - // TODO @puhui999：写个注释哈。 - public static void validateProductSkuExistence(List skus, List products, Function func) { + /** + * 校验商品 sku 是否存在 + * + * @param products 需要校验的商品 + * @param skus 数据库中的商品 skus + * @param func 获取需要校验的商品的 skuId + */ + public static void validateProductSkuExistence(List products, List skus, Function func) { // 校验 sku 个数是否一致 Set skuIdsSet = CollectionUtils.convertSet(products, func); Set skuIdsSet1 = CollectionUtils.convertSet(skus, ProductSkuRespDTO::getId); diff --git a/yudao-server/pom.xml b/yudao-server/pom.xml index b151e6ef23..04118f184b 100644 --- a/yudao-server/pom.xml +++ b/yudao-server/pom.xml @@ -54,11 +54,11 @@ - - - - - + + cn.iocoder.boot + yudao-module-pay-biz + ${revision} + @@ -68,21 +68,21 @@ - - - - - - - - - - - - - - - + + cn.iocoder.boot + yudao-module-promotion-biz + ${revision} + + + cn.iocoder.boot + yudao-module-product-biz + ${revision} + + + cn.iocoder.boot + yudao-module-trade-biz + ${revision} +