1 新增配置修改的通知事件

game-server/internal/event/user/user.go

@@ -7,11 +7,12 @@ import (
 )
 
 const (
-	onlineTopic     = "user:online"     // 用户上线事件
-	offlineTopic    = "user:offline"    // 用户下线事件
-	registerTopic   = "user:register"   // 用户注册成功
-	infoChangeTopic = "user:infoChange" // 用户信息变动
-	goldChangeTopic = "user:goldChange" // 用户金币变动
+	onlineTopic            = "user:online"            // 用户上线事件
+	offlineTopic           = "user:offline"           // 用户下线事件
+	registerTopic          = "user:register"          // 用户注册成功
+	infoChangeTopic        = "user:infoChange"        // 用户信息变动
+	goldChangeTopic        = "user:goldChange"        // 用户金币变动
+	TableConfigChangeTopic = "user:tableConfigChange" // 桌子配置修改的事件
 )
 
 // PublishOnline 发布用户上线事件
@@ -121,3 +122,19 @@ func SubscribeGoldChange(handler func(uid int64)) { // 订阅用户金币变动
 		log.Errorf("subscribe user's gold change event failed: %v", err)
 	}
 }
+
+func PublishTableConfigChange(gameID int64) { // 发布桌子配置修改的事件
+	err := eventbus.Publish(context.Background(), TableConfigChangeTopic, gameID)
+	if err != nil {
+		log.Errorf("publish user's gold change event failed, gameID = %d err = %v", gameID, err)
+	}
+}
+
+func SubscribeTableConfigChange(handler func(gameID int64)) { // 订阅桌子配置修改的事件
+	err := eventbus.Subscribe(context.Background(), TableConfigChangeTopic, func(event *eventbus.Event) {
+		handler(event.Payload.Int64())
+	})
+	if err != nil {
+		log.Errorf("subscribe user's table config change event failed: %v", err)
+	}
+}