update

xcron/cron.go

@@ -70,7 +70,6 @@ func initCron() error {
 	if err = gocron.Add(tasks...); err != nil {
 		return err
 	}
-	eventbus.Eb.Publish(ctx, eventbus.TopicCronInitFinish)
 	logger.Info("[cron] initialized", ctxUtils.CtxTraceIDField(ctx))
 	return nil
 }

xcron/init.go

@@ -12,7 +12,7 @@ import (
 )
 
 func init() {
-	eventbus.Eb.Subscribe(eventbus.TopicGinEngineCreated, func(ctx context.Context) {
+	eventbus.Eb.Subscribe(eventbus.TopicCoreInitFinish, func(ctx context.Context) {
 		initXCron()
 		initLocalCron()
 	})