From 9b916b9092aabc1f9ef52f532cb836845abb02af Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=86=B7=E5=86=B7?= Date: Fri, 11 Oct 2019 11:15:31 +0800 Subject: [PATCH] =?UTF-8?q?:sparkles:=20#654=20quartz=20=E9=85=8D=E7=BD=AE?= =?UTF-8?q?=E4=BD=BF=E7=94=A8Rest=20=E8=B0=83=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pigx/daemon/quartz/util/RestTaskInvok.java | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/pigx-visual/pigx-daemon-quartz/src/main/java/com/pig4cloud/pigx/daemon/quartz/util/RestTaskInvok.java b/pigx-visual/pigx-daemon-quartz/src/main/java/com/pig4cloud/pigx/daemon/quartz/util/RestTaskInvok.java index 296a615a1..6b1b4cf4f 100644 --- a/pigx-visual/pigx-daemon-quartz/src/main/java/com/pig4cloud/pigx/daemon/quartz/util/RestTaskInvok.java +++ b/pigx-visual/pigx-daemon-quartz/src/main/java/com/pig4cloud/pigx/daemon/quartz/util/RestTaskInvok.java @@ -17,14 +17,12 @@ package com.pig4cloud.pigx.daemon.quartz.util; -import com.pig4cloud.pigx.common.core.constant.CommonConstants; -import com.pig4cloud.pigx.common.core.util.R; +import cn.hutool.http.HttpUtil; import com.pig4cloud.pigx.daemon.quartz.entity.SysJob; import com.pig4cloud.pigx.daemon.quartz.exception.TaskException; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; -import org.springframework.web.client.RestTemplate; /** * 定时任务rest反射实现 @@ -32,16 +30,16 @@ import org.springframework.web.client.RestTemplate; * @author 郑健楠 */ @Slf4j -@Component("restTaskInvok") @AllArgsConstructor +@Component("restTaskInvok") public class RestTaskInvok implements ITaskInvok { - private RestTemplate restTemplate; - @Override public void invokMethod(SysJob sysJob) throws TaskException { - R r = restTemplate.getForObject(sysJob.getExecutePath(), R.class); - if (CommonConstants.FAIL == r.getCode()) { + try { + HttpUtil.createGet(sysJob.getExecutePath()) + .execute(); + } catch (Exception e) { log.error("定时任务restTaskInvok异常,执行任务：{}", sysJob.getExecutePath()); throw new TaskException("定时任务restTaskInvok业务执行失败,任务：" + sysJob.getExecutePath()); }