diff --git a/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/enums/IEnumWithLongValue.java b/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/enums/IEnumWithLongValue.java deleted file mode 100644 index 3e46ccc59..000000000 --- a/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/enums/IEnumWithLongValue.java +++ /dev/null @@ -1,81 +0,0 @@ -package ru.spcex.clearing.scheduler.enums; - -import java.io.Serializable; -import java.util.Objects; - -/** - * Удобный интерфейс для enum при использовании TextErrorService. - */ -public interface IEnumWithLongValue extends Serializable { - - - /** - * Проверяет что среди данного набора Enum, присутствует элемент с данным id - * id может быть null - */ - static & IEnumWithLongValue> boolean contains(Long id, T... enumSet) { - for (T e : enumSet) { - if (Objects.equals(id, e.getId())) - return true; - } - return false; - } - - static & IEnumWithLongValue> boolean contains(T e, T... enumSet) { - for (T enumEl : enumSet) { - if (enumEl.equals(e)) - return true; - } - return false; - } - - static & IEnumWithLongValue> Long[] toLongArray(T... enumSet) { - Long[] enumId = new Long[enumSet.length]; - for (int i = 0; i < enumSet.length; i++) - enumId[i] = enumSet[i].getId(); - return enumId; - } - - /** - * Проверяет что среди всех Enum данного класса, присутствует элемент с данным id - * id может быть null - */ - static & IEnumWithLongValue> boolean contains(Class enumClass, Long id) { - for (T e : enumClass.getEnumConstants()) { - if (Objects.equals(id, e.getId())) - return true; - } - return false; - } - - - /** - * Возвращает Enum по id, если в заданном классе такой определен - * id может быть null - * - * @return Enum если нашел, иначе null - */ - static & IEnumWithLongValue> T getEnumById(Class enumClass, Long id) { - for (T e : enumClass.getEnumConstants()) { - if (Objects.equals(id, e.getId())) - return e; - } - return null; - } - - static Long getIdOrNull(IEnumWithLongValue enumVal) { - return enumVal == null ? null : enumVal.getId(); - } - - - /** - * errorCode - **/ - Long getId(); - - default boolean equalsById(Long id) { - return id != null && getId().equals(id); - } - - String elementName(); -} diff --git a/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/enums/TaskStatuses.java b/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/enums/TaskStatuses.java deleted file mode 100644 index b4f82ea38..000000000 --- a/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/enums/TaskStatuses.java +++ /dev/null @@ -1,35 +0,0 @@ -package ru.spcex.clearing.scheduler.enums; - -import java.util.Objects; - -public enum TaskStatuses { - ACTIVE("ACTV"), - BLOCKED("CNCL"), - CANCEL("BLKD"); - - private final String name; - - TaskStatuses(String name) { - this.name = name; - } - - public static TaskStatuses getEnumByName(String name) { - for (TaskStatuses e : TaskStatuses.values()) { - if (Objects.equals(name, e.name())) - return e; - } - return null; - } - - public Boolean equalsByName(String name) { - return this.name.equalsIgnoreCase(name); - } - - public String getName() { - return this.name; - } - - public String elementName() { - return this.name(); - } -} diff --git a/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/enums/Tasks.java b/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/enums/Tasks.java deleted file mode 100644 index b92b42108..000000000 --- a/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/enums/Tasks.java +++ /dev/null @@ -1,45 +0,0 @@ -package ru.spcex.clearing.scheduler.enums; - -import java.util.Objects; - -public enum Tasks { - GBAL("GBAL"),//Зачисление остатков - ABLK("ABLK"),//Блокировка счета - GALB("GALB"),//Запрос остатков по всем счетам - ADBL("ADBL"),//Дозачисление/списание остатков - CORD("CORD"),//Формирование сводного платежного поручения - CORC("CORC"),//Получение подтверждения переводов - GTRD("GTRD"),//Получение сделок из Торговой системы - GVER("GVER"),// Запуск сверки - GBLD("GBLD"),// Поступление средств - SCLR("SCLR"),// Запуск клиринговой сессии - SPRC("SPRC"),// Запуск преклиринга - SPOC("SPOC");// Запуск постклиринга - - private String name; - - Tasks(String name) { - this.name = name; - } - - public static Tasks getEnumByName(String name) { - for (Tasks e : Tasks.values()) { - if (Objects.equals(name, e.name())) - return e; - } - return null; - } - - public Boolean equalsByName(String name) { - return this.name.equalsIgnoreCase(name); - } - - public String getName() { - return this.name; - } - - public String elementName() { - return this.name(); - } - -} diff --git a/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/service/TaskManager.java b/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/service/TaskManager.java index 4bfd70cdb..4db6e99b2 100644 --- a/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/service/TaskManager.java +++ b/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/service/TaskManager.java @@ -11,8 +11,8 @@ import org.slf4j.LoggerFactory; import org.springframework.beans.factory.InitializingBean; import org.springframework.scheduling.TaskScheduler; import ru.clearing.classes.statics.data.scheduler.PlannerAllToday; -import ru.spcex.clearing.scheduler.enums.TaskStatuses; -import ru.spcex.clearing.scheduler.enums.Tasks; +import ru.spcex.platform.enumeration.Status; +import ru.spcex.platform.enumeration.Task; import java.time.LocalDate; import java.time.LocalDateTime; @@ -27,7 +27,8 @@ import java.util.concurrent.ScheduledFuture; import java.util.stream.Collectors; import static ru.spcex.clearing.imdg.IMDGDistributedNames.Map_PlannerAllToday; -import static ru.spcex.clearing.scheduler.enums.TaskStatuses.*; +import static ru.spcex.platform.enumeration.Status.*; +import static ru.spcex.platform.utils.enumeration.IEnumKey.getEnumByKey; /** * Планировщик задач, расписание берёт из Hazelcast map. @@ -73,7 +74,7 @@ public abstract class TaskManager implements EntryAddedListener event) { PlannerAllToday task = event.getValue(); - Tasks taskType = Tasks.getEnumByName(task.getTask()); + Task taskType = getEnumByKey(Task.class, task.getTask()); if (taskType == null) { log.warn("Task skipped, {} task type not recognized", task.getTask()); return; @@ -89,23 +90,23 @@ public abstract class TaskManager implements EntryAddedListener schedulerAllTodays = plannerAllTodayMapStore.values(); Collection sortedSchedulers = - schedulerAllTodays.stream().sorted((o1, o2) -> (ACTIVE.equalsByName(o1.getTaskStatus()) && CANCEL.equalsByName(o2.getTaskStatus())) ? -1 : 0) + schedulerAllTodays.stream().sorted((o1, o2) -> (Active.equalsByKey(o1.getTaskStatus()) && Cancel.equalsByKey(o2.getTaskStatus())) ? -1 : 0) .collect(Collectors.toCollection(ArrayList::new)); for (PlannerAllToday schedulerAllToday : sortedSchedulers) { processTask(schedulerAllToday); @@ -155,8 +156,8 @@ public abstract class TaskManager implements EntryAddedListener