Detalhamento:
Descritivo sobre o funcionamento do serviço Rating Service.
Fluxo do Processo
JOB
- Configurações de scheduler de processamento e diretórios de processamento, serão via banco de dados.
- Também será configurado a quantidade de arquivos simultâneos a serem processados no job.
KAFKA
- Kafka, permitirá multiprocessos para persistência dos dados do arquivo.
- Utilização do Kafka será mediante a configuração, o serviço pode ser utilizado sem Kafka
ShedLock Spring
- ShedLock, permite que o RatingService seja executado simultaneamente em mais de um servidor
Processo de Importação
Processo de Importação dos arquivos NCRF e CADOC3040.
O processo de importação utiliza dois jobs de execução automática, um para cada tipo de arquivo(3040 e NCR). Cada job possui uma linha de configuração na tabela t425sist, onde está configurado o diretório onde o serviço irá buscar os arquivos a serem importados. Para a configuração do agendamento da execução que utiliza uma notação “cron”, será utilizado a coluna ds_cron da tabela t425sist.
Para identificar a configuração na tabela T425CFIT, é utilizado a coluna ID_TP_ITF, onde ‘N’ corresponde a configuração do job para NCRCF e ‘C’ corresponde a configuração do job para 3040.
- Jobs configurados para executar a cada 10 segundos.
select ds_cron from t425sist
- Diretórios configurados para utilização dos Jobs..
select cd_emp, sg_itf, de_itf, nm_dir from t425cfit
where sg_itf in ('CD', 'NC')
Configurações>>Configurações de Interface ---- Em desenvolvimento
Alterar a frequência de execução dos Jobs.
Forma de Importação
A importação se dará da seguinte forma:
- Após iniciado o serviço, os jobs serão executados conforme a configuração obtida na coluna ds_cron. O agendamento do job é carregado uma única vez, ou seja, caso seja necessário alterar o agendamento em ds_cron, será necessário reiniciar o serviço.
- Ao identificar um arquivo no diretório, configurado em nm_dir, o job inicia o processamento movendo o arquivo para a subpasta chamada PROCESSANDO.
- Após o processo de importação, o arquivo será movido para a subpasta SUCESSO, ou, em caso de erro na importação, movido para a subpasta ERRO.
- Não é necessário criar a estrutura de pastas, o serviço irá criar as pastas, incluindo o diretório configurado na tabela t425cfit, caso os mesmos não existam.
Serviço com KAFKA
A utilização do Kafka no serviço é parametrizada, ou seja, o serviço pode ser utilizado com ou sem a utilização do Kafka.
- O Kafka deve estar previamente instalado e em funcionamento, caso contrário será exibido erro de comunicação no log do ratingService.
- Para ativar o uso do Kafka é necessário alterar, na base de dados do Rating, a coluna t425sist.id_kfk para ‘S’.
Exemplo:
update t425sist set id_kfk = 'S'