Skip to content

M
managePayees
Commit 5ba69672 authored by Tulasi Naveen Nadella's avatar Tulasi Naveen Nadella
Browse files
Options

Manage Payees v1

parents
Hide whitespace changes
Inline Side-by-side
Showing with 1634 additions and 0 deletions
.gitignore 0 → 100644
View file @ 5ba69672
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
.mvn/wrapper/maven-wrapper.properties 0 → 100644
View file @ 5ba69672
# 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
#
# https://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.
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.7/apache-maven-3.8.7-bin.zip
wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.1/maven-wrapper-3.1.1.jar
mvnw 0 → 100644
View file @ 5ba69672
#!/bin/sh
# ----------------------------------------------------------------------------
# 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
#
# https://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.
# ----------------------------------------------------------------------------
# ----------------------------------------------------------------------------
# Maven Start Up Batch script
#
# Required ENV vars:
# ------------------
# JAVA_HOME - location of a JDK home dir
#
# Optional ENV vars
# -----------------
# M2_HOME - location of maven2's installed home dir
# MAVEN_OPTS - parameters passed to the Java VM when running Maven
# e.g. to debug Maven itself, use
# set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
# MAVEN_SKIP_RC - flag to disable loading of mavenrc files
# ----------------------------------------------------------------------------
if [ -z "$MAVEN_SKIP_RC" ] ; then
if [ -f /usr/local/etc/mavenrc ] ; then
. /usr/local/etc/mavenrc
fi
if [ -f /etc/mavenrc ] ; then
. /etc/mavenrc
fi
if [ -f "$HOME/.mavenrc" ] ; then
. "$HOME/.mavenrc"
fi
fi
# OS specific support. $var _must_ be set to either true or false.
cygwin=false;
darwin=false;
mingw=false
case "`uname`" in
CYGWIN*) cygwin=true ;;
MINGW*) mingw=true;;
Darwin*) darwin=true
# Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home
# See https://developer.apple.com/library/mac/qa/qa1170/_index.html
if [ -z "$JAVA_HOME" ]; then
if [ -x "/usr/libexec/java_home" ]; then
export JAVA_HOME="`/usr/libexec/java_home`"
else
export JAVA_HOME="/Library/Java/Home"
fi
fi
;;
esac
if [ -z "$JAVA_HOME" ] ; then
if [ -r /etc/gentoo-release ] ; then
JAVA_HOME=`java-config --jre-home`
fi
fi
if [ -z "$M2_HOME" ] ; then
## resolve links - $0 may be a link to maven's home
PRG="$0"
# need this for relative symlinks
while [ -h "$PRG" ] ; do
ls=`ls -ld "$PRG"`
link=`expr "$ls" : '.*-> \(.*\)$'`
if expr "$link" : '/.*' > /dev/null; then
PRG="$link"
else
PRG="`dirname "$PRG"`/$link"
fi
done
saveddir=`pwd`
M2_HOME=`dirname "$PRG"`/..
# make it fully qualified
M2_HOME=`cd "$M2_HOME" && pwd`
cd "$saveddir"
# echo Using m2 at $M2_HOME
fi
# For Cygwin, ensure paths are in UNIX format before anything is touched
if $cygwin ; then
[ -n "$M2_HOME" ] &&
M2_HOME=`cygpath --unix "$M2_HOME"`
[ -n "$JAVA_HOME" ] &&
JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
[ -n "$CLASSPATH" ] &&
CLASSPATH=`cygpath --path --unix "$CLASSPATH"`
fi
# For Mingw, ensure paths are in UNIX format before anything is touched
if $mingw ; then
[ -n "$M2_HOME" ] &&
M2_HOME="`(cd "$M2_HOME"; pwd)`"
[ -n "$JAVA_HOME" ] &&
JAVA_HOME="`(cd "$JAVA_HOME"; pwd)`"
fi
if [ -z "$JAVA_HOME" ]; then
javaExecutable="`which javac`"
if [ -n "$javaExecutable" ] && ! [ "`expr \"$javaExecutable\" : '\([^ ]*\)'`" = "no" ]; then
# readlink(1) is not available as standard on Solaris 10.
readLink=`which readlink`
if [ ! `expr "$readLink" : '\([^ ]*\)'` = "no" ]; then
if $darwin ; then
javaHome="`dirname \"$javaExecutable\"`"
javaExecutable="`cd \"$javaHome\" && pwd -P`/javac"
else
javaExecutable="`readlink -f \"$javaExecutable\"`"
fi
javaHome="`dirname \"$javaExecutable\"`"
javaHome=`expr "$javaHome" : '\(.*\)/bin'`
JAVA_HOME="$javaHome"
export JAVA_HOME
fi
fi
fi
if [ -z "$JAVACMD" ] ; then
if [ -n "$JAVA_HOME" ] ; then
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
# IBM's JDK on AIX uses strange locations for the executables
JAVACMD="$JAVA_HOME/jre/sh/java"
else
JAVACMD="$JAVA_HOME/bin/java"
fi
else
JAVACMD="`\\unset -f command; \\command -v java`"
fi
fi
if [ ! -x "$JAVACMD" ] ; then
echo "Error: JAVA_HOME is not defined correctly." >&2
echo " We cannot execute $JAVACMD" >&2
exit 1
fi
if [ -z "$JAVA_HOME" ] ; then
echo "Warning: JAVA_HOME environment variable is not set."
fi
CLASSWORLDS_LAUNCHER=org.codehaus.plexus.classworlds.launcher.Launcher
# traverses directory structure from process work directory to filesystem root
# first directory with .mvn subdirectory is considered project base directory
find_maven_basedir() {
if [ -z "$1" ]
then
echo "Path not specified to find_maven_basedir"
return 1
fi
basedir="$1"
wdir="$1"
while [ "$wdir" != '/' ] ; do
if [ -d "$wdir"/.mvn ] ; then
basedir=$wdir
break
fi
# workaround for JBEAP-8937 (on Solaris 10/Sparc)
if [ -d "${wdir}" ]; then
wdir=`cd "$wdir/.."; pwd`
fi
# end of workaround
done
echo "${basedir}"
}
# concatenates all lines of a file
concat_lines() {
if [ -f "$1" ]; then
echo "$(tr -s '\n' ' ' < "$1")"
fi
}
BASE_DIR=`find_maven_basedir "$(pwd)"`
if [ -z "$BASE_DIR" ]; then
exit 1;
fi
##########################################################################################
# Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
# This allows using the maven wrapper in projects that prohibit checking in binary data.
##########################################################################################
if [ -r "$BASE_DIR/.mvn/wrapper/maven-wrapper.jar" ]; then
if [ "$MVNW_VERBOSE" = true ]; then
echo "Found .mvn/wrapper/maven-wrapper.jar"
fi
else
if [ "$MVNW_VERBOSE" = true ]; then
echo "Couldn't find .mvn/wrapper/maven-wrapper.jar, downloading it ..."
fi
if [ -n "$MVNW_REPOURL" ]; then
jarUrl="$MVNW_REPOURL/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
else
jarUrl="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
fi
while IFS="=" read key value; do
case "$key" in (wrapperUrl) jarUrl="$value"; break ;;
esac
done < "$BASE_DIR/.mvn/wrapper/maven-wrapper.properties"
if [ "$MVNW_VERBOSE" = true ]; then
echo "Downloading from: $jarUrl"
fi
wrapperJarPath="$BASE_DIR/.mvn/wrapper/maven-wrapper.jar"
if $cygwin; then
wrapperJarPath=`cygpath --path --windows "$wrapperJarPath"`
fi
if command -v wget > /dev/null; then
if [ "$MVNW_VERBOSE" = true ]; then
echo "Found wget ... using wget"
fi
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
wget "$jarUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath"
else
wget --http-user=$MVNW_USERNAME --http-password=$MVNW_PASSWORD "$jarUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath"
fi
elif command -v curl > /dev/null; then
if [ "$MVNW_VERBOSE" = true ]; then
echo "Found curl ... using curl"
fi
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
curl -o "$wrapperJarPath" "$jarUrl" -f
else
curl --user $MVNW_USERNAME:$MVNW_PASSWORD -o "$wrapperJarPath" "$jarUrl" -f
fi
else
if [ "$MVNW_VERBOSE" = true ]; then
echo "Falling back to using Java to download"
fi
javaClass="$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.java"
# For Cygwin, switch paths to Windows format before running javac
if $cygwin; then
javaClass=`cygpath --path --windows "$javaClass"`
fi
if [ -e "$javaClass" ]; then
if [ ! -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
if [ "$MVNW_VERBOSE" = true ]; then
echo " - Compiling MavenWrapperDownloader.java ..."
fi
# Compiling the Java class
("$JAVA_HOME/bin/javac" "$javaClass")
fi
if [ -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
# Running the downloader
if [ "$MVNW_VERBOSE" = true ]; then
echo " - Running MavenWrapperDownloader.java ..."
fi
("$JAVA_HOME/bin/java" -cp .mvn/wrapper MavenWrapperDownloader "$MAVEN_PROJECTBASEDIR")
fi
fi
fi
fi
##########################################################################################
# End of extension
##########################################################################################
export MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"}
if [ "$MVNW_VERBOSE" = true ]; then
echo $MAVEN_PROJECTBASEDIR
fi
MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS"
# For Cygwin, switch paths to Windows format before running java
if $cygwin; then
[ -n "$M2_HOME" ] &&
M2_HOME=`cygpath --path --windows "$M2_HOME"`
[ -n "$JAVA_HOME" ] &&
JAVA_HOME=`cygpath --path --windows "$JAVA_HOME"`
[ -n "$CLASSPATH" ] &&
CLASSPATH=`cygpath --path --windows "$CLASSPATH"`
[ -n "$MAVEN_PROJECTBASEDIR" ] &&
MAVEN_PROJECTBASEDIR=`cygpath --path --windows "$MAVEN_PROJECTBASEDIR"`
fi
# Provide a "standardized" way to retrieve the CLI args that will
# work with both Windows and non-Windows executions.
MAVEN_CMD_LINE_ARGS="$MAVEN_CONFIG $@"
export MAVEN_CMD_LINE_ARGS
WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
exec "$JAVACMD" \
$MAVEN_OPTS \
$MAVEN_DEBUG_OPTS \
-classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \
"-Dmaven.home=${M2_HOME}" \
"-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \
${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@"
mvnw.cmd 0 → 100644
View file @ 5ba69672
@REM ----------------------------------------------------------------------------
@REM Licensed to the Apache Software Foundation (ASF) under one
@REM or more contributor license agreements. See the NOTICE file
@REM distributed with this work for additional information
@REM regarding copyright ownership. The ASF licenses this file
@REM to you under the Apache License, Version 2.0 (the
@REM "License"); you may not use this file except in compliance
@REM with the License. You may obtain a copy of the License at
@REM
@REM https://www.apache.org/licenses/LICENSE-2.0
@REM
@REM Unless required by applicable law or agreed to in writing,
@REM software distributed under the License is distributed on an
@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@REM KIND, either express or implied. See the License for the
@REM specific language governing permissions and limitations
@REM under the License.
@REM ----------------------------------------------------------------------------
@REM ----------------------------------------------------------------------------
@REM Maven Start Up Batch script
@REM
@REM Required ENV vars:
@REM JAVA_HOME - location of a JDK home dir
@REM
@REM Optional ENV vars
@REM M2_HOME - location of maven2's installed home dir
@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
@REM e.g. to debug Maven itself, use
@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
@REM ----------------------------------------------------------------------------
@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
@echo off
@REM set title of command window
title %0
@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO%
@REM set %HOME% to equivalent of $HOME
if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
@REM Execute a user defined script before this one
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
@REM check for pre script, once with legacy .bat ending and once with .cmd ending
if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
:skipRcPre
@setlocal
set ERROR_CODE=0
@REM To isolate internal variables from possible post scripts, we use another setlocal
@setlocal
@REM ==== START VALIDATION ====
if not "%JAVA_HOME%" == "" goto OkJHome
echo.
echo Error: JAVA_HOME not found in your environment. >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
:OkJHome
if exist "%JAVA_HOME%\bin\java.exe" goto init
echo.
echo Error: JAVA_HOME is set to an invalid directory. >&2
echo JAVA_HOME = "%JAVA_HOME%" >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
@REM ==== END VALIDATION ====
:init
@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
@REM Fallback to current working directory if not found.
set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
set EXEC_DIR=%CD%
set WDIR=%EXEC_DIR%
:findBaseDir
IF EXIST "%WDIR%"\.mvn goto baseDirFound
cd ..
IF "%WDIR%"=="%CD%" goto baseDirNotFound
set WDIR=%CD%
goto findBaseDir
:baseDirFound
set MAVEN_PROJECTBASEDIR=%WDIR%
cd "%EXEC_DIR%"
goto endDetectBaseDir
:baseDirNotFound
set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
cd "%EXEC_DIR%"
:endDetectBaseDir
IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
@setlocal EnableExtensions EnableDelayedExpansion
for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
:endReadAdditionalConfig
SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
)
@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
if exist %WRAPPER_JAR% (
if "%MVNW_VERBOSE%" == "true" (
echo Found %WRAPPER_JAR%
)
) else (
if not "%MVNW_REPOURL%" == "" (
SET DOWNLOAD_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
)
if "%MVNW_VERBOSE%" == "true" (
echo Couldn't find %WRAPPER_JAR%, downloading it ...
echo Downloading from: %DOWNLOAD_URL%
)
powershell -Command "&{"^
"$webclient = new-object System.Net.WebClient;"^
"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
"}"^
"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^
"}"
if "%MVNW_VERBOSE%" == "true" (
echo Finished downloading %WRAPPER_JAR%
)
)
@REM End of extension
@REM Provide a "standardized" way to retrieve the CLI args that will
@REM work with both Windows and non-Windows executions.
set MAVEN_CMD_LINE_ARGS=%*
%MAVEN_JAVA_EXE% ^
%JVM_CONFIG_MAVEN_PROPS% ^
%MAVEN_OPTS% ^
%MAVEN_DEBUG_OPTS% ^
-classpath %WRAPPER_JAR% ^
"-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
%WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
if ERRORLEVEL 1 goto error
goto end
:error
set ERROR_CODE=1
:end
@endlocal & set ERROR_CODE=%ERROR_CODE%
if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
@REM check for post script, once with legacy .bat ending and once with .cmd ending
if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd"
:skipRcPost
@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
if "%MAVEN_BATCH_PAUSE%"=="on" pause
if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE%
cmd /C exit /B %ERROR_CODE%
pom.xml 0 → 100644
View file @ 5ba69672
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.12</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.bank.it</groupId>
<artifactId>payees</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>payees</name>
<description>Manage Payees Project</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-validation</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-core</artifactId>
<version>2.15.2</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.15.2</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.mapstruct</groupId>
<artifactId>mapstruct</artifactId>
<version>1.5.3.Final</version>
</dependency>
<dependency>
<groupId>javax.validation</groupId>
<artifactId>validation-api</artifactId>
<version>2.0.1.Final</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<excludes>
<exclude>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclude>
</excludes>
</configuration>
</plugin>
</plugins>
</build>
</project>
src/main/java/com/bank/it/payees/PayeesApplication.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
@SpringBootApplication
@EnableMongoRepositories
public class PayeesApplication {
public static void main(String[] args) {
SpringApplication.run(PayeesApplication.class, args);
}
}
src/main/java/com/bank/it/payees/config/KafkaTopicConfig.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.config;
import com.bank.it.payees.constants.KafkaConstants;
import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.config.TopicBuilder;
@Configuration
public class KafkaTopicConfig {
@Bean
public NewTopic topic(){
return TopicBuilder.name(KafkaConstants.TOPIC_NAME).build();
}
}
src/main/java/com/bank/it/payees/constants/APIMessagesConstants.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.constants;
public class APIMessagesConstants {
public static final String PAYEE_NOT_EXIST_DEL_MSG = "Requested Payee does not exist to be deleted!";
public static final String PAYEE_NOT_EXIST_SEARCH_MSG = "Requested Payee does not exist to be retrieved!";
public static final String PAYEE_NOT_EXIST_SEARCH_ALL_MSG = "Payees does not exist!!";
public static final String PAYEE_DEL_SUCCESS = "Requested Payee deleted successfully";
}
src/main/java/com/bank/it/payees/constants/KafkaConstants.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.constants;
public class KafkaConstants {
public static final String TOPIC_NAME = "PAYEE_TOPIC";
public static final String PAYEE_UPDATE_STATUS = "UPDATED";
public static final String PAYEE_GROUP_ID = "payee_group_id";
}
src/main/java/com/bank/it/payees/controller/PayeeController.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.controller;
import com.bank.it.payees.dto.request.PayeeRequest;
import com.bank.it.payees.dto.response.PayeeResponse;
import com.bank.it.payees.service.IManagePayeeService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.List;
@RestController
@RequestMapping("/payees/v1")
@Slf4j
public class PayeeController {
@Autowired
private IManagePayeeService managePayeeService;
/**
* Request to add new payee
*
* @param payeeRequest
* @return PayeeResponse
*/
@PostMapping("/manage/addPayee")
public ResponseEntity<PayeeResponse> addPayee(@RequestBody @Valid PayeeRequest payeeRequest) {
log.info("Entered Add Payee "+PayeeController.class);
PayeeResponse payeeResponse = managePayeeService.savePayee(payeeRequest);
return new ResponseEntity<>(payeeResponse, HttpStatus.CREATED);
}
/**
* Request to add update payee
*
* @param payeeRequest
* @return PayeeResponse
*/
@PutMapping("/manage/updatePayee")
public ResponseEntity<PayeeResponse> updatePayee(@RequestBody @Valid PayeeRequest payeeRequest) {
log.info("Entered Update Payee "+PayeeController.class);
PayeeResponse payeeResponse = managePayeeService.updatePayee(payeeRequest);
return new ResponseEntity<>(payeeResponse, HttpStatus.ACCEPTED);
}
/**
* Request to retrieve all payees
*
* @param
* @return List of PayeeResponse (Payees)
*/
@GetMapping("/manage/all")
public ResponseEntity<List<PayeeResponse>> findPayees() {
log.info("Entered findPayees "+PayeeController.class);
List<PayeeResponse> listOfPayees = managePayeeService.searchPayees();
return new ResponseEntity<List<PayeeResponse>>(listOfPayees, HttpStatus.ACCEPTED);
}
/**
* Request to retrieve payee based on valid accountNumber
*
* @param accountNumber
* @return PayeeResponse
*/
@GetMapping("/manage/payee/{accountNumber}")
public ResponseEntity<PayeeResponse> findPayee(@PathVariable int accountNumber) {
log.info("Entered findPayee "+PayeeController.class);
PayeeResponse payeeResponse = managePayeeService.searchPayee(accountNumber);
return new ResponseEntity<PayeeResponse>(payeeResponse, HttpStatus.ACCEPTED);
}
/**
* Request to delete payee based on valid accountNumber
*
* @param accountNumber
* @return String msg
*/
@DeleteMapping("/manage/deletePayee/{accountNumber}")
public ResponseEntity<String> deletePayee(@PathVariable int accountNumber) {
log.info("Entered deletePayee "+PayeeController.class);
String payeeDeletionConfirmation = managePayeeService.deletePayee(accountNumber);
return new ResponseEntity<String>(payeeDeletionConfirmation, HttpStatus.ACCEPTED);
}
}
src/main/java/com/bank/it/payees/dto/mapper/PayeeMapper.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.dto.mapper;
import com.bank.it.payees.dto.request.PayeeRequest;
import com.bank.it.payees.dto.response.PayeeResponse;
import com.bank.it.payees.entity.PayeeEntity;
import com.bank.it.payees.entity.PayeeUpdateEntity;
import com.bank.it.payees.model.Payee;
import org.mapstruct.Mapper;
import org.mapstruct.Mapping;
import org.mapstruct.Mappings;
import org.mapstruct.factory.Mappers;
import java.util.List;
@Mapper
public interface PayeeMapper {
PayeeMapper MAPPER = Mappers.getMapper(PayeeMapper.class);
PayeeEntity fromRequestToEntity(PayeeRequest payeeRequest);
PayeeResponse fromEntityToResponse(PayeeEntity payeeEntity);
Payee fromEntityToPayee(PayeeEntity payeeEntity);
PayeeUpdateEntity fromPayeeToPayeeUpdateEntity(Payee payee);
List<PayeeResponse> fromEntityListToResponseList(List<PayeeEntity> payeeEntity);
}
src/main/java/com/bank/it/payees/dto/mapper/PayeeMapperImpl.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.dto.mapper;
import com.bank.it.payees.constants.KafkaConstants;
import com.bank.it.payees.dto.request.PayeeRequest;
import com.bank.it.payees.dto.response.PayeeResponse;
import com.bank.it.payees.entity.PayeeEntity;
import com.bank.it.payees.entity.PayeeUpdateEntity;
import com.bank.it.payees.model.Payee;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.format.annotation.DateTimeFormat;
import java.time.LocalDate;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
public class PayeeMapperImpl implements PayeeMapper{
@Autowired
@DateTimeFormat(pattern = "yyyy-MM-dd")
private LocalDate today;
@Override
public PayeeEntity fromRequestToEntity(PayeeRequest payeeRequest) {
PayeeEntity payeeEntity = new PayeeEntity();
payeeEntity.setId(payeeRequest.getId());
payeeEntity.setAccountNumber(payeeRequest.getAccountNumber());
payeeEntity.setAccountName(payeeRequest.getAccountName());
payeeEntity.setAddress(payeeRequest.getAddress());
payeeEntity.setMobileNumber(payeeRequest.getMobileNumber());
payeeEntity.setNickName(payeeRequest.getNickName());
payeeEntity.setBranchCode(payeeRequest.getBranchCode());
payeeEntity.setBranchName(payeeRequest.getBranchName());
payeeEntity.setNationality(payeeRequest.getNationality());
payeeEntity.setDailyTxnLimit(payeeRequest.getDailyTxnLimit());
return payeeEntity;
}
/**
* @param payeeEntity
* @return
*/
@Override
public PayeeResponse fromEntityToResponse(PayeeEntity payeeEntity) {
PayeeResponse payeeResponse = new PayeeResponse();
payeeResponse.setId(payeeEntity.getId());
payeeResponse.setAccountNumber(payeeEntity.getAccountNumber());
payeeResponse.setAccountName(payeeEntity.getAccountName());
payeeResponse.setAddress(payeeEntity.getAddress());
payeeResponse.setMobileNumber(payeeEntity.getMobileNumber());
payeeResponse.setNickName(payeeEntity.getNickName());
payeeResponse.setBranchCode(payeeEntity.getBranchCode());
payeeResponse.setBranchName(payeeEntity.getBranchName());
payeeResponse.setNationality(payeeEntity.getNationality());
payeeResponse.setDailyTxnLimit(payeeEntity.getDailyTxnLimit());
return payeeResponse;
}
/**
* @param payeeEntity
* @return
*/
@Override
public Payee fromEntityToPayee(PayeeEntity payeeEntity) {
Payee payee = new Payee();
today = LocalDate.now();
payee.setAccountName(payeeEntity.getAccountName());
payee.setAccountNumber(payeeEntity.getAccountNumber());
payee.setMobileNumber(payeeEntity.getMobileNumber());
payee.setBranchCode(payeeEntity.getBranchCode());
payee.setBranchName(payeeEntity.getBranchName());
payee.setStatus(KafkaConstants.PAYEE_UPDATE_STATUS);
payee.setUpdatedDate(today.toString());
return payee;
}
/**
* @param payee
* @return
*/
@Override
public PayeeUpdateEntity fromPayeeToPayeeUpdateEntity(Payee payee) {
PayeeUpdateEntity payeeUpdateEntity = new PayeeUpdateEntity();
payeeUpdateEntity.setAccountNumber(payee.getAccountNumber());
payeeUpdateEntity.setAccountName(payee.getAccountName());
payeeUpdateEntity.setMobileNumber(payee.getMobileNumber());
payeeUpdateEntity.setBranchCode(payee.getBranchCode());
payeeUpdateEntity.setBranchName(payee.getBranchName());
payeeUpdateEntity.setUpdatedDate(payee.getUpdatedDate());
payeeUpdateEntity.setStatus(payee.getStatus());
return payeeUpdateEntity;
}
/**
* @param
* @return
*/
@Override
public List<PayeeResponse> fromEntityListToResponseList(List<PayeeEntity> payeeEntityList) {
List<PayeeResponse> payeeResponseStream = payeeEntityList.stream().map(
(payeeEntity)-> MAPPER.fromEntityToResponse(payeeEntity)
).collect(Collectors.toList());
return payeeResponseStream;
}
}
src/main/java/com/bank/it/payees/dto/request/PayeeRequest.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.dto.request;
import com.bank.it.payees.constants.APIMessagesConstants;
import lombok.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.annotation.Id;
import javax.validation.constraints.*;
import java.io.Serializable;
@AllArgsConstructor
@NoArgsConstructor
@Data
public class PayeeRequest implements Serializable{
@Autowired
private APIMessagesConstants errorMessagesConstants;
@Id
private String id;
private int accountNumber;
@NotNull(message = "Please provide valid account holder name")
private String accountName;
private String address;
@Digits(message="Number should contain 10 digits.", fraction = 0, integer = 10)
private String mobileNumber;
private String nickName;
private String branchCode;
private String branchName;
@NotBlank
private String nationality;
@Min(50000)
@Max(500000)
private int dailyTxnLimit;
}
src/main/java/com/bank/it/payees/dto/response/PayeeResponse.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.dto.response;
import lombok.*;
import org.springframework.data.annotation.Id;
import java.io.Serializable;
@AllArgsConstructor
@NoArgsConstructor
@Data
public class PayeeResponse implements Serializable {
@Id
private String id;
private int accountNumber;
private String accountName;
private String address;
private String mobileNumber;
private String nickName;
private String branchCode;
private String branchName;
private String nationality;
private int dailyTxnLimit;
}
src/main/java/com/bank/it/payees/entity/PayeeEntity.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.entity;
import lombok.*;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
@Data
@NoArgsConstructor
@AllArgsConstructor
@Document(collection = "manage_payees_info")
public class PayeeEntity {
@Id
private String id;
private int accountNumber;
private String accountName;
private String address;
private String mobileNumber;
private String nickName;
private String branchCode;
private String branchName;
private String nationality;
private int dailyTxnLimit;
}
src/main/java/com/bank/it/payees/entity/PayeeUpdateEntity.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
@Data
@NoArgsConstructor
@AllArgsConstructor
@Document(collection = "updated_payees_info")
public class PayeeUpdateEntity {
@Id
private String id;
private int accountNumber;
private String accountName;
private String mobileNumber;
private String branchCode;
private String branchName;
private String status;
private String updatedDate;
}
src/main/java/com/bank/it/payees/exception/PayeeExceptionHandler.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.exception;
import com.bank.it.payees.exception.custom.PayeeCustomException;
import com.bank.it.payees.exception.custom.PayeeNotFoundException;
import org.springframework.http.HttpStatus;
import org.springframework.web.bind.MethodArgumentNotValidException;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import java.util.HashMap;
import java.util.Map;
@RestControllerAdvice
public class PayeeExceptionHandler {
@ResponseStatus(HttpStatus.BAD_REQUEST)
@ExceptionHandler(MethodArgumentNotValidException.class)
public Map<String, String> handleInvalidArgument(MethodArgumentNotValidException ex){
Map<String, String> errorMap = new HashMap<>();
ex.getBindingResult().getFieldErrors().forEach(error -> {
errorMap.put(error.getField(), error.getDefaultMessage());
}
);
return errorMap;
}
@ResponseStatus(HttpStatus.NOT_FOUND)
@ExceptionHandler(PayeeNotFoundException.class)
public Object handlePayeeNotFound(PayeeNotFoundException pe){
PayeeCustomException payeeCustomException = new PayeeCustomException(
pe.getMessage(),
pe.getCause(),
HttpStatus.NOT_FOUND
);
return payeeCustomException;
}
}
src/main/java/com/bank/it/payees/exception/custom/PayeeCustomException.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.exception.custom;
import org.springframework.http.HttpStatus;
public class PayeeCustomException {
private final String message;
private final Throwable throwable;
private final HttpStatus httpStatus;
public PayeeCustomException(String message, Throwable throwable, HttpStatus httpStatus) {
this.message = message;
this.throwable = throwable;
this.httpStatus = httpStatus;
}
public String getMessage() {
return message;
}
public Throwable getThrowable() {
return throwable;
}
public HttpStatus getHttpStatus() {
return httpStatus;
}
}
src/main/java/com/bank/it/payees/exception/custom/PayeeNotFoundException.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.exception.custom;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.stereotype.Component;
import java.util.function.Supplier;
public class PayeeNotFoundException extends RuntimeException {
/**
* Constructs a new runtime exception with the specified detail message.
* The cause is not initialized, and may subsequently be initialized by a
* call to {@link #initCause}.
*
* @param message the detail message. The detail message is saved for
* later retrieval by the {@link #getMessage()} method.
*/
public PayeeNotFoundException(String message) {
super(message);
}
/**
* Constructs a new runtime exception with the specified detail message and
* cause. <p>Note that the detail message associated with
* {@code cause} is <i>not</i> automatically incorporated in
* this runtime exception's detail message.
*
* @param message the detail message (which is saved for later retrieval
* by the {@link #getMessage()} method).
* @param cause the cause (which is saved for later retrieval by the
* {@link #getCause()} method). (A <tt>null</tt> value is
* permitted, and indicates that the cause is nonexistent or
* unknown.)
* @since 1.4
*/
public PayeeNotFoundException(String message, Throwable cause) {
super(message, cause);
}
}
src/main/java/com/bank/it/payees/kafka/Consumer/ConsumerKafkaConfig.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.kafka.Consumer;
import com.bank.it.payees.entity.PayeeUpdateEntity;
import com.bank.it.payees.model.Payee;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.EnableKafka;
import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
import org.springframework.kafka.core.ConsumerFactory;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
import org.springframework.kafka.support.serializer.JsonDeserializer;
import java.util.HashMap;
import java.util.Map;
@EnableKafka
@Configuration
public class ConsumerKafkaConfig {
@Value("${kafka.bootstrapAddress}")
private String bootstrapAddress;
@Value("${kafka.groupId}")
private String groupId;
/**
* Consumer configuration
* @return
*/
@Bean
public ConsumerFactory<String, Payee> payeeConsumerFactory() {
Map<String, Object> map = new HashMap<>();
map.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
map.put(ConsumerConfig.GROUP_ID_CONFIG,groupId);
map.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
map.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
map.put(JsonDeserializer.TRUSTED_PACKAGES,"*");
return new DefaultKafkaConsumerFactory<>(map);
}
@Bean
public ConcurrentKafkaListenerContainerFactory<String,Payee> kafkaListenerContainerFactory() {
ConcurrentKafkaListenerContainerFactory<String,Payee> kafkaListenerContainerFactory = new ConcurrentKafkaListenerContainerFactory<>();
kafkaListenerContainerFactory.setConsumerFactory(payeeConsumerFactory());
return kafkaListenerContainerFactory;
}
}
src/main/java/com/bank/it/payees/kafka/Consumer/ConsumerService.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.kafka.Consumer;
import com.bank.it.payees.constants.KafkaConstants;
import com.bank.it.payees.dto.mapper.PayeeMapper;
import com.bank.it.payees.entity.PayeeUpdateEntity;
import com.bank.it.payees.model.Payee;
import com.bank.it.payees.repository.IUpdatePayeeRepository;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;
@Component
@Slf4j
public class ConsumerService {
@Autowired
private IUpdatePayeeRepository updatePayeeRepo;
/**
* Consumer Implementation
* @param payee
*/
@KafkaListener(topics = KafkaConstants.TOPIC_NAME, groupId = KafkaConstants.PAYEE_GROUP_ID, containerFactory = "kafkaListenerContainerFactory")
private void consume(Payee payee) {
PayeeUpdateEntity payeeUpdateEntity = PayeeMapper.MAPPER.fromPayeeToPayeeUpdateEntity(payee);
updatePayeeRepo.insert(payeeUpdateEntity);
log.info("Payee Details updated successfully via message bus :"+payeeUpdateEntity);
}
}
src/main/java/com/bank/it/payees/kafka/Producer/Producer.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.kafka.Producer;
import com.bank.it.payees.constants.KafkaConstants;
import com.bank.it.payees.model.Payee;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.support.SendResult;
import org.springframework.stereotype.Component;
import org.springframework.util.concurrent.ListenableFuture;
import org.springframework.util.concurrent.ListenableFutureCallback;
@Component
@Slf4j
public class Producer {
@Autowired
private KafkaTemplate<String, Payee> kafkaTemplate;
public Producer(KafkaTemplate<String,Payee> kafkaTemplate) {
this.kafkaTemplate = kafkaTemplate;
}
/**
* Publish the object
* @param payee
*/
public void sendMessage(Payee payee) {
ListenableFuture<SendResult<String,Payee>> feature =kafkaTemplate.send(KafkaConstants.TOPIC_NAME, payee);
feature.addCallback(new ListenableFutureCallback<SendResult<String,Payee>>() {
@Override
public void onFailure(Throwable ex) {
log.info("Error occured while sending",ex);
}
@Override
public void onSuccess(SendResult<String,Payee> result) {
log.info("Send message successfully"+result);
}
});
}
}
src/main/java/com/bank/it/payees/kafka/Producer/ProducerKafkaConfig.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.kafka.Producer;
import com.bank.it.payees.model.Payee;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common.serialization.StringSerializer;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.core.DefaultKafkaProducerFactory;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.core.ProducerFactory;
import org.springframework.kafka.support.serializer.JsonSerializer;
import java.util.HashMap;
import java.util.Map;
@Configuration
public class ProducerKafkaConfig {
@Value("${kafka.bootstrapAddress}")
private String bootstrapAddress;
/**
* Producer kafka configuration
* @return
*/
@Bean
public ProducerFactory<String, Payee> payeeProducerFactory() {
Map<String, Object> map = new HashMap<>();
map.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapAddress);
map.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
map.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
return new DefaultKafkaProducerFactory<>(map);
}
@Bean
public KafkaTemplate<String,Payee> kafkaTemplate() {
return new KafkaTemplate<>(payeeProducerFactory());
}
}
src/main/java/com/bank/it/payees/model/Payee.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.model;
import java.time.LocalDate;
import java.util.Date;
public class Payee
{
private int accountNumber;
private String accountName;
private String mobileNumber;
private String branchCode;
private String branchName;
private String status;
private String updatedDate;
public int getAccountNumber() {
return accountNumber;
}
public void setAccountNumber(int accountNumber) {
this.accountNumber = accountNumber;
}
public String getAccountName() {
return accountName;
}
public void setAccountName(String accountName) {
this.accountName = accountName;
}
public String getMobileNumber() {
return mobileNumber;
}
public void setMobileNumber(String mobileNumber) {
this.mobileNumber = mobileNumber;
}
public String getBranchCode() {
return branchCode;
}
public void setBranchCode(String branchCode) {
this.branchCode = branchCode;
}
public String getBranchName() {
return branchName;
}
public void setBranchName(String branchName) {
this.branchName = branchName;
}
public String getStatus() {
return status;
}
public void setStatus(String status) {
this.status = status;
}
public String getUpdatedDate() {
return updatedDate;
}
public void setUpdatedDate(String updatedDate) {
this.updatedDate = updatedDate;
}
@Override
public String toString() {
return "Payee{" +
"accountNumber=" + accountNumber +
", accountName='" + accountName + '\'' +
", mobileNumber=" + mobileNumber +
", branchCode='" + branchCode + '\'' +
", branchName='" + branchName + '\'' +
", status='" + status + '\'' +
", updatedDate=" + updatedDate +
'}';
}
}
src/main/java/com/bank/it/payees/repository/IManagePayeeRepository.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.repository;
import com.bank.it.payees.entity.PayeeEntity;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.data.mongodb.repository.Query;
import org.springframework.stereotype.Repository;
import java.util.Optional;
@Repository
public interface IManagePayeeRepository extends MongoRepository<PayeeEntity, String> {
@Query("{accountNumber :?0}")
Optional<PayeeEntity> getPayeeEntityByAccountNumber(Integer accountNumber);
}
src/main/java/com/bank/it/payees/repository/IUpdatePayeeRepository.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.repository;
import com.bank.it.payees.entity.PayeeEntity;
import com.bank.it.payees.entity.PayeeUpdateEntity;
import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.stereotype.Repository;
@Repository
public interface IUpdatePayeeRepository extends MongoRepository<PayeeUpdateEntity, String> {
}
src/main/java/com/bank/it/payees/service/IManagePayeeService.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.service;
import com.bank.it.payees.dto.request.PayeeRequest;
import com.bank.it.payees.dto.response.PayeeResponse;
import java.util.List;
public interface IManagePayeeService {
PayeeResponse savePayee(PayeeRequest payeeRequest);
PayeeResponse updatePayee(PayeeRequest payeeRequest);
PayeeResponse searchPayee(int accountNumber);
List<PayeeResponse> searchPayees();
String deletePayee(int accountNumber);
}
src/main/java/com/bank/it/payees/service/ManagePayeeServiceImpl.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.service;
import com.bank.it.payees.constants.APIMessagesConstants;
import com.bank.it.payees.dto.mapper.PayeeMapper;
import com.bank.it.payees.dto.response.PayeeResponse;
import com.bank.it.payees.entity.PayeeEntity;
import com.bank.it.payees.exception.custom.PayeeNotFoundException;
import com.bank.it.payees.kafka.Producer.Producer;
import com.bank.it.payees.model.Payee;
import com.bank.it.payees.repository.IManagePayeeRepository;
import com.bank.it.payees.util.BankAccountNumberGeneratorUtil;
import org.springframework.beans.factory.annotation.Autowired;
import com.bank.it.payees.dto.request.PayeeRequest;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Optional;
@Service
public class ManagePayeeServiceImpl implements IManagePayeeService {
@Autowired
private IManagePayeeRepository managePayeeRepo;
@Autowired
private BankAccountNumberGeneratorUtil bankAccountNumberGeneratorUtil;
/* @Autowired
private PayeeKafkaProducer payeeKafkaProducer;
*/
@Autowired
private Producer producer;
/**
* Persist payee into NOSQL DB
*
* @param payeeRequest
* @return PayeeResponse
*/
@Override
public PayeeResponse savePayee(PayeeRequest payeeRequest) {
payeeRequest.setAccountNumber(bankAccountNumberGeneratorUtil.generatePayeeAccNumber());
PayeeEntity payeeEntity = PayeeMapper.MAPPER.fromRequestToEntity(payeeRequest);
PayeeEntity payeeEntityFromDB = managePayeeRepo.save(payeeEntity);
return PayeeMapper.MAPPER.fromEntityToResponse(payeeEntityFromDB);
}
/**
* Update payee into NOSQL DB
*
* @param payeeRequest
* @return PayeeResponse
*/
@Override
public PayeeResponse updatePayee(PayeeRequest payeeRequest) {
String existingDocumentId = null;
Optional<PayeeEntity> existingDocumentFromDB = managePayeeRepo.getPayeeEntityByAccountNumber(payeeRequest.getAccountNumber());
existingDocumentFromDB.orElseThrow(RuntimeException::new);
payeeRequest.setId(existingDocumentFromDB.isPresent() ? existingDocumentFromDB.get().getId() : existingDocumentId);
PayeeEntity payeeEntity = PayeeMapper.MAPPER.fromRequestToEntity(payeeRequest);
PayeeEntity payeeEntityFromDB = managePayeeRepo.save(payeeEntity);
PayeeResponse payeeResponse = PayeeMapper.MAPPER.fromEntityToResponse(payeeEntityFromDB);
Payee payee = PayeeMapper.MAPPER.fromEntityToPayee(payeeEntity);
producer.sendMessage(payee);
return payeeResponse;
}
/**
* Retrieve payee from NOSQL DB based on accountNumber
*
* @param accountNumber
* @return PayeeResponse
*/
@Override
public PayeeResponse searchPayee(int accountNumber) {
PayeeResponse payeeResponse = null;
Optional<PayeeEntity> payeeEntity = managePayeeRepo.getPayeeEntityByAccountNumber(accountNumber);
if(!payeeEntity.isPresent()) throw new PayeeNotFoundException(APIMessagesConstants.PAYEE_NOT_EXIST_SEARCH_MSG);
payeeResponse = PayeeMapper.MAPPER.fromEntityToResponse(payeeEntity.get());
return Optional.ofNullable(payeeResponse).orElseThrow(RuntimeException::new);
}
/**
* Retrieve all payees from NOSQL DB
*
* @param
* @return List of PayeeResponse
*/
@Override
public List<PayeeResponse> searchPayees() {
List<PayeeEntity> listOfPayees = managePayeeRepo.findAll();
if(!(listOfPayees.size()>0)) throw new PayeeNotFoundException(APIMessagesConstants.PAYEE_NOT_EXIST_SEARCH_ALL_MSG);
return PayeeMapper.MAPPER.fromEntityListToResponseList(listOfPayees);
}
/**
* delete payee from NOSQL DB
*
* @param
* @return String msg
*/
@Override
public String deletePayee(int accountNumber) {
Optional<PayeeEntity> payeeEntity = managePayeeRepo.getPayeeEntityByAccountNumber(accountNumber);
if(!payeeEntity.isPresent()) throw new PayeeNotFoundException(APIMessagesConstants.PAYEE_NOT_EXIST_DEL_MSG);
managePayeeRepo.delete(payeeEntity.get());
return APIMessagesConstants.PAYEE_DEL_SUCCESS;
}
}
src/main/java/com/bank/it/payees/util/BankAccountNumberGeneratorUtil.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees.util;
import org.springframework.stereotype.Component;
import java.util.Random;
import java.util.function.Supplier;
@Component
public class BankAccountNumberGeneratorUtil {
/**
* Generate payee account number
* @return
*/
public int generatePayeeAccNumber() {
Random rand = new Random();
int generatedPayeeAccNumber;
Supplier<Long> generatePayeeAccNumber = (() -> {
return 10000000000L + ((long) rand.nextInt(900000000) * 1000) + rand.nextInt(100);
});
generatedPayeeAccNumber = generatePayeeAccNumber.get().intValue();
return generatedPayeeAccNumber;
}
}
\ No newline at end of file
src/main/resources/application.properties 0 → 100644
View file @ 5ba69672
server.port = 8081
spring.data.mongodb.uri=mongodb://localhost:27017/
spring.data.mongodb.database=MPayee
#Kafka
kafka.bootstrapAddress= localhost:9092
kafka.groupId=payee-api-consumer
#logging
logging.level.org.springframework.data=debug
logging.level.=errors
src/test/java/com/bank/it/payees/PayeesApplicationTests.java 0 → 100644
View file @ 5ba69672
package com.bank.it.payees;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class PayeesApplicationTests {
@Test
void contextLoads() {
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment