From 23b1391e7d8a9a5f558f74e76175ec5c27e7c42a Mon Sep 17 00:00:00 2001
From: yxh <yxh1103@qq.com>
Date: Sun, 18 Feb 2024 11:31:58 +0800
Subject: [PATCH] =?UTF-8?q?add=20=E4=BA=8B=E4=BB=B6=E6=80=BB=E7=BA=BF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 go.mod                                        |  1 +
 go.sum                                        |  1 +
 .../app/common/logic/eventBus/event_bus.go    | 17 ++++++++++++++
 internal/app/common/logic/logic.go            |  1 +
 internal/app/common/service/event_bus.go      | 23 +++++++++++++++++++
 internal/consts/version.go                    |  2 +-
 6 files changed, 44 insertions(+), 1 deletion(-)
 create mode 100644 internal/app/common/logic/eventBus/event_bus.go
 create mode 100644 internal/app/common/service/event_bus.go

diff --git a/go.mod b/go.mod
index 59829c1..8a78e34 100644
--- a/go.mod
+++ b/go.mod
@@ -6,6 +6,7 @@ require (
 	github.com/ArtisanCloud/PowerWeChat/v3 v3.1.8
 	github.com/aliyun/aliyun-oss-go-sdk v2.2.8+incompatible
 	github.com/apache/rocketmq-client-go/v2 v2.1.1
+	github.com/asaskevich/EventBus v0.0.0-20200907212545-49d423059eef
 	github.com/casbin/casbin/v2 v2.42.0
 	github.com/gogf/gf/contrib/drivers/mysql/v2 v2.6.2
 	github.com/gogf/gf/contrib/drivers/pgsql/v2 v2.6.2
diff --git a/go.sum b/go.sum
index aa7ea65..dd9e70a 100644
--- a/go.sum
+++ b/go.sum
@@ -14,6 +14,7 @@ github.com/aliyun/aliyun-oss-go-sdk v2.2.8+incompatible h1:6JF1bjhT0WN2srEmijfOF
 github.com/aliyun/aliyun-oss-go-sdk v2.2.8+incompatible/go.mod h1:T/Aws4fEfogEE9v+HPhhw+CntffsBHJ8nXQCwKr0/g8=
 github.com/apache/rocketmq-client-go/v2 v2.1.1 h1:WY/LkOYSQaVyV+HOqdiIgF4LE3beZ/jwdSLKZlzpabw=
 github.com/apache/rocketmq-client-go/v2 v2.1.1/go.mod h1:GZzExtXY9zpI6FfiVJYAhw2IXQtgnHUuWpULo7nr5lw=
+github.com/asaskevich/EventBus v0.0.0-20200907212545-49d423059eef/go.mod h1:JS7hed4L1fj0hXcyEejnW57/7LCetXggd+vwrRnYeII=
 github.com/benbjohnson/clock v1.1.0 h1:Q92kusRqC1XV2MjkWETPvjJVqKetz1OzxZB7mHJLju8=
 github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA=
 github.com/bsm/ginkgo/v2 v2.12.0 h1:Ny8MWAHyOepLGlLKYmXG4IEkioBysk6GpaRTLC8zwWs=
diff --git a/internal/app/common/logic/eventBus/event_bus.go b/internal/app/common/logic/eventBus/event_bus.go
new file mode 100644
index 0000000..f7223e8
--- /dev/null
+++ b/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())
+}
diff --git a/internal/app/common/logic/logic.go b/internal/app/common/logic/logic.go
index 127dd78..4bcaf29 100644
--- a/internal/app/common/logic/logic.go
+++ b/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"
diff --git a/internal/app/common/service/event_bus.go b/internal/app/common/service/event_bus.go
new file mode 100644
index 0000000..671668b
--- /dev/null
+++ b/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
+}
diff --git a/internal/consts/version.go b/internal/consts/version.go
index 04fdb4a..b2cda3e 100644
--- a/internal/consts/version.go
+++ b/internal/consts/version.go
@@ -9,5 +9,5 @@ package consts
 
 const (
 	Logo    = `CiAgIF9fX19fX19fX19fXyAgICAgICAgICAgX18gCiAgLyBfX19fLyBfX19fL19fXyBfX19fX18vIC9fCiAvIC8gX18vIC9fICAvIF9fIGAvIF9fXy8gX18vCi8gL18vIC8gX18vIC8gL18vIChfXyAgKSAvXyAgClxfX19fL18vICAgIFxfXyxfL19fX18vXF9fLyAg`
-	Version = "3.2.18"
+	Version = "3.2.19"
 )