Definir Numero nStatusProcesso;
Definir alfa   aMensagemProcesso;

Definir Alfa   aResponse_JsonOutput;
Definir Alfa   aSql;
Definir Alfa   aAspaDupla;

Definir Numero nParam_CodEmp;
Definir Numero nParam_CodFil;
Definir Numero nParam_NumAne;
Definir Numero nParam_NumPfa;

Definir Alfa   aParam_CodEmp;
Definir Alfa   aParam_CodFil;
Definir Alfa   aParam_NumAne;
Definir Alfa   aParam_NumPfa;

Definir Interno.com.br.Soelx.Util.genericConsult WsgenericConsult;

Definir Funcao IniciaProcessamento();
Definir Funcao MontaResposta();
Definir Funcao BuscaDadosPrefatura();

aAspaDupla        = "\"";

IniciaProcessamento();

@------------------------------------------------------------------------------@
@----Função para iniciar a distribuição do processamento das informações-------@
@------------------------------------------------------------------------------@
Funcao IniciaProcessamento();{
  aResponse_JsonOutput = "";

  nStatusProcesso   = 1;
  aMensagemProcesso ="Processamento realizado com sucesso.";

  nParam_CodEmp=ListarItens.CodEmp;
  nParam_CodFil=ListarItens.CodFil;
  nParam_NumAne=ListarItens.NumAne;
  nParam_NumPfa=ListarItens.NumPfa;
  nParam_OffSet=ListarItens.OffSet;
  nParam_Limit =ListarItens.Limit;

  Se(nParam_Limit=0){
    nParam_Limit = 99999999;
  }

  Se((nParam_CodEmp=0) ou (nParam_CodFil=0) ou (nParam_NumAne=0) ou (nParam_NumPfa=0)){
    nStatusProcesso   = 0;
    aMensagemProcesso ="É necessário informar todos os parâmetros(codEmp,codFil,numAne,numPfa)";
  }


  Se(nStatusProcesso=1){
    BuscaDadosPrefatura();
  }

  MontaResposta();
}


@--Função que devolve o resultado do processamento dos dados de entrada--------@
Funcao MontaResposta();{
  Se(nStatusProcesso=1){
    ListarItens.JsonOutput     = aResponse_JsonOutput;
  }
  ListarItens.StatusProcesso   = nStatusProcesso;
  ListarItens.MensagemProcesso = aMensagemProcesso;
}

Funcao BuscaDadosPrefatura();{
  IntParaAlfa(nParam_CodEmp,aParam_CodEmp);
  IntParaAlfa(nParam_CodFil,aParam_CodFil);
  IntParaAlfa(nParam_NumAne,aParam_NumAne);
  IntParaAlfa(nParam_NumPfa,aParam_NumPfa);

  aSql = "select \
               e135pfa.codemp       as e135pfa_codemp,\
               e135pfa.codfil       as e135pfa_codfil,\
               e135pfa.numane       as e135pfa_numane,\
               e135pfa.numpfa       as e135pfa_numpfa,\
               e135pes.seqpes       as e135pes_seqpes,\
               e135pes.filped       as e135pes_filped,\
               e135pes.numped       as e135pes_numped,\
               e135pes.seqipd       as e135pes_seqipd,\
               e135pes.seqisp       as e135pes_seqisp,\
               e135pes.codpro       as e135pes_codpro,\
               e135pes.codder       as e135pes_codder,\
               e135pes.cplpes       as e135pes_cplpes,\
               e135pes.codfam       as e135pes_codfam,\
               e135pes.qtdped       as e135pes_qtdped,\
               e135pes.qtdppf       as e135pes_qtdppf,\
               e135pes.unimed       as e135pes_unimed,\
               e135pes.pesbru       as e135pes_pesbru,\
               e135pes.pesliq       as e135pes_pesliq,\
               e135pes.volpes       as e135pes_volpes,\
               e135pes.preuni       as e135pes_preuni,\
               e135pes.prebas       as e135pes_prebas,\
               e135pes.univen       as e135pes_univen,\
               e135pes.qtdven       as e135pes_qtdven,\
               coalesce((REGEXP_REPLACE(e120ipd.pedcli, '[^A-Za-z0-9 ]', '') || case when e120ipd.seqpcl <> ' '  then '/'|| e120ipd.seqpcl ELSE ' ' END),'')   as e120ped_pedcli,\
               e075ppc.procli       as e075ppc_procli,\
               e120ipd.usu_emicer   as e120ipd_emicer \
            from  e135pfa \
            inner join e135pes \
              on  e135pes.codemp = e135pfa.codemp \
              and e135pes.codfil = e135pfa.codfil \
              and e135pes.numane = e135pfa.numane \
              and e135pes.numpfa = e135pfa.numpfa \
            left join e120ped \
              on  e120ped.codemp = e135pes.codemp \
              and e120ped.codfil = e135pes.codfil \
              and e120ped.numped = e135pes.numped \
            left join e075ppc \
              on  e075ppc.codemp = e135pes.codemp \
              and e075ppc.codpro = e135pes.codpro \
              and e075ppc.codder = e135pes.codder \
              and e075ppc.codcli = e135pfa.codcli \
            left join e120ipd \
              on  e120ipd.codemp = e120ped.codemp \
              and e120ipd.codfil = e120ped.codfil \
              and e120ipd.numped = e120ped.numped \
              and e120ipd.seqipd = e135pes.seqipd \
            where e135pfa.codemp=1 \
            and   e135pfa.codfil=1 "+
         " and  (e135pfa.numane = "+ aParam_NumAne + ")" +
         " and  (e135pfa.numpfa = "+ aParam_NumPfa + ")" ;
  WsgenericConsult.queryCompleted = aSql;
  WsgenericConsult.Limit  = nParam_Limit;
  WsgenericConsult.OffSet = nParam_OffSet;
  WsgenericConsult.Executar();
  Se(WsgenericConsult.ErroExecucao <> ""){
    nStatusProcesso   =0;
    aMensagemProcesso =WsgenericConsult.ErroExecucao;
  }senao {
    aResponse_JsonOutput = WsgenericConsult.pmJsonResponse;
  }
}