| | |
|---|
| | | // 查询预约单 |
|---|
| | | List<Integer> driverIds = drivers.stream().map(Driver::getId).collect(Collectors.toList()); |
|---|
| | | List<OrderPrivateCar> orderPrivateCarss = orderPrivateCarMapper.queryOrderByState(driverIds, 2, 1, 2, 3, 4, 5, 6, 11); |
|---|
| | | List<Integer> orderPrivateCarDriverIds = orderPrivateCars.stream().map(OrderPrivateCar::getDriverId).collect(Collectors.toList()); |
|---|
| | | for(int j = 0; j < drivers.size(); j++){ |
|---|
| | | Driver driver1 = drivers.get(j); |
|---|
| | | // 判断该司机是否有30分钟内预约单 |
|---|
| | | long count = orderPrivateCarss.stream().filter(orderPrivateCar1 -> driver1.getId().equals(orderPrivateCar1.getDriverId()) |
|---|
| | | && DateUtil.dateToLocalDateTime(orderPrivateCar1.getTravelTime()).minusMinutes(30).isBefore(LocalDateTime.now()) |
|---|
| | | && DateUtil.dateToLocalDateTime(orderPrivateCar1.getTravelTime()).isAfter(LocalDateTime.now())).count(); |
|---|
| | | if(orderPrivateCar.getOrderType() == 2 && orderPrivateCarDriverIds.contains(driver.getId())){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | if(count > 0){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
