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 16:51:46 +08:00
parent bed568cd49
commit b2e07ce5c6
1 changed files with 11 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
java/src/main/java/com/yfd/platform/modules/experimentalData/service/impl/TsNodesServiceImpl.java
View File

@ -471,46 +471,18 @@ public class TsNodesServiceImpl extends ServiceImpl<TsNodesMapper, TsNodes> impl
.map(TsFiles::getId)
.collect(Collectors.toList()));
}
if (dataset.size() <= 0) {
return true;
if (dataset.size() > 0) {
//批量修改
LambdaUpdateWrapper<TsFiles> updateWrapper1 = new LambdaUpdateWrapper<>();
updateWrapper1.in(TsFiles::getId, dataset).set(TsFiles::getWorkPath, "");
tsFilesMapper.update(null, updateWrapper1);
LambdaQueryWrapper<TsFiles> deleteWrapper = new LambdaQueryWrapper<>();
deleteWrapper.in(TsFiles::getId, dataset)
.and(wrapper -> wrapper.isNull(TsFiles::getBackupPath).or().eq(TsFiles::getBackupPath, ""))
.and(wrapper -> wrapper.isNull(TsFiles::getWorkPath).or().eq(TsFiles::getWorkPath, ""));
tsFilesMapper.delete(deleteWrapper);
}
//批量修改
LambdaUpdateWrapper<TsFiles> updateWrapper1 = new LambdaUpdateWrapper<>();
updateWrapper1.in(TsFiles::getId, dataset).set(TsFiles::getWorkPath, "");
tsFilesMapper.update(null, updateWrapper1);
//批量删除
// LambdaQueryWrapper<TsFiles> deleteWrapper = new LambdaQueryWrapper<>();
// deleteWrapper.in(TsFiles::getId, dataset).isNull(TsFiles::getBackupPath).eq(TsFiles::getBackupPath, "").isNull(TsFiles::getWorkPath).eq(TsFiles::getWorkPath, "");
// tsFilesMapper.delete(deleteWrapper);
//
// LambdaQueryWrapper<TsFiles> deleteWrapper = new LambdaQueryWrapper<>();
// deleteWrapper.in(TsFiles::getId, dataset)
// .and(wrapper -> wrapper.isNull(TsFiles::getBackupPath).or().eq(TsFiles::getBackupPath, ""))
// .and(wrapper -> wrapper.isNull(TsFiles::getWorkPath).or().eq(TsFiles::getWorkPath, ""));
// tsFilesMapper.delete(deleteWrapper);
LambdaQueryWrapper<TsFiles> deleteWrapper = new LambdaQueryWrapper<>();
deleteWrapper.in(TsFiles::getId, dataset)
.and(wrapper -> wrapper.isNull(TsFiles::getBackupPath).or().eq(TsFiles::getBackupPath, ""))
.and(wrapper -> wrapper.isNull(TsFiles::getWorkPath).or().eq(TsFiles::getWorkPath, ""));
tsFilesMapper.delete(deleteWrapper);
// //批量修改TsFiles表结构
// if (dataset.size() > 0) {
// QueryWrapper<TsFiles> updateWrapper = new QueryWrapper<>();
// updateWrapper.in("id", dataset);
// // 创建 TsFiles 实体对象，设置要更新的字段
// TsFiles tsFiles1 = new TsFiles();
// tsFiles1.setWorkPath(""); // 将 work_path 更新为 ""
// tsFilesMapper.update(tsFiles1, updateWrapper);
// LOGGER.info("tsFiles一共删除 {}跳", dataset.size());
// }
//
//// // 递归删除子节点
// deleteChildren(tsNodes.getNodeId(), tsNodes.getTaskId());
//删除当前节点的文件夹 todo 这个地方改动
// 删除 sdlocal 中的文件夹
List<BatchDeleteRequest.DeleteItem> deleteItemList = new ArrayList<>();