greater_wms/erp/views.py

from rest_framework.views import APIView
from rest_framework.response import Response
from rest_framework.permissions import AllowAny
from rest_framework import status
from rest_framework import viewsets
from django_filters.rest_framework import DjangoFilterBackend, OrderingFilter
from django.utils import timezone
from django.db.models import Q, F, Case, When
from utils.page import MyPageNumberPagination
from .models import *
from .serializers import *
from .filter import *
import logging

logger = logging.getLogger('wms.boundBill')

class WMSResponse:
    """
    入库申请专用响应格式
    使用示例：
    return WMSResponse.success(data=serializer.data, total=2, success=2)
    return WMSResponse.error(message='验证失败', total=2, fail_count=1, 
                               fail_materials=[{...}])
    """
    
    @staticmethod
    def success(data, total, success, status=status.HTTP_201_CREATED):
        """成功响应格式"""
        logger.info('成功响应 | 数据: %s', data)
        return Response({
            "status": True,
            "errorCode": status,
            "message": "success",
            "data": {
                "failCount": 0,
                "totalCount": total,
                "successCount": success,
                "fail_materials": []
            }
        }, status=status)

    @staticmethod
    def error(message, total, fail_count, fail_materials=None, 
            status=status.HTTP_400_BAD_REQUEST, exception=None):
        """错误响应格式"""
        if fail_materials is None:
            fail_materials = []
            
        # 记录详细错误日志
        if exception:
            logger.error(f"入库申请错误: {message}", exc_info=exception)
            
        return Response({
            "status": False,
            "errorCode": status,
            "message": message,
            "data": {
                "failCount": fail_count,
                "totalCount": total,
                "successCount": total - fail_count,
                "fail_materials": fail_materials
            }
        }, status=status)
# Create your views here.
# urlpatterns = [
#     path('createInboundApply', views.InboundApplyCreate.as_view()),
#     path('createOutboundApply', views.OutboundApplyCreate.as_view()),
#     path('updateBatchInfo', views.BatchUpdate.as_view()),
#     path('productInfo', views.ProductInfo.as_view()),


# ]

class InboundApplyCreate(APIView):
    """
    生产入库申请
    """
    authentication_classes = []
    permission_classes = [AllowAny]

    def post(self, request):
        logger.info('生产入库申请请求 | 原始数据: %s', request.data)
        
        try:
            total_count = len(request.data.get('materials', []))
            if total_count == 0 :
                return WMSResponse.error(
                    message="物料清单不能为空",
                    total=0,
                    fail_count=0
                )
            if total_count != request.data.get('totalCount', 0):
                return WMSResponse.error(
                    message="物料数量不匹配",
                    total=total_count,
                    fail_count=total_count
                )
            
            serializer = boundPostSerializer(data=request.data)
            if not serializer.is_valid():
          
                return self._handle_validation_error(serializer.errors, total_count)

            unique_result,error_details = self.find_unique_billid_and_number(serializer)
            if not unique_result:
                return WMSResponse.error(
                    message="单据编号或原始单据ID重复",
                    total=total_count,
                    fail_count=total_count,
                    fail_materials=[{
                        "entryIds": None,
                        "production_batch": None,
                        "errors": error_details
                    }]
                )
            # 保存或更新入库单
            bound_bill = self.save_or_update_inbound_bill(serializer)

            # 保存或更新物料明细
            self.save_or_update_material_detail(bound_bill, serializer)
            return WMSResponse.success( 
                data=serializer.data,
                total=total_count,
                success=total_count
            )

        except Exception as e:
            logger.exception("服务器内部错误")
            return WMSResponse.error(
                message="系统处理异常",
                total=total_count,
                fail_count=total_count,
                status=status.HTTP_500_INTERNAL_SERVER_ERROR,
                exception=e
            )

    def _handle_validation_error(self, errors, total_count):
        """增强错误解析"""
        fail_materials = []
        
        # 提取嵌套错误信息
        material_errors = errors.get('materials', [])
        
        for error in material_errors:
            # 解析DRF的错误结构
            if isinstance(error, dict) and 'metadata' in error:
                fail_materials.append({
                    "entryIds": error['metadata'].get('entryIds'),
                    "production_batch": error['metadata'].get('production_batch'),
                    "errors": {
                        "missing_fields": error['metadata']['missing_fields'],
                        "message": error['detail']
                    }
                })
        
        return WMSResponse.error(
            message="物料数据不完整",
            total=total_count,
            fail_count=len(fail_materials),
            fail_materials=fail_materials
    )

    def _format_material_errors(self, error_dict):
        """格式化单个物料的错误信息"""
        return {
            field: details[0] if isinstance(details, list) else details
            for field, details in error_dict.items()
        }

    def find_unique_billid_and_number(self, serializer):
        """增强版唯一性验证"""
        bill_id = serializer.validated_data['billId']
        number = serializer.validated_data['number']
        
        # 使用Q对象进行联合查询
        duplicates_id = InboundBill.objects.filter(
            Q(billId=bill_id) 
        ).only('billId')
        # 使用Q对象进行联合查询
        duplicates_nu = InboundBill.objects.filter(
            Q(number=number)
        ).only( 'number')
        
        error_details = {}
        
        # 检查单据编号重复
        if any(obj.billId != bill_id for obj in duplicates_nu):
            error_details['number'] = ["number入库单编码已存在,但是系统中与之前入库单单据ID不一致，请检查"]
        
        
        # 检查业务编号重复
        if any(obj.number != number for obj in duplicates_id):
            
            error_details['billId'] = ["billId入库单单据ID已存在,但是系统中与之前入库申请单编码不一致，请检查"]
        
    
        if error_details:
            return False,error_details
        return True,None
        
    def save_or_update_inbound_bill(self, serializer):
        """保存或更新入库单"""
        # 保存或更新入库单
        try:
            bound_bill = InboundBill.objects.get(billId=serializer.validated_data['billId'])
            bound_bill.number = serializer.validated_data['number']
            bound_bill.type = serializer.validated_data['type']
            bound_bill.date = serializer.validated_data['date']
            bound_bill.department = serializer.validated_data['department']
            bound_bill.warehouse = serializer.validated_data['warehouse']
            bound_bill.creater = serializer.validated_data['creater']
            bound_bill.note = (serializer.validated_data['note'] if 'note' in serializer.validated_data else '')
            bound_bill.totalCount = serializer.validated_data['totalCount']
            bound_bill.update_time = timezone.now()
            bound_bill.save()
        except InboundBill.DoesNotExist:
            bound_bill = InboundBill.objects.create(
                billId=serializer.validated_data['billId'],
                number=serializer.validated_data['number'],
                type=serializer.validated_data['type'],
                date=serializer.validated_data['date'],
                department=serializer.validated_data['department'],
                warehouse=serializer.validated_data['warehouse'],
                creater=serializer.validated_data['creater'],
                note=(serializer.validated_data['note'] if 'note' in serializer.validated_data else ''),
                totalCount=serializer.validated_data['totalCount'],
                create_time=timezone.now(),
                update_time=timezone.now()
            )
        return bound_bill

    def save_or_update_material_detail(self, bound_bill, serializer):
        """保存或更新物料明细"""
        # 保存或更新物料明细
        for item in serializer.validated_data['materials']:
            try:
                material_detail = MaterialDetail.objects.get(bound_billId=bound_bill, entryIds=item['entryIds'])
                material_detail.production_batch = item['production_batch']
        
                material_detail.goods_code = item['goods_code']
                material_detail.goods_name = item['goods_name']
                material_detail.goods_std = item['goods_std']
         
                material_detail.plan_qty = item['plan_qty']
                material_detail.goods_total_weight = item['plan_qty']
                material_detail.goods_unit = item['goods_unit']
                material_detail.note = (item['note'] if 'note' in item else '')
                material_detail.update_time = timezone.now()
                material_detail.save()
            except MaterialDetail.DoesNotExist:
                material_detail = MaterialDetail.objects.create(
                    bound_billId=bound_bill,
                    entryIds=item['entryIds'],
                    production_batch=item['production_batch'],
                    goods_code=item['goods_code'],
                    goods_name=item['goods_name'],
                    goods_std=item['goods_std'],
                    goods_weight=1,
                    plan_qty=item['plan_qty'],
                    goods_total_weight=item['plan_qty'],
                    goods_unit=item['goods_unit'],
                    note=(item['note'] if 'note' in item else ''),
                    create_time=timezone.now(),
                    update_time=timezone.now()
                )
        return material_detail
