| | |
| | | import com.stylefeng.guns.modular.system.warpper.BaseWarpper; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.CollectionUtils; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.util.ArrayList; |
| | | import java.util.Comparator; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.stream.Collectors; |
| | |
| | | @Override |
| | | public List<Driver> queryDriverLimitTen(Integer type, Double lon, Double lat) { |
| | | List<Driver> drivers = driverMapper.queryIdleDriver(type, null); |
| | | if(CollectionUtils.isEmpty(drivers)){ |
| | | return new ArrayList<>(); |
| | | } |
| | | for (Driver driver : drivers) { |
| | | String value = redisUtil.getValue("DRIVER" + driver.getId()); |
| | | if(null != value){ |
| | | double d = GDMapGeocodingUtil.getDistance(lat,lon,Double.parseDouble(value.split(",")[1]),Double.parseDouble(value.split(",")[0])); |
| | | driver.setLon(Double.parseDouble(value.split(",")[0])); |
| | | driver.setLat(Double.parseDouble(value.split(",")[1])); |
| | | driver.setDistance(d); |
| | | } |
| | | } |
| | | if(drivers.size() > 10){ |
| | | drivers.sort(Comparator.comparing(Driver::getDistance)); |
| | | return drivers.stream().limit(10).collect(Collectors.toList()); |
| | | }else { |
| | | return drivers; |