Merge branch 'master' into docker_package

Merge branch 'dev'
过滤后端 HIQDUCS-666
2022-12-16 14:54:36 +08:00 · 2022-12-16 14:54:25 +08:00 · 2022-12-16 14:54:13 +08:00
7 changed files with 215 additions and 10 deletions
--- a/renren-admin/src/main/java/io/renren/modules/resource/controller/ResourceController.java
+++ b/renren-admin/src/main/java/io/renren/modules/resource/controller/ResourceController.java
@ -23,12 +23,17 @@ import io.renren.modules.resource.videoPreview.AbstractVideoPreviewService;
 import io.renren.modules.resource.videoPreview.VideoPreviewFactory;
 import io.renren.modules.security.user.SecurityUser;
 import io.renren.modules.security.user.UserDetail;
+import io.renren.modules.sys.dao.SysDeptDao;
 import io.renren.modules.sys.dao.SysUserDao;
 import io.renren.modules.sys.dto.SysDeptDTO;
+import io.renren.modules.sys.dto.SysRoleDTO;
 import io.renren.modules.sys.dto.SysUserDTO;
+import io.renren.modules.sys.entity.SysDeptEntity;
 import io.renren.modules.sys.entity.SysUserEntity;
 import io.renren.modules.sys.enums.SuperAdminEnum;
 import io.renren.modules.sys.service.SysDeptService;
+import io.renren.modules.sys.service.SysRoleService;
+import io.renren.modules.sys.service.SysRoleUserService;
 import io.renren.modules.sys.service.SysUserService;
 import io.swagger.annotations.*;
 import org.apache.commons.lang.StringUtils;
