Iniciado a implementacao do rabbit para enviar notificacoes para a fila inves de enviar direto para o DC.

pom.xml

@@ -10,7 +10,7 @@
 	</parent>
 	<groupId>br.com.stackpanel</groupId>
 	<artifactId>duck-api</artifactId>
-	<version>0.2.0-BETA</version>
+	<version>0.3.3-BETA</version>
 	<name/>
 	<description/>
 	<url/>
@@ -43,6 +43,17 @@
 			<version>1.0.0</version>
 		</dependency>
 
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-amqp</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-amqp-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-data-jpa</artifactId>

src/main/java/br/com/stackpanel/duck_api/config/RabbitConfig.java

@@ -0,0 +1,23 @@
+package br.com.stackpanel.duck_api.config;
+
+import org.springframework.amqp.core.Queue;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import static br.com.stackpanel.duck_api.entity.enums.QueueNames.QUEUE_NOTIFICATION_CAD;
+import static br.com.stackpanel.duck_api.entity.enums.QueueNames.QUEUE_NOTIFICATION_ERROR;
+
+@Configuration
+public class RabbitConfig {
+
+    @Bean
+    public Queue queueNotificationError() {
+        return new Queue(QUEUE_NOTIFICATION_ERROR.label, true);
+    }
+
+    @Bean
+    public Queue queueNotificationCad() {
+        return new Queue(QUEUE_NOTIFICATION_CAD.label, true);
+    }
+
+}

src/main/java/br/com/stackpanel/duck_api/entity/Product.java

@@ -35,10 +35,13 @@ public class Product {
     @Column(name = "nomplt")
     private String nomePlataforma;
 
+    @Column(name = "lnkprd")
+    private String linkProduto;
+
     public Product() {
     }
 
-    public Product(Long codigoProduto, String nomeProduto, String descricaoProdutos, BigDecimal precoProdutoAtualizado, BigDecimal precoProdutoPrecoAnterior, LocalDateTime ultimaDataConsultaProduto, LocalDateTime dataEnvioProduto, String nomePlataforma) {
+    public Product(Long codigoProduto, String nomeProduto, String descricaoProdutos, BigDecimal precoProdutoAtualizado, BigDecimal precoProdutoPrecoAnterior, LocalDateTime ultimaDataConsultaProduto, LocalDateTime dataEnvioProduto, String nomePlataforma, String linkProduto) {
         this.codigoProduto = codigoProduto;
         this.nomeProduto = nomeProduto;
         this.descricaoProdutos = descricaoProdutos;
@@ -47,6 +50,15 @@ public class Product {
         this.ultimaDataConsultaProduto = ultimaDataConsultaProduto;
         this.dataEnvioProduto = dataEnvioProduto;
         this.nomePlataforma = nomePlataforma;
+        this.linkProduto = linkProduto;
+    }
+
+    public String getLinkProduto() {
+        return linkProduto;
+    }
+
+    public void setLinkProduto(String linkProduto) {
+        this.linkProduto = linkProduto;
     }
 
     public String getDescricaoProdutos() {

src/main/java/br/com/stackpanel/duck_api/entity/dto/ProductDTO.java

@@ -26,10 +26,12 @@ public class ProductDTO {
     @NotNull
     private String nomePlataforma;
 
+    private String linkProduto;
+
     public ProductDTO() {
     }
 
-    public ProductDTO(Long codigoProduto, String nomeProduto, String descricaoProduto, BigDecimal precoProdutoAtualizado, BigDecimal precoProdutoPrecoAnterior, LocalDateTime ultimaDataConsultaProduto, LocalDateTime dataEnvioProduto, String nomePlataforma) {
+    public ProductDTO(Long codigoProduto, String nomeProduto, String descricaoProduto, BigDecimal precoProdutoAtualizado, BigDecimal precoProdutoPrecoAnterior, LocalDateTime ultimaDataConsultaProduto, LocalDateTime dataEnvioProduto, String nomePlataforma, String linkProduto) {
         this.codigoProduto = codigoProduto;
         this.nomeProduto = nomeProduto;
         this.descricaoProduto = descricaoProduto;
@@ -38,6 +40,15 @@ public class ProductDTO {
         this.ultimaDataConsultaProduto = ultimaDataConsultaProduto;
         this.dataEnvioProduto = dataEnvioProduto;
         this.nomePlataforma = nomePlataforma;
+        this.linkProduto = linkProduto;
+    }
+
+    public String getLinkProduto() {
+        return linkProduto;
+    }
+
+    public void setLinkProduto(String linkProduto) {
+        this.linkProduto = linkProduto;
     }
 
     public String getDescricaoProduto() {

src/main/java/br/com/stackpanel/duck_api/entity/enums/QueueNames.java

@@ -0,0 +1,15 @@
+package br.com.stackpanel.duck_api.entity.enums;
+
+public enum QueueNames {
+
+    QUEUE_NOTIFICATION_ERROR("QUEUE_NOTIFICATION_ERROR"),
+    QUEUE_NOTIFICATION_CAD("QUEUE_NOTIFICATION_CAD");
+
+
+    public final String label;
+
+    private QueueNames(String label) {
+        this.label = label;
+    }
+
+}

src/main/java/br/com/stackpanel/duck_api/entity/mapper/ProductMapper.java

@@ -21,7 +21,8 @@ public class ProductMapper {
                 product.getPrecoProdutoPrecoAnterior(),
                 product.getUltimaDataConsultaProduto(),
                 product.getDataEnvioProduto(),
-                product.getNomePlataforma()
+                product.getNomePlataforma(),
+                product.getLinkProduto()
         );
 
     }
@@ -39,7 +40,8 @@ public class ProductMapper {
                 dto.getPrecoProdutoPrecoAnterior(),
                 dto.getUltimaDataConsultaProduto(),
                 dto.getDataEnvioProduto(),
-                dto.getNomePlataforma()
+                dto.getNomePlataforma(),
+                dto.getLinkProduto()
         );
 
     }

src/main/java/br/com/stackpanel/duck_api/service/RabbitPublisherService.java

@@ -0,0 +1,7 @@
+package br.com.stackpanel.duck_api.service;
+
+public interface RabbitPublisherService {
+
+    void sendNotificationCad(String notificationCad);
+
+}

src/main/java/br/com/stackpanel/duck_api/service/impl/ProductServiceImpl.java

@@ -67,7 +67,6 @@ public class ProductServiceImpl implements ProductService {
                     return productMapper.toProductDTO(produtoExistente);
 
                 } else if (precoNovo.compareTo(precoAtual) < 0) {
-                    // precoNovo < precoAtual → atualiza (ficou mais barato)
                     log.info("Produto '{}' ID: '{}' teve preco atualizado: {} -> {}",
                             dto.getNomeProduto(), produtoExistente.getCodigoProduto(),precoAtual, precoNovo);
 
@@ -78,7 +77,6 @@ public class ProductServiceImpl implements ProductService {
                     produto = productRepository.save(productMapper.toProductEntity(dto));
 
                 } else {
-                    // precoNovo > precoAtual → nao atualiza
                     log.info("Produto '{}' ID: '{}' ja existe com preco menor. Nenhuma alteracao feita.", dto.getNomeProduto(), produtoExistente.getCodigoProduto());
                     return productMapper.toProductDTO(produtoExistente);
                 }

src/main/java/br/com/stackpanel/duck_api/service/impl/RabbitPublisherServiceImpl.java

@@ -0,0 +1,24 @@
+package br.com.stackpanel.duck_api.service.impl;
+
+import br.com.stackpanel.duck_api.service.RabbitPublisherService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+
+import static br.com.stackpanel.duck_api.entity.enums.QueueNames.QUEUE_NOTIFICATION_ERROR;
+
+public class RabbitPublisherServiceImpl implements RabbitPublisherService {
+
+    private static final Logger log = LoggerFactory.getLogger(RabbitPublisherServiceImpl.class);
+    private final RabbitTemplate rabbitTemplate;
+
+    public RabbitPublisherServiceImpl(RabbitTemplate rabbitTemplate) {
+        this.rabbitTemplate = rabbitTemplate;
+    }
+
+    @Override
+    public void sendNotificationCad(String notificationCad) {
+        log.info("Sending notification Cad: {}", notificationCad);
+        rabbitTemplate.convertAndSend(QUEUE_NOTIFICATION_ERROR.label,  notificationCad);
+    }
+}

src/main/resources/application-dbg.properties

@@ -6,3 +6,9 @@ spring.datasource.username=${db_user}
 spring.datasource.driver-class-name=org.postgresql.Driver
 spring.jpa.hibernate.ddl-auto=update
 spring.jpa.show-sql=true
+
+
+spring.rabbitmq.host=rabbit.stackpanel.com.br
+spring.rabbitmq.port=5672
+spring.rabbitmq.username=${rabbit_username}
+spring.rabbitmq.password=${rabbit_password}

src/main/resources/application-prod.properties

@@ -4,3 +4,9 @@ spring.datasource.url=${db_host:jdbc:postgresql://db.stackpanel.com.br:5432/nexu
 spring.datasource.password=${db_pass}
 spring.datasource.username=${db_user}
 spring.datasource.driver-class-name=org.postgresql.Driver
+
+
+spring.rabbitmq.host=rabbit.stackpanel.com.br
+spring.rabbitmq.port=5672
+spring.rabbitmq.username=${rabbit_username}
+spring.rabbitmq.password=${rabbit_password}