From 1234bdaa649fbc3cb0b5b10d2928f301c178dbd3 Mon Sep 17 00:00:00 2001
From: hujiebin <iamhujiebin@users.noreply.github.com>
Date: Fri, 24 Feb 2023 19:29:39 +0800
Subject: [PATCH] Update event.go

---
 domain/event.go | 56 +++++++++++++++++++++++++++++++++++++++++++------
 1 file changed, 50 insertions(+), 6 deletions(-)

diff --git a/domain/event.go b/domain/event.go
index 97af5d7..5d797b2 100644
--- a/domain/event.go
+++ b/domain/event.go
@@ -1,9 +1,53 @@
 package domain
 
-//异步执行的接口
-type AsyncEvent interface {
-	AsyncDo(model *Model, eventData interface{}, n int) error
-	AsyncSize() int
-	AsyncNoTxDo(model *Model, eventData interface{}, n int) error
-	AsyncNoTxSize() int
+import "git.hilo.cn/hilo-common/utils"
+
+//异步执行的接口-老方式-废弃
+//type AsyncEvent interface {
+//	AsyncDo(model *Model, eventData interface{}, n int) error
+//	AsyncSize() int
+//	AsyncNoTxDo(model *Model, eventData interface{}, n int) error
+//	AsyncNoTxSize() int
+//}
+
+// 程序内部事件
+type EventBase struct {
+	//同步执行
+	syncList []func(model *Model, event interface{}) error
+	//异步执行
+	asyncList []func(model *Model, event interface{}) error
+}
+
+// 添加同步事件
+func AddEventSync(event *EventBase, callback func(model *Model, event interface{}) error) {
+	event.syncList = append(event.syncList, callback)
+}
+
+// 添加异步事件
+func AddEventAsync(event *EventBase, callback func(model *Model, event interface{}) error) {
+	event.asyncList = append(event.asyncList, callback)
+}
+
+// 发布事件
+func PublishEvent(event *EventBase, model *Model, data interface{}) error {
+	// 执行同步的领域事件
+	for _, callback := range event.syncList {
+		if err := callback(model, data); err != nil {
+			return err
+		}
+	}
+	// 执行异步的领域事件
+	if len(event.asyncList) > 0 {
+		go func() {
+			defer utils.CheckGoPanic()
+			for _, callback := range event.asyncList {
+				// 异步事件需要用新model,主要是db
+				var newModel = CreateModelContext(model.MyContext)
+				if err := callback(newModel, data); err != nil {
+					model.Log.Errorf("aysnc fail:%v", err)
+				}
+			}
+		}()
+	}
+	return nil
 }
-- 
2.22.0