优化事物

application-webadmin/src/main/java/com/yice/webadmin/app/service/impl/ModelManageServiceImpl.java

@@ -61,7 +61,6 @@ public class ModelManageServiceImpl extends BaseService<ModelManage, Long> imple
      * @param modelManage 新增对象。
      * @return 返回新增对象。
      */
-    @Transactional(rollbackFor = Exception.class)
     @Override
     public ModelManage saveNew(ModelManage modelManage) {
         modelManageMapper.insert(this.buildDefaultValue(modelManage));
@@ -187,7 +186,6 @@ public class ModelManageServiceImpl extends BaseService<ModelManage, Long> imple
         this.modelVersionService.saveNew(modelVersion);
         return reModelManage;
     }
-    @Transactional(rollbackFor = Exception.class)
     @Override
     public ModelVersion saveAndCreateVersionV(ModelManage modelManage, ModelVersion modelVersion) {
         ModelManage reModelManage = this.saveNew(modelManage);

application-webadmin/src/main/java/com/yice/webadmin/app/service/impl/ModelTaskServiceImpl.java

@@ -63,7 +63,6 @@ public class ModelTaskServiceImpl extends BaseService<ModelTask, Long> implement
      * @param modelTask 新增对象。
      * @return 返回新增对象。
      */
-    @Transactional(rollbackFor = Exception.class)
     @Override
     public ModelTask saveNew(ModelTask modelTask) {
         modelTaskMapper.insert(this.buildDefaultValue(modelTask));

application-webadmin/src/main/java/com/yice/webadmin/app/service/impl/ModelVersionServiceImpl.java

@@ -60,7 +60,6 @@ public class ModelVersionServiceImpl extends BaseService<ModelVersion, Long> imp
      * @param modelVersion 新增对象。
      * @return 返回新增对象。
      */
-    @Transactional(rollbackFor = Exception.class)
     @Override
     public ModelVersion saveNew(ModelVersion modelVersion) {
         String modelName = this.modelManageService.getById(modelVersion.getModelId()).getModelName();
@@ -77,7 +76,6 @@ public class ModelVersionServiceImpl extends BaseService<ModelVersion, Long> imp
         }
         modelVersion.setVersionName(modelName + "_V" + modelVersion.getModelVersion());
         modelVersionMapper.insert(this.buildDefaultValue(modelVersion));
-
         return modelVersion;
     }
 

application-webadmin/src/main/java/com/yice/webadmin/app/service/impl/TuningRunServiceImpl.java

@@ -180,6 +180,7 @@ public class TuningRunServiceImpl extends BaseService<TuningRun, Long> implement
 
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public boolean publishToModelVersion(RunPublishDto runPublishDto) {
         TuningRun tuningRun = this.getById(runPublishDto.getRunId());
         ModelVersion modelVersionSource = this.modelVersionService.getById(tuningRun.getModelVersionId());
@@ -272,7 +273,6 @@ public class TuningRunServiceImpl extends BaseService<TuningRun, Long> implement
         }.connectBlocking(5000, TimeUnit.MILLISECONDS);
     }
 
-    @Transactional(rollbackFor = Exception.class)
     public ModelVersion saveAll(TuningRun tuningRun, RunPublishDto runPublishDto, ModelVersion modelVersionSource, ModelTask modelTask) {
         ModelVersion modelVersion = new ModelVersion();
         this.initModelVersion(modelVersion, tuningRun, modelVersionSource);
@@ -292,7 +292,6 @@ public class TuningRunServiceImpl extends BaseService<TuningRun, Long> implement
         return modelVersion;
     }
 
-    @Transactional(rollbackFor = Exception.class)
     public ModelVersion saveAll(TuningRun tuningRun, ModelManage modelManageS, ModelVersion modelVersion, ModelVersion modelVersionSource, ModelTask modelTask) {
         this.initModelVersion(modelVersion, tuningRun, modelVersionSource);
         modelManageS.setModelType(0);
@@ -303,7 +302,7 @@ public class TuningRunServiceImpl extends BaseService<TuningRun, Long> implement
         return modelVersion;
     }
 
-    @Transactional(rollbackFor = Exception.class)
+
     public ModelVersion saveAll(TuningRun tuningRun, ModelVersion modelVersion, ModelVersion modelVersionSource, ModelTask modelTask) {
         this.initModelVersion(modelVersion, tuningRun, modelVersionSource);
         modelVersionService.saveNew(modelVersion);
@@ -337,7 +336,6 @@ public class TuningRunServiceImpl extends BaseService<TuningRun, Long> implement
         modelTask.setTaskId(tuningRun.getTaskId());
     }
 
-    @Transactional(rollbackFor = Exception.class)
     public Boolean updateStatus(Boolean flag, TuningRun tuningRun, ModelVersion modelVersionTarget, String targetModelVersionURl, ModelTask modelTask) {
         if (flag) {
             modelVersionTarget.setModelUrl(targetModelVersionURl);