fix append

This commit is contained in:
zhiqiang feng
2020-12-29 11:11:13 +08:00
parent 2011a10464
commit bb736bba85
+6 -8
View File
@@ -12,28 +12,26 @@ const (
Expression = "(?s)ZCZC.*NNNN" Expression = "(?s)ZCZC.*NNNN"
) )
var buffer []byte var buffer string
var RawLog *rotatelogs.RotateLogs var RawLog *rotatelogs.RotateLogs
func Append(data string) bool { func Append(data string) bool {
buffer = append(buffer, data...) buffer = buffer + data
if buffer[len(buffer)-1] == '\r' {
buffer = append(buffer, '\n')
}
return check() return check()
} }
func check() bool { func check() bool {
teleString := string(buffer) teleString := buffer
if strings.Index(teleString, EndTag) > 0 { if strings.Index(teleString, EndTag) > 0 {
exp, _ := regexp.Compile(Expression) exp, _ := regexp.Compile(Expression)
telegram := exp.FindString(string(buffer)) telegram := exp.FindString(teleString)
if len(telegram) > 0 { if len(telegram) > 0 {
// Log.Info("telegram ", zap.String("text", telegram)) // Log.Info("telegram ", zap.String("text", telegram))
telegram = removeEmpty(telegram) + "\n\n" telegram = removeEmpty(telegram) + "\n\n"
telegram += "\n"
RawLog.Write([]byte(telegram)) RawLog.Write([]byte(telegram))
buffer = nil buffer = ""
InsertTelegram(telegram) InsertTelegram(telegram)
return true return true
} }