AFIP Argentina: Consultas al padron de contribuyentes

[[AgustinOrtu]]

Saludos,

Me termine dando por vencido con Indy (he probado con las diferentes versiones, la 9, la 10, buscado en internet y no hay caso )

He decidido darle una oportunidad a la biblioteca Synapse que es OpenSource. Con esta biblioteca no he tenido ningun problema para realizar las invocaciones GET

El siguiente paso fue eliminar las dependencias con los componentes NetHttpClient

He declarado una interface en la unidad Afip.PublicAPI.HttpClient y delegado la implementacion al usuario:

Código Delphi [-]
  IHttpClient = interface
    ['{AFA99837-6CBB-4111-A268-D8AB8E4CD8DD}']
    function HttpGetText(const AUrl: string): string;
    function HttpGetBinary(const AUrl: string): TStream;
  end;

Cualquier clase que implemente IHttpClient le sirve a mi clase TAfipQuery para comunicarse con el servidor REST

Se proveen dos implementaciones:

- La que ya teniamos hasta ahora, usando los components NetHttpClient

Esa implementacion la he movido a la unidad Afip.PublicAPI.NetHttpClient; esta encapsulado dentro de la clase TNativeHttpClient

- La nueva implementacion usando la biblioteca Synapse, en la unidad Afip.PublicAPI.SynapseHttpClient

He incluido tambien en el repo la propia biblioteca Synapse, con solo agregar la ruta en Delphi, ya esta listo para funcionar

... \AFIP\Third-Party\Synapse

El constructor de TAfipQuery ahora requiere una referencia a una interface de este tipo (dependency injection)

Código Delphi [-]
  constructor Create(const AHttpClient: IHttpClient; const APersister: IPersister_Afip = NIL);

Y eleva una excepcion si le pasamos NIL...

Código Delphi [-]
constructor TAfipQuery.Create(const AHttpClient: IHttpClient; const APersister: IPersister_Afip = NIL);
begin
  if AHttpClient = NIL then
    raise Exception.CreateFmt('%s.Create :: AHttpClient is NIL', [ClassName]);

He eliminado las funciones que operaban (por asi llamarlo de una manera) "al estilo static", o de funcion de clase (class function) porque ahora no tengo mas el constructor por defecto y no quiero seguir acoplando dependencias

Por ultimo he actualizado el demo para que cumpla con esta refactorizacion; tambien he incluido la posibilidad de usar una u otra biblioteca en tiempo de ejecucion (Synapse o NetHttp)

La biblioteca Synapse deberia funcionar con versiones mas antiguas de Delphi e incluso FPC (Lazarus)

[[AgustinOrtu]]

Saludos,

He terminado por desacoplar completamente el diseño

He implementado el parser usando la biblioteca lkJSON

El código ya está publicado, ahora tenemos dos clases que implementan las interfaces parser, usando dos bibliotecas distintas para tratar con JSON: la biblioteca System.Json de Delphi y la lkJSON

De este modo se amplia la compatiblidad con versiones de Delphi mas antiguas

He incluido algunas reformas, por ejemplo ahora el constructor va a tambien requerir las interfaces parser. De este modo el usuario puede incluir su implementacion si asi lo quiere

[[AgustinOrtu]]

Aca se puede ver el demo en ejecucion, compilado con Delphi 2010

Ya he solucionado los problemas de compilación (record helper, namespaces de las unidades, TFormatSettings)

[[AgustinOrtu]]

Hola nuevamente

He creado un port para FreePascal de esta biblioteca

Hay algunas pequeñas diferencias con la version para Delphi (mas que nada las dependencias, tuve que tocar bastante la biblioteca lkJSON)

Pueden obtenerlo acá

Saludos

[fcios]

Hola yo lo hice con 2 componentes de las ICS

TSslHttpCli y TSslContext;

// Consulta a Padrón Nivel 3 WSPN3

Código Delphi [-]
unit Unit1;
// usa los ICS de OverbyteIcsV7Gold
// http://www.overbyte.be/frame_index.h...ducts/ics.html

interface

uses
  Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
  Dialogs, OverbyteIcsWSocket, OverbyteIcsWndControl, OverbyteIcsHttpProt,
  StdCtrls, Buttons;

type
  TForm1 = class(TForm)
    SslHttpCli1: TSslHttpCli;
    SslContext1: TSslContext;
    Label5: TLabel;
    ConsultarCuitBB: TBitBtn;
    ICSMemo1M: TMemo;
    Memo1: TMemo;
    SalirBB: TBitBtn;
    ConsultarCuitE: TEdit;
    procedure SslHttpCli1RequestDone(Sender: TObject; RqType: THttpRequest;
      ErrCode: Word);
    procedure ConsultarCuitBBClick(Sender: TObject);
    procedure SalirBBClick(Sender: TObject);
  private
    { Private declarations }
    sAux : string;
    function  BuscoValorDelNodo1(const sTexto:{wide}String; const sNodoABuscar:string; var sRespuesta:{wide}string):boolean;
  public
    { Public declarations }
  end;

var
  Form1: TForm1;

implementation

