Gestão de Processos Assíncronos

Definir Alfa xSQL;
Definir Alfa xIdentificador;
Definir Alfa xCur_Pedidos;
Definir Numero xQtdPendente;
Definir Alfa xIdentificadores;
Definir Alfa xIdentificadoresJSON;
Definir Alfa xJSON;
Definir Numero xQtdPedidosEnviar;
Definir Alfa xAbrFil;
Definir Numero xTamanho;
Definir Numero xErro;
Definir Alfa xMensagemErro;
Definir numero xIdePle;
Definir alfa aIdePle;
xIdentificadores = "";
xIdentificadoresJSON = "";
IntParaAlfa(CodFil, xAbrFil);
xQtdPedidosEnviar = 0; 
xSQL = "SELECT USU_IDENTF, USU_DATGER FROM USU_TPROCESSOS WHERE USU_TIPPROC = 
'P' AND USU_STATUS = 'P' ORDER BY USU_DATGER"; 
SQL_Criar(xCur_Pedidos);
SQL_DefinirComando(xCur_Pedidos, xSQL);
SQL_AbrirCursor(xCur_Pedidos);
/* Irá retornar todos os pedidos com status pendente de importação */
Enquanto (SQL_EOF(xCur_Pedidos) = 0)
Inicio 
 SQL_RetornarAlfa(xCur_Pedidos, "USU_IDENTF", xIdentificador); 
 xIdentificadores = xIdentificadores + "'" + xIdentificador + "',";
 xIdentificadoresJSON = xIdentificadoresJSON + xIdentificador + ","; 
 xQtdPedidosEnviar++; 
 Se (xQtdPedidosEnviar = 3) 
 Inicio
/* Aqui removemos a ultima virgula na string que serão os parâmetros, nesse caso não 
seria necessário utilizar os identificadores como parâmetros */ 
/* mas estou informando para manter a unicidade da requisição */
 TamanhoAlfa(xIdentificadores, xTamanho);
 xTamanho--;
 CopiarStr(xIdentificadores, 1, xTamanho); 
 TamanhoAlfa(xIdentificadoresJSON, xTamanho);
 xTamanho--;
 CopiarStr(xIdentificadoresJSON, 1, xTamanho);
 /* Parametros que são enviados para o webservice PS: DEVE ter o mesmo nome do 
parâmetro do WS */ 
 xJSON = "{\"Identificadores\": \""+xIdentificadoresJSON+"\"}"; 
 /* Gera a requisição que será enviada pro gerenciador assíncrono executar */ 
 AgendarExecucaoWebserviceEx(CodEmp, xAbrFil, "ainternal.custom.pedido.integrar", 
"executar", xJSON, xIdePle);
 IntParaAlfa(xIdePle, aIdePle);
 xSQL = "UPDATE USU_TPROCESSOS SET USU_IDEPLE = "+aIdePle+" WHERE USU_IDENTF in 
