From c007f0ca1785db093d48f4846cda82fe8e955765 Mon Sep 17 00:00:00 2001
From: kimi <kimi42345@gmail.com>
Date: 星期三, 27 五月 2020 09:59:29 +0800
Subject: [PATCH] merage
---
src/main/java/com/highdatas/mdm/job/JobClient.java | 77 ++++++++++++++++++++++++++++++++++----
1 files changed, 69 insertions(+), 8 deletions(-)
diff --git a/src/main/java/com/highdatas/mdm/job/JobClient.java b/src/main/java/com/highdatas/mdm/job/JobClient.java
index 6e29284..ffb5411 100644
--- a/src/main/java/com/highdatas/mdm/job/JobClient.java
+++ b/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鐨刯obgroup
+ * @return 鏄惁璇锋眰鎴愬姛
+ *
+ */
public boolean saveAutoJobGroup() {
try {
String url = this.url + prefix + "xxlcustapi/saveJobGroup";
@@ -127,7 +149,12 @@
}
}
-
+ /**
+ *
+ * @description: xxljob 鍒犻櫎鑷姩鑾峰彇ip鐨刯obgroup
+ * @return 鏄惁璇锋眰鎴愬姛
+ *
+ */
public boolean removeJobGroup() {
try {
String url = this.url + prefix + "xxlcustapi/saveJobGroup";
@@ -150,7 +177,13 @@
}
-
+ /**
+ *
+ * @description: xxljob 娣诲姞涓�涓猨ob
+ * @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 浣跨敤鐨刪ttp璇锋眰宸ュ叿鏂规硶
+ * @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;
--
Gitblit v1.8.0