From fa4d91768a990d5e8b759300a1271b12f54c10ca Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期五, 22 八月 2025 23:14:15 +0800
Subject: [PATCH] 8.22

---
 UserOKTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/DriverServiceImpl.java |   24 ++++++++++++++++++++++++
 1 files changed, 24 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..c98b407 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 {
@@ -88,6 +90,21 @@
         System.err.println("-----符合条件的司机"+list);
 
         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;
     }
 
 
@@ -177,4 +194,11 @@
         }
         return maps;
     }
+
+    @Override
+    public List<Driver> queryDriversByLineAndCarModel(Integer type,Integer serverCarModelId, Integer lineId) throws Exception {
+        List<Driver> drivers = driverMapper.queryDriversByLineAndCarModel( type,serverCarModelId, lineId);
+
+        return drivers;
+    }
 }

--
Gitblit v1.7.1