浪潮对接单点登录:租户数据隔离功能3

zouyu

昨天 848d609a35569b029bbdd5ab91c1df2a0f568819

浪潮对接单点登录:租户数据隔离功能3

 src/main/java/com/ruoyi/project/system/controller/SysUserController.java

@@ -114,7 +114,8 @@
        }

        List<SysRole> roles = roleService.selectRoleAll();

        ajax.put("roles", SysUser.isAdmin(userId) ? roles : roles.stream().filter(r -> !r.isAdmin()).collect(Collectors.toList()));

        ajax.put("posts", postService.selectPostAll());

//        ajax.put("posts", postService.selectPostAll());

        ajax.put("posts", postService.selectPostByTenantId(SecurityUtils.getLoginUser().getTenantId()));

        SysUserDeptVo sysUserDeptVo = new SysUserDeptVo();

        sysUserDeptVo.setUserId(userId);

        List<SysUserDeptVo> sysUserDeptVos = userDeptService.userLoginFacotryList(sysUserDeptVo);


 src/main/java/com/ruoyi/project/system/mapper/SysPostMapper.java

@@ -2,6 +2,7 @@


import java.util.List;

import com.ruoyi.project.system.domain.SysPost;

import org.apache.ibatis.annotations.Param;



/**

 * 岗位信息 数据层

@@ -96,4 +97,6 @@
     * @return 结果

     */

    public SysPost checkPostCodeUnique(String postCode);



    List<SysPost> selectPostByTenantId(@Param("tenantId") Long tenantId);

}


 src/main/java/com/ruoyi/project/system/service/ISysPostService.java

@@ -96,4 +96,6 @@
     * @return 结果

     */

    public int updatePost(SysPost post);



    public List<SysPost> selectPostByTenantId(Long tenantId);

}


 src/main/java/com/ruoyi/project/system/service/impl/SysPostServiceImpl.java

@@ -1,5 +1,6 @@
package com.ruoyi.project.system.service.impl;



import java.util.Collections;

import java.util.List;



import com.ruoyi.framework.aspectj.lang.annotation.DataScope;

@@ -178,4 +179,10 @@
    {

        return postMapper.updatePost(post);

    }



    @Override

    @DataScope(tenantIdFelid = "p")

    public List<SysPost> selectPostByTenantId(Long tenantId) {

        return postMapper.selectPostByTenantId(tenantId);

    }

}


 src/main/java/com/ruoyi/tide/controller/TideController.java

@@ -19,6 +19,8 @@
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -62,6 +64,7 @@
    }

    @PostMapping("/applicationOrdering")
    @Transactional(rollbackFor = Exception.class,isolation = Isolation.READ_COMMITTED)
    public JSONObject order (@RequestBody TidePojo tidePojo) {
        SysUser user = userService.selectUserByUserName(tidePojo.getPltAccountLogin());
        String defaultPwd = "I73Kj+Mn$+SI";//默认开通密码固定写死
@@ -81,6 +84,8 @@
            //查询公司
            SysDept newSysDept = deptService.selectDeptByDeptName(dept.getDeptName());
            dept.setDeptId(ObjectUtils.isEmpty(newSysDept)?100L:newSysDept.getDeptId());
            dept.setTenantId(dept.getDeptId());
            deptService.updateDept(dept);
            user = new SysUser();
            String password = SecurityUtils.encryptPassword(defaultPwd);
            user.setPassword(password);

 src/main/resources/mapper/system/SysDeptMapper.xml

@@ -132,6 +132,7 @@
             <if test="email != null">email = #{email},</if>
            <if test="deptNick != null and deptNick != '' ">dept_nick = #{deptNick},</if>
             <if test="status != null and status != ''">status = #{status},</if>
             <if test="tenantId != null and tenantId != ''">tenant_id = #{tenantId},</if>
             <if test="updateBy != null and updateBy != ''">update_by = #{updateBy},</if>
             update_time = sysdate()
         </set>

 src/main/resources/mapper/system/SysPostMapper.xml

@@ -73,8 +73,14 @@
        <include refid="selectPostVo"/>
         where post_code=#{postCode} limit 1
    </select>
	
    <update id="updatePost" parameterType="com.ruoyi.project.system.domain.SysPost">
    <select id="selectPostByTenantId" resultType="com.ruoyi.project.system.domain.SysPost">
        <include refid="selectPostVo"/>
        <where>
            AND p.tenant_id = #{tenantId}
        </where>
    </select>

    <update id="updatePost" parameterType="com.ruoyi.project.system.domain.SysPost">
         update sys_post
         <set>
             <if test="postCode != null and postCode != ''">post_code = #{postCode},</if>