Recording Production

fila_grid = {
    'codigo': datos['codigo'],              # Concept code
    'concepto': datos['concepto'],          # Description
    'unidad': datos['unidad'],              # Unit of measure
    'vol_total_proyectado': float(datos['vol_total_proyectado']),  # Authorized
    'acumulado_mes': 0.0,                   # This month total
    'acumulado_programado': 0.0,            # Programmed volume
    'anexo': datos['anexo'],                # Annex (C-2, C-3, etc.)
    'pu_mn': float(datos['pu_mn']),         # Unit price MXN
    'pu_usd': float(datos['pu_usd']),       # Unit price USD
    'estatus_gpu': 'AUTORIZADO',            # GPU status
    # dia1 through dia31 for daily values
}

def guardar_produccion_masiva(request):
    # Get authorized volume considering all OT family
    mapa_autorizado = obtener_volumenes_consolidados(id_ot, codigos)
    
    # Calculate running total
    base_hist = sum(mapa_historia_global[variantes])
    base_otros = mapa_otros_tiempos.get(id_p, Decimal(0))
    running_total = base_hist + base_otros
    
    for dia, vol in enumerate(valores_dia):
        running_total += vol
        
        # Flag as excess if over limit
        es_excedente = round(running_total, 4) > vol_autorizado
        
        Produccion.objects.create(
            volumen_produccion=vol,
            es_excedente=es_excedente,
            id_estatus_cobro_id=1  # PENDIENTE for normal, special handling for excess
        )

def obtener_volumenes_consolidados(id_ot_actual, ids_partidas_codigos):
    """
    Calculate total authorized volume summing initial OT and all reprogramming.
    """
    ot_actual = OTE.objects.get(id=id_ot_actual)
    id_principal = ot_actual.ot_principal or ot_actual.id
    
    # Get all OTs in family
    familia_ots = OTE.objects.filter(
        Q(id=id_principal) | Q(ot_principal=id_principal)
    ).values_list('id', flat=True)
    
    # Get latest authorization for each concept
    partidas_query = PartidaAnexoImportada.objects.filter(
        importacion_anexo__ot_id__in=familia_ots,
        importacion_anexo__es_activo=True,
        id_partida__in=ids_partidas_codigos
    ).order_by('id_partida', '-importacion_anexo_id').distinct('id_partida')
    
    return {p.id_partida: p.volumen_proyectado for p in partidas_query}

# Calculate financial impact
fila_monto_mn = suma_mes_visual * datos['pu_mn']
fila_monto_usd = suma_mes_visual * datos['pu_usd']

# Aggregate totals
total_ejec_mn += fila_monto_mn
total_ejec_usd += fila_monto_usd

totales_financieros = {
    'aut_mn': float(total_aut_mn),      # Authorized
    'ejec_mn': float(total_ejec_mn),    # Executed this month
    'acum_mn': float(total_acum_mn),    # Accumulated to date
    'resta_mn': float(por_ejecutar_mn)  # Remaining
}