From 8e9af0dc003d6f645edf0756f85ac19b5d74076e Mon Sep 17 00:00:00 2001 From: xuhy <3313886187@qq.com> Date: 星期三, 30 四月 2025 16:33:36 +0800 Subject: [PATCH] 咸宁用户端电召修改 --- UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java | 17 +++++++++++++++++ 1 files changed, 17 insertions(+), 0 deletions(-) diff --git a/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java b/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java index 2161e58..5a77d5b 100644 --- a/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java +++ b/UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java @@ -14,11 +14,13 @@ 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.List; import java.util.Map; +import java.util.stream.Collectors; @Service public class DriverServiceImpl extends ServiceImpl<DriverMapper, Driver> implements IDriverService { @@ -89,6 +91,21 @@ return list; } + @Override + public List<Driver> queryIdleDriverAllCall(Integer type, Double lon, Double lat, Double distance, List<Integer> companyIds) throws Exception { + if(CollectionUtils.isEmpty(companyIds)){ + System.err.println("-----未查询到该区域分公司进行推单------"); + return new ArrayList<>(); + } + companyIds = companyIds.stream().distinct().collect(Collectors.toList()); + List<Driver> allDrivers = new ArrayList<>(); + for (Integer companyId : companyIds) { + List<Driver> drivers = driverMapper.queryIdleDriver(type, companyId); + allDrivers.addAll(drivers); + } + System.err.println("-----符合条件的司机"+allDrivers); + return allDrivers; + } /** -- Gitblit v1.7.1