update 完善logstash消息处理

game/game_cluster/internal/mdb/component.go

@@ -83,6 +83,7 @@ func LogstashMigrateTables() {
 	LogstashDB.AutoMigrate(&eventmodels.AssetsEventContent{})
 	LogstashDB.AutoMigrate(&eventmodels.InviteEventContent{})
 	LogstashDB.AutoMigrate(&eventmodels.DiceEventContent{})
+	LogstashDB.AutoMigrate(&eventmodels.TurntableEventContent{})
 	LogstashDB.AutoMigrate(&eventmodels.JoinChannelEventContent{})
 	LogstashDB.AutoMigrate(&eventmodels.FollowEventContent{})
 	LogstashDB.AutoMigrate(&eventmodels.TaskFinishEventContent{})

game/game_cluster/nodes/logstash/module/event/enent.go

@@ -27,6 +27,7 @@ var (
 	_ Eventer = &eventmodels.AssetsEventContent{}
 	_ Eventer = &eventmodels.InviteEventContent{}
 	_ Eventer = &eventmodels.DiceEventContent{}
+	_ Eventer = &eventmodels.TurntableEventContent{}
 	_ Eventer = &eventmodels.JoinChannelEventContent{}
 	_ Eventer = &eventmodels.FollowEventContent{}
 	_ Eventer = &eventmodels.TaskFinishEventContent{}
@@ -47,6 +48,7 @@ func init() {
 	instance.AddEvent(new(eventmodels.AssetsEventContent))
 	instance.AddEvent(new(eventmodels.InviteEventContent))
 	instance.AddEvent(new(eventmodels.DiceEventContent))
+	instance.AddEvent(new(eventmodels.TurntableEventContent))
 	instance.AddEvent(new(eventmodels.JoinChannelEventContent))
 	instance.AddEvent(new(eventmodels.FollowEventContent))
 	instance.AddEvent(new(eventmodels.TaskFinishEventContent))

game/game_cluster/nodes/logstash/module/handlelog/actor_handle_log.go

@@ -2,7 +2,7 @@
  * @Author: Alvin Alvin@qq.com
  * @Date: 2024-09-24 18:54:19
  * @LastEditors: Alvin Alvin@qq.com
- * @LastEditTime: 2024-09-26 11:10:58
+ * @LastEditTime: 2024-09-27 11:02:04
  * @FilePath: \server\game\game_cluster\nodes\logstash\module\handlelog\actor_handle_log.go
  * @Description:
  * 处理其他服务发送的埋点日志
@@ -161,6 +161,20 @@ func (p *HandleLogObject) handlelogContent(req *param.HandleLogReq, e event.Even
 			return code.Error
 		}
 
+	case *eventmodels.TurntableEventContent:
+		content := &eventmodels.TurntableEventContent{}
+		err := json.Unmarshal([]byte(req.JsonContent), &content)
+		if err != nil {
+			mhayaLogger.Warnf("handlelog TurntableEventContent Unmarshal err:%v", err)
+			return code.Error
+		}
+
+		err = mdb.LogstashDB.Create(content).Error
+		if err != nil {
+			mhayaLogger.Warnf("handlelog LogstashDB Create TurntableEventContent err:%v", err)
+			return code.Error
+		}
+
 	case *eventmodels.JoinChannelEventContent:
 		content := &eventmodels.JoinChannelEventContent{}
 		err := json.Unmarshal([]byte(req.JsonContent), &content)