zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

开启/停止作业监控

This commit is contained in:
曹前明 2022-09-12 19:06:05 +08:00
parent e94d2dcaca
commit 38f77c78f5
1 changed files with 30 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
apps/opm/views.py
View File

@ -27,7 +27,8 @@ class OplCateViewSet(CustomModelViewSet):
class OperationViewSet(CustomModelViewSet):
perms_map = {'get': 'operation.view', 'post': 'operation.create', 'put': 'operation.update', 'delete': 'operation.delete'}
perms_map = {'get': 'operation.view', 'post': 'operation.create',
'put': 'operation.update', 'delete': 'operation.delete'}
queryset = Operation.objects.all()
create_serializer_class = OperationCreateUpdateSerializer
update_serializer_class = OperationCreateUpdateSerializer
@ -73,6 +74,34 @@ class OplViewSet(CustomModelViewSet):
raise ParseError('许可证已处理不可编辑')
return super().update(request, *args, **kwargs)
@action(methods=['post'], detail=True, perms_map={'post': '*'},
serializer_class=Serializer, logging_methods=[])
def start_mtask(self, request, pk=None):
"""
开启作业监控
开启作业监控
"""
obj = self.get_object()
if obj.mtask:
# 先关闭
close_mtask(obj.mtask.task_id)
start_mtask(obj)
return Response()
@action(methods=['post'], detail=True, perms_map={'post': '*'},
serializer_class=Serializer, logging_methods=[])
def stop_mtask(self, request, pk=None):
"""
停止作业监控
停止作业监控
"""
obj = self.get_object()
if obj.mtask:
close_mtask(obj.mtask.task_id)
return Response()
class OplWorkerViewSet(CustomModelViewSet):
perms_map = {'get': '*', 'post': 'opl.update', 'put': 'opl.update', 'delete': 'opl.update'}
@ -99,29 +128,6 @@ class OplWorkerViewSet(CustomModelViewSet):
raise ParseError('许可证已处理不可编辑')
return super().update(request, *args, **kwargs)
@action(methods=['post'], detail=True, perms_map={'post': '*'},
serializer_class=Serializer, logging_methods=[])
def start_mtask(self, request, pk=None):
"""
开启作业监控
"""
obj = self.get_object()
if obj.mtask:
# 先关闭
close_mtask(obj.mtask.task_id)
start_mtask(obj)
return Response()
@action(methods=['post'], detail=True, perms_map={'post': '*'},
serializer_class=Serializer, logging_methods=[])
def close_mtask(self, request, pk=None):
"""
停止作业监控
"""
obj = self.get_object()
if obj.mtask:
close_mtask(obj.mtask.task_id)
return Response()
class GasCheckViewSet(CreateModelMixin, ListModelMixin, DestroyModelMixin, CustomGenericViewSet):
perms_map = {'get': '*', 'post': 'opl.update', 'delete': 'opl.update'}