| | |
| | | import com.ruoyi.system.api.domain.vo.WdGoodsGroupPurchaseVO; |
| | | import com.ruoyi.system.api.feignClient.OrderClient; |
| | | import com.ruoyi.system.api.feignClient.SysUserClient; |
| | | import java.time.LocalDateTime; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | |
| | | } |
| | | LambdaQueryWrapper<GoodsGroupPurchase> queryWrapper = Wrappers.lambdaQuery(); |
| | | queryWrapper.eq(GoodsGroupPurchase::getGoodsSkuId, dto.getGoodsSkuId()); |
| | | queryWrapper.eq(GoodsGroupPurchase::getListingStatus, |
| | | ListingStatusEnum.ON_SHELVES.getCode()); |
| | | queryWrapper.le(GoodsGroupPurchase::getStartTime, dto.getStartTime()); |
| | | queryWrapper.ge(GoodsGroupPurchase::getEndTime, dto.getStartTime()); |
| | | queryWrapper.ne(GoodsGroupPurchase::getStartStatus, StartStatusEnum.ENDED); |
| | | long count = this.count(queryWrapper); |
| | | if (count > 0) { |
| | | throw new ServiceException("添加失败,当前商品在该时间段内有其他团购活动"); |
| | |
| | | goodsSku.getSkuName())); |
| | | } |
| | | } |
| | | asyncMethodService.groupPurchaseScheduleTask(Lists.newArrayList(goodsGroupPurchase)); |
| | | if (goodsGroupPurchase.getEndTime().isBefore(LocalDateTime.now())) { |
| | | goodsGroupPurchase.setStartStatus(StartStatusEnum.ENDED); |
| | | goodsGroupPurchase.setGroupStatus(GroupStatusEnum.GROUP_FAILURE); |
| | | this.updateById(goodsGroupPurchase); |
| | | } else { |
| | | asyncMethodService.groupPurchaseScheduleTask(Lists.newArrayList(goodsGroupPurchase)); |
| | | } |
| | | } |
| | | |
| | | /** |