在第十章我們完成了對使用者管理的整合，本章我們將完成對組織架構管理的整合開發工作，首先開啟我們的rbac-produce工程，接著在com/produce/sys/dao目錄底下建立一個UserDao.java介面內容如下：

package com.produce.sys.dao;


import com.base.entity.OrgGroup;
import com.base.entity.QueryOrgGroup;
import com.produce.common.base.dao.GenericDao;

/**
 *@author linzf
 **/
public interface OrgGroupDao extends GenericDao<OrgGroup, QueryOrgGroup> {

    /**
     * 功能描述：根據父節點來查詢最大的節點的值
     * @param parentNode
     * @return
     */
    String getMaxOrgGroup(String parentNode);

    /**
     * 功能描述：根據選單節點NODE來查詢節點資料
     * @param node
     * @return
     */
    OrgGroup findByNode(String node);
}
 

接著在我們的mapper資料夾底下建立一個mybatis_orgGroup.xml檔案，檔案內容如下：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.produce.sys.dao.OrgGroupDao">
	<resultMap type="com.base.entity.OrgGroup" id="OrgGroupMap">
		<id property="groupId" column="group_id"/>
		<result property="existingNum" column="existing_num"/>
		<result property="groupCode" column="group_code"/>
		<result property="name" column="name"/>
		<result property="node" column="node"/>
		<result property="num" column="num"/>
		<result property="parentNode" column="parent_node"/>
	</resultMap>

	<!-- 根據父節點來查詢最大的節點的值 -->
	<select id="getMaxOrgGroup" parameterType="java.lang.String" resultType="java.lang.String">
		select max(o.node) from org_group o where o.parent_node = #{parentNode}
	</select>

	<!-- 根據選單節點NODE來查詢節點資料 -->
	<select id="findByNode" parameterType="java.lang.String" resultMap="OrgGroupMap">
			select * from org_group where node = #{node}
	</select>

	<!--根據主鍵獲取物件-->
	<select id="get" parameterType="com.base.entity.OrgGroup" resultMap="OrgGroupMap">
		SELECT group_id,existing_num,group_code,name,node,num,parent_node FROM org_group 
		WHERE group_id=#{groupId}
	</select>

	<!--儲存-->
	<insert id="save" parameterType="com.base.entity.OrgGroup" useGeneratedKeys="true" keyProperty="groupId">
		INSERT INTO org_group(existing_num,group_code,name,node,num,parent_node)
		VALUES(#{existingNum},#{groupCode},#{name},#{node},#{num},#{parentNode})
	</insert>

	<!--修改-->
	<update id="update" parameterType="com.base.entity.OrgGroup">
		UPDATE org_group SET group_code=#{groupCode},name=#{name},node=#{node},num=#{num},parent_node=#{parentNode}
		WHERE group_id=#{groupId}
	</update>

	<!--刪除-->
	<delete id="delete" parameterType="com.base.entity.OrgGroup">
		 DELETE FROM org_group WHERE group_id=#{groupId}
	</delete>

	<!--分頁查詢-->
	<select id="findByPage" parameterType="com.base.entity.QueryOrgGroup" resultMap="OrgGroupMap">
		SELECT group_id,existing_num,group_code,name,node,num,parent_node FROM org_group
		WHERE 1=1
		<if test="existingNum!=null and existingNum!='' "  >
		AND existing_num=#{existingNum}
		</if>
		<if test="groupCode!=null and groupCode!='' "  >
		AND group_code=#{groupCode}
		</if>
		<if test="name!=null and name!='' "  >
		AND name=#{name}
		</if>
		<if test="node!=null and node!='' "  >
		AND node=#{node}
		</if>
		<if test="num!=null and num!='' "  >
		AND num=#{num}
		</if>
		<if test="parentNode!=null and parentNode!='' "  >
		AND parent_node=#{parentNode}
		</if>
		<if test="sort!= null">
		order by ${sort} ${order}
		</if>
		limit #{offset},#{limit}
	</select>

	<!--統計-->
	<select id="count" parameterType="com.base.entity.QueryOrgGroup" resultType="int">
		SELECT count(*) FROM org_group
		WHERE 1=1
		<if test="existingNum!=null and existingNum!='' ">
		AND existing_num=#{existingNum}
		</if>
		<if test="groupCode!=null and groupCode!='' ">
		AND group_code=#{groupCode}
		</if>
		<if test="name!=null and name!='' ">
		AND name=#{name}
		</if>
		<if test="node!=null and node!='' ">
		AND node=#{node}
		</if>
		<if test="num!=null and num!='' ">
		AND num=#{num}
		</if>
		<if test="parentNode!=null and parentNode!='' ">
		AND parent_node=#{parentNode}
		</if>
	</select>

	<!--查詢-->
	<select id="query" parameterType="com.base.entity.QueryOrgGroup" resultMap="OrgGroupMap">
		SELECT group_id,existing_num,group_code,name,node,num,parent_node FROM org_group
		WHERE 1=1
		<if test="existingNum!=null and existingNum!='' ">
		AND existing_num=#{existingNum}
		</if>
		<if test="groupCode!=null and groupCode!='' ">
		AND group_code=#{groupCode}
		</if>
		<if test="name!=null and name!='' ">
		AND name=#{name}
		</if>
		<if test="node!=null and node!='' ">
		AND node=#{node}
		</if>
		<if test="num!=null and num!='' ">
		AND num=#{num}
		</if>
		<if test="parentNode!=null and parentNode!='' ">
		AND parent_node=#{parentNode}
		</if>
		<if test="sort!= null">
		order by ${sort} ${order}
		</if>
	</select>
</mapper>
 

接著在com/produce/sys/service目錄底下建立一個OrgGroupService.java實現類內容如下：

package com.produce.sys.service;


import com.base.entity.OrgGroup;
import com.base.entity.QueryOrgGroup;
import com.produce.common.base.dao.GenericDao;
import com.produce.common.base.service.GenericService;
import com.produce.sys.dao.OrgGroupDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

/**
 *@author linzf
 **/
@Service("orgGroupService")
@Transactional(rollbackFor={IllegalArgumentException.class})
public class OrgGroupService extends GenericService<OrgGroup, QueryOrgGroup> {
	@Autowired
	@SuppressWarnings("SpringJavaAutowiringInspection")
	private OrgGroupDao orgGroupDao;
	@Override
	protected GenericDao<OrgGroup, QueryOrgGroup> getDao() {
		return orgGroupDao;
	}

	/**
	 * 功能描述：根據父節點來查詢最大的節點的值
	 * @param parentNode
	 * @return
	 */
	public String getMaxOrgGroup(String parentNode){
		return orgGroupDao.getMaxOrgGroup(parentNode);
	}

	/**
	 * 功能描述：根據選單節點NODE來查詢節點資料
	 * @param node
	 * @return
	 */
	public OrgGroup findByNode(String node){
		return orgGroupDao.findByNode(node);
	}
}
 

最後在我們的com/produce/sys/controller底下建立我們的UserController.java實現類內容如下：

package com.produce.sys.controller;

import com.base.common.Page;
import com.base.entity.OrgGroup;
import com.base.entity.QueryOrgGroup;
import com.base.entity.QueryUser;
import com.produce.common.base.constant.SystemStaticConst;
import com.produce.common.base.controller.GenericController;
import com.produce.common.base.service.GenericService;
import com.produce.sys.service.OrgGroupService;
import com.produce.sys.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/*
* 類描述：
* @auther linzf
* @create 2018/2/6 0006 
*/
@RestController
@RequestMapping("/group")
public class OrgGroupController extends GenericController<OrgGroup, QueryOrgGroup> {

    @Autowired
    private OrgGroupService orgGroupService;
    @Autowired
    private UserService userService;

    @Override
    protected GenericService<OrgGroup, QueryOrgGroup> getService() {
        return orgGroupService;
    }

    @Override
    public Map<String, Object> get(@RequestBody OrgGroup entity) throws Exception {
        Map<String,Object> result = new HashMap<String, Object>();
        entity = orgGroupService.get(entity);
        if(entity==null){
            result.put(SystemStaticConst.RESULT, SystemStaticConst.FAIL);
            result.put(SystemStaticConst.MSG,"獲取資料失敗！");
        }else{
            result.put(SystemStaticConst.RESULT, SystemStaticConst.SUCCESS);
            result.put(SystemStaticConst.MSG,"獲取資料成功！");
            entity.setOrgGroup(orgGroupService.findByNode(entity.getParentNode()));
            result.put("entity",entity);
        }
        return result;
    }

    @Override
    public Map<String, Object> update(@RequestBody OrgGroup entity) throws Exception {
        Map<String,Object> result = new HashMap<String, Object>();
        OrgGroup update = new OrgGroup();
        update.setGroupId(entity.getGroupId());
        update = orgGroupService.get(update);
        update.setName(entity.getName());
        update.setGroupCode(entity.getGroupCode());
        update.setNum(entity.getNum());
        boolean success = orgGroupService.update(update);
        if(success){
            result.put(SystemStaticConst.RESULT, SystemStaticConst.SUCCESS);
            result.put(SystemStaticConst.MSG,"修改資料成功！");
            result.put("entity",entity);
        }else{
            result.put(SystemStaticConst.RESULT, SystemStaticConst.FAIL);
            result.put(SystemStaticConst.MSG,"修改資料失敗！");
        }
        return result;
    }

    /**
     * 功能描述：獲取組織架構底下的相應的使用者
     * @return
     */
    @RequestMapping(value = "/userList",method = RequestMethod.POST,produces = MediaType.APPLICATION_JSON_VALUE)
    public Map<String,Object> userList(@RequestBody QueryUser user){
        Map<String,Object> result = new HashMap<String, Object>();
        Page page = userService.findByGroupUserPage(user);
        result.put("totalCount",page.getTotal());
        result.put("result",page.getRows());
        return result;
    }

    /**
     * 功能描述：獲取組織架構的整顆選單樹
     * @return
     */
    @RequestMapping(value = "/loadGroupTree",method = RequestMethod.POST,produces = MediaType.APPLICATION_JSON_VALUE)
    public Map<String,Object> loadGroupTree(){
        Map<String,Object> result = new HashMap<String, Object>();
        List<OrgGroup> orgGroupList = orgGroupService.query(null);
        result.put(SystemStaticConst.RESULT, SystemStaticConst.SUCCESS);
        result.put(SystemStaticConst.MSG,"載入組織機構資料成功！");
        result.put("data",orgGroupList);
        return result;
    }

    @Override
    public Map<String, Object> save(@RequestBody OrgGroup entity) throws Exception  {
        String max_node = getMaxNode(orgGroupService.getMaxOrgGroup(entity.getOrgGroup().getNode()),entity.getOrgGroup().getNode());
        entity.setParentNode(entity.getOrgGroup().getNode());
        entity.setNode(max_node);
        return super.save(entity);
    }


    private String getMaxNode(String node,String parentNode){
        String max_node = "";
        if(node==null){
            max_node = parentNode + "001";
        }else{
            String n = (Integer.parseInt(node.substring(node.length()-3)) + 1) + "";
            switch(n.length()){
                case 1:
                    max_node = parentNode + "00" + n;
                    break;
                case 2:
                    max_node = parentNode + "0" + n;
                    break;
                case 3:
                    max_node = parentNode + "" + n;
                    break;
            }
        }
        return max_node;
    }



}

到此處我們完成了對使用者管理的整合，接著啟動我們的註冊中心，鏈路中心同時啟動我們的rbac-produce，接著直接訪問我們的swagger工程地址：http://127.0.0.1:8100/swagger-ui.html#/，那麼我們會看到如下的頁面則表示我們的角色管理已經整合成功了。

QQ交流群：578746866