factory/apps/pm/views.py

from django.db import transaction
from rest_framework.decorators import action
from rest_framework.exceptions import ParseError
from rest_framework.response import Response
from rest_framework.serializers import Serializer

from apps.utils.serializers import PkSerializer
from apps.utils.viewsets import CustomModelViewSet

from .filters import MtaskFilter, UtaskFilter
from .models import Mtask, Utask
from .serializers import MtaskSerializer, SchedueSerializer, UtaskSerializer, MtaskDaySerializer
from .services import PmService
from django.utils import timezone

# Create your views here.


class UtaskViewSet(CustomModelViewSet):
    """
    list: 生产大任务

    生产大任务
    """
    queryset = Utask.objects.all()
    serializer_class = UtaskSerializer
    filterset_class = UtaskFilter
    select_related_fields = ['material']
    ordering = ['-start_date']

    def perform_destroy(self, instance):
        if instance.state >= Utask.UTASK_WORKING:
            raise ParseError('该任务状态不可删除')
        return super().perform_destroy(instance)

    @action(methods=['post'], detail=True, perms_map={'post': 'utask.stop'}, serializer_class=Serializer)
    @transaction.atomic
    def stop(self, request, *args, ):
        """停止任务

        停止任务
        """
        obj = self.get_object()
        user = request.user
        now = timezone.now()
        if obj.state == Utask.UTASK_WORKING:
            obj.state = Utask.UTASK_STOP
            obj.update_by = user
            obj.update_time = now
            obj.save()
            # 停止所有小任务
            Mtask.objects.filter(
                utask=obj, state=Mtask.MTASK_ASSGINED).update(state=Mtask.MTASK_STOP, update_by=user, update_time=now)
        else:
            raise ParseError('该状态下不可停止')
        return Response()

    @action(methods=['post'], detail=False, perms_map={'post': 'utask.schedue'}, serializer_class=SchedueSerializer)
    @transaction.atomic
    def schedue_utasks(self, request, *args, **kwargs):
        """从多个订单明细生成大任务

        从多个订单明细生成大任务
        """
        sr = SchedueSerializer(data=request.data)
        sr.is_valid(raise_exception=True)
        vdata = sr.validated_data
        PmService.make_utasks_from_orderitems(request.user,
                                              request.data['orderitems'], vdata['start_date'], vdata['end_date'], vdata.get('belong_dept', None))
        return Response()

    @action(methods=['post'], detail=False, perms_map={'post': 'utask.schedue'}, serializer_class=PkSerializer)
    @transaction.atomic
    def schedue_mtasks(self, request, *args, **kwargs):
        """任务分解

        任务分解
        """
        sr = PkSerializer(data=request.data)
        sr.is_valid(raise_exception=True)
        vdata = sr.validated_data
        utasks = Utask.objects.filter(
            id__in=vdata['ids'], state=Utask.UTASK_CREATED)
        for i in utasks:
            PmService.schedue_mtasks(request.user, i)
        return Response()

    @action(methods=['post'], detail=False, perms_map={'post': 'utask.assgin'}, serializer_class=PkSerializer)
    @transaction.atomic
    def assgin(self, request, *args, **kwargs):
        """下达任务

        下达任务
        """
        ids = request.data.get('ids', [])
        user = request.user
        now = timezone.now()
        utasks = Utask.objects.filter(
            id__in=ids, state=Utask.UTASK_DECOMPOSE)  # 已分解的任务
        Mtask.objects.filter(utask__in=utasks, state=Mtask.MTASK_CREATED).update(
            state=Mtask.MTASK_ASSGINED, update_by=user, update_time=now)
        utasks.update(
            state=Utask.UTASK_ASSGINED, update_by=user, update_time=now)
        # 此处要更新订单状态
        from apps.sam.models import OrderItem, Order
        orderIds = OrderItem.objects.filter(
            utask__in=utasks).values_list('order', flat=True).distinct()
        Order.objects.filter(id__in=orderIds, state=Order.ORDER_SUBMITED).update(
            state=Order.ORDER_DOING)
        return Response()


class MtaskViewSet(CustomModelViewSet):
    """
    list: 生产任务

    生产任务
    """
    queryset = Mtask.objects.all()
    serializer_class = MtaskSerializer
    filterset_class = MtaskFilter
    select_related_fields = ['material_in', 'material_out', 'mgroup']
    ordering_fields = ['start_date', 'mgroup__process__sort']
    ordering = ['-start_date', 'mgroup__process__sort', '-create_time']

    @action(methods=['post'], detail=False, perms_map={'post': '*'}, serializer_class=MtaskDaySerializer)
    @transaction.atomic
    def day(self, request):
        """获取指定车间指定日期的代表工序生产任务

        获取指定车间指定日期的代表工序生产任务
        """
        sr = MtaskDaySerializer(data=request.data)
        sr.is_valid(raise_exception=True)
        vdata = sr.validated_data
        mtasks = Mtask.objects.filter(
            is_count_utask=True,
            mgroup__belong_dept__name=vdata['belong_dept_name'], start_date__lte=vdata['date'], end_date__gte=vdata['date']).order_by(
            'utask', 'mgroup__process__sort', 'create_time'
        )
        data = MtaskSerializer(instance=mtasks, many=True).data
        return Response(data)

    @action(methods=['get'], detail=True, perms_map={'get': '*'})
    @transaction.atomic
    def related(self, request, *args, **kwargs):
        """获取已下达的所有的兄弟小任务

        获取已下达的所有的兄弟小任务
        """
        obj = self.get_object()
        rdata = MtaskSerializer(instance=obj.related, many=True).data
        return Response(rdata)

    def perform_destroy(self, instance):
        if instance.state != Mtask.MTASK_CREATED:
            raise ParseError('该任务非创建中不可删除')
        return super().perform_destroy(instance)

    @action(methods=['post'], detail=False, perms_map={'post': 'mtask.submit'}, serializer_class=PkSerializer)
    @transaction.atomic
    def submit(self, request, *args, **kwargs):
        """提交任务(根据任务ID)

        提交任务后不可更新日志
        """
        ids = request.data.get('ids', [])
        mtasks = Mtask.objects.filter(
            id__in=ids, state=Mtask.MTASK_ASSGINED)
        PmService.mtasks_submit(mtasks)
        return Response()

    @action(methods=['post'], detail=True, perms_map={'post': 'mtask.submit'}, serializer_class=Serializer)
    @transaction.atomic
    def submit_related_same_day(self, request, *args, **kwargs):
        """提交同一天该部门下大任务的所有兄弟小任务

        提交同一天的该部门下大任务的所有兄弟小任务
        """
        mtask = self.get_object()
        mtasks = mtask.related
        PmService.mtasks_submit(mtasks)
        return Response()