wslpg.py

#!/usr/bin/python
# -*- coding: utf8 -*-
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by the
# Free Software Foundation; either version 3, or (at your option) any later
# version.
#
# This program is distributed in the hope that it will be useful, but
# WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTIBILITY
# or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
# for more details.

"""Módulo para obtener código de operación electrónico (COE) para 
Liquidación Primaria Electrónica de Granos del web service WSLPG de AFIP
"""

__author__ = "Mariano Reingart <reingart@gmail.com>"
__copyright__ = "Copyright (C) 2013 Mariano Reingart"
__license__ = "GPL 3.0"
__version__ = "1.23a"

LICENCIA = """
wslpg.py: Interfaz para generar Código de Operación Electrónica para
Liquidación Primaria de Granos (LpgService)
Copyright (C) 2013 Mariano Reingart reingart@gmail.com
http://www.sistemasagiles.com.ar/trac/wiki/LiquidacionPrimariaGranos

Este progarma es software libre, se entrega ABSOLUTAMENTE SIN GARANTIA
y es bienvenido a redistribuirlo respetando la licencia GPLv3.

Para información adicional sobre garantía, soporte técnico comercial
e incorporación/distribución en programas propietarios ver PyAfipWs:
http://www.sistemasagiles.com.ar/trac/wiki/PyAfipWs
"""

AYUDA="""
Opciones: 
  --ayuda: este mensaje

  --debug: modo depuración (detalla y confirma las operaciones)
  --formato: muestra el formato de los archivos de entrada/salida
  --prueba: genera y autoriza una liquidación de prueba (no usar en producción!)
  --xml: almacena los requerimientos y respuestas XML (depuración)
  --dbf: utilizar tablas DBF (xBase) para los archivos de intercambio
  --json: utilizar formato json para el archivo de intercambio
  --dummy: consulta estado de servidores
  
  --autorizar: Autorizar Liquidación Primaria de Granos (liquidacionAutorizar)
  --ajustar: Ajustar Liquidación Primaria de Granos (liquidacionAjustar)
  --anular: Anular una Liquidación Primaria de Granos (liquidacionAnular)
  --consultar: Consulta una liquidación (parámetros: nro de orden y COE)
  --ult: Consulta el último número de orden registrado en AFIP 
         (liquidacionUltimoNroOrdenConsultar)

  --pdf: genera el formulario C 1116 B en formato PDF
  --mostrar: muestra el documento PDF generado (usar con --pdf)
  --imprimir: imprime el documento PDF generado (usar con --mostrar y --pdf)

  --autorizar-lsg: Autoriza una Liquidación Secundaria de Granos (lsgAutorizar)
    --lsg --anular: Anula una LSG (lsgAnular)
    --lsg --consular: Consulta una LSG por pto_emision, nro_orden o COE
    --lsg --ult: Consulta el último Nº LSG emitida (lsgConsultarUltimoNroOrden)
  --autorizar-cg: Autorizar Certificación de Granos (cgAutorizar)
    --cg --anular: Solicita anulación de un CG (cgSolicitarAnulacion)
    --cg --consultar: Consulta una CG por pto_emision, nro_orden o COE
    --cg --ult: Consulta el último Nº LSG emitida (cgConsultarUltimoNroOrden)
  --informar-calidad: Informa la calidad de una CG (cgInformarCalidad)

  --provincias: obtiene el listado de provincias
  --localidades: obtiene el listado de localidades por provincia
  --tipograno: obtiene el listado de los tipos de granos disponibles
  --campanias: obtiene el listado de las campañas 
  --gradoref: obtiene el listado de los grados de referencias
  --gradoent: obtiene el listado de los grados y valores entregados
  --certdeposito: obtiene el listado de los tipos de certificados de depósito
  --deducciones: obtiene el listado de los tipos de deducciones
  --retenciones: obtiene el listado de los tipos de retenciones
  --puertos: obtiene el listado de los puertos habilitados
  --actividades: obtiene el listado de las actividades habilitados
  --actividadesrep: devuelve las actividades en las que emisor/representado 
                    se encuentra inscripto en RUOCA
  --operaciones: obtiene el listado de las operaciones para el representado


Ver wslpg.ini para parámetros de configuración (URL, certificados, etc.)"
"""

import os, sys, shelve
import decimal, datetime
import traceback
import pprint
from pysimplesoap.client import SoapFault
from fpdf import Template
import utils

# importo funciones compartidas:
from utils import leer, escribir, leer_dbf, guardar_dbf, N, A, I, json, BaseWS, inicializar_y_capturar_excepciones, get_install_dir


WSDL = "https://fwshomo.afip.gov.ar/wslpg/LpgService?wsdl"
#WSDL = "https://serviciosjava.afip.gob.ar/wslpg/LpgService?wsdl"
#WSDL = "file:wslpg.wsdl"

DEBUG = False
XML = False
CONFIG_FILE = "wslpg.ini"
HOMO = True

# definición del formato del archivo de intercambio:

ENCABEZADO = [
    ('tipo_reg', 1, A), # 0: encabezado liquidación
    ('nro_orden', 18, N), 
    ('cuit_comprador', 11, N),
    ('nro_act_comprador', 5, N),
    ('nro_ing_bruto_comprador', 15, N), 
    ('cod_tipo_operacion', 2, N), 
    ('es_liquidacion_propia', 1, A),  # S o N
    ('es_canje', 1, A),  # S o N
    ('cod_puerto', 4, N), 
    ('des_puerto_localidad', 240, A), 
    ('cod_grano', 3, N), 
    ('cuit_vendedor', 11, N), 
    ('nro_ing_bruto_vendedor', 15, N), 
    ('actua_corredor', 1, A),  # S o N
    ('liquida_corredor', 1, A),  # S o N
    ('cuit_corredor', 11, N), 
    ('nro_ing_bruto_corredor', 15, N), 
    ('comision_corredor', 5, I, 2), # 3.2
    ('fecha_precio_operacion', 10, A), # 26/02/2013
    ('precio_ref_tn', 8, I, 3), # 4.3
    ('cod_grado_ref', 2, A),
    ('cod_grado_ent', 2, A),
    ('factor_ent', 6, I, 3), # 3.3
    ('precio_flete_tn', 7, I, 2), # 5.2
    ('cont_proteico', 6, I, 3), # 3.3
    ('alic_iva_operacion', 5, I, 2), # 3.2
    ('campania_ppal', 4, N),
    ('cod_localidad_procedencia', 6, N), 
    ('reservado1', 200, A),   # datos_adicionales (compatibilidad hacia atras)
    
    ('coe', 12, N),
    ('coe_ajustado', 12, N),
    ('estado', 2, A),
    
    ('total_deduccion', 17, I, 2), # 17.2
    ('total_retencion', 17, I, 2), # 17.2
    ('total_retencion_afip', 17, I, 2), # 17.2
    ('total_otras_retenciones', 17, I, 2), # 17.2
    ('total_neto_a_pagar', 17, I, 2), # 17.2
    ('total_iva_rg_2300_07', 17, I, 2), # 17.2
    ('total_pago_segun_condicion', 17, I, 2), # 17.2
    
    ('fecha_liquidacion', 10, A), 
    ('nro_op_comercial', 10, N), 
    ('precio_operacion', 17, I, 3), # 17.3
    ('subtotal', 17, I, 2), # 17.2
    ('importe_iva', 17, I, 2), # 17.2
    ('operacion_con_iva', 17, I, 2), # 17.2
    ('total_peso_neto', 8, N), # 17.2

    # Campos WSLPGv1.1:
    ('pto_emision', 4, N), 
    ('cod_prov_procedencia', 2, N),
    ('peso_neto_sin_certificado', 8, N),
    
    ('cod_tipo_ajuste', 2, N),
    ('val_grado_ent', 4, I, 3), # 1.3

    # Campos WSLPGv1.3:
    ('cod_prov_procedencia_sin_certificado', 2, N),
    ('cod_localidad_procedencia_sin_certificado', 6, N), 

    # Campos WSLPGv1.4 (ajustes):
    ('nro_contrato', 15, N),
    ('tipo_formulario', 2, N), 
    ('nro_formulario', 12, N), 
    # datos devuetos:
    ('total_iva_10_5', 17, I, 2), # 17.2
    ('total_iva_21', 17, I, 2), # 17.2
    ('total_retenciones_ganancias', 17, I, 2), # 17.2
    ('total_retenciones_iva', 17, I, 2), # 17.2
    
    ('datos_adicionales', 400, A), # max 400 desde WSLPGv1.2

    # Campos agregados WSLPGv1.5 (ajustes):
    ('iva_deducciones', 17, I, 2), # 17.2
    ('subtotal_deb_cred', 17, I, 2), # 17.2
    ('total_base_deducciones', 17, I, 2), # 17.2
    
    # Campos agregados WSLPGv1.6 (liquidación secundaria base):
    ('cantidad_tn', 11, I, 3),      #  8.3
    ('nro_act_vendedor', 5, N),
    # Campos agregados WSLPGv1.9 (liquidación secundaria base):
    ('total_deducciones', 19, I , 2),    
    ('total_percepciones', 19, I , 2),
    ]

CERTIFICADO = [
    ('tipo_reg', 1, A), # 1: Certificado
    ('tipo_certificado_deposito', 2, N), 
    ('nro_certificado_deposito', 12, N), 
    ('peso_neto', 8, N), 
    ('cod_localidad_procedencia', 6, N), 
    ('cod_prov_procedencia', 2, N),
    ('reservado', 2, N),
    ('campania', 4, N),
    ('fecha_cierre', 10, A),
    ('peso_neto_total_certificado', 8, N), # para ajuste unificado (WSLPGv1.4)
    ('coe_certificado_deposito', 12, N), # para certificacion (WSLPGv1.6)
    ]
    
RETENCION = [
    ('tipo_reg', 1, A), # 2: Retencion
    ('codigo_concepto', 2, A), 
    ('detalle_aclaratorio', 30, A),
    ('base_calculo', 10, I, 2),  # 8.2
    ('alicuota', 6, I, 2),  # 3.2
    ('nro_certificado_retencion', 14, N), 
    ('fecha_certificado_retencion', 10, A),
    ('importe_certificado_retencion', 17, I, 2), # 17.2
    ('importe_retencion', 17, I, 2), # 17.2
    ]

DEDUCCION = [
    ('tipo_reg', 1, A), # 3: Deducción
    ('codigo_concepto', 2, A), 
    ('detalle_aclaratorio', 30, A), # max 50 por WSLPGv1.2
    ('dias_almacenaje', 4, N),
    ('reservado1', 6, I, 3),
    ('comision_gastos_adm', 5, I, 2), # 3.2
    ('base_calculo', 10, I, 2),  # 8.2
    ('alicuota', 6, I, 2),  # 3.2
    ('importe_iva', 17, I, 2), # 17.2
    ('importe_deduccion', 17, I, 2), # 17.2
    ('precio_pkg_diario', 11, I, 8), # 3.8, ajustado WSLPGv1.2
    ]

PERCEPCION = [
    ('tipo_reg', 1, A), # P: Percepcion
    ('detalle_aclaratoria', 50, A), # max 50 por WSLPGv1.8
    ('base_calculo', 10, I, 2),  # 8.2
    ('alicuota', 6, I, 2),  # 3.2
    ]

OPCIONAL = [
    ('tipo_reg', 1, A), # O: Opcional
    ('codigo', 50, A), 
    ('descripcion', 250, A), 
    ]

AJUSTE = [
    ('tipo_reg', 1, A), # 4: ajuste débito / 5: crédito (WSLPGv1.4)
    ('concepto_importe_iva_0', 20, A),
    ('importe_ajustar_iva_0', 15, I, 2), # 11.2
    ('concepto_importe_iva_105', 20, A),
    ('importe_ajustar_iva_105', 15, I, 2), # 11.2
    ('concepto_importe_iva_21', 20, A),
    ('importe_ajustar_iva_21', 15, I, 2), # 11.2
    ('diferencia_peso_neto', 8, N),
    ('diferencia_precio_operacion', 17, I, 3), # 17.3
    ('cod_grado', 2, A),
    ('val_grado', 4, I, 3), # 1.3
    ('factor', 6, I, 3), # 3.3
    ('diferencia_precio_flete_tn', 7, I, 2), # 5.2
    ('datos_adicionales', 400, A),
    # datos devueltos:
    ('fecha_liquidacion', 10, A), 
    ('nro_op_comercial', 10, N), 
    ('precio_operacion', 17, I, 3), # 17.3
    ('subtotal', 17, I, 2), # 17.2
    ('importe_iva', 17, I, 2), # 17.2
    ('operacion_con_iva', 17, I, 2), # 17.2
    ('total_peso_neto', 8, N), # 17.2
    ('total_deduccion', 17, I, 2), # 17.2
    ('total_retencion', 17, I, 2), # 17.2
    ('total_retencion_afip', 17, I, 2), # 17.2
    ('total_otras_retenciones', 17, I, 2), # 17.2
    ('total_neto_a_pagar', 17, I, 2), # 17.2
    ('total_iva_rg_2300_07', 17, I, 2), # 17.2
    ('total_pago_segun_condicion', 17, I, 2), # 17.2
    ('iva_calculado_iva_0', 15, I, 2), # 15.2
    ('iva_calculado_iva_105', 15, I, 2), # 15.2
    ('iva_calculado_iva_21', 15, I, 2), # 15.2
    ]

CERTIFICACION = [
    ('tipo_reg', 1, A), # 7: encabezado certificación
    # campos de la cabecera para todas las certificaciones (WSLPGv1.6)
    ('pto_emision', 4, N),
    ('nro_orden', 8, N),
    ('tipo_certificado', 1, A),   # P:Primaria,R:Retiro,T:Transferencia,E:Preexistente
    ('nro_planta', 6, N),
    ('nro_ing_bruto_depositario', 15, N),
    ('titular_grano', 1, A),        # "P" (Propio) "T" (Tercero)
    ('cuit_depositante', 11, N),    # obligatorio si titular_grano es T
    ('nro_ing_bruto_depositante', 15, N),
    ('cuit_corredor', 11, N),
    ('cod_grano', 3, N),
    ('campania', 4, N),
    ('datos_adicionales', 400, A),
    ('reservado1', 14, A),          # reservado para futuros campos (no usar)
    # campos para CgAutorizarPrimariaType ex-cgAutorizarDeposito (WSLPGv1.6-1.8)
    ('nro_act_depositario', 5, N),              # nuevo WSLPGv1.8 tambien R/T
    ('descripcion_tipo_grano', 20, A),
    ('monto_almacenaje', 10, I, 2),
    ('monto_acarreo', 10, I, 2),
    ('monto_gastos_generales', 10, I, 2),
    ('monto_zarandeo', 10, I, 2),
    ('porcentaje_secado_de', 5, I, 2),
    ('porcentaje_secado_a', 5, I, 2),
    ('monto_secado', 10, I, 2),
    ('monto_por_cada_punto_exceso', 10, I, 2),
    ('monto_otros', 10, I, 2),
    ('reservado_calidad', 35, A),               # ver subestructura WSLPGv1.10 
    ('peso_neto_merma_volatil', 10, I , 2),
    ('porcentaje_merma_secado', 5, I, 2),
    ('peso_neto_merma_secado', 10, I, 2),
    ('porcentaje_merma_zarandeo', 5, I, 2),
    ('peso_neto_merma_zarandeo', 10, I, 2),
    ('peso_neto_certificado', 10, I, 2),        # WSLPGv1.9 2 decimales!
    ('servicios_secado', 8, I, 3),
    ('servicios_zarandeo', 8, I, 3),
    ('servicios_otros', 7, I, 3),
    ('servicios_forma_de_pago', 20, A),
    # campos para cgAutorizarRetiroTransferencia (WSLPGv1.6):
    ('cuit_receptor', 11, N),
    ('fecha', 10, A),                           # no usado WSLPGv1.8
    ('nro_carta_porte_a_utilizar', 9, N),       # obligatorio para retiro
    ('cee_carta_porte_a_utilizar', 14, N),      # no usado WSLPGv1.8
    # para cgAutorizarPreexistente (WSLPGv1.6):
    ('tipo_certificado_deposito_preexistente', 1, N),  # "R": Retiro "T": Tra.
    ('nro_certificado_deposito_preexistente', 12, N),
    ('cac_certificado_deposito_preexistente', 14, N),  # cambio WSLPGv1.8
    ('fecha_emision_certificado_deposito_preexistente', 10, A),
    ('peso_neto', 8, N),
    # nro_planta definido previamente - agregado WSLPGv1.8
    
    # datos devueltos por el webservice:
    ('reservado2', 183, N),     # padding para futuros campos (no usar)
    ('coe', 12, N),
    ('fecha_certificacion', 10, A), 
    ('estado', 2, A),

    ('reservado3', 101, A),     # padding para futuros campos (no usar)
    
    # otros campos devueltos (opcionales)
    # 'pesosResumen'
    ('peso_bruto_certificado', 10, I , 2),
    ('peso_merma_secado', 10, I , 2),
    ('peso_merma_zarandeo', 10, I , 2),
    # peso_neto_certificado definido arriba
    # serviciosResumen
    ('importe_iva', 10, I , 2),
    ('servicio_gastos_generales', 10, I , 2),
    ('servicio_otros', 10, I , 2),
    ('servicio_total', 10, I , 2),
    ('servicio_zarandeo', 10, I , 2),
    # planta
    ('cuit_titular_planta', 11, N),
    ('razon_social_titular_planta', 11, A),

]

CTG = [                             # para cgAutorizarDeposito (WSLPGv1.6)
    ('tipo_reg', 1, A), # C: CTG
    ('nro_ctg', 8, N),
    ('nro_carta_porte', 9, N),
    ('porcentaje_secado_humedad', 5, I, 2),
    ('importe_secado', 10, I, 2),
    ('peso_neto_merma_secado', 10, I, 2),
    ('tarifa_secado', 10, I, 2),
    ('importe_zarandeo', 10, I, 2),
    ('peso_neto_merma_zarandeo', 10, I, 2),
    ('tarifa_zarandeo', 10, I, 2),
    ('peso_neto_confirmado_definitivo', 10, I, 2),
]

DET_MUESTRA_ANALISIS = [            # para cgAutorizarDeposito (WSLPGv1.6)
    ('tipo_reg', 1, A), # D: detalle muestra analisis
    ('descripcion_rubro', 400, A),
    ('tipo_rubro', 1, A),           #  "B" (Bonificación) y "R" (Rebaja)
    ('porcentaje', 5, I, 2),
    ('valor', 5, I, 2),
]

CALIDAD = [             # para cgAutorizar y cgInformarCalidad (WSLPGv1.10)
    ('tipo_reg', 1, A), # Q: caldiad
    ('analisis_muestra', 10, N),
    ('nro_boletin', 10, N),
    ('cod_grado', 2, A),                        # nuevo WSLPGv1.10: G1 G2 ....
    ('valor_grado', 4, I, 3),                   # solo para cod_grado F1 F2 ...
    ('valor_contenido_proteico', 5, I, 3),
    ('valor_factor', 6, I, 3),
]

EVENTO = [
    ('tipo_reg', 1, A), # E: Evento
    ('codigo', 4, A), 
    ('descripcion', 250, A), 
    ]
    
ERROR = [
    ('tipo_reg', 1, A), # R: Error
    ('codigo', 4, A), 
    ('descripcion', 250, A), 
    ]

DATO = [
    ('tipo_reg', 1, A), # 9: Dato adicional
    ('campo', 25, A), 
    ('valor', 250, A), 
    ]


