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

extdb-importer http://jira.mfd.msk:8088/browse/CLS-641 поправил опечатку

Browse source
This commit is contained in:
AKurakin 2024-02-09 19:25:12 +03:00
parent 4d7a2ebbf7
commit b722a9b90e
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
clearing-parent/extdb-importer/src/main/java/ru/spcex/clearing/extdb/importer/services/ExtDBImporterService.java
View file

@ -58,7 +58,7 @@ public class ExtDBImporterService {
public synchronized void process(boolean byCommand) { public synchronized void process(boolean byCommand) {
log.debug("Start process import SCrossRate from DB. byCommand={}", byCommand); log.debug("Start process import SCrossRate from DB. byCommand={}", byCommand);
String sql = String.format("SELECT * FROM %s.Trades", schema); String sql = String.format("SELECT * FROM %s.crossRate", schema);
Collection<SCrossRate> crossRatesFromDB = jdbcTemplate.query(sql, Collection<SCrossRate> crossRatesFromDB = jdbcTemplate.query(sql,
(resultSet, i) -> readSCrossRate(resultSet)); (resultSet, i) -> readSCrossRate(resultSet));
Instant currentInstant = Instant.now(); Instant currentInstant = Instant.now();
@ -86,7 +86,7 @@ public class ExtDBImporterService {
// В extDb нет таких полей, заполнить: // В extDb нет таких полей, заполнить:
crossRateDb.setGenerationTime(currentInstant); crossRateDb.setGenerationTime(currentInstant);
crossRateDb.setGenerationId(makeGenerationId(sCrossRate.getDate(), sCrossRate.getCurrCode())); crossRateDb.setGenerationId(makeGenerationId(crossRateDb.getDate(), crossRateDb.getCurrCode()));
} else { } else {
log.warn(messageResolver.resolve(new EnumMessage(crossRateNotValid, crossRateDb.getCurrCode()))); log.warn(messageResolver.resolve(new EnumMessage(crossRateNotValid, crossRateDb.getCurrCode())));
} }
@ -98,7 +98,7 @@ public class ExtDBImporterService {
} else { } else {
log.debug("Successfully import SCrossRate from DB by scheduled."); log.debug("Successfully import SCrossRate from DB by scheduled.");
} }
// STradesImportedRequest importRequest = new STradesImportedRequest(); // CrossRatesImportedRequest importRequest = new CrossRatesImportedRequest();
// kafka.get().sendRequestToQueue(Consts.S_CROSS_RATES_IMPORTED, importRequest); // kafka.get().sendRequestToQueue(Consts.S_CROSS_RATES_IMPORTED, importRequest);
} else { } else {
log.debug("No SCrossRate were created or updated from DB. Kafka command will not be send"); log.debug("No SCrossRate were created or updated from DB. Kafka command will not be send");
@ -145,10 +145,10 @@ public class ExtDBImporterService {
SCrossRate object = new SCrossRate(); SCrossRate object = new SCrossRate();
object.setDate(getLocalDateFromSqlDate(resultSet, "DATE")); object.setDate(getLocalDateFromSqlDate(resultSet, "DATE"));
object.setCurrency(resultSet.getObject("CURRENCY", String.class)); object.setCurrency(resultSet.getObject("CURRENCY", String.class));
object.setCurrCode(resultSet.getObject("CURR_CODE", String.class)); object.setCurrCode(resultSet.getObject("CURRCODE", String.class));
object.setFaceValue(resultSet.getObject("FACE_VALUE", BigDecimal.class)); object.setFaceValue(resultSet.getObject("FACEVALUE", BigDecimal.class));
object.setRate(resultSet.getObject("RATE", BigDecimal.class)); object.setRate(resultSet.getObject("RATE", BigDecimal.class));
object.setUnitRate(resultSet.getObject("UNIT_RATE", BigDecimal.class)); object.setUnitRate(resultSet.getObject("UNITRATE", BigDecimal.class));
return object; return object;
} }