package com.alibaba.schedulerx.pop;

import java.util.ArrayList;
import java.util.List;

import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.schedulerx2.model.v20190430.CreateJobRequest;
import com.aliyuncs.schedulerx2.model.v20190430.CreateJobRequest.ContactInfo;
import com.aliyuncs.schedulerx2.model.v20190430.CreateJobResponse;

public class CreateJavaJob {

    public static void main(String[] args) throws Exception {
     //  OpenAPI 的接入點(diǎn)，可查看產(chǎn)品支持的地域列表或根據(jù)購(gòu)買產(chǎn)品的地域填寫。
        String regionId = "cn-shanghai";
        //鑒權(quán)使用的 AccessKey ID，由阿里云官網(wǎng)控制臺(tái)獲取。
        String accessKeyId = "<yourAccessKeyId>";
        //鑒權(quán)使用的 AccessKey Secret，由阿里云官網(wǎng)控制臺(tái)獲取
        String accessKeySecret = "<yourAccessKeySecret>";
        //產(chǎn)品名稱。
        String productName ="schedulerx2";
        //對(duì)照支持地域列表選擇 Domain 填寫。
        String domain ="schedulerx.cn-shanghai.aliyuncs.com";
        //構(gòu)建 OpenAPI 客戶端。
        DefaultProfile.addEndpoint(regionId, productName, domain);
        DefaultProfile defaultProfile = DefaultProfile.getProfile(regionId, accessKeyId, accessKeySecret);
        DefaultAcsClient client = new DefaultAcsClient(defaultProfile);
        
        CreateJobRequest request = new CreateJobRequest();
        request.setJobType("java");
        request.setExecuteMode("standalone");
        request.setDescription("test");
        request.setName("helloworld");
        request.setClassName("com.alibaba.schedulerx.test.helloworld");
        request.setTimeType(1);
        request.setTimeExpression("0 0/10 * * * ?");
        request.setNamespace("xxxxx");
        request.setGroupId("xxxxxxx");
        // monitor
        request.setTimeoutEnable(true);
        request.setTimeoutKillEnable(true);
        request.setFailEnable(true);
        request.setTimeout(12300L);
        List<ContactInfo> contactInfosList = new ArrayList<>();
        ContactInfo contactInfo1 = new ContactInfo();
        contactInfo1.setUserName("userA");
        contactInfo1.setUserPhone("1381111****");
        ContactInfo contactInfo2 = new ContactInfo();
        contactInfo2.setUserName("userB");
        contactInfo2.setUserPhone("1382222****");
        contactInfosList.add(contactInfo1);
        contactInfosList.add(contactInfo2);
        request.setContactInfos(contactInfosList);
        // attrs
        //request.setQueueSize(123);
        request.setTaskMaxAttempt(1);
        request.setTaskAttemptInterval(100);
        CreateJobResponse response = client.getAcsResponse(request);
        if (response.getSuccess()) {
            System.out.println("jobId=" + response.getData().getJobId());
        } else {
            System.out.println(response.getMessage());
        }
    }

}

package com.alibaba.schedulerx.pop;

import com.alibaba.schedulerx.common.domain.HttpAttribute;
import com.alibaba.schedulerx.common.util.JsonUtil;

import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.schedulerx2.model.v20190430.CreateJobRequest;
import com.aliyuncs.schedulerx2.model.v20190430.CreateJobResponse;

public class CreateHttpJob {

