merage

kimi

2020-05-27 c007f0ca1785db093d48f4846cda82fe8e955765

 src/main/java/com/highdatas/mdm/job/JobClient.java

@@ -41,6 +41,12 @@
    private JobClient() {

        this.prefix = "/xxl-job-admin/";

    }

    /**

     *

     * @description: xxljob 登录接口

     * @return 具体数据

     *

     */

    public  boolean login() {

        String url = this.url + prefix + "login";

        Map<String, String> params = new LinkedHashMap<>();

@@ -56,6 +62,12 @@
        return  success;

    }



    /**

     *

     * @description: xxljob 参数转换

     * @return 是否请求成功

     *

     */

    private boolean parse(JSONObject result) {

        boolean success = true;

        Integer code = result.getInteger(Constant.Code);

@@ -67,7 +79,12 @@
        return success;

    }





    /**

     *

     * @description: xxljob 保存jobGroup

     * @return 是否请求成功

     *

     */

    public boolean saveJobGroup() {

        try {

            String url =  this.url + prefix + "xxlcustapi/saveJobGroup";

@@ -97,7 +114,12 @@
        }



    }



    /**

     *

     * @description: xxljob 保存自动获取ip的jobgroup

     * @return 是否请求成功

     *

     */

    public boolean saveAutoJobGroup() {

        try {

            String url =  this.url + prefix + "xxlcustapi/saveJobGroup";

@@ -127,7 +149,12 @@
        }



    }



    /**

     *

     * @description: xxljob 删除自动获取ip的jobgroup

     * @return 是否请求成功

     *

     */

    public boolean removeJobGroup() {

        try {

            String url =  this.url + prefix + "xxlcustapi/saveJobGroup";

@@ -150,7 +177,13 @@


    }





    /**

     *

     * @description: xxljob 添加一个job

     * @param  assemble 汇集任务

     * @return 是否请求成功

     *

     */

    public boolean addJob(SysAssemble assemble) {

        try {

            String jobId = createJobId(assemble.getId());

@@ -189,7 +222,12 @@
        }



    }



    /**

     *

     * @description: xxljob 创建job id

     * @return 是否请求成功

     *

     */

    private String createJobId(String id) {

        if (StringUtils.isEmpty(id)) {

            id = DbUtils.getUUID();

@@ -202,7 +240,13 @@
            return id;

        }

    }



    /**

     *

     * @description: xxljob 更新job

     * @param assemble huiji renwu

     * @return 是否请求成功

     *

     */

    public boolean updateJob(SysAssemble assemble) {

        try {

            String jobId = createJobId(assemble.getId());

@@ -239,7 +283,13 @@
        }



    }



    /**

     *

     * @description: xxljob 删除job

     * @param  jobId job ID

     * @return 是否请求成功

     *

     */

    public boolean deleteJob(String jobId) {



        try {

@@ -294,6 +344,12 @@


    }



    /**

     *

     * @description: xxljob 触发一次

     * @return 是否请求成功

     *

     */

    public boolean trigger(SysAssemble assemble) {

        if (StringUtils.isEmpty(assemble.getJobId())) {

            return false;

@@ -323,7 +379,12 @@


    }





    /**

     *

     * @description: xxljob 使用的http请求工具方法

     * @return 是否请求成功

     *

     */

    private  String     HttpRestClient(String url, HttpMethod method, Map<String, String> formParams, String getParams,  MediaType mediaType) {

        if (!StringUtils.isEmpty(getParams)) {

            url = url + Constant.QUESTION + getParams;