update...

潘钊
1 parent d06bd98b
Showing 2 changed files with 13 additions and 2 deletions
src/main/java/com/bsth/client/GpsBeforeBuffer.java
src/main/java/com/bsth/entity/GpsEntity.java
@@ -22,7 +22,7 @@ import java.util.concurrent.*;
 public class GpsBeforeBuffer implements CommandLineRunner{
     static ConcurrentLinkedQueue<GpsEntity> linkedList = new ConcurrentLinkedQueue();
-    static final int MAX_SIZE = 4000 * 20;
+    static final int MAX_SIZE = 4000 * 12;
     static int size = 0;
     public void put(GpsEntity gps){
@@ -75,6 +75,9 @@ public class GpsEntity {
      */
     private int source;
+    /** 网关收到时间 */
+    private Long serverTimestamp;
+
     public static GpsEntity getInstance(BasicInfo basicInfo, int version, int source){
         //放弃补发数据
         byte cacheData = getCacheState(basicInfo.getServiceState());
@@ -96,7 +99,7 @@ public class GpsEntity {
         gps.setState((int) getService(basicInfo.getServiceState()));
         gps.setVersion(version);
         gps.setSource(source);
-
+        gps.setServerTimestamp(System.currentTimeMillis());
         return gps;
     }
 /*    public GpsEntity(BasicInfo basicInfo, int version, int source) {
@@ -242,4 +245,12 @@ public class GpsEntity {
     public void setSource(int source) {
         this.source = source;
     }
+
+    public Long getServerTimestamp() {
+        return serverTimestamp;
+    }
+
+    public void setServerTimestamp(Long serverTimestamp) {
+        this.serverTimestamp = serverTimestamp;
+    }
 }