diff --git a/pav-websocket/src/main/java/com/palnet/comn/utils/DateUtils.java b/pav-websocket/src/main/java/com/palnet/comn/utils/DateUtils.java index 5b5082c..23c12fe 100644 --- a/pav-websocket/src/main/java/com/palnet/comn/utils/DateUtils.java +++ b/pav-websocket/src/main/java/com/palnet/comn/utils/DateUtils.java @@ -111,6 +111,14 @@ public class DateUtils { } + public static long diffSecond(Instant firstDate, Instant secondDate) { + + long diffDate = secondDate.getEpochSecond() - firstDate.getEpochSecond(); + + return diffDate; + + } + public static long diffMinute(Instant firstDate , Instant secondDate) { long diffDate = secondDate.getEpochSecond() - firstDate.getEpochSecond(); diff --git a/pav-websocket/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java b/pav-websocket/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java index 5195725..2c21875 100644 --- a/pav-websocket/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java +++ b/pav-websocket/src/main/java/com/palnet/process/scheduler/GpHistoryScheduler.java @@ -32,7 +32,7 @@ public class GpHistoryScheduler { if(Objects.nonNull(allHistory)) { allHistory.forEach((k, v) -> { Instant serverRcvDt = DateUtils.stringToDatetime(v.getServerRcvDt()); - long diffSecond = DateUtils.diffMinute(serverRcvDt, Instant.now()); + long diffSecond = DateUtils.diffSecond(serverRcvDt, Instant.now()); if(diffSecond > timeLimit) { gpHistoryShareContext.removeHistory(k);