Alawn/udf
1
0
Fork 0
mirror of https://gitee.com/wangkang/udf.git synced 2026-10-29 08:28:40 +00:00
Code Issues Releases Wiki Activity

调整RmsJobDisallowConcurrent处理逻辑

Browse Source
This commit is contained in:
wangkang
2017-08-28 19:49:52 +08:00
parent 47f266485e
commit 0bcbe04f15
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
udf-starter-scheduler/src/main/java/org/itkk/udf/scheduler/job/AbstractBaseRmsJob.java
+4 -4
View File
@@ -81,7 +81,7 @@ public abstract class AbstractBaseRmsJob extends AbstractBaseJob {
RmsJobResult result = new RmsJobResult();
result.setId(rmsJobParam.getId());
result.setStats(RmsJobStats.SKIP.value());
saveRmsJobEvent(rmsJobParam, result);
save(rmsJobParam, result);
}
}
@@ -111,7 +111,7 @@ public abstract class AbstractBaseRmsJob extends AbstractBaseJob {
throw new SchException("http状态:" + result.getStatusCode().toString());
}
//记录
saveRmsJobEvent(rmsJobParam, result.getBody().getResult());
save(rmsJobParam, result.getBody().getResult());
} catch (Exception e) {
//定义返回值
RmsJobResult result = new RmsJobResult();
@@ -119,7 +119,7 @@ public abstract class AbstractBaseRmsJob extends AbstractBaseJob {
result.setStats(RmsJobStats.ERROR.value());
result.setErrorMsg(ExceptionUtils.getStackTrace(e));
//记录
saveRmsJobEvent(rmsJobParam, result);
save(rmsJobParam, result);
//抛出异常
log.error("RmsJob error:", e);
throw new JobExecutionException(e);
@@ -143,7 +143,7 @@ public abstract class AbstractBaseRmsJob extends AbstractBaseJob {
* @param param param
* @param result result
*/
private void saveRmsJobEvent(RmsJobParam param, RmsJobResult result) {
private void save(RmsJobParam param, RmsJobResult result) {
IRmsJobEvent rmsJobEvent = this.getRmsJobEvent();
if (rmsJobEvent != null) {
rmsJobEvent.save(param, result);