RTC Forums

implementation

{$R *.DFM}

procedure ServiceController(CtrlCode: DWord); stdcall;
begin
  vgad.Controller(CtrlCode);
end;

function Tvgad.GetServiceController: TServiceController;
begin
  Result := ServiceController;
end;

procedure Tvgad.ServiceExecute(Sender: TService);
begin

  Timer1.Enabled := True;

  DoConectarDBSistema;
  DoConectarDBDatos;
  qrSQL.Close;
  qrSQL.SQL.Text := 'SELECT IP_SERVER, PUERTO FROM PARAMETRO';
  qrSQL.Open();
  rtcServer.ServerAddr := qrSQL.FieldByName('IP_SERVER').AsString;
  rtcServer.ServerPort := qrSQL.FieldByName('PUERTO').AsString;

  rtcServer.Listen();

  while not Terminated do
	  ServiceThread.ProcessRequests(True);
  Timer1.Enabled := False;

end;

procedure Tvgad.rtcServerDataReceived(Sender: TRtcConnection);
Var sDato: String;
  FF: Text;
  sFile: String;
begin

  Timer1.Enabled := False;
  sDato := Sender.Read;
  qrSQL.SQL.Text := ' insert into vw_linea ( ' +
                    '    linea)     ' +
                    '  values (     ' +
                    '    :linea)    ' ;
  qrSQL.ParamByName('linea').AsString := sDato;
  Try
    qrSQL.ExecSQL;
    Timer1.Enabled := True;
  Except
    on E: Exception do begin
      // Log the received string
      sFile := 'c:\GADIDX\LOG\LineasX.log';
      AssignFile(FF, 'c:\GADIDX\LOG\LineasX.log');
      if FileExists(sFile) then begin
        Append(FF);
      end else begin
        Rewrite(FF);
      end;
      Writeln(FF, sDato);
      CloseFile(FF);

      // Log the error exception
      sFile := 'c:\GADIDX\LOG\Errores.log';
      AssignFile(FF, 'c:\GADIDX\LOG\Errores.log');
      if FileExists(sFile) then begin
        Append(FF);
      end else begin
        Rewrite(FF);
      end;
      sDato := FormatDateTime('dd/mm/yyyy hh:mm:ss', Now) +
                ': ECN = ' + E.ClassName +
                '  ---  ' +
                ' EM = ' + E.Message;
      Writeln(FF, sDato);
      CloseFile(FF);


      Timer1.Enabled := True;
    end;
  End;
end;

procedure Tvgad.ServiceDestroy(Sender: TObject);
begin
  rtcServer.StopListen;
end;

procedure Tvgad.Timer1Timer(Sender: TObject);
var
  FF: Text;
  sFile: String;
begin
  sFile := 'c:\GADIDX\LOG\GadIdx.log';
  AssignFile(FF, 'c:\GADIDX\LOG\GadIdx.log');
  if FileExists(sFile) then begin
    Rewrite(FF);
  end else begin
    Rewrite(FF);
  end;
  Writeln(FF, FormatDateTime('dd/mm/yyyy hh:mm:ss', Now));
  CloseFile(FF);
end;

procedure Tvgad.DoConectarDBSistema;
begin
  //
  fdCia.Connected := False;
  with fdCia.Params do
  begin
    Clear;
    Add('DriverID=FB');
    Add('Database=' + 'C:\GADIDX\DATOS\SYSTEMS.WAS');
    Add('User_Name=SYSDBA');
    Add('Password=masterkey');
    Add('CharacterSet=UNICODE_FSS');
    Add('CreateDatabase=No');
    Add('ExtendedMetadata=True');
    Add('Server=' + '');
    Add('Protocol=' + 'LOCAL');
  end;
  fdCia.Open();
  cnDato.Close;

end;

procedure Tvgad.cnDatoAfterConnect(Sender: TObject);
begin
  qrSQL.SQL.Text := 'UPDATE PARAMETRO SET ULTIMA_FECHA_SERVIDOR = :FECHA';
  qrSQL.ParamByName('FECHA').AsDateTime := NOW;
  qrSQL.ExecSQL;
end;

procedure Tvgad.DoConectarDBDatos;
begin
  //
  // Vamos buscar la ruta de la base de datos de la primara compania
  qrCia.Close;
  qrCia.Open;
  //
  // Vamos asignar la ruta de la base de datos de la compania.
  cnDato.Connected := False;
  with cnDato.Params do
  begin
    Clear;
    Add('DriverID=FB');
    Add('Database='   + qrCia.FieldByName('RUTA_BASE_DATO').AsString);
    Add('User_Name=SYSDBA');
    Add('Password=masterkey');
    Add('Server='     + qrCia.FieldByName('SERVIDOR').AsString);
    Add('Protocol='   + qrCia.FieldByName('PROTOCOLO').AsString);
    Add('CreateDatabase=No');
    Add('ExtendedMetadata=True');
  end;
  cnDato.Open();
  qrCia.Close;
  fdCia.Close;
end;


end.