Django项目中的实现rbac功能

一、什么是rbac
rbac翻译意思就是(Role-Based Access Contro)基于角色的权限控制

二、优势
1.将用户和权限的关系
2.易扩展,易于维护

比如张三李四需要用客户列表访问权限,如果上百个用户,单独分配权限会麻烦,如果单独放客户列表权限在销售角色里面,张三李四放到销售角色里就OK了

三、RBAC流程图

第一张:用户表
第二张:角色表
第三张表:用户表和角色表多对多的关系,一个用户可以有多个角色
第四张表:权限表
第五张表:权限表和角色表多对多的关系,多个权限可以放到一个角色里面

四、效果图

五、本章案例
背景:开发一个固定资产管理系统
实现功能:根据不同用户登陆分配不同权限,jack是CTO这个角色,CTO对所有页面有增删改查的权限,当jack登陆的时候,显示有增删改查的按钮。当登陆lucy,因为是COO的权限,有所有页面查询的权限,只能查看,无法添加修改删除。

1.在django中把rbac做成组件,到别的项目也可以直接拿来用
2.在项目中新创建一个名为rbac应用,startapp rbac
3.在rbac应用里mode.pyl写ORM,分别是账号表,角色表,权限表,权限组表

from django.db import models

# Create your models here.
class Account(models.Model):
    name=models.CharField(max_length=32)
    pwd=models.CharField(max_length=32)
    roles=models.ManyToManyField(to="Role")
    def __str__(self): return self.name

class Role(models.Model):
    title=models.CharField(max_length=32)
    permissions=models.ManyToManyField(to="Permission")
    def __str__(self): return self.title

class Permission(models.Model):
    title=models.CharField(max_length=32)
    url=models.CharField(max_length=32)
    action=models.CharField(max_length=32,default="")
    group=models.ForeignKey("PermissionGroup",default=1,on_delete=models.CASCADE)
    def __str__(self):return self.title

class PermissionGroup(models.Model):
    title = models.CharField(max_length=32)
    def __str__(self): return self.title

4.在rdac的admin文件中添加下面数据,为了后台管理

from django.contrib import admin
from .models import *
class PerConfig(admin.ModelAdmin):
list_display = ["title","url","group","action"]
admin.site.register(Account)
admin.site.register(Role)
admin.site.register(Permission,PerConfig)
admin.site.register(PermissionGroup)

5.在后台分别对应写入4张表数据

这是权限表,这里可以理解为一个URL等于一个权限

6.开始写组件
在rbac应用中,创建一个service的python包,然后在下面创建perssions.py文件

###############################在session注册权限列表##############################
def initial_session(user,request):
    #获取当前用户所在的所有角色拥有的权限url,组id,动作,去掉重复
    permissions = user.roles.all().values("permissions__url","permissions__group_id","permissions__action").distinct()

    #把结果放到一个字典中
    permission_dict={}
    for item in permissions:
        gid=item.get(‘permissions__group_id‘)

        #判断当前组id是否已经存在到字典中
        if not gid in permission_dict:
            #加逗号是因为考虑还有数据
            #permission_dict{1:{"url":["/device_list/"],"action":"[search"]},2:{"url":["/device_list/"],"action":["search"}]}
            permission_dict[gid]={
                "urls":[item["permissions__url"],],
                "actions":[item["permissions__action"],]
            }
        else:
            permission_dict[gid]["urls"].append(item["permissions__url"])
            permission_dict[gid]["actions"].append(item["permissions__action"])

    request.session[‘permission_dict‘] = permission_dict

然后再创建rbac.py,写一个类,最终写到setting.py的MIDDLEWARE。

import re
from django.utils.deprecation import MiddlewareMixin
from django.shortcuts import  HttpResponse,redirect

class ValidPermission(MiddlewareMixin):
    def process_request(self,request):

        # 当前访问路径
        current_path = request.path_info

        # 检查是否属于白名单,如果是下面路径url不用校验
        valid_url_list=["/login/","/reg/","/admin/.*","/index/",‘/logout/‘]

        for valid_url in valid_url_list:
            ret=re.match(valid_url,current_path)
            if ret:
                return None

        # 校验是否登录,这步是为了让用户去登陆,而不是返回一个没有权限的页面
        user_id=request.session.get("user_id")
        if not user_id:
            return redirect("/index/")

        # 校验url
        permission_dict=request.session.get("permission_dict")
        for item in permission_dict.values():
              urls=item[‘urls‘]
              for reg in urls:
                  reg="^%s$"%reg
                  ret=re.match(reg,current_path)
                  if ret:
                      request.actions=item[‘actions‘]
                      return None

        return HttpResponse("没有访问权限!")

7.写views.py文件,当用户在登陆页面登陆发送账号密码过来时,进行校验,如果存在账号表中,就在session会话中注册这个用户id,调用rbac组件,如果通过了就返回页面

#登陆函数
def login(request):
    if  request.method=="POST":
        user=request.POST.get("user")
        pwd=request.POST.get("pwd")
        #获取Account表里面去找有没有当前的用户名和密码
        user=Account.objects.filter(name=user,pwd=pwd).first()
        if user:
            ############################### 在session中注册用户ID######################
            request.session["user_id"]=user.pk
            #调用组件
            initial_session(user,request)
            return redirect("/device_list/")
    return render(request,"index.html")

8.在view.py视图文件中添加下面代码,Per(request.actions)获取当前用户动作

