From c8aee7b9bfd79cfd741d7e5692520f4f51a31a86 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期一, 18 五月 2020 18:30:01 +0800
Subject: [PATCH] bak 修改 获取版本数据前
---
src/main/java/com/highdatas/mdm/job/JobClient.java | 39 +++++++++++++++++++++++++++++++++++----
1 files changed, 35 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/job/JobClient.java b/src/main/java/com/highdatas/mdm/job/JobClient.java
index 5b339f4..6e29284 100644
--- a/src/main/java/com/highdatas/mdm/job/JobClient.java
+++ b/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);
--
Gitblit v1.8.0