From 841518339c61434ae92926cd108de087737d17c6 Mon Sep 17 00:00:00 2001 From: trialblazerseee <84778104+trialblazerseee@users.noreply.github.com> Date: Thu, 27 Feb 2025 10:55:30 +0530 Subject: [PATCH 1/3] Added Limit to avoid bulk transfer uin transfer to history table and consume more time. --- .../io/mosip/kernel/uingenerator/repository/UinRepository.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/uingenerator/repository/UinRepository.java b/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/uingenerator/repository/UinRepository.java index 9798700f638..b29fce0120f 100644 --- a/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/uingenerator/repository/UinRepository.java +++ b/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/uingenerator/repository/UinRepository.java @@ -54,7 +54,7 @@ public interface UinRepository extends JpaRepository { public void updateStatus(@Param("status") String status, @Param("contextUser") String contextUser, @Param("uptimes") LocalDateTime uptimes, @Param("uin") String uin); - @Query(value = "select uu.uin, uu.cr_by, uu.cr_dtimes, uu.del_dtimes, uu.is_deleted, uu.upd_by, uu.upd_dtimes, uu.uin_status from kernel.uin uu where uu.uin_status=?", nativeQuery = true) + @Query(value = "select uu.uin, uu.cr_by, uu.cr_dtimes, uu.del_dtimes, uu.is_deleted, uu.upd_by, uu.upd_dtimes, uu.uin_status from kernel.uin uu where uu.uin_status=? LIMIT 100000", nativeQuery = true) public List findByStatus(String status); long countByStatusAndIsDeletedFalse(String status); From 6e162cb1af9b6e6f9356d8a52fad4eaaa106039e Mon Sep 17 00:00:00 2001 From: trialblazerseee <84778104+trialblazerseee@users.noreply.github.com> Date: Thu, 27 Feb 2025 10:57:28 +0530 Subject: [PATCH 2/3] Modified Batch to Transfer Issued UIN Records to History Table. --- .../mosip/kernel/uingenerator/service/impl/UinServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/uingenerator/service/impl/UinServiceImpl.java b/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/uingenerator/service/impl/UinServiceImpl.java index b0975f6e29b..1e7b549b6a9 100644 --- a/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/uingenerator/service/impl/UinServiceImpl.java +++ b/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/uingenerator/service/impl/UinServiceImpl.java @@ -128,7 +128,7 @@ public UinStatusUpdateReponseDto updateUinStatus(UinEntity uinAck, RoutingContex @Transactional(transactionManager = "transactionManager") @Override public void transferUin() { - List uinEntities=uinRepository.findByStatus(UinGeneratorConstant.ASSIGNED); + List uinEntities=uinRepository.findByStatus(UinGeneratorConstant.ISSUED); List uinEntitiesAssined = modelMapper.map(uinEntities, new TypeToken>() {}.getType()); uinRepositoryAssigned.saveAll(uinEntitiesAssined); uinRepository.deleteAll(uinEntities); From eae2ae7fb63bd42052501ed012b03636d5df1034 Mon Sep 17 00:00:00 2001 From: trialblazerseee <84778104+trialblazerseee@users.noreply.github.com> Date: Thu, 27 Feb 2025 10:58:55 +0530 Subject: [PATCH 3/3] Modified Batch Basic Configuration level changes to reduce load --- .../kernel/idgenerator/IDGeneratorVertxApplication.java | 9 +++++---- .../kernel/idgenerator/config/UinServiceRouter.java | 2 +- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/idgenerator/IDGeneratorVertxApplication.java b/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/idgenerator/IDGeneratorVertxApplication.java index 292af017f39..8f8b8d4b276 100644 --- a/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/idgenerator/IDGeneratorVertxApplication.java +++ b/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/idgenerator/IDGeneratorVertxApplication.java @@ -11,6 +11,7 @@ import javax.annotation.PostConstruct; +import io.mosip.kernel.core.exception.ExceptionUtils; import org.apache.commons.io.IOUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.autoconfigure.SpringBootApplication; @@ -143,7 +144,7 @@ private static void loadPropertiesFromConfigServer() { vertx.close(); startApplication(); } else { - LOGGER.warn(json.cause().getMessage() + "\n"); + LOGGER.warn(json.cause().getMessage() + "\n" + ExceptionUtils.getStackTrace(json.cause())); json.otherwiseEmpty(); retriever.close(); vertx.close(); @@ -151,7 +152,7 @@ private static void loadPropertiesFromConfigServer() { } }); } catch (Exception exception) { - LOGGER.warn(exception.getMessage() + "\n"); + LOGGER.warn(exception.getMessage() + "\n" + ExceptionUtils.getStackTrace(exception)); vertx.close(); startApplication(); } @@ -173,7 +174,7 @@ private static void startApplication() { Verticle[] workerVerticles = { new VidPoolCheckerVerticle(context), new VidPopulatorVerticle(context), new VidExpiryVerticle(context), new VidIsolatorVerticle(context) }; Stream.of(workerVerticles).forEach(verticle -> deploy(verticle, workerOptions, vertx)); - vertx.setTimer(1000, handler -> initVIDPool()); + vertx.setTimer(10000, handler -> initVIDPool()); Verticle[] uinVerticles = { new UinGeneratorVerticle(context),new UinTransferVerticle(context)}; Stream.of(uinVerticles).forEach(verticle -> vertx.deployVerticle(verticle, stringAsyncResult -> { if (stringAsyncResult.succeeded()) { @@ -183,7 +184,7 @@ private static void startApplication() { + stringAsyncResult.cause()); } })); - vertx.setTimer(1000, handler -> initUINPool()); + vertx.setTimer(10000, handler -> initUINPool()); } @PostConstruct diff --git a/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/idgenerator/config/UinServiceRouter.java b/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/idgenerator/config/UinServiceRouter.java index e731ee2e0d6..4ca4967070f 100644 --- a/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/idgenerator/config/UinServiceRouter.java +++ b/kernel/kernel-idgenerator-service/src/main/java/io/mosip/kernel/idgenerator/config/UinServiceRouter.java @@ -129,7 +129,7 @@ private void getRouter(Vertx vertx, RoutingContext routingContext, boolean isSig Router router, int workerExecutorPool) { ResponseWrapper reswrp = new ResponseWrapper<>(); String timestamp = DateUtils.getUTCCurrentDateTimeString(); - WorkerExecutor executor = vertx.createSharedWorkerExecutor("get-uin", workerExecutorPool); + WorkerExecutor executor = vertx.createSharedWorkerExecutor("get-uin", workerExecutorPool, 1); executor.executeBlocking(blockingCodeHandler -> { try { checkAndGenerateUins(vertx);