class OutboundApplyCreate(APIView):
    """
    生产出库申请
    """
    authentication_classes = []  # 禁用所有认证类
    permission_classes = [AllowAny]  # 允许任意访问
    def post(self, request):

        return Response(status=status.HTTP_200_OK)

class BatchUpdate(APIView):
    """
    批次信息更新
    """
    authentication_classes = []  # 禁用所有认证类
    permission_classes = [AllowAny]  # 允许任意访问
    def post(self, request):
        logger.info('批次信息更新')
        serializer = BatchUpdateSerializer(data=request.data)
        return Response(serializer.data, status=status.HTTP_200_OK)

class ProductInfo(APIView):
    """
    商品信息查询
    """
    authentication_classes = []  # 禁用所有认证类
    permission_classes = [AllowAny]  # 允许任意访问
    def post(self, request):
        logger.info('商品信息查询')
        serializer = ProductInfoSerializer(data=request.data)
        return Response(serializer.data, status=status.HTTP_200_OK)

class InboundBills(viewsets.ModelViewSet):
    """
        retrieve:
            Response a data list（get）
        list:
            Response a data list（all）
    """
    authentication_classes = []  # 禁用所有认证类
    permission_classes = [AllowAny]  # 允许任意访问
    
    pagination_class = MyPageNumberPagination   
    filter_backends = [DjangoFilterBackend, OrderingFilter, ]
    ordering_fields = ['id', "create_time", "update_time", ]
    filter_class = InboundBillFilter

    def get_project(self):
        try:
            id = self.kwargs.get('pk')
            return id
        except:
            return None

    def get_queryset(self):
        id = self.get_project()
        if self.request.user:
            if id is None:
                return InboundBill.objects.filter(is_delete=False)
            else:
                return InboundBill.objects.filter(id=id)
        else:
            return InboundBill.objects.none()
    def  get_serializer_class(self):
        if self.action in ['retrieve', 'list']:
            return InboundApplySerializer
        else:
            return self.http_method_not_allowed(request=self.request)

class Materials(viewsets.ModelViewSet):
    """
        retrieve:
            Response a data list（get）
        list:
            Response a data list（all）
    """
    authentication_classes = []  # 禁用所有认证类
    permission_classes = [AllowAny]  # 允许任意访问
    
    pagination_class = MyPageNumberPagination   
    filter_backends = [DjangoFilterBackend, OrderingFilter, ]
    ordering_fields = ['id', "create_time", "update_time", ]
    filter_class = MaterialDetailFilter

    def get_project(self):
        try:
            id = self.kwargs.get('pk')
            return id
        except:
            return None

    def get_queryset(self):
        id = self.get_project()
        if self.request.user:
            if id is None:
                return MaterialDetail.objects.filter(is_delete=False)
            else:
                return MaterialDetail.objects.filter(id=id)
        else:
            return MaterialDetail.objects.none()

    def  get_serializer_class(self):
        if self.action in ['retrieve', 'list']:
            return MaterialDetailSerializer
        else:
            return self.http_method_not_allowed(request=self.request)