diff --git a/src/main/java/com/project/task/domain/service/impl/DeleteTaskDomainServiceImpl.java b/src/main/java/com/project/task/domain/service/impl/DeleteTaskDomainServiceImpl.java index 83cd3ea..508a103 100644 --- a/src/main/java/com/project/task/domain/service/impl/DeleteTaskDomainServiceImpl.java +++ b/src/main/java/com/project/task/domain/service/impl/DeleteTaskDomainServiceImpl.java @@ -2,12 +2,15 @@ package com.project.task.domain.service.impl; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.project.base.domain.enums.StatusEnum; import com.project.base.domain.exception.BusinessErrorException; import com.project.base.domain.result.Result; import com.project.task.domain.entity.TaskEntity; +import com.project.task.domain.entity.TaskUserEntity; import com.project.task.domain.service.DeleteTaskDomainService; import com.project.task.domain.service.TaskBaseService; +import com.project.task.domain.service.TaskUserBaseService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -18,6 +21,9 @@ import java.util.List; public class DeleteTaskDomainServiceImpl implements DeleteTaskDomainService { @Autowired private TaskBaseService taskBaseService; + + @Autowired + private TaskUserBaseService taskUserBaseService; @Override public Result batchDelete(List ids) throws Exception { if (CollUtil.isEmpty(ids)) { @@ -38,6 +44,13 @@ public class DeleteTaskDomainServiceImpl implements DeleteTaskDomainService { throw new BusinessErrorException("任务不存在或已被删除"); } taskBaseService.removeBatchByIds(ids); + // 删除关联数据 + for (Long id : ids) { + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(TaskUserEntity::getTaskId , id); + taskUserBaseService.remove(queryWrapper); + } + return Result.success("删除成功"); } }