1. //异步编排 多线程执行
    3.         //获取现在时间段的秒杀商品 并合并到dailySecondKillVO
    4.         //判断activityDateVO是否有指定时间  如果为空则为当前时间
    5.         CompletableFuture<List<DailySecondKillVO>> listCompletableFuture = CompletableFuture.supplyAsync(() -> {
    6.             System.out.println(1);
    7.             List<DailySecondKillVO> dailySecondKillVO = new ArrayList<>();
    8.             //获取参加今天秒杀的商品
    9.             List<SecondKillApplicationEntity> secondKillApplication = secondKillApplicationDao.secondKillGoodsToday();
    11.             if (activityDateVO.getStartIntervalTime() == null) {
    12.                 long count = secondKillApplication.parallelStream()
    13.                         .filter(secondKillApplicationEntity -> secondKillApplicationEntity.getStartIntervalTime().isBefore(LocalTime.now()) && secondKillApplicationEntity.getEndIntervalTime().isAfter(LocalTime.now()))
    14.                         .map(secoundEntity -> {
    15.                             DailySecondKillVO dailySecondKillVO1 = new DailySecondKillVO();
    16.                             BeanUtils.copyProperties(secoundEntity, dailySecondKillVO1);
    17.                             dailySecondKillVO.add(dailySecondKillVO1);
    18.                             return dailySecondKillVO;
    19.                         })
    20.                         .count();
    21.             } else {
    22.                 long count = secondKillApplication.parallelStream()
    23.                         .filter(secondKillApplicationEntity -> secondKillApplicationEntity.getStartIntervalTime().equals(activityDateVO.getStartIntervalTime()))
    24.                         .map(secoundEntity -> {
    25.                             DailySecondKillVO dailySecondKillVO1 = new DailySecondKillVO();
    26.                             BeanUtils.copyProperties(secoundEntity, dailySecondKillVO1);
    27.                             dailySecondKillVO.add(dailySecondKillVO1);
    28.                             return dailySecondKillVO;
    29.                         })
    30.                         .count();
    31.             }
    32.             return dailySecondKillVO;
    33.         }, executor);
    35.         CompletableFuture<List<SpikeTimePeriodEntity>> sort = CompletableFuture.supplyAsync(() -> {
    36.             System.out.println(2);
    37.             List<SpikeTimePeriodEntity> timeSlot = spikeTimePeriodDao.timeSlot();
    38.             int size = timeSlot.size();
    39.             if (size <= 5) {
    40.                 int count = 5 - size;
    41.                 QueryWrapper<SpikeTimePeriodEntity> queryWrapper = new QueryWrapper<>(new SpikeTimePeriodEntity());
    42.                 queryWrapper.orderByAsc("sort");
    43.                 queryWrapper.last("limit " + count);
    44.                 List<SpikeTimePeriodEntity> spikeTimePeriodEntities1 = spikeTimePeriodDao.selectList(queryWrapper);
    45.                 timeSlot.addAll(spikeTimePeriodEntities1);
    46.             }
    47.             return timeSlot;
    48.         }, executor);
    50.         //构建时间段选型按照现在的时间段 以及后面四个
    52.         CompletableFuture<Void> voidCompletableFuture = CompletableFuture.allOf(listCompletableFuture, sort);
    53.         try {
    54.             return R.ok().put("dailySecondKillVO",listCompletableFuture.get()).put("timeSlot",sort.get());
    55.         } catch (InterruptedException e) {
    56.             throw new RuntimeException(e);
    57.         } catch (ExecutionException e) {
    58.             throw new RuntimeException(e);
    59.         }