django restful framework一対の多方向更新データベース

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import uuid
from django.db import models

class Asset(models.Model):

    id = models.UUIDField(default=uuid.uuid4, primary_key=True)
    ops_id = models.CharField(max_length=30, unique=True, null=True, blank=True, verbose_name=_('ops asset id'))
    ip = models.GenericIPAddressField(max_length=32, verbose_name=_('IP'), db_index=True)
    hostname = models.CharField(max_length=128, verbose_name=_('Hostname'))
    domain = models.ForeignKey("assets.Domain", null=True, blank=True, related_name='assets', verbose_name=_("Domain"), on_delete=models.SET_NULL) #  Foreignkey 
    created_by = models.CharField(max_length=32, null=True, blank=True, verbose_name=_('Created by'))
    date_created = models.DateTimeField(auto_now_add=True, null=True, blank=True, verbose_name=_('Date created'))
    comment = models.TextField(max_length=128, default='', blank=True, verbose_name=_('Comment'))

    def __str__(self):
        return '{0.hostname}({0.ip})'.format(self)

    class Meta:
        verbose_name = _("Asset")

# -*- coding: utf-8 -*-

from rest_framework import serializers
from ..models import Domain

class DomainBindAssetSerializer(serializers.ModelSerializer):

    class Meta:
        model = Domain
        fields = ['id','name','assets']
        read_only_fields = ('id', 'name')


    def update(self, instance, validated_data):
        instance.id = validated_data.get('id',instance.id)
        instance.name = validated_data.get('name',instance.name)
        instance.save()
        instance.assets.set(validated_data.get('assets',instance.assets.all()))
        return instance

# ~*~ coding: utf-8 ~*~

from common.permissions import IsOrgAdminOrAppUser
from common.utils import get_logger
from rest_framework import status
from rest_framework.generics import RetrieveUpdateDestroyAPIView
from rest_framework.views import Response

from .. import serializers
from ..models import Domain, Gateway

class DomainWithAssetsUpdateApi(RetrieveUpdateDestroyAPIView):
    queryset = Domain.objects.all()
    serializer_class = serializers.DomainBindAssetSerializer
    permission_classes = ()
    authentication_classes = ()

    def get_object(self, pk):
        try:
            return Domain.objects.get(id=pk)
        except Domain.DoesNotExist:
            logger.error("domain id is not existed.")
            False

    def get(self, request, *args, **kwargs):
        """query domain with assets"""
        data = {"msg": '', 'result': None, 'code': None}
        domain = self.get_object(kwargs.get('pk'))
        try:
            if not domain:
                raise Exception("Domain not exists! Check url!")
            serializer = serializers.DomainBindAssetSerializer(domain)
            code = status.HTTP_200_OK
            data['result'] = serializer.data
            data['code'] = code
            logger.info("Domain bind assets:{}".format(domain.assets))
        except Exception as e:
            code = status.HTTP_422_UNPROCESSABLE_ENTITY
            data['msg'] = str(e)
            data['code'] = code
            logger.error(str(e))
        finally:
            return Response(data=data, status=code)

    def put(self, request, *args, **kwargs):
        """bind assets to domain"""
        data = {"msg": '', 'result': None, 'code': None}

        domain = self.get_object(kwargs.get("pk", None))
        if not domain:
            code = status.HTTP_404_NOT_FOUND
            data['msg'] = "Domain not exists, check url!"
            data['code'] = code
            return Response(data=data, status=code)

        try:
            serializer = serializers.DomainBindAssetSerializer(data=request.data, instance=domain, partial=True)
            if serializer.is_valid():
                serializer.save()
                code = status.HTTP_202_ACCEPTED
                data['result'] = serializer.data
                data['code'] = code
            else:
                code = status.HTTP_422_UNPROCESSABLE_ENTITY
                data['msg'] = serializer.errors
                data['code'] = code
        except Exception as e:
            code = 500
            data['msg'] = str(e)
            data['code'] = code
            logger.error("Assets bind domain occur error:{}".format(str(e)))
        finally:
            return Response(data=data, status=code)

# coding:utf-8
from django.urls import path
from rest_framework_bulk.routes import BulkRouter
from rest_framework_nested import routers


from .. import api

app_name = 'assets'

router = BulkRouter()
router.register(r'assets', api.AssetViewSet, 'asset')
router.register(r'domain', api.DomainViewSet, 'domain')


urlpatterns = [
	...
    path('domain//assets/',api.DomainWithAssetsUpdateApi.as_view(), name='domain-assets-update'),
    ...
]

urlpatterns += router.urls + cmd_filter_router.urls