diff --git a/src/main/java/au/com/royalpay/payment/manage/task/BillOrderCheckTask.java b/src/main/java/au/com/royalpay/payment/manage/task/BillOrderCheckTask.java index c44acb701..6badb7396 100644 --- a/src/main/java/au/com/royalpay/payment/manage/task/BillOrderCheckTask.java +++ b/src/main/java/au/com/royalpay/payment/manage/task/BillOrderCheckTask.java @@ -27,7 +27,7 @@ public class BillOrderCheckTask { private SynchronizedScheduler synchronizedScheduler; @Scheduled(cron = "0 0/3 * * * ?") - public void checkGreenChannel() { + public void checkBillOrderCheck() { synchronizedScheduler.executeProcess("manage_task:checkGreenChannel", 120_000, () -> { List orderIds = billOrderMapper.findOrderIdByStatus("0"); if (CollectionUtils.isEmpty(orderIds)) { diff --git a/src/main/java/au/com/royalpay/payment/manage/task/CheckPartnerAuthStatusAndSendMessageTask.java b/src/main/java/au/com/royalpay/payment/manage/task/CheckPartnerAuthStatusAndSendMessageTask.java index 75da6d0b9..7a4cb84a7 100644 --- a/src/main/java/au/com/royalpay/payment/manage/task/CheckPartnerAuthStatusAndSendMessageTask.java +++ b/src/main/java/au/com/royalpay/payment/manage/task/CheckPartnerAuthStatusAndSendMessageTask.java @@ -25,8 +25,8 @@ public class CheckPartnerAuthStatusAndSendMessageTask { // simpleClientService.checkAuthAndSendMessage(); // } @Scheduled(cron = "0 0 9 * * ?") - public void checkGreenChannel() { - synchronizedScheduler.executeProcess("manage_task:CheckPartnerAuthStatus", 120_000, () -> simpleClientService.checkGreenChannelClients()); + public void checkPartnerAuthStatusAndSendMessage() { + synchronizedScheduler.executeProcess("manage_task:checkPartnerAuthStatusAndSendMessage", 120_000, () -> simpleClientService.checkGreenChannelClients()); } } diff --git a/src/main/java/au/com/royalpay/payment/manage/task/CustomerImpressionTask.java b/src/main/java/au/com/royalpay/payment/manage/task/CustomerImpressionTask.java index 0e0920d32..265908393 100644 --- a/src/main/java/au/com/royalpay/payment/manage/task/CustomerImpressionTask.java +++ b/src/main/java/au/com/royalpay/payment/manage/task/CustomerImpressionTask.java @@ -34,8 +34,8 @@ public class CustomerImpressionTask { private ThreadPoolExecutor generatePool = new ThreadPoolExecutor(10, 30, 5, TimeUnit.SECONDS, new LinkedBlockingQueue()); @Scheduled(cron = "0 30 3 * * ?") - public void generateTags() { - synchronizedScheduler.executeProcess("manage_task:CustomerImpression", 120_000, () -> { + public void customerImpressionGenerateTags() { + synchronizedScheduler.executeProcess("manage_task:customerImpressionGenerateTags", 120_000, () -> { List clients = clientMapper.listValidClient(); List> splitList = new ArrayList<>(); for (int i = 0; i < clients.size(); i += 200) { @@ -57,7 +57,7 @@ public class CustomerImpressionTask { } @Scheduled(cron = "0/1 * * * * ?") - public void generateInfo() { + public void customerImpressionGenerateInfo() { synchronizedScheduler.executeProcess("manage_task:CustomerImpression", 1_000, () -> customerImpressionService.generateInfo()); } } diff --git a/src/main/java/au/com/royalpay/payment/manage/task/DailyReportGenerationTask.java b/src/main/java/au/com/royalpay/payment/manage/task/DailyReportGenerationTask.java index 020182dd2..692be43b4 100644 --- a/src/main/java/au/com/royalpay/payment/manage/task/DailyReportGenerationTask.java +++ b/src/main/java/au/com/royalpay/payment/manage/task/DailyReportGenerationTask.java @@ -26,8 +26,8 @@ public class DailyReportGenerationTask { private SynchronizedScheduler synchronizedScheduler; @Scheduled(cron = "0 0 10 * * ?") - public void autoGenerateReport() { - synchronizedScheduler.executeProcess("manage_task:autoGenerateDailyReport", 120_000, () -> { + public void dailyReportAutoGenerateReport() { + synchronizedScheduler.executeProcess("manage_task:dailyReportAutoGenerateReport", 120_000, () -> { Date yesterday = DateUtils.addDays(new Date(), -1); dailyReport.generateReport(DateFormatUtils.format(yesterday, "yyyy-MM-dd"), true); }); diff --git a/src/main/java/au/com/royalpay/payment/manage/task/DirectedBillCodeStatusDailyCheck.java b/src/main/java/au/com/royalpay/payment/manage/task/DirectedBillCodeStatusDailyCheck.java index acf52088f..872b28a8d 100644 --- a/src/main/java/au/com/royalpay/payment/manage/task/DirectedBillCodeStatusDailyCheck.java +++ b/src/main/java/au/com/royalpay/payment/manage/task/DirectedBillCodeStatusDailyCheck.java @@ -20,8 +20,8 @@ public class DirectedBillCodeStatusDailyCheck { private SynchronizedScheduler synchronizedScheduler; @Scheduled(cron = "0 30 5 * * ?") - public void statusDailyCheck() { - synchronizedScheduler.executeProcess("manage_task:dailyCheckDirected", 120_000, + public void directedBillCodeStatusDailyCheck() { + synchronizedScheduler.executeProcess("manage_task:directedBillCodeStatusDailyCheck", 120_000, () -> partnerBillService.dailyCheckDirectedBillCode()); } } diff --git a/src/main/java/au/com/royalpay/payment/manage/task/OfeiOrderCheckTask.java b/src/main/java/au/com/royalpay/payment/manage/task/OfeiOrderCheckTask.java index 661c55dc5..8b633e4b6 100644 --- a/src/main/java/au/com/royalpay/payment/manage/task/OfeiOrderCheckTask.java +++ b/src/main/java/au/com/royalpay/payment/manage/task/OfeiOrderCheckTask.java @@ -27,7 +27,7 @@ public class OfeiOrderCheckTask { private SynchronizedScheduler synchronizedScheduler; @Scheduled(cron = "0 0/20 * * * ?") - public void checkGreenChannel() { + public void ofeiOrderCheck() { synchronizedScheduler.executeProcess("manage_task:ofeiOrderCheck", 120_000, () -> { List orderIds = topUpOrderMapper.findOrderIdByStatus("10"); if (CollectionUtils.isEmpty(orderIds)) { diff --git a/src/main/java/au/com/royalpay/payment/manage/task/PartnerInitEmailChecker.java b/src/main/java/au/com/royalpay/payment/manage/task/PartnerInitEmailChecker.java index 9464522ed..b1f1e31cc 100644 --- a/src/main/java/au/com/royalpay/payment/manage/task/PartnerInitEmailChecker.java +++ b/src/main/java/au/com/royalpay/payment/manage/task/PartnerInitEmailChecker.java @@ -23,9 +23,9 @@ public class PartnerInitEmailChecker { private SynchronizedScheduler synchronizedScheduler; @Scheduled(cron = "0 0/5 * * * *") - public void checkEmailStatus() { + public void checkPartnerInitEmail() { if (PlatformEnvironment.getEnv().taskEnabled()) { - synchronizedScheduler.executeProcess("manage_task:emailStatusCheck", 120_000, + synchronizedScheduler.executeProcess("manage_task:checkPartnerInitEmail", 120_000, () -> clientManager.checkEmailStatus()); } } diff --git a/src/main/java/au/com/royalpay/payment/manage/task/PartnerTransactionsDailyMsgTaskManager.java b/src/main/java/au/com/royalpay/payment/manage/task/PartnerTransactionsDailyMsgTaskManager.java index 0ee93c32b..9caf1046e 100644 --- a/src/main/java/au/com/royalpay/payment/manage/task/PartnerTransactionsDailyMsgTaskManager.java +++ b/src/main/java/au/com/royalpay/payment/manage/task/PartnerTransactionsDailyMsgTaskManager.java @@ -24,8 +24,8 @@ public class PartnerTransactionsDailyMsgTaskManager { private SynchronizedScheduler synchronizedScheduler; @Scheduled(cron = "0 0 8 * * ?") - public void analysisDashboard() { - synchronizedScheduler.executeProcess("manage_task:partnerDailyMsg", 120_000, + public void partnerTransactionsDailyMsg() { + synchronizedScheduler.executeProcess("manage_task:partnerTransactionsDailyMsg", 120_000, () -> customersAnalysisService.sendPartnerTransactionDaily(DateUtils.addDays(new Date(), -1))); } } diff --git a/src/main/java/au/com/royalpay/payment/manage/task/PostponeClientTask.java b/src/main/java/au/com/royalpay/payment/manage/task/PostponeClientTask.java index f2342bb43..a612bc40a 100644 --- a/src/main/java/au/com/royalpay/payment/manage/task/PostponeClientTask.java +++ b/src/main/java/au/com/royalpay/payment/manage/task/PostponeClientTask.java @@ -50,7 +50,7 @@ public class PostponeClientTask { @Scheduled(cron = "0 30 8 * * ?") - public void checkGreenChannel() { + public void postponeClient() { synchronizedScheduler.executeProcess("manage_task:postPoneClient", 120_000, () -> { Date now = new Date(); Date tomorrow = DateUtils.addDays(now, 1); diff --git a/src/main/java/au/com/royalpay/payment/manage/task/WeekReportGenerationTask.java b/src/main/java/au/com/royalpay/payment/manage/task/WeekReportGenerationTask.java index aef28d736..24595f9e1 100644 --- a/src/main/java/au/com/royalpay/payment/manage/task/WeekReportGenerationTask.java +++ b/src/main/java/au/com/royalpay/payment/manage/task/WeekReportGenerationTask.java @@ -26,8 +26,8 @@ public class WeekReportGenerationTask { private SynchronizedScheduler synchronizedScheduler; @Scheduled(cron = "0 0 2 * * 1") - public void autoGenerateReport() { - synchronizedScheduler.executeProcess("manage_task:genWeekReport", 120_000, () -> { + public void weekReportGeneration() { + synchronizedScheduler.executeProcess("manage_task:weekReportGeneration", 120_000, () -> { Date lastweek = new Date(); lastweek = DateUtils.addDays(lastweek, -7); weekReporter.generateReport(DateFormatUtils.format(lastweek, "yyyy-MM-dd"), true);