fix: 防止并发

Author: cyz-home

type_exception.go

@@ -37,7 +37,8 @@ var ExceptionSplit = "github.com/sirupsen/logrus/"
 
 func (b *Exception) Handler(entry *logrus.Entry) (*entries, []tag) {
 	strStack := entry.Data["stack"].(string)
-	return b.ToSave(strStack, entry.Message)
+
+	return (*b).ToSave(strStack, entry.Message)
 }
 
 func (b *Exception) ToSave(strStack, msg string) (*entries, []tag) {

type_job.go

@@ -23,7 +23,7 @@ type Job struct {
 	Hostname   string      `json:"hostname"`
 }
 
-func (b *Job) Boot() {
+func (j *Job) Boot() {
 	if app2.IsDebug() && app.HasBean("queue") {
 		server := app.GetBean("queue").(*servers.Queue)
 		server.AddMiddleware(func(job constraint.Job, next func(constraint.Job)) {
@@ -45,11 +45,13 @@ func (b *Job) Boot() {
 	}
 }
 
-func (b *Job) BindType() string {
+func (j *Job) BindType() string {
 	return "job"
 }
 
-func (b *Job) Handler(entry *logrus.Entry) (*entries, []tag) {
+func (j *Job) Handler(entry *logrus.Entry) (*entries, []tag) {
+	b := *j
+
 	b.Name = entry.Message
 	b.Data = entry.Data["data"]
 	b.Status = entry.Data["status"].(string)

type_log.go

@@ -14,11 +14,13 @@ type Log struct {
 	Context map[string]interface{} `json:"context"`
 }
 
-func (b *Log) BindType() string {
+func (l *Log) BindType() string {
 	return "log"
 }
 
-func (b *Log) Handler(entry *logrus.Entry) (*entries, []tag) {
+func (l *Log) Handler(entry *logrus.Entry) (*entries, []tag) {
+	b := *l
+
 	if entry.Level <= logrus.ErrorLevel {
 		hasError = true
 		defer func() {

type_query.go

@@ -23,22 +23,24 @@ type Query struct {
 	Hostname   string   `json:"hostname"`
 }
 
-func (b *Query) Init() {
-	b.Hostname, _ = os.Hostname()
+func (q *Query) Init() {
+	q.Hostname, _ = os.Hostname()
 }
 
-func (b *Query) BindType() string {
+func (q *Query) BindType() string {
 	return "query"
 }
 
 // QuerySplit 切割标识, 这个标识以后的代码才是业务的
 var QuerySplit = "/app/entity/"
 
-func (b *Query) Handler(entry *logrus.Entry) (*entries, []tag) {
+func (q *Query) Handler(entry *logrus.Entry) (*entries, []tag) {
 	if strings.Index(entry.Message, "telescope_") != -1 {
 		return nil, nil
 	}
-	b.File = ""
+
+	b := *q
+
 	// 根据模型目录 /app/entity/ 定位业务调用
 	stack := string(debug.Stack())
 	arr := strings.Split(string(stack), "\n")

type_redis.go

@@ -16,14 +16,16 @@ type Redis struct {
 	Hostname   string `json:"hostname"`
 }
 
-func (b *Redis) BindType() string {
+func (r *Redis) BindType() string {
 	return "redis"
 }
 
 // RedisSplit 切割标识, 这个标识以后的代码才是业务的
 var RedisSplit = "github.com/sirupsen/logrus/"
 
-func (b *Redis) Handler(entry *logrus.Entry) (*entries, []tag) {
+func (r *Redis) Handler(entry *logrus.Entry) (*entries, []tag) {
+	b := *r
+
 	file, line := GetStackCallFile(string(debug.Stack()), RedisSplit)
 
 	b.Connection = file + ":" + line

type_request.go

@@ -27,15 +27,17 @@ type Request struct {
 	Hostname         string                 `json:"hostname,omitempty"`
 }
 
-func (b *Request) Init() {
-	b.Hostname, _ = os.Hostname()
+func (req *Request) Init() {
+	req.Hostname, _ = os.Hostname()
 }
 
-func (b *Request) BindType() string {
+func (req *Request) BindType() string {
 	return "request"
 }
 
-func (b *Request) Handler(entry *logrus.Entry) (*entries, []tag) {
+func (req *Request) Handler(entry *logrus.Entry) (*entries, []tag) {
+	b := *req
+
 	b.Payload = make(map[string]interface{})
 
 	uuId := uuid.NewV4().String()

type_schedule.go

@@ -17,11 +17,13 @@ type Schedule struct {
 	Hostname    string      `json:"hostname"`
 }
 
-func (b *Schedule) BindType() string {
+func (s *Schedule) BindType() string {
 	return "schedule"
 }
 
-func (b *Schedule) Handler(entry *logrus.Entry) (*entries, []tag) {
+func (s *Schedule) Handler(entry *logrus.Entry) (*entries, []tag) {
+	b := *s
+
 	b.Command = entry.Message
 	return &entries{
 		Uuid:                 uuid.NewV4().String(),

type_tcp.go

@@ -24,13 +24,15 @@ type Tcp struct {
 	Hostname         string                 `json:"hostname,omitempty"`
 }
 
-func (b *Tcp) BindType() string {
+func (c *Tcp) BindType() string {
 	return "tcp"
 }
 
 // Handler
 // logrus.WithFields(logrus.Fields{"type": "tcp","read": raw,"tags": []string{str}}).Debug(tpc_route)
-func (b *Tcp) Handler(entry *logrus.Entry) (*entries, []tag) {
+func (c *Tcp) Handler(entry *logrus.Entry) (*entries, []tag) {
+	b := *c
+
 	ip, ok := entry.Data["ip"]
 	if ok {
 		b.IpAddress = ip.(string)