From 3bd78b9ae8bbf7da47428ab3413045639abcfd9c Mon Sep 17 00:00:00 2001 From: "lisai17@sina.com" Date: Fri, 21 May 2021 23:07:10 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=84=E7=90=86CheckExceptionDataJob?= =?UTF-8?q?=E5=BC=82=E5=B8=B8=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ssjygl/jobs/CheckExceptionDataJob.java | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/jobs/CheckExceptionDataJob.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/jobs/CheckExceptionDataJob.java index f45ef5d..a55b00c 100644 --- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/jobs/CheckExceptionDataJob.java +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/jobs/CheckExceptionDataJob.java @@ -27,12 +27,16 @@ public class CheckExceptionDataJob implements Job { long nowst = System.currentTimeMillis(); for (Map.Entry entry : SvrCacheData.SUP_HEARTBEAT.entrySet()) { - Record c = entry.getValue(); - long st = c.getLong("tm"); + Record c = entry.getValue(); + if (c.get("tm") != null) { + long st = c.getLong("tm"); - // 五分钟以内的才进行判断，超过5分钟的，就认为是离线了 - // 离线的砂站会产生正常的未同步数据 - if (nowst - st < Const.SUP_OFFLINE_TIME) { + // 五分钟以内的才进行判断，超过5分钟的，就认为是离线了 + // 离线的砂站会产生正常的未同步数据 + if (nowst - st < Const.SUP_OFFLINE_TIME) { + onlineids.add(entry.getKey().toString()); + } + } else { onlineids.add(entry.getKey().toString()); } } @@ -62,7 +66,7 @@ public class CheckExceptionDataJob implements Job { log.error("没有找到在线砂站信息。"); } - if(SyncTaskService.me.getTaskQueueSize() > 10){ + if (SyncTaskService.me.getTaskQueueSize() > 10) { content += "task queue 还有 " + SyncTaskService.me.getTaskQueueSize() + " 条数据等待处理。"; }