xcron

go.mod

@@ -35,7 +35,7 @@ require (
 	github.com/swaggo/swag v1.8.12
 	github.com/uptrace/opentelemetry-go-extra/otelgorm v0.2.3
 	github.com/vmihailenco/msgpack v4.0.4+incompatible
-	gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.2
+	gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.3
 	go.opentelemetry.io/contrib v1.24.0
 	go.opentelemetry.io/otel v1.24.0
 	go.opentelemetry.io/otel/exporters/jaeger v1.17.0

go.sum

@@ -608,8 +608,8 @@ github.com/yuin/gopher-lua v0.0.0-20210529063254-f4c35e4016d9 h1:k/gmLsJDWwWqbLC
 github.com/yuin/gopher-lua v0.0.0-20210529063254-f4c35e4016d9/go.mod h1:E1AXubJBdNmFERAOucpDIxNzeGfLzg0mYh+UfMWdChA=
 github.com/yusufpapurcu/wmi v1.2.3 h1:E1ctvB7uKFMOJw3fdOW32DwGE9I7t++CRUEMKvFoFiw=
 github.com/yusufpapurcu/wmi v1.2.3/go.mod h1:SBZ9tNy3G9/m5Oi98Zks0QjeHVDvuK0qfxQmPyzfmi0=
-gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.2 h1:VjZhGdhX/Dr0gAkdmRBHkoG6kcweEm3T76SSjpMT/pE=
-gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.2/go.mod h1:aa6yOw4iYog1VGo7k27pdbGzEuXy4jgA14pM4FGMTVE=
+gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.3 h1:xjmaDtDja2iDrQJgWpaiEI/oKwXbVCOY43tgSqFTqIU=
+gitlab.wanzhuangkj.com/tush/xxl-job-executor-go v1.0.3/go.mod h1:aa6yOw4iYog1VGo7k27pdbGzEuXy4jgA14pM4FGMTVE=
 go.opencensus.io v0.21.0/go.mod h1:mSImk1erAIZhrmZN+AvHh14ztQfjbGwt4TtuofqLduU=
 go.opencensus.io v0.22.0/go.mod h1:+kGneAE2xo2IficOXnaByMWTGM9T73dGwxeWcUqIpI8=
 go.opencensus.io v0.22.2/go.mod h1:yxeiOL68Rb0Xd1ddK5vPZ/oVn4vY4Ynel7k9FzqtOIw=

xcron/xcron.go

@@ -2,6 +2,7 @@ package xcron
 
 import (
 	"context"
+	"fmt"
 
 	"github.com/gin-gonic/gin"
 	"github.com/jinzhu/copier"
@@ -123,18 +124,18 @@ func xxlJob(r *gin.Engine) {
 type log struct{}
 
 func (l *log) Info(format string, a ...interface{}) {
-	logger.Infof(format, a...)
+	logger.Infof("[xxl-executor]%s", fmt.Sprintf(format, a...))
 }
 
 func (l *log) Error(format string, a ...interface{}) {
-	logger.Errorf(format, a...)
+	logger.Errorf("[xxl-executor]%s", fmt.Sprintf(format, a...))
 }
 
 func customMiddleware(tf xxl.TaskFunc) xxl.TaskFunc {
 	return func(cxt context.Context, req *xxl.RunReq) string {
-		logger.Info("[xxl][middleware]=====req=====", logger.Any("req", req))
+		logger.Info("[xxl-executor][middleware]=====req=====", logger.Any("req", req))
 		res := tf(cxt, req)
-		logger.Info("[xxl][middleware]=====rsp=====", logger.Any("res", res))
+		logger.Info("[xxl-executor][middleware]=====rsp=====", logger.Any("res", res))
 		return res
 	}
 }