From 1209ca3fd4bae60b6d58c356f91f5d66e271f201 Mon Sep 17 00:00:00 2001 From: fangcheng Date: Thu, 4 May 2017 17:52:29 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=9C=E7=A8=8B=E6=97=A0=E6=B3=95=E8=AE=BF?= =?UTF-8?q?=E9=97=AE=E7=AD=89=E6=83=85=E5=86=B5=EF=BC=8C=E4=B8=B4=E6=97=B6?= =?UTF-8?q?=E9=98=9F=E5=88=97=E5=8F=8D=E5=8E=8B=E5=9B=9E=E9=98=9F=E5=88=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../center.manager/src/main/java/com/lyms/cm/job/SyncFixJob.java | 3 ++- .../center.manager/src/main/java/com/lyms/cm/job/SyncTmpJob.java | 8 ++++++-- 2 files changed, 8 insertions(+), 3 deletions(-) diff --git a/parent/center.manager/src/main/java/com/lyms/cm/job/SyncFixJob.java b/parent/center.manager/src/main/java/com/lyms/cm/job/SyncFixJob.java index d011a74..6ad5e7c 100644 --- a/parent/center.manager/src/main/java/com/lyms/cm/job/SyncFixJob.java +++ b/parent/center.manager/src/main/java/com/lyms/cm/job/SyncFixJob.java @@ -14,6 +14,7 @@ import org.springframework.data.redis.core.RedisTemplate; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.lyms.base.common.entity.organ.OrganGroup; import com.lyms.base.common.service.organ.OrganGroupService; +import com.lyms.base.common.service.sys.impl.SyncDataBasicServiceImpl; import com.lyms.sync.ParamsAdpter; import com.lyms.sync.SyncCallback; import com.lyms.sync.SyncCenter; @@ -46,7 +47,7 @@ public class SyncFixJob { private static List pullUrlList = null; - private static String remoteClazz = "com.lyms.hospital.service.sys.impl.SyncDataBasicServiceImpl"; + private static String remoteClazz = SyncDataBasicServiceImpl.class.getName(); private static String remoteMethod = "selectOne"; private final AtomicBoolean reset = new AtomicBoolean(false); diff --git a/parent/center.manager/src/main/java/com/lyms/cm/job/SyncTmpJob.java b/parent/center.manager/src/main/java/com/lyms/cm/job/SyncTmpJob.java index 3de293a..0d68c03 100644 --- a/parent/center.manager/src/main/java/com/lyms/cm/job/SyncTmpJob.java +++ b/parent/center.manager/src/main/java/com/lyms/cm/job/SyncTmpJob.java @@ -46,10 +46,14 @@ public class SyncTmpJob { if (model != null) { // 任务发送执行 String result = HttpUtils.REMOTE.post(model); + if(result == null){//远程无法访问等情况 + work.backPressure(); + return; + } model = JsonUtils.jsonToBean(result, ChannelData.class); if (model != null && model.getAck()) { - work.backPressure(); - } + work.backPressure(); + } } } } -- 1.8.3.1