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

.gitea/workflows/build.yaml

@@ -0,0 +1,15 @@
+name: Build e Deploy
+
+on:
+  push:
+    branches: [ "main", "master" ]
+
+
+jobs:
+  build-and-deploy:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Chamar Webhook do Coolify
+        run: |
+          curl -X GET "${{ secrets.DUCK_WEBHOOK }}" \
+          -H "Authorization: Bearer ${{ secrets.COOLIFY_TOKEN }}"

pom.xml

@@ -10,7 +10,7 @@
 	</parent>
 	<groupId>br.com.stackpanel</groupId>
 	<artifactId>duck-api</artifactId>
-	<version>0.0.1-SNAPSHOT</version>
+	<version>0.3.3-BETA</version>
 	<name/>
 	<description/>
 	<url/>
@@ -29,7 +29,31 @@
 	<properties>
 		<java.version>21</java.version>
 	</properties>
+	<repositories>
+		<repository>
+			<id>jitpack.io</id>
+			<url>https://jitpack.io</url>
+		</repository>
+	</repositories>
 	<dependencies>
+
+		<dependency>
+			<groupId>com.github.eduardomcb</groupId>
+			<artifactId>discord-webhook</artifactId>
+			<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/config/WebHookConfig.java

@@ -0,0 +1,53 @@
+package br.com.stackpanel.duck_api.config;
+
+import br.com.stackpanel.duck_api.entity.enums.TypeError;
+import br.com.stackpanel.duck_api.service.impl.ProductServiceImpl;
+import com.eduardomcb.discord.webhook.WebhookClient;
+import com.eduardomcb.discord.webhook.WebhookManager;
+import com.eduardomcb.discord.webhook.models.Message;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+@Component
+public class WebHookConfig {
+
+    private final String LOG_ERROR = "https://discord.com/api/webhooks/1510367769839800541/ikEQ4mnp8GBtSltnn5qwhOBawlBC8EkVfff-zFlDhBpyuTBH_-7DM0LWhEoHXNl3sHSu";
+    private final String LOG_PRECO = "https://discord.com/api/webhooks/1510368038589829140/BIkXq8-n3ZxJBv5vEYrqvu7Agf-v-dz1P1RoLHmJ7J9IkJQhVWbA_hQyWKagC2ZPzPcV";
+    private final String LOG_CADASTRO = "https://discord.com/api/webhooks/1510368356354490438/mYfx6EKfQk-MdOxbRj0rcvr49Z4MGfDHfeeHeneDWoMuTLGYIpjBpUzwi1vZwf5VA-pW";
+
+    private final Logger log = LoggerFactory.getLogger(ProductServiceImpl.class);
+
+    public void SendWebHook(String message, TypeError typeError){
+        Message msgwh = new Message().setContent(message);
+
+        String urlWebHook = switch (typeError) {
+            case LOG_ERROR -> LOG_ERROR;
+            case LOG_PRECO -> LOG_PRECO;
+            case LOG_CADASTRO -> LOG_CADASTRO;
+        };
+
+
+        WebhookManager webhookManager = new WebhookManager()
+                .setChannelUrl(urlWebHook)
+                .setMessage(msgwh);
+
+        webhookManager.setListener(
+                new WebhookClient.Callback() {
+                    @Override
+                    public void onSuccess(String response) {
+                        log.info("Mensagem enviada com sucesso!");
+                    }
+
+                    @Override
+                    public void onFailure(int statusCode, String errorMessage) {
+                        log.error("Ouve uma falha ao enviar mensagem error: '{}' status: '{}'", errorMessage, statusCode);
+                    }
+                }
+        );
+
+        webhookManager.exec();
+
+    }
+
+}

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/enums/TypeError.java

@@ -0,0 +1,8 @@
+package br.com.stackpanel.duck_api.entity.enums;
+
+public enum TypeError {
+    LOG_ERROR,
+    LOG_PRECO,
+    LOG_CADASTRO;
+
+}

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/repository/ProductRepository.java

@@ -1,9 +1,26 @@
 package br.com.stackpanel.duck_api.repository;
 
 import br.com.stackpanel.duck_api.entity.Product;
+
+import java.math.BigDecimal;
+import java.util.Optional;
+
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;
 
 @Repository
 public interface ProductRepository extends JpaRepository<Product, Long> {
+
+    @Query("""
+                SELECT prd
+                FROM Product prd
+                WHERE 1=1
+                AND (:codigoProduto IS NULL OR prd.codigoProduto = :codigoProduto)
+                AND (:nomeProduto IS NULL OR prd.nomeProduto LIKE :nomeProduto)
+                AND (:descricao IS NULL OR prd.descricaoProdutos LIKE :descricao)
+                AND (:preco IS NULL OR prd.precoProdutoAtualizado = :preco)
+            """)
+    Product buscarProdutosFiltro(Long codigoProduto, String nomeProduto, String descricao, BigDecimal preco);
+
 }

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

@@ -1,7 +1,9 @@
 package br.com.stackpanel.duck_api.service.impl;
 
+import br.com.stackpanel.duck_api.config.WebHookConfig;
 import br.com.stackpanel.duck_api.entity.Product;
 import br.com.stackpanel.duck_api.entity.dto.ProductDTO;
