From 0bcbe04f155ccda9589672f1977af9b60081ae2b Mon Sep 17 00:00:00 2001
From: wangkang <wangkangit@163.com>
Date: Mon, 28 Aug 2017 19:49:52 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4RmsJobDisallowConcurrent?=
 =?UTF-8?q?=E5=A4=84=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../org/itkk/udf/scheduler/job/AbstractBaseRmsJob.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/udf-starter-scheduler/src/main/java/org/itkk/udf/scheduler/job/AbstractBaseRmsJob.java b/udf-starter-scheduler/src/main/java/org/itkk/udf/scheduler/job/AbstractBaseRmsJob.java
index f9834ce..de507de 100644
--- a/udf-starter-scheduler/src/main/java/org/itkk/udf/scheduler/job/AbstractBaseRmsJob.java
+++ b/udf-starter-scheduler/src/main/java/org/itkk/udf/scheduler/job/AbstractBaseRmsJob.java
@@ -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);