class Per(object):
    def __init__(self,actions):
        self.actions=actions
    def add(self):
        return "add" in self.actions
    def delete(self):
        return "delete" in self.actions
    def edit(self):
        return "edit" in self.actions
    def list(self):
        return "search" in self.actions

def device_list(request):
    ret = models.Device.objects.all()
    #在前端页面显示用户名
    per = Per(request.actions)
    return render(request, ‘device/device_list.html‘, locals())

9.前端页面写模板语言,下面代码是写在form表单

<div class="col-md-1 pull-right new-add">
    #判断用户是否有add添加权限,如果有则显示按钮,否则不显示
     {% if per.add %}
         <a href="/add_device/" class="btn btn-success">
             <i class="fa fa-plus fa-fw"></i>新增
         </a>
     {% endif %}
</div>

同样是判断是否有删除和编辑权限

{% if per.delete %}
   <a class="btn btn-danger del" href="/del_device/{{ device.id }}">
        <i class="fa fa-trash-o fa-fw"></i>删除
   </a>
   {% endif %}
   {% if per.edit %}
      <a class="btn btn-info" href="/edit_device/{{ device.id }}">
       <i class="fa fa-pencil fa-fw"></i>编辑
     </a>
{% endif %}

10.显示图,登陆jack用户

再登陆luyc用户

可以看到lucy没有添加删除编辑的按钮,就算成功了。

补充一点,url和views.py都写在项目中,不是写在应用中喔。

原文地址:https://blog.51cto.com/beckoning/2353758

时间: 2024-08-30 04:29:14

Django项目中的实现rbac功能的相关文章

Django项目中使用Redis

Django项目中使用Redis DjangoRedis 1 redis Redis 是一个 key-value 存储系统,常用于缓存的存储.django-redis 基于 BSD 许可, 是一个使 Django 支持 Redis cache/session 后端的全功能组件. 1.1 为何要用 django-redis ? 持续更新 本地化的 redis-py URL 符号连接字符串 可扩展客户端 可扩展解析器 可扩展序列器 默认客户端主/从支持 完善的测试 已在一些项目的生产环境中作为 ca

django项目中遇到要实现定时任务

django项目中遇到要实现定时任务,所以选用了简单易用的django-crontab插件. 1.安装 django-crontab pip install django-crontab 2.定时要执行的脚本 先写个简单的测试脚本. ipoms/crons.py import datetime def update_stock_status(): start_time = datetime.datetime.now() print start_time, ", begin update_stoc

在Django项目中使用富文本编辑器

1 开发要点 现在网上有很多的富文本编辑器,包括Markdown.tinymce.UEditor.KindEditor.ckeditor等等.在项目中使用这些编辑器主要有以下几个问题: 编辑页面 在HTML页面渲染编辑器: 定制编辑器的功能,比如有哪些文本样式.图片上传.代码插入: 定制编辑器的样式,指的是编辑器整体的样式,比如高度.宽度.显示位置等等: 预览内容: 获取内容: 显示页面 显示内容: 2 Django APP 下表列出一些常用的APP,它们都可以在GitHub上找的到,链接见下文

django项目中购物车的实现

对于做项目而言,最重要的是分析清楚自己负责模块的思路,确定思路后,把每一步实现的步骤确定后,根据步骤,去实现代码,测试. 购物车的逻辑:    登录用户可以添加购物车,未登陆用户页可以添加到购物车    登陆用户的保存user.id sku_id count selected      保存在redis中,以hash和set两种方式保存    未登陆用户保存sku_id count selectd  保存再cookie中    cart = {            sku_id:{count:

异步任务利器Celery(二)在django项目中使用Celery

Celery 4.0支持django1.8及以上的版本,低于1.8的项目使用Celery 3.1. 一个django项目的组织如下: - proj/ - manage.py - proj/ - __init__.py - settings.py - urls.py 首先建立proj/proj/celery.py文件: from __future__ import absolute_import, unicode_literals import os from celery import Cele

django项目中使用FastDFS

FastDFS客户端与自定义文件存储系统 1. FastDFS的Python客户端 python版本的FastDFS客户端使用说明参考https://github.com/jefforeilly/fdfs_client-py 安装 安装提供给大家的fdfs_client-py-master.zip到虚拟环境中 pip install fdfs_client-py-master.zippip install mutagenpip isntall requests 使用 使用FastDFS客户端,需

从数据库反向生成django项目中的models文件

1.创建一个django项目 2.在项目配置文件settings.py中配置好数据库的相关配置 3.确保所关联的数据库中已经有表存在 4.在pycharm终端进入到项目的根目录,执行python manage.py inspectdb,查看可以导入到models的相关信息 5.执行python manage.py inspectdb > (需要导入表的app)/models.py,即可完成反向生成models文件 6.进入models文件进行相关修改 原文地址:https://www.cnblo

django 项目中mysql 的编码,数据库迁移问题

以管理员的身份进入cmd net start mysql mysql -u root -p 没有密码直接回车,进入mysql可以创建数据库, 如退出mysql  执行 \q:命令 创建数据库  记得指定编码    create database orm_1128 character set utf8;  orm_1128是数据库名字 修改数据库的字符集mysql>use mydb mysql>alter database mydb character set utf8; 如果报错, ERROR

Django项目中引用js,css文件的可行方法

首先,在manager.py同层级下创建static文件夹, 里面放上css , js, image等文件或者文件夹 第二,在项目同名的app中settings文件末尾添加以下内容: STATIC_URL = '/static/' HERE = os.path.dirname(os.path.abspath(__file__)) HERE = os.path.join(HERE, '../') STATICFILES_DIRS = ( # Put strings here, like "/hom