|
|
@@ -1387,13 +1387,36 @@ public class KwfTruckService {
|
|
|
//按照车辆id进行分组
|
|
|
Map<Long, List<KwfTruck>> truckIdAndTruckListMap = kwfTrucks.stream().collect(Collectors.groupingBy(KwfTruck::getId));
|
|
|
//获取要返回的车辆信息
|
|
|
- List<CapacityStatusVo.Truck> trucks = kwfFleetTrucks.stream().map(x -> getTruck(x, fleetMap, truckIdAndTruckListMap)).collect(Collectors.toList());
|
|
|
-
|
|
|
+ List<CapacityStatusVo.Truck> trucks = Lists.newArrayList();
|
|
|
+ fleetIdAndFleetTruckListMap.forEach((fleetId, fleetTruckList) -> {
|
|
|
+ buildTruck(fleetId, fleetTruckList, fleetMap);
|
|
|
+ });
|
|
|
+
|
|
|
CapacityStatusVo capacityStatusVo = new CapacityStatusVo();
|
|
|
capacityStatusVo.setTruck(trucks);
|
|
|
return capacityStatusVo;
|
|
|
}
|
|
|
|
|
|
+ private static void buildTruck(Long fleetId, List<KwfFleetTruck> fleetTruckList, Map<Long, KwfFleet> fleetMap) {
|
|
|
+ CapacityStatusVo.Truck truck = new CapacityStatusVo.Truck();
|
|
|
+ truck.setFleetId(String.valueOf(fleetId));
|
|
|
+ truck.setFleetName(fleetMap.getOrDefault(fleetId, new KwfFleet()).getName());
|
|
|
+ //获取空闲车辆数
|
|
|
+ truck.setIdleNum("0");
|
|
|
+ truck.setRunningNum("0");
|
|
|
+ if (CollectionUtils.isNotEmpty(fleetTruckList)) {
|
|
|
+ long idleNum = fleetTruckList.stream()
|
|
|
+ .filter(ft -> Objects.equals(ft.getStatus(), 0))
|
|
|
+ .count();
|
|
|
+ truck.setIdleNum(String.valueOf(idleNum));
|
|
|
+ long runningNum = fleetTruckList.stream()
|
|
|
+ .filter(ft -> Objects.equals(ft.getStatus(), 1))
|
|
|
+ .count();
|
|
|
+ truck.setRunningNum(String.valueOf(runningNum));
|
|
|
+ }
|
|
|
+ truck.setAbnormalNum("0");
|
|
|
+ }
|
|
|
+
|
|
|
|
|
|
public CapacityTotalStatusVo queryTotalCapacityStatus(CapacityStatusReq req) {
|
|
|
log.info("获取运力实况总是统计");
|