From 4a6eaa4caa261e9628cfd2c395bd320fae0fe6a5 Mon Sep 17 00:00:00 2001 From: daiqy88 Date: Thu, 12 Mar 2026 15:55:58 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E4=BB=BF=E7=9C=9F=E5=B7=A5?= =?UTF-8?q?=E5=86=B5=E5=BA=93=E4=B8=8E=E6=A0=87=E5=87=86=E5=BA=93=E7=BB=91?= =?UTF-8?q?=E5=AE=9A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/SimulationTaskPoolServiceImpl.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/task/src/main/java/com/sdm/task/service/impl/SimulationTaskPoolServiceImpl.java b/task/src/main/java/com/sdm/task/service/impl/SimulationTaskPoolServiceImpl.java index bcf38684..229413ee 100644 --- a/task/src/main/java/com/sdm/task/service/impl/SimulationTaskPoolServiceImpl.java +++ b/task/src/main/java/com/sdm/task/service/impl/SimulationTaskPoolServiceImpl.java @@ -12,6 +12,7 @@ import com.sdm.common.common.SdmResponse; import com.sdm.common.common.ThreadLocalContext; import com.sdm.common.entity.pojo.task.FlowBindTaskPoolItem; import com.sdm.common.entity.pojo.task.TaskBaseInfo; +import com.sdm.common.entity.req.data.DeleteFileSimulationMappingReq; import com.sdm.common.entity.req.data.GetFileSimulationMappingReq; import com.sdm.common.entity.req.data.SaveFileSimulationMappingReq; import com.sdm.common.entity.req.system.LaunchApproveReq; @@ -316,13 +317,29 @@ public class SimulationTaskPoolServiceImpl extends BaseService implements ISimul } } } + List standardDeleteTask = new ArrayList<>(); //需要删除标准库的task uuid for(TaskPoolItem taskPoolItem:updateTasks) //删除更新分析项的关联关系 { mapper.deleteTaskFlowRelateByTaskUuid(taskPoolItem.uuid, poolName, currentVersion); + standardDeleteTask.add(taskPoolItem.uuid); //更新的task需要将绑定的标准库删除 } for(String taskUuid:deleteTaskUuids) //删除已删除分析项的关联关系 { mapper.deleteTaskFlowRelateByTaskUuid(taskUuid,poolName,currentVersion); + standardDeleteTask.add(taskUuid);//删除的task需要将绑定的标准库删除 + } + //删除task绑定的标准库 + if(!standardDeleteTask.isEmpty()) { + List deleteFileSimulationMappingReqs = new ArrayList<>(); + for(String taskUuid:standardDeleteTask) + { + DeleteFileSimulationMappingReq req = new DeleteFileSimulationMappingReq(); + req.setSimulationPoolTaskId(taskUuid); + req.setSimulationPoolId(currentBrief.id); + req.setSimulationPoolVersion(currentVersion); + deleteFileSimulationMappingReqs.add(req); + } + simulationMappingFeignClient.deleteFileSimulationMapping(deleteFileSimulationMappingReqs); } //将添加和更新task合并一起后一起添加关联关系，需要检查关系是否重复绑定 addTasks.addAll(updateTasks);