#291 作业启用/禁用写入到数据库

vipshop · Nov 17, 2017 · 284d983 · 284d983
1 parent c6636e2
commit 284d983
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/saturn-console/src/main/java/com/vip/saturn/job/console/service/impl/RestApiServiceImpl.java b/saturn-console/src/main/java/com/vip/saturn/job/console/service/impl/RestApiServiceImpl.java
@@ -391,8 +391,7 @@ public void call(CuratorRepository.CuratorFrameworkOp curatorFrameworkOp)
 							long ctime = curatorFrameworkOp.getCtime(enabledNodePath);
 							long mtime = curatorFrameworkOp.getMtime(enabledNodePath);
 							checkUpdateStatusToEnableAllowed(ctime, mtime);
-
-							curatorFrameworkOp.update(enabledNodePath, "true");
+							jobOperationService.setJobEnabledState(jobName, true);
 						}
 					}
 				});
@@ -410,8 +409,7 @@ public void call(CuratorRepository.CuratorFrameworkOp curatorFrameworkOp)
 						if (Boolean.valueOf(enabled)) {
 							long mtime = curatorFrameworkOp.getMtime(enabledNodePath);
 							checkUpdateStatusToDisableAllowed(mtime);
-
-							curatorFrameworkOp.update(enabledNodePath, "false");
+							jobOperationService.setJobEnabledState(jobName, false);
 						} else {
 							throw new SaturnJobConsoleHttpException(HttpStatus.CREATED.value(),
 									"The job is already disable");