| | |
|---|
| | | import java.math.MathContext; |
|---|
| | | import java.math.RoundingMode; |
|---|
| | | import java.text.SimpleDateFormat; |
|---|
| | | import java.time.LocalDateTime; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | |
|---|
| | | |
|---|
| | | @Service |
|---|
| | |
|---|
| | | //获取空闲司机 |
|---|
| | | List<Driver> list = driverService.queryIdleDriver(1, orderPrivateCar.getServerCarModelId(), orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat(), pushOrder.getPushDistance(), null);//所有附近空闲司机 |
|---|
| | | if(list.size() > 0){ |
|---|
| | | // 查询预约单 |
|---|
| | | List<Integer> driverIds = list.stream().map(Driver::getId).collect(Collectors.toList()); |
|---|
| | | List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryOrderByState(driverIds, 2, 1, 1, 2, 3, 4, 5, 6, 11); |
|---|
| | | double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数 |
|---|
| | | int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数（下标截取） |
|---|
| | | list = list.subList(0, lastIndex);//获取空闲司机中占比数据 |
|---|
| | | for(Driver driver : list){//开始进行推送 |
|---|
| | | // 判断该司机是否有30分钟内预约单 |
|---|
| | | long count = orderPrivateCars.stream().filter(orderPrivateCar1 -> driver.getId().equals(orderPrivateCar1.getDriverId()) |
|---|
| | | && DateUtil.dateToLocalDateTime(orderPrivateCar1.getTravelTime()).minusMinutes(30).isBefore(LocalDateTime.now()) |
|---|
| | | && DateUtil.dateToLocalDateTime(orderPrivateCar1.getTravelTime()).isAfter(LocalDateTime.now())).count(); |
|---|
| | | if(count > 0){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | boolean bo = false; |
|---|
| | | for(Integer integer : integers){ |
|---|
| | | if(integer.compareTo(driver.getId()) == 0){ |
|---|
