From 02c19c963ec25252ba0d88d99c65655156a6f9e9 Mon Sep 17 00:00:00 2001 From: taskain7 Date: Mon, 22 Aug 2022 03:03:47 +0200 Subject: [PATCH] [FINERACT-1678] Job execution listeners --- .../listener/COBExecutionListenerRunner.java | 70 +++++++++++++++++++ .../listener/FineractCOBAfterJobListener.java | 28 ++++++++ .../FineractCOBBeforeJobListener.java | 28 ++++++++ .../cob/loan/LoanCOBManagerConfiguration.java | 10 ++- 4 files changed, 135 insertions(+), 1 deletion(-) create mode 100644 fineract-provider/src/main/java/org/apache/fineract/cob/listener/COBExecutionListenerRunner.java create mode 100644 fineract-provider/src/main/java/org/apache/fineract/cob/listener/FineractCOBAfterJobListener.java create mode 100644 fineract-provider/src/main/java/org/apache/fineract/cob/listener/FineractCOBBeforeJobListener.java diff --git a/fineract-provider/src/main/java/org/apache/fineract/cob/listener/COBExecutionListenerRunner.java b/fineract-provider/src/main/java/org/apache/fineract/cob/listener/COBExecutionListenerRunner.java new file mode 100644 index 000000000..36569a366 --- /dev/null +++ b/fineract-provider/src/main/java/org/apache/fineract/cob/listener/COBExecutionListenerRunner.java @@ -0,0 +1,70 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package org.apache.fineract.cob.listener; + +import java.util.ArrayList; +import java.util.Arrays; +import java.util.List; +import org.springframework.batch.core.JobExecution; +import org.springframework.batch.core.JobExecutionListener; +import org.springframework.context.ApplicationContext; + +public class COBExecutionListenerRunner implements JobExecutionListener { + + private final List beforeJobListeners = new ArrayList<>(); + private final List afterJobListeners = new ArrayList<>(); + + public COBExecutionListenerRunner(ApplicationContext applicationContext, String jobName) { + addBeforeListeners(applicationContext, jobName); + addAfterListeners(applicationContext, jobName); + } + + @Override + public void beforeJob(JobExecution jobExecution) { + beforeJobListeners.forEach(beforeJobListener -> beforeJobListener.beforeJob(jobExecution)); + } + + @Override + public void afterJob(JobExecution jobExecution) { + afterJobListeners.forEach(afterJobListener -> afterJobListener.afterJob(jobExecution)); + } + + private void addAfterListeners(ApplicationContext applicationContext, String jobName) { + List afterListenerClassNames = Arrays.stream(applicationContext.getBeanNamesForType(FineractCOBAfterJobListener.class)) + .toList(); + for (String afterListenerClassName : afterListenerClassNames) { + FineractCOBAfterJobListener afterListener = (FineractCOBAfterJobListener) applicationContext.getBean(afterListenerClassName); + if (jobName.equals(afterListener.getJobName())) { + afterJobListeners.add(afterListener); + } + } + } + + private void addBeforeListeners(ApplicationContext applicationContext, String jobName) { + List beforeListenerClassNames = Arrays.stream(applicationContext.getBeanNamesForType(FineractCOBBeforeJobListener.class)) + .toList(); + for (String beforeListenerClassName : beforeListenerClassNames) { + FineractCOBBeforeJobListener beforeListener = (FineractCOBBeforeJobListener) applicationContext + .getBean(beforeListenerClassName); + if (jobName.equals(beforeListener.getJobName())) { + beforeJobListeners.add(beforeListener); + } + } + } +} diff --git a/fineract-provider/src/main/java/org/apache/fineract/cob/listener/FineractCOBAfterJobListener.java b/fineract-provider/src/main/java/org/apache/fineract/cob/listener/FineractCOBAfterJobListener.java new file mode 100644 index 000000000..feb7cf319 --- /dev/null +++ b/fineract-provider/src/main/java/org/apache/fineract/cob/listener/FineractCOBAfterJobListener.java @@ -0,0 +1,28 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package org.apache.fineract.cob.listener; + +import org.springframework.batch.core.JobExecution; + +public interface FineractCOBAfterJobListener { + + void afterJob(JobExecution jobExecution); + + String getJobName(); +} diff --git a/fineract-provider/src/main/java/org/apache/fineract/cob/listener/FineractCOBBeforeJobListener.java b/fineract-provider/src/main/java/org/apache/fineract/cob/listener/FineractCOBBeforeJobListener.java new file mode 100644 index 000000000..4261b05f8 --- /dev/null +++ b/fineract-provider/src/main/java/org/apache/fineract/cob/listener/FineractCOBBeforeJobListener.java @@ -0,0 +1,28 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package org.apache.fineract.cob.listener; + +import org.springframework.batch.core.JobExecution; + +public interface FineractCOBBeforeJobListener { + + void beforeJob(JobExecution jobExecution); + + String getJobName(); +} diff --git a/fineract-provider/src/main/java/org/apache/fineract/cob/loan/LoanCOBManagerConfiguration.java b/fineract-provider/src/main/java/org/apache/fineract/cob/loan/LoanCOBManagerConfiguration.java index 30a91ee59..807f45d50 100644 --- a/fineract-provider/src/main/java/org/apache/fineract/cob/loan/LoanCOBManagerConfiguration.java +++ b/fineract-provider/src/main/java/org/apache/fineract/cob/loan/LoanCOBManagerConfiguration.java @@ -20,6 +20,7 @@ package org.apache.fineract.cob.loan; import org.apache.fineract.cob.COBBusinessStepService; import org.apache.fineract.cob.COBPropertyService; +import org.apache.fineract.cob.listener.COBExecutionListenerRunner; import org.apache.fineract.infrastructure.jobs.service.JobName; import org.apache.fineract.portfolio.loanaccount.domain.LoanRepository; import org.springframework.batch.core.Job; @@ -32,6 +33,7 @@ import org.springframework.batch.integration.config.annotation.EnableBatchIntegr import org.springframework.batch.integration.partition.RemotePartitioningManagerStepBuilderFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; +import org.springframework.context.ApplicationContext; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.integration.channel.DirectChannel; @@ -58,6 +60,8 @@ public class LoanCOBManagerConfiguration { private JobOperator jobOperator; @Autowired private JobExplorer jobExplorer; + @Autowired + private ApplicationContext applicationContext; @Bean public LoanCOBPartitioner partitioner() { @@ -72,7 +76,11 @@ public class LoanCOBManagerConfiguration { @Bean(name = "loanCOBJob") public Job loanCOBJob() { - return jobBuilderFactory.get(JobName.LOAN_COB.name()).start(loanCOBStep()).incrementer(new RunIdIncrementer()).build(); + return jobBuilderFactory.get(JobName.LOAN_COB.name()) // + .listener(new COBExecutionListenerRunner(applicationContext, JobName.LOAN_COB.name())) // + .start(loanCOBStep()) // + .incrementer(new RunIdIncrementer()) // + .build(); } }