From e58137c31916370d245104230610546d3052500a Mon Sep 17 00:00:00 2001 From: gaoyutao Date: Mon, 29 Sep 2025 20:47:26 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E8=84=9A=E6=9C=AC=E6=89=A7?= =?UTF-8?q?=E8=A1=8C=E7=AD=96=E7=95=A5=E4=B8=8A=E6=8A=A5=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../agent/client/scheduler/task/SpecificTimeTaskService.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/tongran/agent/client/scheduler/task/SpecificTimeTaskService.java b/src/main/java/com/tongran/agent/client/scheduler/task/SpecificTimeTaskService.java index 47622b5..4edad56 100644 --- a/src/main/java/com/tongran/agent/client/scheduler/task/SpecificTimeTaskService.java +++ b/src/main/java/com/tongran/agent/client/scheduler/task/SpecificTimeTaskService.java @@ -10,6 +10,7 @@ import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.io.IOException; +import java.time.Instant; import java.time.LocalDateTime; import java.util.Arrays; import java.util.List; @@ -101,7 +102,8 @@ public class SpecificTimeTaskService { json.put("resCode",1); json.put("resMsg", ""); json.put("result", jsonObject.toJSONString()); - Message message = Message.builder().clientId(request.getClientId()).dataType(request.getDataType()).data(jsonObject.toJSONString()).build(); + json.put("timestamp", Instant.now().getEpochSecond()); + Message message = Message.builder().clientId(request.getClientId()).dataType(request.getDataType()).data(json.toJSONString()).build(); if (Objects.nonNull(sessionManager.getSessionById(request.getClientId()))) { System.out.println("发送执行结果: " + json.toJSONString()); // 注意：toJSONString() sessionManager.writeAndFlush(sessionManager.getSessionById(request.getClientId()).getChannel(), message);