ThbTech/FileManage
1
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects 1 Releases Wiki Activity

代码提交

Browse Source
This commit is contained in:
lilin 2025-05-28 18:41:21 +08:00
parent 464db91efc
commit 2bd50f4462
1 changed files with 31 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsTaskServiceImpl.java
View File

@ -9,7 +9,10 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yfd.platform.config.ResponseResult; import com.yfd.platform.config.ResponseResult;
import com.yfd.platform.modules.experimentalData.domain.TsFiles; import com.yfd.platform.modules.experimentalData.domain.TsFiles;
import com.yfd.platform.modules.experimentalData.domain.TsNodes;
import com.yfd.platform.modules.experimentalData.domain.TsTask; import com.yfd.platform.modules.experimentalData.domain.TsTask;
import com.yfd.platform.modules.experimentalData.mapper.TsFilesMapper;
import com.yfd.platform.modules.experimentalData.mapper.TsNodesMapper;
import com.yfd.platform.modules.experimentalData.mapper.TsTaskMapper; import com.yfd.platform.modules.experimentalData.mapper.TsTaskMapper;
import com.yfd.platform.modules.experimentalData.service.ITsFilesService; import com.yfd.platform.modules.experimentalData.service.ITsFilesService;
import com.yfd.platform.modules.experimentalData.service.ITsNodesService; import com.yfd.platform.modules.experimentalData.service.ITsNodesService;
@ -60,6 +63,12 @@ public class TsTaskServiceImpl extends ServiceImpl<TsTaskMapper, TsTask> impleme
@Resource @Resource
private ITsFilesService tsFilesService; private ITsFilesService tsFilesService;
@Resource
private TsNodesMapper tsNodesMapper;
@Resource
private TsFilesMapper tsFilesMapper;
@Resource @Resource
private StorageSourceContext storageSourceContext; private StorageSourceContext storageSourceContext;
@ -255,19 +264,30 @@ public class TsTaskServiceImpl extends ServiceImpl<TsTaskMapper, TsTask> impleme
//循环所有的ID //循环所有的ID
for (String taskId : dataset) { for (String taskId : dataset) {
//删除项目
// 删除节点表
LambdaQueryWrapper<TsNodes> deleteWrapper = new LambdaQueryWrapper<>();
deleteWrapper.eq(TsNodes::getTaskId, taskId);
tsNodesMapper.delete(deleteWrapper);
// 删除文件表
LambdaQueryWrapper<TsFiles> deleteWrapperFiles = new LambdaQueryWrapper<>();
deleteWrapperFiles.eq(TsFiles::getTaskId, taskId);
tsFilesMapper.delete(deleteWrapperFiles);
TsTask tsTask = tsTaskMapper.selectById(taskId); TsTask tsTask = tsTaskMapper.selectById(taskId);
String path = "/" + tsTask.getTaskName() + "/"; // String path = "/" + tsTask.getTaskName() + "/";
//调用删除节点 根据任务ID // //调用删除节点 根据任务ID
Boolean deleteTsnodes = tsNodesService.deleteTsNodesByTaskId(taskId, path); // Boolean deleteTsnodes = tsNodesService.deleteTsNodesByTaskId(taskId, path);
//如果删除成功 接着删除节点表数据 // //如果删除成功 接着删除节点表数据
if (deleteTsnodes) { // if (deleteTsnodes) {
LOGGER.info("tsNodes表结删除改成功"); // LOGGER.info("tsNodes表结删除改成功");
value = true; // value = true;
} else { // } else {
LOGGER.error("tsNodes表结构删除失败"); // LOGGER.error("tsNodes表结构删除失败");
value = false; // value = false;
} // }
// 删除 local 中的文件夹 项目文件夹 // 删除 local 中的文件夹 项目文件夹