From 1a6fa89e9ffc8ade73afbeda3e6c791bad1d4cd9 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期二, 15 八月 2023 17:30:57 +0800
Subject: [PATCH] 添加bom子项的上报

---
 gui/gui.go |   14 ++++++++------
 1 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/gui/gui.go b/gui/gui.go
index 1dfdb39..94048e8 100644
--- a/gui/gui.go
+++ b/gui/gui.go
@@ -1,11 +1,12 @@
 package gui
 
 import (
-	"kingdee-dbapi/logger"
 	"strings"
 
 	"kingdee-dbapi/config"
 	"kingdee-dbapi/kingdee"
+	"kingdee-dbapi/logger"
+	"kingdee-dbapi/nsqclient"
 	"kingdee-dbapi/report"
 	"kingdee-dbapi/static"
 	"kingdee-dbapi/webserver"
@@ -26,6 +27,7 @@
 
 func NewDisplay() *Display {
 	a := app.New()
+
 	// 璁剧疆鍥炬爣
 	a.SetIcon(static.IconPng)
 
@@ -79,17 +81,17 @@
 		if err != nil {
 			logger.Error("db init error:%s", err.Error())
 			dialog.ShowError(err, w)
-
-			if !config.Options.Debug {
-				return
-			}
 		}
 
 		form.Disable()
 		submitBtn.Text = "宸插惎鍔�"
 		submitBtn.Disable()
 
-		report.StartReport()
+		report.Start()
+
+		// 寮�鍚闃匰QL鏌ヨ
+		go nsqclient.InitNsqConsumer(config.Options.SqlQueryTopic, "sensor01", kingdee.SqlQueryHandle)
+		go nsqclient.InitNsqConsumer(config.Options.CSTQueryTopic, "sensor01", kingdee.CSTQueryHandle)
 
 		go webserver.Serve(serverPort.Text)
 	})

--
Gitblit v1.8.0