From cb333d0a0c522f0f54ac2ab8c2991297de7ea030 Mon Sep 17 00:00:00 2001 From: chents <78666437@qq.com> Date: Thu, 11 May 2023 20:56:41 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../modules/business/controller/CommonApiController.java | 1 - src/main/java/org/springblade/modules/job/CarInfoTask.java | 7 ++----- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/src/main/java/org/springblade/modules/business/controller/CommonApiController.java b/src/main/java/org/springblade/modules/business/controller/CommonApiController.java index 831636c..b4f39f7 100644 --- a/src/main/java/org/springblade/modules/business/controller/CommonApiController.java +++ b/src/main/java/org/springblade/modules/business/controller/CommonApiController.java @@ -140,7 +140,6 @@ public class CommonApiController extends BladeController { @GetMapping("get-car-speed") public R getCarSpeed(@RequestParam String carNo) { CarInfoVO info = carInfoService.getCarInfo(carNo); - carInfoTask.getCarSpeed(carNo); if (Func.isEmpty(info)) { return R.fail("未获取到车辆信息, 请检查车是否已掉线"); } diff --git a/src/main/java/org/springblade/modules/job/CarInfoTask.java b/src/main/java/org/springblade/modules/job/CarInfoTask.java index a8ea20a..29ac1a1 100644 --- a/src/main/java/org/springblade/modules/job/CarInfoTask.java +++ b/src/main/java/org/springblade/modules/job/CarInfoTask.java @@ -48,10 +48,6 @@ public class CarInfoTask { System.out.println("======存入实时车辆信息到redis成功========="); } - @Scheduled(cron = "0/1 * * * * ?") - public void setCarInfo() { -// redisTemplate.opsForValue().set("car-current-number", device); - } @Scheduled(cron = "0/10 * * * * ?") public void parseCarInfo() { @@ -103,7 +99,8 @@ public class CarInfoTask { } @Scheduled(cron = "0/1 * * * * ?") - public void getCarSpeed(String carNo) { + public void getCarSpeed() { + String carNo = (String) redisTemplate.opsForValue().get("car-current-number"); CarInfoVO info = carInfoService.getCarInfo(carNo); if (Func.isEmpty(info)) { throw new RuntimeException("未获取到车辆信息, 请检查车是否已掉线");