fix: 补充 heartbeat 接口更新 runer.last_heartbeat_timestamp value

1 files changed, 5 insertions, 0 deletions

diff --git a/src/main/java/net/geedge/asw/module/runner/controller/RunnerController.java b/src/main/java/net/geedge/asw/module/runner/controller/RunnerController.java
index d9d119f..e7499c8 100644
--- a/src/main/java/net/geedge/asw/module/runner/controller/RunnerController.java
+++ b/src/main/java/net/geedge/asw/module/runner/controller/RunnerController.java
@@ -97,6 +97,11 @@ public class RunnerController {
             return;
         }
 
+        // update last_heartbeat_timestamp
+        runnerService.update(new LambdaUpdateWrapper<RunnerEntity>()
+                .set(RunnerEntity::getLastHeartbeatTimestamp, System.currentTimeMillis())
+                .eq(RunnerEntity::getId, runner.getId()));
+
         // findjob by platform
         String platform = platformMap.entrySet().stream().filter(entry -> entry.getValue() > 0).findFirst().map(entry -> entry.getKey()).orElseGet(null);
         JobEntity job = jobService.assignPendingJob(runner.getId(), platform);