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

create sdf56 by task GALB

Browse source
This commit is contained in:
etreschenkov 2023-05-24 11:17:22 +03:00
parent af54945fde
commit d8db3048c1
2 changed files with 65 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
clearing-parent/balance-service/src/main/java/ru/spcex/clearing/balance/service/Sdf08Service.java
View file

@ -12,7 +12,6 @@ import ru.spcex.clearing.platform.messaging.domain.Consts;
import ru.spcex.clearing.platform.messaging.domain.cud.balance.ExportToFileRequest; import ru.spcex.clearing.platform.messaging.domain.cud.balance.ExportToFileRequest;
import ru.spcex.clearing.platform.messaging.service.QueueConsumer; import ru.spcex.clearing.platform.messaging.service.QueueConsumer;
import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender; import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
import ru.spcex.platform.enumeration.Task;
import ru.spcex.platform.imdg.api.Imdg; import ru.spcex.platform.imdg.api.Imdg;
import ru.spcex.platform.imdg.api.ImdgId; import ru.spcex.platform.imdg.api.ImdgId;
import ru.spcex.platform.imdg.api.ImdgProvider; import ru.spcex.platform.imdg.api.ImdgProvider;
@ -36,10 +35,10 @@ public class Sdf08Service extends QueueConsumer implements InitializingBean {
@Override @Override
public void afterPropertiesSet() { public void afterPropertiesSet() {
callback(Object.class) // callback(Object.class)
.setConsumer(this::newSDf08) // .setConsumer(this::newSDf08)
.forDestination(Task.getAllBalance.topic(), callbacks::put); // .forDestination(Task.getAllBalance.topic(), callbacks::put);
init(); // init();
} }
private void newSDf08(BaseRequest<Object> userRequest) { private void newSDf08(BaseRequest<Object> userRequest) {

61
clearing-parent/balance-service/src/main/java/ru/spcex/clearing/balance/service/Sdf56Service.java Normal file
View file

@ -0,0 +1,61 @@
package ru.spcex.clearing.balance.service;
import org.apache.kafka.clients.consumer.Consumer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.stereotype.Service;
import ru.clearing.classes.statics.data.sdf.SDf56;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import ru.spcex.clearing.platform.messaging.domain.BaseRequest;
import ru.spcex.clearing.platform.messaging.service.QueueConsumer;
import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
import ru.spcex.platform.enumeration.Task;
import ru.spcex.platform.imdg.api.Imdg;
import ru.spcex.platform.imdg.api.ImdgId;
import ru.spcex.platform.imdg.api.ImdgProvider;
import java.time.Instant;
@Service
public class Sdf56Service extends QueueConsumer implements InitializingBean {
private final Logger log = LoggerFactory.getLogger(getClass());
private final Imdg<SDf56> sdf56Map;
private final ImdgId idGenerator;
private final KafkaSender kafkaReqProducer;
public Sdf56Service(Consumer<String, Object> kafkaQueue, ImdgProvider imdgProvider, KafkaSender kafkaReqProducer) {
super(kafkaQueue);
this.sdf56Map = imdgProvider.getImdg(IMDGDistributedNames.Map_SDf56, SDf56.class);
this.idGenerator = imdgProvider.getImdgIdGenerator();
this.kafkaReqProducer = kafkaReqProducer;
}
@Override
public void afterPropertiesSet() {
callback(Object.class)
.setConsumer(this::newSDf56)
.forDestination(Task.getAllBalance.topic(), callbacks::put);
init();
}
private void newSDf56(BaseRequest<Object> userRequest) {
log.debug("GALB request received; creating sdf56");
SDf56 sDf56 = new SDf56();
sDf56.setNumber(idGenerator.nextId().toString());
Instant now = Instant.now();
sDf56.setStart_datetime(String.valueOf(now.toEpochMilli()));
sDf56.setEnd_datetime(String.valueOf(now.toEpochMilli()));
sDf56.setAccount("ТБС");
sDf56.setDeal("КОД УК");
sDf56.setGenerationTime(now);
sDf56.setGenerationId(idGenerator.nextId());
sdf56Map.insert(sDf56);
// ExportToFileRequest exportRequest = new ExportToFileRequest();
// exportRequest.setSdfGroupId(s.getGenerationId());
// exportRequest.setNameOfTable("DF-08");
// kafkaReqProducer.sendRequestToQueue(Consts.EXPORT_PROCESS, exportRequest);
log.debug("successfully processed, new id {}", sDf56.getId());
}
}