+import br.com.stackpanel.duck_api.entity.enums.TypeError;
 import br.com.stackpanel.duck_api.entity.mapper.ProductMapper;
 import br.com.stackpanel.duck_api.exception.ProductInvalidException;
 import br.com.stackpanel.duck_api.repository.ProductRepository;
@@ -10,6 +12,8 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.dao.DataIntegrityViolationException;
 import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
 import java.util.List;
 
 @Service
@@ -19,10 +23,12 @@ public class ProductServiceImpl implements ProductService {
 
     private final ProductRepository productRepository;
     private final ProductMapper productMapper;
+    private final WebHookConfig webHookConfig;
 
-    public ProductServiceImpl(ProductRepository productRepository, ProductMapper productMapper) {
+    public ProductServiceImpl(ProductRepository productRepository, ProductMapper productMapper, WebHookConfig webHookConfig) {
         this.productRepository = productRepository;
         this.productMapper = productMapper;
+        this.webHookConfig = webHookConfig;
     }
 
     @Override
@@ -34,6 +40,8 @@ public class ProductServiceImpl implements ProductService {
         } catch (Exception e) {
             log.error("Ocorreu um erro ao buscar produtos. Erro original: {}", e.getMessage());
 
+            webHookConfig.SendWebHook("<@&1510364267956928713> Ocorreu um erro ao buscar produtos. Erro original: " + e.getMessage(), TypeError.LOG_ERROR);
+
             throw new RuntimeException("Ocorreu um erro interno ao buscar produtos.");
         }
 
@@ -42,18 +50,56 @@ public class ProductServiceImpl implements ProductService {
     @Override
     public ProductDTO salvarProduto(ProductDTO dto) {
         try {
-            Product produto = productRepository.save(productMapper.toProductEntity(dto));
+            Product produtoExistente = productRepository.buscarProdutosFiltro(
+                    null, dto.getNomeProduto(), null, null
+            );
 
-            log.info("Produto salvo com sucesso. ID: {}", produto.getCodigoProduto());
+            Product produto;
 
+            if (produtoExistente != null) {
+                log.warn("Produto '{}' com ID: '{}' ja existe no sistema.", dto.getNomeProduto(), produtoExistente.getCodigoProduto());
+
+                BigDecimal precoAtual = produtoExistente.getPrecoProdutoAtualizado();
+                BigDecimal precoNovo  = dto.getPrecoProdutoAtualizado();
+
+                if (precoAtual.equals(precoNovo)) {
+                    log.info("Produto '{}' ID: '{}' ja existe com o mesmo preco.", dto.getNomeProduto(), produtoExistente.getCodigoProduto());
+                    return productMapper.toProductDTO(produtoExistente);
+
+                } else if (precoNovo.compareTo(precoAtual) < 0) {
+                    log.info("Produto '{}' ID: '{}' teve preco atualizado: {} -> {}",
+                            dto.getNomeProduto(), produtoExistente.getCodigoProduto(),precoAtual, precoNovo);
+
+                    webHookConfig.SendWebHook("<@&1510364303776153803> O Produto " + dto.getNomeProduto() + " teve preco atualizado: " + precoAtual + " para " + precoNovo, TypeError.LOG_PRECO);
+
+                    dto.setCodigoProduto(produtoExistente.getCodigoProduto());
+                    dto.setPrecoProdutoPrecoAnterior(precoAtual);
+                    produto = productRepository.save(productMapper.toProductEntity(dto));
+
+                } else {
+                    log.info("Produto '{}' ID: '{}' ja existe com preco menor. Nenhuma alteracao feita.", dto.getNomeProduto(), produtoExistente.getCodigoProduto());
+                    return productMapper.toProductDTO(produtoExistente);
+                }
+
+            } else {
+                webHookConfig.SendWebHook("<@&1510364549717688460> O Produto " + dto.getNomeProduto() + " foi cadastrado com sucesso.", TypeError.LOG_CADASTRO);
+                produto = productRepository.save(productMapper.toProductEntity(dto));
+            }
+
+            log.info("Produto salvo com sucesso. ID: {}, Nome: '{}'", produto.getCodigoProduto(), produto.getNomeProduto());
             return productMapper.toProductDTO(produto);
+
         } catch (DataIntegrityViolationException e) {
             String message = e.getMostSpecificCause().getMessage();
+            log.error("Erro de integridade ao salvar o produto '{}'. Motivo: {}", dto.getNomeProduto(), message);
 
-            log.error("Erro de integridade ao salvar o produto '{}'. Motivo {}", dto.getNomeProduto(), message);
+            webHookConfig.SendWebHook("<@&1510364267956928713> Erro de integridade ao salvar o produto: " + dto.getNomeProduto() + " Motivo: {}" + message, TypeError.LOG_ERROR);
             throw new ProductInvalidException("Os dados do produto sao invalidos ou ja existem no sistema.");
+
         } catch (Exception e) {
-            log.error("Erro inesperado ao salvar produto '{}'. Erro original {}", dto.getNomeProduto(), e.getMessage());
+            log.error("Erro inesperado ao salvar produto '{}'. Erro: {}", dto.getNomeProduto(), e.getMessage());
+
+            webHookConfig.SendWebHook("<@&1510364267956928713> Erro inesperado ao salvar produto: " + dto.getNomeProduto() + " Erro: " + e.getMessage(), TypeError.LOG_ERROR);
 
             throw new RuntimeException("Ocorreu um erro interno ao salvar o produto.");
         }

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}