基于Springboot+Redis+Mysql的商品秒杀系统源码+数据库（毕业设计）.zip

package com.wsl.shoppingkill.serviceImpl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.wsl.shoppingkill.common.log.MyLog; import com.wsl.shoppingkill.common.util.ObjectUtil; import com.wsl.shoppingkill.domain.Activity; import com.wsl.shoppingkill.domain.Advertise; import com.wsl.shoppingkill.domain.Goods; import com.wsl.shoppingkill.domain.Sku; import com.wsl.shoppingkill.mapper.ActivityMapper; import com.wsl.shoppingkill.mapper.GoodsMapper; import com.wsl.shoppingkill.mapper.SkuMapper; import com.wsl.shoppingkill.obj.constant.LoggerEnum; import com.wsl.shoppingkill.obj.constant.RedisEnum; import com.wsl.shoppingkill.obj.param.ActivityParam; import com.wsl.shoppingkill.obj.param.ActivityUpdateParam; import com.wsl.shoppingkill.obj.vo.ActivityByGoodsVO; import com.wsl.shoppingkill.obj.vo.ActivityVO; import com.wsl.shoppingkill.obj.vo.KillGoodsVO; import com.wsl.shoppingkill.service.ActivityService; import com.wsl.shoppingkill.service.SkuService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; import org.springframework.dao.DataAccessException; import org.springframework.data.redis.core.RedisCallback; import org.springframework.data.redis.core.RedisOperations; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.SessionCallback; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.interceptor.TransactionAspectSupport; import javax.annotation.Resource; import java.math.BigDecimal; import java.time.LocalDateTime; import java.util.*; import java.util.concurrent.TimeUnit; import java.util.function.Function; import java.util.stream.Collectors; /** * @author WangShilei */ @Service @Slf4j public class ActivityServiceImpl extends ServiceImpl<ActivityMapper, Activity> implements ActivityService { @Resource private ActivityMapper activityMapper; @Resource private GoodsMapper goodsMapper; @Resource private SkuMapper skuMapper; @Resource private SkuService skuService; @Resource private RedisTemplate<String, Object> redisTemplate; @Override public List<ActivityVO> getActivityAll(ActivityParam activityParam) { activityParam.setTime(LocalDateTime.now()); return activityMapper.getActivityAll(activityParam); } @Override public List<KillGoodsVO> getActivityFuture() { LocalDateTime now = LocalDateTime.now().plusHours(1).withMinute(0).withSecond(0).withNano(0); LocalDateTime end = now.plusHours(5); Set<String> keys = redisTemplate.keys(RedisEnum.GOODS_FUTURE + "*"); if (CollectionUtils.isNotEmpty(keys)) { List<Object> redisList = redisTemplate.executePipelined((RedisCallback<Object>) redisConnection -> { redisConnection.openPipeline(); keys.forEach(li -> redisConnection.get(li.getBytes())); return null; }); List<KillGoodsVO> activitiesList = ObjectUtil.castList(redisList, KillGoodsVO.class); activitiesList = activitiesList.stream().filter(Objects::nonNull).collect(Collectors.toList()); if (CollectionUtils.isNotEmpty(activitiesList)) { return activitiesList; } } List<Activity> activities = activityMapper.selectList(new QueryWrapper<Activity>() .ge(Advertise.START_TIME, now) .le(Advertise.START_TIME, end)); if (CollectionUtils.isEmpty(activities)) { return new ArrayList<>(); } List<KillGoodsVO> goodsByActivity = getGoodsByActivity(activities); redisTemplate.executePipelined(new SessionCallback() { //管道操作 @Override public Object execute(RedisOperations operations) throws DataAccessException { for (KillGoodsVO activity : goodsByActivity) { if (activity.getId() != null) { String s = RedisEnum.GOODS_FUTURE + activity.getId(); operations.opsForValue().set(s, activity, 1L, TimeUnit.HOURS); } } return null; } }); return goodsByActivity; } @Override public List<KillGoodsVO> getActivityDoing(LocalDateTime now) { if (now == null) { now = LocalDateTime.now(); } List<Activity> activities = activityMapper.selectList(new QueryWrapper<Activity>() .le(Advertise.START_TIME, now) .ge(Advertise.END_TIME, now)); if (CollectionUtils.isNotEmpty(activities)) { return getGoodsByActivity(activities); } return new ArrayList<>(); } @Override public IPage<ActivityByGoodsVO> getActivityByGoods(Long current, Long size, Long id, String name) { return goodsMapper.getActivityBuyGoods(new Page<>(current, size), id, name); } @Override @MyLog(detail = "添加/更新一个活动", grade = LoggerEnum.WORN) @Transactional(rollbackFor = Exception.class) public boolean addOrUpdateActivity(ActivityUpdateParam activity) { List<Activity> activityList = new ArrayList<>(8); //获取对应商品的SKU数量 Sku sku = new Sku(); Map<Long, List<Sku>> collect = sku.selectList(new QueryWrapper<Sku>().select(Sku.ID, Sku.NUM) .in(Sku.ID, activity.getSkuList() .stream() .map(ActivityUpdateParam.Sku::getId) .map(String::valueOf) .collect(Collectors.toList()) )).stream().collect(Collectors.groupingBy(Sku::getId)); log.info(activity.getSkuList().toString()); //如果有交叉时段，则不更新 List<Long> ids = new ArrayList<>(); collect.values().forEach(li -> li.forEach(v -> ids.add(v.getId()))); long count = activityMapper.selectList(new QueryWrapper<Activity>() .in(Activity.SKU_ID, ids) .le(Activity.START_TIME, activity.getStartTime()) .ge(Activity.END_TIME, activity.getStartTime()) .or() .in(Activity.SKU_ID, ids) .le(Activity.START_TIME, activity.getEndTime()) .ge(Activity.END_TIME, activity.getEndTime()) ).size(); if (count > 0) { return false; } //遍历判断 List<Sku> skuListTemp = new ArrayList<>(); activity.getSkuList().forEach(li -> { Activity activityTemp = new Activity(); activityTemp.setStartTime(activity.getStartTime()) .setEndTime(activity.getEndTime()) .setUpdateTime(LocalDateTime.now()) .setSkuId(li.getId()); //设置id更新 if (li.getAId() != null && li.getAId() > 0) { activityTemp.setId(li.getAId()); } else { activityTemp.setCreatTime(LocalDateTime.now()); } //价格>0才更新 if (li.getPrice().compareTo(BigDecimal.ZERO) > 0) { activityTemp.setPrice(li.getPrice()); } //数量不能超库存数量 //TODO: bug if (li.getTotalNum() <= collect.get(li.getId()).get(0).getNum()) { activityTemp.setTotalNum(li.getTotalNum()).setSellNum(li.getTotalNum()); } else { activityTemp.setTotalNum(collect.get(li.getId()).get(0).getNum()).setSellNum(collect.get(li.getId()).get(0).getNum()); } Sku sku1 = collect.get(li.getId()).get(