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

zhangzengfei

2023-09-11 1873461012c99801f364bd07fae2c218d245048e

 main.go

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

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

@@ -16,8 +18,8 @@
)

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

   config.Load()

@@ -30,17 +32,33 @@
   // 初始化nsq
   nsqclient.InitNsqProducer()

   // 开启订阅
   go nsqclient.InitNsqConsumer(config.Options.QueryTopic, "sensor01", kingdee.QueryMsgHandle)

   // 设置中文字体
   setFont()
   defer os.Unsetenv("FYNE_FONT")
   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() {
@@ -50,6 +68,13 @@
      // 微软雅黑-常规
      if strings.Contains(path, "msyh.ttf") {
         os.Setenv("FYNE_FONT", path)

         break
      }
      // 黑体-常规
      if strings.Contains(path, "simhei.ttf") {
         os.Setenv("FYNE_FONT", path)

         break
      }
   }