From 62e0d03c9ee56c16c6645a96cdefc6e5649af2e7 Mon Sep 17 00:00:00 2001 From: Yun Date: Sat, 4 Oct 2025 20:48:08 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E6=8A=A5=E6=89=A7=E8=A1=8C=E6=83=85?= =?UTF-8?q?=E5=86=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cluster.go | 2 +- once.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/cluster.go b/cluster.go index 8863490..39af518 100644 --- a/cluster.go +++ b/cluster.go @@ -514,7 +514,7 @@ func (l *Cluster) processTask(taskId string) { l.logger.Infof(ctx, "doTask timer begin taskId:%s", taskId) // 上报执行情况 - executeVal := fmt.Sprintf("%s|%s|%s|%s", taskId, l.instanceId, u.String(), begin.Format(time.RFC3339Nano)) + executeVal := fmt.Sprintf("tid:%s|insId:%s|uuid:%s|time:%s", taskId, l.instanceId, u.String(), begin.Format(time.RFC3339Nano)) l.redis.ZAdd(ctx, l.executeInfoKey, &redis.Z{ Score: float64(begin.UnixMilli()), Member: executeVal, diff --git a/once.go b/once.go index 5ca74fa..a1ec45d 100644 --- a/once.go +++ b/once.go @@ -456,7 +456,7 @@ func (l *Once) processTask(key string) { defer lock.Unlock() // 上报执行情况 - executeVal := fmt.Sprintf("%s|%s|%s|%s", key, l.instanceId, u.String(), begin.Format(time.RFC3339Nano)) + executeVal := fmt.Sprintf("tid:%s|insId:%s|uuid:%s|time:%s", key, l.instanceId, u.String(), begin.Format(time.RFC3339Nano)) l.redis.ZAdd(ctx, l.executeInfoKey, &redis.Z{ Score: float64(begin.UnixMilli()), Member: executeVal,