bak 修改 获取版本数据前

kimi

2020-05-18 c8aee7b9bfd79cfd741d7e5692520f4f51a31a86

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

@@ -98,6 +98,36 @@


    }



    public boolean saveAutoJobGroup() {

        try {

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

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

            params.put("appName","MDMApp");

            params.put("order", "1");

            params.put("title","数据汇集定时任务执行器");

            params.put("modelId","MDM");

            params.put("addressType","0");

//            params.put("addressList",local);

            String s = null;

            Map<String, Object> paramMap = new HashMap<>();

            paramMap.putAll(params);

            String urlParamsByMap = HttpUtils.getUrlParamsByMap(paramMap);



            s = HttpRestClient(url, HttpMethod.POST, null, urlParamsByMap, MediaType.APPLICATION_JSON);



            JSONObject result = (JSONObject) JSON.parse(s);

            boolean success = parse(result);

            if (!success){

                log.error("请求saveJobGroup失败:" + result.getString("msg"));

            }

            return success;

        }catch (Exception e){

            e.printStackTrace();

            return false;

        }



    }



    public boolean removeJobGroup() {

        try {

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

@@ -135,11 +165,11 @@
            params.put("cronGen_display",assemble.getCron());

            params.put("executorBlockStrategy","DISCARD_LATER");

            params.put("executorTimeout","0");

            params.put("executorFailRetryCount","3");

            params.put("executorFailRetryCount","0");

            params.put("triggerStatus","1");

            params.put("glueType","BEAN");

            params.put("executorRouteStrategy","FIRST");

            params.put("jobDesc","创建汇集job");

            params.put("jobDesc","创建汇集job" + jobId);

            Map<String, Object> paramMap = new HashMap<>();

            paramMap.putAll(params);

            String urlParamsByMap = HttpUtils.getUrlParamsByMap(paramMap);

@@ -165,7 +195,7 @@
            id = DbUtils.getUUID();

        }

        try {

            String jobId  = "MDM-" + DbUtils.Bit16(id);

            String jobId  = "MDM-" + id;

            return jobId;

        } catch (Exception e) {

            e.printStackTrace();

@@ -175,6 +205,7 @@


    public boolean updateJob(SysAssemble assemble) {

        try {

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

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

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

            params.put("modelId","MDM");

@@ -190,7 +221,7 @@
            params.put("triggerStatus","1");

            params.put("glueType","BEAN");

            params.put("executorRouteStrategy","FIRST");

            params.put("jobDesc","更新汇集job");

            params.put("jobDesc","更新汇集job" + jobId);

            Map<String, Object> paramMap = new HashMap<>();

            paramMap.putAll(params);

            String urlParamsByMap = HttpUtils.getUrlParamsByMap(paramMap);