From 55cd288dd9b0096e54db8450f3669f4ae8084e40 Mon Sep 17 00:00:00 2001
From: aalehin <aalehin@mfd.ru>
Date: Mon, 12 Dec 2022 13:15:34 +0300
Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-57=20---=20?=
 =?UTF-8?q?scheduler=5Fservice:=20=D0=B4=D0=BE=D0=B1=D0=B0=D0=B2=D0=BB?=
 =?UTF-8?q?=D0=B5=D0=BD=D0=B8=D0=B5=20=D0=B7=D0=B0=D0=BF=D0=B8=D1=81=D0=B8?=
 =?UTF-8?q?=20=D0=B2=20launcher=20=D1=87=D0=B5=D1=80=D0=B5=D0=B7=20=D0=BD?=
 =?UTF-8?q?=D0=BE=D0=B2=D1=8B=D0=B9=20=D1=81=D0=B5=D1=80=D0=B2=D0=B8=D1=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../scheduler/service/LauncherService.java    | 52 +++++++++++++++++++
 1 file changed, 52 insertions(+)
 create mode 100644 clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/service/LauncherService.java

diff --git a/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/service/LauncherService.java b/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/service/LauncherService.java
new file mode 100644
index 000000000..82e9862af
--- /dev/null
+++ b/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/service/LauncherService.java
@@ -0,0 +1,52 @@
+package ru.spcex.clearing.scheduler.service;
+
+import org.apache.kafka.clients.consumer.Consumer;
+import org.apache.kafka.clients.producer.Producer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.beans.factory.annotation.Autowired;
+import ru.clearing.classes.statics.data.scheduler.Launcher;
+import ru.spcex.clearing.imdg.IMDGDistributedNames;
+import ru.spcex.clearing.platform.messaging.domain.BaseRequest;
+import ru.spcex.clearing.platform.messaging.domain.Consts;
+import ru.spcex.clearing.platform.messaging.domain.cud.schedule.LauncherCommandRequest;
+import ru.spcex.clearing.platform.messaging.service.QueueConsumer;
+import ru.spcex.platform.imdg.api.Imdg;
+import ru.spcex.platform.imdg.api.ImdgProvider;
+
+import java.time.Instant;
+
+public class LauncherService extends QueueConsumer implements InitializingBean {
+    private final Logger log = LoggerFactory.getLogger(getClass());
+    private final Imdg<Launcher> launcherMap;
+
+    @Autowired
+    public LauncherService(Consumer<String, Object> kafkaQueue, Producer<String, Object> kafkaProducer,
+                           ImdgProvider imdgProvider) {
+        super(kafkaQueue, kafkaProducer);
+        this.launcherMap = imdgProvider.getImdg(IMDGDistributedNames.Map_Launcher, Launcher.class);
+    }
+
+    @Override
+    public void afterPropertiesSet() {
+        callback(LauncherCommandRequest.class)
+                .setConsumer(this::newLauncher)
+                .forDestination(Consts.LAUNCHER_NEW, callbacks::put);
+        init();
+    }
+
+    private void newLauncher(BaseRequest<LauncherCommandRequest> userRequest) {
+        LauncherCommandRequest req = userRequest.getRequestPayload();
+        log.debug("LauncherCommandRequest received");
+        Instant created = Instant.now();
+        Launcher launcher = new Launcher();
+        launcher.setTask(req.getTaskName());
+        launcher.setSenderId(req.getUserId());
+        launcher.setCreated(created);
+        launcher.setUpdated(created);
+        launcherMap.insert(launcher);
+        log.debug("successfully processed, new id {}", launcher.getId());
+    }
+
+}