个人中心
文章发布
退出
作者热门文章
- Java锁的逻辑（结合对象头和ObjectMonitor）
- 还在用饼状图？来瞧瞧这些炫酷的百分比可视化新图形（附代码实现）⛵
- 自动注册实体类到EntityFrameworkCore上下文，并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
29
4
django rest_framework中GenericAPIView配合拓展类mixin或者视图集viewset可以复用其代码，减少自己编写的代码量。下面我要实现自己的视图类，以减少代码量
新建一个myView.py
from
collections
import
OrderedDict
from
rest_framework
import
status
from
rest_framework.generics
import
GenericAPIView
from
rest_framework.pagination
import
PageNumberPagination
from
rest_framework.response
import
Response
from
rest_framework.settings
import
api_settings
from
rest_framework.views
import
APIView
class
MyView(APIView):
queryset
= None
#
模型数据
serializer_class = None
#
序列化类
filter_class = []
#
过滤字段
lookup_field =
'
id
'
#
删改的查找字段
ordeing_field = (
'
id
'
,)
#
排序字段
pagination_class = None
#
分页器
def
get_queryset(self):
"""
获取queryset数据列表
"""
assert
self.queryset
is
not
None, (
"
'%s' should either include a `queryset` attribute,
"
"
or override the `get_queryset()` method.
"
% self.
__class__
.
__name__
)
self.queryset
=
self.queryset.all()
#
self.filter_queryset()
return
self.queryset
def
filter_queryset(self, queryset):
"""
过滤queryset数据
"""
search_dict
=
{}
for
fc
in
self.filter_class:
field
=
self.request.query_params.dict().get(fc)
if
field:
search_dict[fc]
=
field
queryset
= queryset.filter(**
search_dict)
return
queryset
def
get_serializer(self, *args, **
kwargs):
"""
获取序列化模型
"""
serializer_class
=
self.get_serializer_class()
kwargs.setdefault(
'
context
'
, self.get_serializer_context())
return
serializer_class(*args, **
kwargs)
def
get_serializer_class(self):
"""
获取序列化模型类， 判断存在否
"""
assert
self.serializer_class
is
not
None, (
"
'%s' should either include a `serializer_class` attribute,
"
"
or override the `get_serializer_class()` method.
"
% self.
__class__
.
__name__
)
return
self.serializer_class
def
get_serializer_context(self):
return
{
'
request
'
: self.request,
'
format
'
: self.format_kwarg,
'
view
'
: self
}
def
create(self, request, *args, **
kwargs):
"""
创建一条数据
"""
serializer_class
=
self.get_serializer_class()
serializer
= serializer_class(data=
request.data)
serializer.is_valid(raise_exception
=
True)
serializer.save()
return
Response(serializer.data, status=
status.HTTP_201_CREATED)
def
update(self, request, *args, **
kwargs):
"""
更新修改一条数据
"""
try
:
instance
= self.queryset.get(id=
request.data.get(self.lookup_field))
except
Exception:
return
Response({
'
state
'
:
'
fail
'
,
'
msg
'
:
'
未找到该数据
'
}, status=
status.HTTP_400_BAD_REQUEST)
serializer_class
=
self.get_serializer_class()
serializer
= serializer_class(instance=instance, data=
request.data)
serializer.is_valid(raise_exception
=
True)
serializer.save()
return
Response(serializer.data, status=
status.HTTP_201_CREATED)
def
destroy(self, request, *args, **
kwargs):
"""
删除数据，传入的时数组，表示可以删除多条
"""
try
:
instance
= self.queryset.filter(id__in=
request.data.get(self.lookup_field))
except
Exception:
return
Response({
'
state
'
:
'
fail
'
,
'
msg
'
:
'
未找到数据
'
}, status=
status.HTTP_400_BAD_REQUEST)
instance.delete()
return
Response({
'
state
'
:
'
success
'
,
'
msg
'
:
'
删除成功
'
}, status=
status.HTTP_204_NO_CONTENT)
@property
def
paginator(self):
"""
分页器属性
"""
if
not
hasattr(self,
'
_paginator
'
):
if
self.pagination_class
is
None:
self._paginator
=
None
else
:
self._paginator
=
self.pagination_class()
return
self._paginator
def
get_paginate_queryset(self, queryset):
"""
获取分页queryset
"""
paginator
=
self.paginator
if
paginator
is
None:
return
None
return
paginator.paginate_queryset(
queryset
=
queryset,
request
=
self.request,
view
=
self
)
def
get_paginated_response(self, data):
"""
获取分页后的返回
"""
assert
self.paginator
is
not
None
#
print(self.paginator.page.paginator.count)
return
self.paginator.get_paginated_response(data)
def
order_by_queryset(self, queryset):
"""
queryset数据进行排序
"""
return
queryset.order_by(*
self.ordeing_field)
class
MyPagination(PageNumberPagination):
page_size
= 10
#
表示每页的默认显示数量
max_page_size = 50
#
max_page_size：表示每页最大显示数量，做限制使用，避免突然大量的查询数据，数据库崩溃
page_size_query_param =
'
page_size
'
#
page_size_query_param：表示url中每页数量参数
page_query_param =
'
page_num
'
#
page_query_param：表示url中的页码参数
def
get_paginated_response(self, data):
"""
重构分页返回的数据
"""
return
Response(OrderedDict([
(
'
total
'
, self.page.paginator.count),
(
'
data
'
, data)
]))
class
MixinGetPageList:
"""
get只获取分页数据
"""
def
get(self, request, *args, **
kwargs):
queryset
=
self.get_queryset()
queryset
=
self.filter_queryset(queryset)
queryset
=
self.order_by_queryset(queryset)
serializer_class
=
self.get_serializer_class()
queryset
=
self.get_paginate_queryset(queryset)
serializer
= serializer_class(queryset, many=
True)
return
self.get_paginated_response(serializer.data)
class
MixinGetAllList:
"""
get只获取所有数据
"""
def
get(self, request, *args, **
kwargs):
queryset
=
self.get_queryset()
queryset
=
self.filter_queryset(queryset)
queryset
=
self.order_by_queryset(queryset)
serializer_class
=
self.get_serializer_class()
serializer
= serializer_class(queryset, many=
True)
return
Response(serializer.data)
class
MixinGetList:
"""
get获取分页和所有数据
"""
all_serializer_class
= None
#
获取所有的序列化类
def
get(self, request, *args, **
kwargs):
queryset
=
self.get_queryset()
queryset
=
self.filter_queryset(queryset)
queryset
=
self.order_by_queryset(queryset)
params
=
request.query_params.dict()
if
self.pagination_class
is
not
None
and
params.get(
'
all
'
)
is
None:
serializer_class
=
self.get_serializer_class()
queryset
=
self.get_paginate_queryset(queryset)
serializer
= serializer_class(queryset, many=
True)
return
self.get_paginated_response(serializer.data)
self.serializer_class
=
self.all_serializer_class
serializer_class
=
self.get_serializer_class()
serializer
= serializer_class(queryset, many=
True)
return
Response(serializer.data)
class
MixinPostCreateModel:
"""
post增加数据
"""
def
post(self, request):
return
self.create(request)
class
MixinPutUpdateModel:
"""
put修改数据
"""
def
put(self, request):
return
self.update(request)
class
MixinDeleteDestroyModel:
"""
delete删除数据
"""
def
delete(self, request):
return
self.destroy(request)
class
MyMixin(MyView):
"""
增删改查
"""
def
get(self, request, *args, **
kwargs):
queryset
=
self.get_queryset()
queryset
=
self.filter_queryset(queryset)
queryset
=
self.order_by_queryset(queryset)
serializer_class
=
self.get_serializer_class()
if
self.pagination_class
is
not
None:
queryset
=
self.get_paginate_queryset(queryset)
#
print(queryset)
serializer
= serializer_class(queryset, many=
True)
return
self.get_paginated_response(serializer.data)
serializer
= serializer_class(queryset, many=
True)
return
Response(serializer.data)
def
post(self, request):
return
self.create(request)
def
put(self, request):
return
self.update(request)
def
delete(self, request):
return
self.destroy(request)
。
定义的数据库模型，也就是models.py的模型 。
class
Gender(models.Model):
class
Meta:
db_table
=
'
gender
'
name
= models.CharField(verbose_name=
"
名字
"
, max_length=16)
。
序列化文件 serializer.py 。
class
GenderSerializer(serializers.ModelSerializer):
class
Meta:
model
=
models.Gender
fields
=
'
__all__
'
def
create(self, validated_data):
res
= models.Gender.objects.create(**
validated_data)
return
res
def
update(self, instance, validated_data):
instance.name
= validated_data.get(
'
name
'
)
instance.save()
return
instance
。
然后新建一个视图文件 。
from
ani
import
models
from
ani.serializer
import
GenderSerializer
from
utils.myView
import
MyPagination, MyView, MixinGetList, MixinPostCreateModel, MixinPutUpdateModel, \
MixinDeleteDestroyModel
class
GenderView(MyView, MixinGetList, MixinPostCreateModel, MixinPutUpdateModel, MixinDeleteDestroyModel):
queryset
=
models.Gender.objects.all()
serializer_class
=
GenderSerializer
all_serializer_class
=
GenderSerializer
filter_class
= [
'
name__icontains
'
]
pagination_class
=
MyPagination
lookup_field
=
'
id
'
ordeing_field
= (
'
-id
'
,)
依次继承get、post、put、delete，实现查、增、改、删.
。
。
。
接下来对请求参数，及返回参数进行加密，加解密可以看我之前的文章 。
先新建一个MyResponse.py，自定义自己的返回类 。
import
json
from
rest_framework.response
import
Response
from
utils.encryption
import
setDataAes
class
AESResponse(Response):
def
__init__
(self, data=None, secret=
'
www
'
, status=None, template_name=None, headers=
None,
exception
=False, content_type=
None):
enaes_data
=
setDataAes(secret, json.dumps(data))
super(AESResponse, self).
__init__
(data=enaes_data, status=status, template_name=template_name, headers=
headers,
exception
=exception, content_type=content_type)
。
将myView.py中的Response都替换为自定义返回类，新建了一个myViewEncryp.py 。
from
collections
import
OrderedDict
from
rest_framework
import
status
from
rest_framework.generics
import
GenericAPIView
from
rest_framework.pagination
import
PageNumberPagination
from
rest_framework.settings
import
api_settings
from
rest_framework.views
import
APIView
from
utils.MyResponse
import
AESResponse
from
utils.tools
import
get_secret
class
MyView(APIView):
queryset
= None
#
模型数据
serializer_class = None
#
序列化模型
filter_class = []
#
过滤字段
lookup_field =
'
id
'
#
删改的查找字段
ordeing_field = (
'
id
'
,)
#
排序字段
pagination_class = None
#
分页器
def
get_queryset(self):
"""
获取queryset数据列表
"""
assert
self.queryset
is
not
None, (
"
'%s' should either include a `queryset` attribute,
"
"
or override the `get_queryset()` method.
"
% self.
__class__
.
__name__
)
self.queryset
=
self.queryset.all()
#
self.filter_queryset()
return
self.queryset
def
filter_queryset(self, queryset):
"""
过滤queryset数据
"""
search_dict
=
{}
for
fc
in
self.filter_class:
field
=
self.request.query_params.dict().get(fc)
if
field:
search_dict[fc]
=
field
queryset
= queryset.filter(**
search_dict)
return
queryset
def
get_serializer(self, *args, **
kwargs):
"""
获取序列化模型
"""
serializer_class
=
self.get_serializer_class()
kwargs.setdefault(
'
context
'
, self.get_serializer_context())
return
serializer_class(*args, **
kwargs)
def
get_serializer_class(self):
"""
获取序列化模型类， 判断存在否
"""
assert
self.serializer_class
is
not
None, (
"
'%s' should either include a `serializer_class` attribute,
"
"
or override the `get_serializer_class()` method.
"
% self.
__class__
.
__name__
)
return
self.serializer_class
def
get_serializer_context(self):
return
{
'
request
'
: self.request,
'
format
'
: self.format_kwarg,
'
view
'
: self
}
def
create(self, request, *args, **
kwargs):
"""
创建一条数据
"""
serializer_class
=
self.get_serializer_class()
serializer
= serializer_class(data=
request.data)
serializer.is_valid(raise_exception
=
True)
serializer.save()
secret
=
get_secret(request)
return
AESResponse(serializer.data, secret=secret, status=
status.HTTP_201_CREATED)
def
update(self, request, *args, **
kwargs):
"""
更新修改一条数据
"""
secret
=
get_secret(request)
try
:
instance
= self.queryset.get(id=
request.data.get(self.lookup_field))
except
Exception:
return
AESResponse({
'
state
'
:
'
fail
'
,
'
msg
'
:
'
未找到该数据
'
}, secret=secret, status=
status.HTTP_400_BAD_REQUEST)
serializer_class
=
self.get_serializer_class()
serializer
= serializer_class(instance=instance, data=
request.data)
serializer.is_valid(raise_exception
=
True)
serializer.save()
return
AESResponse(serializer.data, secret=secret, status=
status.HTTP_201_CREATED)
def
destroy(self, request, *args, **
kwargs):
"""
删除数据，传入的时数组，表示可以删除多条
"""
secret
=
get_secret(request)
try
:
instance
= self.queryset.filter(id__in=
request.data.get(self.lookup_field))
except
Exception:
return
AESResponse({
'
state
'
:
'
fail
'
,
'
msg
'
:
'
未找到数据
'
}, secret=secret, status=
status.HTTP_400_BAD_REQUEST)
instance.delete()
return
AESResponse({
'
state
'
:
'
success
'
,
'
msg
'
:
'
删除成功
'
}, secret=secret, status=
status.HTTP_204_NO_CONTENT)
@property
def
paginator(self):
"""
分页器属性
"""
if
not
hasattr(self,
'
_paginator
'
):
if
self.pagination_class
is
None:
self._paginator
=
None
else
:
self._paginator
=
self.pagination_class()
return
self._paginator
def
get_paginate_queryset(self, queryset):
"""
获取分页queryset
"""
paginator
=
self.paginator
if
paginator
is
None:
return
None
return
paginator.paginate_queryset(
queryset
=
queryset,
request
=
self.request,
view
=
self
)
def
get_paginated_response(self, data):
"""
获取分页后的返回
"""
assert
self.paginator
is
not
None
#
print(self.paginator.page.paginator.count)
return
self.paginator.get_paginated_response(data)
def
order_by_queryset(self, queryset):
"""
queryset数据进行排序
"""
return
queryset.order_by(*
self.ordeing_field)
class
MyPagination(PageNumberPagination):
page_size
= 10
#
表示每页的默认显示数量
max_page_size = 50
#
max_page_size：表示每页最大显示数量，做限制使用，避免突然大量的查询数据，数据库崩溃
page_size_query_param =
'
page_size
'
#
page_size_query_param：表示url中每页数量参数
page_query_param =
'
page_num
'
#
page_query_param：表示url中的页码参数
def
get_paginated_response(self, data):
"""
重构分页返回的数据
"""
secret
=
get_secret(self.request)
return
AESResponse(OrderedDict([
(
'
total
'
, self.page.paginator.count),
(
'
data
'
, data)
]), secret
=
secret)
class
MixinGetPageList:
"""
get只获取分页数据
"""
def
get(self, request, *args, **
kwargs):
queryset
=
self.get_queryset()
queryset
=
self.filter_queryset(queryset)
queryset
=
self.order_by_queryset(queryset)
serializer_class
=
self.get_serializer_class()
queryset
=
self.get_paginate_queryset(queryset)
serializer
= serializer_class(queryset, many=
True)
return
self.get_paginated_response(serializer.data)
class
MixinGetAllList:
"""
get只获取所有数据
"""
def
get(self, request, *args, **
kwargs):
queryset
=
self.get_queryset()
queryset
=
self.filter_queryset(queryset)
queryset
=
self.order_by_queryset(queryset)
serializer_class
=
self.get_serializer_class()
serializer
= serializer_class(queryset, many=
True)
secret
=
get_secret(request)
return
AESResponse(serializer.data, secret=
secret)
class
MixinGetList:
"""
get获取分页和所有数据
"""
all_serializer_class
=
None
def
get(self, request, *args, **
kwargs):
queryset
=
self.get_queryset()
queryset
=
self.filter_queryset(queryset)
queryset
=
self.order_by_queryset(queryset)
params
=
request.query_params.dict()
if
self.pagination_class
is
not
None
and
params.get(
'
all
'
)
is
None:
serializer_class
=
self.get_serializer_class()
queryset
=
self.get_paginate_queryset(queryset)
serializer
= serializer_class(queryset, many=
True)
return
self.get_paginated_response(serializer.data)
self.serializer_class
=
self.all_serializer_class
serializer_class
=
self.get_serializer_class()
serializer
= serializer_class(queryset, many=
True)
secret
=
get_secret(request)
return
AESResponse(serializer.data, secret=
secret)
class
MixinPostCreateModel:
"""
post增加数据
"""
def
post(self, request):
return
self.create(request)
class
MixinPutUpdateModel:
"""
put修改数据
"""
def
put(self, request):
return
self.update(request)
class
MixinDeleteDestroyModel:
"""
delete删除数据
"""
def
delete(self, request):
return
self.destroy(request)
class
MyMixin(MyView):
def
get(self, request, *args, **
kwargs):
queryset
=
self.get_queryset()
queryset
=
self.filter_queryset(queryset)
queryset
=
self.order_by_queryset(queryset)
serializer_class
=
self.get_serializer_class()
if
self.pagination_class
is
not
None:
queryset
=
self.get_paginate_queryset(queryset)
#
print(queryset)
serializer
= serializer_class(queryset, many=
True)
return
self.get_paginated_response(serializer.data)
serializer
= serializer_class(queryset, many=
True)
secret
=
get_secret(request)
return
AESResponse(serializer.data, secret=
secret)
def
post(self, request):
return
self.create(request)
def
put(self, request):
return
self.update(request)
def
delete(self, request):
return
self.destroy(request)
。
其中加密的密钥是用户的token，或者写死的字符串，tools.py 。
def
get_secret(request):
"""
获取加密的key
"""
return
request.META.get(
'
HTTP_AUTHORIZATION
'
)
or
'
wchime
'
。
如果前端的请求参数加密，那么需要对参数解密，使用装饰器，decorators.py 。
def
request_decrypt(func):
"""
解密请求参数
只对data解密，data传入的必须是字典，不然没有update属性
"""
def
wrap(request, *args, **
kwargs):
data
=
request.data
#
print(data)
secret =
get_secret(request)
decrypt_data
= getDataAes(secret, data.get(
'
text
'
))
if
decrypt_data:
data
=
json.loads(decrypt_data)
del
request.data[
'
text
'
]
request.data.update(data)
#
print(decrypt_data)
return
func(request, *args, **
kwargs)
return
wrap
。
这时候视图文件需要装饰器解密 。
from
django.utils.decorators
import
method_decorator
from
ani
import
models
from
ani.serializer
import
GenderSerializer
from
utils.decorators
import
request_decrypt
from
utils.myViewEncryp
import
MyPagination, MyView, MixinGetList, MixinPostCreateModel, MixinPutUpdateModel, \
MixinDeleteDestroyModel
@method_decorator(request_decrypt, name
=
'
put
'
)
@method_decorator(request_decrypt, name
=
'
delete
'
)
@method_decorator(request_decrypt, name
=
'
post
'
)
class
GenderView(MyView, MixinGetList, MixinPostCreateModel, MixinPutUpdateModel, MixinDeleteDestroyModel):
queryset
=
models.Gender.objects.all()
serializer_class
=
GenderSerializer
all_serializer_class
=
GenderSerializer
filter_class
= [
'
name__icontains
'
]
pagination_class
=
MyPagination
lookup_field
=
'
id
'
ordeing_field
= (
'
-id
'
,)
。
项目文件结构 。
。
。
请求提交参数脚本 。
import
json
import
requests
from
encryption
import
setDataAes, getDataAes
d
= {
'
name
'
:
'
aaa
'
}
body
= setDataAes(
"
wchime
"
, json.dumps(d))
url
=
'
http://127.0.0.1:4000/ani/gender
'
print
(body)
data
= {
'
text
'
: body}
res
= requests.post(url, json=
data)
print
(res.text)
print
(getDataAes(
"
wchime
"
, res.text))
。
打印结果 。
。
。
。
最后此篇关于Django自定义视图类及实现请求参数和返回参数加解密的文章就讲到这里了,如果你想了解更多关于Django自定义视图类及实现请求参数和返回参数加解密的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
29
4
0
好的，所以我编辑了以下... 只需将以下内容放入我的 custom.css #rt-utility .rt-block {CODE HERE} 但是当我尝试改变... 与 #rt-sideslid
在表格 View 中，我有一个自定义单元格(在界面生成器中高度为 500)。在该单元格中，我有一个 Collection View ，我按 (10,10,10,10) 固定到边缘。但是在 tablev
对于我的无能，我很抱歉，但总的来说，我对 Cocoa、Swift 和面向对象编程还很陌生。我的主要来源是《Cocoa Programming for OS X》(第 5 版)，以及 Apple 的充满
我正在使用 meta-tegra 为我的 NVIDIA Jetson Nano 构建自定义图像。我需要 PyTorch，但没有它的配方。我在设备上构建了 PyTorch，并将其打包到设备上的轮子中。现
在 jquery 中使用 $.POST 和 $.GET 时，有没有办法将自定义变量添加到 URL 并发送它们？我尝试了以下方法: $.ajax({type:"POST", url:"file.php?
Traefik 已经默认实现了很多中间件，可以满足大部分我们日常的需求，但是在实际工作中，用户仍然还是有自定义中间件的需求，为解决这个问题，官方推出了一个 Traefik Pilot[1] 的功
我想让我的 CustomTextInputLayout 将 Widget.MaterialComponents.TextInputLayout.OutlinedBox 作为默认样式，无需在 XML 中
我在 ~/.emacs 中有以下自定义函数: (defun xi-rgrep (term) (grep-compute-defaults) (interactive "sSearch Te
我有下表: 考虑到每个月的权重，我的目标是在 5 个月内分散 10,000 个单位。与 10,000 相邻的行是我最好的尝试(我在这上面花了几个小时)。黄色是我所追求的。 我试图用来计算的逻辑如下:计
我的表单中有一个字段，它是文件类型。当用户点击保存图标时，我想自然地将文件上传到服务器并将文件名保存在数据库中。我尝试通过回显文件名来测试它，但它似乎不起作用。另外，如何将文件名添加到数据库中？是在模
我有一个 python 脚本来发送电子邮件，它工作得很好，但问题是当我检查我的电子邮件收件箱时。 我希望该用户名是自定义用户名，而不是整个电子邮件地址。 最佳答案 发件人地址应该使用的格式是: You
我想减小 ggcorrplot 中标记的大小，并减少文本和绘图之间的空间。 library(ggcorrplot) data(mtcars) corr <- round(cor(mtcars), 1)
GTK+ noob 问题在这里: 是否可以自定义 GtkFileChooserButton 或 GtkFileChooserDialog 以删除“位置”部分(左侧)和顶部的“位置”输入框？ 我实际上要
我正在尝试在主页上使用 ajax 在 magento 中使用 ajax 显示流行的产品列表，我可以为 5 或“N”个产品执行此操作，但我想要的是将分页工具栏与结果集一起添加. 这是我添加的以显示流行产
我正在尝试使用 PasswordResetForm 内置函数。 由于我想要自定义表单字段，因此我编写了自己的表单: class FpasswordForm(PasswordResetForm):
据我了解，新的 Angular 7 提供了拖放功能。我搜索了有关 DnD 的 Tree 组件，但没有找到与树相关的内容。 我在 Stackblitz 上找到的一个工作示例.对比drag'ndrop功能
我必须开发一个自定义选项卡控件并决定使用 WPF/XAML 创建它，因为我无论如何都打算学习它。完成后应该是这样的: 到目前为止，我取得了很好的进展，但还有两个问题: 只有第一个/最后一个标签项应该有
我要定制xtable用于导出到 LaTeX。我知道有些问题是关于 xtable在这里，但我找不到我要找的具体东西。 以下是我的表的外观示例: my.table <- data.frame(Specif
用ejs在这里显示日期 它给我结果 Tue Feb 02 2016 16:02:24 GMT+0530 (IST) 但是我需要表现为 19th January, 2016 如何在ejs中执行此操作？
我想问在 JavaFX 中使用自定义对象制作 ListView 的最佳方法，我想要一个每个项目如下所示的列表: 我搜了一下，发现大部分人都是用细胞工厂的方法来做的。有没有其他办法？例如使用客户 fxm
我是一名优秀的程序员,十分优秀！