add 事件总线

internal/app/common/logic/eventBus/event_bus.go

@@ -0,0 +1,17 @@
+/**
+ * @Company: 云南奇讯科技有限公司
+ * @Author: yxf
+ * @Description:
+ * @Date: 2024/1/25 16:22
+ */
+
+package eventBus
+
+import (
+	"github.com/asaskevich/EventBus"
+	"github.com/tiger1103/gfast/v3/internal/app/common/service"
+)
+
+func init() {
+	service.RegisterEventBus(EventBus.New())
+}

internal/app/common/logic/logic.go

@@ -8,6 +8,7 @@ import (
 	_ "github.com/tiger1103/gfast/v3/internal/app/common/logic/bigUpload"
 	_ "github.com/tiger1103/gfast/v3/internal/app/common/logic/cache"
 	_ "github.com/tiger1103/gfast/v3/internal/app/common/logic/captcha"
+	_ "github.com/tiger1103/gfast/v3/internal/app/common/logic/eventBus"
 	_ "github.com/tiger1103/gfast/v3/internal/app/common/logic/middleware"
 	_ "github.com/tiger1103/gfast/v3/internal/app/common/logic/snowIDGen"
 	_ "github.com/tiger1103/gfast/v3/internal/app/common/logic/sysConfig"

internal/app/common/service/event_bus.go

@@ -0,0 +1,23 @@
+// ================================================================================
+// Code generated by GoFrame CLI tool. DO NOT EDIT.
+// You can delete these comments if you wish manually maintain this interface file.
+// ================================================================================
+
+package service
+
+import (
+	eventBus "github.com/asaskevich/EventBus"
+)
+
+var localEventBus eventBus.Bus
+
+func EventBus() eventBus.Bus {
+	if localEventBus == nil {
+		panic("implement not found for interface EventBus, forgot register?")
+	}
+	return localEventBus
+}
+
+func RegisterEventBus(i eventBus.Bus) {
+	localEventBus = i
+}