("+xIdentificadores+")";
 ExecSQLEX(xSQL, xErro, xMensagemErro); 
 xQuantidadeRequisicoesGerar--; 
 xQtdPedidosEnviar = 0; 
 xIdentificadores = ""; 
 xIdentificadoresJSON = ""; 
 Fim; 
 SQL_Proximo(xCur_Pedidos);
 
 Se ((SQL_EOF(xCur_Pedidos) <> 0) e (xQtdPedidosEnviar > 0))
 Inicio
 TamanhoAlfa(xIdentificadores, xTamanho);
 xTamanho--;
 CopiarStr(xIdentificadores, 1, xTamanho);
 TamanhoAlfa(xIdentificadoresJSON, xTamanho);
 xTamanho--;
 CopiarStr(xIdentificadoresJSON, 1, xTamanho); 
 /* Parametros que são enviados para o webservice PS: DEVE ter o mesmo nome do 
parâmetro do WS */
 xJSON = "{\"Identificadores\": \""+xIdentificadoresJSON+"\"}";
 /* Gera a requisição que será enviada pro gerenciador assíncrono executar */ 
 AgendarExecucaoWebserviceEx(CodEmp, xAbrFil, "", "", xJSON, xIdePle);
 ExecSQLEX("UPDATE USU_TPROCESSOS SET USU_IDEPLE = :xIdePle WHERE USU_IDENTF in 
(:xIdentificadores)", xErro, xMensagemErro); 
 xQtdPedidosEnviar = 0; 
 xIdentificadores = ""; 
 xIdentificadoresJSON = ""; 
 Fim; 
Fim;
SQL_FecharCursor(xCur_Pedidos);
SQL_Destruir(xCur_Pedidos);

definir alfa xIdentificador;
definir numero xQuantidade;
definir numero xLinhaAtual;
Definir alfa xMensagemErro; 
definir alfa xCursorDados;
Definir Numero xErro;
Definir Numero nIdentificador; 
Definir Alfa xStatus;
Definir Alfa xIdePle;
Definir Numero nIdePle;
Definir Alfa xSQL;
Definir Alfa xCursor;
Definir alfa xMensagem;
 
definir interno.com.senior.g5.co.mcm.ven.pedidos.GravarPedidos_13 wsped;
nIdePle = executar.IdePle;
IntParaAlfa(nIdePle, xIdePle);
xLinhaAtual = 0;
/* Altera o status da requisição pra Em Andamento, permitindo que saia da fila de execução */
AlterarStatusPlanoExecucao(nIdePle, 2); 
/* Altera o status na tabela de pedido indicando que os pedidos estão em processamento */
xSQL = "UPDATE USU_TPROCESSOS SET USU_STATUS = 'EP', USU_DATINI = GETDATE() WHERE 
USU_IDEPLE = "+ xIdePle; 
ExecSQLEX(xSQL, xErro, xMensagemErro);
/* Recupera todos os pedidos que serão processados naquela requisição */
xSQL = "SELECT * FROM USU_TPROCESSOS WHERE USU_IDEPLE = " +xIdePle;
SQL_Criar(xCursor);
SQL_DefinirComando(xCursor, xSQL);
SQL_AbrirCursor(xCursor);
/* Adicionar um passo de execução do pedido que está sendo integrado */
InserirPassoPlanoExecucao(nIdePle, "Carregando pedidos...");
Enquanto (SQL_EOF(xCursor) = 0)
inicio
 /* Adiciona na grid do WS interno os pedidos que serão integrados */
 SQL_RetornarAlfa(xCursor, "USU_IDENTF", xIdentificador); 
 wsped.Pedido.CriarLinha();
 wsped.Pedido.opeExe = "1";
 wsped.Pedido.CodEmp = 1;
 wsped.Pedido.CodFil = 1;
 wsped.Pedido.NumPed = 5;
 wsped.Pedido.IdeExt = xIdentificador;
 xLinhaAtual++; 
 SQL_Proximo(xCursor);
fim;
SQL_FecharCursor(xCursor);
SQL_Destruir(xCursor);
Se (wsped.Pedido.QtdLinhas > 0)
Inicio
 /* Adicionar um passo de execução do pedido que está sendo integrado */
 InserirPassoPlanoExecucao(nIdePle, "Executando importação do pedido");
 wsped.modoExecucao = 1; 
 wsped.executar(); 
 
 xLinhaAtual = 0; 
 xQuantidade = wsped.respostaPedido.QtdLinhas; 
 Enquanto (xLinhaAtual < xQuantidade)
 Inicio
 wsped.respostaPedido.LinhaAtual = xLinhaAtual; 
 
 nIdentificador = wsped.respostaPedido.IdeExt; 
 IntParaAlfa(nIdentificador, xIdentificador);
 
 Se (wsped.respostaPedido.tipRet = 1)
 Inicio 
 xMensagem = "Pedido id "+ xIdentificador+" importado com sucesso"; 
 /* Adicionar um passo de execução do pedido que está sendo integrado */ 
 InserirPassoPlanoExecucao(nIdePle, xMensagem); 
 xStatus = "C"; 
 xMensagemErro = "OK";
 Fim
 Senao
 Inicio
 xStatus = "E";
 xMensagem = "Pedido id "+ xIdentificador+" importado com erro. Mensagem: " + 
wsped.respostaPedido.retorno; 
 /* Adicionar um passo de execução do pedido que está sendo integrado */ 
 InserirPassoPlanoExecucao(nIdePle, xMensagem); 
 Fim; 
 xSQL = "UPDATE USU_TPROCESSOS SET USU_STATUS = :xStatus, USU_DATINI = GETDATE(), 
USU_MSGLOG = :xMensagemErro WHERE USU_IDEPLE =" + xIdentificador; 
 ExecSQLEX(xSQL, xErro, xMensagemErro); 
 xLinhaAtual++; 
 Fim;
Fim;
/* Altera o status da requisição pra Finalizado */
AlterarStatusPlanoExecucao(nIdePle, 3);