From 3e9a1a28b1283e40bc7edb94e2370c74e7fd68e0 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期五, 17 五月 2024 15:54:29 +0800
Subject: [PATCH] 添加订阅查询接口
---
main.go | 19 +++++++++++++++----
1 files changed, 15 insertions(+), 4 deletions(-)
diff --git a/main.go b/main.go
index 1e8a151..d055edf 100644
--- a/main.go
+++ b/main.go
@@ -7,9 +7,10 @@
"os"
"os/signal"
"syscall"
- "time"
+ "gat1400Exchange/client"
"gat1400Exchange/config"
+ "gat1400Exchange/cron"
"gat1400Exchange/models"
"gat1400Exchange/pkg/logger"
"gat1400Exchange/routes"
@@ -36,9 +37,17 @@
Handler: r,
}
+ // 鍚姩1400瀹㈡埛绔�
+ ctx, cancel := context.WithCancel(context.Background())
+ go client.Init1400Client(ctx)
+
// 鍚姩缃戠粶瑙嗛瀛楃鍙犲姞鍣ㄦ湇鍔�
- go service.NVCSServer()
- go service.DeviceInfoReportTask()
+ go service.StartNVCSServer()
+
+ go service.InitSubscribeTask()
+
+ // 鍚姩瀹氭椂浠诲姟
+ cron.Init()
// Initializing the server in a goroutine so that
// it won't block the graceful shutdown handling below
@@ -62,11 +71,13 @@
// The context is used to inform the server it has 5 seconds to finish
// the request it is currently handling
- ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+ //ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
if err := srv.Shutdown(ctx); err != nil {
logger.Error("Server forced to shutdown:", err)
}
+ service.StopSubscribeTask()
+
logger.Info("Server exiting!")
}
--
Gitblit v1.8.0