| | |
|---|
| | | 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() |
|---|
| | | |
|---|
| | | // 开启订阅 |
|---|
| | | go nsqclient.InitNsqConsumer(config.Options.QueryTopic, "sensor01", kingdee.QueryMsgHandle) |
|---|
| | | // 开启订阅SQL查询 |
|---|
| | | go nsqclient.InitNsqConsumer(config.Options.SqlQueryTopic, "sensor01", kingdee.SqlQueryHandle) |
|---|
| | | go nsqclient.InitNsqConsumer(config.Options.CSTQueryTopic, "sensor01", kingdee.CSTQueryHandle) |
|---|
| | | |
|---|
| | | go webserver.Serve(serverPort.Text) |
|---|
| | | }) |
|---|
