diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/task/ExtractBizDataToOpenData.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/task/ExtractBizDataToOpenData.java index ebcd5aa27d..bed579f907 100644 --- a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/task/ExtractBizDataToOpenData.java +++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/task/ExtractBizDataToOpenData.java @@ -48,10 +48,11 @@ public class ExtractBizDataToOpenData { do { //StrConstant.PY_ROOT_AGENCY patrolCountResult = griderOnlineNumService.insertData(StrConstant.PY_ROOT_AGENCY); - if (!patrolCountResult) { + //如果成功 则跳出循环 + if (patrolCountResult) { break; } - //如果 重试次数为1了 就让歇个 5分钟 + //如果失败 待重试次数剩为1时 就让歇个 5分钟 if (retryTime == 1) { Thread.sleep(NumConstant.FIVE * NumConstant.SIXTY * NumConstant.ONE_THOUSAND); } @@ -59,7 +60,8 @@ public class ExtractBizDataToOpenData { if (!patrolCountResult) { log.error("插入网格员在线人数失败,请检查原因,时间:{}", currentTime); } - + //休眠10s + Thread.sleep( NumConstant.TEN * NumConstant.ONE_THOUSAND); } catch (Exception e) { log.warn("tryLock method extractGridMemberPatrollingCount fail"); } finally {