|
...
|
...
|
@@ -2,7 +2,6 @@ package main |
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/port/mqtt"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/port/task"
|
|
|
|
|
|
|
|
"github.com/beego/beego/v2/server/web"
|
|
...
|
...
|
@@ -34,7 +33,7 @@ func main() { |
|
|
|
log.Logger.Debug("server start ....")
|
|
|
|
log.Logger.Debug(fmt.Sprintf("ENABLE_KAFKA_LOG:%v", constant.ENABLE_KAFKA_LOG))
|
|
|
|
|
|
|
|
go mqtt.Start()
|
|
|
|
//go mqtt.Start()
|
|
|
|
go task.Run()
|
|
|
|
cron := crontab.NewCrontabService(nil)
|
|
|
|
cron.StartCrontabTask()
|
...
|
...
|
|
