2020-12-21 16:18:08 +08:00
|
|
|
package utils
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
"log"
|
|
|
|
|
"regexp"
|
|
|
|
|
"strings"
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
const (
|
|
|
|
|
EndTag = "NNNN"
|
|
|
|
|
Expression = "(?s)ZCZC.*NNNN"
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
var buffer []byte
|
|
|
|
|
|
|
|
|
|
func Append(data []byte) {
|
|
|
|
|
buffer = append(buffer, data...)
|
|
|
|
|
if buffer[len(buffer)-1] == '\r' {
|
|
|
|
|
buffer = append(buffer, '\n')
|
|
|
|
|
}
|
|
|
|
|
check()
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func check() {
|
|
|
|
|
teleString := string(buffer)
|
|
|
|
|
if strings.Index(teleString, EndTag) > 0 {
|
|
|
|
|
exp, _ := regexp.Compile(Expression)
|
|
|
|
|
telegram := exp.FindString(string(buffer))
|
|
|
|
|
|
|
|
|
|
if len(telegram) > 0 {
|
|
|
|
|
log.Println("telegram : ", telegram)
|
|
|
|
|
buffer = nil
|
2020-12-21 17:59:37 +08:00
|
|
|
InsertTelegram(telegram)
|
2020-12-21 16:18:08 +08:00
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|