优化代码,新增库文件相关功能。

This commit is contained in:
chenxudong 2025-03-07 14:20:40 +08:00
parent 83ff46efc3
commit ff2d3c3e7b
14 changed files with 424 additions and 73 deletions

View File

@ -30,33 +30,33 @@ public class EdFileInfoController {
@Resource @Resource
private EdFileInfoService edFileInfoService; private EdFileInfoService edFileInfoService;
@UserOperation(value = "查看工程树", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "查看工程树", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequestMapping("tree") @RequestMapping("tree")
public ElectromagneticResult<?> tree() { public ElectromagneticResult<?> tree() {
return edFileInfoService.tree(PrjQuerySource.SYS_DB.value); return edFileInfoService.tree(PrjQuerySource.SYS_DB.value);
} }
@UserOperation(value = "创建文件夹", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "创建文件夹", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequestMapping("createFolder") @RequestMapping("createFolder")
public ElectromagneticResult<?> createFolder(@RequestBody CreateFolderDTO createFolderDTO) { public ElectromagneticResult<?> createFolder(@RequestBody CreateFolderDTO createFolderDTO) {
return edFileInfoService.createFolder(createFolderDTO, DataOwnEnum.SYS_FILE.code); return edFileInfoService.createFolder(createFolderDTO, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "作废", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "作废", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.DELETE) @RequiredPermission(value = FilePermission.DELETE)
@RequestMapping("delete") @RequestMapping("delete")
public ElectromagneticResult<?> delete(@RequestParam String id) { public ElectromagneticResult<?> delete(@RequestParam String id) {
return edFileInfoService.delete(id, DataOwnEnum.SYS_FILE.code); return edFileInfoService.delete(id, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "查询文件", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "查询文件", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.VIEW) @RequiredPermission(value = FilePermission.VIEW)
@RequestMapping("info") @RequestMapping("info")
public ElectromagneticResult<?> info(@RequestBody FileInfoQueryDTO fileInfoQueryDTO) { public ElectromagneticResult<?> info(@RequestBody FileInfoQueryDTO fileInfoQueryDTO) {
return edFileInfoService.queryEdFileInfo(fileInfoQueryDTO, DataOwnEnum.SYS_FILE.code); return edFileInfoService.queryEdFileInfo(fileInfoQueryDTO, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "上传文件", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "上传文件", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.UPLOAD) @RequiredPermission(value = FilePermission.UPLOAD)
@RequestMapping("upload") @RequestMapping("upload")
public ElectromagneticResult<?> upload(@RequestParam("parentId") String parentId, public ElectromagneticResult<?> upload(@RequestParam("parentId") String parentId,
@ -65,21 +65,21 @@ public class EdFileInfoController {
return edFileInfoService.upload(parentId, file, strategy, DataOwnEnum.SYS_FILE.code); return edFileInfoService.upload(parentId, file, strategy, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "下载文件", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "下载文件", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.DOWNLOAD) @RequiredPermission(value = FilePermission.DOWNLOAD)
@RequestMapping("download") @RequestMapping("download")
public ResponseEntity<InputStreamResource> download(@RequestParam String id, HttpServletResponse response) { public ResponseEntity<InputStreamResource> download(@RequestParam String id, HttpServletResponse response) {
return edFileInfoService.download(id, response, DataOwnEnum.SYS_FILE.code); return edFileInfoService.download(id, response, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "更新文件信息", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "更新文件信息", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.EDIT) @RequiredPermission(value = FilePermission.EDIT)
@RequestMapping("updateFileInfo") @RequestMapping("updateFileInfo")
public ElectromagneticResult<?> updateFileInfo(@RequestBody UpdateFileInfoDTO updateFileInfoDTO) { public ElectromagneticResult<?> updateFileInfo(@RequestBody UpdateFileInfoDTO updateFileInfoDTO) {
return edFileInfoService.updateFileInfo(updateFileInfoDTO, DataOwnEnum.SYS_FILE.code); return edFileInfoService.updateFileInfo(updateFileInfoDTO, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "移动文件", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "移动文件", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.MOVE) @RequiredPermission(value = FilePermission.MOVE)
@RequestMapping("moveFile") @RequestMapping("moveFile")
public ElectromagneticResult<?> moveFile(@RequestParam("id") String id, public ElectromagneticResult<?> moveFile(@RequestParam("id") String id,
@ -88,7 +88,7 @@ public class EdFileInfoController {
return edFileInfoService.moveFile(id, targetFolderId, strategy, DataOwnEnum.SYS_FILE.code); return edFileInfoService.moveFile(id, targetFolderId, strategy, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "复制文件", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "复制文件", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.MOVE) @RequiredPermission(value = FilePermission.MOVE)
@RequestMapping("copyFile") @RequestMapping("copyFile")
public ElectromagneticResult<?> copyFile(@RequestParam("id") String id, public ElectromagneticResult<?> copyFile(@RequestParam("id") String id,
@ -97,27 +97,27 @@ public class EdFileInfoController {
return edFileInfoService.copyFile(id, targetFolderId, strategy, DataOwnEnum.SYS_FILE.code); return edFileInfoService.copyFile(id, targetFolderId, strategy, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "查看文件历史版本信息", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "查看文件历史版本信息", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.VIEW) @RequiredPermission(value = FilePermission.VIEW)
@RequestMapping("versionView") @RequestMapping("versionView")
public ElectromagneticResult<?> versionView(@RequestParam String fileId) { public ElectromagneticResult<?> versionView(@RequestParam String fileId) {
return edFileInfoService.versionView(fileId); return edFileInfoService.versionView(fileId);
} }
@UserOperation(value = "回退版本", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "回退版本", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.EDIT) @RequiredPermission(value = FilePermission.EDIT)
@RequestMapping("versionBack") @RequestMapping("versionBack")
public ElectromagneticResult<?> versionBack(@RequestParam String fileId, @RequestParam int targetVersion) { public ElectromagneticResult<?> versionBack(@RequestParam String fileId, @RequestParam int targetVersion) {
return edFileInfoService.versionBack(fileId, targetVersion); return edFileInfoService.versionBack(fileId, targetVersion);
} }
@UserOperation(value = "导出数据库", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "导出数据库", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequestMapping("batchExport") @RequestMapping("batchExport")
public ResponseEntity<InputStreamResource> batchExport(@RequestParam String fileIds, HttpServletResponse response) throws IOException { public ResponseEntity<InputStreamResource> batchExport(@RequestParam String fileIds, HttpServletResponse response) throws IOException {
return edFileInfoService.batchExport(fileIds, response, DataOwnEnum.SYS_FILE.code); return edFileInfoService.batchExport(fileIds, response, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "批量上传数据库", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "批量上传数据库", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequestMapping(value = "/mergeChunks", method = RequestMethod.GET) @RequestMapping(value = "/mergeChunks", method = RequestMethod.GET)
public ElectromagneticResult<?> mergeChunks(@RequestParam String identifier, public ElectromagneticResult<?> mergeChunks(@RequestParam String identifier,
@RequestParam String fileName, @RequestParam String fileName,
@ -125,7 +125,7 @@ public class EdFileInfoController {
return edFileInfoService.mergeChunks(identifier, fileName, totalChunks, DataOwnEnum.SYS_FILE.code); return edFileInfoService.mergeChunks(identifier, fileName, totalChunks, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "批量上传数据库", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "批量上传数据库", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequestMapping(value = "/batchImport", method = RequestMethod.POST) @RequestMapping(value = "/batchImport", method = RequestMethod.POST)
public ElectromagneticResult<?> batchImport(FileChunkDTO fileChunkDTO) { public ElectromagneticResult<?> batchImport(FileChunkDTO fileChunkDTO) {
return edFileInfoService.batchImport(fileChunkDTO); return edFileInfoService.batchImport(fileChunkDTO);
@ -137,27 +137,27 @@ public class EdFileInfoController {
return edFileInfoService.checkChunkExist(fileChunkDTO); return edFileInfoService.checkChunkExist(fileChunkDTO);
} }
@UserOperation(value = "查询发布管理", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "查询发布管理", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequestMapping(value = "/uploadRecord", method = RequestMethod.GET) @RequestMapping(value = "/uploadRecord", method = RequestMethod.GET)
public ElectromagneticResult<?> uploadRecord(@RequestParam int pageNum, @RequestParam int pageSize) { public ElectromagneticResult<?> uploadRecord(@RequestParam int pageNum, @RequestParam int pageSize) {
return edFileInfoService.uploadRecord(pageNum, pageSize, DataOwnEnum.SYS_FILE.code); return edFileInfoService.uploadRecord(pageNum, pageSize, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "查询文件详细信息", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "查询文件详细信息", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.VIEW) @RequiredPermission(value = FilePermission.VIEW)
@RequestMapping(value = "/fileDetail", method = RequestMethod.GET) @RequestMapping(value = "/fileDetail", method = RequestMethod.GET)
public ElectromagneticResult<?> detail(@RequestParam String id) { public ElectromagneticResult<?> detail(@RequestParam String id) {
return edFileInfoService.detail(id); return edFileInfoService.detail(id);
} }
@UserOperation(value = "查询子文件集", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "查询子文件集", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.VIEW) @RequiredPermission(value = FilePermission.VIEW)
@RequestMapping(value = "/queryChildFolder", method = RequestMethod.GET) @RequestMapping(value = "/queryChildFolder", method = RequestMethod.GET)
public ElectromagneticResult<?> queryChildFolder(@RequestParam String parentId) { public ElectromagneticResult<?> queryChildFolder(@RequestParam String parentId) {
return edFileInfoService.queryChildFolder(parentId, DataOwnEnum.SYS_FILE.code); return edFileInfoService.queryChildFolder(parentId, DataOwnEnum.SYS_FILE.code);
} }
@UserOperation(value = "预览文件", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "预览文件", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.DOWNLOAD) @RequiredPermission(value = FilePermission.DOWNLOAD)
@RequestMapping(value = "preview", method = RequestMethod.GET) @RequestMapping(value = "preview", method = RequestMethod.GET)
public ResponseEntity<InputStreamResource> preview(@RequestParam String id, HttpServletResponse response) { public ResponseEntity<InputStreamResource> preview(@RequestParam String id, HttpServletResponse response) {
@ -171,7 +171,7 @@ public class EdFileInfoController {
* @return * @return
*/ */
@GetMapping("/collection") @GetMapping("/collection")
@UserOperation(value = "收藏了文件", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "收藏了文件", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> addFavorite(@RequestParam String id) { public ElectromagneticResult<?> addFavorite(@RequestParam String id) {
String userId = UserThreadLocal.getUserId(); String userId = UserThreadLocal.getUserId();
return ElectromagneticResultUtil.success(edFileInfoService.addFavorite(userId, id)); return ElectromagneticResultUtil.success(edFileInfoService.addFavorite(userId, id));
@ -184,7 +184,7 @@ public class EdFileInfoController {
* @return * @return
*/ */
@GetMapping("/removeCollection") @GetMapping("/removeCollection")
@UserOperation(value = "从收藏夹移除了文件", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "从收藏夹移除了文件", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> removeFavorite(@RequestParam String id) { public ElectromagneticResult<?> removeFavorite(@RequestParam String id) {
String userId = UserThreadLocal.getUserId(); String userId = UserThreadLocal.getUserId();
return ElectromagneticResultUtil.success(edFileInfoService.removeFavorite(userId, id)); return ElectromagneticResultUtil.success(edFileInfoService.removeFavorite(userId, id));
@ -196,7 +196,7 @@ public class EdFileInfoController {
* @return * @return
*/ */
@PostMapping("/listCollection") @PostMapping("/listCollection")
@UserOperation(value = "查看了收藏夹", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "查看了收藏夹", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> listFavorite(@RequestBody FileInfoQueryDTO fileInfoQueryDTO) { public ElectromagneticResult<?> listFavorite(@RequestBody FileInfoQueryDTO fileInfoQueryDTO) {
String userId = UserThreadLocal.getUserId(); String userId = UserThreadLocal.getUserId();
return ElectromagneticResultUtil.success(edFileInfoService.findFavorite(userId, fileInfoQueryDTO)); return ElectromagneticResultUtil.success(edFileInfoService.findFavorite(userId, fileInfoQueryDTO));

View File

@ -30,7 +30,7 @@ public class EdFileRelationController {
* @return * @return
*/ */
@RequestMapping(value = "/create", method = RequestMethod.POST) @RequestMapping(value = "/create", method = RequestMethod.POST)
@UserOperation(value = "创建了文件关系", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "创建了文件关系", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> createRelation(@RequestBody EdFileRelation relation) { public ElectromagneticResult<?> createRelation(@RequestBody EdFileRelation relation) {
return ElectromagneticResultUtil.success(edFileRelationService.createRelation(relation)); return ElectromagneticResultUtil.success(edFileRelationService.createRelation(relation));
} }
@ -42,7 +42,7 @@ public class EdFileRelationController {
* @return * @return
*/ */
@RequestMapping(value = "/update", method = RequestMethod.POST) @RequestMapping(value = "/update", method = RequestMethod.POST)
@UserOperation(value = "更新了文件关系", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "更新了文件关系", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> updateRelation(@RequestBody UpdateRelationDTO updateRelation) { public ElectromagneticResult<?> updateRelation(@RequestBody UpdateRelationDTO updateRelation) {
LambdaUpdateWrapper<EdFileRelation> wrapper = new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<EdFileRelation> wrapper = new LambdaUpdateWrapper<>();
wrapper.eq(EdFileRelation::getId, updateRelation.getRelationId()).set(EdFileRelation::getRelationship, updateRelation.getRelationship()); wrapper.eq(EdFileRelation::getId, updateRelation.getRelationId()).set(EdFileRelation::getRelationship, updateRelation.getRelationship());
@ -60,7 +60,7 @@ public class EdFileRelationController {
* @return * @return
*/ */
@RequestMapping(value = "/cancel/{relationId}", method = RequestMethod.GET) @RequestMapping(value = "/cancel/{relationId}", method = RequestMethod.GET)
@UserOperation(value = "取消了文件关系", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "取消了文件关系", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> cancelRelation(@PathVariable("relationId") String relationId) { public ElectromagneticResult<?> cancelRelation(@PathVariable("relationId") String relationId) {
return ElectromagneticResultUtil.success(edFileRelationService.cancelRelation(relationId)); return ElectromagneticResultUtil.success(edFileRelationService.cancelRelation(relationId));
} }
@ -69,7 +69,7 @@ public class EdFileRelationController {
* 展示文件关系 * 展示文件关系
*/ */
@RequestMapping(value = "listRelations/{id}", method = RequestMethod.GET) @RequestMapping(value = "listRelations/{id}", method = RequestMethod.GET)
@UserOperation(value = "查看了文件关系", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "查看了文件关系", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> listRelations(@PathVariable("id") String id) { public ElectromagneticResult<?> listRelations(@PathVariable("id") String id) {
return ElectromagneticResultUtil.success(edFileRelationService.listRelations(id)); return ElectromagneticResultUtil.success(edFileRelationService.listRelations(id));
} }
@ -78,7 +78,7 @@ public class EdFileRelationController {
* 检验文件名是否唯一 * 检验文件名是否唯一
*/ */
@RequestMapping(value = "/checkFileNameExist", method = RequestMethod.POST) @RequestMapping(value = "/checkFileNameExist", method = RequestMethod.POST)
@UserOperation(value = "校验文件名唯一性", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "校验文件名唯一性", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> checkFileNameExist(@RequestBody CheckNameUniqueRequest checkNameUniqueRequest) { public ElectromagneticResult<?> checkFileNameExist(@RequestBody CheckNameUniqueRequest checkNameUniqueRequest) {
return ElectromagneticResultUtil.success(edFileRelationService.checkNameExist(checkNameUniqueRequest)); return ElectromagneticResultUtil.success(edFileRelationService.checkNameExist(checkNameUniqueRequest));
} }
@ -87,7 +87,7 @@ public class EdFileRelationController {
* 本地上传并建立关系 * 本地上传并建立关系
*/ */
@RequestMapping(value = "/upload", method = RequestMethod.POST) @RequestMapping(value = "/upload", method = RequestMethod.POST)
@UserOperation(value = "上传了文件并创建了文件关系", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "上传了文件并创建了文件关系", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> uploadRelation(@RequestParam("parentId") String parentId, public ElectromagneticResult<?> uploadRelation(@RequestParam("parentId") String parentId,
@RequestParam("file") MultipartFile file, @RequestParam("file") MultipartFile file,
@RequestParam("description") String description, @RequestParam("description") String description,

View File

@ -20,19 +20,19 @@ public class FileFormatController {
private FileFormatService fileFormatService; private FileFormatService fileFormatService;
@GetMapping("/add") @GetMapping("/add")
@UserOperation(value = "新增文件格式", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "新增文件格式", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> addFileFormat(@RequestParam String suffixName) { public ElectromagneticResult<?> addFileFormat(@RequestParam String suffixName) {
return ElectromagneticResultUtil.success(fileFormatService.addFileFormat(suffixName)); return ElectromagneticResultUtil.success(fileFormatService.addFileFormat(suffixName));
} }
@GetMapping("/delete") @GetMapping("/delete")
@UserOperation(value = "删除文件格式", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "删除文件格式", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> deleteFileFormat(@RequestParam String id) { public ElectromagneticResult<?> deleteFileFormat(@RequestParam String id) {
return ElectromagneticResultUtil.success(fileFormatService.deleteFileFormat(id)); return ElectromagneticResultUtil.success(fileFormatService.deleteFileFormat(id));
} }
@GetMapping("/list") @GetMapping("/list")
@UserOperation(value = "查询文件格式列表", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "查询文件格式列表", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> list() { public ElectromagneticResult<?> list() {
return ElectromagneticResultUtil.success(fileFormatService.getList()); return ElectromagneticResultUtil.success(fileFormatService.getList());
} }

View File

@ -20,19 +20,19 @@ public class FileRecycleController {
private FileRecycleService fileRecycleService; private FileRecycleService fileRecycleService;
@RequestMapping("list") @RequestMapping("list")
@UserOperation(value = "查看回收站", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "查看回收站", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> list(@RequestBody RecycleFileQueryDTO pars) { public ElectromagneticResult<?> list(@RequestBody RecycleFileQueryDTO pars) {
return fileRecycleService.list(pars); return fileRecycleService.list(pars);
} }
@RequestMapping("remove") @RequestMapping("remove")
@UserOperation(value = "彻底清除文件", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "彻底清除文件", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> remove(@RequestParam String fileId) { public ElectromagneticResult<?> remove(@RequestParam String fileId) {
return fileRecycleService.remove(fileId); return fileRecycleService.remove(fileId);
} }
@RequestMapping("recover") @RequestMapping("recover")
@UserOperation(value = "文件恢复", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "文件恢复", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> recover(@RequestParam String fileId) { public ElectromagneticResult<?> recover(@RequestParam String fileId) {
return fileRecycleService.recover(fileId); return fileRecycleService.recover(fileId);
} }

View File

@ -28,55 +28,55 @@ public class ProjectController {
@Resource @Resource
private PermissionService permissionService; private PermissionService permissionService;
@UserOperation(value = "创建层级", modelName = UserOperationModuleEnum.PRJ_SETTING) @UserOperation(value = "创建层级", modelName = UserOperationModuleEnum.SYS_PRJ_SETTING)
@RequestMapping("create") @RequestMapping("create")
public ElectromagneticResult<?> create(@RequestParam String prjName) { public ElectromagneticResult<?> create(@RequestParam String prjName) {
return edPrjService.createNewPrj(prjName, DataOwnEnum.SYS_PRJ.code); return edPrjService.createNewPrj(prjName, DataOwnEnum.SYS_PRJ.code);
} }
@UserOperation(value = "删除层级", modelName = UserOperationModuleEnum.PRJ_SETTING) @UserOperation(value = "删除层级", modelName = UserOperationModuleEnum.SYS_PRJ_SETTING)
@RequestMapping("delete") @RequestMapping("delete")
public ElectromagneticResult<?> delete(@RequestParam String prjId) { public ElectromagneticResult<?> delete(@RequestParam String prjId) {
return edPrjService.delete(prjId, DataOwnEnum.SYS_PRJ.code); return edPrjService.delete(prjId, DataOwnEnum.SYS_PRJ.code);
} }
@UserOperation(value = "修改层级名", modelName = UserOperationModuleEnum.PRJ_SETTING) @UserOperation(value = "修改层级名", modelName = UserOperationModuleEnum.SYS_PRJ_SETTING)
@RequestMapping("modify") @RequestMapping("modify")
public ElectromagneticResult<?> modifyPrjName(@RequestParam String newPrjName, @RequestParam String prjId) { public ElectromagneticResult<?> modifyPrjName(@RequestParam String newPrjName, @RequestParam String prjId) {
return edPrjService.modifyPrjName(prjId, newPrjName, DataOwnEnum.SYS_PRJ.code); return edPrjService.modifyPrjName(prjId, newPrjName, DataOwnEnum.SYS_PRJ.code);
} }
@UserOperation(value = "查询所有层级", modelName = UserOperationModuleEnum.PRJ_SETTING) @UserOperation(value = "查询所有层级", modelName = UserOperationModuleEnum.SYS_PRJ_SETTING)
@RequestMapping("queryAll") @RequestMapping("queryAll")
public ElectromagneticResult<?> queryAll() { public ElectromagneticResult<?> queryAll() {
return edPrjService.queryAllPrjInfo(PrjQuerySource.SYS_PRJ.value); return edPrjService.queryAllPrjInfo(PrjQuerySource.SYS_PRJ.value);
} }
@UserOperation(value = "添加子集", modelName = UserOperationModuleEnum.PRJ_SETTING) @UserOperation(value = "添加子集", modelName = UserOperationModuleEnum.SYS_PRJ_SETTING)
@RequestMapping("addFolder") @RequestMapping("addFolder")
public ElectromagneticResult<?> addFolder(@RequestParam String folderName, @RequestParam String parentId) { public ElectromagneticResult<?> addFolder(@RequestParam String folderName, @RequestParam String parentId) {
return edPrjService.addFolder(parentId, folderName, DataOwnEnum.SYS_PRJ.code); return edPrjService.addFolder(parentId, folderName, DataOwnEnum.SYS_PRJ.code);
} }
@UserOperation(value = "修改子集名称", modelName = UserOperationModuleEnum.PRJ_SETTING) @UserOperation(value = "修改子集名称", modelName = UserOperationModuleEnum.SYS_PRJ_SETTING)
@RequestMapping("modifyFolder") @RequestMapping("modifyFolder")
public ElectromagneticResult<?> modifyFolder(@RequestParam String newFolderName, @RequestParam String id) { public ElectromagneticResult<?> modifyFolder(@RequestParam String newFolderName, @RequestParam String id) {
return edPrjService.modifyFolder(id, newFolderName, DataOwnEnum.SYS_PRJ.code); return edPrjService.modifyFolder(id, newFolderName, DataOwnEnum.SYS_PRJ.code);
} }
@UserOperation(value = "废除子集", modelName = UserOperationModuleEnum.PRJ_SETTING) @UserOperation(value = "废除子集", modelName = UserOperationModuleEnum.SYS_PRJ_SETTING)
@RequestMapping("deleteFolder") @RequestMapping("deleteFolder")
public ElectromagneticResult<?> deleteFolder(@RequestParam String id) { public ElectromagneticResult<?> deleteFolder(@RequestParam String id) {
return edPrjService.deleteFolder(id, DataOwnEnum.SYS_PRJ.code); return edPrjService.deleteFolder(id, DataOwnEnum.SYS_PRJ.code);
} }
@UserOperation(value = "更改层级顺序", modelName = UserOperationModuleEnum.PRJ_SETTING) @UserOperation(value = "更改层级顺序", modelName = UserOperationModuleEnum.SYS_PRJ_SETTING)
@RequestMapping("folderResort") @RequestMapping("folderResort")
public ElectromagneticResult<?> folderResort(@RequestBody List<FolderResortDTO> folderResortDTOList) { public ElectromagneticResult<?> folderResort(@RequestBody List<FolderResortDTO> folderResortDTOList) {
return edPrjService.folderResort(folderResortDTOList); return edPrjService.folderResort(folderResortDTOList);
} }
@UserOperation(value = "发布层级", modelName = UserOperationModuleEnum.PRJ_SETTING) @UserOperation(value = "发布层级", modelName = UserOperationModuleEnum.SYS_PRJ_SETTING)
@RequestMapping("publish") @RequestMapping("publish")
public ElectromagneticResult<?> publish(@RequestParam String prjId) { public ElectromagneticResult<?> publish(@RequestParam String prjId) {
edPrjService.publish(prjId, DataOwnEnum.SYS_PRJ.code); edPrjService.publish(prjId, DataOwnEnum.SYS_PRJ.code);
@ -85,13 +85,13 @@ public class ProjectController {
return ElectromagneticResultUtil.success(true); return ElectromagneticResultUtil.success(true);
} }
@UserOperation(value = "引用层级", modelName = UserOperationModuleEnum.PRJ_SETTING) @UserOperation(value = "引用层级", modelName = UserOperationModuleEnum.SYS_PRJ_SETTING)
@RequestMapping("follow") @RequestMapping("follow")
public ElectromagneticResult<?> follow(@RequestParam String sourceId, @RequestParam String targetId) { public ElectromagneticResult<?> follow(@RequestParam String sourceId, @RequestParam String targetId) {
return edPrjService.follow(sourceId, targetId, DataOwnEnum.SYS_PRJ.code); return edPrjService.follow(sourceId, targetId, DataOwnEnum.SYS_PRJ.code);
} }
@UserOperation(value = "查询层级发布状态", modelName = UserOperationModuleEnum.PRJ_SETTING) @UserOperation(value = "查询层级发布状态", modelName = UserOperationModuleEnum.SYS_PRJ_SETTING)
@RequestMapping("publishStatus") @RequestMapping("publishStatus")
public ElectromagneticResult<?> publishStatus(@RequestBody QueryPublishStatus queryPublishStatus) { public ElectromagneticResult<?> publishStatus(@RequestBody QueryPublishStatus queryPublishStatus) {
return edPrjService.publishStatus(queryPublishStatus, DataOwnEnum.SYS_PRJ.code); return edPrjService.publishStatus(queryPublishStatus, DataOwnEnum.SYS_PRJ.code);

View File

@ -0,0 +1,204 @@
package com.electromagnetic.industry.software.manage.controller;
import com.electromagnetic.industry.software.common.annotations.RequiredPermission;
import com.electromagnetic.industry.software.common.annotations.UserOperation;
import com.electromagnetic.industry.software.common.enums.DataOwnEnum;
import com.electromagnetic.industry.software.common.enums.FilePermission;
import com.electromagnetic.industry.software.common.enums.PrjQuerySource;
import com.electromagnetic.industry.software.common.enums.UserOperationModuleEnum;
import com.electromagnetic.industry.software.common.resp.ElectromagneticResult;
import com.electromagnetic.industry.software.common.util.ElectromagneticResultUtil;
import com.electromagnetic.industry.software.common.util.UserThreadLocal;
import com.electromagnetic.industry.software.manage.pojo.req.CreateFolderDTO;
import com.electromagnetic.industry.software.manage.pojo.req.FileChunkDTO;
import com.electromagnetic.industry.software.manage.pojo.req.FileInfoQueryDTO;
import com.electromagnetic.industry.software.manage.pojo.req.UpdateFileInfoDTO;
import com.electromagnetic.industry.software.manage.service.EdFileInfoService;
import org.springframework.core.io.InputStreamResource;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
@RestController
@RequestMapping("/data/ed/repo/file")
public class RepoEdFileInfoController {
@Resource
private EdFileInfoService edFileInfoService;
@UserOperation(value = "查看工程树", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequestMapping("tree")
public ElectromagneticResult<?> tree() {
return edFileInfoService.tree(PrjQuerySource.REPO_DB.value);
}
@UserOperation(value = "创建文件夹", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequestMapping("createFolder")
public ElectromagneticResult<?> createFolder(@RequestBody CreateFolderDTO createFolderDTO) {
return edFileInfoService.createFolder(createFolderDTO, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "作废", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.DELETE)
@RequestMapping("delete")
public ElectromagneticResult<?> delete(@RequestParam String id) {
return edFileInfoService.delete(id, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "查询文件", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.VIEW)
@RequestMapping("info")
public ElectromagneticResult<?> info(@RequestBody FileInfoQueryDTO fileInfoQueryDTO) {
return edFileInfoService.queryEdFileInfo(fileInfoQueryDTO, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "上传文件", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.UPLOAD)
@RequestMapping("upload")
public ElectromagneticResult<?> upload(@RequestParam("parentId") String parentId,
@RequestParam("file") MultipartFile file,
@RequestParam("strategy") Integer strategy) {
return edFileInfoService.upload(parentId, file, strategy, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "下载文件", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.DOWNLOAD)
@RequestMapping("download")
public ResponseEntity<InputStreamResource> download(@RequestParam String id, HttpServletResponse response) {
return edFileInfoService.download(id, response, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "更新文件信息", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.EDIT)
@RequestMapping("updateFileInfo")
public ElectromagneticResult<?> updateFileInfo(@RequestBody UpdateFileInfoDTO updateFileInfoDTO) {
return edFileInfoService.updateFileInfo(updateFileInfoDTO, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "移动文件", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.MOVE)
@RequestMapping("moveFile")
public ElectromagneticResult<?> moveFile(@RequestParam("id") String id,
@RequestParam("targetFolderId") String targetFolderId,
@RequestParam("strategy") Integer strategy) {
return edFileInfoService.moveFile(id, targetFolderId, strategy, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "复制文件", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.MOVE)
@RequestMapping("copyFile")
public ElectromagneticResult<?> copyFile(@RequestParam("id") String id,
@RequestParam("targetFolderId") String targetFolderId,
@RequestParam("strategy") Integer strategy) {
return edFileInfoService.copyFile(id, targetFolderId, strategy, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "查看文件历史版本信息", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.VIEW)
@RequestMapping("versionView")
public ElectromagneticResult<?> versionView(@RequestParam String fileId) {
return edFileInfoService.versionView(fileId);
}
@UserOperation(value = "回退版本", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.EDIT)
@RequestMapping("versionBack")
public ElectromagneticResult<?> versionBack(@RequestParam String fileId, @RequestParam int targetVersion) {
return edFileInfoService.versionBack(fileId, targetVersion);
}
@UserOperation(value = "导出数据库", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequestMapping("batchExport")
public ResponseEntity<InputStreamResource> batchExport(@RequestParam String fileIds, HttpServletResponse response) throws IOException {
return edFileInfoService.batchExport(fileIds, response, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "批量上传数据库", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequestMapping(value = "/mergeChunks", method = RequestMethod.GET)
public ElectromagneticResult<?> mergeChunks(@RequestParam String identifier,
@RequestParam String fileName,
@RequestParam Integer totalChunks) {
return edFileInfoService.mergeChunks(identifier, fileName, totalChunks, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "批量上传数据库", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequestMapping(value = "/batchImport", method = RequestMethod.POST)
public ElectromagneticResult<?> batchImport(FileChunkDTO fileChunkDTO) {
return edFileInfoService.batchImport(fileChunkDTO);
}
@UserOperation(value = "批量上传数据库")
@RequestMapping(value = "/batchImport", method = RequestMethod.GET)
public ElectromagneticResult<?> checkChunkExist(FileChunkDTO fileChunkDTO) {
return edFileInfoService.checkChunkExist(fileChunkDTO);
}
@UserOperation(value = "查询发布管理", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequestMapping(value = "/uploadRecord", method = RequestMethod.GET)
public ElectromagneticResult<?> uploadRecord(@RequestParam int pageNum, @RequestParam int pageSize) {
return edFileInfoService.uploadRecord(pageNum, pageSize, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "查询文件详细信息", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.VIEW)
@RequestMapping(value = "/fileDetail", method = RequestMethod.GET)
public ElectromagneticResult<?> detail(@RequestParam String id) {
return edFileInfoService.detail(id);
}
@UserOperation(value = "查询子文件集", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.VIEW)
@RequestMapping(value = "/queryChildFolder", method = RequestMethod.GET)
public ElectromagneticResult<?> queryChildFolder(@RequestParam String parentId) {
return edFileInfoService.queryChildFolder(parentId, DataOwnEnum.SYS_FILE.code);
}
@UserOperation(value = "预览文件", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
@RequiredPermission(value = FilePermission.DOWNLOAD)
@RequestMapping(value = "preview", method = RequestMethod.GET)
public ResponseEntity<InputStreamResource> preview(@RequestParam String id, HttpServletResponse response) {
return edFileInfoService.preview(id, response, DataOwnEnum.SYS_FILE.code);
}
/**
* 添加进收藏夹
*
* @param id 文件id
* @return
*/
@GetMapping("/collection")
@UserOperation(value = "收藏了文件", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
public ElectromagneticResult<?> addFavorite(@RequestParam String id) {
String userId = UserThreadLocal.getUserId();
return ElectromagneticResultUtil.success(edFileInfoService.addFavorite(userId, id));
}
/**
* 从收藏夹移除
*
* @param id 文件id
* @return
*/
@GetMapping("/removeCollection")
@UserOperation(value = "从收藏夹移除了文件", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
public ElectromagneticResult<?> removeFavorite(@RequestParam String id) {
String userId = UserThreadLocal.getUserId();
return ElectromagneticResultUtil.success(edFileInfoService.removeFavorite(userId, id));
}
/**
* 展示当前用户收藏夹文件
*
* @return
*/
@PostMapping("/listCollection")
@UserOperation(value = "查看了收藏夹", modelName = UserOperationModuleEnum.REPO_PRJ_DATABASE)
public ElectromagneticResult<?> listFavorite(@RequestBody FileInfoQueryDTO fileInfoQueryDTO) {
String userId = UserThreadLocal.getUserId();
return ElectromagneticResultUtil.success(edFileInfoService.findFavorite(userId, fileInfoQueryDTO));
}
}

View File

@ -0,0 +1,91 @@
package com.electromagnetic.industry.software.manage.controller;
import com.electromagnetic.industry.software.common.annotations.UserOperation;
import com.electromagnetic.industry.software.common.enums.DataOwnEnum;
import com.electromagnetic.industry.software.common.enums.PrjQuerySource;
import com.electromagnetic.industry.software.common.enums.UserOperationModuleEnum;
import com.electromagnetic.industry.software.common.resp.ElectromagneticResult;
import com.electromagnetic.industry.software.manage.pojo.req.FolderResortDTO;
import com.electromagnetic.industry.software.manage.pojo.req.QueryPublishStatus;
import com.electromagnetic.industry.software.manage.service.EdPrjService;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
@RestController
@RequestMapping("/data/ed/repo/prj")
public class RepoPrjController {
@Resource
private EdPrjService edPrjService;
@UserOperation(value = "创建层级", modelName = UserOperationModuleEnum.REPO_PRJ_SETTING)
@RequestMapping("create")
public ElectromagneticResult<?> create(@RequestParam String prjName) {
return edPrjService.createNewPrj(prjName, DataOwnEnum.USER_PRJ.code);
}
@UserOperation(value = "删除层级", modelName = UserOperationModuleEnum.REPO_PRJ_SETTING)
@RequestMapping("delete")
public ElectromagneticResult<?> delete(@RequestParam String prjId) {
return edPrjService.delete(prjId, DataOwnEnum.REPO_PRJ.code);
}
@UserOperation(value = "修改层级名", modelName = UserOperationModuleEnum.REPO_PRJ_SETTING)
@RequestMapping("modify")
public ElectromagneticResult<?> modifyPrjName(@RequestParam String newPrjName, @RequestParam String prjId) {
return edPrjService.modifyPrjName(prjId, newPrjName, DataOwnEnum.REPO_PRJ.code);
}
@UserOperation(value = "查询所有层级", modelName = UserOperationModuleEnum.REPO_PRJ_SETTING)
@RequestMapping("queryAll")
public ElectromagneticResult<?> queryAll() {
return edPrjService.queryAllPrjInfo(PrjQuerySource.REPO_PRJ.value);
}
@UserOperation(value = "添加子集", modelName = UserOperationModuleEnum.REPO_PRJ_SETTING)
@RequestMapping("addFolder")
public ElectromagneticResult<?> addFolder(@RequestParam String folderName, @RequestParam String parentId) {
return edPrjService.addFolder(parentId, folderName, DataOwnEnum.REPO_PRJ.code);
}
@UserOperation(value = "修改子集名称", modelName = UserOperationModuleEnum.REPO_PRJ_SETTING)
@RequestMapping("modifyFolder")
public ElectromagneticResult<?> modifyFolder(@RequestParam String newFolderName, @RequestParam String id) {
return edPrjService.modifyFolder(id, newFolderName, DataOwnEnum.REPO_PRJ.code);
}
@UserOperation(value = "废除子集", modelName = UserOperationModuleEnum.REPO_PRJ_SETTING)
@RequestMapping("deleteFolder")
public ElectromagneticResult<?> deleteFolder(@RequestParam String id) {
return edPrjService.deleteFolder(id, DataOwnEnum.REPO_PRJ.code);
}
@UserOperation(value = "更改层级顺序", modelName = UserOperationModuleEnum.REPO_PRJ_SETTING)
@RequestMapping("folderResort")
public ElectromagneticResult<?> folderResort(@RequestBody List<FolderResortDTO> folderResortDTOList) {
return edPrjService.folderResort(folderResortDTOList);
}
@UserOperation(value = "发布层级", modelName = UserOperationModuleEnum.REPO_PRJ_SETTING)
@RequestMapping("publish")
public ElectromagneticResult<?> publish(@RequestParam String prjId) {
return edPrjService.publish(prjId, DataOwnEnum.REPO_PRJ.code);
}
@UserOperation(value = "引用层级", modelName = UserOperationModuleEnum.REPO_PRJ_SETTING)
@RequestMapping("follow")
public ElectromagneticResult<?> follow(@RequestParam String sourceId, @RequestParam String targetId) {
return edPrjService.follow(sourceId, targetId, DataOwnEnum.REPO_PRJ.code);
}
@UserOperation(value = "查询层级发布状态", modelName = UserOperationModuleEnum.REPO_PRJ_SETTING)
@RequestMapping("publishStatus")
public ElectromagneticResult<?> publishStatus(@RequestBody QueryPublishStatus queryPublishStatus) {
return edPrjService.publishStatus(queryPublishStatus, DataOwnEnum.REPO_PRJ.code);
}
}

View File

@ -30,7 +30,7 @@ public class UserEdFileRelationController {
* @return * @return
*/ */
@RequestMapping(value = "/create", method = RequestMethod.POST) @RequestMapping(value = "/create", method = RequestMethod.POST)
@UserOperation(value = "创建文件关系", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "创建文件关系", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> createRelation(@RequestBody EdFileRelation relation) { public ElectromagneticResult<?> createRelation(@RequestBody EdFileRelation relation) {
return ElectromagneticResultUtil.success(edFileRelationService.createRelation(relation)); return ElectromagneticResultUtil.success(edFileRelationService.createRelation(relation));
} }
@ -42,7 +42,7 @@ public class UserEdFileRelationController {
* @return * @return
*/ */
@RequestMapping(value = "/update", method = RequestMethod.POST) @RequestMapping(value = "/update", method = RequestMethod.POST)
@UserOperation(value = "更新文件关系", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "更新文件关系", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> updateRelation(@RequestBody UpdateRelationDTO updateRelation) { public ElectromagneticResult<?> updateRelation(@RequestBody UpdateRelationDTO updateRelation) {
LambdaUpdateWrapper<EdFileRelation> wrapper = new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<EdFileRelation> wrapper = new LambdaUpdateWrapper<>();
wrapper.eq(EdFileRelation::getId, updateRelation.getRelationId()).set(EdFileRelation::getRelationship, updateRelation.getRelationship()); wrapper.eq(EdFileRelation::getId, updateRelation.getRelationId()).set(EdFileRelation::getRelationship, updateRelation.getRelationship());
@ -60,7 +60,7 @@ public class UserEdFileRelationController {
* @return * @return
*/ */
@RequestMapping(value = "/cancel/{relationId}", method = RequestMethod.GET) @RequestMapping(value = "/cancel/{relationId}", method = RequestMethod.GET)
@UserOperation(value = "取消文件关系", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "取消文件关系", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> cancelRelation(@PathVariable("relationId") String relationId) { public ElectromagneticResult<?> cancelRelation(@PathVariable("relationId") String relationId) {
return ElectromagneticResultUtil.success(edFileRelationService.cancelRelation(relationId)); return ElectromagneticResultUtil.success(edFileRelationService.cancelRelation(relationId));
} }
@ -69,7 +69,7 @@ public class UserEdFileRelationController {
* 展示文件关系 * 展示文件关系
*/ */
@RequestMapping(value = "listRelations/{id}", method = RequestMethod.GET) @RequestMapping(value = "listRelations/{id}", method = RequestMethod.GET)
@UserOperation(value = "查看文件关系", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "查看文件关系", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> listRelations(@PathVariable("id") String id) { public ElectromagneticResult<?> listRelations(@PathVariable("id") String id) {
return ElectromagneticResultUtil.success(edFileRelationService.listRelations(id)); return ElectromagneticResultUtil.success(edFileRelationService.listRelations(id));
} }
@ -78,7 +78,7 @@ public class UserEdFileRelationController {
* 检验文件名是否唯一 * 检验文件名是否唯一
*/ */
@RequestMapping(value = "/checkFileNameExist", method = RequestMethod.POST) @RequestMapping(value = "/checkFileNameExist", method = RequestMethod.POST)
@UserOperation(value = "校验文件名唯一性", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "校验文件名唯一性", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> checkFileNameExist(@RequestBody CheckNameUniqueRequest checkNameUniqueRequest) { public ElectromagneticResult<?> checkFileNameExist(@RequestBody CheckNameUniqueRequest checkNameUniqueRequest) {
return ElectromagneticResultUtil.success(edFileRelationService.checkNameExist(checkNameUniqueRequest)); return ElectromagneticResultUtil.success(edFileRelationService.checkNameExist(checkNameUniqueRequest));
} }
@ -87,7 +87,7 @@ public class UserEdFileRelationController {
* 本地上传并建立关系 * 本地上传并建立关系
*/ */
@RequestMapping(value = "/upload", method = RequestMethod.POST) @RequestMapping(value = "/upload", method = RequestMethod.POST)
@UserOperation(value = "上传了文件并创建文件关系", modelName = UserOperationModuleEnum.DATABASE) @UserOperation(value = "上传了文件并创建文件关系", modelName = UserOperationModuleEnum.SYS_PRJ_DATABASE)
public ElectromagneticResult<?> uploadRelation(@RequestParam("parentId") String parentId, public ElectromagneticResult<?> uploadRelation(@RequestParam("parentId") String parentId,
@RequestParam("file") MultipartFile file, @RequestParam("file") MultipartFile file,
@RequestParam("description") String description, @RequestParam("description") String description,

View File

@ -261,10 +261,10 @@ public class CommonService {
* *
* @param querySource 0询管理员从层级定义处查 2.用户从数据库管理界面查询 * @param querySource 0询管理员从层级定义处查 2.用户从数据库管理界面查询
* @param accessibleIds * @param accessibleIds
* @param obj * @param returnType
* @return * @return
*/ */
public Map<Integer, List<String>> querySysPrjTree(int querySource, List<String> accessibleIds, Object obj) { public Map<Integer, List<String>> querySysPrjTree(int querySource, List<String> accessibleIds, Object returnType) {
/** /**
* querySource=SYS_PRJ从层级定义处查询 querySource=SYS_DB从数据库界面处查询 * querySource=SYS_PRJ从层级定义处查询 querySource=SYS_DB从数据库界面处查询
@ -308,7 +308,7 @@ public class CommonService {
prjQueryWrapper.ne(EdFileInfo::getDataStatus, EleDataStatusEnum.WAIT_DELETED.code); prjQueryWrapper.ne(EdFileInfo::getDataStatus, EleDataStatusEnum.WAIT_DELETED.code);
} }
List<EdFileInfo> edFileInfos = edFileInfoMapper.selectList(prjQueryWrapper); List<EdFileInfo> edFileInfos = edFileInfoMapper.selectList(prjQueryWrapper);
String jsonTree = createTree(edFileInfos, obj); String jsonTree = createTree(edFileInfos, returnType);
List<String> list = map.getOrDefault(querySource, new ArrayList<>()); List<String> list = map.getOrDefault(querySource, new ArrayList<>());
list.add(jsonTree); list.add(jsonTree);
map.put(querySource, list); map.put(querySource, list);
@ -321,7 +321,7 @@ public class CommonService {
return map; return map;
} }
public Map<Integer, List<String>> queryUserPrjTree(int querySource, Object object) { public Map<Integer, List<String>> queryUserPrjTree(int querySource, Object returnType) {
Map<Integer, List<String>> map = new HashMap<>(); Map<Integer, List<String>> map = new HashMap<>();
try { try {
@ -329,6 +329,7 @@ public class CommonService {
LambdaQueryWrapper<EdFileInfo> queryWrapper = Wrappers.lambdaQuery(EdFileInfo.class) LambdaQueryWrapper<EdFileInfo> queryWrapper = Wrappers.lambdaQuery(EdFileInfo.class)
.select(EdFileInfo::getId) .select(EdFileInfo::getId)
.eq(EdFileInfo::getEffectFlag, EffectFlagEnum.EFFECT.code) .eq(EdFileInfo::getEffectFlag, EffectFlagEnum.EFFECT.code)
.eq(EdFileInfo::getDataOwn, DataOwnEnum.USER_PRJ.code)
.eq(EdFileInfo::getCreatedBy, UserThreadLocal.getUserId()) .eq(EdFileInfo::getCreatedBy, UserThreadLocal.getUserId())
.eq(EdFileInfo::getParentId, PRJ_PARENT_ID); .eq(EdFileInfo::getParentId, PRJ_PARENT_ID);
List<String> prjIds = edFileInfoMapper.selectList(queryWrapper).stream().map(EdFileInfo::getId).collect(Collectors.toList()); List<String> prjIds = edFileInfoMapper.selectList(queryWrapper).stream().map(EdFileInfo::getId).collect(Collectors.toList());
@ -349,7 +350,49 @@ public class CommonService {
} }
List<EdFileInfo> edFileInfos = edFileInfoMapper.selectList(prjQueryWrapper); List<EdFileInfo> edFileInfos = edFileInfoMapper.selectList(prjQueryWrapper);
String jsonTree = createTree(edFileInfos, object); String jsonTree = createTree(edFileInfos, returnType);
List<String> list = map.getOrDefault(querySource, new ArrayList<>());
list.add(jsonTree);
map.put(querySource, list);
}
} catch (Exception e) {
String info = "查询用户层级信息失败";
log.error(info, e);
throw new BizException(info);
}
return map;
}
public Map<Integer, List<String>> queryRepoPrjTree(int querySource, Object returnType) {
Map<Integer, List<String>> map = new HashMap<>();
try {
// 首先查出所有的工程id
LambdaQueryWrapper<EdFileInfo> queryWrapper = Wrappers.lambdaQuery(EdFileInfo.class)
.select(EdFileInfo::getId)
.eq(EdFileInfo::getDataOwn, DataOwnEnum.REPO_PRJ.code)
.eq(EdFileInfo::getEffectFlag, EffectFlagEnum.EFFECT.code)
.eq(EdFileInfo::getCreatedBy, UserThreadLocal.getUserId())
.eq(EdFileInfo::getParentId, PRJ_PARENT_ID);
List<String> prjIds = edFileInfoMapper.selectList(queryWrapper).stream().map(EdFileInfo::getId).collect(Collectors.toList());
for (String id : prjIds) {
LambdaQueryWrapper<EdFileInfo> prjQueryWrapper = Wrappers.lambdaQuery(EdFileInfo.class)
.eq(EdFileInfo::getDataOwn, DataOwnEnum.REPO_PRJ.code)
.eq(EdFileInfo::getEffectFlag, EffectFlagEnum.EFFECT.code)
.eq(EdFileInfo::getDataType, EleDataTypeEnum.FOLDER.code)
.likeRight(EdFileInfo::getFilePath, id);
if (querySource == PrjQuerySource.REPO_DB.value) {
prjQueryWrapper.and(qr -> qr.eq(EdFileInfo::getDataStatus, EleDataStatusEnum.WAIT_DELETED.code)
.or()
.eq(EdFileInfo::getDataStatus, EleDataStatusEnum.PUBLISHED.code));
} else {
prjQueryWrapper.ne(EdFileInfo::getDataStatus, EleDataStatusEnum.WAIT_DELETED.code);
}
List<EdFileInfo> edFileInfos = edFileInfoMapper.selectList(prjQueryWrapper);
String jsonTree = createTree(edFileInfos, returnType);
List<String> list = map.getOrDefault(querySource, new ArrayList<>()); List<String> list = map.getOrDefault(querySource, new ArrayList<>());
list.add(jsonTree); list.add(jsonTree);
map.put(querySource, list); map.put(querySource, list);

View File

@ -204,11 +204,14 @@ public class EdFileInfoServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileI
.eq(EdFileInfo::getCreatedBy, UserThreadLocal.getUserId()) .eq(EdFileInfo::getCreatedBy, UserThreadLocal.getUserId())
.eq(EdFileInfo::getParentId, PRJ_PARENT_ID)).stream().map(EdFileInfo::getId).collect(Collectors.toList()); .eq(EdFileInfo::getParentId, PRJ_PARENT_ID)).stream().map(EdFileInfo::getId).collect(Collectors.toList());
} }
Map<Integer, List<String>> map;
Map<Integer, List<String>> map = (querySource == PrjQuerySource.SYS_DB.value) ? if (querySource == PrjQuerySource.SYS_DB.value) {
commonService.querySysPrjTree(querySource, accessibleIds, new FileProjectVO()) : map = commonService.querySysPrjTree(querySource, accessibleIds, new FileProjectVO());
commonService.queryUserPrjTree(querySource, new FileProjectVO()); } else if (querySource == PrjQuerySource.USER_DB.value) {
map = commonService.queryUserPrjTree(querySource, new FileProjectVO());
} else {
map = commonService.queryRepoPrjTree(querySource, new FileProjectVO());
}
List<String> strings = map.getOrDefault(querySource, new ArrayList<>()); List<String> strings = map.getOrDefault(querySource, new ArrayList<>());
List<FileProjectVO> res = new ArrayList<>(); List<FileProjectVO> res = new ArrayList<>();
strings.forEach(e -> { strings.forEach(e -> {

View File

@ -232,13 +232,16 @@ public class EdPrjServiceImpl extends ServiceImpl<EdFileInfoMapper, EdFileInfo>
public ElectromagneticResult<?> queryAllPrjInfo(int querySource) { public ElectromagneticResult<?> queryAllPrjInfo(int querySource) {
/** /**
* querySource=SYS_PRJ管理员从层级定义处查询 querySource=USER_PRJ用户从自定义层级结构处查询 * querySource=SYS_PRJ管理员从层级定义处查询 querySource=USER_PRJ用户从自定义层级结构处查询 querySource=REPO_PRJ
*/ */
Map<Integer, List<String>> map;
Map<Integer, List<String>> map = (querySource == PrjQuerySource.SYS_PRJ.value) ? if (querySource == PrjQuerySource.SYS_PRJ.value) {
commonService.querySysPrjTree(querySource, null, new ProjectVO()) : map = commonService.querySysPrjTree(querySource, null, new ProjectVO());
commonService.queryUserPrjTree(querySource, new ProjectVO()); } else if (querySource == PrjQuerySource.USER_PRJ.value) {
map = commonService.queryUserPrjTree(querySource, new ProjectVO());
} else {
map = commonService.queryRepoPrjTree(querySource, new ProjectVO());
}
List<String> res = map.getOrDefault(querySource, new ArrayList<>()); List<String> res = map.getOrDefault(querySource, new ArrayList<>());
List<ProjectVO> projectVOS = new ArrayList<>(); List<ProjectVO> projectVOS = new ArrayList<>();
res.forEach(e -> { res.forEach(e -> {

View File

@ -8,6 +8,7 @@ public enum FileRepeatEnum {
IGNORE(1, "跳过所有冲突文件"), IGNORE(1, "跳过所有冲突文件"),
REVERSION(2, "所有冲突文件版本更新"), REVERSION(2, "所有冲突文件版本更新"),
NEW(3, "重命名所有冲突文件, 文件后加“_1”"); NEW(3, "重命名所有冲突文件, 文件后加“_1”");
public int code; public int code;
public String desc; public String desc;

View File

@ -8,7 +8,9 @@ public enum PrjQuerySource {
SYS_PRJ(0), SYS_PRJ(0),
SYS_DB(1), SYS_DB(1),
USER_PRJ(2), USER_PRJ(2),
USER_DB(3); USER_DB(3),
REPO_PRJ(4),
REPO_DB(5);
public final int value; public final int value;

View File

@ -7,22 +7,26 @@ import java.util.Objects;
@AllArgsConstructor @AllArgsConstructor
public enum UserOperationModuleEnum { public enum UserOperationModuleEnum {
PRJ_SETTING("prjSetting", "层级定义"), SYS_PRJ_SETTING("sys_prj_setting", "数据库层级定义"),
SYS_PRJ_DATABASE("sys_prj_database", "数据库管理"),
REPO_PRJ_DATABASE("repo_prj_database", "库数据管理"),
REPO_PRJ_SETTING("repo_prj_setting", "库数据层级定义"),
USER_PRJ("user_prj", "个人数据"),
UNKNOWN("unknown", "未分组"), UNKNOWN("unknown", "未分组"),
DATABASE("database", "数据库管理"),
USER("user", "人员管理"), USER("user", "人员管理"),
USER_PRJ("userPrj", "个人数据"),
TAG("tag", "标签管理"), TAG("tag", "标签管理"),
LOG("log", "操作记录审计"), LOG("log", "操作记录审计"),
TMP("tmp", "临时文件"), TMP("tmp", "临时文件"),
BACKUP_FILE("backupFile", "系统文件备份"), BACKUP_FILE("backup_file", "系统文件备份"),
PERMISSION("permission", "权限管理"); PERMISSION("permission", "权限管理");
public final String key; public final String key;
public final String desc; public final String desc;
public static String getDesc(String key) { public static String getDesc(String key) {
for (UserOperationModuleEnum e : UserOperationModuleEnum.values()) { for (UserOperationModuleEnum e : UserOperationModuleEnum.values()) {
if (Objects.equals(e.key, key)) { if (Objects.equals(e.key, key)) {