commit

amd64/dispatch_server/main.go

@@ -73,8 +73,8 @@ func main() {
 	api1.POST("/start-project", handler.StartProject)
 	api2 := router.Group("/simulation/resource/scheduler")
 	api2.POST("/confirm", handler.Confirm)
+	api2.POST("/tick", handler.Tick)
 	api2.POST("/state", handler.State)
-	api2.POST("/confirm", handler.Confirm)
 	err := router.Run(":" + infra.ApplicationYaml.Web.Port)
 	if err != nil {
 		infra.GlobalLogger.Error("程序崩溃，监听端口 " + util.ToString(infra.ApplicationYaml.Web.Port) + " 失败。")

amd64/dispatch_server/package/infra/i_kafka.go

@@ -21,4 +21,5 @@ func InitKafkaProducer(broker string) {
 	if err != nil {
 		GlobalLogger.Errorf("初始化kafka生产者失败，配置信息为：%v，错误信息为：%v", broker, err)
 	}
+	GlobalLogger.Errorf("初始化kafka生产者成功：%v", broker)
 }