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);
    }
  }
}