From 740affd0288733aee4cfb8c2e3b9af01ded0d913 Mon Sep 17 00:00:00 2001 From: chents <78666437@qq.com> Date: Wed, 17 May 2023 15:31:14 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E9=9D=99=E6=80=81=E5=8F=98?= =?UTF-8?q?=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/org/springblade/modules/job/CarInfoTask.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/springblade/modules/job/CarInfoTask.java b/src/main/java/org/springblade/modules/job/CarInfoTask.java index 58610d9..66702e5 100644 --- a/src/main/java/org/springblade/modules/job/CarInfoTask.java +++ b/src/main/java/org/springblade/modules/job/CarInfoTask.java @@ -49,6 +49,8 @@ public class CarInfoTask { private static final String WEB = "web"; private static final String CURRENT_CAR_INFO = "current_car_info"; private static final String SPEED = "speed"; + private static final String ONLINE = "online"; + private static final String OFFLINE = "offline"; private final ICarInfoService carInfoService; @@ -83,7 +85,7 @@ public class CarInfoTask { String carNo = CarInfoCache.getPushCarNo(); HashMap statusMap = new HashMap<>(); if (Func.isEmpty(carNo)) { - statusMap.put("status","offline"); + statusMap.put("status",OFFLINE); message.setContent(JSON.toJSONString(statusMap)); websocketService.broadcast(message); return; @@ -97,7 +99,7 @@ public class CarInfoTask { } } if (Func.isEmpty(info)) { - statusMap.put("status","offline"); + statusMap.put("status",OFFLINE); message.setContent(JSON.toJSONString(statusMap)); websocketService.broadcast(message); return; @@ -240,7 +242,7 @@ public class CarInfoTask { WebSocketMessage message = new WebSocketMessage(); HashMap statusMap = new HashMap<>(); if (Func.isEmpty(info)) { - statusMap.put("status","offline"); + statusMap.put("status",OFFLINE); message.setContent(JSON.toJSONString(statusMap)); websocketService.broadcast(message); return;