From 9c9e84febdd175d96a4dab6769f92842f8c1c471 Mon Sep 17 00:00:00 2001 From: Thaqi2021 Date: Mon, 24 Mar 2025 13:02:45 +0530 Subject: [PATCH] common scheduler --- .../gcc/erppostdata/common/MySchduler.java | 80 ++++++++++++++ .../erppostdata/communityhall/CHPostData.java | 2 +- .../communityhall/CmhScheduler.java | 102 +++++++++--------- .../erppostdata/config/DatabaseConfig.java | 2 +- .../petregistration/PRPostData.java | 2 +- .../petregistration/PetScheduler.java | 102 +++++++++--------- src/main/resources/application.properties | 15 +-- 7 files changed, 193 insertions(+), 112 deletions(-) create mode 100644 src/main/java/com/gcc/erppostdata/common/MySchduler.java diff --git a/src/main/java/com/gcc/erppostdata/common/MySchduler.java b/src/main/java/com/gcc/erppostdata/common/MySchduler.java new file mode 100644 index 0000000..5a88649 --- /dev/null +++ b/src/main/java/com/gcc/erppostdata/common/MySchduler.java @@ -0,0 +1,80 @@ +package com.gcc.erppostdata.common; + +import com.gcc.erppostdata.communityhall.CmhQueryBank; +import com.gcc.erppostdata.petregistration.PetQueryBank; +import com.gcc.erppostdata.repo.CommunityHallLogRepo; +import com.gcc.erppostdata.repo.PetLogRepo; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.annotation.Configuration; +import org.springframework.scheduling.annotation.EnableScheduling; +import org.springframework.scheduling.annotation.Scheduled; + +import java.util.Date; +import java.util.List; +import java.util.Map; + +@Configuration +@EnableScheduling +public class MySchduler { + + @Autowired + CmhQueryBank queryBank; + + @Autowired + CommunityHallLogRepo communityHallLogRepo; + + @Autowired + PetQueryBank petQueryBank; + + @Autowired + PetLogRepo petLogRepo; + + @Scheduled(fixedRate = 3600000) // Runs every 1 hour (3600000 milliseconds) + public void hourlyScheduled() { + oneHourCmhSch(); + oneHourPetSch(); + } + + @Scheduled(fixedRate = 10800000) + public void threeHoursScheduled() { + threeHourCmhSch(); + threeHourPetSch(); + } + + + public void oneHourCmhSch() { + System.out.println("community Hourly Post data"+new Date()); + int lastBookingIdInserted = communityHallLogRepo.getLastBookingIdInserted(); + System.out.println("community Hall lastBookingIdInserted:---->"+lastBookingIdInserted); + queryBank.hourlyPushData( lastBookingIdInserted); + + } + public void threeHourCmhSch() { + System.out.println("CommunityHall Three Hour Post data"+new Date()); List> dataByStatus = communityHallLogRepo.getDataByStatus(String.valueOf(0)); + for (Map data : dataByStatus) { + queryBank.resendPushData(data.get("transactionId").toString(), + data.get("id").toString() + ); + } + } + + + public void oneHourPetSch() { + System.out.println("Pet Hourly Post data"+new Date()); + int lastUniqueIdInserted = petLogRepo.getLastUniqueIdInserted(); + System.out.println("Pet License lastUniqueIdInserted:--->"+lastUniqueIdInserted); + petQueryBank.hourlyPushData(lastUniqueIdInserted); + } + public void threeHourPetSch() { + System.out.println("Pet Three Hour Post data"+new Date()); + List> dataByStatus = petLogRepo.getDataByStatus(String.valueOf(0)); + for (Map data : dataByStatus) { + petQueryBank.resendPushData(data.get("uniqueId").toString(), + data.get("id").toString() + ); + } + + + } + +} diff --git a/src/main/java/com/gcc/erppostdata/communityhall/CHPostData.java b/src/main/java/com/gcc/erppostdata/communityhall/CHPostData.java index ff67714..9a5bb80 100644 --- a/src/main/java/com/gcc/erppostdata/communityhall/CHPostData.java +++ b/src/main/java/com/gcc/erppostdata/communityhall/CHPostData.java @@ -224,8 +224,8 @@ public class CHPostData { status = res.get("ResultStatus").toString(); } } + System.out.println("ResultStatus: " + status +"msgStatus: " + msgStatus); - System.out.println("ResultStatus: " + status); String msg = "Already Updated this collection"; ErpCHPostData com = new ErpCHPostData(); diff --git a/src/main/java/com/gcc/erppostdata/communityhall/CmhScheduler.java b/src/main/java/com/gcc/erppostdata/communityhall/CmhScheduler.java index 9fdd202..93cae7a 100644 --- a/src/main/java/com/gcc/erppostdata/communityhall/CmhScheduler.java +++ b/src/main/java/com/gcc/erppostdata/communityhall/CmhScheduler.java @@ -1,51 +1,51 @@ -package com.gcc.erppostdata.communityhall; - - -import com.gcc.erppostdata.repo.CommunityHallLogRepo; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.context.annotation.Configuration; -import org.springframework.scheduling.annotation.EnableScheduling; -import org.springframework.scheduling.annotation.Scheduled; - -import java.util.List; -import java.util.Map; - -@Configuration -@EnableScheduling // Enable scheduling -public class CmhScheduler { - - @Autowired - CmhQueryBank queryBank; - - @Autowired - CommunityHallLogRepo communityHallLogRepo; - - @Scheduled(fixedRate = 3600000) // Runs every 1 hour (3600000 milliseconds) - public void oneHouseScheduledMethod() { - int lastBookingIdInserted = communityHallLogRepo.getLastBookingIdInserted(); - System.out.println("community Hall lastBookingIdInserted:---->"+lastBookingIdInserted); - queryBank.hourlyPushData( lastBookingIdInserted); - - } - @Scheduled(fixedRate = 10800000) - public void threeHouseScheduledMethod() { - System.out.println("im for ERP post data"); - List> dataByStatus = communityHallLogRepo.getDataByStatus(String.valueOf(0)); - for (Map data : dataByStatus) { - queryBank.resendPushData(data.get("transactionId").toString(), - data.get("id").toString() - ); - } - - - } - - - @Scheduled(fixedRate = 10000) - public void tensecScheduledMethod(){ - -// System.out.print("hello"); - } - - -} +//package com.gcc.erppostdata.communityhall; +// +// +//import com.gcc.erppostdata.repo.CommunityHallLogRepo; +//import org.springframework.beans.factory.annotation.Autowired; +//import org.springframework.context.annotation.Configuration; +//import org.springframework.scheduling.annotation.EnableScheduling; +//import org.springframework.scheduling.annotation.Scheduled; +// +//import java.util.List; +//import java.util.Map; +// +//@Configuration +//@EnableScheduling // Enable scheduling +//public class CmhScheduler { +// +// @Autowired +// CmhQueryBank queryBank; +// +// @Autowired +// CommunityHallLogRepo communityHallLogRepo; +// +// @Scheduled(fixedRate = 3600000) // Runs every 1 hour (3600000 milliseconds) +// public void oneHouseScheduledMethod() { +// int lastBookingIdInserted = communityHallLogRepo.getLastBookingIdInserted(); +// System.out.println("community Hall lastBookingIdInserted:---->"+lastBookingIdInserted); +// queryBank.hourlyPushData( lastBookingIdInserted); +// +// } +// @Scheduled(fixedRate = 10800000) +// public void threeHouseScheduledMethod() { +// System.out.println("im for ERP post data"); +// List> dataByStatus = communityHallLogRepo.getDataByStatus(String.valueOf(0)); +// for (Map data : dataByStatus) { +// queryBank.resendPushData(data.get("transactionId").toString(), +// data.get("id").toString() +// ); +// } +// +// +// } +// +// +// @Scheduled(fixedRate = 10000) +// public void tensecScheduledMethod(){ +// +//// System.out.print("hello"); +// } +// +// +//} diff --git a/src/main/java/com/gcc/erppostdata/config/DatabaseConfig.java b/src/main/java/com/gcc/erppostdata/config/DatabaseConfig.java index 00a26e1..9a9661f 100644 --- a/src/main/java/com/gcc/erppostdata/config/DatabaseConfig.java +++ b/src/main/java/com/gcc/erppostdata/config/DatabaseConfig.java @@ -24,7 +24,7 @@ public class DatabaseConfig { // @Autowired // private AppConfig appConfig; - String chDb="communityhall_live"; + String chDb="communityhall_live";//communityhall_live String petDb="gcc_pets"; String userName="root"; diff --git a/src/main/java/com/gcc/erppostdata/petregistration/PRPostData.java b/src/main/java/com/gcc/erppostdata/petregistration/PRPostData.java index 6f42288..ad930a2 100644 --- a/src/main/java/com/gcc/erppostdata/petregistration/PRPostData.java +++ b/src/main/java/com/gcc/erppostdata/petregistration/PRPostData.java @@ -231,7 +231,7 @@ public class PRPostData { } } - System.out.println("ResultStatus: " + status); + System.out.println("ResultStatus: " + status +"msgStatus: " + msgStatus); String msg = "Already Updated this collection"; String conFailure = "Connection Failure"; if(conFailure.equals(msgStatus) ) { diff --git a/src/main/java/com/gcc/erppostdata/petregistration/PetScheduler.java b/src/main/java/com/gcc/erppostdata/petregistration/PetScheduler.java index 841fe26..755d56a 100644 --- a/src/main/java/com/gcc/erppostdata/petregistration/PetScheduler.java +++ b/src/main/java/com/gcc/erppostdata/petregistration/PetScheduler.java @@ -1,51 +1,51 @@ -package com.gcc.erppostdata.petregistration; - - -import com.gcc.erppostdata.repo.PetLogRepo; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.context.annotation.Configuration; -import org.springframework.scheduling.annotation.EnableScheduling; -import org.springframework.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Service; - -import java.util.List; -import java.util.Map; - -//@Configuration -//@EnableScheduling -@Service -public class PetScheduler { - - @Autowired - PetQueryBank petQueryBank; - - @Autowired - PetLogRepo petLogRepo; - - @Scheduled(fixedRate = 3600000) // Runs every 1 hour (3600000 milliseconds) - public void oneHouseScheduledMethod() { - int lastUniqueIdInserted = petLogRepo.getLastUniqueIdInserted(); - System.out.println("Pet License lastUniqueIdInserted:--->"+lastUniqueIdInserted); - petQueryBank.hourlyPushData(lastUniqueIdInserted); - } - @Scheduled(fixedRate = 10800000) - public void threeHouseScheduledMethod() { - System.out.println("im for ERP pet post data test"); - List> dataByStatus = petLogRepo.getDataByStatus(String.valueOf(0)); - for (Map data : dataByStatus) { - petQueryBank.resendPushData(data.get("uniqueId").toString(), - data.get("id").toString() - ); - } - - - } - - - @Scheduled(fixedRate = 10000) - public void tensecScheduledMethod(){ - -// System.out.print("hello"); - } - -} +//package com.gcc.erppostdata.petregistration; +// +// +//import com.gcc.erppostdata.repo.PetLogRepo; +//import org.springframework.beans.factory.annotation.Autowired; +//import org.springframework.context.annotation.Configuration; +//import org.springframework.scheduling.annotation.EnableScheduling; +//import org.springframework.scheduling.annotation.Scheduled; +//import org.springframework.stereotype.Service; +// +//import java.util.List; +//import java.util.Map; +// +////@Configuration +////@EnableScheduling +//@Service +//public class PetScheduler { +// +// @Autowired +// PetQueryBank petQueryBank; +// +// @Autowired +// PetLogRepo petLogRepo; +// +// @Scheduled(fixedRate = 3600000) // Runs every 1 hour (3600000 milliseconds) +// public void oneHouseScheduledMethod() { +// int lastUniqueIdInserted = petLogRepo.getLastUniqueIdInserted(); +// System.out.println("Pet License lastUniqueIdInserted:--->"+lastUniqueIdInserted); +// petQueryBank.hourlyPushData(lastUniqueIdInserted); +// } +// @Scheduled(fixedRate = 10800000) +// public void threeHouseScheduledMethod() { +// System.out.println("im for ERP pet post data test"); +// List> dataByStatus = petLogRepo.getDataByStatus(String.valueOf(0)); +// for (Map data : dataByStatus) { +// petQueryBank.resendPushData(data.get("uniqueId").toString(), +// data.get("id").toString() +// ); +// } +// +// +// } +// +// +// @Scheduled(fixedRate = 10000) +// public void tensecScheduledMethod(){ +// +//// System.out.print("hello"); +// } +// +//} diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index 5d594ba..fef7616 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -1,11 +1,12 @@ spring.application.name=erppostdata -spring.datasource.url=jdbc:mysql://127.0.0.1:3306/erppostdata -spring.datasource.username=root -spring.datasource.password=root -spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver - -spring.jpa.database-platform=org.hibernate.dialect.MySQL8Dialect -spring.jpa.hibernate.ddl-auto=update +#spring.datasource.url=jdbc:mysql://127.0.0.1:3306/erppostdata +#spring.datasource.username=root +#spring.datasource.password=gccroot +#spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver +# +#spring.jpa.database-platform=org.hibernate.dialect.MySQL8Dialect +#spring.jpa.hibernate.ddl-auto=update spring.profiles.active=prod +server.port=8067