using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Drawing;
using RM.Lib.WinForms;
using RM.Lib.Workflow;
using RM.Lib;
using System.Data;

namespace RM.ExemploAtividadeCustom
{
  [RMSDescription(typeof(Properties.Resources), "sActivityTeste")]
  [RMSActivityCategory(typeof(Properties.Resources), "sCategoryIntegracao")]
  public class ConTotvsMessageActivity : RMSActivity
  {
    //Implementação da regra de execução da atividade de FV.
    protected override void OnExecute()
    {
      // verifica se o serviço esta disponível...
      if (this.BrokerService == null)
        throw new RMSWorkflowException("Serviço não disponível!");

      //Cria uma nova instancia do DataServer gerado pela ferramenta de medatados.
      //No exemplo abaixo, foi gerado o dataServer de metadados "RMSPRJ3249920Server". O nome desse dataserver 
      //poderá ser consultado no arquivo "_Broker.dat" localizado dentro do diretório de instalação das dlls do Rm.
      IRMSDataServer dataServerProduto = (IRMSDataServer)this.BrokerService.CreateServer("RMSPRJ3249920Server");

      //Cria uma instancia da classe RMSContext para informar a coligada e usuario.
      RMSContext context = new RMSContext();
      context.CodColigada = 1;
      context.CodUsuario = "mestre";

      //Objeto ownerData em caso de existencia do mesmo em um dataServer.
      object ownerData = null;

      //Exemplo de filtro a ser enviado para o método readView.
      string filter = "Codigo like '%000%' ";

      //Leitura da visão dos dados.
      //Método READVIEW: Esse método retornará os dados fornecidos pelo DataServer através do filtro passado
      //e contexto. Esse método é o mesmo que é executado em todas as visões do RM.
      DataSet dsView = dataServerProduto.ReadView(context, new object[] { filter }, ownerData);
      if (dsView.Tables[0].Rows.Count == 3)
        RM.Lib.RMSException.Throw("Foram encontrados 3 registros!");

      //Inclusão de um novo registro
      //Busca um registro inexistente.
      DataSet dsNewRecord = dataServerProduto.ReadRecord(context, null, ownerData);

      //Preenche os dados do registro.
      DataRow r = dsNewRecord.Tables[0].NewRow();
      r["CodColigada"] = "1";
      r["Id"] = "1";
      r["Codigo"] = "00010";
      r["Descricao"] = "Produto teste";
      dsNewRecord.Tables[0].Rows.Add(r);
      //Executa o método abaixo para enviar o registro para o DataServer
      dataServerProduto.SaveRecord(context, ref dsNewRecord, ownerData);

      //READRECORD: Esse método retornará apenas um registro. Esse método é o mesmo que é executado ao realizar a edição 
      //ou inclusão de um novo registro.Ele retornará o registro com as seguintes chaves:
      //CodColigada = 1 e Id = 1
      DataSet dsRecord = dataServerProduto.ReadRecord(context, new object[] { 1, 1 }, ownerData);
      if (dsRecord.Tables[0].Rows.Count == 0)
        RM.Lib.RMSException.Throw("Registro não encontrado!");

      //Realiza uma alteração no registro,,,
      dsRecord.Tables[0].Rows[0]["Descricao"] = "Produto teste alterado";
      //Executa o método abaixo para enviar o registro para o DataServer
      dataServerProduto.SaveRecord(context, ref dsRecord, ownerData);

      //Execlui o registro.
      dsRecord.Tables[0].Rows[0].Delete();
      dataServerProduto.SaveRecord(context, ref dsRecord, ownerData);
    }
  }
}

Esse exemplo foi criado utilizando um dataServer simples criado através do recurso de Metadados do RM.
Lembrando que ao utilizar esse mesmo exemplo com algum outro dataServer do RM, poderão existir particularidades que impeça correto funcionamento do exemplo.
Logo, não garantimos que o exemplo se aplicará em qualquer dataServer do RM.
Lembrando também que a construção de uma atividade customizada é de total responsabilidade do cliente.

Ao executar o SaveRecord os registros serão, Inseridos, Atualizados ou Removidos de acordo com o rowState do DataSet informado no SaveRecord.