From 8b733d697351f29cb276ee23755985e8eaff93df Mon Sep 17 00:00:00 2001
From: wangkang <wangkangit@163.com>
Date: Mon, 12 Jun 2017 18:16:12 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=89=8B=E5=8A=A8=E8=A7=A6?=
 =?UTF-8?q?=E5=8F=91=E7=9A=84=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../client/service/SchClientService.java      | 56 +++++++++++++++++++
 1 file changed, 56 insertions(+)
 create mode 100644 udf-starter-scheduler-client/src/main/java/com/egridcloud/udf/scheduler/client/service/SchClientService.java

diff --git a/udf-starter-scheduler-client/src/main/java/com/egridcloud/udf/scheduler/client/service/SchClientService.java b/udf-starter-scheduler-client/src/main/java/com/egridcloud/udf/scheduler/client/service/SchClientService.java
new file mode 100644
index 0000000..e3988e8
--- /dev/null
+++ b/udf-starter-scheduler-client/src/main/java/com/egridcloud/udf/scheduler/client/service/SchClientService.java
@@ -0,0 +1,56 @@
+/**
+ * SchClientService.java
+ * Created at 2017-06-12
+ * Created by Administrator
+ * Copyright (C) 2016 egridcloud.com, All rights reserved.
+ */
+package com.egridcloud.udf.scheduler.client.service;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.ParameterizedTypeReference;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+
+import com.egridcloud.udf.core.RestResponse;
+import com.egridcloud.udf.rms.Rms;
+
+/**
+ * 描述 : SchClientService
+ *
+ * @author Administrator
+ *
+ */
+@Service
+public class SchClientService {
+
+  /**
+   * 描述 : rms
+   */
+  @Autowired
+  private Rms rms;
+
+  /**
+   * 描述 : 触发作业
+   *
+   * @param jobCode 作业代码
+   * @param param 参数
+   * @return id
+   */
+  public String trigger(String jobCode, Map<String, String> param) {
+    //接口编号
+    final String serviceCode = "SCHEDULER_JOB_4";
+    //rest参数
+    Map<String, String> uriVariables = new HashMap<>();
+    uriVariables.put("jobCode", jobCode);
+    //请求
+    ResponseEntity<RestResponse<String>> result =
+        rms.call(serviceCode, param, null, new ParameterizedTypeReference<RestResponse<String>>() {
+        }, uriVariables);
+    //返回
+    return result.getBody().getResult();
+  }
+
+}