Browse Source

上报网格员数据

dev
jianjun 3 years ago
parent
commit
b7993edeef
  1. 8
      epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/task/ExtractBizDataToOpenData.java

8
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 { do {
//StrConstant.PY_ROOT_AGENCY //StrConstant.PY_ROOT_AGENCY
patrolCountResult = griderOnlineNumService.insertData(StrConstant.PY_ROOT_AGENCY); patrolCountResult = griderOnlineNumService.insertData(StrConstant.PY_ROOT_AGENCY);
if (!patrolCountResult) { //如果成功 则跳出循环
if (patrolCountResult) {
break; break;
} }
//如果 重试次数为1了 就让歇个 5分钟 //如果失败 待重试次数剩为1时 就让歇个 5分钟
if (retryTime == 1) { if (retryTime == 1) {
Thread.sleep(NumConstant.FIVE * NumConstant.SIXTY * NumConstant.ONE_THOUSAND); Thread.sleep(NumConstant.FIVE * NumConstant.SIXTY * NumConstant.ONE_THOUSAND);
} }
@ -59,7 +60,8 @@ public class ExtractBizDataToOpenData {
if (!patrolCountResult) { if (!patrolCountResult) {
log.error("插入网格员在线人数失败,请检查原因,时间:{}", currentTime); log.error("插入网格员在线人数失败,请检查原因,时间:{}", currentTime);
} }
//休眠10s
Thread.sleep( NumConstant.TEN * NumConstant.ONE_THOUSAND);
} catch (Exception e) { } catch (Exception e) {
log.warn("tryLock method extractGridMemberPatrollingCount fail"); log.warn("tryLock method extractGridMemberPatrollingCount fail");
} finally { } finally {

Loading…
Cancel
Save