feat: add log component

zhangqijia
1 parent c1d56a47
Showing 6 changed files with 91 additions and 1 deletions Show diff stats
cmd/gameserver/service/agent.go
common/components/icompontents.go
docker/restart.sh
models/RoleLog.go
models/role.go
models/schema.go
@@ -131,11 +131,16 @@ func (c *Agent) OnMessage(msg components.IMessage) error {
 		return c.Send(-101, msg.GetHeader().GetMsgID(), nil, msg.GetHeader().GetPreserve())
 	}
  
+	c.Role.StartActionUnicode()
+
 	// 调用协议号对应的逻辑函数
 	f := method.(func(role *models.RoleModel, msg components.IMessage) (int32, interface{}))
 	errCode, protoMsg := f(c.Role, msg)
 	logger.Debug("rsp errcode: %d, protocode: %d", errCode, msg.GetHeader().GetMsgID())
-	return c.SendMsg(errCode, msg.GetHeader().GetMsgID(), protoMsg, msg.GetHeader().GetPreserve())
+	err := c.SendMsg(errCode, msg.GetHeader().GetMsgID(), protoMsg, msg.GetHeader().GetPreserve())
+
+	c.Role.EndActionUnicode()
+	return err
 }
  
 func (c *Agent) OnTimer() {
@@ -161,6 +161,7 @@ type (
 		Update()
  
 		SetProperty(key string, val interface{})
+		GetProperty(key string) interface{}
 		SetProperties(properties map[string]interface{})
 		IncrProperty(key string, val int64) int64
 		ParseFields(message protoreflect.Message, properties map[string]interface{}) []int32
@@ -5,3 +5,5 @@
 /usr/local/bin/docker-compose -f /Users/zhaolu/Documents/pro2d/docker-compose-service.yml up -d
 /usr/local/bin/docker ps -a
 /usr/local/bin/docker rmi $(/usr/local/bin/docker images -f "dangling=true" -q)
+
+docker rmi $(docker images -f "dangling=true" -q)
 \ No newline at end of file
 package models
+
+import (
+	"encoding/json"
+	"fmt"
+	"pro2d/common"
+	"pro2d/common/logger"
+	"sync/atomic"
+)
+
+var LogType = map[string]string{
+	"in_item":   "common",
+	"out_item":  "common",
+	"in_hero":   "common",
+	"out_hero":  "common",
+	"in_equip":  "common",
+	"out_equip": "common",
+
+	"role_action": "common",
+}
+
+var commonRoleField = []string{
+	"id",
+	"uid",
+	"name",
+	"device",
+	"level",
+}
+
+func (m *RoleModel) MyLog(logType string, content map[string]interface{}) {
+	_, ok := LogType[logType]
+	if !ok {
+		logger.Error("LOG ERROR: new logType [%s] need Add Maping.", logType)
+		return
+	}
+
+	doc := make(map[string]interface{})
+	for _, field := range commonRoleField {
+		if content[field] != nil {
+			logger.Error("LOG ERROR: logType [%s] had field [%s] overwrite default.", logType, field)
+		}
+
+		v := m.GetProperty(field)
+		if v != nil {
+			doc[field] = v
+		}
+	}
+	content["ucode"] = m.GetActionUnicode()
+	for field, value := range content {
+		doc[field] = value
+	}
+	doc["@type"] = logType
+	j, err := json.Marshal(doc)
+	if err != nil {
+		logger.Error("LOG ERROR: logType [%s]  json.Marshal", logType)
+		return
+	}
+	logger.Debug(j)
+}
+
+func (m *RoleModel) StartActionUnicode() {
+	uniqueCount := atomic.AddInt64(&m.uniqueCount, 1)
+	m.actionUcode = fmt.Sprintf("%s-%d-%d", m.Data.Id, common.Timex(), uniqueCount)
+}
+
+func (m *RoleModel) EndActionUnicode() {
+	m.actionUcode = ""
+}
+
+func (m *RoleModel) GetActionUnicode() string {
+	return m.actionUcode
+}
@@ -21,6 +21,9 @@ type RoleModel struct {
 	Items      common.IMapStringNum //背包
  
 	lastSaveTs int64
+
+	uniqueCount int64
+	actionUcode string
 }
  
 func RoleExistByUid(uid string) *RoleModel {
@@ -171,6 +171,14 @@ func (s *Schema) SetProperty(key string, val interface{}) {
 	s.cacheFields[strings.ToLower(key)] = val
 }
  
+func (s *Schema) GetProperty(key string) interface{} {
+	idx, ok := s.reflectIndex[strings.ToLower(key)]
+	if !ok {
+		return nil
+	}
+	return s.reflectValue.Field(idx).Interface()
+}
+
 //更新内存，并把字段缓存
 func (s *Schema) SetProperties(properties map[string]interface{}) {
 	for key, val := range properties {