Skip to content

B
byit-myth-job
Commit 59c18e05 by guominglei
Options

修改日志级别为debug

parent b50eb59a
Showing with 51 additions and 50 deletions
byit-myth-executor/myth-executor-plugin/src/main/java/com/byit/utils/JobUtils.java
......@@ -50,7 +50,7 @@ public class JobUtils {
*/
private static final String REQUEST_FLOW_START = "/api/flow/start";
/**
* 开始工作流
* 校验工作流是否存在
*/
private static final String REQUEST_FLOW_EXIST = "/api/flow/exist";
/**
......@@ -195,10 +195,10 @@ public class JobUtils {
* @return 添加结果
*/
public static ResponseResult addJob(PluginBeanJobInfo pluginBeanJobInfo){
log.info("---------------开始添加一个任务,jobHandelName:{}---------------------", pluginBeanJobInfo.getJobHandelName());
log.debug("---------------开始添加一个任务,jobHandelName:{}---------------------", pluginBeanJobInfo.getJobHandelName());
//发送请求 添加任务
String response = createHttpRequest(REQUEST_ADD_JOB_RESOURCES_SUFFIX, JSON.toJSONString(pluginBeanJobInfo));
log.info("--------------------添加任务完成，添加结果为：{}------------------------", response);
log.debug("--------------------添加任务完成，添加结果为：{}------------------------", response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -208,12 +208,12 @@ public class JobUtils {
* @return
*/
public static ResponseResult publish(PluginPackage pluginPackage){
log.info("---------------开始发布工作流,flowName:{}---------------------", pluginPackage.getFlow().getName());
log.debug("---------------开始发布工作流,flowName:{}---------------------", pluginPackage.getFlow().getName());
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_PUBLISH, "param=" + JSON.toJSONString(pluginPackage, WriteClassName));
//String addRequestResult = HttpUtil.post(requestUrl, JSON.toJSONString(pluginPackage, WriteClassName))
log.info("--------------------添加任务完成，添加结果为：{}------------------------", response);
log.debug("--------------------添加任务完成，添加结果为：{}------------------------", response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -229,7 +229,7 @@ public class JobUtils {
map.put("workspaceName",workspaceName);
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_START, "param="+JSON.toJSONString(map,WriteClassName));
log.info("--------------------开始接口调用成功，结果为：{}------------------------", response);
log.debug("--------------------开始接口调用成功，结果为：{}------------------------", response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -245,7 +245,7 @@ public class JobUtils {
map.put("workspaceName",workspaceName);
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_EXIST, "param="+JSON.toJSONString(map));
log.info("--------------------校验工作流是否存在接口调用成功，结果为：{}------------------------", response);
log.debug("--------------------校验工作流是否存在接口调用成功，结果为：{}------------------------", response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -261,7 +261,7 @@ public class JobUtils {
map.put("workspaceName",workspaceName);
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_STOP,"param="+JSON.toJSONString(map,WriteClassName));
log.info("--------------------暂停接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------暂停接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -277,7 +277,7 @@ public class JobUtils {
map.put("workspaceName",workspaceName);
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_DELETE,"param="+JSON.toJSONString(map,WriteClassName));
log.info("--------------------删除接口调用成功，结果为：{}------------------------", response);
log.debug("--------------------删除接口调用成功，结果为：{}------------------------", response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -293,7 +293,7 @@ public class JobUtils {
map.put("workspaceName",workspaceName);
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_REPEAL,"param="+JSON.toJSONString(map,WriteClassName));
log.info("--------------------删除接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------删除接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
/**
......@@ -302,9 +302,10 @@ public class JobUtils {
* @return
*/
public static ResponseResult startSchedule(String runIds){
log.debug("重新开始调度接口 runids:{}",runIds);
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_REREPEAL, "runIds=" + runIds);
log.info("--------------------重新开始调度接口调用成功，结果为：{}------------------------", response);
log.debug("--------------------重新开始调度接口调用成功，结果为：{}------------------------", response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -323,7 +324,7 @@ public class JobUtils {
map.put("nodeName", nodeName);
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_KILL_JOB,"param="+JSON.toJSONString(map,WriteClassName));
log.info("--------------------杀死任务接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------杀死任务接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -339,7 +340,7 @@ public class JobUtils {
map.put("workspaceName", workspaceName);
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_KILL_FLOW, "param="+JSON.toJSONString(map,WriteClassName));
log.info("--------------------杀死工作流接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------杀死工作流接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -350,7 +351,7 @@ public class JobUtils {
public static ResponseResult reRunJob(RunInfo runInfo){
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_RERUNJOB,"param="+JSON.toJSONString(runInfo, WriteClassName));
log.info("--------------------重跑节点接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------重跑节点接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -362,7 +363,7 @@ public class JobUtils {
public static ResponseResult reRunFlow(RunInfo runInfo){
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_RERUNFLOW,"param="+JSON.toJSONString(runInfo, WriteClassName));
log.info("--------------------重跑节点接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------重跑节点接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -373,7 +374,7 @@ public class JobUtils {
public static ResponseResult makeSuccess(RunInfo runInfo){
//发送请求 添加任务
String response = createHttpRequest(REQUEST_FLOW_MAKESUCCESS,"param="+JSON.toJSONString(runInfo, WriteClassName));
log.info("--------------------手动置为成功接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------手动置为成功接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -396,7 +397,7 @@ public class JobUtils {
param.put("scheduleStatus", scheduleStatus);
param.put("executeStatus", executeStatus);
String response = createHttpRequest(REQUEST_LOADSCHEDULE, "param=" + JSON.toJSONString(param));
log.info("--------------------获取运行实例接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------获取运行实例接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -412,7 +413,7 @@ public class JobUtils {
param.put("runId", runId);
param.put("flowName", flowName);
String response = createHttpRequest(REQUEST_LOADSCHEDULELOG, "param=" + JSON.toJSONString(param));
log.info("--------------------获取工作流运行实例的节点日志接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------获取工作流运行实例的节点日志接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -429,7 +430,7 @@ public class JobUtils {
param.put("endTime", endTime);
param.put("workspaceName", workspaceName);
String response = createHttpRequest(REQUEST_LOADSTATISTICDATA, "param=" + JSON.toJSONString(param));
log.info("--------------------获取运行的统计数据接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------获取运行的统计数据接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -448,7 +449,7 @@ public class JobUtils {
param.put("workspaceName", workspaceName);
param.put("flowName", flowName);
String response = createHttpRequest(REQUEST_LOADNODESTATISTICDATA, "param=" + JSON.toJSONString(param));
log.info("--------------------获取节点运行的统计数据接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------获取节点运行的统计数据接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -463,7 +464,7 @@ public class JobUtils {
param.put("workspaceName", workspaceName);
param.put("flowNames", flowNames);
String response = createHttpRequest(REQUEST_LOADCURRENTSTATUS, "param=" + JSON.toJSONString(param));
log.info("--------------------获取当前的工作流运行状态接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------获取当前的工作流运行状态接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -483,7 +484,7 @@ public class JobUtils {
param.put("repairTimes", repairTimes);
String response = createHttpRequest(REQUEST_REPAIRFLOW, "param=" + JSON.toJSONString(param));
log.info("--------------------补批工作流接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------补批工作流接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -493,10 +494,10 @@ public class JobUtils {
* @return
*/
public static ResponseResult addWorkspace(String workspaceName){
log.info("---------------开始创建工作空间,workspaceName:{}---------------------", workspaceName);
log.debug("---------------开始创建工作空间,workspaceName:{}---------------------", workspaceName);
//发送请求 添加任务
String response = createHttpRequest(REQUEST_WORKSPACE_ADD, "workspaceName="+ workspaceName);
log.info("--------------------创建工作空间接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------创建工作空间接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -506,10 +507,10 @@ public class JobUtils {
* @return
*/
public static ResponseResult existWorkspace(String workspaceName){
log.info("---------------判断工作空间是否存在,workspaceName:{}---------------------", workspaceName);
log.debug("---------------判断工作空间是否存在,workspaceName:{}---------------------", workspaceName);
//发送请求 添加任务
String response = createHttpRequest(REQUEST_WORKSPACE_EXIST, "workspaceName="+ workspaceName);
log.info("--------------------判断工作空间是否存在接口调用成功，结果为：{}------------------------",response);
log.debug("--------------------判断工作空间是否存在接口调用成功，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -518,17 +519,17 @@ public class JobUtils {
* @return
*/
public static ResponseResult realExectNode(RunNode runNode){
log.info("---------------立即运行节点---------------------");
log.debug("---------------立即运行节点---------------------");
//立即运行节点
String response = createHttpRequest(REQUEST_REAL_EXECT, "param=" + JSON.toJSONString(runNode));
log.info("--------------------立即运行节点，结果为：{}------------------------",response);
log.debug("--------------------立即运行节点，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
public static ResponseResult runHistroy(String nodeId){
log.info("-------------获取运行历史----------------------");
log.debug("-------------获取运行历史----------------------");
String response = createHttpRequest(REQUEST_RUN_HISTORY, "nodeId=" + nodeId);
log.info("--------------------获取运行历史，结果为：{}------------------------",response);
log.debug("--------------------获取运行历史，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -540,9 +541,9 @@ public class JobUtils {
* @return com.byit.dto.web.ResponseResult
*/
public static ResponseResult addJavaTask(JavaTask javaTask){
log.info("-------------添加任务----------------------");
log.debug("-------------添加任务----------------------");
String response = createHttpRequest(REQUEST_ADD_JAVATASK, "param=" + JSON.toJSONString(javaTask, WriteClassName));
log.info("--------------------添加任务，结果为：{}------------------------",response);
log.debug("--------------------添加任务，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -554,9 +555,9 @@ public class JobUtils {
* @return com.byit.dto.web.ResponseResult
*/
public static ResponseResult updateJavaTask(JavaTask javaTask){
log.info("-------------修改任务----------------------");
log.debug("-------------修改任务----------------------");
String response = createHttpRequest(REQUEST_UPDATE_JAVATASK, "param=" + JSON.toJSONString(javaTask, WriteClassName));
log.info("--------------------修改任务，结果为：{}------------------------",response);
log.debug("--------------------修改任务，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -568,9 +569,9 @@ public class JobUtils {
* @return com.byit.dto.web.ResponseResult
*/
public static ResponseResult deleteJavaTask(String jobName){
log.info("-------------删除任务----------------------");
log.debug("-------------删除任务----------------------");
String response = createHttpRequest(REQUEST_DELETE_JAVATASK, "jobName=" + jobName);
log.info("--------------------删除任务，结果为：{}------------------------",response);
log.debug("--------------------删除任务，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -582,9 +583,9 @@ public class JobUtils {
* @return com.byit.dto.web.ResponseResult
*/
public static ResponseResult existJavaTask(String jobName){
log.info("-------------判断是否存在任务----------------------");
log.debug("-------------判断是否存在任务----------------------");
String response = createHttpRequest(REQUEST_EXIST_JAVATASK, "jobName=" + jobName);
log.info("--------------------判断是否存在任务，结果为：{}------------------------",response);
log.debug("--------------------判断是否存在任务，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -598,13 +599,13 @@ public class JobUtils {
* @return com.byit.dto.web.ResponseResult
*/
public static ResponseResult loadLogByJobName(String jobName, Long startTime, Long endTime){
log.info("-------------根据jobName获取运行日志----------------------");
log.debug("-------------根据jobName获取运行日志----------------------");
Map<String, Object> map = new HashMap<>();
map.put("jobName", jobName);
map.put("startTime", startTime);
map.put("endTime", endTime);
String response = createHttpRequest(REQUEST_LOADLOG_JOBNAME, "param=" + JSON.toJSONString(map));
log.info("--------------------根据jobName获取运行日志，结果为：{}------------------------",response);
log.debug("--------------------根据jobName获取运行日志，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -618,13 +619,13 @@ public class JobUtils {
* @return com.byit.dto.web.ResponseResult
*/
public static ResponseResult loadLogByTaskName(String taskName, Long startTime, Long endTime){
log.info("-------------根据taskName获取运行日志----------------------");
log.debug("-------------根据taskName获取运行日志----------------------");
Map<String, Object> map = new HashMap<>();
map.put("taskName", taskName);
map.put("startTime", startTime);
map.put("endTime", endTime);
String response = createHttpRequest(REQUEST_LOADLOG_TASKNAME, "param=" + JSON.toJSONString(map));
log.info("--------------------根据taskName获取运行日志，结果为：{}------------------------",response);
log.debug("--------------------根据taskName获取运行日志，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -634,9 +635,9 @@ public class JobUtils {
* @return
*/
public static ResponseResult runJavaTask(String jobName){
log.info("-------------立即运行quartz任务----------------------");
log.debug("-------------立即运行quartz任务----------------------");
String response = createHttpRequest(REQUEST_RUN_JAVATASK, "jobName=" + jobName);
log.info("--------------------立即运行quartz任务，结果为：{}------------------------",response);
log.debug("--------------------立即运行quartz任务，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -646,9 +647,9 @@ public class JobUtils {
* @return
*/
public static ResponseResult runTask(JavaTask javaTask){
log.info("-------------立即运行quartz任务----------------------");
log.debug("-------------立即运行quartz任务----------------------");
String response = createHttpRequest(REQUEST_RUN_TASK, "param=" + JSON.toJSONString(javaTask,WriteClassName));
log.info("--------------------立即运行quartz任务，结果为：{}------------------------",response);
log.debug("--------------------立即运行quartz任务，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -658,9 +659,9 @@ public class JobUtils {
* @return
*/
public static ResponseResult loadCurrentStatusByJobName(String jobNames){
log.info("-------------获取当前的运行状态----------------------");
log.debug("-------------获取当前的运行状态----------------------");
String response = createHttpRequest(REQUEST_LOADSTATUS_JAVATASK, "jobNames=" + jobNames);
log.info("--------------------获取当前的运行状态，结果为：{}------------------------",response);
log.debug("--------------------获取当前的运行状态，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......@@ -670,9 +671,9 @@ public class JobUtils {
* @return
*/
public static ResponseResult killRunNode(Integer logId) {
log.info("-------------杀死当前运行的节点----------------------");
log.debug("-------------杀死当前运行的节点----------------------");
String response = createHttpRequest(KILL_NODE_RUN_ING, "logId=" + logId);
log.info("--------------------获取当前的运行状态，结果为：{}------------------------",response);
log.debug("--------------------获取当前的运行状态，结果为：{}------------------------",response);
return JSON.parseObject(response, ResponseResult.class);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment