feat: dispara pedido via kafka no topico pedido

FIAP-Tech-Chalenge · Aug 28, 2024 · 4569ec7 · 4569ec7
1 parent 9a9143e
commit 4569ec7
Show file tree

Hide file tree

Showing 8 changed files with 128 additions and 22 deletions.
diff --git a/...idoapi/application/controllers/cozinha/pedidos/preparo/IniciaPreparoPedidoController.java b/...idoapi/application/controllers/cozinha/pedidos/preparo/IniciaPreparoPedidoController.java
@@ -8,9 +8,11 @@
 import com.fiap.mspedidoapi.domain.presenters.pedido.PedidoProntoPresenter;
 import com.fiap.mspedidoapi.domain.useCase.pedido.IniciaPreparoPedidoUseCase;
 import com.fiap.mspedidoapi.infra.adpter.repository.pedido.PreparaPedidoRepository;
+import com.fiap.mspedidoapi.infra.kafka.producers.PreparaPedidoProducer;
 import com.fiap.mspedidoapi.infra.repository.PedidosMongoRepository;
 import io.swagger.v3.oas.annotations.Operation;
 import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -22,11 +24,15 @@
 @RequestMapping("cozinha/pedido")
 public class IniciaPreparoPedidoController {
     private final PedidosMongoRepository pedidosMongoRepository;
+    @Value("${spring.kafka.producer.bootstrap-servers}")
+    private String servers;
 
     @PostMapping("/inicia-preparo")
     @Operation(tags = {"cozinha"})
     public ResponseEntity<Object> iniciaPreparoPedido(@RequestBody StoreIniciaPreparoProdutoRequest iniciaPreparoProdutoRequest) {
-        IniciaPreparoPedidoUseCase useCase = new IniciaPreparoPedidoUseCase(new PreparaPedidoRepository(pedidosMongoRepository));
+        IniciaPreparoPedidoUseCase useCase = new IniciaPreparoPedidoUseCase(
+            new PreparaPedidoRepository(pedidosMongoRepository),
+            new PreparaPedidoProducer(servers));
         useCase.execute(iniciaPreparoProdutoRequest.uuid(), iniciaPreparoProdutoRequest.tempoDePreparo());
         OutputInterface outputInterface = useCase.getOutputInterface();
 

diff --git a/src/main/java/com/fiap/mspedidoapi/domain/gateway/pedido/PreparaPedidoInterface.java b/src/main/java/com/fiap/mspedidoapi/domain/gateway/pedido/PreparaPedidoInterface.java
@@ -1,12 +1,11 @@
 package com.fiap.mspedidoapi.domain.gateway.pedido;
 
-import com.fiap.mspedidoapi.domain.entity.entrega.Entrega;
+import com.fiap.mspedidoapi.domain.entity.pedido.PedidoEntity;
 import com.fiap.mspedidoapi.domain.exception.pedido.PedidoNaoEncontradoException;
-import com.fiap.mspedidoapi.infra.collection.pedido.Pedido;
 
 import java.util.UUID;
 
 public interface PreparaPedidoInterface {
-    Pedido encontraPedidoPorUuid(UUID pedidoUuid) throws PedidoNaoEncontradoException;
-    Entrega movePedidoParaEmPreparacao(UUID pedidoUuid, Integer tempoDePreparoEmMinutos) throws PedidoNaoEncontradoException;
+    PedidoEntity encontraPedidoPorUuid(UUID pedidoUuid) throws PedidoNaoEncontradoException;
+    PedidoEntity movePedidoParaEmPreparacao(UUID pedidoUuid, Integer tempoDePreparoEmMinutos) throws PedidoNaoEncontradoException;
 }
diff --git a/...in/java/com/fiap/mspedidoapi/domain/gateway/producers/PreparaPedidoProducerInterface.java b/...in/java/com/fiap/mspedidoapi/domain/gateway/producers/PreparaPedidoProducerInterface.java
@@ -0,0 +1,7 @@
+package com.fiap.mspedidoapi.domain.gateway.producers;
+
+import com.fiap.mspedidoapi.domain.output.pedido.PedidoEmPreparacaoOutput;
+
+public interface PreparaPedidoProducerInterface {
+    void send(PedidoEmPreparacaoOutput pedidoEmPreparacaoOutput);
+}
diff --git a/src/main/java/com/fiap/mspedidoapi/domain/output/pedido/PedidoEmPreparacaoOutput.java b/src/main/java/com/fiap/mspedidoapi/domain/output/pedido/PedidoEmPreparacaoOutput.java
@@ -0,0 +1,34 @@
+package com.fiap.mspedidoapi.domain.output.pedido;
+
+import com.fiap.mspedidoapi.domain.entity.pedido.PedidoEntity;
+import com.fiap.mspedidoapi.domain.generic.output.OutputInterface;
+import com.fiap.mspedidoapi.domain.generic.output.OutputStatus;
+import lombok.Data;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+import lombok.Setter;
+
+@Data
+@RequiredArgsConstructor
+@Getter
+@Setter
+public class PedidoEmPreparacaoOutput implements OutputInterface {
+    private PedidoEntity pedido;
+    private OutputStatus outputStatus;
+
+    public PedidoEmPreparacaoOutput(PedidoEntity pedido, OutputStatus outputStatus) {
+        this.pedido = pedido;
+        this.outputStatus = outputStatus;
+    }
+
+    @Override
+    public Object getBody() {
+        return this.pedido;
+    }
+
+    @Override
+    public OutputStatus getOutputStatus() {
+        return this.outputStatus;
+    }
+
+}
diff --git a/src/main/java/com/fiap/mspedidoapi/domain/useCase/pedido/IniciaPreparoPedidoUseCase.java b/src/main/java/com/fiap/mspedidoapi/domain/useCase/pedido/IniciaPreparoPedidoUseCase.java
@@ -1,14 +1,14 @@
 package com.fiap.mspedidoapi.domain.useCase.pedido;
 
-import com.fiap.mspedidoapi.domain.entity.entrega.Entrega;
+import com.fiap.mspedidoapi.domain.entity.pedido.PedidoEntity;
 import com.fiap.mspedidoapi.domain.enums.pedido.StatusPedido;
 import com.fiap.mspedidoapi.domain.exception.pedido.PedidoNaoEncontradoException;
 import com.fiap.mspedidoapi.domain.gateway.pedido.PreparaPedidoInterface;
+import com.fiap.mspedidoapi.domain.gateway.producers.PreparaPedidoProducerInterface;
 import com.fiap.mspedidoapi.domain.generic.output.OutputError;
 import com.fiap.mspedidoapi.domain.generic.output.OutputInterface;
 import com.fiap.mspedidoapi.domain.generic.output.OutputStatus;
-import com.fiap.mspedidoapi.domain.output.pedido.PedidoProntoOutput;
-import com.fiap.mspedidoapi.infra.collection.pedido.Pedido;
+import com.fiap.mspedidoapi.domain.output.pedido.PedidoEmPreparacaoOutput;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 
@@ -19,6 +19,7 @@
 public class IniciaPreparoPedidoUseCase {
 
     private final PreparaPedidoInterface preparaPedidoInterface;
+    private final PreparaPedidoProducerInterface preparaPedidoProducerInterface;
     private OutputInterface outputInterface;
 
     public void execute(UUID pedidoUUID, Integer tempoDePreparoEmMinutos) {
@@ -32,19 +33,19 @@ public void execute(UUID pedidoUUID, Integer tempoDePreparoEmMinutos) {
                 return;
             }
 
-            Pedido pedidoEncontrado = preparaPedidoInterface.encontraPedidoPorUuid(pedidoUUID);
+            PedidoEntity pedidoEncontrado = preparaPedidoInterface.encontraPedidoPorUuid(pedidoUUID);
 
             if(pedidoEncontrado.getStatusPedido() != StatusPedido.RECEBIDO) {
                 this.outputInterface = new OutputError(
                     "Error", 
-                    new OutputStatus(404, "Not found", "Pedido precisa estar com status RECEBIDO para dar inicio ao preparo")
+                    new OutputStatus(404, "Status invalido", "Pedido precisa estar com status RECEBIDO para dar inicio ao preparo")
                 );
                 return;
             }
 
-            Entrega entrega = preparaPedidoInterface.movePedidoParaEmPreparacao(pedidoUUID, tempoDePreparoEmMinutos);
-            this.outputInterface = new PedidoProntoOutput(
-                entrega,
+            PedidoEntity pedidoEmPreparacao = preparaPedidoInterface.movePedidoParaEmPreparacao(pedidoUUID, tempoDePreparoEmMinutos);
+            this.outputInterface = new PedidoEmPreparacaoOutput(
+                pedidoEmPreparacao,
                 new OutputStatus(200, "OK", "Pedido atualizado.")
             );
 
@@ -59,6 +60,13 @@ public void execute(UUID pedidoUUID, Integer tempoDePreparoEmMinutos) {
                     e.getMessage(),
                     new OutputStatus(500, "Internal Server Error", "Erro no servidor")
             );
+        } finally {
+            if (this.preparaPedidoProducerInterface != null
+                    && this.outputInterface instanceof PedidoEmPreparacaoOutput &&
+                    this.outputInterface.getOutputStatus().getCode() == 200
+            ) {
+                this.preparaPedidoProducerInterface.send((PedidoEmPreparacaoOutput) outputInterface);
+            }
         }
     }
 

diff --git a/...ain/java/com/fiap/mspedidoapi/infra/adpter/repository/pedido/PreparaPedidoRepository.java b/...ain/java/com/fiap/mspedidoapi/infra/adpter/repository/pedido/PreparaPedidoRepository.java
@@ -1,6 +1,5 @@
 package com.fiap.mspedidoapi.infra.adpter.repository.pedido;
 
-import com.fiap.mspedidoapi.domain.entity.entrega.Entrega;
 import com.fiap.mspedidoapi.domain.enums.pedido.StatusPedido;
 import com.fiap.mspedidoapi.domain.exception.pedido.PedidoNaoEncontradoException;
 import com.fiap.mspedidoapi.domain.gateway.pedido.PreparaPedidoInterface;
@@ -16,24 +15,40 @@ public class PreparaPedidoRepository implements PreparaPedidoInterface{
     public final PedidosMongoRepository pedidosMongoRepository;
 
     @Override
-    public Pedido encontraPedidoPorUuid(UUID pedidoUuid) throws PedidoNaoEncontradoException {
+    public com.fiap.mspedidoapi.domain.entity.pedido.PedidoEntity encontraPedidoPorUuid(UUID pedidoUuid) throws PedidoNaoEncontradoException {
         Optional<Pedido> pedidoEncontrado = pedidosMongoRepository.findByUuidPedido(pedidoUuid);
         if(pedidoEncontrado.isPresent()){
-            return pedidoEncontrado.get();
+            Pedido pedidoModel = pedidoEncontrado.get();
+            return new com.fiap.mspedidoapi.domain.entity.pedido.PedidoEntity(
+                pedidoModel.getUuidPedido(),
+                pedidoModel.getClienteUuid(),
+                pedidoModel.getStatusPedido(),
+                pedidoModel.getStatusPagamento(),
+                pedidoModel.getTempoDePreparo(),
+                pedidoModel.getTotal()
+            );
         }else{
             throw new PedidoNaoEncontradoException("Pedido não encontrado");
         }
     }
 
     @Override
-    public Entrega movePedidoParaEmPreparacao(UUID pedidoUuid, Integer tempoDePreparoEmMinutos) throws PedidoNaoEncontradoException {
+    public com.fiap.mspedidoapi.domain.entity.pedido.PedidoEntity movePedidoParaEmPreparacao(UUID pedidoUuid, Integer tempoDePreparoEmMinutos) throws PedidoNaoEncontradoException {
         Optional<Pedido> pedido = pedidosMongoRepository.findByUuidPedido(pedidoUuid);
         if(pedido.isPresent()){
-            Pedido pedidoEncontrado = pedido.get();
-            pedidoEncontrado.setTempoDePreparo(tempoDePreparoEmMinutos);
-            pedidoEncontrado.setStatusPedido(StatusPedido.EM_PREPARACAO);
-            pedidosMongoRepository.save(pedidoEncontrado);
-            return new Entrega(pedidoEncontrado.getUuidPedido(), pedidoEncontrado.getNumeroPedido(), pedidoEncontrado.getStatusPedido());
+            Pedido pedidoModel = pedido.get();
+            pedidoModel.setTempoDePreparo(tempoDePreparoEmMinutos);
+            pedidoModel.setStatusPedido(StatusPedido.EM_PREPARACAO);
+            pedidosMongoRepository.save(pedidoModel);
+
+            return new com.fiap.mspedidoapi.domain.entity.pedido.PedidoEntity(
+                pedidoModel.getUuidPedido(),
+                pedidoModel.getClienteUuid(),
+                pedidoModel.getStatusPedido(),
+                pedidoModel.getStatusPagamento(),
+                pedidoModel.getTempoDePreparo(),
+                pedidoModel.getTotal()
+            );
         }else{
             throw new PedidoNaoEncontradoException("Pedido não encontrado");
         }

diff --git a/...com/fiap/mspedidoapi/infra/dependecy/kafka/resolvers/producers/KafkaProducerResolver.java b/...com/fiap/mspedidoapi/infra/dependecy/kafka/resolvers/producers/KafkaProducerResolver.java
@@ -7,4 +7,7 @@ public class KafkaProducerResolver {
     public String getEntregaProducer() {
         return KafkaTopicsEnum.entrega.name();
     }
+    public String getPedidoProducer() {
+        return KafkaTopicsEnum.pedido.name();
+    }
 }
diff --git a/src/main/java/com/fiap/mspedidoapi/infra/kafka/producers/PreparaPedidoProducer.java b/src/main/java/com/fiap/mspedidoapi/infra/kafka/producers/PreparaPedidoProducer.java
@@ -0,0 +1,34 @@
+package com.fiap.mspedidoapi.infra.kafka.producers;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import com.fiap.mspedidoapi.domain.gateway.producers.PreparaPedidoProducerInterface;
+import com.fiap.mspedidoapi.domain.output.pedido.PedidoEmPreparacaoOutput;
+import com.fiap.mspedidoapi.infra.dependecy.kafka.resolvers.producers.KafkaProducerResolver;
+import com.fiap.mspedidoapi.infra.dependecy.kafka.resolvers.producers.KafkaSenderConfig;
+
+import java.util.UUID;
+
+public class PreparaPedidoProducer extends KafkaSenderConfig implements PreparaPedidoProducerInterface {
+    private final ObjectMapper objectMapper = new ObjectMapper();   
+
+    public PreparaPedidoProducer(String servers) {
+        super(servers, new KafkaProducerResolver().getPedidoProducer());
+    }
+
+    @Override
+    public void send(PedidoEmPreparacaoOutput pedidoEmPreparacaoOutput) {
+        try {
+            ObjectNode jsonNode = objectMapper.createObjectNode();
+            jsonNode.put("uuid_pedido", pedidoEmPreparacaoOutput.getPedido().getPedidoId().toString());
+            jsonNode.put("status_pedido", pedidoEmPreparacaoOutput.getPedido().getStatusPedido().toString());
+            jsonNode.put("numero_pedido", pedidoEmPreparacaoOutput.getPedido().getNumeroPedido());
+            jsonNode.put("tempo_preparo", pedidoEmPreparacaoOutput.getPedido().getTempoDePreparoEmMinutos());
+            String json = jsonNode.toString();
+            send(UUID.randomUUID().toString(), json);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+}