uses StrUtils{PosEx};

const
  myEOL        = #13+#10; // simula enter o fin de linea

{$R *.dfm}

procedure TForm1.ConsultarCuitBBClick(Sender: TObject);
var
  nCantErrores :byte;
  sCuit : string;
  sRespu :string;
const nMAX_ERRORES = 2; // PORQUE LA PRIMERA VEZ QUE SE CONECTA ES POSIBLE QUE DE ERROR

begin
  ConsultarCuitBB.Enabled := False;
  ConsultarCuitBB.Update;        

  ConsultarCuitE.Text := StringReplace(ConsultarcuitE.Text,'-','',[rfReplaceAll]);
  sCuit := ConsultarCuitE.Text;

  SslHttpCli1.URL := 'https://soa.afip.gob.ar/sr-padron/v2/persona/'+
    sCuit;

  SslHttpCli1.RcvdStream := TMemoryStream.Create;

  nCantErrores :=0;
  while True do begin
    try
      IcSMemo1M.Lines.Clear;
      SslHttpCli1.Get;
    except
      on E: Exception do begin
        if e.Message = 'Connection aborted on request' then begin
          ICSMemo1M.Lines.Append('Error al conectar, verifique tener libeay32.dll y ssleay32.dll'+myeol+
                              e.Message {+' '+e.ClassName});
          ConsultarCuitBB.Enabled := True;
          Exit;
        end;
        ICSMemo1M.Lines.Append(myEOL+'Error al conectar '+myeol+e.Message {+' '+e.ClassName});
        ConsultarCuitBB.Enabled := True;
        exit;
      end;
    end;        // 123,34,115,117, = {"su

//  if SslHttpCli1.RcvdStream = nil then begin
    if SslHttpCli1.RcvdCount = 0 then begin
        Inc(nCantErrores);
        sAux := DateTimeToStr(Now) + ' ERROR DE CONEXION, RX, ' +
          ' INTENTO ' + IntToStr(nCantErrores) +myeol+ 'VERIFIQUE QUE EXISTE LIBEAY32.DLL Y SSLEAY32.DLL' ;
          // myEOL+ e.ClassName + myEOL + e.Message;
        //  GraboErrorLog(sSistema+myEOL+sAux,not bMostrarError);
        ICSMemo1M.Lines.Append(sAux);
        if nCantErrores <= nMAX_ERRORES then begin
          // MuestroErrorArba(False,True,sAux);
          ICSMemo1M.Lines.Append('Intento '+intToStr(nCantErrores));
        end else
        begin
          //MuestroErrorArba(False,True,sAux,5);
          ICSMemo1M.Lines.Append(sAux);
          Break;
        end;
      Continue;
    end;

    Break;
  end;
  SslHttpCli1.RcvdStream.Free;
  SslHttpCli1.RcvdStream := nil;

  if BuscoValorDelNodo1(ICSMemo1M.Text,'success', sRespu) = True then begin
    Memo1.Lines.Append('success='+sRespu);
  end else begin
    memo1.Lines.Append('No se encuentra cuit ' + sCuit + myeol+
      ICSMemo1m.Text);
  end;

  if BuscoValorDelNodo1(ICSMemo1M.Text,'idPersona', sRespu) = True then begin
    Memo1.Lines.Append('idPersona='+sRespu);
  end else begin
    memo1.Lines.Append('No se encuentra cuit ' + sCuit + myeol+
      ICSMemo1m.Text);
  end;

  if BuscoValorDelNodo1(ICSMemo1M.Text,'tipoPersona', sRespu) = True then begin
    Memo1.Lines.Append('tipoPersona='+ sRespu);
  end else begin
    memo1.Lines.Append('No se encuentra tipoPersona para ' + sCuit + myeol+
      ICSMemo1m.Text);
  end;


  //
  ConsultarCuitBB.Enabled := True;
end;

function  TForm1.BuscoValorDelNodo1(const sTexto:{wide}String; const sNodoABuscar:string; var sRespuesta:{wide}string):boolean;
// usada para AFIP
// si no encontró el sNodoABuscar retorna False y limpia sRespuesta
// sTexto : texto donde buscar el sNodoABuscar
// sNodoABuscar es el string a buscar ej. 'direccion'
//
var n,n2,nLongNodo:integer;
begin
  n:=Pos('"' + sNodoABuscar + '":',sTexto);
  if n = 0 then begin // si no lo encuentra retorna FALSE
    Result := False;
  sRespuesta := '';
    Exit;
  end;
  Result := True;
  nLongNodo := Length(sNodoABuscar) + 3;

  // busco donde empieza el nodo
  if sTexto[n + nLongNodo ] = '[' then begin // si es array
    n2 := PosEx(']',sTexto,n) +1 ;
  end
  else
    n2 := PosEx(',',sTexto,n);

  if sTexto[n2-1] = '}' then // saco el cierre } de por ejemplo idProvincia
    Dec(n2);


//  if n2 = 0 then
//    MuestroError(True,'NO SE ENCUENTRA FIN DE NODO' + sNodoABuscar,LogSL,True);
//sRespuesta := MidStr(sTexto,n+nLongNodo,n2{-n-nLongNodo});
  sRespuesta := copy(sTexto,n+nLongNodo,n2-n-nLongNodo);
