xjm
/
ssjygl-xsct-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

处理CheckExceptionDataJob异常判断

dev
lisai17@sina.com 2021-05-21 23:07:10 +08:00
parent 86ac3c6f0f
commit 3bd78b9ae8
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/jobs/CheckExceptionDataJob.java
View File

@ -27,12 +27,16 @@ public class CheckExceptionDataJob implements Job {
long nowst = System.currentTimeMillis();
for (Map.Entry<Integer, Record> 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() + " 条数据等待处理。";
}