From bd47b3f1c3398b2c0bd44ffbc903d60307ed556c Mon Sep 17 00:00:00 2001
From: xiwa <xw2sy@163.com>
Date: Tue, 20 Feb 2024 21:16:05 +0800
Subject: [PATCH] =?UTF-8?q?fix:http=E6=8F=92=E4=BB=B6=E4=B8=8A=E6=8A=A5?=
 =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=97=B6=E9=97=B4=E3=80=81=E5=81=9C=E6=AD=A2?=
 =?UTF-8?q?=E6=8F=92=E4=BB=B6=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/cc/iotkit/plugins/http/service/HttpVerticle.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/http-plugin/src/main/java/cc/iotkit/plugins/http/service/HttpVerticle.java b/http-plugin/src/main/java/cc/iotkit/plugins/http/service/HttpVerticle.java
index 72edd62..cfa2a5b 100755
--- a/http-plugin/src/main/java/cc/iotkit/plugins/http/service/HttpVerticle.java
+++ b/http-plugin/src/main/java/cc/iotkit/plugins/http/service/HttpVerticle.java
@@ -64,7 +64,8 @@ public class HttpVerticle extends AbstractVerticle implements Handler<RoutingCon
     public void start() {
         Executors.newSingleThreadScheduledExecutor().schedule(this::initHttpServer, 3, TimeUnit.SECONDS);
     }
-    private void initHttpServer(){
+
+    private void initHttpServer() {
         httpServer = vertx.createHttpServer();
         Router router = Router.router(vertx);
         router.route().handler(BodyHandler.create()).handler(this);
@@ -79,6 +80,9 @@ public class HttpVerticle extends AbstractVerticle implements Handler<RoutingCon
 
     @Override
     public void stop() {
+        httpServer.close(rst -> {
+            log.info("http server close:{}", rst.succeeded());
+        });
     }
 
     @Override
@@ -153,6 +157,7 @@ public class HttpVerticle extends AbstractVerticle implements Handler<RoutingCon
                                 .level(EventLevel.INFO)
                                 .name(parts[3])
                                 .params(payload.getJsonObject("params").getMap())
+                                .time(System.currentTimeMillis())
                                 .build()
                 );
                 end(response);
@@ -169,6 +174,7 @@ public class HttpVerticle extends AbstractVerticle implements Handler<RoutingCon
                                     .productKey(productKey)
                                     .deviceName(deviceName)
                                     .params(payload.getJsonObject("params").getMap())
+                                    .time(System.currentTimeMillis())
                                     .build()
                     );
                     end(response);