首页统计
parent
28adc5863b
commit
a1d837b5a5
|
|
@ -146,7 +146,7 @@ public class OnStarted {
|
||||||
Integer speed = param.getSpeed();
|
Integer speed = param.getSpeed();
|
||||||
CompletableFuture.runAsync(() -> {
|
CompletableFuture.runAsync(() -> {
|
||||||
try {
|
try {
|
||||||
LocalDateTime startTime = LocalDateTime.now().minusSeconds(300);
|
LocalDateTime startTime = LocalDateTime.now().minusSeconds(60 * 30);
|
||||||
int errCount = 0;
|
int errCount = 0;
|
||||||
while (true) {
|
while (true) {
|
||||||
// 检查是否被取消
|
// 检查是否被取消
|
||||||
|
|
@ -165,7 +165,7 @@ public class OnStarted {
|
||||||
|
|
||||||
List<TruckLocationTrackEntity> records = resultPage.getRecords();
|
List<TruckLocationTrackEntity> records = resultPage.getRecords();
|
||||||
if (records.isEmpty()) {
|
if (records.isEmpty()) {
|
||||||
if (errCount >= 300) {
|
if (errCount >= 3600) {
|
||||||
log.error("暂无实时数据, 车牌号: {}, 时间: {}", licensePlate, startTime);
|
log.error("暂无实时数据, 车牌号: {}, 时间: {}", licensePlate, startTime);
|
||||||
Websocket.publish(new WsMsg()
|
Websocket.publish(new WsMsg()
|
||||||
.setEvent("down/truck_location_track/realtime")
|
.setEvent("down/truck_location_track/realtime")
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue