修复bom第一启动时的全量上报

zhangzengfei

2023-09-11 1873461012c99801f364bd07fae2c218d245048e

 main.go

@@ -1,6 +1,8 @@
package main

import (
   "kingdee-dbapi/report"
   "kingdee-dbapi/webserver"
   "os"
   "strings"

@@ -16,7 +18,7 @@
)

func main() {
   logger.InitLog("kingdee-dbapi.log", "debug", 15, false)
   logger.InitLog("log/kingdee-dbapi.log", "debug", 15, false)
   logger.Info("kingdee-dbapi start!")

   config.Load()
@@ -36,10 +38,29 @@
   defer kingdee.CloseDB()

   // 创建窗口并运行
   window := gui.NewDisplay()
   dbConnectedChan := make(chan bool)
   window := gui.NewDisplay(dbConnectedChan)

   // 数据库连接成功后启动其他服务
   go onSqlServerConnected(dbConnectedChan)

   window.ShowMainWindow()
}

func onSqlServerConnected(dbConnectedChan chan bool) {
   <-dbConnectedChan

   logger.Debug("数据库已连接, 启动接口服务")
   report.Start()

   // 开启订阅SQL查询
   go nsqclient.InitNsqConsumer(config.Options.SqlQueryTopic, "sensor01", kingdee.SqlQueryHandle)
   go nsqclient.InitNsqConsumer(config.Options.CSTQueryTopic, "sensor01", kingdee.CSTQueryHandle)
   go nsqclient.InitNsqConsumer(config.Options.BomQueryTopic, "sensor01", report.HandleBomQuery)

   go webserver.Serve(config.Options.WebPort)
}

func setFont() {
   fontPaths := findfont.List()