Linha RM

Atalhos

Páginas filhas
  • Integração RM x SmartLink Behavior Sharing - Visão desenvolvedor

Versões comparadas

Versão antiga 27

changes.mady.by.user Erlon Cesar Lima De Freitas

Gravado em

comparado com

Nova versão 28

changes.mady.by.user Erlon Cesar Lima De Freitas

Gravado em

Chave

  • Esta linha foi adicionada.
  • Esta linha foi removida.
  • A formatação mudou.

...

  1. Criar um projeto (classLibrary .NET) na solution do segmento em questão, com o seguinte padrão de nome: RM.[Segmento].XXX.SmartLink.Service.
    1. Exemplo: RM.Glb.SGDP.SmartLink.Service.dll
  2. Adicionar referência para a dll "RM.Lib.SmartLink.dll";

  3. Criar uma classe herdando da ancestral "RMSSmartLinkConsumerMessageBase".

  4. A classe "RMSSmartLinkConsumerMessageBase" herda da classe RMSObject da Lib. Consequentemente, as classes de "consumers" poderão chamar os métodos "CreateFacade" e "CreateModule" dentro de suas estruturas.

  5. Carimbar a classe com o atributo "RMSSmartLinkConsumerMessageAttr". Nesse atributo, devem ser informados os dados abaixo:

    PropriedadeDescrição
    Cod.SistemaIdentificador da aplicação
    ComandoNome do Comando da mensagem

  6. Código fonte de exemplo (extraído da classe "GlbSGDPConsumerDataCommandMessage" localizada na solution de Globais, projeto "RM.Glb.SGDP.SmartLink.Service":

    Bloco de código
    languagec#
    firstline1
    linenumberstrue
    using RM.Glb.SGDP.SmartLink.Service.Domain.Interfaces;
using RM.Lib;
using RM.Lib.SmartLink.Domain;
using RM.Lib.SmartLink.Domain.Consumer;
using RM.Lib.SmartLink.Domain.Interfaces;
using RM.Lib.SmartLink.Domain.Publisher;
using System;
using System.Runtime.Serialization;

namespace RM.Glb.SGDP.SmartLink.Service.Domain
{
  /// <summary>
  /// Regras de implementação do mecanismo de processamento da mensagem SGDDataCommand do SGDP
  /// </summary>
  [RMSSmartLinkConsumerMessageAttr(CodSistema.Glb, "SGDPDataCommand")]
  public class GlbSGDPConsumerDataCommandMessage : RMSSmartLinkConsumerMessageBase
  {
    protected override ConsumerMessageExecuteResult DoExecute(string message)
    {
      logService.NotifyLogInfo(Properties.Resources.sconTotvsAppInicioExecucaoDoConsumerSGDPDataCommandConsumer);
      ConsumerMessageExecuteResult result = new ConsumerMessageExecuteResult();
      IGlbSGDPResolverService resolver = GlbSGDPResolveFactory.NewSGDPResolve(this.DBS, this.logService);
      IRMSSmartLinkPublisherService smartLinkPublisherService = RMSSmartLinkPublisherFactory.NewSmartLinkPublisher(this.DBS, this.logService);
      IGlbSGDPPublisherMessageService publisher = new GlbSGDPPublisherMessageService(smartLinkPublisherService, resolver, logService);

      ExecuteDataCommandParms par = new ExecuteDataCommandParms();
      par.Message = message;
      try
      {
        var execDataResult = resolver.ExecuteSGDPDataCommand(par);
        logService.NotifyLogInfo(Properties.Resources.sconTotvsAppJSonSGDPDataResponseCommandForamGerados, "Quantidade JSons Gerados", execDataResult?.JsonResults?.Count);
        result.CorrelatedID = execDataResult.RequestId;
        if (execDataResult?.JsonResults != null)
        {
          foreach (var jsonResult in execDataResult.JsonResults)
          {
            AddResponseDataCommandParms parResponse = new AddResponseDataCommandParms();
            parResponse.Message = jsonResult;
            parResponse.CorrelatedId = execDataResult.RequestId;
            publisher.AddResponseDataCommand(parResponse);
          }
        }
      }
      catch(Exception ex)
      {
        logService.NotifyLogError(new GlbSGDPConsumerDataCommandMessageException(
          Properties.Resources.sconTotvsAppErroAoProcessarSGDDataCommand, ex));
      }
      logService.NotifyLogInfo(Properties.Resources.sconTotvsAppFimExecucaoDoConsumerSGDPDataCommandConsumer);
      return result;
    }
  }

  [Serializable]
  public class GlbSGDPConsumerDataCommandMessageException : RMSApplicationException
  {
    public GlbSGDPConsumerDataCommandMessageException() : base()
    {
    }

    public GlbSGDPConsumerDataCommandMessageException(string message) : base(message)
    {
    }

    public GlbSGDPConsumerDataCommandMessageException(string message, Exception ex) : base(message, ex, string.Empty)
    {
    }

    public GlbSGDPConsumerDataCommandMessageException(SerializationInfo info, StreamingContext context)
  : base(info, context)
    {
    }
  }
}

...

Caso ocorra erro na execução de alguma mensagem, a mesma poderá ser executada novamente. A quantidade de tentativas de execução é parametrizada no json de configurações genérico da integração TotvsApp. Esse json, chamado "totvsAppConfig_v2.json",  está localizado no plataforma GCP (Google Cloud Platform).

Essa configuração está localizada no atributo "TotvsAppGlobalConfig.IntegrationSmartLinkInfo.QtdeTentativasExec".

A hora de execução dessa próxima tentativa de execução é calculada baseado em algumas informações conforme os atributos abaixo:



...