    public static void main(String[] args) throws Exception {
     // OpenAPI 的接入點(diǎn)，具體查看支持地域列表或根據(jù)購(gòu)買地域填寫。
        String regionId = "cn-shanghai";
        //鑒權(quán)使用的 AccessKey ID，由阿里云官網(wǎng)控制臺(tái)獲取。
        String accessKeyId = "<yourAccessKeyId>";
        //鑒權(quán)使用的 AccessKey Secret，由阿里云官網(wǎng)控制臺(tái)獲取。
        String accessKeySecret = "<yourAccessKeySecret>";
        //產(chǎn)品名稱。
        String productName ="schedulerx2";
        //對(duì)照支持地域列表選擇 Domain 填寫。
        String domain ="schedulerx.cn-shanghai.aliyuncs.com";
        //構(gòu)建 OpenAPI 客戶端。
        DefaultProfile.addEndpoint(regionId, productName, domain);
        DefaultProfile defaultProfile = DefaultProfile.getProfile(regionId, accessKeyId, accessKeySecret);
        DefaultAcsClient client = new DefaultAcsClient(defaultProfile);
        
        CreateJobRequest request = new CreateJobRequest();
        request.setNamespace("xxxxxxxx");
        request.setGroupId("xxxxxx");
        request.setJobType("http");
        request.setName("testHttpJob");
        request.setDescription("testHttpJob");
        request.setTimeType(1);
        request.setTimeExpression("20 0/5 * * * ?");
        request.setExecuteMode("standalone");
        HttpAttribute httpAttribute = new HttpAttribute();
        httpAttribute.setUrl("http://192.168.0.0:8080/test");
        httpAttribute.setMethod("GET");
        httpAttribute.setTimeout(10); //單位秒
        httpAttribute.setRespKey("code");
        httpAttribute.setRespValue("200");
        request.setContent(JsonUtil.toJson(httpAttribute));
        //POST 參數(shù)，格式 key1=value1&key2=value2。
        request.setParameters("key1=value1&key2=value2");   
        
        //發(fā)送請(qǐng)求。
        CreateJobResponse response = client.getAcsResponse(request);
        if (!response.getSuccess()) {
            System.out.println(response.getMessage());
            System.out.println("createApp: "+response.getRequestId());
        } else {
            System.out.println(JsonUtil.toJson(response));
        }
    }
    
}

package com.alibaba.schedulerx.pop;

import java.util.ArrayList;
import java.util.List;

import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.schedulerx2.model.v20190430.CreateJobRequest;
import com.aliyuncs.schedulerx2.model.v20190430.CreateJobRequest.ContactInfo;
import com.aliyuncs.schedulerx2.model.v20190430.CreateJobResponse;

public class CreateJavaJob {

    public static void main(String[] args) throws Exception {
     // OpenAPI 的接入點(diǎn)，可查看產(chǎn)品支持的地域列表或根據(jù)購(gòu)買產(chǎn)品的地域填寫。
        String regionId = "cn-shanghai";
        //鑒權(quán)使用的 AccessKey ID，由阿里云官網(wǎng)控制臺(tái)獲取
        String accessKeyId = "xxxxxx";
        //鑒權(quán)使用的 AccessKey Secret，由阿里云官網(wǎng)控制臺(tái)獲取
        String accessKeySecret = "xxxxxxxx";
        //產(chǎn)品名稱
        String productName ="schedulerx2";
        //對(duì)照支持地域列表選擇 Domain 填寫
        String domain ="schedulerx.cn-shanghai.aliyuncs.com";
        //構(gòu)建 OpenAPI 客戶端
        DefaultProfile.addEndpoint(regionId, productName, domain);
        DefaultProfile defaultProfile = DefaultProfile.getProfile(regionId, accessKeyId, accessKeySecret);
        DefaultAcsClient client = new DefaultAcsClient(defaultProfile);
        
        CreateJobRequest request = new CreateJobRequest();
        request.setJobType("java");
        request.setExecuteMode("standalone");
        request.setDescription("test");
        request.setName("helloworld");
        request.setClassName("com.alibaba.schedulerx.test.helloworld");
        request.setTimeType(5);
        request.setTimeExpression("2021-12-30 12:12:12");
        request.setNamespace("xxxxxx");
        request.setGroupId("xxxxxxx");
        // 報(bào)警監(jiān)控
        request.setTimeoutEnable(true);
        request.setTimeoutKillEnable(true);
        request.setFailEnable(true);
        request.setTimeout(12300L);
        // 高級(jí)配置
        request.setMaxAttempt(3);
        request.setAttemptInterval(30);
        CreateJobResponse response = client.getAcsResponse(request);
        if (response.getSuccess()) {
            System.out.println("jobId=" + response.getData().getJobId());
        } else {
            System.out.println(response.getMessage());
        }
    }
    
}