| | |
| | | package main |
| | | |
| | | import ( |
| | | "kingdee-dbapi/report" |
| | | "kingdee-dbapi/webserver" |
| | | "os" |
| | | "strings" |
| | | |
| | |
| | | defer kingdee.CloseDB() |
| | | |
| | | // 创建窗口并运行 |
| | | window := gui.NewDisplay() |
| | | var dbConnectedChan 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() |
| | | |