1.加入历史到离站信息查询接口

王通
1 parent 0ccf4fdc
Showing 2 changed files with 66 additions and 2 deletions
src/main/java/com/bsth/server_rs/gps/entity/HistoryArrivalEntity.java
src/main/java/com/bsth/server_rs/schedule/real/ScheduleRealService.java
+package com.bsth.server_rs.gps.entity;
+
+public class HistoryArrivalEntity {
+
+    private String deviceId;
+
+    private int lineId;
+
+    private String stopNo;
+
+    private int upDown;
+
+    private int inOut;
+
+    private long ts;
+
+    public String getDeviceId() {
+        return deviceId;
+    }
+
+    public void setDeviceId(String deviceId) {
+        this.deviceId = deviceId;
+    }
+
+    public int getLineId() {
+        return lineId;
+    }
+
+    public void setLineId(int lineId) {
+        this.lineId = lineId;
+    }
+
+    public String getStopNo() {
+        return stopNo;
+    }
+
+    public void setStopNo(String stopNo) {
+        this.stopNo = stopNo;
+    }
+
+    public int getUpDown() {
+        return upDown;
+    }
+
+    public void setUpDown(int upDown) {
+        this.upDown = upDown;
+    }
+
+    public int getInOut() {
+        return inOut;
+    }
+
+    public void setInOut(int inOut) {
+        this.inOut = inOut;
+    }
+
+    public long getTs() {
+        return ts;
+    }
+
+    public void setTs(long ts) {
+        this.ts = ts;
+    }
+}
@@ -360,7 +360,7 @@ public class ScheduleRealService implements InitializingBean {
     @Override
     public void afterPropertiesSet() throws Exception {
-        /*Application.mainServices.scheduleWithFixedDelay(new Runnable() {
+        Application.mainServices.scheduleWithFixedDelay(new Runnable() {
             @Override
             public void run() {
                 try {
@@ -419,6 +419,6 @@ public class ScheduleRealService implements InitializingBean {
                     logger.error("kafka发电子路单调度异常", e);
                 }
             }
-        }, 30, 240, TimeUnit.SECONDS);*/
+        }, 30, 240, TimeUnit.SECONDS);
     }
 }