From ef31b6f48eb2a5114f9bee43a9933d1cbde8935a Mon Sep 17 00:00:00 2001 From: "autumn.g@foxmail.com" Date: Thu, 7 Dec 2023 16:26:30 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E5=8A=A0=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/jsowell/netty/handler/LoginRequestHandler.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/handler/LoginRequestHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/handler/LoginRequestHandler.java index b67c8bdeb..fdfb4ef90 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/handler/LoginRequestHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/handler/LoginRequestHandler.java @@ -195,6 +195,7 @@ public class LoginRequestHandler extends AbstractHandler { if (pileBasicInfo != null) { flag = Constants.zeroByteArray; + // 异步修改充电桩状态 CompletableFuture.runAsync(() -> { try { // 更改桩和该桩下的枪口状态分别为 在线、空闲 公共方法修改状态 @@ -204,6 +205,7 @@ public class LoginRequestHandler extends AbstractHandler { } }); + // 异步发送对时指令 CompletableFuture.runAsync(() -> { try { Thread.sleep(200); @@ -216,6 +218,7 @@ public class LoginRequestHandler extends AbstractHandler { }); // log.info("下面进行下发二维码 pileSn:{}, thread:{}", pileSn, Thread.currentThread().getName()); + // 异步发送下发二维码指令 CompletableFuture.runAsync(() -> { try { Thread.sleep(600); @@ -240,6 +243,7 @@ public class LoginRequestHandler extends AbstractHandler { } } + // 异步保持登录报文 CompletableFuture.runAsync(() -> { // 保存报文 没有登录认证通过还要不要保存报文？ try {