插件端的业务逻辑添加事务

byit-myth-admin/src/main/java/com/byit/service/impl/ApiFlowServiceImpl.java

@@ -459,6 +459,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void deleteFlow(String flowName, String workspaceName) {
         log.info("删除工作空间【{}】---工作流【{}】调度", workspaceName, flowName);
         Workspace workspace = workspaceMapper.getByName(workspaceName);
@@ -502,6 +503,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void start(String flowName, String workspaceName) throws ParseException {
         log.info("开始工作空间【{}】---工作流【{}】调度", workspaceName, flowName);
         Workspace workspace = workspaceMapper.getByName(workspaceName);
@@ -515,6 +517,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void repealSchedule(String flowName, String workspaceName) throws ParseException {
         log.info("撤销工作空间【{}】---工作流【{}】调度", workspaceName, flowName);
         Workspace workspace = workspaceMapper.getByName(workspaceName);
@@ -569,6 +572,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public String stopSchedule(String flowName, String workspaceName) {
         log.info("停止工作空间【{}】---工作流【{}】调度", workspaceName, flowName);
         Workspace workspace = workspaceMapper.getByName(workspaceName);
@@ -590,6 +594,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void reStartSchedule(String runIds) {
         ValidationUtil.dataNotBank(runIds, "运行id不允许为空！");
         List<String> runIdList = Arrays.asList(runIds.split(","));