class WSLPG(BaseWS):
    "Interfaz para el WebService de Liquidación Primaria de Granos"    
    _public_methods_ = ['Conectar', 'Dummy', 'LoadTestXML',
                        'AutorizarLiquidacion',
                        'AutorizarLiquidacionSecundaria', 
                        'AnularLiquidacionSecundaria','AnularLiquidacion',
                        'CrearLiquidacion', 'CrearLiqSecundariaBase',
                        'AgregarCertificado', 'AgregarRetencion', 
                        'AgregarDeduccion', 'AgregarPercepcion',
                        'AgregarOpcional', 'AgregarCalidad',
                        'ConsultarLiquidacion', 'ConsultarUltNroOrden',
                        'ConsultarLiquidacionSecundaria',
                        'ConsultarLiquidacionSecundariaUltNroOrden',
                        'CrearAjusteBase', 
                        'CrearAjusteDebito', 'CrearAjusteCredito',
                        'AjustarLiquidacionUnificado',
                        'AjustarLiquidacionUnificadoPapel',
                        'AjustarLiquidacionContrato',
                        'AnalizarAjusteDebito', 'AnalizarAjusteCredito',
                        'AsociarLiquidacionAContrato', 'ConsultarAjuste',
                        'ConsultarLiquidacionesPorContrato', 
                        'CrearCertificacionCabecera', 
                        'AgregarCertificacionPrimaria',
                        'AgregarCertificacionRetiroTransferencia',
                        'AgregarCertificacionPreexistente',
                        'AgregarDetalleMuestraAnalisis', 'AgregarCTG',
                        'AutorizarCertificacion', 
                        'InformarCalidadCertificacion',
                        'AnularCertificacion',
                        'ConsultarCertificacion',
                        'ConsultarCertificacionUltNroOrden',
                        'LeerDatosLiquidacion',
                        'ConsultarCampanias',
                        'ConsultarTipoGrano',
                        'ConsultarGradoEntregadoXTipoGrano',
                        'ConsultarCodigoGradoReferencia',
                        'ConsultarTipoCertificadoDeposito',
                        'ConsultarTipoDeduccion',
                        'ConsultarTipoRetencion',
                        'ConsultarPuerto',
                        'ConsultarTipoActividad', 
                        'ConsultarTipoActividadRepresentado',
                        'ConsultarProvincias',
                        'ConsultarLocalidadesPorProvincia',
                        'ConsultarTiposOperacion',
                        'BuscarLocalidades',
                        'AnalizarXml', 'ObtenerTagXml',
                        'SetParametro', 'GetParametro',
                        'CargarFormatoPDF', 'AgregarCampoPDF', 'AgregarDatoPDF',
                        'CrearPlantillaPDF', 'ProcesarPlantillaPDF', 
                        'GenerarPDF', 'MostrarPDF',
                        ]
    _public_attrs_ = ['Token', 'Sign', 'Cuit', 
        'AppServerStatus', 'DbServerStatus', 'AuthServerStatus', 
        'Excepcion', 'ErrCode', 'ErrMsg', 'LanzarExcepciones', 'Errores',
        'XmlRequest', 'XmlResponse', 'Version', 'Traceback', 'InstallDir',
        'COE', 'COEAjustado', 'Estado', 'Resultado', 'NroOrden',
        'TotalDeduccion', 'TotalRetencion', 'TotalRetencionAfip', 
        'TotalOtrasRetenciones', 'TotalNetoAPagar', 'TotalPagoSegunCondicion',
        'TotalIvaRg2300_07', 'Subtotal', 'TotalIva105', 'TotalIva21',
        'TotalRetencionesGanancias', 'TotalRetencionesIVA', 'NroContrato',
        'FechaCertificacion', 
        ]
    _reg_progid_ = "WSLPG"
    _reg_clsid_ = "{9D21C513-21A6-413C-8592-047357692608}"

    # Variables globales para BaseWS:
    HOMO = HOMO
    WSDL = WSDL
    LanzarExcepciones = False
    Version = "%s %s" % (__version__, HOMO and 'Homologación' or '')

    def inicializar(self):
        BaseWS.inicializar(self)
        self.AppServerStatus = self.DbServerStatus = self.AuthServerStatus = None
        self.errores = []
        self.COE = self.COEAjustado = ""
        self.Estado = self.Resultado = self.NroOrden = self.NroContrato = ''
        self.TotalDeduccion = ""
        self.TotalRetencion = ""
        self.TotalRetencionAfip = ""
        self.TotalOtrasRetenciones = ""
        self.TotalNetoAPagar = ""
        self.TotalIvaRg2300_07 = ""
        self.TotalPagoSegunCondicion = ""
        self.Subtotal = self.TotalIva105 = self.TotalIva21 = ""
        self.TotalRetencionesGanancias = self.TotalRetencionesIVA = ""
        self.datos = {}

    @inicializar_y_capturar_excepciones
    def Conectar(self, cache=None, url="", proxy="", wrapper="", cacert=None, timeout=None):
        "Establecer la conexión a los servidores de la AFIP"
        # llamo al constructor heredado:
        ok = BaseWS.Conectar(self, cache, url, proxy, wrapper, cacert, timeout)
        if ok:        
            # corrijo ubicación del servidor (puerto htttp 80 en el WSDL)
            location = self.client.services['LpgService']['ports']['LpgEndPoint']['location']
            if location.startswith("http://"):
                print "Corrigiendo WSDL ...", location,
                location = location.replace("http://", "https://").replace(":80", ":443")
                self.client.services['LpgService']['ports']['LpgEndPoint']['location'] = location
                print location
            
            try:
                # intento abrir el diccionario persistente de localidades
                import wslpg_datos
                localidades_db = os.path.join(self.cache, "localidades.dat")
                # verificar que puede escribir en el dir, sino abrir solo lectura
                flag = os.access(self.cache, os.W_OK) and 'c' or 'r'
                wslpg_datos.LOCALIDADES = shelve.open(localidades_db, flag=flag)
                if DEBUG: print "Localidades en BD:", len(wslpg_datos.LOCALIDADES)
                self.Traceback = "Localidades en BD: %s" % len(wslpg_datos.LOCALIDADES)
            except Exception, e:
                print "ADVERTENCIA: No se pudo abrir la bbdd de localidades:", e
                self.Excepcion = str(e)
            
        return ok

    def __analizar_errores(self, ret):
        "Comprueba y extrae errores si existen en la respuesta XML"
        errores = []
        if 'errores' in ret:
            errores.extend(ret['errores'])
        if 'erroresFormato' in ret:
            errores.extend(ret['erroresFormato'])
        if errores:
            self.Errores = ["%(codigo)s: %(descripcion)s" % err['error'] 
                            for err in errores]
            self.errores = [
                {'codigo': err['error']['codigo'],
                 'descripcion': err['error']['descripcion'].replace("\n", "")
                                .replace("\r", "")} 
                             for err in errores]
            self.ErrCode = ' '.join(self.Errores)
            self.ErrMsg = '\n'.join(self.Errores)

    @inicializar_y_capturar_excepciones
    def Dummy(self):
        "Obtener el estado de los servidores de la AFIP"
        results = self.client.dummy()['return']
        self.AppServerStatus = str(results['appserver'])
        self.DbServerStatus = str(results['dbserver'])
        self.AuthServerStatus = str(results['authserver'])
        return True

    @inicializar_y_capturar_excepciones
    def CrearLiquidacion(self, nro_orden=None, cuit_comprador=None, 
               nro_act_comprador=None, nro_ing_bruto_comprador=None,
               cod_tipo_operacion=None,
               es_liquidacion_propia=None, es_canje=None,
               cod_puerto=None, des_puerto_localidad=None, cod_grano=None,
               cuit_vendedor=None, nro_ing_bruto_vendedor=None,
               actua_corredor=None, liquida_corredor=None, cuit_corredor=None,
               comision_corredor=None, nro_ing_bruto_corredor=None,
               fecha_precio_operacion=None,
               precio_ref_tn=None, cod_grado_ref=None, cod_grado_ent=None,
               factor_ent=None, precio_flete_tn=None, cont_proteico=None,
               alic_iva_operacion=None, campania_ppal=None,
               cod_localidad_procedencia=None,
               datos_adicionales=None, pto_emision=1, cod_prov_procedencia=None, 
               peso_neto_sin_certificado=None, val_grado_ent=None,
               cod_localidad_procedencia_sin_certificado=None,
               cod_prov_procedencia_sin_certificado=None,
               nro_contrato=None,
               **kwargs
               ):
        "Inicializa internamente los datos de una liquidación para autorizar"

        # limpio los campos especiales (segun validaciones de AFIP)
        if alic_iva_operacion == 0:
            alic_iva_operacion = None   # no informar alicuota p/ monotributo
        if val_grado_ent == 0:
            val_grado_ent = None
        # borrando datos corredor si no corresponden
        if actua_corredor == "N":
            cuit_corredor = None
            comision_corredor = None
            nro_ing_bruto_corredor = None
        elif es_liquidacion_propia == "N" and liquida_corredor == "N":
            nro_ing_bruto_corredor = None           # validación 1623
        
        # si no corresponde elimino el peso neto certificado campo opcional
        if not peso_neto_sin_certificado or not int(peso_neto_sin_certificado):
            peso_neto_sin_certificado = None
        
        if cod_puerto and int(cod_puerto) != 14:
            des_puerto_localidad = None             # validacion 1630

        # limpio los campos opcionales para no enviarlos si no corresponde:
        if cod_grado_ref == "":
            cod_grado_ref = None
        if cod_grado_ent == "":
            cod_grado_ent = None
        if val_grado_ent == 0:
            val_grado_ent = None

        # creo el diccionario con los campos generales de la liquidación:
        self.liquidacion = dict(
                            ptoEmision=pto_emision,
                            nroOrden=nro_orden,
                            cuitComprador=cuit_comprador,
                            nroActComprador=nro_act_comprador,
                            nroIngBrutoComprador=nro_ing_bruto_comprador,
                            codTipoOperacion=cod_tipo_operacion,
                            esLiquidacionPropia=es_liquidacion_propia,
                            esCanje=es_canje,
                            codPuerto=cod_puerto,
                            desPuertoLocalidad=des_puerto_localidad,
                            codGrano=cod_grano,
                            cuitVendedor=cuit_vendedor,
                            nroIngBrutoVendedor=nro_ing_bruto_vendedor,
                            actuaCorredor=actua_corredor,
                            liquidaCorredor=liquida_corredor,
                            cuitCorredor=cuit_corredor,
                            comisionCorredor=comision_corredor,
                            nroIngBrutoCorredor=nro_ing_bruto_corredor,
                            fechaPrecioOperacion=fecha_precio_operacion,
                            precioRefTn=precio_ref_tn,
                            codGradoRef=cod_grado_ref,
                            codGradoEnt=cod_grado_ent,
                            valGradoEnt=val_grado_ent,
                            factorEnt=factor_ent,
                            precioFleteTn=precio_flete_tn,
                            contProteico=cont_proteico,
                            alicIvaOperacion=alic_iva_operacion,
                            campaniaPPal=campania_ppal,
                            codLocalidadProcedencia=cod_localidad_procedencia,
                            codProvProcedencia=cod_prov_procedencia,
                            datosAdicionales=datos_adicionales,
                            pesoNetoSinCertificado=peso_neto_sin_certificado,
                            numeroContrato=nro_contrato or None,
                            certificados=[],
            )
        # para compatibilidad hacia atras, "copiar" los campos si no hay cert:
        if peso_neto_sin_certificado:
            if cod_localidad_procedencia_sin_certificado is None:
                cod_localidad_procedencia_sin_certificado = cod_localidad_procedencia
            if cod_prov_procedencia_sin_certificado is None:
                cod_prov_procedencia_sin_certificado = cod_prov_procedencia
            self.liquidacion.update(dict(
                codLocalidadProcedenciaSinCertificado=cod_localidad_procedencia_sin_certificado,
                codProvProcedenciaSinCertificado=cod_prov_procedencia_sin_certificado,
                ))

        # inicializo las listas que contentran las retenciones y deducciones:
        self.retenciones = []
        self.deducciones = []
        return True

    @inicializar_y_capturar_excepciones
    def CrearLiqSecundariaBase(self, pto_emision=1, nro_orden=None, 
            nro_contrato=None,
            cuit_comprador=None, nro_ing_bruto_comprador=None,
            cod_puerto=None, des_puerto_localidad=None, 
            cod_grano=None, cantidad_tn=None,
            cuit_vendedor=None, nro_act_vendedor=None,  # nuevo!!
            nro_ing_bruto_vendedor=None,
            actua_corredor=None, liquida_corredor=None, cuit_corredor=None,
            nro_ing_bruto_corredor=None, 
            fecha_precio_operacion=None, precio_ref_tn=None,
            precio_operacion=None, alic_iva_operacion=None, campania_ppal=None,
            cod_localidad_procedencia=None, cod_prov_procedencia=None,
            datos_adicionales=None,
            **kwargs):
        "Inicializa los datos de una liquidación secundaria de granos (base)"
 
        # creo el diccionario con los campos generales de la liquidación:
        self.liquidacion = dict(
            ptoEmision=pto_emision, nroOrden=nro_orden,
            numeroContrato=nro_contrato or None, cuitComprador=cuit_comprador, 
            nroIngBrutoComprador=nro_ing_bruto_comprador,
            codPuerto=cod_puerto, desPuertoLocalidad=des_puerto_localidad,
            codGrano=cod_grano, cantidadTn=cantidad_tn,
            cuitVendedor=cuit_vendedor, nroActVendedor=nro_act_vendedor,
            nroIngBrutoVendedor=nro_ing_bruto_vendedor,
            actuaCorredor=actua_corredor, liquidaCorredor=liquida_corredor,
            cuitCorredor=cuit_corredor or None, 
            nroIngBrutoCorredor=nro_ing_bruto_corredor or None,
            fechaPrecioOperacion=fecha_precio_operacion,
            precioRefTn=precio_ref_tn, precioOperacion=precio_operacion,
            alicIvaOperacion=alic_iva_operacion or None, 
            campaniaPPal=campania_ppal,
            codLocalidad=cod_localidad_procedencia, 
            codProvincia=cod_prov_procedencia,
            datosAdicionales=datos_adicionales,
            )
        # inicializo las listas que contentran las retenciones y deducciones:
        self.deducciones = []
        self.percepciones = []
        self.opcionales = []
        return True

    @inicializar_y_capturar_excepciones
    def AgregarCertificado(self, tipo_certificado_deposito=None,
                           nro_certificado_deposito=None,
                           peso_neto=None,
                           cod_localidad_procedencia=None,
                           cod_prov_procedencia=None,
                           campania=None, fecha_cierre=None, 
                           peso_neto_total_certificado=None,
                           coe_certificado_deposito=None,       # WSLPGv1.6
                           **kwargs):
        "Agrego el certificado a la liquidación / certificación de granos"
        # limpio campos opcionales:
        if not peso_neto_total_certificado:
            peso_neto_total_certificado = None  # 0 no es válido
        cert = dict(
                        tipoCertificadoDeposito=tipo_certificado_deposito,
                        nroCertificadoDeposito=nro_certificado_deposito,
                        pesoNeto=peso_neto,
                        codLocalidadProcedencia=cod_localidad_procedencia,
                        codProvProcedencia=cod_prov_procedencia,
                        campania=campania,
                        fechaCierre=fecha_cierre,
                        pesoNetoTotalCertificado=peso_neto_total_certificado,
                        coeCertificadoDeposito=coe_certificado_deposito,
                      )
        if not coe_certificado_deposito:
            self.liquidacion['certificados'].append({'certificado': cert})
        else:
            self.certificacion['retiroTransferencia']['certificadoDeposito'] = cert
        return True

    @inicializar_y_capturar_excepciones
    def AgregarRetencion(self, codigo_concepto, detalle_aclaratorio, 
                               base_calculo, alicuota, 
                               nro_certificado_retencion=None, 
                               fecha_certificado_retencion=None,
                               importe_certificado_retencion=None,
                               **kwargs):
        "Agrega la información referente a las retenciones de la liquidación"
        # limpio los campos opcionales:
        if fecha_certificado_retencion is not None and not fecha_certificado_retencion.strip():
            fecha_certificado_retencion = None
        if importe_certificado_retencion is not None and not float(importe_certificado_retencion):
            importe_certificado_retencion = None
        if nro_certificado_retencion is not None and not int(nro_certificado_retencion):
            nro_certificado_retencion = None
        self.retenciones.append(dict(
                                    retencion=dict(
                                        codigoConcepto=codigo_concepto,
                                        detalleAclaratorio=detalle_aclaratorio,
                                        baseCalculo=base_calculo,
                                        alicuota=alicuota,
                                        nroCertificadoRetencion=nro_certificado_retencion,
                                        fechaCertificadoRetencion=fecha_certificado_retencion,
                                        importeCertificadoRetencion=importe_certificado_retencion,
                                    ))
                            )
        return True

    @inicializar_y_capturar_excepciones
    def AgregarDeduccion(self, codigo_concepto=None, detalle_aclaratorio=None,
                               dias_almacenaje=None, precio_pkg_diario=None,
                               comision_gastos_adm=None, base_calculo=None,
                               alicuota=None, **kwargs):
        "Agrega la información referente a las deducciones de la liquidación."
        # limpiar campo según validación (comision_gastos_adm puede ser 0.00!)
        if codigo_concepto != "CO" and comision_gastos_adm is not None \
            and float(comision_gastos_adm) == 0:
            comision_gastos_adm = None
        # no enviar campos para prevenir errores AFIP 1705, 1707, 1708
        if base_calculo is not None:
            if codigo_concepto == "AL":
                base_calculo = None
            if codigo_concepto == "CO" and float(base_calculo) == 0:
                base_calculo = None         # no enviar, por retrocompatibilidad
        if codigo_concepto != "AL":
            dias_almacenaje = None
            precio_pkg_diario = None
        self.deducciones.append(dict(
                                    deduccion=dict(
                                        codigoConcepto=codigo_concepto,
                                        detalleAclaratorio=detalle_aclaratorio,
                                        diasAlmacenaje=dias_almacenaje,
                                        precioPKGdiario=precio_pkg_diario,
                                        comisionGastosAdm=comision_gastos_adm,
                                        baseCalculo=base_calculo,
                                        alicuotaIva=alicuota, 
                                    ))
                            )
        return True

    @inicializar_y_capturar_excepciones
    def AgregarPercepcion(self, codigo_concepto=None, detalle_aclaratoria=None,
                               base_calculo=None, alicuota=None, **kwargs):
        "Agrega la información referente a las percepciones de la liq. sec."
        self.percepciones.append(dict(
                                    percepcion=dict(
                                        detalleAclaratoria=detalle_aclaratoria,
                                        baseCalculo=base_calculo,
                                        alicuota=alicuota,
                                    ))
                            )
        return True

    @inicializar_y_capturar_excepciones
    def AgregarOpcional(self, codigo=None, descripcion=None, **kwargs):
        "Agrega la información referente a los opcionales de la liq. seq."
        self.opcionales.append(dict(
                                    opcional=dict(
                                        codigo=codigo,
                                        descripcion=descripcion,
                                    ))
                            )
        return True
    
    @inicializar_y_capturar_excepciones
    def AutorizarLiquidacion(self):
        "Autorizar Liquidación Primaria Electrónica de Granos"
        
        # limpio los elementos que no correspondan por estar vacios:
        if not self.liquidacion['certificados']:
            del self.liquidacion['certificados']
        if not self.retenciones:
            self.retenciones = None
        if not self.deducciones:
            self.deducciones = None
        
        # llamo al webservice:
        ret = self.client.liquidacionAutorizar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        liquidacion=self.liquidacion,
                        retenciones=self.retenciones,
                        deducciones=self.deducciones,
                        )

        # analizo la respusta
        ret = ret['liqReturn']
        self.__analizar_errores(ret)
        self.AnalizarLiquidacion(ret.get('autorizacion'), self.liquidacion)
        return True

    @inicializar_y_capturar_excepciones
    def AutorizarLiquidacionSecundaria(self):
        "Autorizar Liquidación Secundaria Electrónica de Granos"

        # extraer y adaptar los campos para liq. sec.
        if self.deducciones:
            self.liquidacion['deduccion'] = []
            for it in self.deducciones:
                ded = it['deduccion']                  # no se agrupa
                self.liquidacion['deduccion'].append({
                    'detalleAclaratoria': ded['detalleAclaratorio'],
                    'baseCalculo': ded['baseCalculo'], 
                    'alicuotaIVA': ded['alicuotaIva']})
        if self.percepciones:
            self.liquidacion['percepcion'] = []
            for it in self.percepciones:
                per = it['percepcion']                  # no se agrupa
                self.liquidacion['percepcion'].append(per)
        if self.opcionales:
            self.liquidacion['opcionales'] = self.opcionales    # agrupado ok
        
        # llamo al webservice:
        ret = self.client.lsgAutorizar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        liqSecundariaBase=self.liquidacion,
                        )

        # analizo la respusta
        ret = ret['oReturn']
        self.__analizar_errores(ret)
        self.AnalizarLiquidacion(ret.get('autorizacion'), self.liquidacion)
        return True

    def AnalizarLiquidacion(self, aut, liq=None, ajuste=False):
        "Método interno para analizar la respuesta de AFIP"
        # proceso los datos básicos de la liquidación (devuelto por consultar):
        if liq:
            self.params_out = dict(
                        pto_emision=liq.get('ptoEmision'),
                        nro_orden=liq.get('nroOrden'),
                        cuit_comprador=liq.get('cuitComprador'),
                        nro_act_comprador=liq.get('nroActComprador'),
                        nro_ing_bruto_comprador=liq.get('nroIngBrutoComprador'),
                        cod_tipo_operacion=liq.get('codTipoOperacion'),
                        es_liquidacion_propia=liq.get('esLiquidacionPropia'),
                        es_canje=liq.get('esCanje'),
                        cod_puerto=liq.get('codPuerto'),
                        des_puerto_localidad=liq.get('desPuertoLocalidad'),
                        cod_grano=liq.get('codGrano'),
                        cuit_vendedor=liq.get('cuitVendedor'),
                        nro_ing_bruto_vendedor=liq.get('nroIngBrutoVendedor'),
                        actua_corredor=liq.get('actuaCorredor'),
                        liquida_corredor=liq.get('liquidaCorredor'),
                        cuit_corredor=liq.get('cuitCorredor'),
                        comision_corredor=liq.get('comisionCorredor'),
                        nro_ing_bruto_corredor=liq.get('nroIngBrutoCorredor'),
                        fecha_precio_operacion=liq.get('fechaPrecioOperacion'),
                        precio_ref_tn=liq.get('precioRefTn'),
                        cod_grado_ref=liq.get('codGradoRef'),
                        cod_grado_ent=liq.get('codGradoEnt'),
                        factor_ent=liq.get('factorEnt'),
                        precio_flete_tn=liq.get('precioFleteTn'),
                        cont_proteico=liq.get('contProteico'),
                        alic_iva_operacion=liq.get('alicIvaOperacion'),
                        campania_ppal=liq.get('campaniaPPal'),
                        cod_localidad_procedencia=liq.get('codLocalidadProcedencia'),
                        cod_prov_procedencia=liq.get('codProvProcedencia'),
                        datos_adicionales=liq.get('datosAdicionales'),
                        peso_neto_sin_certificado=liq.get('pesoNetoSinCertificado'),
                        cod_localidad_procedencia_sin_certificado=liq.get('codLocalidadProcedenciaSinCertificado'),
                        cod_prov_procedencia_sin_certificado=liq.get('codProvProcedenciaSinCertificado'),
                        certificados=[],
                    )
            if ajuste:
                self.params_out.update(
                        # ajustes:
                        diferencia_peso_neto=liq.get('diferenciaPesoNeto'),
                        diferencia_precio_operacion=liq.get('diferenciaPrecioOperacion'),
                        cod_grado=liq.get('codGrado'),
                        val_grado=liq.get('valGrado'),
                        factor=liq.get('factor'),
                        diferencia_precio_flete_tn=liq.get('diferenciaPrecioFleteTn'),
                        concepto_importe_iva_0=liq.get('conceptoImporteIva0'),
                        importe_ajustar_iva_0=liq.get('importeAjustarIva0'),
                        concepto_importe_iva_105=liq.get('conceptoImporteIva105'),
                        importe_ajustar_iva_105=liq.get('importeAjustarIva105'),
                        concepto_importe_iva_21=liq.get('conceptoImporteIva21'),
                        importe_ajustar_iva_21=liq.get('importeAjustarIva21'),
                    )
                # analizar detalle de importes ajustados discriminados por alicuota
                # (por compatibildiad y consistencia se usan los mismos campos)
                for it in liq.get("importes"):
                    it = it['importeReturn']
                    tasa = "iva_%s" % str(it['alicuota']).replace(".", "").strip()
                    self.params_out["concepto_importe_%s" % tasa] = it['concepto']
                    self.params_out["importe_ajustar_%s" % tasa] = it['importe']
                    self.params_out["iva_calculado_%s" % tasa] = it['ivaCalculado']
            if 'certificados' in liq:
                for c in liq['certificados']:
                    cert = c['certificado']
                    self.params_out['certificados'].append(dict(
                        tipo_certificado_deposito=cert['tipoCertificadoDeposito'],
                        nro_certificado_deposito=cert['nroCertificadoDeposito'],
                        peso_neto=cert['pesoNeto'],
                        cod_localidad_procedencia=cert['codLocalidadProcedencia'],
                        cod_prov_procedencia=cert['codProvProcedencia'],
                        campania=cert['campania'],
                        fecha_cierre=cert['fechaCierre'],
                    ))

        self.params_out['errores'] = self.errores
            
        # proceso la respuesta de autorizar, ajustar (y consultar):
        if aut:
            self.TotalDeduccion = aut.get('totalDeduccion')
            self.TotalRetencion = aut.get('totalRetencion')
            self.TotalRetencionAfip = aut.get('totalRetencionAfip')
            self.TotalOtrasRetenciones = aut.get('totalOtrasRetenciones')
            self.TotalNetoAPagar = aut.get('totalNetoAPagar')
            self.TotalIvaRg2300_07 = aut.get('totalIvaRg2300_07')
            self.TotalPagoSegunCondicion = aut.get('totalPagoSegunCondicion')
            self.COE = str(aut.get('coe', ''))
            self.COEAjustado = aut.get('coeAjustado')
            self.Estado = aut.get('estado', '')
            self.NroContrato = aut.get('numeroContrato', '')

            # actualizo parámetros de salida:
            self.params_out['coe'] = self.COE
            self.params_out['coe_ajustado'] = self.COEAjustado
            self.params_out['estado'] = self.Estado
            self.params_out['total_deduccion'] = self.TotalDeduccion
            self.params_out['total_retencion'] = self.TotalRetencion
            self.params_out['total_retencion_afip'] = self.TotalRetencionAfip
            self.params_out['total_otras_retenciones'] = self.TotalOtrasRetenciones
            self.params_out['total_neto_a_pagar'] = self.TotalNetoAPagar
            self.params_out['total_iva_rg_2300_07'] = self.TotalIvaRg2300_07
            self.params_out['total_pago_segun_condicion'] = self.TotalPagoSegunCondicion

            # datos adicionales:
            self.params_out['nro_orden'] = aut.get('nroOrden')
            self.params_out['cod_tipo_ajuste'] = aut.get('codTipoAjuste')
            fecha = aut.get('fechaLiquidacion')
            if fecha:
                fecha = str(fecha)
            self.params_out['fecha_liquidacion'] = fecha
            self.params_out['importe_iva'] = aut.get('importeIva')
            self.params_out['nro_op_comercial'] = aut.get('nroOpComercial')
            self.params_out['operacion_con_iva'] = aut.get('operacionConIva')
            self.params_out['precio_operacion'] = aut.get('precioOperacion')
            self.params_out['total_peso_neto'] = aut.get('totalPesoNeto')
            self.params_out['subtotal'] = aut.get('subTotal')
            # LSG (especificos):
            self.params_out['total_deducciones'] = aut.get('totalDeducciones')
            self.params_out['total_percepciones'] = aut.get('totalPercepciones')
            # sub estructuras:
            self.params_out['retenciones'] = []
            self.params_out['deducciones'] = []
            for retret in aut.get("retenciones", []):
                retret = retret['retencionReturn']
                self.params_out['retenciones'].append({
                    'importe_retencion': retret['importeRetencion'],
                    'alicuota': retret['retencion'].get('alicuota'),
                    'base_calculo': retret['retencion'].get('baseCalculo'),
                    'codigo_concepto': retret['retencion'].get('codigoConcepto'),
                    'detalle_aclaratorio': retret['retencion'].get('detalleAclaratorio', "").replace("\n", ""),
                    'importe_certificado_retencion': retret['retencion'].get('importeCertificadoRetencion'),
                    'nro_certificado_retencion': retret['retencion'].get('nroCertificadoRetencion'),
                    'fecha_certificado_retencion': retret['retencion'].get('fechaCertificadoRetencion'),
                    })
            for dedret in aut.get("deducciones", []):
                dedret = dedret['deduccionReturn']
                self.params_out['deducciones'].append({
                    'importe_deduccion': dedret['importeDeduccion'],
                    'importe_iva': dedret.get('importeIva'),
                     'alicuota': dedret['deduccion'].get('alicuotaIva'),
                     'base_calculo': dedret['deduccion'].get('baseCalculo'),
                     'codigo_concepto': dedret['deduccion'].get('codigoConcepto'),
                     'detalle_aclaratorio': dedret['deduccion'].get('detalleAclaratorio', "").replace("\n", ""),
                     'dias_almacenaje': dedret['deduccion'].get('diasAlmacenaje'),
                     'precio_pkg_diario': dedret['deduccion'].get('precioPKGdiario'),
                     'comision_gastos_adm': dedret['deduccion'].get('comisionGastosAdm'),
                    })
        

    @inicializar_y_capturar_excepciones
    def CrearAjusteBase(self, 
               pto_emision=1, nro_orden=None,       # unificado, contrato, papel
               coe_ajustado=None,                   # unificado
               nro_contrato=None,                   # contrato
               tipo_formulario=None,                # papel
               nro_formulario=None,                 # papel
               actividad=None,                      # contrato / papel
               cod_grano=None,                      # contrato / papel
               cuit_vendedor=None,                  # contrato / papel
               cuit_comprador=None,                 # contrato / papel
               cuit_corredor=None,                  # contrato / papel
               nro_ing_bruto_vendedor=None,         # papel
               nro_ing_bruto_comprador=None,        # papel
               nro_ing_bruto_corredor=None,         # papel
               tipo_operacion=None,                 # papel
               precio_ref_tn=None,                  # contrato
               cod_grado_ent=None,                  # contrato
               val_grado_ent=None,                  # contrato
               precio_flete_tn=None,                # contrato
               cod_puerto=None,                     # contrato
               des_puerto_localidad=None,           # contrato
               cod_provincia=None,                  # unificado, contrato, papel
               cod_localidad=None,                  # unificado, contrato, papel
               comision_corredor=None,              # papel
               **kwargs
               ):
        "Inicializa internamente los datos de una liquidación para ajustar"

        # ajusto nombre de campos para compatibilidad hacia atrás (encabezado):
        if 'cod_localidad_procedencia' in kwargs:
            cod_localidad = kwargs['cod_localidad_procedencia']
        if 'cod_provincia_procedencia' in kwargs:
            cod_provincia = kwargs['cod_provincia_procedencia']
        if 'nro_act_comprador' in kwargs:
            actividad = kwargs['nro_act_comprador']
        if 'cod_tipo_operacion' in kwargs:
            tipo_operacion = kwargs['cod_tipo_operacion']
            
        # limpio los campos especiales (segun validaciones de AFIP)
        if val_grado_ent == 0:
            val_grado_ent = None
        # borrando datos si no corresponden
        if cuit_corredor and int(cuit_corredor) == 0:
            cuit_corredor = None
            comision_corredor = None
            nro_ing_bruto_corredor = None
               
        if cod_puerto and int(cod_puerto) != 14:
            des_puerto_localidad = None             # validacion 1630

        # limpio los campos opcionales para no enviarlos si no corresponde:
        if cod_grado_ent == "":
            cod_grado_ent = None
        if val_grado_ent == 0:
            val_grado_ent = None

        # creo el diccionario con los campos generales del ajuste base:
        self.ajuste = { 'ajusteBase': {
                            'ptoEmision': pto_emision,
                            'nroOrden': nro_orden,
                            'coeAjustado': coe_ajustado,
                            'nroContrato': nro_contrato,
                            'tipoFormulario': tipo_formulario,
                            'nroFormulario': nro_formulario,
                            'actividad': actividad,
                            'codGrano': cod_grano,
                            'cuitVendedor': cuit_vendedor,
                            'cuitComprador': cuit_comprador,
                            'cuitCorredor': cuit_corredor,
                            'nroIngBrutoVendedor': nro_ing_bruto_vendedor,
                            'nroIngBrutoComprador': nro_ing_bruto_comprador,
                            'nroIngBrutoCorredor': nro_ing_bruto_corredor,
                            'tipoOperacion': tipo_operacion,
                            'codPuerto': cod_puerto,
                            'desPuertoLocalidad': des_puerto_localidad,
                            'comisionCorredor': comision_corredor,
                            'precioRefTn': precio_ref_tn,
                            'codGradoEnt': cod_grado_ent,
                            'valGradoEnt': val_grado_ent,
                            'precioFleteTn': precio_flete_tn,
                            'codLocalidad': cod_localidad,
                            'codProv': cod_provincia,
                            'certificados': [],
                            }
                        }
        # para compatibilidad con AgregarCertificado
        self.liquidacion = self.ajuste['ajusteBase']
        return True

    @inicializar_y_capturar_excepciones
    def CrearAjusteCredito(self, 
               datos_adicionales=None,              # unificado, contrato, papel
               concepto_importe_iva_0=None,         # unificado, contrato, papel
               importe_ajustar_iva_0=None,          # unificado, contrato, papel
               concepto_importe_iva_105=None,       # unificado, contrato, papel
               importe_ajustar_iva_105=None,        # unificado, contrato, papel
               concepto_importe_iva_21=None,        # unificado, contrato, papel
               importe_ajustar_iva_21=None,         # unificado, contrato, papel
               diferencia_peso_neto=None,           # unificado
               diferencia_precio_operacion=None,    # unificado
               cod_grado=None,                      # unificado
               val_grado=None,                      # unificado  
               factor=None,                         # unificado
               diferencia_precio_flete_tn=None,     # unificado
               **kwargs
               ):
        "Inicializa internamente los datos del crédito del ajuste"

        self.ajuste['ajusteCredito'] = {
            'diferenciaPesoNeto': diferencia_peso_neto,
            'diferenciaPrecioOperacion': diferencia_precio_operacion,
            'codGrado': cod_grado,
            'valGrado': val_grado,
            'factor': factor,
            'diferenciaPrecioFleteTn': diferencia_precio_flete_tn,
            'datosAdicionales': datos_adicionales,
            'opcionales': None,
            'conceptoImporteIva0': concepto_importe_iva_0,
            'importeAjustarIva0': importe_ajustar_iva_0,
            'conceptoImporteIva105': concepto_importe_iva_105,
            'importeAjustarIva105': importe_ajustar_iva_105,
            'conceptoImporteIva21': concepto_importe_iva_21,
            'importeAjustarIva21': importe_ajustar_iva_21,
            'deducciones': [],
            'retenciones': [],
            }
        # vinculación con AgregarOpcional:
        self.opcionales = self.ajuste['ajusteCredito']['opcionales']
        # vinculación con AgregarRetencion y AgregarDeduccion
        self.deducciones = self.ajuste['ajusteCredito']['deducciones']
        self.retenciones = self.ajuste['ajusteCredito']['retenciones']
        return True

    @inicializar_y_capturar_excepciones
    def CrearAjusteDebito(self, 
               datos_adicionales=None,              # unificado, contrato, papel
               concepto_importe_iva_0=None,         # unificado, contrato, papel
               importe_ajustar_iva_0=None,          # unificado, contrato, papel
               concepto_importe_iva_105=None,       # unificado, contrato, papel
               importe_ajustar_iva_105=None,        # unificado, contrato, papel
               concepto_importe_iva_21=None,        # unificado, contrato, papel
               importe_ajustar_iva_21=None,         # unificado, contrato, papel
               diferencia_peso_neto=None,           # unificado
               diferencia_precio_operacion=None,    # unificado
               cod_grado=None,                      # unificado
               val_grado=None,                      # unificado  
               factor=None,                         # unificado
               diferencia_precio_flete_tn=None,     # unificado
               **kwargs
               ):
        "Inicializa internamente los datos del crédito del ajuste"

        self.ajuste['ajusteDebito'] = {
            'diferenciaPesoNeto': diferencia_peso_neto,
            'diferenciaPrecioOperacion': diferencia_precio_operacion,
            'codGrado': cod_grado,
            'valGrado': val_grado,
            'factor': factor,
            'diferenciaPrecioFleteTn': diferencia_precio_flete_tn,
            'datosAdicionales': datos_adicionales,
            'opcionales': None,
            'conceptoImporteIva0': concepto_importe_iva_0,
            'importeAjustarIva0': importe_ajustar_iva_0,
            'conceptoImporteIva105': concepto_importe_iva_105,
            'importeAjustarIva105': importe_ajustar_iva_105,
            'conceptoImporteIva21': concepto_importe_iva_21,
            'importeAjustarIva21': importe_ajustar_iva_21,
            'deducciones': [],
            'retenciones': [],
            }
        # vinculación con AgregarOpcional:
        self.opcionales = self.ajuste['ajusteDebito']['opcionales']
        # vinculación con AgregarRetencion y AgregarDeduccion
        self.deducciones = self.ajuste['ajusteDebito']['deducciones']
        self.retenciones = self.ajuste['ajusteDebito']['retenciones']
        return True

    @inicializar_y_capturar_excepciones
    def AjustarLiquidacionUnificado(self):
        "Ajustar Liquidación Primaria de Granos"
        
        # limpiar estructuras no utilizadas (si no hay deducciones / retenciones)
        for k in ('ajusteDebito', 'ajusteCredito'):
            if not any(self.ajuste[k].values()):
                del self.ajuste[k]
            else:
                if not self.ajuste[k]['deducciones']:
                    del self.ajuste[k]['deducciones']
                if not self.ajuste[k]['retenciones']:
                    del self.ajuste[k]['retenciones']

        # llamar al webservice:
        ret = self.client.liquidacionAjustarUnificado(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        **self.ajuste
                        )
        # analizar el resultado:
        ret = ret['ajusteUnifReturn']
        self.__analizar_errores(ret)
        if 'ajusteUnificado' in ret:
            aut = ret['ajusteUnificado']
            self.AnalizarAjuste(aut)
        return True

    @inicializar_y_capturar_excepciones
    def AjustarLiquidacionUnificadoPapel(self):
        "Ajustar Liquidación realizada en un formulario F1116 B / C (papel)"
        
        # limpiar arrays no enviados:
        if not self.ajuste['ajusteBase']['certificados']:
            del self.ajuste['ajusteBase']['certificados']
        for k1 in ('ajusteCredito', 'ajusteDebito'):
            for k2 in ('retenciones', 'deducciones'):
                if not self.ajuste[k1][k2]:
                    del self.ajuste[k1][k2]
        ret = self.client.liquidacionAjustarUnificadoPapel(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        **self.ajuste
                        )
        ret = ret['ajustePapelReturn']
        self.__analizar_errores(ret)
        if 'ajustePapel' in ret:
            aut = ret['ajustePapel']
            self.AnalizarAjuste(aut)
        return True

    @inicializar_y_capturar_excepciones
    def AjustarLiquidacionContrato(self):
        "Ajustar Liquidación activas relacionadas a un contrato"
        
        # limpiar arrays no enviados:
        if not self.ajuste['ajusteBase']['certificados']:
            del self.ajuste['ajusteBase']['certificados']
        for k1 in ('ajusteCredito', 'ajusteDebito'):
            for k2 in ('retenciones', 'deducciones'):
                if not self.ajuste[k1][k2]:
                    del self.ajuste[k1][k2]

        ret = self.client.liquidacionAjustarContrato(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        **self.ajuste
                        )
        ret = ret['ajusteContratoReturn']
        self.__analizar_errores(ret)
        if 'ajusteContrato' in ret:
            aut = ret['ajusteContrato']
            self.AnalizarAjuste(aut)
        return True

    def AnalizarAjuste(self, aut, base=True):
        "Método interno para analizar la respuesta de AFIP (ajustes)"
        
        # para compatibilidad con la generacion de PDF (completo datos)
        if hasattr(self, "liquidacion") and self.liquidacion and base:
            self.AnalizarLiquidacion(aut=None, liq=self.liquidacion)
            
        self.params_out['errores'] = self.errores
            
        # proceso la respuesta de autorizar, ajustar (y consultar):
        if aut:
            # en caso de anulación o no ser ajuste, ahora no devuelve datos:
            self.COE = str(aut.get('coe', ""))
            self.COEAjustado = aut.get('coeAjustado')
            self.NroContrato = aut.get('nroContrato')
            self.Estado = aut.get('estado', "")

            totunif = aut.get("totalesUnificados") or {}
            self.Subtotal = totunif.get('subTotalGeneral')
            self.TotalIva105 = totunif.get('iva105')
            self.TotalIva21 = totunif.get('iva21')
            self.TotalRetencionesGanancias = totunif.get('retencionesGanancias')
            self.TotalRetencionesIVA = totunif.get('retencionesIVA')
            self.TotalOtrasRetenciones = totunif.get('importeOtrasRetenciones')
            self.TotalNetoAPagar = totunif.get('importeNeto')
            self.TotalIvaRg2300_07 = totunif.get('ivaRG2300_2007')
            self.TotalPagoSegunCondicion = totunif.get('pagoSCondicion')
            
            # actualizo parámetros de salida:
            self.params_out['coe'] = self.COE
            self.params_out['coe_ajustado'] = self.COEAjustado
            self.params_out['estado'] = self.Estado
            self.params_out['nro_orden'] = aut.get('nroOrden')
            self.params_out['cod_tipo_operacion'] = aut.get('codTipoOperacion')
            self.params_out['nro_contrato'] = aut.get('nroContrato')
            self.params_out['nro_op_comercial'] = aut.get('nroOpComercial', "")

            
            # actualizo totales solo para ajuste base (liquidacion general) 
            if base:
                self.params_out['subtotal'] = self.Subtotal
                self.params_out['iva_deducciones'] = totunif.get('ivaDeducciones')
                self.params_out['subtotal_deb_cred'] = totunif.get('subTotalDebCred')
                self.params_out['total_base_deducciones'] = totunif.get('totalBaseDeducciones')
                self.params_out['total_iva_10_5'] = self.TotalIva105
                self.params_out['total_iva_21'] = self.TotalIva21
                self.params_out['total_retenciones_ganancias'] = self.TotalRetencionesGanancias
                self.params_out['total_retenciones_iva'] = self.TotalRetencionesIVA
                self.params_out['total_otras_retenciones'] = self.TotalOtrasRetenciones
                self.params_out['total_neto_a_pagar'] = self.TotalNetoAPagar
                self.params_out['total_iva_rg_2300_07'] = self.TotalIvaRg2300_07
                self.params_out['total_pago_segun_condicion'] = self.TotalPagoSegunCondicion
            
                # almaceno los datos de ajustes crédito y débito para usarlos luego
                self.__ajuste_base = aut
                self.__ajuste_debito = aut.get('ajusteDebito') or {}
                self.__ajuste_credito = aut.get('ajusteCredito') or {}
        else:
            self.__ajuste_base = None
            self.__ajuste_debito = None
            self.__ajuste_credito = None
        return True
    
    @inicializar_y_capturar_excepciones
    def AnalizarAjusteDebito(self):
        "Método para analizar la respuesta de AFIP para Ajuste Debito"
        # para compatibilidad con la generacion de PDF (completo datos)
        liq = {}
        if hasattr(self, "liquidacion") and self.liquidacion:
            liq.update(self.liquidacion)
        if hasattr(self, "ajuste") and 'ajusteDebito' in self.ajuste:
            liq.update(self.ajuste['ajusteDebito'])

        liq.update(self.__ajuste_debito)
        self.AnalizarLiquidacion(aut=self.__ajuste_debito, liq=liq, ajuste=True)
        self.AnalizarAjuste(self.__ajuste_base, base=False)  # datos generales
        return True

    @inicializar_y_capturar_excepciones
    def AnalizarAjusteCredito(self):
        "Método para analizar la respuesta de AFIP para Ajuste Credito"
        liq = {}
        if hasattr(self, "liquidacion") and self.liquidacion:
            liq.update(self.liquidacion)
        if hasattr(self, "ajuste") and 'ajusteCredito' in self.ajuste:
            liq.update(self.ajuste['ajusteCredito'])
        liq.update(self.__ajuste_credito)
        self.AnalizarLiquidacion(aut=self.__ajuste_credito, liq=liq, ajuste=True)
        self.AnalizarAjuste(self.__ajuste_base, base=False)  # datos generales
        return True

    @inicializar_y_capturar_excepciones
    def CrearCertificacionCabecera(self, pto_emision=1, nro_orden=None,
            tipo_certificado=None, nro_planta=None,
            nro_ing_bruto_depositario=None, titular_grano=None,
            cuit_depositante=None, nro_ing_bruto_depositante=None,
            cuit_corredor=None, cod_grano=None, campania=None, 
            datos_adicionales=None,
            **kwargs):
        "Inicializa los datos de una certificación de granos (cabecera)"
 
        self.certificacion = {}
        self.certificacion['cabecera'] = dict(
                ptoEmision=pto_emision,
                nroOrden=nro_orden,
                tipoCertificado=tipo_certificado,
                nroPlanta=nro_planta or None,                       # opcional
                nroIngBrutoDepositario=nro_ing_bruto_depositario,
                titularGrano=titular_grano,
                cuitDepositante=cuit_depositante or None,           # opcional
                nroIngBrutoDepositante=nro_ing_bruto_depositante or None,  # opcional
                cuitCorredor=cuit_corredor or None,                 # opcional
                codGrano=cod_grano,
                campania=campania,
                datosAdicionales=datos_adicionales,                 # opcional
            )
        return True

    @inicializar_y_capturar_excepciones
    def AgregarCertificacionPrimaria(self, 
            nro_act_depositario=None,
            descripcion_tipo_grano=None,
            monto_almacenaje=None, monto_acarreo=None, 
            monto_gastos_generales=None, monto_zarandeo=None,
            porcentaje_secado_de=None, porcentaje_secado_a=None,
            monto_secado=None, monto_por_cada_punto_exceso=None,
            monto_otros=None, 
            porcentaje_merma_volatil=None, peso_neto_merma_volatil=None, 
            porcentaje_merma_secado=None, peso_neto_merma_secado=None, 
            porcentaje_merma_zarandeo=None, peso_neto_merma_zarandeo=None,
            peso_neto_certificado=None, servicios_secado=None,  
            servicios_zarandeo=None, servicios_otros=None, 
            servicios_forma_de_pago=None,
            **kwargs):
        
        self.certificacion['primaria'] = dict(
                nroActDepositario=nro_act_depositario,
                ctg=[],                        # <!--0 or more repetitions:-->
                descripcionTipoGrano=descripcion_tipo_grano,
                montoAlmacenaje=monto_almacenaje,
                montoAcarreo=monto_acarreo,
                montoGastosGenerales=monto_gastos_generales,
                montoZarandeo=monto_zarandeo,
                porcentajeSecadoDe=porcentaje_secado_de,
                porcentajeSecadoA=porcentaje_secado_a,
                montoSecado=monto_secado,
                montoPorCadaPuntoExceso=monto_por_cada_punto_exceso,
                montoOtros=monto_otros,
                porcentajeMermaVolatil=porcentaje_merma_volatil,
                pesoNetoMermaVolatil=peso_neto_merma_volatil,
                porcentajeMermaSecado=porcentaje_merma_secado,
                pesoNetoMermaSecado=peso_neto_merma_secado,
                porcentajeMermaZarandeo=porcentaje_merma_zarandeo,
                pesoNetoMermaZarandeo=peso_neto_merma_zarandeo,
                pesoNetoCertificado=peso_neto_certificado,
                serviciosSecado=servicios_secado or None,           # opcional
                serviciosZarandeo=servicios_zarandeo or None,
                serviciosOtros=servicios_otros or None,
                serviciosFormaDePago=servicios_forma_de_pago or None,
            )
        return True

    
    @inicializar_y_capturar_excepciones
    def AgregarCertificacionRetiroTransferencia(self, 
            nro_act_depositario=None,
            cuit_receptor=None,
            fecha=None, 
            nro_carta_porte_a_utilizar=None,
            cee_carta_porte_a_utilizar=None,
            **kwargs):
        self.certificacion['retiroTransferencia'] = dict(
                nroActDepositario=nro_act_depositario,
                cuitReceptor=cuit_receptor or None,                 # opcional
                fecha=fecha,
                nroCartaPorteAUtilizar=nro_carta_porte_a_utilizar or None,
                ceeCartaPorteAUtilizar=cee_carta_porte_a_utilizar or None,
                certificadoDeposito=[],        # <!--0 or more repetitions:-->
                )
        return True

    @inicializar_y_capturar_excepciones
    def AgregarCertificacionPreexistente(self, 
            tipo_certificado_deposito_preexistente=None,
            nro_certificado_deposito_preexistente=None,
            cac_certificado_deposito_preexistente=None,
            fecha_emision_certificado_deposito_preexistente=None,
            peso_neto=None, nro_planta=None,
            **kwargs):
        self.certificacion['preexistente'] = dict(
                tipoCertificadoDepositoPreexistente=tipo_certificado_deposito_preexistente,
                nroCertificadoDepositoPreexistente=nro_certificado_deposito_preexistente,
                cacCertificadoDepositoPreexistente=cac_certificado_deposito_preexistente,
                fechaEmisionCertificadoDepositoPreexistente=fecha_emision_certificado_deposito_preexistente,
                pesoNeto=peso_neto, nroPlanta=nro_planta,
                )
        return True

    @inicializar_y_capturar_excepciones
    def AgregarCalidad(self, analisis_muestra=None, nro_boletin=None,
                             cod_grado=None, valor_grado=None, 
                             valor_contenido_proteico=None, valor_factor=None, 
                             **kwargs):
        "Agrega la información sobre la calidad, al autorizar o posteriormente"
        self.certificacion['primaria']['calidad'] = dict(
                analisisMuestra=analisis_muestra,
                nroBoletin=nro_boletin,
                codGrado=cod_grado,                 # G1 G2 G3 F1 F2 F3
                valorGrado=valor_grado or None,                     # opcional
                valorContProteico=valor_contenido_proteico or None,
                valorFactor=valor_factor or None,                   # opcional
                detalleMuestraAnalisis=[],     # <!--1 or more repetitions:-->
                )

    @inicializar_y_capturar_excepciones
    def AgregarDetalleMuestraAnalisis(self, descripcion_rubro=None, 
                                      tipo_rubro=None, porcentaje=None, 
                                      valor=None,
                                      **kwargs):
        "Agrega la información referente al detalle de la certificación"
        
        det = dict(
                descripcionRubro=descripcion_rubro,
                tipoRubro=tipo_rubro,
                porcentaje=porcentaje,
                valor=valor,
            )
        self.certificacion['primaria']['calidad']['detalleMuestraAnalisis'].append(det)
        return True

    @inicializar_y_capturar_excepciones
    def AgregarCTG(self, nro_ctg=None, nro_carta_porte=None,
                         porcentaje_secado_humedad=None, importe_secado=None,
                         peso_neto_merma_secado=None, tarifa_secado=None,
                         importe_zarandeo=None, peso_neto_merma_zarandeo=None,
                         tarifa_zarandeo=None, 
                         peso_neto_confirmado_definitivo=None,
                         **kwargs):
        "Agrega la información referente a una CTG de la certificación"
        
        ctg = dict(
                nroCTG=nro_ctg,
                nroCartaDePorte=nro_carta_porte,
                pesoNetoConfirmadoDefinitivo=peso_neto_confirmado_definitivo,
                porcentajeSecadoHumedad=porcentaje_secado_humedad,
                importeSecado=importe_secado,
                pesoNetoMermaSecado=peso_neto_merma_secado,
                tarifaSecado=tarifa_secado,
                importeZarandeo=importe_zarandeo,
                pesoNetoMermaZarandeo=peso_neto_merma_zarandeo,
                tarifaZarandeo=tarifa_zarandeo,
            )
        self.certificacion['primaria']['ctg'].append(ctg)
        return True

    @inicializar_y_capturar_excepciones
    def AutorizarCertificacion(self):
        "Autoriza una Certificación Primaria de Depósito de Granos (C1116A/RT)"
        
        # limpio los elementos que no correspondan por estar vacios:
        for k1 in ('primaria', 'retiroTransferencia'):
            dic = self.certificacion.get(k1)
            if not dic: continue
            for k2 in ('ctg', 'detalleMuestraAnalisis', 'certificadoDeposito'):
                if k2 in dic and not dic[k2]:
                    del dic[k2]
            
        # llamo al webservice:
        ret = self.client.cgAutorizar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        **self.certificacion
                        )

        # analizo la respusta
        ret = ret['oReturn']
        self.__analizar_errores(ret)
        self.AnalizarAutorizarCertificadoResp(ret)
        return True

    def AnalizarAutorizarCertificadoResp(self, ret):
        "Metodo interno para extraer datos de la Respuesta de Certificación"
        aut = ret.get('autorizacion')
        if aut:
            self.PtoEmision = aut['ptoEmision']
            self.NroOrden = aut['nroOrden']
            self.FechaCertificacion = str(aut.get('fechaCertificacion', ""))
            self.COE = aut['coe']
            self.Estado = aut['estado']
            # actualizo parámetros de salida:
            self.params_out['coe'] = self.COE
            self.params_out['estado'] = self.Estado
            self.params_out['nro_orden'] = self.NroOrden
            self.params_out['fecha_certificacion'] = self.FechaCertificacion.replace("-", "")
            if "planta" in aut:
                p = aut.get("planta")
                self.params_out['nro_planta'] = p.get("nroPlanta")
                self.params_out['cuit_titular_planta'] = p.get("cuitTitularPlanta")
                self.params_out['razon_social_titular_planta'] = p.get("razonSocialTitularPlanta")
            # otros campos devueltos (opcionales)
            p = aut.get('pesosResumen', {})
            self.params_out['peso_bruto_certificado'] = p.get("pesoBrutoCertificado")
            self.params_out['peso_merma_secado'] = p.get("pesoMermaSecado")
            self.params_out['peso_merma_volatil'] = p.get("pesoMermaVolatil")
            self.params_out['peso_merma_zarandeo'] = p.get("pesoMermaZarandeo")
            self.params_out['peso_neto_certificado'] = p.get("pesoNetoCertificado")
            p = aut.get('serviciosResumen', {})
            self.params_out['importe_iva'] = p.get("importeIVA")
            self.params_out['servicio_gastos_generales'] = p.get("servicioGastosGenerales")
            self.params_out['servicio_otros'] = p.get("servicioOtros")
            self.params_out['servicio_total'] = p.get("servicioTotal")
            self.params_out['servicio_zarandeo'] = p.get("servicioZarandeo")
        # datos devueltos según el tipo de certificacion (consultas):
        cab = ret.get('cabecera')
        if cab:
            self.params_out['pto_emision'] = cab.get('ptoEmision')
            self.params_out['nro_orden'] = cab.get('nroOrden')
            self.params_out['tipo_certificado'] = cab.get('tipoCertificado')
            self.params_out['nro_planta'] = cab.get('nroPlanta')
            self.params_out['nro_ing_bruto_depositario'] = cab.get('nroIngBrutoDepositario')
            self.params_out['titular_grano'] = cab.get('titularGrano')
            self.params_out['cuit_depositante'] = cab.get('cuitDepositante')
            self.params_out['nro_ing_bruto_depositante'] = cab.get('nroIngBrutoDepositante')
            self.params_out['cuit_corredor'] = cab.get('cuitCorredor')
            self.params_out['cod_grano'] = cab.get('codGrano')
            self.params_out['campania'] = cab.get('campania')
            self.params_out['datos_adicionales'] = cab.get('datosAdicionales')
        pri = ret.get('primaria')
        if pri:
            self.params_out['nro_act_depositario'] = pri.get('nroActDepositario')
            self.params_out['descripcion_tipo_grano'] = pri.get('descripcionTipoGrano')
            self.params_out['monto_almacenaje'] = pri.get('montoAlmacenaje')
            self.params_out['monto_acarreo'] = pri.get('montoAcarreo')
            self.params_out['monto_gastos_generales'] = pri.get('montoGastosGenerales')
            self.params_out['monto_zarandeo'] = pri.get('montoZarandeo')
            self.params_out['porcentaje_secado_de'] = pri.get('porcentajeSecadoDe')
            self.params_out['porcentaje_secado_a'] = pri.get('porcentajeSecadoA')
            self.params_out['monto_secado'] = pri.get('montoSecado')
            self.params_out['monto_por_cada_punto_exceso'] = pri.get('montoPorCadaPuntoExceso')
            self.params_out['monto_otros'] = pri.get('montoOtros')
            self.params_out['porcentaje_merma_volatil'] = pri.get('porcentajeMermaVolatil')
            self.params_out['porcentaje_merma_secado'] = pri.get('porcentajeMermaSecado')
            self.params_out['peso_neto_merma_secado'] = pri.get('pesoNetoMermaSecado')
            self.params_out['porcentaje_merma_zarandeo'] = pri.get('pesoNetoMermaZarandeo')
            self.params_out['peso_neto_certificado'] = pri.get('pesoNetoCertificado')
            self.params_out['servicios_secado'] = pri.get('serviciosSecado')
            self.params_out['servicios_zarandeo'] = pri.get('serviciosZarandeo')
            self.params_out['servicios_otros'] = pri.get('serviciosOtros')
            self.params_out['servicios_forma_de_pago'] = pri.get('serviciosFormaDePago')
            # sub estructuras:
            self.params_out['ctgs'] = []
            self.params_out['det_muestra_analisis'] = []
            for ctg in pri.get("ctg", []):
                self.params_out['ctgs'].append({
                    'nro_ctg': ctg.get('nroCTG'),
                    'nro_carta_porte': ctg.get('nroCartaDePorte'),
                    'peso_neto_confirmado_definitivo': ctg.get('pesoNetoConfirmadoDefinitivo'),
                    'porcentaje_secado_humedad': ctg.get('porcentajeSecadoHumedad'),
                    'importe_secado': ctg.get('importeSecado'),
                    'peso_neto_merma_secado': ctg.get('pesoNetoMermaSecado'),
                    'importe_zarandeo': ctg.get('importeZarandeo'),
                    'peso_neto_merma_zarandeo': ctg.get('pesoNetoMermaZarandeo'),
                    'tarifa_zarandeo': ctg.get('tarifaZarandeo'),
                    })
            self.params_out['calidad'] = []
            for cal in [pri.get("calidad", {})]:
                self.params_out['calidad'].append({
                    'analisis_muestra': cal.get('analisisMuestra'),
                    'nro_boletin': cal.get('nroBoletin'),
                    'nro_act_depositario': cal.get('nroActDepositario'),
                    'cod_grado': cal.get('codGrado'),
                    'valor_grado': cal.get('valorGrado'),
                    'valor_contenido_proteico': cal.get('valorContProteico'),
                    'valor_factor': cal.get('valorFactor')
                    })
                for det in cal.get("detalleMuestraAnalisis", []):
                    self.params_out['det_muestra_analisis'].append({
                        'descripcion_rubro': det.get('descripcionRubro'),
                        'tipo_rubro': det.get('tipoRubro'),
                        'porcentaje': det.get('porcentaje'),
                        'valor': det.get('valor'),
                        })
        rt = ret.get('retiroTransferencia')
        if rt:
            self.params_out['nro_act_depositario'] = rt.get('nroActDepositario')
            self.params_out['cuit_receptor'] = rt.get('cuitReceptor')
            self.params_out['nro_carta_porte_a_utilizar'] = rt.get('nroCartaPorteAUtilizar')
            # sub estructuras:
            self.params_out['certificados'] = []
            for cert in rt.get("certificadoDeposito", []):
                self.params_out['certificados'].append({
                    'coe_certificado_deposito': cert.get('coeCertificadoDeposito'),
                    'peso_neto': cert.get('pesoNeto'),
                    })
        pre = ret.get('preexistente')
        if pre:
            self.params_out['nro_planta'] = pre.get('nroPlanta')
            self.params_out['tipo_certificado_deposito_preexistente'] = pre.get('tipoCertificadoDepositoPreexistente')
            self.params_out['nro_certificado_deposito_preexistente'] = pre.get('nroCertificadoDepositoPreexistente')
            self.params_out['cac_certificado_deposito_preexistente'] = pre.get('cacCertificadoDepositoPreexistente')
            self.params_out['fecha_emision_certificado_deposito_preexistente'] = pre.get('fechaEmisionCertificadoDepositoPreexistente')
            self.params_out['peso_neto'] = pre.get('pesoNeto')

    @inicializar_y_capturar_excepciones
    def InformarCalidadCertificacion(self, coe):
        "Informar calidad de un certificado (C1116A/RT)"
        
        # llamo al webservice:
        ret = self.client.cgInformarCalidad(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        coe=coe,
                        calidad=self.certificacion['primaria']['calidad'],
                        )

        # analizo la respusta
        ret = ret['oReturn']
        self.__analizar_errores(ret)
        self.AnalizarAutorizarCertificadoResp(ret)
        return True

    @inicializar_y_capturar_excepciones
    def AnularCertificacion(self, coe):
        "Anular liquidación activa"
        ret = self.client.cgSolicitarAnulacion(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        coe=coe,
                        )
        ret = ret['oReturn']
        self.__analizar_errores(ret)
        self.Estado = ret.get('estadoCertificado', "")
        return self.COE

    @inicializar_y_capturar_excepciones
    def AsociarLiquidacionAContrato(self, coe=None, nro_contrato=None, 
                                          cuit_comprador=None, 
                                          cuit_vendedor=None,
                                          cuit_corredor=None,
                                          cod_grano=None,
                                    **kwargs):
        "Asociar una Liquidación a un contrato"
        
        ret = self.client.asociarLiquidacionAContrato(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        coe=coe,
                        nroContrato=nro_contrato,
                        cuitComprador=cuit_comprador,
                        cuitVendedor=cuit_vendedor,
                        cuitCorredor=cuit_corredor,
                        codGrano=cod_grano,
                        )
        ret = ret['liquidacion']
        self.__analizar_errores(ret)
        if 'liquidacion' in ret:
            # analizo la respusta
            liq = ret['liquidacion']
            aut = ret['autorizacion']
            self.AnalizarLiquidacion(aut, liq)
        return True

    @inicializar_y_capturar_excepciones
    def ConsultarLiquidacionesPorContrato(self, nro_contrato=None, 
                                                cuit_comprador=None, 
                                                cuit_vendedor=None,
                                                cuit_corredor=None,
                                                cod_grano=None,
                                                **kwargs):
        "Obtener los COE de liquidaciones relacionadas a un contrato"
        ret = self.client.liquidacionPorContratoConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        nroContrato=nro_contrato,
                        cuitComprador=cuit_comprador,
                        cuitVendedor=cuit_vendedor,
                        cuitCorredor=cuit_corredor,
                        codGrano=cod_grano,
                        )
        ret = ret['liqPorContratoCons']
        self.__analizar_errores(ret)
        if 'coeRelacionados' in ret:
            # analizo la respuesta = [{'coe': "...."}]
            self.DatosLiquidacion = sorted(ret['coeRelacionados'])  
            # establezco el primer COE
            self.LeerDatosLiquidacion()
        return True
    
    @inicializar_y_capturar_excepciones
    def ConsultarLiquidacion(self, pto_emision=None, nro_orden=None, coe=None):
        "Consulta una liquidación por No de orden"
        if coe:
            ret = self.client.liquidacionXCoeConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        coe=coe,
                        )
        else:
            ret = self.client.liquidacionXNroOrdenConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        ptoEmision=pto_emision,
                        nroOrden=nro_orden,
                        )
        ret = ret['liqConsReturn']
        self.__analizar_errores(ret)
        if 'liquidacion' in ret:
            aut = ret['autorizacion']
            liq = ret['liquidacion']
            self.AnalizarLiquidacion(aut, liq)
        return True

    @inicializar_y_capturar_excepciones
    def ConsultarLiquidacionSecundaria(self, pto_emision=None, nro_orden=None, coe=None):
        "Consulta una liquidación sequndaria por No de orden o coe"
        if coe:
            ret = self.client.lsgConsultarXCoe(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        coe=coe,
                        )
        else:
            ret = self.client.lsgConsultarXNroOrden(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        ptoEmision=pto_emision,
                        nroOrden=nro_orden,
                        )
        ret = ret['oReturn']
        self.__analizar_errores(ret)
        if 'liquidacion' in ret:
            aut = ret['autorizacion']
            liq = ret['liquidacion']
            self.AnalizarLiquidacion(aut, liq)
        return True

    @inicializar_y_capturar_excepciones
    def ConsultarCertificacion(self, pto_emision=None, nro_orden=None, coe=None):
        "Consulta una certificacion por No de orden o COE"
        if coe:
            ret = self.client.cgConsultarXCoe(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        coe=coe,
                        )
        else:
            ret = self.client.cgConsultarXNroOrden(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        ptoEmision=pto_emision,
                        nroOrden=nro_orden,
                        )
        ret = ret['oReturn']
        self.__analizar_errores(ret)
        if 'autorizacion' in ret:
            self.AnalizarAutorizarCertificadoResp(ret)
        return True

    @inicializar_y_capturar_excepciones
    def ConsultarAjuste(self, pto_emision=None, nro_orden=None, nro_contrato=None):
        "Consulta un ajuste de liquidación por No de orden o numero de contrato"
        if nro_contrato:
            ret = self.client.ajustePorContratoConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        nroContrato=nro_contrato,
                        )
            ret = ret['ajusteContratoReturn']
        else:
            ret = self.client.ajusteXNroOrdenConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        ptoEmision=pto_emision,
                        nroOrden=nro_orden,
                        )
            ret = ret['ajusteXNroOrdenConsReturn']
        self.__analizar_errores(ret)
        if 'ajusteUnificado' in ret:
            aut = ret['ajusteUnificado']
            self.AnalizarAjuste(aut)
        return True

    @inicializar_y_capturar_excepciones
    def ConsultarUltNroOrden(self, pto_emision=1):
        "Consulta el último No de orden registrado"
        ret = self.client.liquidacionUltimoNroOrdenConsultar(
                    auth={
                        'token': self.Token, 'sign': self.Sign,
                        'cuit': self.Cuit, },
                    ptoEmision=pto_emision,
                    )
        ret = ret['liqUltNroOrdenReturn']
        self.__analizar_errores(ret)
        self.NroOrden = ret['nroOrden']
        return True

    @inicializar_y_capturar_excepciones
    def ConsultarLiquidacionSecundariaUltNroOrden(self, pto_emision=1):
        "Consulta el último No de orden registrado para LSG"
        ret = self.client.lsgConsultarUltimoNroOrden(
                    auth={
                        'token': self.Token, 'sign': self.Sign,
                        'cuit': self.Cuit, },
                    ptoEmision=pto_emision,
                    )
        ret = ret['liqUltNroOrdenReturn']
        self.__analizar_errores(ret)
        self.NroOrden = ret['nroOrden']
        return True

    @inicializar_y_capturar_excepciones
    def ConsultarCertificacionUltNroOrden(self, pto_emision=1):
        "Consulta el último No de orden registrado para CG"
        ret = self.client.cgConsultarUltimoNroOrden(
                    auth={
                        'token': self.Token, 'sign': self.Sign,
                        'cuit': self.Cuit, },
                    ptoEmision=pto_emision,
                    )
        ret = ret['liqUltNroOrdenReturn']
        self.__analizar_errores(ret)
        self.NroOrden = ret['nroOrden']
        return True

    @inicializar_y_capturar_excepciones
    def LeerDatosLiquidacion(self, pop=True):
        "Recorro los datos devueltos y devuelvo el primero si existe"
        
        if self.DatosLiquidacion:
            # extraigo el primer item
            if pop:
                datos_liq = self.DatosLiquidacion.pop(0)
            else:
                datos_liq = self.DatosLiquidacion[0]
            self.COE = str(datos_liq['coe'])
            self.Estado = unicode(datos_liq.get('estado', ""))
            return self.COE
        else:
            return ""

    @inicializar_y_capturar_excepciones
    def AnularLiquidacion(self, coe):
        "Anular liquidación activa"
        ret = self.client.liquidacionAnular(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        coe=coe,
                        )
        ret = ret['anulacionReturn']
        self.__analizar_errores(ret)
        self.Resultado = ret['resultado']
        return self.COE
    
    @inicializar_y_capturar_excepciones
    def AnularLiquidacionSecundaria(self, coe):
        "Anular liquidación secundaria activa"
        ret = self.client.lsgAnular(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        coe=coe,
                        )
        ret = ret['anulacionReturn']
        self.__analizar_errores(ret)
        self.Resultado = ret['resultado']
        return self.COE
        
    def ConsultarCampanias(self, sep="||"):
        ret = self.client.campaniasConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                            )['campaniaReturn']
        self.__analizar_errores(ret)
        array = ret.get('campanias', [])
        return [("%s %%s %s %%s %s" % (sep, sep, sep)) %
                    (it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
               for it in array]

    def ConsultarTipoGrano(self, sep="||"):
        ret = self.client.tipoGranoConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                            )['tipoGranoReturn']
        self.__analizar_errores(ret)
        array = ret.get('granos', [])
        if sep is None:
            return dict([(it['codigoDescripcion']['codigo'], 
                          it['codigoDescripcion']['descripcion']) 
                         for it in array])
        else:
            return [("%s %%s %s %%s %s" % (sep, sep, sep)) %
                    (it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
               for it in array]

    def ConsultarCodigoGradoReferencia(self, sep="||"):
        "Consulta de Grados según Grano."
        ret = self.client.codigoGradoReferenciaConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                            )['gradoRefReturn']
        self.__analizar_errores(ret)
        array = ret.get('gradosRef', [])
        if sep is None:
            return dict([(it['codigoDescripcion']['codigo'], 
                          it['codigoDescripcion']['descripcion']) 
                           for it in array])
        else:
            return [("%s %%s %s %%s %s" % (sep, sep, sep)) %
                    (it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
               for it in array]

    def ConsultarGradoEntregadoXTipoGrano(self, cod_grano, sep="||"):
        "Consulta de Grado y Valor según Grano Entregado."
        ret = self.client.codigoGradoEntregadoXTipoGranoConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        codGrano=cod_grano,
                            )['gradoEntReturn']
        self.__analizar_errores(ret)
        array = ret.get('gradoEnt', [])
        if sep is None:
            return dict([(it['gradoEnt']['codigoDescripcion']['codigo'],
                          it['gradoEnt']['valor'])
                         for it in array])
        else:
            return [("%s %%s %s %%s %s %%s %s" % (sep, sep, sep, sep)) %
                    (it['gradoEnt']['codigoDescripcion']['codigo'], 
                     it['gradoEnt']['codigoDescripcion']['descripcion'],
                     it['gradoEnt']['valor'],
                     ) 
               for it in array]

    def ConsultarTipoCertificadoDeposito(self, sep="||"):
        "Consulta de tipos de Certificados de Depósito"
        ret = self.client.tipoCertificadoDepositoConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                            )['tipoCertDepReturn']
        self.__analizar_errores(ret)
        array = ret.get('tiposCertDep', [])
        return [("%s %%s %s %%s %s" % (sep, sep, sep)) %
                    (it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
               for it in array]

    def ConsultarTipoDeduccion(self, sep="||"):
        "Consulta de tipos de Deducciones"
        ret = self.client.tipoDeduccionConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                            )['tipoDeduccionReturn']
        self.__analizar_errores(ret)
        array = ret.get('tiposDeduccion', [])
        return [("%s %%s %s %%s %s" % (sep, sep, sep)) %
                    (it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
               for it in array]

    def ConsultarTipoRetencion(self, sep="||"):
        "Consulta de tipos de Retenciones."
        ret = self.client.tipoRetencionConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                            )['tipoRetencionReturn']
        self.__analizar_errores(ret)
        array = ret.get('tiposRetencion', [])
        return [("%s %%s %s %%s %s" % (sep, sep, sep)) %
                    (it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
               for it in array]

    def ConsultarPuerto(self, sep="||"):
        "Consulta de Puertos habilitados"
        ret = self.client.puertoConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                            )['puertoReturn']
        self.__analizar_errores(ret)
        array = ret.get('puertos', [])
        return [("%s %%s %s %%s %s" % (sep, sep, sep)) %
                    (it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
               for it in array]

    def ConsultarTipoActividad(self, sep="||"):
        "Consulta de Tipos de Actividad."
        ret = self.client.tipoActividadConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                            )['tipoActividadReturn']
        self.__analizar_errores(ret)
        array = ret.get('tiposActividad', [])
        return [("%s %%s %s %%s %s" % (sep, sep, sep)) %
                    (it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
               for it in array]

    def ConsultarTipoActividadRepresentado(self, sep="||"):
        "Consulta de Tipos de Actividad inscripta en el RUOCA."
        try:
            ret = self.client.tipoActividadRepresentadoConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                            )['tipoActividadReturn']
            self.__analizar_errores(ret)
            array = ret.get('tiposActividad', [])
            self.Excepcion = self.Traceback = ""
            return [("%s %%s %s %%s %s" % (sep, sep, sep)) %
                    (it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
               for it in array]
        except Exception:
            ex = utils.exception_info()
            self.Excepcion = ex['msg']
            self.Traceback = ex['tb']
            if sep:
                return ["ERROR"]

    def ConsultarProvincias(self, sep="||"):
        "Consulta las provincias habilitadas"
        ret = self.client.provinciasConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                            )['provinciasReturn']
        self.__analizar_errores(ret)
        array = ret.get('provincias', [])
        if sep is None:
            return dict([(int(it['codigoDescripcion']['codigo']), 
                              it['codigoDescripcion']['descripcion']) 
                         for it in array])
        else:
            return [("%s %%s %s %%s %s" % (sep, sep, sep)) %
                    (it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
               for it in array]

    def ConsultarLocalidadesPorProvincia(self, codigo_provincia, sep="||"):
        ret = self.client.localidadXProvinciaConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                        codProvincia=codigo_provincia,
                        )['localidadesReturn']
        self.__analizar_errores(ret)
        array = ret.get('localidades', [])
        if sep is None:
            return dict([(str(it['codigoDescripcion']['codigo']), 
                          it['codigoDescripcion']['descripcion']) 
                         for it in array])
        else:
            return [("%s %%s %s %%s %s" % (sep, sep, sep)) % 
                    (it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
               for it in array]

    def BuscarLocalidades(self, cod_prov, cod_localidad=None, consultar=True):
        "Devuelve la localidad o la consulta en AFIP (uso interno)"
        # si no se especifíca cod_localidad, es util para reconstruir la cache
        import wslpg_datos as datos
        if not str(cod_localidad) in datos.LOCALIDADES and consultar:
            d = self.ConsultarLocalidadesPorProvincia(cod_prov, sep=None)
            try:
                # actualizar el diccionario persistente (shelve)
                datos.LOCALIDADES.update(d)
            except Exception, e:
                print "EXCEPCION CAPTURADA", e
                # capturo errores por permisos (o por concurrencia)
                datos.LOCALIDADES = d
        return datos.LOCALIDADES.get(str(cod_localidad), "")

    def ConsultarTiposOperacion(self, sep="||"):
        "Consulta tipo de Operación por Actividad."
        ops = []
        ret = self.client.tipoActividadConsultar(
                        auth={
                            'token': self.Token, 'sign': self.Sign,
                            'cuit': self.Cuit, },
                            )['tipoActividadReturn']
        self.__analizar_errores(ret)
        for it_act in ret.get('tiposActividad', []):

            ret = self.client.tipoOperacionXActividadConsultar(
                            auth={
                                'token': self.Token, 'sign': self.Sign,
                                'cuit': self.Cuit, },
                            nroActLiquida=it_act['codigoDescripcion']['codigo'],
                            )['tipoOperacionReturn']
            self.__analizar_errores(ret)
            array = ret.get('tiposOperacion', [])
            if sep:
                ops.extend([("%s %%s %s %%s %s %%s %s" % (sep, sep, sep, sep)) % 
                    (it_act['codigoDescripcion']['codigo'],
                     it['codigoDescripcion']['codigo'], 
                     it['codigoDescripcion']['descripcion']) 
                   for it in array])
            else:
                ops.extend([(it_act['codigoDescripcion']['codigo'],
                             it['codigoDescripcion']['codigo'], 
                             it['codigoDescripcion']['descripcion']) 
                           for it in array])
        return ops


    # Funciones para generar PDF:


    def CargarFormatoPDF(self, archivo="liquidacion_form_c1116b_wslpg.csv"):
        "Cargo el formato de campos a generar desde una planilla CSV"

        # si no encuentro archivo, lo busco en el directorio predeterminado:
        if not os.path.exists(archivo):
            archivo = os.path.join(self.InstallDir, "plantillas", os.path.basename(archivo))

        if DEBUG: print "abriendo archivo ", archivo
        # inicializo la lista de los elementos:
        self.elements = []
        for lno, linea in enumerate(open(archivo.encode('latin1')).readlines()):
            if DEBUG: print "procesando linea ", lno, linea
            args = []
            for i,v in enumerate(linea.split(";")):
                if not v.startswith("'"): 
                    v = v.replace(",",".")
                else:
                    v = v#.decode('latin1')
                if v.strip()=='':
                    v = None
                else:
                    v = eval(v.strip())
                args.append(v)

            # corrijo path relativo para las imágenes:
            if args[1] == 'I':
                if not os.path.exists(args[14]):
                    args[14] = os.path.join(self.InstallDir, "plantillas", os.path.basename(args[14]))
                if DEBUG: print "NUEVO PATH:", args[14]          

            self.AgregarCampoPDF(*args)

        self.AgregarCampoPDF("anulado", 'T', 150, 250, 0, 0, 
              size=70, rotate=45, foreground=0x808080, 
              priority=-1)

        if HOMO:
            self.AgregarCampoPDF("homo", 'T', 100, 250, 0, 0,
                              size=70, rotate=45, foreground=0x808080, 
                              priority=-1)

        
        # cargo los elementos en la plantilla
        self.template.load_elements(self.elements)
        
        return True        


    def AgregarCampoPDF(self, nombre, tipo, x1, y1, x2, y2, 
                           font="Arial", size=12,
                           bold=False, italic=False, underline=False, 
                           foreground= 0x000000, background=0xFFFFFF,
                           align="L", text="", priority=0, **kwargs):
        "Agrego un campo a la plantilla"
        # convierto colores de string (en hexadecimal)
        if isinstance(foreground, basestring): foreground = int(foreground, 16)
        if isinstance(background, basestring): background = int(background, 16)
        if isinstance(text, unicode): text = text.encode("latin1")
        field = {
                'name': nombre, 
                'type': tipo, 
                'x1': x1, 'y1': y1, 'x2': x2, 'y2': y2, 
                'font': font, 'size': size,
                'bold': bold, 'italic': italic, 'underline': underline, 
                'foreground': foreground, 'background': background,
                'align': align, 'text': text, 'priority': priority}
        field.update(kwargs)
        self.elements.append(field)
        return True


    def CrearPlantillaPDF(self, papel="A4", orientacion="portrait"):
        "Iniciar la creación del archivo PDF"
        
        # genero el renderizador con propiedades del PDF
        t = Template(
                 format=papel, orientation=orientacion,
                 title="F 1116 B/C %s" % (self.NroOrden),
                 author="CUIT %s" % self.Cuit,
                 subject="COE %s" % self.params_out.get('coe'),
                 keywords="AFIP Liquidacion Electronica Primaria de Granos", 
                 creator='wslpg.py %s (http://www.PyAfipWs.com.ar)' % __version__,)
        self.template = t
        return True
        

    def AgregarDatoPDF(self, campo, valor, pagina='T'):
        "Agrego un dato a la factura (internamente)"
        self.datos[campo] = valor
        return True

    def ProcesarPlantillaPDF(self, num_copias=1, lineas_max=24, qty_pos='izq', 
                                   clave=''):
        "Generar el PDF según la factura creada y plantilla cargada"
        try:
            f = self.template
            liq = self.params_out
            # actualizo los campos según la clave (ajuste debitos / creditos)
            if clave and clave in liq:
                liq = liq.copy()
                liq.update(liq[clave])  # unificar con AnalizarAjusteCredito/Debito

            if HOMO:
                self.AgregarDatoPDF("homo", u"HOMOLOGACIÓN")

            copias = {1: 'Original', 2: 'Duplicado', 3: 'Triplicado', 
                      4: 'Cuadruplicado', 5: 'Quintuplicado'}
                        
            # convierto el formato de intercambio para representar los valores:        
            fmt_encabezado = dict([(v[0], v[1:]) for v in ENCABEZADO])
            fmt_deduccion = dict([(v[0], v[1:]) for v in DEDUCCION])
            fmt_retencion = dict([(v[0], v[1:]) for v in RETENCION])
            
            def formatear(campo, valor, formato):
                "Convertir el valor a una cadena correctamente s/ formato ($ % ...)"
                if campo in formato and v is not None:
                    fmt = formato[campo]
                    if fmt[1] == N:
                        if 'cuit' in campo:
                            c = str(valor)
                            if len(c) == 11:
                                valor = "%s-%s-%s" % (c[0:2], c[2:10], c[10:])
                            else:
                                valor = ""
                        elif 'peso' in campo:
                            valor = "%s Kg" % valor
                        elif valor is not None and valor != "":
                            valor = "%d" % int(valor)
                        else:
                            valor = ""
                    elif fmt[1] == I:
                        valor = ("%%0.%df" % fmt[2]) % valor
                        if 'alic' in campo or 'comision' in campo:
                            valor = valor + " %"
                        elif 'factor' in campo or 'cont' in campo or 'cant' in campo:
                            pass
                        else:
                            valor = "$ " + valor
                    elif 'fecha' in campo:
                        d = valor
                        if isinstance(d, (datetime.date, datetime.datetime)):
                            valor = d.strftime("%d/%m/%Y")
                        else:
                            valor = "%s/%s/%s" % (d[8:10], d[5:7], d[0:4])
                return valor

            def buscar_localidad_provincia(cod_prov, cod_localidad): 
                "obtener la descripción de la provincia/localidad (usar cache)"
                cod_prov = int(cod_prov)
                cod_localidad = str(cod_localidad)
                provincia = datos.PROVINCIAS[cod_prov]
                localidad = self.BuscarLocalidades(cod_prov, cod_localidad)
                return localidad, provincia                

            # divido los datos adicionales (debe haber renglones 1 al 9):
            if liq.get('datos_adicionales') and f.has_key('datos_adicionales1'):
                d = liq.get('datos_adicionales')
                for i, ds in enumerate(f.split_multicell(d, 'datos_adicionales1')):
                    liq['datos_adicionales%s' % (i + 1)] = ds
                
            for copia in range(1, num_copias+1):
                
                # completo campos y hojas
                f.add_page()                   
                f.set('copia', copias.get(copia, "Adicional %s" % copia))
                
                f.set('anulado', {'AC': '', '': 'SIN ESTADO',
                                  'AN': "ANULADO"}.get(liq['estado'], "ERROR"))

                try:
                    cod_tipo_ajuste = int(liq["cod_tipo_ajuste"] or '0')
                except: 
                    cod_tipo_ajuste = None
                f.set('tipo_ajuste', {3: u'Liquidación de Débito', 
                                      4: u'Liquidación de Crédito',
                                      }.get(cod_tipo_ajuste, ''))

                # limpio datos del corredor si no corresponden:
                if liq.get('actua_corredor', 'N') == 'N':
                    if liq.get('cuit_corredor', None) == 0:
                        del liq['cuit_corredor']
                    
                # establezco campos según tabla encabezado:
                for k,v in liq.items():
                    v = formatear(k, v, fmt_encabezado)
                    if isinstance(v, (basestring, int, long, float)):
                        f.set(k, v)
                    elif isinstance(v, decimal.Decimal):
                        f.set(k, str(v))
                    elif isinstance(v, datetime.datetime):
                        f.set(k, str(v))

                import wslpg_datos as datos
                
                campania = int(liq.get('campania_ppal') or 0)
                f.set("campania_ppal", datos.CAMPANIAS.get(campania, campania))
                f.set("tipo_operacion", datos.TIPOS_OP.get(int(liq.get('cod_tipo_operacion') or 0), ""))
                f.set("actividad", datos.ACTIVIDADES.get(int(liq.get('nro_act_comprador') or 0), ""))
                if 'cod_grano' in liq and liq['cod_grano']:
                    cod_grano = int(liq['cod_grano'])
                else:
                    cod_grano = int(self.datos.get('cod_grano') or 0)
                f.set("grano", datos.GRANOS.get(cod_grano, ""))
                cod_puerto = int(liq.get('cod_puerto', self.datos.get('cod_puerto')) or 0)
                if cod_puerto in datos.PUERTOS:
                    f.set("des_puerto_localidad", datos.PUERTOS[cod_puerto])

                cod_grado_ref = liq.get('cod_grado_ref', self.datos.get('cod_grado_ref')) or ""
                if cod_grado_ref in datos.GRADOS_REF:
                    f.set("des_grado_ref", datos.GRADOS_REF[cod_grado_ref])
                else:
                    f.set("des_grado_ref", cod_grado_ref)
                cod_grado_ent = liq.get('cod_grado_ent', self.datos.get('cod_grado_ent'))
                if 'val_grado_ent' in liq and int(liq.get('val_grado_ent') or 0):
                    val_grado_ent = liq['val_grado_ent']
                elif 'val_grado_ent' in self.datos:
                    val_grado_ent = self.datos.get('val_grado_ent')
                elif cod_grano in datos.GRADO_ENT_VALOR: 
                    valores = datos.GRADO_ENT_VALOR[cod_grano]
                    if cod_grado_ent in valores:
                        val_grado_ent = valores[cod_grado_ent]
                    else:
                        val_grado_ent = ""
                else:
                    val_grado_ent = ""
                f.set("valor_grado_ent", "%s %s" % (cod_grado_ent or "", val_grado_ent or ""))
                f.set("cont_proteico", liq.get('cont_proteico', self.datos.get('cont_proteico', "")))
                
                if liq.get('certificados'):
                    # uso la procedencia del certificado de depósito 
                    cert = liq['certificados'][0]
                    localidad, provincia = buscar_localidad_provincia(
                        cert['cod_prov_procedencia'],
                        cert['cod_localidad_procedencia'])
                elif liq.get('cod_prov_procedencia_sin_certificado'):
                    localidad, provincia = buscar_localidad_provincia(
                        liq['cod_prov_procedencia_sin_certificado'], 
                        liq['cod_localidad_procedencia_sin_certificado'])
                else:
                    localidad, provincia = "", ""
    
                f.set("procedencia", "%s - %s" % (localidad, provincia))
                
                # si no se especifíca, uso la procedencia para el lugar
                if not self.datos.get('lugar_y_fecha'):
                    localidad, provincia = buscar_localidad_provincia(
                        liq['cod_prov_procedencia'], 
                        liq['cod_localidad_procedencia'])
                    lugar = "%s - %s " % (localidad, provincia)
                    fecha = datetime.datetime.today().strftime("%d/%m/%Y")
                    f.set("lugar_y_fecha", "%s, %s" % (fecha, lugar))
                    if 'lugar_y_fecha' in self.datos:
                        del self.datos['lugar_y_fecha']

                if HOMO:
                    homo = "(pruebas)"
                else:
                    homo = ""
                
                if int(liq['cod_tipo_operacion'] or 0) == 1: 
                    f.set("comprador.L", "COMPRADOR:")
                    f.set("vendedor.L", "VENDEDOR:")
                    f.set("formulario", u"Form. Electrónico 1116 B %s" % homo)
                else:
                    f.set("comprador.L", "MANDATARIO/CONSIGNATARIO:")
                    f.set("vendedor.L", "MANDANTE/COMITENTE:")
                    f.set("formulario", u"Form. Electrónico 1116 C %s" % homo)
                
                if int(liq.get("coe_ajustado") or 0) or int(liq.get("nro_contrato") or 0):
                    f.set("formulario", u"Ajuste Unificado %s" % homo)

                certs = []
                for cert in liq.get('certificados', []):
                    certs.append(u"%s Nº %s" % (
                        datos.TIPO_CERT_DEP[int(cert['tipo_certificado_deposito'])],
                        cert['nro_certificado_deposito']))
                f.set("certificados_deposito", ', '.join(certs))

                for i, deduccion in enumerate(liq.get('deducciones', [])):
                    for k, v in deduccion.items():
                        v = formatear(k, v, fmt_deduccion)
                        f.set("deducciones_%s_%02d" % (k, i + 1), v)

                for i, retencion in enumerate(liq.get('retenciones', [])):
                    for k, v in retencion.items():
                        v = formatear(k, v, fmt_retencion)
                        f.set("retenciones_%s_%02d" % (k, i + 1), v)
                    if retencion['importe_certificado_retencion']:
                        d = retencion['fecha_certificado_retencion']
                        f.set('retenciones_cert_retencion_%02d' % (i + 1),
                            "%s $ %0.2f %s" % (
                                retencion['nro_certificado_retencion'] or '',
                                retencion['importe_certificado_retencion'],
                                "%s/%s/%s" % (d[8:10], d[5:7], d[2:4]), 
                            ))

                # cargo campos adicionales ([PDF] en .ini y AgregarDatoPDF)
                for k,v in self.datos.items():
                    f.set(k, v)
                
                # Ajustes:
                
                if clave:
                    f.set('subtipo_ajuste', {'ajuste_debito': u'AJUSTE DÉBITO',
                           'ajuste_credito': u'AJUSTE CRÉDITO'}[clave])
                
                if int(liq.get('coe_ajustado') or 0):
                    f.set("leyenda_coe_nro", "COE Ajustado:")
                    f.set("nro_contrato_o_coe_ajustado", liq['coe_ajustado'])
                    f.set("coe_relacionados.L", "")
                    f.set("coe_relacionados", "")
                elif liq.get('nro_contrato'):
                    f.set("leyenda_coe_nro", "Contrato Ajustado:")
                    f.set("nro_contrato_o_coe_ajustado", liq['nro_contrato'])
                    ##f.set("coe_relacionados", TODO)
                    
            return True
        except Exception, e:
            ex = utils.exception_info()
            try:
                f.set('anulado', "%(name)s:%(lineno)s" % ex)
            except:
                pass
            self.Excepcion = ex['msg']
            self.Traceback = ex['tb']
            if DEBUG:
                print self.Excepcion
                print self.Traceback
            return False

    def GenerarPDF(self, archivo="", dest="F"):
        "Generar archivo de salida en formato PDF"
        try:
            self.template.render(archivo, dest=dest)
            return True
        except Exception, e:
            self.Excepcion = str(e)
            return False

    def MostrarPDF(self, archivo, imprimir=False):
        try:
            if sys.platform=="linux2":
                os.system("evince ""%s""" % archivo)
            else:
                operation = imprimir and "print" or ""
                os.startfile(archivo, operation)
            return True
        except Exception, e:
            self.Excepcion = str(e)
            return False

def escribir_archivo(dic, nombre_archivo, agrega=True):
    archivo = open(nombre_archivo, agrega and "a" or "w")
    if '--json' in sys.argv:
        json.dump(dic, archivo, sort_keys=True, indent=4)
    elif '--dbf' in sys.argv:
        formatos = [('Encabezado', ENCABEZADO, [dic]), 
                    ('Certificacion', CERTIFICACION, [dic]),
                    ('Certificado', CERTIFICADO, dic.get('certificados', [])), 
                    ('Retencion', RETENCION, dic.get('retenciones', [])), 
                    ('Deduccion', DEDUCCION, dic.get('deducciones', [])),
                    ('Percepcion', PERCEPCION, dic.get('percepciones', [])),
                    ('Opcional', OPCIONAL, dic.get('opcionales', [])),
                    ('AjusteCredito', AJUSTE, dic.get('ajuste_credito', [])),
                    ('AjusteDebito', AJUSTE, dic.get('ajuste_debito', [])),
                    ('CTG', CTG, dic.get('ctgs', [])),
                    ('DetMuestraAnalisis', DET_MUESTRA_ANALISIS, dic.get('det_muestra_analisis', [])),
                    ('Calidad', CALIDAD, dic.get('calidad', [])),
                    ('Dato', DATO, dic.get('datos', [])),
                    ('Error', ERROR, dic.get('errores', [])),
                    ]
        guardar_dbf(formatos, agrega, conf_dbf)
    else:
        dic['tipo_reg'] = 0
        archivo.write(escribir(dic, ENCABEZADO))
        dic['tipo_reg'] = 7
        archivo.write(escribir(dic, CERTIFICACION))
        if 'certificados' in dic:
            for it in dic['certificados']:
                it['tipo_reg'] = 1
                archivo.write(escribir(it, CERTIFICADO))
        if 'retenciones' in dic:
            for it in dic['retenciones']:
                it['tipo_reg'] = 2
                archivo.write(escribir(it, RETENCION))
        if 'deducciones' in dic:
            for it in dic['deducciones']:
                it['tipo_reg'] = 3
                archivo.write(escribir(it, DEDUCCION))
        if 'percepciones' in dic:
            for it in dic['percepciones']:
                it['tipo_reg'] = 'P'
                archivo.write(escribir(it, PERCEPCION))
        if 'opcionales' in dic:
            for it in dic['opcionales']:
                it['tipo_reg'] = 'O'
                archivo.write(escribir(it, OPCIONAL))
        if 'ajuste_debito' in dic:
            dic['ajuste_debito']['tipo_reg'] = 4
            archivo.write(escribir(dic['ajuste_debito'], AJUSTE))
            for it in dic['ajuste_debito'].get('retenciones', []):
                it['tipo_reg'] = 2
                archivo.write(escribir(it, RETENCION))
            for it in dic['ajuste_debito'].get('deducciones', []):
                it['tipo_reg'] = 3
                archivo.write(escribir(it, DEDUCCION))
        if 'ajuste_credito' in dic:
            dic['ajuste_credito']['tipo_reg'] = 5
            archivo.write(escribir(dic['ajuste_credito'], AJUSTE))
            for it in dic['ajuste_credito'].get('retenciones', []):
                it['tipo_reg'] = 2
                archivo.write(escribir(it, RETENCION))
            for it in dic['ajuste_credito'].get('deducciones', []):
                it['tipo_reg'] = 3
                archivo.write(escribir(it, DEDUCCION))
        if 'ctgs' in dic:
            for it in dic['ctgs']:
                it['tipo_reg'] = 'C'
                archivo.write(escribir(it, CTG))
        if 'det_muestra_analisis' in dic:
            for it in dic['det_muestra_analisis']:
                it['tipo_reg'] = 'D'
                archivo.write(escribir(it, DET_MUESTRA_ANALISIS))
        if 'calidad' in dic:
            for it in dic['calidad']:
                it['tipo_reg'] = 'Q'
                archivo.write(escribir(it, CALIDAD))
        if 'datos' in dic:
            for it in dic['datos']:
                it['tipo_reg'] = 9
                archivo.write(escribir(it, DATO))
        if 'errores' in dic:
            for it in dic['errores']:
                it['tipo_reg'] = 'R'
                archivo.write(escribir(it, ERROR))
    archivo.close()

def leer_archivo(nombre_archivo):
    archivo = open(nombre_archivo, "r")
    if '--json' in sys.argv:
        dic = json.load(archivo)
    elif '--dbf' in sys.argv:
        dic = {'retenciones': [], 'deducciones': [], 'certificados': [], 
               'percepciones': [], 'opcionales': [],
               'datos': [], 'ajuste_credito': [], 'ajuste_debito': [], 
               'ctgs': [], 'det_muestra_analisis': [], 'calidad': [],
              }
        formatos = [('Encabezado', ENCABEZADO, dic),
                    ('Certificacion', CERTIFICACION, dic),
                    ('Certificado', CERTIFICADO, dic['certificados']), 
                    ('Retencio', RETENCION, dic['retenciones']), 
                    ('Deduccion', DEDUCCION, dic['deducciones']),
                    ('Percepcion', PERCEPCION, dic['percepciones']),
                    ('Opcional', OPCIONAL, dic['opcionales']),
                    ('AjusteCredito', AJUSTE, dic['ajuste_credito']),
                    ('AjusteDebito', AJUSTE, dic['ajuste_debito']),
                    ('CTG', CTG, dic.get('ctgs', [])),
                    ('DetMuestraAnalisis', DET_MUESTRA_ANALISIS, dic.get('det_muestra_analisis', [])),
                    ('Calidad', CALIDAD, dic.get('calidad', [])),
                    ('Dato', DATO, dic['datos']),
                    ]
        leer_dbf(formatos, conf_dbf)
    else:
        dic = {'retenciones': [], 'deducciones': [], 'certificados': [], 
               'percepciones': [], 'opcionales': [],
               'datos': [], 'ajuste_credito': {}, 'ajuste_debito': {}, 
               'ctgs': [], 'det_muestra_analisis': [], 'calidad': [],
               }
        for linea in archivo:
            if str(linea[0])=='0':
                # encabezado base de las liquidaciones
                d = leer(linea, ENCABEZADO)
                if d['reservado1']:
                    print "ADVERTENCIA: USAR datos adicionales (nueva posición)" 
                    d['datos_adicionales'] = d['reservado1'] 
                dic.update(d)
                # referenciar la liquidación para agregar ret. / ded.:
                liq = dic
            elif str(linea[0])=='1':
                dic['certificados'].append(leer(linea, CERTIFICADO))
            elif str(linea[0])=='2':
                liq['retenciones'].append(leer(linea, RETENCION))
            elif str(linea[0])=='3':
                d = leer(linea, DEDUCCION)
                # ajustes por cambios en afip (compatibilidad hacia atras):
                if d['reservado1']:
                    print "ADVERTENCIA: USAR precio_pkg_diario!" 
                    d['precio_pkg_diario'] = d['reservado1'] 
                liq['deducciones'].append(d)
            elif str(linea[0])=='P':
                liq['percepciones'].append(leer(linea, PERCEPCION))
            elif str(linea[0])=='O':
                liq['opcionales'].append(leer(linea, OPCIONAL))
            elif str(linea[0])=='4':
                liq = leer(linea, AJUSTE)
                liq.update({'retenciones': [], 'deducciones': [], 'datos': []})
                dic['ajuste_debito'] = liq
            elif str(linea[0])=='5':
                liq = leer(linea, AJUSTE)
                liq.update({'retenciones': [], 'deducciones': [], 'datos': []})
                dic['ajuste_credito'] = liq
            elif str(linea[0])=='7':
                # actualizo con cabecera para certificaciones de granos:
                d = leer(linea, CERTIFICACION)
                dic.update(d)
            elif str(linea[0])=='C':
                dic['ctgs'].append(leer(linea, CTG))
            elif str(linea[0])=='D':
                dic['det_muestra_analisis'].append(leer(linea, DET_MUESTRA_ANALISIS))
            elif str(linea[0])=='Q':
                dic['calidad'].append(leer(linea, CALIDAD))
            elif str(linea[0])=='9':
                dic['datos'].append(leer(linea, DATO))
            else:
                print "Tipo de registro incorrecto:", linea[0]
    archivo.close()
                
    if not 'nro_orden' in dic:
        raise RuntimeError("Archivo de entrada invalido, revise campos y lineas en blanco")

    if DEBUG:
        import pprint; pprint.pprint(dic)
    return dic
    

# busco el directorio de instalación (global para que no cambie si usan otra dll)
INSTALL_DIR = WSLPG.InstallDir = get_install_dir()


if __name__ == '__main__':
    if '--ayuda' in sys.argv:
        print LICENCIA
        print AYUDA
        sys.exit(0)
    if '--formato' in sys.argv:
        print "Formato:"
        for msg, formato in [('Encabezado', ENCABEZADO), 
                             ('Certificado', CERTIFICADO), 
                             ('Retencion', RETENCION), 
                             ('Deduccion', DEDUCCION), 
                             ('Percepcion', PERCEPCION),
                             ('Opcional', OPCIONAL), 
                             ('Ajuste', AJUSTE),
                             ('Certificacion', CERTIFICACION),
                             ('CTG', CTG),
                             ('Det. Muestra Analisis', DET_MUESTRA_ANALISIS),
                             ('Calidad', CALIDAD),
                             ('Evento', EVENTO), ('Error', ERROR), 
                             ('Dato', DATO)]:
            comienzo = 1
            print "=== %s ===" % msg
            for fmt in formato:
                clave, longitud, tipo = fmt[0:3]
                dec = len(fmt)>3 and fmt[3] or (tipo=='I' and '2' or '')
                print " * Campo: %-20s Posición: %3d Longitud: %4d Tipo: %s Decimales: %s" % (
                    clave, comienzo, longitud, tipo, dec)
                comienzo += longitud
        sys.exit(0)

    if "--register" in sys.argv or "--unregister" in sys.argv:
        import win32com.server.register
        win32com.server.register.UseCommandLine(WSLPG)
        sys.exit(0)

    import csv
    from ConfigParser import SafeConfigParser

    from wsaa import WSAA

    try:
    
        if "--version" in sys.argv:
            print "Versión: ", __version__

        if len(sys.argv)>1 and sys.argv[1].endswith(".ini"):
            CONFIG_FILE = sys.argv[1]
            print "Usando configuracion:", CONFIG_FILE
         
        config = SafeConfigParser()
        config.read(CONFIG_FILE)
        CERT = config.get('WSAA','CERT')
        PRIVATEKEY = config.get('WSAA','PRIVATEKEY')
        CUIT = config.get('WSLPG','CUIT')
        ENTRADA = config.get('WSLPG','ENTRADA')
        SALIDA = config.get('WSLPG','SALIDA')
        
        if config.has_option('WSAA','URL') and not HOMO:
            WSAA_URL = config.get('WSAA','URL')
        else:
            WSAA_URL = None #wsaa.WSAAURL
        if config.has_option('WSLPG','URL') and not HOMO:
            WSLPG_URL = config.get('WSLPG','URL')
        else:
            WSLPG_URL = WSDL

        PROXY = config.has_option('WSAA', 'PROXY') and config.get('WSAA', 'PROXY') or None
        CACERT = config.has_option('WSAA', 'CACERT') and config.get('WSAA', 'CACERT') or None
        WRAPPER = config.has_option('WSAA', 'WRAPPER') and config.get('WSAA', 'WRAPPER') or None
        
        if config.has_section('DBF'):
            conf_dbf = dict(config.items('DBF'))
            if DEBUG: print "conf_dbf", conf_dbf
        else:
            conf_dbf = {}
            
        DEBUG = '--debug' in sys.argv
        XML = '--xml' in sys.argv

        if DEBUG:
            print "Usando Configuración:"
            print "WSAA_URL:", WSAA_URL
            print "WSLPG_URL:", WSLPG_URL
            print "CACERT", CACERT
            print "WRAPPER", WRAPPER
        # obteniendo el TA
        from wsaa import WSAA
        wsaa = WSAA()
        ta = wsaa.Autenticar("wslpg", CERT, PRIVATEKEY, wsdl=WSAA_URL, 
                               proxy=PROXY, wrapper=WRAPPER, cacert=CACERT)
        if not ta:
            sys.exit("Imposible autenticar con WSAA: %s" % wsaa.Excepcion)

        # cliente soap del web service
        wslpg = WSLPG()
        wslpg.LanzarExcepciones = True
        wslpg.Conectar(url=WSLPG_URL, proxy=PROXY, wrapper=WRAPPER, cacert=CACERT)
        wslpg.SetTicketAcceso(ta)
        wslpg.Cuit = CUIT

        if '--dummy' in sys.argv:
            ret = wslpg.Dummy()
            print "AppServerStatus", wslpg.AppServerStatus
            print "DbServerStatus", wslpg.DbServerStatus
            print "AuthServerStatus", wslpg.AuthServerStatus
            ##sys.exit(0)

        if '--autorizar' in sys.argv:
        
            if '--prueba' in sys.argv:
                pto_emision = 99
                # genero una liquidación de ejemplo:
                dic = dict(
                    pto_emision=pto_emision,
                    nro_orden=0,  # que lo calcule automáticamente
                    cuit_comprador='20400000000',  
                    nro_act_comprador=40, nro_ing_bruto_comprador='20400000000',
                    cod_tipo_operacion=2 if "--consign" in sys.argv else 1,
                    es_liquidacion_propia='N', es_canje='N',
                    cod_puerto=14, des_puerto_localidad="DETALLE PUERTO",
                    cod_grano=31, 
                    cuit_vendedor=23000000019, nro_ing_bruto_vendedor=23000000019,
                    actua_corredor="S", liquida_corredor="S", 
                    cuit_corredor=wslpg.Cuit, # uso Cuit representado
                    comision_corredor=1, nro_ing_bruto_corredor=wslpg.Cuit,
                    fecha_precio_operacion="2013-02-07",
                    precio_ref_tn=2000,
                    cod_grado_ref="G1",
                    cod_grado_ent="FG",
                    factor_ent=98, val_grado_ent=1.02,
                    precio_flete_tn=10,
                    cont_proteico=20,
                    alic_iva_operacion=10.5,
                    campania_ppal=1213,
                    cod_localidad_procedencia=5544,
                    cod_prov_procedencia=12,
                    nro_contrato=0,
                    datos_adicionales=("DATOS ADICIONALES 1234 " * 17) + ".",
                    ##peso_neto_sin_certificado=2000,
                    precio_operacion=None,  # para probar ajustar
                    total_peso_neto=1000,   # para probar ajustar
                    certificados=[dict(   
                        tipo_certificado_deposito=5,
                        nro_certificado_deposito=555501200729,
                        peso_neto=1000,
                        cod_localidad_procedencia=3,
                        cod_prov_procedencia=1,
                        campania=1213,
                        fecha_cierre="2013-01-13",)],
                    retenciones=[dict(
                            codigo_concepto="RI",
                            detalle_aclaratorio="DETALLE DE IVA",
                            base_calculo=1000,
                            alicuota=10.5,
                        ), dict(
                            codigo_concepto="RG",
                            detalle_aclaratorio="DETALLE DE GANANCIAS",
                            base_calculo=100,
                            alicuota=0,
                        ), dict(
                            codigo_concepto="OG",
                            detalle_aclaratorio="OTRO GRAVAMEN",
                            base_calculo=1000,
                            alicuota=0,
                            nro_certificado_retencion=111111111111, 
                            fecha_certificado_retencion="2013-05-01",
                            importe_certificado_retencion=105,
                        )],
                    deducciones=[dict(
                            codigo_concepto="OD",
                            detalle_aclaratorio="FLETE",
                            dias_almacenaje="0",
                            precio_pkg_diario=0.0,
                            comision_gastos_adm=0.0,
                            base_calculo=100.0,
                            alicuota=21.0,
                        ),dict(
                            codigo_concepto="AL",
                            detalle_aclaratorio="ALMACENAJE",
                            dias_almacenaje="30",
                            precio_pkg_diario=0.0001,
                            comision_gastos_adm=0.0,
                            alicuota=21.0,
                        ),],
                    datos=[
                        dict(campo="nombre_comprador", valor="NOMBRE 1"),
                        dict(campo="domicilio1_comprador", valor="DOMICILIO 1"),
                        dict(campo="domicilio2_comprador", valor="DOMICILIO 1"),
                        dict(campo="localidad_comprador", valor="LOCALIDAD 1"),
                        dict(campo="iva_comprador", valor="R.I."),
                        dict(campo="nombre_vendedor", valor="NOMBRE 2"),
                        dict(campo="domicilio1_vendedor", valor="DOMICILIO 2"),
                        dict(campo="domicilio2_vendedor", valor="DOMICILIO 2"),
                        dict(campo="localidad_vendedor", valor="LOCALIDAD 2"),
                        dict(campo="iva_vendedor", valor="R.I."),
                        dict(campo="nombre_corredor", valor="NOMBRE 3"),
                        dict(campo="domicilio_corredor", valor="DOMICILIO 3"),
                        ]
                    )
                if "--sincorr" in sys.argv:
                    # ajusto datos para prueba sin corredor
                    dic.update(dict(
                        cuit_comprador=wslpg.Cuit,  
                        nro_act_comprador=29, nro_ing_bruto_comprador=wslpg.Cuit,
                        actua_corredor="N", liquida_corredor="N", 
                        cuit_corredor=0,
                        comision_corredor=0, nro_ing_bruto_corredor=0,))
                    dic['retenciones'][1]['alicuota'] = 15
                    del dic['datos'][-1]
                    del dic['datos'][-1]
                if "--sincert" in sys.argv:
                    # ajusto datos para prueba sin certificado de deposito
                    dic['peso_neto_sin_certificado'] = 10000
                    dic['cod_prov_procedencia_sin_certificado'] = 1
                    dic['cod_localidad_procedencia_sin_certificado'] = 15124
                    dic['certificados'] = []
                if "--singrado" in sys.argv:
                    # ajusto datos para prueba sin grado ni valor entregado
                    dic['cod_grado_ref'] = ""
                    dic['cod_grado_ent'] = ""
                    dic['val_grado_ent'] = 0
                if "--consign" in sys.argv:
                    # agrego deducción por comisión de gastos administrativos
                    dic['deducciones'].append(dict(
                            codigo_concepto="CO",
                            detalle_aclaratorio="COMISION",
                            dias_almacenaje=None,
                            precio_pkg_diario=None,
                            comision_gastos_adm=1.0,
                            base_calculo=1000.00,
                            alicuota=21.0,
                        ))
                escribir_archivo(dic, ENTRADA)
            dic = leer_archivo(ENTRADA)
                
            if int(dic['nro_orden']) == 0 and not '--testing' in sys.argv:
                # consulto el último número de orden emitido:
                ok = wslpg.ConsultarUltNroOrden(dic['pto_emision'])
                if ok:
                    dic['nro_orden'] = wslpg.NroOrden + 1

            # establezco los parametros (se pueden pasar directamente al metodo)
            for k, v in sorted(dic.items()):
                if DEBUG: print "%s = %s" % (k, v)
                wslpg.SetParametro(k, v)
                
            # cargo la liquidación:
            wslpg.CrearLiquidacion()

            for cert in dic.get('certificados', []):
                wslpg.AgregarCertificado(**cert)

            for ded in dic.get('deducciones', []):
                wslpg.AgregarDeduccion(**ded)

            for ret in dic.get('retenciones', []):
                wslpg.AgregarRetencion(**ret)

            if '--testing' in sys.argv:
                # mensaje de prueba (no realiza llamada remota), 
                # usar solo si no está operativo
                if '--error' in sys.argv:
                    wslpg.LoadTestXML("wslpg_error.xml")     # cargo error
                else:
                    wslpg.LoadTestXML("wslpg_aut_test.xml")  # cargo respuesta

            print "Liquidacion: pto_emision=%s nro_orden=%s nro_act=%s tipo_op=%s" % (
                    wslpg.liquidacion['ptoEmision'], 
                    wslpg.liquidacion['nroOrden'], 
                    wslpg.liquidacion['nroActComprador'],
                    wslpg.liquidacion['codTipoOperacion'], 
                    )
            
            if not '--dummy' in sys.argv:        
                if '--recorrer' in sys.argv:
                    print "Consultando actividades y operaciones habilitadas..."
                    lista_act_op = wslpg.ConsultarTiposOperacion(sep=None)
                    # recorro las actividades habilitadas buscando la 
                    for nro_act, cod_op, det in lista_act_op:
                        print "Probando nro_act=", nro_act, "cod_op=", cod_op, 
                        wslpg.liquidacion['nroActComprador'] = nro_act
                        wslpg.liquidacion['codTipoOperacion'] = cod_op
                        ret = wslpg.AutorizarLiquidacion()
                        if wslpg.COE:
                            print
                            break       # si obtuve COE salgo
                        else:
                            print wslpgPDF.Errores
                else:
                    print "Autorizando..." 
                    ret = wslpg.AutorizarLiquidacion()
                    
            if wslpg.Excepcion:
                print >> sys.stderr, "EXCEPCION:", wslpg.Excepcion
                if DEBUG: print >> sys.stderr, wslpg.Traceback
            print "Errores:", wslpg.Errores
            print "COE", wslpg.COE
            print "COEAjustado", wslpg.COEAjustado
            print "TootalDeduccion", wslpg.TotalDeduccion
            print "TotalRetencion", wslpg.TotalRetencion
            print "TotalRetencionAfip", wslpg.TotalRetencionAfip
            print "TotalOtrasRetenciones", wslpg.TotalOtrasRetenciones
            print "TotalNetoAPagar", wslpg.TotalNetoAPagar
            print "TotalIvaRg2300_07", wslpg.TotalIvaRg2300_07
            print "TotalPagoSegunCondicion", wslpg.TotalPagoSegunCondicion
            if False and '--testing' in sys.argv:
                assert wslpg.COE == "330100000357"
                assert wslpg.COEAjustado == None
                assert wslpg.Estado == "AC"
                assert wslpg.TotalPagoSegunCondicion == 1968.00
                assert wslpg.GetParametro("fecha_liquidacion") == "2013-02-07"
                assert wslpg.GetParametro("retenciones", 1, "importe_retencion") == "157.60"

            if DEBUG: 
                pprint.pprint(wslpg.params_out)

            # actualizo el archivo de salida con los datos devueltos
            dic.update(wslpg.params_out)
            escribir_archivo(dic, SALIDA, agrega=('--agrega' in sys.argv))  

        if '--ajustar' in sys.argv:
            print "Ajustando..."
            if '--prueba' in sys.argv:
                # genero una liquidación de ejemplo:
                dic = dict(
                    pto_emision=55, nro_orden=0, coe_ajustado='330100025869',
                    cod_localidad_procedencia=5544, cod_prov_procedencia=12,
                    cod_puerto=14, des_puerto_localidad="DETALLE PUERTO",
                    cod_grano=31,   # no enviado a AFIP, pero usado para el PDF
                    certificados=[dict(
                       tipo_certificado_deposito=5,
                       nro_certificado_deposito=555501200729,
                       peso_neto=10000,
                       cod_localidad_procedencia=3,
                       cod_prov_procedencia=1,
                       campania=1213,
                       fecha_cierre='2013-01-13',
                       peso_neto_total_certificado=10000,
                       )],
                    ajuste_credito=dict(
                        diferencia_peso_neto=1000, diferencia_precio_operacion=100,
                        cod_grado="G2", val_grado=1.0, factor=100,
                        diferencia_precio_flete_tn=10,
                        datos_adicionales='AJUSTE CRED UNIF',
                        concepto_importe_iva_0='Alicuota Cero',
                        importe_ajustar_Iva_0=900,
                        concepto_importe_iva_105='Alicuota Diez',
                        importe_ajustar_Iva_105=800,
                        concepto_importe_iva_21='Alicuota Veintiuno',
                        importe_ajustar_Iva_21=700,
                        deducciones=[dict(codigo_concepto="AL",
                               detalle_aclaratorio="Deduc Alm",
                               dias_almacenaje="1",
                               precio_pkg_diario=0.01,
                               comision_gastos_adm=1.0,
                               base_calculo=1000.0,
                               alicuota=10.5, )],
                        retenciones=[dict(codigo_concepto="RI",
                               detalle_aclaratorio="Ret IVA",
                               base_calculo=1000,
                               alicuota=10.5, )], 
                        ),
                    ajuste_debito=dict(
                        diferencia_peso_neto=500, diferencia_precio_operacion=100,
                        cod_grado="G2", val_grado=1.0, factor=100,
                        diferencia_precio_flete_tn=0.01,
                        datos_adicionales='AJUSTE DEB UNIF',
                        concepto_importe_iva_0='Alic 0',
                        importe_ajustar_Iva_0=250,
                        concepto_importe_iva_105='Alic 10.5',
                        importe_ajustar_Iva_105=200,
                        concepto_importe_iva_21='Alicuota 21',
                        importe_ajustar_Iva_21=50,
                        deducciones=[dict(codigo_concepto="AL",
                               detalle_aclaratorio="Deduc Alm",
                               dias_almacenaje="1",
                               precio_pkg_diario=0.01,
                               comision_gastos_adm=1.0,
                               base_calculo=500.0,
                               alicuota=10.5, )],
                        retenciones=[dict(codigo_concepto="RI",
                               detalle_aclaratorio="Ret IVA",
                               base_calculo=100,
                               alicuota=10.5, )],
                        ),
                    datos=[
                        dict(campo="nombre_comprador", valor="NOMBRE 1"),
                        dict(campo="domicilio1_comprador", valor="DOMICILIO 1"),
                        dict(campo="domicilio2_comprador", valor="DOMICILIO 1"),
                        dict(campo="localidad_comprador", valor="LOCALIDAD 1"),
                        dict(campo="iva_comprador", valor="R.I."),
                        dict(campo="nombre_vendedor", valor="NOMBRE 2"),
                        dict(campo="domicilio1_vendedor", valor="DOMICILIO 2"),
                        dict(campo="domicilio2_vendedor", valor="DOMICILIO 2"),
                        dict(campo="localidad_vendedor", valor="LOCALIDAD 2"),
                        dict(campo="iva_vendedor", valor="R.I."),
                        dict(campo="nombre_corredor", valor="NOMBRE 3"),
                        dict(campo="domicilio_corredor", valor="DOMICILIO 3"),
                        # completo datos no contemplados en la respuesta por AFIP:
                        dict(campo="cod_grano", valor="31"),
                        dict(campo="cod_grado_ent", valor="G1"),
                        dict(campo="cod_grado_ref", valor="G1"),
                        dict(campo="factor_ent", valor="98"),
                        dict(campo="cod_puerto", valor=14),
                        dict(campo="cod_localidad_procedencia", valor=3),
                        dict(campo="cod_prov_procedencia", valor=1),
                        dict(campo="precio_ref_tn", valor="$ 1000,00"),
                        dict(campo="precio_flete_tn", valor="$ 100,00"),
                        dict(campo="des_grado_ref", valor="G1"),
                        dict(campo="alic_iva_operacion", valor=""),
                        ]
                    )
                if '--contrato' in sys.argv:
                    dic.update(
                        {'nro_act_comprador': 40,
                         'cod_grado_ent': 'G1',
                         'cod_grano': 31,
                         'cod_puerto': 14,
                         'cuit_comprador': 20400000000,
                         'cuit_corredor': 20267565393,
                         'cuit_vendedor': 23000000019,
                         'des_puerto_localidad': 'Desc Puerto',
                         'nro_contrato': 27,
                         'precio_flete_tn': 1000,
                         'precio_ref_tn': 1000,
                         'val_grado_ent': 1.01})
                    #del dic['ajuste_debito']['retenciones']
                    #del dic['ajuste_credito']['retenciones']
                escribir_archivo(dic, ENTRADA)
            
            dic = leer_archivo(ENTRADA)
                            
            if int(dic['nro_orden']) == 0 and not '--testing' in sys.argv:
                # consulto el último número de orden emitido:
                ok = wslpg.ConsultarUltNroOrden(dic['pto_emision'])
                if ok:
                    dic['nro_orden'] = wslpg.NroOrden + 1
            
            if '--contrato' in sys.argv:
                for k in ("nro_contrato", "nro_act_comprador", "cod_grano", 
                          "cuit_vendedor", "cuit_comprador", "cuit_corredor", 
                          "precio_ref_tn", "cod_grado_ent", "val_grado_ent", 
                          "precio_flete_tn", "cod_puerto", 
                          "des_puerto_localidad"):
                    v = dic.get(k)
                    if v:
                        wslpg.SetParametro(k, v)
                        
            wslpg.CrearAjusteBase(pto_emision=dic['pto_emision'], 
                              nro_orden=dic['nro_orden'], 
                              coe_ajustado=dic['coe_ajustado'],
                              cod_localidad=dic['cod_localidad_procedencia'],
                              cod_provincia=dic['cod_prov_procedencia'],
                              )
            
            for cert in dic.get('certificados', []):
                if cert:
                    wslpg.AgregarCertificado(**cert)

            liq = dic['ajuste_credito']
            wslpg.CrearAjusteCredito(**liq)
            for ded in liq.get('deducciones', []):
                wslpg.AgregarDeduccion(**ded)
            for ret in liq.get('retenciones', []):
                wslpg.AgregarRetencion(**ret)
            
            liq = dic['ajuste_debito']
            wslpg.CrearAjusteDebito(**liq)
            for ded in liq.get('deducciones', []):
                wslpg.AgregarDeduccion(**ded)
            for ret in liq.get('retenciones', []):
                wslpg.AgregarRetencion(**ret)
            
            if '--testing' in sys.argv:
                wslpg.LoadTestXML("tests/wslpg_ajuste_unificado.xml")

            if '--contrato' in sys.argv:
                ret = wslpg.AjustarLiquidacionContrato()
            else:
                ret = wslpg.AjustarLiquidacionUnificado()
            
            if wslpg.Excepcion:
                print >> sys.stderr, "EXCEPCION:", wslpg.Excepcion
                if DEBUG: print >> sys.stderr, wslpg.Traceback
            print "Errores:", wslpg.Errores
            print "COE", wslpg.COE
            print "Subtotal", wslpg.Subtotal
            print "TotalIva105", wslpg.TotalIva105
            print "TotalIva21", wslpg.TotalIva21
            print "TotalRetencionesGanancias", wslpg.TotalRetencionesGanancias
            print "TotalRetencionesIVA", wslpg.TotalRetencionesIVA
            print "TotalNetoAPagar", wslpg.TotalNetoAPagar
            print "TotalIvaRg2300_07", wslpg.TotalIvaRg2300_07
            print "TotalPagoSegunCondicion", wslpg.TotalPagoSegunCondicion
            
            # actualizo el archivo de salida con los datos devueltos
            dic.update(wslpg.params_out)            
            ok = wslpg.AnalizarAjusteCredito()
            dic['ajuste_credito'].update(wslpg.params_out)
            ok = wslpg.AnalizarAjusteDebito()
            dic['ajuste_debito'].update(wslpg.params_out)
            escribir_archivo(dic, SALIDA, agrega=('--agrega' in sys.argv))  

            if DEBUG: 
                pprint.pprint(dic)
        
        if '--asociar' in sys.argv:
            print "Asociando...",
            if '--prueba' in sys.argv:
                # genero datos de ejemplo en el archivo para consultar:
                dic = dict(coe="330100004664", nro_contrato=26, cod_grano=31,
                           cuit_comprador="20400000000", 
                           cuit_vendedor="23000000019",
                           cuit_corredor="20267565393",
                           )
                escribir_archivo(dic, ENTRADA)
            dic = leer_archivo(ENTRADA)
            print ', '.join(sorted(["%s=%s" % (k, v) for k,v in dic.items() 
                                    if k in ("nro_contrato", "coe") or 
                                    k.startswith("cuit")]))
            wslpg.AsociarLiquidacionAContrato(**dic)
            print "Errores:", wslpg.Errores
            print "COE", wslpg.COE
            print "Estado", wslpg.Estado
            # actualizo el archivo de salida con los datos devueltos
            dic.update(wslpg.params_out)
            escribir_archivo(dic, SALIDA, agrega=('--agrega' in sys.argv))  
            
        if '--anular' in sys.argv:
            ##print wslpg.client.help("anularLiquidacion")
            try:
                coe = sys.argv[sys.argv.index("--anular") + 1]
            except IndexError:
                coe = 330100000357

            if '--lsg' in sys.argv:
                print "Anulando COE LSG", coe
                ret = wslpg.AnularLiquidacionSecundaria(coe)
            if '--cg' in sys.argv:
                print "Anulando COE CG", coe
                ret = wslpg.AnularCertificacion(coe)
            else:
                print "Anulando COE", coe
                ret = wslpg.AnularLiquidacion(coe)
            if wslpg.Excepcion:
                print >> sys.stderr, "EXCEPCION:", wslpg.Excepcion
                if DEBUG: print >> sys.stderr, wslpg.Traceback
            print "COE", wslpg.COE
            print "Resultado", wslpg.Resultado
            print "Errores:", wslpg.Errores
            sys.exit(0)
            
        if '--consultar' in sys.argv:
            pto_emision = None
            nro_orden = 0
            coe = None
            try:
                pto_emision = sys.argv[sys.argv.index("--consultar") + 1]
                nro_orden = sys.argv[sys.argv.index("--consultar") + 2]
                coe = sys.argv[sys.argv.index("--consultar") + 3]
            except IndexError:
                pass
            if '--testing' in sys.argv:
                # mensaje de prueba (no realiza llamada remota), 
                # usar solo si no está operativo
                wslpg.LoadTestXML("wslpg_cons_test.xml")     # cargo prueba
            print "Consultando: pto_emision=%s nro_orden=%s coe=%s" % (pto_emision, nro_orden, coe)
            if '--lsg' in sys.argv:
                ret = wslpg.ConsultarLiquidacionSecundaria(pto_emision=pto_emision, nro_orden=nro_orden, coe=coe)
            if '--cg' in sys.argv:
                ret = wslpg.ConsultarCertificacion(pto_emision=pto_emision, nro_orden=nro_orden, coe=coe)
            else:
                ret = wslpg.ConsultarLiquidacion(pto_emision=pto_emision, nro_orden=nro_orden, coe=coe)
            print "COE", wslpg.COE
            print "Estado", wslpg.Estado
            print "Errores:", wslpg.Errores

            # actualizo el archivo de salida con los datos devueltos
            escribir_archivo(wslpg.params_out, SALIDA, agrega=('--agrega' in sys.argv))

            if DEBUG: 
                pprint.pprint(wslpg.params_out)

        if '--consultar_ajuste' in sys.argv:
            pto_emision = None
            nro_orden = 0
            nro_contrato = None
            try:
                pto_emision = int(sys.argv[sys.argv.index("--consultar_ajuste") + 1])
                nro_orden = int(sys.argv[sys.argv.index("--consultar_ajuste") + 2])
                nro_contrato = int(sys.argv[sys.argv.index("--consultar_ajuste") + 3])
            except IndexError:
                pass
            print "Consultando: pto_emision=%s nro_orden=%s nro_contrato=%s" % (
                    pto_emision, nro_orden, nro_contrato)
            wslpg.ConsultarAjuste(pto_emision, nro_orden, nro_contrato)
            print "COE", wslpg.COE
            print "Estado", wslpg.Estado
            print "Errores:", wslpg.Errores
            # actualizo el archivo de salida con los datos devueltos
            dic = wslpg.params_out            
            ok = wslpg.AnalizarAjusteCredito()
            dic['ajuste_credito'] = wslpg.params_out
            ok = wslpg.AnalizarAjusteDebito()
            dic['ajuste_debito'] = wslpg.params_out
            escribir_archivo(dic, SALIDA, agrega=('--agrega' in sys.argv))  
            if DEBUG: 
                pprint.pprint(dic)
                
        if '--consultar_por_contrato' in sys.argv:
            print "Consultando liquidaciones por contrato...",
            if '--prueba' in sys.argv:
                # genero datos de ejemplo en el archivo para consultar:
                dic = dict(nro_contrato=26, cod_grano=31,
                           cuit_comprador="20400000000", 
                           cuit_vendedor="23000000019",
                           cuit_corredor="20267565393",
                           )
                escribir_archivo(dic, ENTRADA)
            dic = leer_archivo(ENTRADA)
            print ', '.join(sorted(["%s=%s" % (k, v) for k,v in dic.items() 
                             if k == "nro_contrato" or k.startswith("cuit")]))
            wslpg.ConsultarLiquidacionesPorContrato(**dic)
            print "Errores:", wslpg.Errores
            while wslpg.COE:
                print "COE", wslpg.COE
                wslpg.LeerDatosLiquidacion()
                ##print "Estado", wslpg.Estado
                # actualizo el archivo de salida con los datos devueltos
                dic['coe'] = wslpg.COE
                escribir_archivo(dic, SALIDA, agrega=True)
                
        if '--ult' in sys.argv:
            try:
                pto_emision = int(sys.argv[sys.argv.index("--ult") + 1])
            except IndexError, ValueError:
                pto_emision = 1
            print "Consultando ultimo nro_orden para pto_emision=%s" % pto_emision,
            if '--lsg' in sys.argv:
                print "LSG"
                ret = wslpg.ConsultarLiquidacionSecundariaUltNroOrden(pto_emision)
            elif '--cg' in sys.argv:
                print "CG"
                ret = wslpg.ConsultarCertificacionUltNroOrden(pto_emision)            
            else:
                print "LPG"
                ret = wslpg.ConsultarUltNroOrden(pto_emision)
            if wslpg.Excepcion:
                print >> sys.stderr, "EXCEPCION:", wslpg.Excepcion
                if DEBUG: print >> sys.stderr, wslpg.Traceback
            print "Ultimo Nro de Orden", wslpg.NroOrden
            print "Errores:", wslpg.Errores
            sys.exit(0)

        if '--autorizar-lsg' in sys.argv:
        
            if '--prueba' in sys.argv:
                # genero una liquidación de ejemplo:
                dic = dict(
                    pto_emision=99,
                    nro_orden=1,  nro_contrato=100001232,
                    cuit_comprador='20400000000',  
                    nro_ing_bruto_comprador='123',
                    cod_puerto=14, des_puerto_localidad="DETALLE PUERTO",
                    cod_grano=2, cantidad_tn=100,
                    cuit_vendedor="23000000019", nro_act_vendedor=29,
                    nro_ing_bruto_vendedor=123456,
                    actua_corredor="S", liquida_corredor="S",
                    cuit_corredor=wslpg.Cuit, # uso Cuit representado
                    nro_ing_bruto_corredor=wslpg.Cuit,
                    fecha_precio_operacion="2014-10-10",
                    precio_ref_tn=100, precio_operacion=150,
                    alic_iva_operacion=10.5, campania_ppal=1314,
                    cod_localidad_procedencia=197,
                    cod_prov_procedencia=10,
                    datos_adicionales="Prueba",
                    deducciones=[{'detalle_aclaratorio': 'deduccion 1',
                                  'base_calculo': 100, 'alicuota_iva': 21}],
                    percepciones=[{'detalle_aclaratoria': 'percepcion 1',
                                  'base_calculo': 1000, 'alicuota_iva': 21}],
                    opcionales=[{'codigo': 1, 
                                 'descripcion': 'previsto para info adic.'}],
                )
                escribir_archivo(dic, ENTRADA, agrega=False)
            dic = leer_archivo(ENTRADA)
            
            # cargo la liquidación:
            wslpg.CrearLiqSecundariaBase(**dic)
            
            for ded in dic.get('deducciones', []):
                wslpg.AgregarDeduccion(**ded)
            for per in dic.get("percepciones", []):
                wslpg.AgregarPercepcion(**per)
            for opc in dic.get("opcionales", []):
                wslpg.AgregarOpcional(**opc)

            print "Liquidacion Secundaria: pto_emision=%s nro_orden=%s" % (
                    wslpg.liquidacion['ptoEmision'],
                    wslpg.liquidacion['nroOrden'],
                    )
            
            if '--testing' in sys.argv:
                # mensaje de prueba (no realiza llamada remota), 
                wslpg.LoadTestXML("wslpg_lsg_autorizar_resp.xml")
            
            wslpg.AutorizarLiquidacionSecundaria()
            
            if wslpg.Excepcion:
                print >> sys.stderr, "EXCEPCION:", wslpg.Excepcion
                if DEBUG: print >> sys.stderr, wslpg.Traceback
            print "Errores:", wslpg.Errores
            print "COE", wslpg.COE
            print wslpg.GetParametro("cod_tipo_operacion")
            print wslpg.GetParametro("fecha_liquidacion") 
            print wslpg.GetParametro("subtotal")
            print wslpg.GetParametro("importe_iva")
            print wslpg.GetParametro("operacion_con_iva")
            print wslpg.GetParametro("total_peso_neto")
            print wslpg.GetParametro("numero_contrato")

            # actualizo el archivo de salida con los datos devueltos
            dic.update(wslpg.params_out)
            escribir_archivo(dic, SALIDA, agrega=('--agrega' in sys.argv))  
            
        if '--autorizar-cg' in sys.argv:
        
            if '--prueba' in sys.argv:
                # genero una certificación de ejemplo a autorizar:
                dic = dict(
                        pto_emision=99, nro_orden=1,  
                        tipo_certificado="P", nro_planta="1",
                        nro_ing_bruto_depositario="20267565393",
                        titular_grano="T",
                        cuit_depositante='20111111112',  
                        nro_ing_bruto_depositante='123',
                        cuit_corredor='20222222223',
                        cod_grano=2, campania=1314,
                        datos_adicionales="Prueba",)
           
                # datos provisorios de prueba (segun tipo de certificación):
                if '--primaria' in sys.argv:
                    dep = dict(
                        nro_act_depositario=29,
                        tipo_certificado="P",
                        descripcion_tipo_grano="SOJA",
                        monto_almacenaje=1, monto_acarreo=2, 
                        monto_gastos_generales=3, monto_zarandeo=4,
                        porcentaje_secado_de=5, porcentaje_secado_a=4,
                        monto_secado=7, monto_por_cada_punto_exceso=8,
                        monto_otros=9, 
                        porcentaje_merma_volatil=15, peso_neto_merma_volatil=16, 
                        porcentaje_merma_secado=17, peso_neto_merma_secado=18, 
                        porcentaje_merma_zarandeo=19, peso_neto_merma_zarandeo=20,
                        peso_neto_certificado=21, servicios_secado=22,  
                        servicios_zarandeo=23, servicios_otros=24, 
                        servicios_forma_de_pago=25,
                        )
                    dic.update(dep)
                    
                    det = dict(descripcion_rubro="bonif", 
                               tipo_rubro="B", porcentaje=1, valor=1)
                    dic['det_muestra_analisis'] = [det]
                    
                    cal = dict(analisis_muestra=10, nro_boletin=11,
                               cod_grado="F1", valor_grado=1.02, 
                               valor_contenido_proteico=1, valor_factor=1)
                    dic['calidad'] = [cal]

                    ctg = dict(nro_ctg="123456", nro_carta_porte=1000,
                            porcentaje_secado_humedad=1, importe_secado=2,
                            peso_neto_merma_secado=3, tarifa_secado=4,
                            importe_zarandeo=5, peso_neto_merma_zarandeo=6,
                            tarifa_zarandeo=7, 
                            peso_neto_confirmado_definitivo=1)
                    dic['ctgs'] = [ctg, ctg]

                if '--retiro-transf' in sys.argv:
                    rt = dict(
                            nro_act_depositario=29,
                            tipo_certificado="R",
                            cuit_receptor="20400000000",
                            fecha="2014-11-26", 
                            nro_carta_porte_a_utilizar="12345",
                            cee_carta_porte_a_utilizar="123456789012",
                            )
                    dic.update(rt)
                    cert = dict(
                           peso_neto=10000,
                           coe_certificado_deposito="123456789012", 
                        )
                    dic['certificados'] = [cert]

                if '--preexistente' in sys.argv:
                    pre = dict(
                            tipo_certificado="E",
                            tipo_certificado_deposito_preexistente=1, # "R" o "T"
                            nro_certificado_deposito_preexistente="12345",
                            cac_certificado_deposito_preexistente="123456789012",
                            fecha_emision_certificado_deposito_preexistente="2014-11-26",
                            peso_neto=1000, nro_planta=1,
                            )
                    dic.update(pre)

                escribir_archivo(dic, ENTRADA, agrega=False)
            dic = leer_archivo(ENTRADA)
            
            # cargar los datos según el tipo de certificación:
            
            wslpg.CrearCertificacionCabecera(**dic)

            if dic["tipo_certificado"] in ('P'):
                wslpg.AgregarCertificacionPrimaria(**dic)
                for ctg in dic.get("ctgs", []):
                    wslpg.AgregarCTG(**ctg)
                for cal in dic.get("calidad", []):
                    wslpg.AgregarCalidad(**cal) 
                for det in dic.get("det_muestra_analisis", []):
                    wslpg.AgregarDetalleMuestraAnalisis(**det) 
            
            if dic["tipo_certificado"] in ('R', 'T'):
                wslpg.AgregarCertificacionRetiroTransferencia(**dic)
                for cert in dic.get("certificados", []):
                    wslpg.AgregarCertificado(**cert)

            if dic["tipo_certificado"] in ('E', ):
                wslpg.AgregarCertificacionPreexistente(**dic)
            
            print "Certificacion: pto_emision=%s nro_orden=%s tipo=%s" % (
                    wslpg.certificacion['cabecera']['ptoEmision'],
                    wslpg.certificacion['cabecera']['nroOrden'],
                    wslpg.certificacion['cabecera']['tipoCertificado'],
                    )
            
            if '--testing' in sys.argv:
                # mensaje de prueba (no realiza llamada remota), 
                wslpg.LoadTestXML("wslpg_cert_autorizar_resp.xml")
            
            wslpg.AutorizarCertificacion()
            
            if wslpg.Excepcion:
                print >> sys.stderr, "EXCEPCION:", wslpg.Excepcion
                if DEBUG: print >> sys.stderr, wslpg.Traceback
            print "Errores:", wslpg.Errores
            print "COE", wslpg.COE
            print wslpg.GetParametro("fecha_certificacion") 

            # actualizo el archivo de salida con los datos devueltos
            dic.update(wslpg.params_out)
            escribir_archivo(dic, SALIDA, agrega=('--agrega' in sys.argv))  
            
        # Informar calidad (solo CG primarias)
        
        if '--informar-calidad' in sys.argv:
            dic = leer_archivo(ENTRADA)
            wslpg.CrearCertificacionCabecera(**dic)
            wslpg.AgregarCertificacionPrimaria()
            
            for cal in dic.get("calidad", []):
                wslpg.AgregarCalidad(**cal) 
            for det in dic.get("det_muestra_analisis", []):
                wslpg.AgregarDetalleMuestraAnalisis(**det) 
            
            # intento obtener el COE por linea de parametros o del archivo:
            try:
                coe = sys.argv[sys.argv.index("--informar-calidad") + 1]
            except IndexError:
                coe = dic['coe']
            
            print "Informar Calidad: coe=%s " % (coe, )
            wslpg.InformarCalidadCertificacion(coe)
            
            if wslpg.Excepcion:
                print >> sys.stderr, "EXCEPCION:", wslpg.Excepcion
                if DEBUG: print >> sys.stderr, wslpg.Traceback
            print "Errores:", wslpg.Errores
            print "COE", wslpg.COE
            # actualizo el archivo de salida con los datos devueltos
            dic.update(wslpg.params_out)
            escribir_archivo(dic, SALIDA, agrega=('--agrega' in sys.argv))  

        # Recuperar parámetros:
        
        if '--campanias' in sys.argv:
            ret = wslpg.ConsultarCampanias()
            print "\n".join(ret)
        
        if '--tipograno' in sys.argv:
            ret = wslpg.ConsultarTipoGrano()
            print "\n".join(ret)

        if '--gradoref' in sys.argv:
            ret = wslpg.ConsultarCodigoGradoReferencia()
            print "\n".join(ret)

        if '--gradoent' in sys.argv:
            ##wslpg.LoadTestXML("wslpg_cod.xml")     # cargo respuesta de ej
            cod_grano = raw_input("Ingrese el código de grano: ")
            ret = wslpg.ConsultarGradoEntregadoXTipoGrano(cod_grano=cod_grano)
            print "\n".join(ret)
        
        if '--datos' in sys.argv:
            print "# Grados"
            print wslpg.ConsultarCodigoGradoReferencia(sep=None)
            
            print "# Datos de grado entregado por tipo de granos:"
            for cod_grano in wslpg.ConsultarTipoGrano(sep=None):
                grad_ent = wslpg.ConsultarGradoEntregadoXTipoGrano(cod_grano, sep=None)
                print cod_grano, ":", grad_ent, ","

        if '--shelve' in sys.argv:
            print "# Construyendo BD de Localidades por Provincias"            
            import wslpg_datos as datos
            for cod_prov, desc_prov in wslpg.ConsultarProvincias(sep=None).items():
                print "Actualizando Provincia", cod_prov, desc_prov
                d = wslpg.BuscarLocalidades(cod_prov)

        if '--certdeposito' in sys.argv:
            ret = wslpg.ConsultarTipoCertificadoDeposito()
            print "\n".join(ret)

        if '--deducciones' in sys.argv:
            ret = wslpg.ConsultarTipoDeduccion()
            print "\n".join(ret)

        if '--retenciones' in sys.argv:
            ret = wslpg.ConsultarTipoRetencion()
            print "\n".join(ret)
            
        if '--puertos' in sys.argv:
            ret = wslpg.ConsultarPuerto()
            print "\n".join(ret)

        if '--actividades' in sys.argv:
            ret = wslpg.ConsultarTipoActividad()
            print "\n".join(ret)

        if '--actividadesrep' in sys.argv:
            ret = wslpg.ConsultarTipoActividadRepresentado()
            print "\n".join(ret)
            print "Errores:", wslpg.Errores
            
        if '--operaciones' in sys.argv:
            ret = wslpg.ConsultarTiposOperacion()
            print "\n".join(ret)

        if '--provincias' in sys.argv:
            ret = wslpg.ConsultarProvincias()
            print "\n".join(ret)
                    
        if '--localidades' in sys.argv:
            cod_prov = raw_input("Ingrese el código de provincia:")
            ret = wslpg.ConsultarLocalidadesPorProvincia(cod_prov)
            print "\n".join(ret)

        # Generación del PDF:

        if '--pdf' in sys.argv:
        
            # cargo los datos del archivo de salida:
            liq = wslpg.params_out = leer_archivo(SALIDA)
        
            conf_liq = dict(config.items('LIQUIDACION'))
            conf_pdf = dict(config.items('PDF'))
        
            # establezco formatos (cantidad de decimales) según configuración:
            wslpg.FmtCantidad = conf_liq.get("fmt_cantidad", "0.2")
            wslpg.FmtPrecio = conf_liq.get("fmt_precio", "0.2")

            # determino el formato según el tipo de liquidación y datos
            if '--ajuste' not in sys.argv:
                # liquidación estándar
                formatos = [('formato', '')]
                copias = int(conf_liq.get("copias", 3))
            else:
                # ajustes (páginas distintas), revisar si hay debitos/creditos:
                formatos = [('formato_ajuste_base', '')]
                copias = 1
                if liq['ajuste_debito']:
                    formatos.append(('formato_ajuste_debcred', 'ajuste_debito' ))
                if liq['ajuste_credito']:
                    formatos.append(('formato_ajuste_debcred', 'ajuste_credito'))

            wslpg.CrearPlantillaPDF(
                        papel=conf_liq.get("papel", "legal"), 
                        orientacion=conf_liq.get("orientacion", "portrait"),
                        )

            for num_formato, (formato, clave) in enumerate(formatos):
                # cargo el formato CSV por defecto (liquidacion....csv)
                wslpg.CargarFormatoPDF(conf_liq.get(formato))
                
                # datos fijos (configuracion):
                for k, v in conf_pdf.items():
                    wslpg.AgregarDatoPDF(k, v)

                # datos adicionales (tipo de registro 9):
                for dato in liq.get('datos', []):
                    wslpg.AgregarDatoPDF(dato['campo'], dato['valor'])
                    if DEBUG: print "DATO", dato['campo'], dato['valor']

                wslpg.ProcesarPlantillaPDF(num_copias=copias,
                                        lineas_max=int(conf_liq.get("lineas_max", 24)),
                                        qty_pos=conf_liq.get("cant_pos") or 'izq',
                                        clave=clave)
                if wslpg.Excepcion:
                    print >> sys.stderr, "EXCEPCION:", wslpg.Excepcion
                    if DEBUG: print >> sys.stderr, wslpg.Traceback

                salida = conf_liq.get("salida", "")

                # genero el nombre de archivo según datos de factura
                d = os.path.join(conf_liq.get('directorio', "."), 
                                 liq['fecha_liquidacion'].replace("-", "_"))
                if not os.path.isdir(d):
                    if DEBUG: print "Creando directorio!", d 
                    os.makedirs(d)
                fs = conf_liq.get('archivo','pto_emision,nro_orden').split(",")
                fn = u'_'.join([unicode(liq.get(ff,ff)) for ff in fs])
                fn = fn.encode('ascii', 'replace').replace('?','_')
                salida = os.path.join(d, "%s.pdf" % fn)
                if num_formato == len(formatos) - 1:
                    dest = "F"  # si es el último, escribir archivo
                else:
                    dest = ""   # sino, no escribir archivo todavía
                wslpg.GenerarPDF(archivo=salida, dest=dest)
                print "Generando PDF", salida, dest
            if '--mostrar' in sys.argv:
                wslpg.MostrarPDF(archivo=salida,
                                 imprimir='--imprimir' in sys.argv)

        print "hecho."
        
    except SoapFault,e:
        print >> sys.stderr, "Falla SOAP:", e.faultcode, e.faultstring.encode("ascii","ignore")
        sys.exit(3)
    except Exception, e:
        try:
            print >> sys.stderr, traceback.format_exception_only(sys.exc_type, sys.exc_value)[0]
        except:
            print >> sys.stderr, "Excepción no disponible:", type(e)
        if DEBUG:
            raise
        sys.exit(5)
    finally:
        if XML:
            open("wslpg_request.xml", "w").write(wslpg.client.xml_request)
            open("wslpg_response.xml", "w").write(wslpg.client.xml_response)