update 新增分享事件

game/game_cluster/internal/mdb/component.go

@@ -89,4 +89,5 @@ func LogstashMigrateTables() {
 	LogstashDB.AutoMigrate(&eventmodels.FollowEventContent{})
 	LogstashDB.AutoMigrate(&eventmodels.TaskFinishEventContent{})
 	LogstashDB.AutoMigrate(&eventmodels.BackendOperationEventContent{})
+	LogstashDB.AutoMigrate(&eventmodels.ShareEventContent{})
 }

game/game_cluster/internal/mdb/eventmodels/shareEvent.go

@@ -0,0 +1,12 @@
+package eventmodels
+
+// 分享事件
+type ShareEventContent struct {
+	UserBasic
+	EventBasic
+	ShareType int `json:"share_type"` // 分享事件的类型
+}
+
+func (e *ShareEventContent) EventName() string {
+	return "Share"
+}

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

@@ -33,6 +33,7 @@ var (
 	_ Eventer = &eventmodels.FollowEventContent{}
 	_ Eventer = &eventmodels.TaskFinishEventContent{}
 	_ Eventer = &eventmodels.BackendOperationEventContent{}
+	_ Eventer = &eventmodels.ShareEventContent{}
 )
 
 func init() {
@@ -55,6 +56,7 @@ func init() {
 	instance.AddEvent(new(eventmodels.FollowEventContent))
 	instance.AddEvent(new(eventmodels.TaskFinishEventContent))
 	instance.AddEvent(new(eventmodels.BackendOperationEventContent))
+	instance.AddEvent(new(eventmodels.ShareEventContent))
 }
 
 func GetEventIdMap() *EventManage {

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-10-01 15:25:38
+ * @LastEditTime: 2024-10-03 10:42:25
  * @FilePath: \server\game\game_cluster\nodes\logstash\module\handlelog\actor_handle_log.go
  * @Description:
  * 处理其他服务发送的埋点日志
@@ -244,6 +244,21 @@ func (p *HandleLogObject) handlelogContent(req *param.HandleLogReq, e event.Even
 			mhayaLogger.Warnf("handlelog LogstashDB Create BackendOperationEventContent err:%v", err)
 			return code.Error
 		}
+
+	case *eventmodels.ShareEventContent:
+		content := &eventmodels.ShareEventContent{}
+		err := json.Unmarshal([]byte(req.JsonContent), &content)
+		if err != nil {
+			mhayaLogger.Warnf("handlelog ShareEventContent Unmarshal err:%v", err)
+			return code.Error
+		}
+
+		err = mdb.LogstashDB.Create(content).Error
+		if err != nil {
+			mhayaLogger.Warnf("handlelog LogstashDB Create ShareEventContent err:%v", err)
+			return code.Error
+		}
+
 	}
 
 	return code.OK