diff --git a/src/main/java/com/gunshi/project/ss/controller/DocCategoryController.java b/src/main/java/com/gunshi/project/ss/controller/DocCategoryController.java new file mode 100644 index 0000000..e59397f --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/controller/DocCategoryController.java @@ -0,0 +1,63 @@ +package com.gunshi.project.ss.controller; + + +import com.gunshi.project.ss.entity.vo.UserRoleVo; +import com.gunshi.project.ss.model.DocCategory; +import com.gunshi.project.ss.service.DocCategoryService; +import com.ruoyi.common.core.domain.R; +import io.swagger.v3.oas.annotations.Operation; +import io.swagger.v3.oas.annotations.tags.Tag; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +@Tag(name = "资料类别") +@RestController +@RequestMapping(value = "/docCategory") +public class DocCategoryController { + + + @Autowired + private DocCategoryService docCategoryService; + + @Operation(summary = "新增分类") + @PostMapping("/insert") + public R insert(@RequestBody DocCategory docCategory){ + Boolean flg = docCategoryService.insert(docCategory); + return R.ok(flg); + } + + @Operation(summary = "更新分类") + @PostMapping("/edit") + public R edit(@RequestBody DocCategory docCategory){ + Boolean flg = docCategoryService.edit(docCategory); + return R.ok(flg); + } + + @Operation(summary = "更新分类") + @GetMapping("/del/{id}") + public R edit(@PathVariable("id") Long id){ + Boolean flg = docCategoryService.del(id); + return R.ok(flg); + } + + @Operation(summary = "获取树状结构和配置的权限") + @GetMapping("/list") + public R list() { + DocCategory docCategory = docCategoryService.tree(); + return R.ok(docCategory); + } + + @Operation(summary = "获取全部角色/部门下用户") + @GetMapping("/getAllUserAndRole") + public R getAllUserAndRole(){ + UserRoleVo vo = docCategoryService.getAllUserAndRole(); + return R.ok(vo); + } + + @Operation(summary = "检查是否有权限") + @GetMapping("/checkPermission/{userId}/{docCategoryId}") + public R checkPermission(@PathVariable("userId") Long userId,@PathVariable("docCategoryId") Long docCategoryId){ + String[] strings = docCategoryService.checkPermission(docCategoryId, userId); + return R.ok(strings); + } +} diff --git a/src/main/java/com/gunshi/project/ss/entity/vo/DocSysDeptUserVo.java b/src/main/java/com/gunshi/project/ss/entity/vo/DocSysDeptUserVo.java new file mode 100644 index 0000000..00a8a9e --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/entity/vo/DocSysDeptUserVo.java @@ -0,0 +1,16 @@ +package com.gunshi.project.ss.entity.vo; + +import lombok.Data; + +import java.util.List; + +@Data +public class DocSysDeptUserVo { + private String deptId; + + private String deptName; + + private List children; + + private List users; +} diff --git a/src/main/java/com/gunshi/project/ss/entity/vo/DocSysRoleVo.java b/src/main/java/com/gunshi/project/ss/entity/vo/DocSysRoleVo.java new file mode 100644 index 0000000..84eeda2 --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/entity/vo/DocSysRoleVo.java @@ -0,0 +1,11 @@ +package com.gunshi.project.ss.entity.vo; + +import lombok.Data; + +@Data +public class DocSysRoleVo { + + private String roleId; + + private String roleName; +} diff --git a/src/main/java/com/gunshi/project/ss/entity/vo/DocSysUserVo.java b/src/main/java/com/gunshi/project/ss/entity/vo/DocSysUserVo.java new file mode 100644 index 0000000..34bd892 --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/entity/vo/DocSysUserVo.java @@ -0,0 +1,11 @@ +package com.gunshi.project.ss.entity.vo; + +import lombok.Data; + +@Data +public class DocSysUserVo { + + private String userId; + + private String userName; +} diff --git a/src/main/java/com/gunshi/project/ss/mapper/DocCategoryMapper.java b/src/main/java/com/gunshi/project/ss/mapper/DocCategoryMapper.java new file mode 100644 index 0000000..0458397 --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/mapper/DocCategoryMapper.java @@ -0,0 +1,9 @@ +package com.gunshi.project.ss.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.gunshi.project.ss.model.DocCategory; +import org.apache.ibatis.annotations.Mapper; + +@Mapper +public interface DocCategoryMapper extends BaseMapper { +} diff --git a/src/main/java/com/gunshi/project/ss/mapper/DocPermissionConfigMapper.java b/src/main/java/com/gunshi/project/ss/mapper/DocPermissionConfigMapper.java new file mode 100644 index 0000000..344976a --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/mapper/DocPermissionConfigMapper.java @@ -0,0 +1,9 @@ +package com.gunshi.project.ss.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.gunshi.project.ss.model.DocPermissionConfig; +import org.apache.ibatis.annotations.Mapper; + +@Mapper +public interface DocPermissionConfigMapper extends BaseMapper { +} diff --git a/src/main/java/com/gunshi/project/ss/model/DocCategory.java b/src/main/java/com/gunshi/project/ss/model/DocCategory.java new file mode 100644 index 0000000..e95920b --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/model/DocCategory.java @@ -0,0 +1,59 @@ +package com.gunshi.project.ss.model; + +import com.alibaba.druid.sql.visitor.functions.Insert; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import com.gunshi.project.ss.common.validate.markers.Update; +import io.swagger.v3.oas.annotations.media.Schema; +import jakarta.validation.constraints.NotNull; +import lombok.Data; + +import java.time.LocalDateTime; +import java.util.List; + +@Data +@TableName("doc_category") +@Schema(description = "资料类别表") +public class DocCategory { + @TableId(value = "id",type = IdType.AUTO) + @NotNull(message = "id不能为空", groups = {Update.class}) + @Schema(description = "主键id") + private Long id; + + @TableField("category_name") + @NotNull(message = "分类名称不能为空", groups = {Insert.class, Update.class}) + @Schema(description = "分类名称") + private String categoryName; + + @TableField("parent_id") + @Schema(description = "父级id 0为第一级") + private Long parentId; + + @TableField("category_code") + @Schema(description = "当前类目代码") + private String categoryCode; + + @TableField("sort_order") + @Schema(description = "显示顺序") + private Integer sortOrder; + + @TableField("create_time") + @Schema(description = "创建时间") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") + private LocalDateTime createTime; + + @TableField("level") + @Schema(description = "当前层级") + private Integer level; + + @TableField(exist = false) + @Schema(description = "子分类列表") + private List children; + + @TableField(exist = false) + @Schema(description = "所有者权限") + private List permissions; +} \ No newline at end of file diff --git a/src/main/java/com/gunshi/project/ss/model/DocCenter.java b/src/main/java/com/gunshi/project/ss/model/DocCenter.java new file mode 100644 index 0000000..d2db1f9 --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/model/DocCenter.java @@ -0,0 +1,95 @@ +package com.gunshi.project.ss.model; + +import com.alibaba.druid.sql.visitor.functions.Insert; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import com.gunshi.project.ss.common.validate.markers.Update; +import io.swagger.v3.oas.annotations.media.Schema; +import jakarta.validation.constraints.NotNull; +import lombok.Data; + +import java.time.LocalDateTime; +import java.util.List; + +@Data +@TableName("doc_center") +@Schema(description = "资料中心") +public class DocCenter { + + @TableId(value = "id",type = IdType.AUTO) + @NotNull(message = "id不能为空", groups = {Update.class}) + @Schema(description = "主键id") + private Long id; + + @TableField("doc_name") + @NotNull(message = "档案名称不能为空", groups = {Insert.class, Update.class}) + @Schema(description = "档案名称") + private String docName; + + @TableField("replace_id") + @NotNull(message = "替换档案id不能为空", groups = {Insert.class, Update.class}) + @Schema(description = "替换档案id") + private Long replaceId; + + @TableField("doc_category_id") + @Schema(description = "资料类别id") + private Integer docCategoryId; + + @TableField("group_id") + @Schema(description = "组id - 用于替换档案时") + private Long groupId; + + @TableField("doc_number") + @NotNull(message = "档案编号不能为空", groups = {Insert.class, Update.class}) + @Schema(description = "档案编号SS-XX-XX-0000") + private String docNumber; + + @TableField("doc_version") + @Schema(description = "档案版本") + private Integer docVersion; + + @TableField("create_time") + @Schema(description = "创建时间") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") + private LocalDateTime createTime; + + @TableField("abolish_time") + @Schema(description = "废止时间") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") + private LocalDateTime abolishTime; + + @TableField("user_id") + @Schema(description = "归档人id") + private Long userId; + + @TableField("business_name") + @Schema(description = "业务名称（用于不同业务文件归档后的文件查询）") + private String businessName; + + @TableField("secret_level") + @Schema(description = "保密级别 0公开 1秘密 2机密") + private Integer secretLevel; + + @TableField("is_abolish") + @Schema(description = "0未废止 1已废止") + private Integer isAbolish; + + @TableField(exist = false) + @Schema(description = "归档人名称") + private String userName; + + @TableField(exist = false) + @Schema(description = "资料分类名称") + private String categoryName; + + @TableField(exist = false) + @Schema(description = "文件列表") + private List files; + + @TableField(exist = false) + @Schema(description = "操作日志列表") + private List logs; +} \ No newline at end of file diff --git a/src/main/java/com/gunshi/project/ss/model/DocOperateLog.java b/src/main/java/com/gunshi/project/ss/model/DocOperateLog.java new file mode 100644 index 0000000..da326d6 --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/model/DocOperateLog.java @@ -0,0 +1,54 @@ +package com.gunshi.project.ss.model; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.time.LocalDateTime; + +@Data +@TableName("doc_operate_log") +@Schema(description = "档案行为日志表") +public class DocOperateLog { + + @TableId(value = "id",type = IdType.AUTO) + @Schema(description = "主键ID") + private Long id; + + @TableField("user_id") + @Schema(description = "用户id") + private Long userId; + + @TableField("operate_type") + @Schema(description = "操作类型") + private String operateType; + + @TableField("doc_number") + @Schema(description = "相关档案编号") + private String docNumber; + + @TableField("doc_name") + @Schema(description = "档案名称") + private String docName; + + @TableField("file_id") + @Schema(description = "文件id") + private Long fileId; + + @TableField("create_time") + @Schema(description = "操作时间") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") + private LocalDateTime createTime; + + @TableField(exist = false) + @Schema(description = "用户名称") + private String userName; + + @TableField(exist = false) + @Schema(description = "操作类型名称") + private String operateTypeName; +} \ No newline at end of file diff --git a/src/main/java/com/gunshi/project/ss/model/DocPermissionConfig.java b/src/main/java/com/gunshi/project/ss/model/DocPermissionConfig.java new file mode 100644 index 0000000..eaebf96 --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/model/DocPermissionConfig.java @@ -0,0 +1,56 @@ +package com.gunshi.project.ss.model; + +import com.alibaba.druid.sql.visitor.functions.Insert; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.gunshi.project.ss.common.validate.markers.Update; +import io.swagger.v3.oas.annotations.media.Schema; +import jakarta.validation.constraints.NotNull; +import lombok.Data; + +import java.util.List; + +@Data +@TableName("doc_permission_config") +@Schema(description = "资料权限配置表") +public class DocPermissionConfig { + + @TableId(value = "id",type = IdType.AUTO) + @NotNull(message = "id不能为空", groups = {Update.class}) + @Schema(description = "主键ID") + private Long id; + + @TableField("category_id") + @NotNull(message = "资料分类id不能为空", groups = {Insert.class, Update.class}) + @Schema(description = "资料分类id") + private Long categoryId; + + @TableField("target_type") + @NotNull(message = "权限目标类型不能为空", groups = {Insert.class, Update.class}) + @Schema(description = "权限目标类型 1-角色，2-人员") + private Short targetType; + + @TableField("targer_id") + @NotNull(message = "目标ID不能为空", groups = {Insert.class, Update.class}) + @Schema(description = "目标ID（角色ID，或者用户ID）") + private Long targerId; + + @TableField("permission_code") + @NotNull(message = "权限编码不能为空", groups = {Insert.class, Update.class}) + @Schema(description = "所有权限，比如：add,edit,delete,view,download 权限以,分隔开") + private String permissionCode; + + @TableField(exist = false) + @Schema(description = "目标名称（角色名称或用户名称）") + private String targetName; + + @TableField(exist = false) + @Schema(description = "资料分类名称") + private String categoryName; + + @TableField(exist = false) + @Schema(description = "权限列表") + private List permissions; +} \ No newline at end of file diff --git a/src/main/java/com/gunshi/project/ss/service/DocCategoryService.java b/src/main/java/com/gunshi/project/ss/service/DocCategoryService.java new file mode 100644 index 0000000..843a88c --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/service/DocCategoryService.java @@ -0,0 +1,150 @@ +package com.gunshi.project.ss.service; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.gunshi.project.ss.entity.vo.UserRoleVo; +import com.gunshi.project.ss.mapper.DocCategoryMapper; +import com.gunshi.project.ss.model.DocCategory; +import com.gunshi.project.ss.model.DocPermissionConfig; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.time.LocalDateTime; +import java.util.Comparator; +import java.util.LinkedList; +import java.util.List; +import java.util.Queue; +import java.util.stream.Collectors; + +@Service +@Slf4j +@Transactional(rollbackFor = Exception.class) +public class DocCategoryService extends ServiceImpl { + + @Autowired + private DocCategoryMapper docCategoryMapper; + + @Autowired + private DocPermissionConfigService docPermissionConfigService; + + + + public DocCategory tree() { + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(DocCategory::getParentId,0); + queryWrapper.last("limit 1"); + DocCategory docCategory = docCategoryMapper.selectOne(queryWrapper); + List allList = docCategoryMapper.selectList(null); + buildTree(docCategory,allList); + return docCategory; + } + + /** + * 采用BFS 非递归方式进行树形结构的构建 + * @param docCategory + * @return + */ + private DocCategory buildTree(DocCategory docCategory,List allList) { + Queue docCategoryDeque = new LinkedList<>(); + if(docCategory != null){ + docCategoryDeque.add(docCategory); + } + while(!docCategoryDeque.isEmpty()){ + int size = docCategoryDeque.size(); + while(size > 0){ + DocCategory pop = docCategoryDeque.remove(); + List childrens = allList.stream().filter(o -> { + return o.getParentId().equals(pop.getId()); + }).sorted(Comparator.comparing(DocCategory::getSortOrder)) // 升序排列 + .collect(Collectors.toList()); + pop.setChildren(childrens); + //判断赋予的权限 + if(pop.getLevel() != null && pop.getLevel() == 3){ + //只有最后一层才有权限 + List permissions = docPermissionConfigService.getPermissionByDocId(pop.getId()); + pop.setPermissions(permissions); + } + childrens.forEach(item -> {docCategoryDeque.add(item);}); + size--; + } + } + return docCategory; + } + + public UserRoleVo getAllUserAndRole() { + return docPermissionConfigService.getAllUserAndRole(); + } + + public Boolean insert(DocCategory docCategory) { + docCategory.setCreateTime(LocalDateTime.now()); + checkCategoryCodeSame(docCategory); + save(docCategory); + List permissions = docCategory.getPermissions(); + for (DocPermissionConfig permission : permissions) { + permission.setCategoryId(docCategory.getId()); + } + docPermissionConfigService.saveBatch(permissions); + return true; + } + + public void checkCategoryCodeSame(DocCategory docCategory) { + if(docCategory.getLevel() != 2){ + return; + } + String categoryCode = docCategory.getCategoryCode(); + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(DocCategory::getLevel,2); + queryWrapper.eq(DocCategory::getCategoryCode,categoryCode); + Long count = docCategoryMapper.selectCount(queryWrapper); + if(count > 0){ + throw new IllegalArgumentException("对不起，二级类目代码重复，请检查"); + } + } + + public String[] checkPermission(Long docCategoryId,Long loginUserId) { +// //对于超级管理员来说，直接赋予所有权限 +// if(loginUserId == 1l){ +// return new String[]{"add","edit","delete","view","download"}; +// } + String[] permissions = docPermissionConfigService.checkPermission(docCategoryId,loginUserId); + return permissions; + } + + public Boolean edit(DocCategory docCategory) { + updateById(docCategory); + docPermissionConfigService.deleteByDocCategoryId(docCategory.getId()); + List permissions = docCategory.getPermissions(); + permissions.stream().forEach(item -> {item.setCategoryId(docCategory.getId());}); + docPermissionConfigService.saveBatch(permissions); + //TODO 同步更新所有关联档案的档案号(这里不用该，我到时候直接递归查上来然后进行拼接即可） + return true; + } + + public Boolean del(Long id) { + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(DocCategory::getId, id); + DocCategory docCategory = this.baseMapper.selectOne(queryWrapper); + if(docCategory == null){ + return true; + } + Integer level = docCategory.getLevel(); + if(level == 1){ + throw new IllegalArgumentException("对不起，无法删除一级类目数据"); + }else if(level == 2){ + //如果二级类目下有三级类目，则无法删除 + LambdaQueryWrapper childrenQueryWrapper = new LambdaQueryWrapper<>(); + childrenQueryWrapper.eq(DocCategory::getParentId, docCategory.getId()); + Long count = this.baseMapper.selectCount(childrenQueryWrapper); + if(count > 0){ + throw new IllegalArgumentException("对不起，该类目下设有下级类目，无法删除"); + } + }else{ + //TODO 三级类目，如果关联有档案，则无法删除 + } + docPermissionConfigService.deleteByDocCategoryId(docCategory.getId()); + this.baseMapper.deleteById(id); + return true; + } +} diff --git a/src/main/java/com/gunshi/project/ss/service/DocPermissionConfigService.java b/src/main/java/com/gunshi/project/ss/service/DocPermissionConfigService.java new file mode 100644 index 0000000..a4e5180 --- /dev/null +++ b/src/main/java/com/gunshi/project/ss/service/DocPermissionConfigService.java @@ -0,0 +1,229 @@ +package com.gunshi.project.ss.service; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.gunshi.project.ss.entity.vo.DocSysDeptUserVo; +import com.gunshi.project.ss.entity.vo.DocSysRoleVo; +import com.gunshi.project.ss.entity.vo.DocSysUserVo; +import com.gunshi.project.ss.entity.vo.UserRoleVo; +import com.gunshi.project.ss.mapper.DocPermissionConfigMapper; +import com.gunshi.project.ss.model.DocPermissionConfig; +import com.ruoyi.common.core.domain.entity.SysDept; +import com.ruoyi.common.core.domain.entity.SysRole; +import com.ruoyi.common.core.domain.entity.SysUser; +import com.ruoyi.common.utils.StringUtils; +import com.ruoyi.system.mapper.SysDeptMapper; +import com.ruoyi.system.mapper.SysRoleMapper; +import com.ruoyi.system.mapper.SysUserMapper; +import com.ruoyi.system.mapper.SysUserRoleMapper; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.util.*; +import java.util.stream.Collectors; + +@Service +@Slf4j +@Transactional(rollbackFor = Exception.class) +public class DocPermissionConfigService extends ServiceImpl { + + @Autowired + private DocPermissionConfigMapper docPermissionConfigMapper; + + @Autowired + private SysUserMapper sysUserMapper; + + @Autowired + private SysDeptMapper sysDeptMapper; + + @Autowired + private SysRoleMapper sysRoleMapper; + + @Autowired + private SysUserRoleMapper sysUserRoleMapper; + + public List getPermissionByDocId(Long id) { + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(DocPermissionConfig::getCategoryId,id); + List permissionConfigs = docPermissionConfigMapper.selectList(queryWrapper); + for (DocPermissionConfig permissionConfig : permissionConfigs) { + Short targetType = permissionConfig.getTargetType(); + if(targetType == 1){ + //表示是根据角色 + SysRole sysRole = sysRoleMapper.selectRoleById(permissionConfig.getTargerId()); + if(sysRole != null){ + permissionConfig.setTargetName(sysRole.getRoleName()); + } + }else{ + //表示是按用户id + SysUser sysUser = sysUserMapper.selectUserById(permissionConfig.getTargerId()); + if(sysUser != null){ + permissionConfig.setTargetName(sysUser.getNickName()); + } + } + String permissionCode = permissionConfig.getPermissionCode(); + if(StringUtils.isNotEmpty(permissionCode)){ + String[] split = permissionCode.split(","); + List permissionList = Arrays.asList(split); + permissionConfig.setPermissions(permissionList); + } + } + return permissionConfigs; + } + + public UserRoleVo getAllUserAndRole() { + UserRoleVo vo = new UserRoleVo(); + SysRole sysRole = new SysRole(); + sysRole.setStatus("0"); + List sysRoles = sysRoleMapper.selectRoleList(sysRole); + List docSysRoleVos = new ArrayList<>(); + vo.setDocSysRoles(docSysRoleVos); + sysRoles.forEach(sysRole1 -> { + DocSysRoleVo docSysRoleVo = new DocSysRoleVo(); + docSysRoleVo.setRoleName(sysRole1.getRoleName()); + docSysRoleVo.setRoleId(sysRole1.getRoleId().toString()); + docSysRoleVos.add(docSysRoleVo); + }); + + SysDept sysDept = new SysDept(); + sysDept.setStatus("0"); + List sysDepts = sysDeptMapper.selectDeptList(sysDept); + List topLevelDepts = filterTopLevelDepts(sysDepts); + List docSysDeptUserVos = new ArrayList<>(); + vo.setDocSysDeptUsers(docSysDeptUserVos); + for (SysDept dept : topLevelDepts) { + DocSysDeptUserVo docSysDeptUserVo = new DocSysDeptUserVo(); + docSysDeptUserVo.setDeptId(dept.getDeptId().toString()); + docSysDeptUserVo.setDeptName(dept.getDeptName()); + buildDeptTree(docSysDeptUserVo,sysDepts); + docSysDeptUserVos.add(docSysDeptUserVo); + } + return vo; + } + + public List filterTopLevelDepts(List allDepts) { + // 收集所有部门的ID + Set allDeptIds = allDepts.stream() + .map(SysDept::getDeptId) + .filter(Objects::nonNull) + .collect(Collectors.toSet()); + + // 找出所有顶级部门 + return allDepts.stream() + .filter(dept -> { + Long parentId = dept.getParentId(); + // 条件1: parentId为null + // 条件2: parentId为0（如果0表示顶级） + // 条件3: parentId不在现有部门ID列表中 + return parentId == null + || parentId == 0 + || !allDeptIds.contains(parentId); + }) + .collect(Collectors.toList()); + } + + public DocSysDeptUserVo buildDeptTree(DocSysDeptUserVo doc,List allDepts) { + List childrens = new ArrayList<>(); + for (SysDept dept : allDepts) { + String delFlag = dept.getDelFlag(); + Long parentId = dept.getParentId(); + if(parentId.toString().equals(doc.getDeptId()) && delFlag.equals("0")){ + childrens.add(dept); + } + } + if(!childrens.isEmpty()){ + List chirldren = new ArrayList<>(); + childrens.forEach(sysDept -> { + DocSysDeptUserVo docSysDeptUserVo = new DocSysDeptUserVo(); + docSysDeptUserVo.setDeptId(sysDept.getDeptId().toString()); + docSysDeptUserVo.setDeptName(sysDept.getDeptName()); + chirldren.add(docSysDeptUserVo); + }); + doc.setChildren(chirldren); + for (DocSysDeptUserVo docSysDeptUserVo : chirldren) { + buildDeptTree(docSysDeptUserVo,allDepts); + } + }else{ + //查看 + SysUser user = new SysUser(); + user.setStatus("0"); + user.setDeptId(Long.valueOf(doc.getDeptId())); + List sysUsers = sysUserMapper.selectUserList(user); + List docSysUserVos = new ArrayList<>(); + doc.setUsers(docSysUserVos); + for (SysUser sysUser : sysUsers) { + DocSysUserVo docSysUserVo = new DocSysUserVo(); + docSysUserVo.setUserId(sysUser.getUserId().toString()); + docSysUserVo.setUserName(sysUser.getUserName()); + docSysUserVos.add(docSysUserVo); + } + } + return doc; + } + + public String[] checkPermission(Long categoryId, Long loginUserId) { + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(DocPermissionConfig::getCategoryId,categoryId); + List permissionConfigs = this.baseMapper.selectList(queryWrapper); + if(permissionConfigs.isEmpty()){ + return new String[0]; + } + Short targetType = permissionConfigs.get(0).getTargetType();//只会出现一种 + if(targetType == 1){ + //角色 + SysUser sysUser = sysUserMapper.selectUserById(loginUserId); + if(sysUser != null){ + //根据用户获取角色id + List roles = sysUser.getRoles(); + if(roles.isEmpty()){ + return new String[0]; + } + List collect = roles.stream().filter(Objects::nonNull).map(SysRole::getRoleId).filter(Objects::nonNull).collect(Collectors.toList()); + queryWrapper.in(DocPermissionConfig::getTargerId,collect); + //去查询 + List permissions = this.baseMapper.selectList(queryWrapper); + if(!permissions.isEmpty()){ + String[] res = null; + int ans = 0; + for (DocPermissionConfig permission : permissions) { + if(StringUtils.isNotEmpty(permission.getPermissionCode())){ + String[] split = permission.getPermissionCode().split(","); + if(split.length > ans){ + res = split; + ans = split.length; + }else{ + continue; + } + } + } + return res; + }else{ + return new String[0]; + } + } + }else{ + //人员 + queryWrapper.eq(DocPermissionConfig::getTargerId,loginUserId); + DocPermissionConfig docPermissionConfig = this.baseMapper.selectOne(queryWrapper); + if(docPermissionConfig != null){ + String permissionCode = docPermissionConfig.getPermissionCode(); + if(StringUtils.isNotEmpty(permissionCode)){ + String[] split = permissionCode.split(","); + return split; + }else{ + return new String[0]; + } + } + return new String[0]; + } + return new String[0]; + } + + public void deleteByDocCategoryId(Long docCatrgoryId) { + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(DocPermissionConfig::getCategoryId,docCatrgoryId); + this.baseMapper.delete(queryWrapper); + } +}