@ -85,6 +90,17 @@ public class ResourceController {
    @Value("${resource.path}")
    private String uploadPath;

+    @Value("${big_date.assignee_role_name}")
+    private String roleName0; // 具备审批的角色名称(普通)
+
+    @Value("${big_date.assignee_district_role_name}")
+    private String roleName1; // 具备审批的角色名称（区县）
+    @Value("${big_date.assignee_city_role_name}")
+    private String roleName2; // 具备审批的角色名称(市区)
+
+    @Value("${big_date.assignee_meet_role_id}")
+    private String defaultAssigneeRoleId; // 会客厅审核人角色
+
    @Autowired
    private ResourceService resourceService;

@ -99,6 +115,14 @@ public class ResourceController {
    @Autowired
    private SysUserService sysUserService;

+    @Autowired
+    private SysRoleService sysRoleService;
+    @Autowired
+    private SysRoleUserService sysRoleUserService;
+
+    @Autowired
+    private SysDeptDao sysDeptDao;
+
    @Resource(name = "${hisense.gateway.name}")
    private ApiGateway apiGateway;

@ -126,6 +150,74 @@ public class ResourceController {
            @ApiImplicitParam(name = "region", value = "是否过滤只出用户区域内部门", paramType = "query", dataType = "String")
    })
    public Result<PageData<ResourceDTO>> page(@ApiIgnore @RequestParam Map<String, Object> params) {
+        // 2022.12.16 后台过滤只出所属区域资源
+        Boolean region = params.containsKey("region") ? (Boolean) params.get("region") : false; // 是否需要过滤只出用户所属区域资源
+        while (region) {
+            List<Long> deptIds = new ArrayList<>();
+            UserDetail user = SecurityUser.getUser(); // 当前用户
+            if (SuperAdminEnum.YES.value() != user.getSuperAdmin()) { // 非超级管理员
+                Optional<SysUserDTO> userDTOOptional = Optional.ofNullable(sysUserService.get(user.getId()));
+                if (userDTOOptional.isPresent()) {
+                    SysRoleDTO roleDTO0 = sysRoleService.getByName(roleName0); // 部门审核员
+                    SysRoleDTO roleDTO1 = sysRoleService.getByName(roleName1); // 区管理员
+                    SysRoleDTO roleDTO2 = sysRoleService.getByName(roleName2); // 市管理员
+                    List<Long> useIds0 = sysRoleUserService.getUserIdListByRoleId(roleDTO0.getId()); // 部门审核员列表
+                    List<Long> useIds1 = sysRoleUserService.getUserIdListByRoleId(roleDTO1.getId()); // 区管理员
+                    List<Long> useIds02 = sysRoleUserService.getUserIdListByRoleId(roleDTO2.getId()); // 市管理员
+                    List<Long> useIds = sysRoleUserService.getUserIdListByRoleId(Long.parseLong(defaultAssigneeRoleId)); // 运维管理员
+
+                    if (useIds.contains(user.getId())) { // 为运维管理员时
+                        logger.info("运维管理员出所有资源");
+                        break;
+                    }
+                    if (useIds02.contains(user.getId())) { // 为市管理员
+                        logger.info("市管理员");
+                        break;
+                    }
+
+                    SysDeptEntity sysDeptEntity = null;
+                    if (userDTOOptional.get().getDeptId() != null) {
+                        sysDeptEntity = sysDeptDao.getById(userDTOOptional.get().getDeptId());
+                    }
+
+                    if (sysDeptEntity == null || sysDeptEntity.getDistrict() == null) {
+                        logger.info("该用户部门信息异常" + user.toString());
+                        break;
+                    }
+
+                    if (useIds1.contains(user.getId())) { // 区管理员
+                        logger.info("区管理员");
+                        SysDeptEntity finalSysDeptEntity = sysDeptEntity;
+                        List<Long> deptId = sysDeptDao.getIdFromDistrict(sysDeptEntity.getDistrict());
+                        List<Long> temp = new ArrayList<Long>() {
+                            {
+                                add(finalSysDeptEntity.getId());
+                                if (!deptId.isEmpty()) {
+                                    addAll(deptId);
+                                }
+                            }
+                        };
+                        deptIds.addAll(temp);
+                        params.put("deptIds", deptIds.stream().distinct().collect(Collectors.toList()));
+                        break;
+                    }
+                    if (useIds0.contains(user.getId())) { // 部门审核员
+                        logger.info("部门审核员");
+                        SysDeptEntity finalSysDeptEntity1 = sysDeptEntity;
+                        List<Long> temp = new ArrayList<Long>() {
+                            {
+                                add(finalSysDeptEntity1.getId());
+                            }
+                        };
+                        deptIds.addAll(temp);
+                        params.put("deptIds", deptIds.stream().distinct().collect(Collectors.toList()));
+                        break;
+                    }
+                }
+
+            }
+        }
+
        PageData<ResourceDTO> page = resourceService.page(params);
        page.getList().forEach(item -> {
            item.setInfoList(resourceService.selectAttrsByResourceId(item.getId()));
--- a/renren-admin/src/main/java/io/renren/modules/resource/service/impl/ResourceServiceImpl.java
+++ b/renren-admin/src/main/java/io/renren/modules/resource/service/impl/ResourceServiceImpl.java
@ -62,6 +62,7 @@ import io.renren.modules.sys.entity.SysDeptEntity;
 import io.renren.modules.sys.enums.SuperAdminEnum;
 import io.renren.modules.sys.service.SysDeptService;
 import io.renren.modules.sys.service.SysRoleService;
+import io.renren.modules.sys.service.SysRoleUserService;
 import io.renren.modules.sys.service.SysUserService;
 import lombok.SneakyThrows;
 import okhttp3.*;
@ -270,6 +271,8 @@ public class ResourceServiceImpl extends CrudServiceImpl<ResourceDao, ResourceEn

    @Autowired
    private SysRoleService sysRoleService;
+    @Autowired
+    private SysRoleUserService sysRoleUserService;

    private JdbcTemplate lcJdbcTemplate = JdbcTemplateFactory.getJdbcTemplate();

@ -312,8 +315,18 @@ public class ResourceServiceImpl extends CrudServiceImpl<ResourceDao, ResourceEn
                    wrapper.eq(org.apache.commons.lang3.StringUtils.isNotEmpty(params.get("creator").toString()), "creator", params.get("creator").toString());
                    break;
                case "deptId":
-                    wrapper.eq(org.apache.commons.lang3.StringUtils.isNotEmpty(params.get("deptId").toString()), "dept_id", Long.parseLong(params.get("deptId").toString()));
+                    wrapper.eq(org.apache.commons.lang3.StringUtils.isNumeric(params.get("deptId").toString()), "dept_id", Long.parseLong(params.get("deptId").toString()));
                    break;
+                case "deptIds": {
+                    List<Long> deptIds = new ArrayList<>();
+                    try {
+                        deptIds = (List<Long>) params.get("deptIds");
+                    } catch (Exception ex) {
+                        logger.error("", ex);
+                    }
+                    wrapper.in(deptIds.isEmpty(), "dept_id", deptIds);
+                }
+                break;
                default:
                    break;
            }
@ -517,20 +530,77 @@ public class ResourceServiceImpl extends CrudServiceImpl<ResourceDao, ResourceEn
        Integer pageSize = jsonObject.getInteger("pageSize");
        // 2022.12.16 后台过滤只出所属区域资源
        Boolean region = jsonObject.containsKey("region") ? jsonObject.getBooleanValue("region") : false; // 是否需要过滤只出用户所属区域资源
-        if (region) {
+        while (region) {
            UserDetail user = SecurityUser.getUser(); // 当前用户
            if (SuperAdminEnum.YES.value() != user.getSuperAdmin()) { // 非超级管理员
                Optional<SysUserDTO> userDTOOptional = Optional.ofNullable(sysUserService.get(user.getId()));
-                SysRoleDTO roleDTO0 = sysRoleService.getByName(roleName0);
-                SysRoleDTO roleDTO1 = sysRoleService.getByName(roleName1);
-                SysRoleDTO roleDTO2 = sysRoleService.getByName(roleName2);
-                userDTOOptional.ifPresent(userDto -> {
-                    if (userDto.getDeptId() != null) {
-                        SysDeptEntity sysDeptEntity = sysDeptDao.getById(userDto.getDeptId());
+                if (userDTOOptional.isPresent()) {
+                    SysRoleDTO roleDTO0 = sysRoleService.getByName(roleName0); // 部门审核员
+                    SysRoleDTO roleDTO1 = sysRoleService.getByName(roleName1); // 区管理员
+                    SysRoleDTO roleDTO2 = sysRoleService.getByName(roleName2); // 市管理员
+                    List<Long> useIds0 = sysRoleUserService.getUserIdListByRoleId(roleDTO0.getId()); // 部门审核员列表
+                    List<Long> useIds1 = sysRoleUserService.getUserIdListByRoleId(roleDTO1.getId()); // 区管理员
+                    List<Long> useIds02 = sysRoleUserService.getUserIdListByRoleId(roleDTO2.getId()); // 市管理员
+                    List<Long> useIds = sysRoleUserService.getUserIdListByRoleId(Long.parseLong(defaultAssigneeRoleId)); // 运维管理员
+
+                    if (useIds.contains(user.getId())) { // 为运维管理员时
+                        logger.info("运维管理员出所有资源");
+                        break;
                    }
-                });
+                    if (useIds02.contains(user.getId())) { // 为市管理员
+                        logger.info("市管理员");
+                        break;
+                    }
+
+                    SysDeptEntity sysDeptEntity = null;
+                    if (userDTOOptional.get().getDeptId() != null) {
+                        sysDeptEntity = sysDeptDao.getById(userDTOOptional.get().getDeptId());
+                    }
+
+                    if (sysDeptEntity == null || sysDeptEntity.getDistrict() == null) {
+                        logger.info("该用户部门信息异常" + user.toString());
+                        break;
+                    }
+
+                    if (useIds1.contains(user.getId())) { // 区管理员
+                        logger.info("区管理员");
+                        SysDeptEntity finalSysDeptEntity = sysDeptEntity;
+                        List<Long> deptId = sysDeptDao.getIdFromDistrict(sysDeptEntity.getDistrict());
+                        List<Long> temp = new ArrayList<Long>() {
+                            {
+                                add(finalSysDeptEntity.getId());
+                                if (!deptId.isEmpty()) {
+                                    addAll(deptId);
+                                }
+                            }
+                        };
+                        if (!resourceDTO.getDeptIds().isEmpty()) {
+                            temp.addAll(resourceDTO.getDeptIds());
+                        }
+                        resourceDTO.setDeptIds(temp.stream().distinct().collect(Collectors.toList()));
+                        break;
+                    }
+                    if (useIds0.contains(user.getId())) { // 部门审核员
+                        logger.info("部门审核员");
+                        if (userDTOOptional.get().getDeptId() != null) {
+                            SysDeptEntity finalSysDeptEntity = sysDeptEntity;
+                            List<Long> temp = new ArrayList<Long>() {
+                                {
+                                    add(finalSysDeptEntity.getId());
+                                }
+                            };
+                            if (!resourceDTO.getDeptIds().isEmpty()) {
+                                temp.addAll(resourceDTO.getDeptIds());
+                            }
+                            resourceDTO.setDeptIds(temp.stream().distinct().collect(Collectors.toList())); // 只出自己部门
+                        }
+                        break;
+                    }
+                }
+
            }
        }
+
        Boolean nonChinese = jsonObject.containsKey("nonChinese") ? jsonObject.getBoolean("nonChinese") : Boolean.FALSE; // 不传默认为中文走全文索引
        //默认按上架时间降序排列
        String orderField;
--- a/renren-admin/src/main/java/io/renren/modules/security/user/UserDetail.java
+++ b/renren-admin/src/main/java/io/renren/modules/security/user/UserDetail.java
@ -28,4 +28,21 @@ public class UserDetail implements Serializable {
     */
    private List<Long> deptIdList;

+    @Override
+    public String toString() {
+        return "UserDetail{" +
+                "id=" + id +
+                ", username='" + username + '\'' +
+                ", realName='" + realName + '\'' +
+                ", headUrl='" + headUrl + '\'' +
+                ", gender=" + gender +
+                ", email='" + email + '\'' +
+                ", mobile='" + mobile + '\'' +
+                ", deptId=" + deptId +
+                ", password='" + password + '\'' +
+                ", status=" + status +
+                ", superAdmin=" + superAdmin +
+                ", deptIdList=" + deptIdList +
+                '}';
+    }
 }
--- a/renren-admin/src/main/java/io/renren/modules/sys/dao/SysDeptDao.java
+++ b/renren-admin/src/main/java/io/renren/modules/sys/dao/SysDeptDao.java
@ -44,4 +44,6 @@ public interface SysDeptDao extends BaseDao<SysDeptEntity> {

    Map<String, Object> selectUCSDeptByLCDeptName(@Param("deptName") String deptName);

+    List<Long> getIdFromDistrict(@Param("district") Long district);
+
 }
--- a/renren-admin/src/main/java/io/renren/modules/sys/service/SysDeptService.java
+++ b/renren-admin/src/main/java/io/renren/modules/sys/service/SysDeptService.java
@ -34,4 +34,12 @@ public interface SysDeptService extends BaseService<SysDeptEntity> {

    SysDeptDTO getByName(String name);

+    /**
+     * 查询该区域内部门id
+     *
+     * @param district
+     * @return
+     */
+    List<Long> getIdFromDistrict(Long district);
+
 }
--- a/renren-admin/src/main/java/io/renren/modules/sys/service/impl/SysDeptServiceImpl.java
+++ b/renren-admin/src/main/java/io/renren/modules/sys/service/impl/SysDeptServiceImpl.java
@ -51,7 +51,7 @@ public class SysDeptServiceImpl extends BaseServiceImpl<SysDeptDao, SysDeptEntit
        List<SysDeptEntity> entityList = baseDao.getList(params);
        List<SysDeptDTO> dtoList = ConvertUtils.sourceToTarget(entityList, SysDeptDTO.class);
        List<SysDeptDTO> result = dtoList.stream().skip((curPage - 1) * limit).limit(limit).collect(Collectors.toList());
-        return new PageData( TreeUtils.build(result), dtoList.size());
+        return new PageData(TreeUtils.build(result), dtoList.size());
    }

    @Override
@ -147,6 +147,17 @@ public class SysDeptServiceImpl extends BaseServiceImpl<SysDeptDao, SysDeptEntit
        return ConvertUtils.sourceToTarget(entity, SysDeptDTO.class);
    }

+    /**
+     * 查询该区域内部门id
+     *
+     * @param district
+     * @return
+     */
+    @Override
+    public List<Long> getIdFromDistrict(Long district) {
+        return baseDao.getIdFromDistrict(district);
+    }
+

    /**
     * 获取所有上级部门ID
--- a/renren-admin/src/main/resources/mapper/sys/SysDeptDao.xml
+++ b/renren-admin/src/main/resources/mapper/sys/SysDeptDao.xml
@ -43,8 +43,13 @@
    <select id="selectLCDeptByRegion" resultType="java.lang.String">
        SELECT lc_name FROM t_ucs_lc_dept_rel WHERE district = #{region}
    </select>
+
    <select id="selectUCSDeptByLCDeptName" resultType="java.util.Map">
        SELECT * FROM t_ucs_lc_dept_rel WHERE lc_name = #{deptName}
    </select>

+    <select id="getIdFromDistrict" resultType="java.lang.Long">
+        SELECT id from sys_dept WHERE district = #{district};
+    </select>
+
 </mapper>
Author	SHA1	Message	Date
wangliwen	d1dab827ad	Merge branch 'master' into docker_package	2022-12-16 14:54:36 +08:00
wangliwen	7795d59223	Merge branch 'dev'	2022-12-16 14:54:25 +08:00
wangliwen	9e37adfceb	过滤后端 HIQDUCS-666	2022-12-16 14:54:13 +08:00