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() + " 条数据等待处理。"; }