disable scheduler

This commit is contained in:
root
2025-11-23 17:22:26 +05:00
parent 7af6cf2cd9
commit 3941980337
6 changed files with 36 additions and 0 deletions
@@ -38,6 +38,9 @@ public class KapitalParserService implements ParserService {
@Value("${rss.kapital.url}")
private String rssFeedUrl;
@Value("${parser.scheduler.enabled:true}")
private boolean schedulerEnabled;
@Override
public String getSourceName() {
return "kapital";
@@ -49,6 +52,10 @@ public class KapitalParserService implements ParserService {
*/
@Scheduled(cron = "0 0/5 * * * ?")
public void scheduledParseAndStoreNews() {
if (!schedulerEnabled) {
logger.debug("⏸️ Планировщик отключен. Пропуск планового парсинга Kapital.kz");
return;
}
logger.info("🔄 Запуск планового парсинга новостей с Kapital.kz...");
try {
List<MarketItem> savedItems = parseAndSaveRssFeed();
@@ -38,6 +38,9 @@ public class KursivParserService implements ParserService {
@Value("${rss.feed.url}")
private String rssFeedUrl;
@Value("${parser.scheduler.enabled:true}")
private boolean schedulerEnabled;
@Override
public String getSourceName() {
return "kursiv";
@@ -49,6 +52,10 @@ public class KursivParserService implements ParserService {
*/
@Scheduled(cron = "0 0/5 * * * ?")
public void scheduledParseAndStoreNews() {
if (!schedulerEnabled) {
logger.debug("⏸️ Планировщик отключен. Пропуск планового парсинга Kursiv.media");
return;
}
logger.info("🔄 Запуск планового парсинга новостей с Kursiv.media...");
try {
List<MarketItem> savedItems = parseAndSaveRssFeed();
@@ -38,6 +38,9 @@ public class LsmParserService implements ParserService {
@Value("${rss.lsm.url}")
private String rssFeedUrl;
@Value("${parser.scheduler.enabled:true}")
private boolean schedulerEnabled;
@Override
public String getSourceName() {
return "lsm";
@@ -49,6 +52,10 @@ public class LsmParserService implements ParserService {
*/
@Scheduled(cron = "0 0/30 * * * ?")
public void scheduledParseAndStoreNews() {
if (!schedulerEnabled) {
logger.debug("⏸️ Планировщик отключен. Пропуск планового парсинга LSM.kz");
return;
}
logger.info("🔄 Запуск планового парсинга новостей с LSM.kz...");
try {
List<MarketItem> savedItems = parseAndSaveRssFeed();
@@ -38,6 +38,9 @@ public class RbcParserService implements ParserService {
@Value("${rss.rbc.url}")
private String rssFeedUrl;
@Value("${parser.scheduler.enabled:true}")
private boolean schedulerEnabled;
@Override
public String getSourceName() {
return "rbc";
@@ -49,6 +52,10 @@ public class RbcParserService implements ParserService {
*/
@Scheduled(cron = "0 0/30 * * * ?")
public void scheduledParseAndStoreNews() {
if (!schedulerEnabled) {
logger.debug("⏸️ Планировщик отключен. Пропуск планового парсинга РБК");
return;
}
logger.info("🔄 Запуск планового парсинга новостей с РБК...");
try {
List<MarketItem> savedItems = parseAndSaveRssFeed();
@@ -38,6 +38,9 @@ public class VedomostiParserService implements ParserService {
@Value("${rss.vedomosti.url}")
private String rssFeedUrl;
@Value("${parser.scheduler.enabled:true}")
private boolean schedulerEnabled;
@Override
public String getSourceName() {
return "vedomosti";
@@ -49,6 +52,10 @@ public class VedomostiParserService implements ParserService {
*/
@Scheduled(cron = "0 0/30 * * * ?")
public void scheduledParseAndStoreNews() {
if (!schedulerEnabled) {
logger.debug("⏸️ Планировщик отключен. Пропуск планового парсинга Ведомости");
return;
}
logger.info("🔄 Запуск планового парсинга новостей с Ведомости...");
try {
List<MarketItem> savedItems = parseAndSaveRssFeed();
@@ -33,6 +33,7 @@ rss.rbc.url=https://static.feed.rbc.ru/rbc/logical/footer/news.rss
rss.vedomosti.url=https://www.vedomosti.ru/rss/rubric/technology/internet
# Scheduler Configuration
parser.scheduler.enabled=false
spring.task.scheduling.pool.size=5
spring.task.scheduling.thread-name-prefix=scheduled-task-