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 param) { + //接口编号 + final String serviceCode = "SCHEDULER_JOB_4"; + //rest参数 + Map uriVariables = new HashMap<>(); + uriVariables.put("jobCode", jobCode); + //请求 + ResponseEntity> result = + rms.call(serviceCode, param, null, new ParameterizedTypeReference>() { + }, uriVariables); + //返回 + return result.getBody().getResult(); + } + +}