pkg/timerx
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

上报执行情况

Browse Source
This commit is contained in:
Yun
2025-10-04 20:48:08 +08:00
parent 14eb90bf7d
commit 62e0d03c9e
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cluster.go
+1 -1
View File
@@ -514,7 +514,7 @@ func (l *Cluster) processTask(taskId string) {
l.logger.Infof(ctx, "doTask timer begin taskId:%s", taskId) 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{ l.redis.ZAdd(ctx, l.executeInfoKey, &redis.Z{
Score: float64(begin.UnixMilli()), Score: float64(begin.UnixMilli()),
Member: executeVal, Member: executeVal,
once.go
+1 -1
View File
@@ -456,7 +456,7 @@ func (l *Once) processTask(key string) {
defer lock.Unlock() 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{ l.redis.ZAdd(ctx, l.executeInfoKey, &redis.Z{
Score: float64(begin.UnixMilli()), Score: float64(begin.UnixMilli()),
Member: executeVal, Member: executeVal,