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

MoneyMarketSecurityUpdateRequest, CommonDeleteRequest -> WithId

Browse source 
Planner, PlannerTemplate fill created/updated
This commit is contained in:
ialbert 2022-12-26 13:14:04 +03:00
parent e278d65325
commit 095b2d86d1
5 changed files with 13 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
clearing-parent/dbf-exporter/src/main/resources/application.properties
View file

@ -9,7 +9,7 @@ export-dbf-service.hazelcast.password=dev-pass
export-dbf-service.common.encoding=cp866 export-dbf-service.common.encoding=cp866
export-dbf-service.common.threads-count=10 export-dbf-service.common.threads-count=10
export-dbf-service.store.out-dir=/opt/clearing/file/exporter/ export-dbf-service.store.out-dir=d:\\trash\\clearing\\exporter\\out\\
export-dbf-service.kafka-consumer.bootstrap-servers=localhost:9092 export-dbf-service.kafka-consumer.bootstrap-servers=localhost:9092
export-dbf-service.kafka-consumer.group-id=dev-group-balance-service export-dbf-service.kafka-consumer.group-id=dev-group-balance-service

4
clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/service/PlannerService.java
View file

@ -18,6 +18,8 @@ import ru.spcex.clearing.platform.messaging.service.QueueConsumer;
import ru.spcex.platform.imdg.api.Imdg; import ru.spcex.platform.imdg.api.Imdg;
import ru.spcex.platform.imdg.api.ImdgProvider; import ru.spcex.platform.imdg.api.ImdgProvider;
import java.time.Instant;
@Service @Service
public class PlannerService extends QueueConsumer implements InitializingBean { public class PlannerService extends QueueConsumer implements InitializingBean {
private final Logger log = LoggerFactory.getLogger(getClass()); private final Logger log = LoggerFactory.getLogger(getClass());
@ -48,6 +50,7 @@ public class PlannerService extends QueueConsumer implements InitializingBean {
PlannerNewRequest req = userRequest.getRequestPayload(); PlannerNewRequest req = userRequest.getRequestPayload();
log.debug("PlannerNewRequest received"); log.debug("PlannerNewRequest received");
Planner planner = new Planner(); Planner planner = new Planner();
planner.setCreated(Instant.now());
planner.setTask(req.getTask()); planner.setTask(req.getTask());
planner.setTaskTime(req.getTaskTime()); planner.setTaskTime(req.getTaskTime());
planner.setClearingDate(req.getClearingDate()); planner.setClearingDate(req.getClearingDate());
@ -63,6 +66,7 @@ public class PlannerService extends QueueConsumer implements InitializingBean {
PlannerUpdateRequest req = userRequest.getRequestPayload(); PlannerUpdateRequest req = userRequest.getRequestPayload();
log.debug("PlannerUpdateRequest received id = {}", req.getId()); log.debug("PlannerUpdateRequest received id = {}", req.getId());
Planner planner = plannerMap.getSingleObjectByID(req.getId()); Planner planner = plannerMap.getSingleObjectByID(req.getId());
planner.setUpdated(Instant.now());
planner.setTask(req.getTask()); planner.setTask(req.getTask());
planner.setTaskTime(req.getTaskTime()); planner.setTaskTime(req.getTaskTime());
planner.setClearingDate(req.getClearingDate()); planner.setClearingDate(req.getClearingDate());

4
clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/service/PlannerTemplateService.java
View file

@ -18,6 +18,8 @@ import ru.spcex.clearing.platform.messaging.service.QueueConsumer;
import ru.spcex.platform.imdg.api.Imdg; import ru.spcex.platform.imdg.api.Imdg;
import ru.spcex.platform.imdg.api.ImdgProvider; import ru.spcex.platform.imdg.api.ImdgProvider;
import java.time.Instant;
@Service @Service
public class PlannerTemplateService extends QueueConsumer implements InitializingBean { public class PlannerTemplateService extends QueueConsumer implements InitializingBean {
private final Logger log = LoggerFactory.getLogger(getClass()); private final Logger log = LoggerFactory.getLogger(getClass());
@ -48,6 +50,7 @@ public class PlannerTemplateService extends QueueConsumer implements Initializin
PlannerTemplateNewRequest req = userRequest.getRequestPayload(); PlannerTemplateNewRequest req = userRequest.getRequestPayload();
log.debug("PlannerTemplateNewRequest received"); log.debug("PlannerTemplateNewRequest received");
PlannerTemplate plannerTemplate = new PlannerTemplate(); PlannerTemplate plannerTemplate = new PlannerTemplate();
plannerTemplate.setCreated(Instant.now());
plannerTemplate.setTask(req.getTask()); plannerTemplate.setTask(req.getTask());
plannerTemplate.setTaskTime(req.getTaskTime()); plannerTemplate.setTaskTime(req.getTaskTime());
plannerTemplate.setTaskStatus(req.getTaskStatus()); plannerTemplate.setTaskStatus(req.getTaskStatus());
@ -61,6 +64,7 @@ public class PlannerTemplateService extends QueueConsumer implements Initializin
PlannerTemplateUpdateRequest req = userRequest.getRequestPayload(); PlannerTemplateUpdateRequest req = userRequest.getRequestPayload();
log.debug("PlannerTemplateUpdateRequest received"); log.debug("PlannerTemplateUpdateRequest received");
PlannerTemplate plannerTemplate = plannerTemplateMap.getSingleObjectByID(req.getId()); PlannerTemplate plannerTemplate = plannerTemplateMap.getSingleObjectByID(req.getId());
plannerTemplate.setUpdated(Instant.now());
plannerTemplate.setTask(req.getTask()); plannerTemplate.setTask(req.getTask());
plannerTemplate.setTaskTime(req.getTaskTime()); plannerTemplate.setTaskTime(req.getTaskTime());
plannerTemplate.setTaskStatus(req.getTaskStatus()); plannerTemplate.setTaskStatus(req.getTaskStatus());

3
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/common/CommonDeleteRequest.java
View file

@ -1,8 +1,9 @@
package ru.spcex.clearing.platform.messaging.domain.cud.common; package ru.spcex.clearing.platform.messaging.domain.cud.common;
import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonProperty;
import ru.spcex.platform.classes.base.interfaces.WithId;
public class CommonDeleteRequest { public class CommonDeleteRequest implements WithId {
@JsonProperty @JsonProperty
public Long id; public Long id;

3
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/cud/securitites/MoneyMarketSecurityUpdateRequest.java
View file

@ -7,11 +7,12 @@ import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import ru.spcex.clearing.platform.messaging.domain.json.deserialize.LocalDateDeserializer; import ru.spcex.clearing.platform.messaging.domain.json.deserialize.LocalDateDeserializer;
import ru.spcex.clearing.platform.messaging.domain.json.serialize.LocalDateSerializer; import ru.spcex.clearing.platform.messaging.domain.json.serialize.LocalDateSerializer;
import ru.spcex.platform.classes.base.interfaces.WithEndDt; import ru.spcex.platform.classes.base.interfaces.WithEndDt;
import ru.spcex.platform.classes.base.interfaces.WithId;
import ru.spcex.platform.classes.base.interfaces.WithStartDt; import ru.spcex.platform.classes.base.interfaces.WithStartDt;
import java.time.LocalDate; import java.time.LocalDate;
public class MoneyMarketSecurityUpdateRequest implements WithStartDt, WithEndDt { public class MoneyMarketSecurityUpdateRequest implements WithId, WithStartDt, WithEndDt {
@JsonProperty @JsonProperty
public Long id; public Long id;
@JsonFormat(pattern = "yyyy-MM-dd", timezone = "Europe/Moscow") @JsonFormat(pattern = "yyyy-MM-dd", timezone = "Europe/Moscow")