128 lines
2.6 KiB
Go
128 lines
2.6 KiB
Go
package f5
|
|
|
|
import (
|
|
"q5"
|
|
"os"
|
|
"sync"
|
|
"fmt"
|
|
"time"
|
|
)
|
|
|
|
type tgLogMsgNode struct {
|
|
gameId int32
|
|
jsonStr string
|
|
next *tgLogMsgNode
|
|
}
|
|
|
|
type tgLog struct {
|
|
isPolyLog bool
|
|
topNode *tgLogMsgNode
|
|
botNode *tgLogMsgNode
|
|
msgMutex sync.Mutex
|
|
chGoSaveExit chan int
|
|
}
|
|
|
|
func (this *tgLog) init() {
|
|
this.chGoSaveExit = make(chan int)
|
|
go this.goSaveToFile()
|
|
}
|
|
|
|
func (this *tgLog) unInit() {
|
|
this.chGoSaveExit <- 1
|
|
}
|
|
|
|
func (this *tgLog) SetPolyLog(isPolyLog bool) {
|
|
this.isPolyLog = isPolyLog
|
|
}
|
|
|
|
func (this *tgLog) AddTrackLog(
|
|
gameId int32,
|
|
accountId string,
|
|
remoteAddr string,
|
|
logClass1 int32,
|
|
logClass2 int32,
|
|
prop map[string]string) {
|
|
eventName := fmt.Sprintf("event_%d_%d", logClass1, logClass2)
|
|
this.AddTrackLogEx(gameId, accountId, remoteAddr, eventName, prop)
|
|
}
|
|
|
|
func (this *tgLog) AddTrackLogEx(
|
|
gameId int32,
|
|
accountId string,
|
|
remoteAddr string,
|
|
eventName string,
|
|
prop map[string]string) {
|
|
logObj := struct {
|
|
AccountId string `json:"#account_id"`
|
|
Type string `json:"#type""`
|
|
Time string `json:"#time"`
|
|
EventName string `json:"#event_name""`
|
|
Ip string `json:"#ip""`
|
|
Properties map[string]string `json:"properties"`
|
|
} {
|
|
AccountId: accountId,
|
|
Type: "track",
|
|
Time: q5.FormatUnixDateTime(_app.GetNowSeconds(), _app.GetLocation()),
|
|
EventName: eventName,
|
|
Ip: remoteAddr,
|
|
Properties: prop,
|
|
}
|
|
p := new(tgLogMsgNode)
|
|
p.gameId = gameId
|
|
p.jsonStr = q5.EncodeJson(logObj)
|
|
this.msgMutex.Lock()
|
|
defer this.msgMutex.Unlock()
|
|
if this.botNode != nil {
|
|
this.botNode.next = p
|
|
this.botNode = p
|
|
} else {
|
|
this.topNode = p
|
|
this.botNode = p
|
|
}
|
|
}
|
|
|
|
func (this *tgLog) goSaveToFile() {
|
|
var workNode *tgLogMsgNode
|
|
for {
|
|
select {
|
|
case <-this.chGoSaveExit:
|
|
return
|
|
case <-time.After(time.Millisecond * 1000 * 10):
|
|
}
|
|
this.msgMutex.Lock()
|
|
workNode = this.topNode
|
|
this.topNode = nil
|
|
this.botNode = nil
|
|
this.msgMutex.Unlock()
|
|
if workNode != nil {
|
|
for workNode != nil {
|
|
f := this.getLogFile(workNode.gameId)
|
|
if f != nil {
|
|
f.Write([]byte(workNode.jsonStr + "\n"))
|
|
f.Close()
|
|
}
|
|
workNode = workNode.next
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
func (this *tgLog) getLogFile(gameId int32) *os.File {
|
|
fileName := fmt.Sprintf(TGLOG_FILENAME,
|
|
os.Getpid(),
|
|
q5.FormatUnixDateEx(_app.GetNowSeconds(), _app.GetLocation()))
|
|
logDir := ""
|
|
if this.isPolyLog {
|
|
logDir = fmt.Sprintf(POLY_TGLOG_ROOT, _app.GetPkgName(), gameId)
|
|
} else {
|
|
logDir = fmt.Sprintf(TGLOG_ROOT, _app.GetPkgName())
|
|
}
|
|
q5.ForceCreateDir(logDir)
|
|
if f, err := os.OpenFile(logDir + fileName, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0666); err == nil {
|
|
return f
|
|
} else {
|
|
_sysLog.Warning("tgLog.goSaveToFile err:%s", err)
|
|
return nil
|
|
}
|
|
}
|