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

currency session registry creation bugfix currency_pair_security search

Browse source 
all sessions 1st step changed sdf51 -> sdf56
This commit is contained in:
ialbert 2024-05-03 16:19:16 +03:00
parent e3f5236aee
commit a65ac4b9b6
2 changed files with 3 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/BalanceRevise.java
View file

@ -45,8 +45,8 @@ import ru.spcex.platform.imdg.api.predicate.ImdgPredicateBuilder;
import ru.spcex.platform.imdg.api.predicate.specific.RegistryCodeSqlBuilder; import ru.spcex.platform.imdg.api.predicate.specific.RegistryCodeSqlBuilder;
import ru.spcex.platform.imdg.api.predicate.specific.StatementRevisePredicate; import ru.spcex.platform.imdg.api.predicate.specific.StatementRevisePredicate;
import ru.spcex.platform.utils.enumeration.EnumMessage; import ru.spcex.platform.utils.enumeration.EnumMessage;
import ru.spcex.platform.utils.time.TimeUtil;
import static ru.spcex.platform.utils.number.BigDecimalUtil.safeBD; import static ru.spcex.platform.utils.number.BigDecimalUtil.safeBD;
import ru.spcex.platform.utils.time.TimeUtil;
@Service @Service
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE) @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
@ -77,10 +77,7 @@ public class BalanceRevise implements ISessionStage {
@Override @Override
public StageResult<?> submit(Task<?> task) { public StageResult<?> submit(Task<?> task) {
switch (task.getTaskType()) { switch (task.getTaskType()) {
case StartRevise -> { case StartRevise, FormingPaymentInstruction -> {
return sendSdfs51();
}
case FormingPaymentInstruction -> {
LocalTime fromTime = null; LocalTime fromTime = null;
if (task.getData() instanceof LocalTime) { if (task.getData() instanceof LocalTime) {
fromTime = (LocalTime) task.getData(); fromTime = (LocalTime) task.getData();

2
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/stage/impl/RegistryCurrBuilder.java
View file

@ -126,7 +126,7 @@ public class RegistryCurrBuilder implements IRegistryBuilder {
//TM_T = RUB [quote_currency_id] balance=settlement_ammount //TM_T = RUB [quote_currency_id] balance=settlement_ammount
reg.setContract(String.valueOf(exec.getSecurityId())); reg.setContract(String.valueOf(exec.getSecurityId()));
CurrencyPairSecurity curPairSec = currPairSecImdg.getFirstObjectBySQL( CurrencyPairSecurity curPairSec = currPairSecImdg.getFirstObjectBySQL(
"code = '%s'".formatted(exec.getSecuritySymbol()) //fixme or securityId = "" "id = %d".formatted(exec.getSecurityId())
); );
CurrencyPairDictionary curPairDict = null; CurrencyPairDictionary curPairDict = null;
if (curPairSec != null) { if (curPairSec != null) {