|
@@ -2,6 +2,7 @@ package cn.iocoder.yudao.module.promotion.service.combination;
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
|
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
|
|
|
import cn.iocoder.yudao.module.member.api.user.MemberUserApi;
|
|
|
import cn.iocoder.yudao.module.member.api.user.dto.MemberUserRespDTO;
|
|
|
import cn.iocoder.yudao.module.product.api.sku.ProductSkuApi;
|
|
@@ -14,6 +15,7 @@ import cn.iocoder.yudao.module.promotion.dal.dataobject.combination.CombinationA
|
|
|
import cn.iocoder.yudao.module.promotion.dal.dataobject.combination.CombinationRecordDO;
|
|
|
import cn.iocoder.yudao.module.promotion.dal.mysql.combination.CombinationRecordMapper;
|
|
|
import cn.iocoder.yudao.module.promotion.enums.combination.CombinationRecordStatusEnum;
|
|
|
+import cn.iocoder.yudao.module.trade.api.order.TradeOrderApi;
|
|
|
import org.springframework.context.annotation.Lazy;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
@@ -24,6 +26,7 @@ import java.time.LocalDateTime;
|
|
|
import java.util.List;
|
|
|
|
|
|
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
|
|
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
|
|
|
import static cn.iocoder.yudao.module.promotion.enums.ErrorCodeConstants.*;
|
|
|
|
|
|
// TODO 芋艿:等拼团记录做完,完整 review 下
|
|
@@ -51,6 +54,8 @@ public class CombinationRecordServiceImpl implements CombinationRecordService {
|
|
|
@Resource
|
|
|
@Lazy
|
|
|
private ProductSkuApi productSkuApi;
|
|
|
+ @Resource
|
|
|
+ private TradeOrderApi tradeOrderApi;
|
|
|
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@@ -97,6 +102,35 @@ public class CombinationRecordServiceImpl implements CombinationRecordService {
|
|
|
}
|
|
|
|
|
|
// TODO @puhui999:有一个应该在创建那要做下;就是当前 activityId 已经有未支付的订单,不允许在发起新的;要么支付,要么去掉先;
|
|
|
+ @Override
|
|
|
+ public void validateCombinationRecord(Long activityId, Long userId, Long skuId, Integer count) {
|
|
|
+ // 1.1 校验拼团活动是否存在
|
|
|
+ CombinationActivityDO activity = combinationActivityService.validateCombinationActivityExists(activityId);
|
|
|
+ // 1.2 校验活动是否开启
|
|
|
+ if (ObjectUtil.equal(activity.getStatus(), CommonStatusEnum.DISABLE.getStatus())) {
|
|
|
+ throw exception(COMBINATION_ACTIVITY_STATUS_DISABLE);
|
|
|
+ }
|
|
|
+ // 1.3 校验是否超出单次限购数量
|
|
|
+ if (count > activity.getSingleLimitCount()) {
|
|
|
+ throw exception(COMBINATION_RECORD_FAILED_SINGLE_LIMIT_COUNT_EXCEED);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 2. 校验是否超出总限购数量
|
|
|
+ List<CombinationRecordDO> recordList = getRecordListByUserIdAndActivityId(userId, activityId);
|
|
|
+ if (CollUtil.isEmpty(recordList)) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ // 过滤出拼团成功的
|
|
|
+ // TODO @puhui999:count 要不存一个在 record 里?
|
|
|
+ List<Long> skuIds = convertList(recordList, CombinationRecordDO::getSkuId,
|
|
|
+ item -> ObjectUtil.equals(item.getStatus(), CombinationRecordStatusEnum.SUCCESS.getStatus()));
|
|
|
+ Integer countSum = tradeOrderApi.getOrderItemCountSumByOrderIdAndSkuId(convertList(recordList,
|
|
|
+ CombinationRecordDO::getOrderId,
|
|
|
+ item -> ObjectUtil.equals(item.getStatus(), CombinationRecordStatusEnum.SUCCESS.getStatus())), skuIds);
|
|
|
+ if (activity.getTotalLimitCount() < countSum) {
|
|
|
+ throw exception(COMBINATION_RECORD_FAILED_TOTAL_LIMIT_COUNT_EXCEED);
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@@ -105,21 +139,26 @@ public class CombinationRecordServiceImpl implements CombinationRecordService {
|
|
|
CombinationActivityDO activity = combinationActivityService.validateCombinationActivityExists(reqDTO.getActivityId());
|
|
|
// 1.2 需要校验下,他当前是不是已经参加了该拼团;
|
|
|
// TODO @puhui999:拼团应该可以重复参加;应该去校验总共的上限哈,就是 activity.totalLimitCount
|
|
|
- CombinationRecordDO recordDO = recordMapper.selectByUserIdAndOrderId(reqDTO.getUserId(), reqDTO.getOrderId());
|
|
|
- if (recordDO != null) {
|
|
|
- throw exception(COMBINATION_RECORD_EXISTS);
|
|
|
+ List<CombinationRecordDO> records = recordMapper.selectListByUserId(reqDTO.getUserId());
|
|
|
+ List<Long> orderIds = convertList(records, CombinationRecordDO::getOrderId);
|
|
|
+ // 1.2.1 如果存在订单才去校验
|
|
|
+ if (CollUtil.isNotEmpty(orderIds)) {
|
|
|
+
|
|
|
}
|
|
|
// 1.3 校验用户是否参加了其它拼团
|
|
|
List<CombinationRecordDO> recordDOList = recordMapper.selectListByUserIdAndStatus(reqDTO.getUserId(), CombinationRecordStatusEnum.IN_PROGRESS.getStatus());
|
|
|
if (CollUtil.isNotEmpty(recordDOList)) {
|
|
|
throw exception(COMBINATION_RECORD_FAILED_HAVE_JOINED);
|
|
|
}
|
|
|
- // TODO @puhui999:有个开始时间未校验
|
|
|
- // 1.4 校验当前活动是否过期
|
|
|
+ // 1、4 校验活动是否开启
|
|
|
+ if (LocalDateTime.now().isAfter(activity.getStartTime())) {
|
|
|
+ throw exception(COMBINATION_RECORD_FAILED_TIME_NOT_START);
|
|
|
+ }
|
|
|
+ // 1.5 校验当前活动是否过期
|
|
|
if (LocalDateTime.now().isAfter(activity.getEndTime())) {
|
|
|
throw exception(COMBINATION_RECORD_FAILED_TIME_END);
|
|
|
}
|
|
|
- // 1.5 父拼团是否存在,是否已经满了
|
|
|
+ // 1.6 父拼团是否存在,是否已经满了
|
|
|
if (reqDTO.getHeadId() != null) {
|
|
|
// 查询进行中的父拼团
|
|
|
CombinationRecordDO record = recordMapper.selectOneByHeadId(reqDTO.getHeadId(), CombinationRecordStatusEnum.IN_PROGRESS.getStatus());
|