treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-51

Browse source 
---
some fix up
This commit is contained in:
aalehin 2022-11-29 19:10:53 +03:00
parent d5a7154a25
commit 49729c4d08
2 changed files with 44 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/services/AbstractHazelcastLifecycleSupport.java
View file

@ -19,30 +19,30 @@ import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;
import static ru.spcex.clearing.imdg.util.Util.makeSchedulerAllTodayMap;
//todo почистить класс
public abstract class AbstractHazelcastLifecycleSupport implements InitializingBean, DisposableBean {
/**
* Рабочая версия БД. Треьуется вручную сверять с DDL.sql и накручивать эту переменную.
*/
public abstract String getCheckDbVersion();
/**
* Обязательная сверка у этих классов SerialVersionUID во время подключения к Storage.
*/
public abstract Class[] getSerialVersionUIDClasses();
private final Logger log = LoggerFactory.getLogger(this.getClass());
private final HazelcastInstance hazelcastServerInstance;
private final JdbcTemplate jdbcTemplate;
// private final HazelcastClientListener clientListener;
// private final ITaskAdministrator startupTasksAdministrator;
public AbstractHazelcastLifecycleSupport(HazelcastInstance hazelcastServerInstance, JdbcTemplate jdbcTemplate) {
this.hazelcastServerInstance = hazelcastServerInstance;
this.jdbcTemplate = jdbcTemplate;
}
/**
* Рабочая версия БД. Треьуется вручную сверять с DDL.sql и накручивать эту переменную.
*/
public abstract String getCheckDbVersion();
// private final HazelcastClientListener clientListener;
// private final ITaskAdministrator startupTasksAdministrator;
/**
* Обязательная сверка у этих классов SerialVersionUID во время подключения к Storage.
*/
public abstract Class[] getSerialVersionUIDClasses();
@Override
public void afterPropertiesSet() {
@ -99,7 +99,7 @@ public abstract class AbstractHazelcastLifecycleSupport implements InitializingB
boolean generatorResult = generator.init(maxKey);
if (generatorResult) {
log.info("IDGenerator {} success init by {}", IMDGDistributedNames.MAP_SEQUENCE_NAME, maxKey);
// makeSchedulerAllTodayMap();
makeSchedulerAllTodayMap(hazelcastServerInstance);
} else {
log.info("IDGenerator {} already initialized in other node", IMDGDistributedNames.MAP_SEQUENCE_NAME);
}
@ -114,7 +114,6 @@ public abstract class AbstractHazelcastLifecycleSupport implements InitializingB
}
@Override
public void destroy() {
hazelcastServerInstance.shutdown();

30
clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/util/Util.java Normal file
View file

@ -0,0 +1,30 @@
package ru.spcex.clearing.imdg.util;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.core.IMap;
import ru.clearing.classes.statics.data.scheduler.Scheduler;
import ru.clearing.classes.statics.data.scheduler.Timetable;
import ru.clearing.classes.statics.data.scheduler.TradingCalendar;
import java.time.LocalDate;
import java.util.List;
import static ru.spcex.clearing.imdg.IMDGDistributedNames.*;
public class Util {
public static void makeSchedulerAllTodayMap(HazelcastInstance hazelcastInstance) {
IMap<Long, Scheduler> schedulerMap = hazelcastInstance.getMap(Map_Scheduler);
IMap<Long, TradingCalendar> tradingCalendarMap = hazelcastInstance.getMap(Map_TradingCalendar);
IMap<Long, Timetable> timetableMap = hazelcastInstance.getMap(Map_Timetable);
Boolean isTradingCalendarEmpty = tradingCalendarMap.isEmpty();
List<Scheduler> listOfSchedulerOnDate = schedulerMap.values().stream().filter((x) -> x.getClearingDate().isEqual(LocalDate.now())).toList();
if (isTradingCalendarEmpty) {
//то из timeTable все активные записи.
} else {
}
}
}