end;


procedure TForm1.SslHttpCli1RequestDone(Sender: TObject;
  RqType: THttpRequest; ErrCode: Word);
var
  Data : String;
begin
    SslHttpCli1.SendStream.Free;
    SslHttpCli1.SendStream := nil;

    if ErrCode <> 0 then begin
        ICSMemo1M{ICSErrorM}.Lines.Append('Post error #' + IntToStr(ErrCode));
        SslHttpCli1.RcvdStream.Free;
        SslHttpCli1.RcvdStream := nil;
        Exit;
    end;
    if SslHttpCli1.StatusCode <> 200 then begin
        ICSMemo1M{ICSErrorM}.Lines.Append('Post error: ' + IntToStr(SslHttpCli1.StatusCode) +
                SslHttpCli1.ReasonPhrase);
        SslHttpCli1.RcvdStream.Free;
        SslHttpCli1.RcvdStream := nil;
        Exit;
    end;
//  Memo1.Lines.Append('Post was OK. Response was:');
    SslHttpCli1.RcvdStream.Seek(0, 0);
    SetLength(Data, SslHttpCli1.RcvdStream.Size);
    SslHttpCli1.RcvdStream.Read(Data[1], Length(Data));
    ICSMemo1M.Lines.Append(Data);
  // grabo log
//  ArbaLogSL.Append(FormatDateTime('dd-mm-yyyy hh:nn:ss ',now)+ UltimaActualizacionL.Caption+
//    ' TX '+ArbaDatosSL[ccDESCRIPCION]+
//    myEOL + ArbaSL.Text +myEOL+
//   'RX'+ myEOL + SslHttpCli1.RcvdHeader.Text +myEOL+ Data +myEOL);

//  ArbaLogSL.SaveToFile(sArbaArchivoLog);
end;

procedure TForm1.SalirBBClick(Sender: TObject);
begin
  Close;
end;

end.

[elrayo76]

He visto el código y esta todo muy bueno.

El problema es que necesitamos entre todos buscar alguna solución para poder usar tu código con las librerías que trae Delphi XE8. Es que intento por mi parte usar lo menos posible componentes de terceros, ya que en ocaciones me ha pasado que al cambiar de versión de Delphi no hay actualización de los mismos y es engorroso ponerce a tocarlos para hacerlos compatibles.

Saludos,
El Rayo

[[AgustinOrtu]]

Yo utilizo ese codigo con Delphi 2010. Compila sin ningun problema. Eso si, necesitas la biblioteca Synapse para la parte de HTTP, ya que con Indy he tenido problemas; y alguna otra biblioteca para tratar con JSON, yo he usado lkJson

De hecho, el mismo codigo lo he traducido a FreePascal (hay algunas cuestiones menores relacionadas con el soporte a genericos y ayudantes, pero es en esencia el mismo codigo)

Si queres usar otras bibliotecas simplemente tenes que implementar un par de interfaces:

Las que convierten JSON a objetos de negocio, definidas en Afip.PublicAPI.Parsers.pas

Código PHP:

  IAfip_PersonParser = interface
    ['{3A2CC23D-B463-45C8-B3BA-8546DBF21A62}']
    function JsonToPerson(const AJson: string): IPersona_Afip;
    function JsonToDocumentos(const AJson: string): TArray<string>;
  end;

  IAfip_ItemParser = interface
    ['{0EF21EDC-EFE9-4600-8732-1BBE3A7B136C}']
    function JsonToItems(const AJson: string): TArray<TItem_Afip>;
    function JsonToDependencies(const AJson: string): TArray<TDependencia_Afip>;
  end; 


Y un cliente HTTP, esta interfaz esta definida en Afip.PublicAPI.HttpClient.pas

Código PHP:

  /// <summary>
  ///  Esta interface define los dos metodos basicos que tienen que implementar los clientes HTTP
  ///  Segun la documentacion de la AFIP el encoding del response es UTF-8
  /// </summary>
  IHttpClient = interface
    ['{AFA99837-6CBB-4111-A268-D8AB8E4CD8DD}']
    function HttpGetText(const AUrl: string): string;
    function HttpGetBinary(const AUrl: string): TStream;
  end; 


Despues conectas todo, creando una instancia de la clase TAfipQuery. El constructor te va a indicar que objetos necesitas suministrar:

Código Delphi [-]
var
  API_AFIP: IApi_Afip;
  HttpClient: IHttpClient;
  PersonParser: IAfip_PersonParser;
  ItemsParser: IAfip_ItemParser;
begin
  HttpClient := // crear http client
  PersonParser := // crear parser json
  ItemsParser:= // crear parser json
  API_AFIP:= TAfipQuery.Create(HttpClient, PersonParser, ItemsParser);
  // usar API

[elrayo76]

Perdón que mi mensaje anterior salió dos veces. Dío error al enviarlo la primera vez y cuando lo mande la segunda no me dicuenta que ya se había grabado la primera

Saludos