Update event.go

domain/event.go

 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
 }