运单预警

performance-web/src/main/java/com/clx/performance/service/impl/trace/TruckTraceServiceImpl.java

@@ -55,6 +55,8 @@ public class TruckTraceServiceImpl implements TruckTraceService {
         // 停留时长计算
         Integer parkIdx = null;
         for (int i=0; i<traceList.size(); i++){
+            if (traceList.get(i).getSpeed() == null){continue;}
+
             if (traceList.get(i).getSpeed().compareTo(new BigDecimal(PARK_SPEED)) < 0){
                 parkIdx = i;
             }
@@ -65,6 +67,11 @@ public class TruckTraceServiceImpl implements TruckTraceService {
             }
         }
 
+        if (parkIdx!=null && parkIdx < traceList.size()-1){
+            long stayTime = Duration.between(LocalDateTimeUtils.parseTime(traceList.get(parkIdx).getGpsTime()), LocalDateTimeUtils.parseTime(traceList.get(traceList.size()-1).getGpsTime())).getSeconds();
+            traceList.get(parkIdx).setStayTime(new BigDecimal(stayTime).divide(new BigDecimal(60), 1, RoundingMode.HALF_UP));
+        }
+
         return traceList;
     }
 
@@ -94,9 +101,13 @@ public class TruckTraceServiceImpl implements TruckTraceService {
             }
         }
 
-        return traceList;
+        if (parkIdx!=null && parkIdx < traceList.size()-1){
+            long stayTime = Duration.between(LocalDateTimeUtils.parseTime(traceList.get(parkIdx).getGpsTime()), LocalDateTimeUtils.parseTime(traceList.get(traceList.size()-1).getGpsTime())).getSeconds();
+            traceList.get(parkIdx).setStayTime(new BigDecimal(stayTime).divide(new BigDecimal(60), 1, RoundingMode.HALF_UP));
         }
 
+        return traceList;
+    }
 
     @Override
     public void truckTraceSave(TruckTraceAddParam param){