update 新增用户领取事件

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

@@ -0,0 +1,18 @@
+package eventmodels
+
+import "github.com/mhaya/game/game_cluster/internal/data"
+
+// 用户奖励事件
+type UserRewardEventContent struct {
+	UserBasic
+	EventBasic
+	Source    int               `json:"source"`
+	SourceId  int               `json:"sourceId"`
+	AddReward []data.ItemReward `json:"AddReward"`
+	SubReward []data.ItemReward `json:"SubReward"`
+	Desc      interface{}       `json:"desc"`
+}
+
+func (e *UserRewardEventContent) EventName() string {
+	return "UserReward"
+}

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

@@ -24,6 +24,7 @@ var (
 	_ Eventer = &eventmodels.UserLoginEventContent{}
 	_ Eventer = &eventmodels.UserUpdateInfoEventContent{}
 	_ Eventer = &eventmodels.UserWithdrawEventContent{}
+	_ Eventer = &eventmodels.UserRewardEventContent{}
 	_ Eventer = &eventmodels.AssetsEventContent{}
 	_ Eventer = &eventmodels.InviteEventContent{}
 	_ Eventer = &eventmodels.DiceEventContent{}
@@ -46,6 +47,7 @@ func init() {
 	instance.AddEvent(new(eventmodels.UserLoginEventContent))
 	instance.AddEvent(new(eventmodels.UserUpdateInfoEventContent))
 	instance.AddEvent(new(eventmodels.UserWithdrawEventContent))
+	instance.AddEvent(new(eventmodels.UserRewardEventContent))
 	instance.AddEvent(new(eventmodels.AssetsEventContent))
 	instance.AddEvent(new(eventmodels.InviteEventContent))
 	instance.AddEvent(new(eventmodels.DiceEventContent))

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