From 79df89dbef1ad9fe1710d89e410e3973de33bf3d Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期二, 24 九月 2024 15:16:12 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mpk/service/impl/ProjectServiceImpl.java |   31 ++++++-------------------------
 1 files changed, 6 insertions(+), 25 deletions(-)

diff --git a/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mpk/service/impl/ProjectServiceImpl.java b/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mpk/service/impl/ProjectServiceImpl.java
index dc0a2fb..2ab3194 100644
--- a/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mpk/service/impl/ProjectServiceImpl.java
+++ b/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mpk/service/impl/ProjectServiceImpl.java
@@ -1,6 +1,6 @@
 package com.iailab.module.model.mpk.service.impl;
 
-import cn.hutool.core.io.FileUtil;
+import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.iailab.framework.common.page.PageData;
@@ -13,8 +13,6 @@
 import com.iailab.module.model.mpk.dto.ProjectModelDTO;
 import com.iailab.module.model.mpk.dto.ProjectPackageHistoryDTO;
 import com.iailab.module.model.mpk.entity.ProjectEntity;
-import com.iailab.module.model.mpk.entity.ProjectModelEntity;
-import com.iailab.module.model.mpk.entity.ProjectPackageHistoryModelEntity;
 import com.iailab.module.model.mpk.service.ProjectModelService;
 import com.iailab.module.model.mpk.service.ProjectPackageHistoryModelService;
 import com.iailab.module.model.mpk.service.ProjectPackageHistoryService;
@@ -24,7 +22,6 @@
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
 
 import java.io.File;
 import java.util.*;
@@ -83,7 +80,7 @@
     }
 
     @Override
-    @Transactional(rollbackFor = Exception.class)
+    @DSTransactional(rollbackFor = Exception.class)
     public void save(ProjectDTO dto) {
         ProjectEntity entity = ConvertUtils.sourceToTarget(dto, ProjectEntity.class);
         String projectId = UUID.randomUUID().toString();
@@ -94,20 +91,12 @@
         //关联模型
         List<MpkFileDTO> models = dto.getModels();
         if (CollectionUtils.isNotEmpty(models)) {
-            List<ProjectModelEntity> projectModelList = new ArrayList<>(models.size());
-            for (MpkFileDTO model : models) {
-                ProjectModelEntity projectModel = new ProjectModelEntity();
-                projectModel.setId(UUID.randomUUID().toString());
-                projectModel.setProjectId(projectId);
-                projectModel.setModelId(model.getId());
-                projectModelList.add(projectModel);
-            }
-            projectModelService.insertBatch(projectModelList);
+            projectModelService.create(models,projectId);
         }
     }
 
     @Override
-    @Transactional(rollbackFor = Exception.class)
+    @DSTransactional(rollbackFor = Exception.class)
     public void update(ProjectDTO dto) {
         ProjectEntity entity = ConvertUtils.sourceToTarget(dto, ProjectEntity.class);
         entity.setUpdateTime(new Date());
@@ -122,20 +111,12 @@
         //关联模型
         List<MpkFileDTO> models = dto.getModels();
         if (CollectionUtils.isNotEmpty(models)) {
-            List<ProjectModelEntity> projectModelList = new ArrayList<>(models.size());
-            for (MpkFileDTO model : models) {
-                ProjectModelEntity projectModel = new ProjectModelEntity();
-                projectModel.setId(UUID.randomUUID().toString());
-                projectModel.setProjectId(projectId);
-                projectModel.setModelId(model.getId());
-                projectModelList.add(projectModel);
-            }
-            projectModelService.insertBatch(projectModelList);
+            projectModelService.create(models,projectId);
         }
     }
 
     @Override
-    @Transactional(rollbackFor = Exception.class)
+    @DSTransactional(rollbackFor = Exception.class)
     public void delete(String id) {
         //删除备份文件
         Map<String,Object> map = new HashMap<>();

--
Gitblit v1.9.3