refactor: refactor packages domain

pom.xml

@@ -95,17 +95,17 @@
 
 	<build>
 		<plugins>
-		 <plugin>
-            <groupId>org.flywaydb</groupId>
-            <artifactId>flyway-maven-plugin</artifactId>
-            <version>9.16.3</version> <!-- Use a versão mais recente disponível -->
-            <configuration>
-                <url>jdbc:mysql://localhost:3306/</url>
-                <user>root</user>
-                <password>subscription</password>
-								<schemas>subscription</schemas>
-            </configuration>
-        </plugin>
+			 <plugin>
+				<groupId>org.flywaydb</groupId>
+				<artifactId>flyway-maven-plugin</artifactId>
+				<version>9.16.3</version>
+				<configuration>
+					<url>jdbc:mysql://localhost:3306/</url>
+					<user>root</user>
+					<password>subscription</password>
+					<schemas>subscription</schemas>
+				</configuration>
+			</plugin>
 			<plugin>
 				<groupId>org.springframework.boot</groupId>
 				<artifactId>spring-boot-maven-plugin</artifactId>

src/main/java/ada/tech/tenthirty/tvpackages/payloads/PackageRequest.java → src/main/java/ada/tech/tenthirty/tvpackages/application/payloads/PackageRequest.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.payloads;
+package ada.tech.tenthirty.tvpackages.application.payloads;
 
 
 import lombok.Data;

src/main/java/ada/tech/tenthirty/tvpackages/payloads/SubscriptionRequest.java → src/main/java/ada/tech/tenthirty/tvpackages/application/payloads/SubscriptionRequest.java

@@ -1,7 +1,7 @@
-package ada.tech.tenthirty.tvpackages.payloads;
+package ada.tech.tenthirty.tvpackages.application.payloads;
 
 
-import ada.tech.tenthirty.tvpackages.entity.StatusSubscription;
+import ada.tech.tenthirty.tvpackages.domain.StatusSubscription;
 import lombok.Data;
 import java.util.List;
 

src/main/java/ada/tech/tenthirty/tvpackages/payloads/UpdateSubscriptionRequest.java → src/main/java/ada/tech/tenthirty/tvpackages/application/payloads/UpdateSubscriptionRequest.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.payloads;
+package ada.tech.tenthirty.tvpackages.application.payloads;
 
 import lombok.Data;
 

src/main/java/ada/tech/tenthirty/tvpackages/payloads/response/PackageResponse.java → src/main/java/ada/tech/tenthirty/tvpackages/application/payloads/response/PackageResponse.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.payloads.response;
+package ada.tech.tenthirty.tvpackages.application.payloads.response;
 
 import lombok.Data;
 

src/main/java/ada/tech/tenthirty/tvpackages/payloads/response/SubscriptionResponse.java → src/main/java/ada/tech/tenthirty/tvpackages/application/payloads/response/SubscriptionResponse.java

@@ -1,7 +1,6 @@
-package ada.tech.tenthirty.tvpackages.payloads.response;
+package ada.tech.tenthirty.tvpackages.application.payloads.response;
 
-import ada.tech.tenthirty.tvpackages.entity.Package;
-import ada.tech.tenthirty.tvpackages.entity.StatusSubscription;
+import ada.tech.tenthirty.tvpackages.domain.StatusSubscription;
 import lombok.Data;
 
 import java.util.List;

src/main/java/ada/tech/tenthirty/tvpackages/rest/SubscriptionController.java → src/main/java/ada/tech/tenthirty/tvpackages/application/rest/SubscriptionController.java

@@ -1,10 +1,10 @@
-package ada.tech.tenthirty.tvpackages.rest;
+package ada.tech.tenthirty.tvpackages.application.rest;
 
-import ada.tech.tenthirty.tvpackages.payloads.SubscriptionRequest;
-import ada.tech.tenthirty.tvpackages.payloads.UpdateSubscriptionRequest;
-import ada.tech.tenthirty.tvpackages.payloads.response.SubscriptionResponse;
-import ada.tech.tenthirty.tvpackages.service.AddPackageSubscription;
-import ada.tech.tenthirty.tvpackages.service.CreateSubscription;
+import ada.tech.tenthirty.tvpackages.application.payloads.SubscriptionRequest;
+import ada.tech.tenthirty.tvpackages.application.payloads.UpdateSubscriptionRequest;
+import ada.tech.tenthirty.tvpackages.application.payloads.response.SubscriptionResponse;
+import ada.tech.tenthirty.tvpackages.application.service.AddPackageSubscription;
+import ada.tech.tenthirty.tvpackages.application.service.CreateSubscription;
 import ada.tech.tenthirty.tvpackages.utils.SubscriptionConvert;
 import lombok.RequiredArgsConstructor;
 

src/main/java/ada/tech/tenthirty/tvpackages/service/AddPackageSubscription.java → src/main/java/ada/tech/tenthirty/tvpackages/application/service/AddPackageSubscription.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.service;
+package ada.tech.tenthirty.tvpackages.application.service;
 
 import org.springframework.stereotype.Service;
 

src/main/java/ada/tech/tenthirty/tvpackages/application/service/CreateSubscription.java

@@ -0,0 +1,73 @@
+package ada.tech.tenthirty.tvpackages.application.service;
+
+import ada.tech.tenthirty.tvpackages.domain.Package;
+import ada.tech.tenthirty.tvpackages.domain.Subscription;
+import ada.tech.tenthirty.tvpackages.domain.User;
+import ada.tech.tenthirty.tvpackages.application.payloads.SubscriptionRequest;
+import ada.tech.tenthirty.tvpackages.infra.queue.NotifyInvoiceProducer;
+import ada.tech.tenthirty.tvpackages.infra.queue.ScheduleTechnicalVisitProducer;
+import ada.tech.tenthirty.tvpackages.infra.queue.payloads.NotifyInvoiceRequest;
+import ada.tech.tenthirty.tvpackages.infra.queue.payloads.ScheduleTechnicalVisitRequest;
+import ada.tech.tenthirty.tvpackages.infra.repository.SubscriptionRepository;
+import ada.tech.tenthirty.tvpackages.infra.repository.UserRepository;
+import ada.tech.tenthirty.tvpackages.utils.FormatDate;
+import ada.tech.tenthirty.tvpackages.utils.SubscriptionConvert;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class CreateSubscription {
+    private final SubscriptionRepository subscriptionRepository;
+    private final UserRepository userRepository;
+    private final ScheduleTechnicalVisitProducer technicalVisitQueue;
+    private final NotifyInvoiceProducer notifyInvoiceQueue;
+
+
+    public Subscription execute(SubscriptionRequest subscriptionRequest) {
+        User user = new User();
+        user.setTransactionId(subscriptionRequest.getUserId());
+        userRepository.save(user);
+
+        Subscription subscription = SubscriptionConvert.toEntity(subscriptionRequest);
+        subscription.setUser(user);
+        subscriptionRepository.save(subscription);
+
+        ScheduleTechnicalVisit(subscriptionRequest.getTransactionId(), true);
+        NotifyInvoice(subscriptionRequest.getUserId(), subscription.getListPackage());
+        return subscription;
+    }
+
+    private void ScheduleTechnicalVisit(String idUser, Boolean newUser){
+        ScheduleTechnicalVisitRequest scheduleTechnicalVisitRequest = new ScheduleTechnicalVisitRequest();
+        scheduleTechnicalVisitRequest.setIdUser(idUser);
+        scheduleTechnicalVisitRequest.setNewUSer(newUser);
+
+        try {
+            technicalVisitQueue.execute(scheduleTechnicalVisitRequest);
+        } catch (JsonProcessingException e) {
+            log.error("Não foi possível enviar a mensagem ao destinatário", e);
+            throw new RuntimeException(e);
+        }
+    }
+
+    private void  NotifyInvoice(String idUser, List<Package> listPackage){
+        NotifyInvoiceRequest notifyInvoiceProducer = new NotifyInvoiceRequest();
+
+        notifyInvoiceProducer.setIdUser(idUser);
+        notifyInvoiceProducer.setIssueDate(FormatDate.dayMothYears());
+        notifyInvoiceProducer.setListPackage(listPackage);
+
+        try{
+            notifyInvoiceQueue.execute(notifyInvoiceProducer);
+        } catch (JsonProcessingException e) {
+            log.error("Não foi possível enviar a mensagem ao destinatário", e);
+            throw new RuntimeException(e);
+        }
+    }
+}

src/main/java/ada/tech/tenthirty/tvpackages/service/GetOpenInvoice.java → src/main/java/ada/tech/tenthirty/tvpackages/application/service/GetOpenInvoice.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.service;
+package ada.tech.tenthirty.tvpackages.application.service;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;

src/main/java/ada/tech/tenthirty/tvpackages/service/GetSubscriptionById.java → src/main/java/ada/tech/tenthirty/tvpackages/application/service/GetSubscriptionById.java

@@ -1,7 +1,7 @@
-package ada.tech.tenthirty.tvpackages.service;
+package ada.tech.tenthirty.tvpackages.application.service;
 
-import ada.tech.tenthirty.tvpackages.entity.Subscription;
-import ada.tech.tenthirty.tvpackages.repository.SubscriptionRepository;
+import ada.tech.tenthirty.tvpackages.domain.Subscription;
+import ada.tech.tenthirty.tvpackages.infra.repository.SubscriptionRepository;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 

src/main/java/ada/tech/tenthirty/tvpackages/service/HttpPayment.java → src/main/java/ada/tech/tenthirty/tvpackages/application/service/HttpPayment.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.service;
+package ada.tech.tenthirty.tvpackages.application.service;
 
 import org.springframework.core.ParameterizedTypeReference;
 import org.springframework.http.HttpMethod;

src/main/java/ada/tech/tenthirty/tvpackages/entity/Package.java → src/main/java/ada/tech/tenthirty/tvpackages/domain/Package.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.entity;
+package ada.tech.tenthirty.tvpackages.domain;
 
 import java.math.BigDecimal;
 

src/main/java/ada/tech/tenthirty/tvpackages/entity/StatusSubscription.java → src/main/java/ada/tech/tenthirty/tvpackages/domain/StatusSubscription.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.entity;
+package ada.tech.tenthirty.tvpackages.domain;
 
 public enum StatusSubscription {
   SUSPENDED,

src/main/java/ada/tech/tenthirty/tvpackages/entity/Subscription.java → src/main/java/ada/tech/tenthirty/tvpackages/domain/Subscription.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.entity;
+package ada.tech.tenthirty.tvpackages.domain;
 
 import java.util.List;
 import jakarta.persistence.*;

src/main/java/ada/tech/tenthirty/tvpackages/entity/User.java → src/main/java/ada/tech/tenthirty/tvpackages/domain/User.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.entity;
+package ada.tech.tenthirty.tvpackages.domain;
 
 import jakarta.persistence.*;
 import lombok.AllArgsConstructor;

src/main/java/ada/tech/tenthirty/tvpackages/config/SubscriptionQueue.java → src/main/java/ada/tech/tenthirty/tvpackages/infra/config/NotifyInvoiceQueue.java

@@ -1,18 +1,17 @@
-package ada.tech.tenthirty.tvpackages.config;
+package ada.tech.tenthirty.tvpackages.infra.config;
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.amqp.core.Queue;
 import org.springframework.beans.factory.annotation.Value;
 
 @Configuration
-public class SubscriptionQueue{
-    @Value("${config.subscription-package.queue.out}")
+public class NotifyInvoiceQueue {
+    @Value("${config.notify-invoice.queue.out}")
     private String queueSubs;
 
     @Bean
     public Queue queue(){
         return new Queue(queueSubs, true);
     }
 }
-

src/main/java/ada/tech/tenthirty/tvpackages/config/OpenApiConfig.java → src/main/java/ada/tech/tenthirty/tvpackages/infra/config/OpenApiConfig.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.config;
+package ada.tech.tenthirty.tvpackages.infra.config;
 
 import io.swagger.v3.oas.models.OpenAPI;
 import io.swagger.v3.oas.models.info.Info;

src/main/java/ada/tech/tenthirty/tvpackages/config/TechnicalVisitQueue.java → src/main/java/ada/tech/tenthirty/tvpackages/infra/config/TechnicalVisitQueue.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.config;
+package ada.tech.tenthirty.tvpackages.infra.config;
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;

src/main/java/ada/tech/tenthirty/tvpackages/queue/NotifyInvoiceProducer.java → src/main/java/ada/tech/tenthirty/tvpackages/infra/queue/NotifyInvoiceProducer.java

@@ -1,12 +1,12 @@
-package ada.tech.tenthirty.tvpackages.queue;
+package ada.tech.tenthirty.tvpackages.infra.queue;
 
+import ada.tech.tenthirty.tvpackages.infra.queue.payloads.NotifyInvoiceRequest;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.amqp.core.Queue;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import ada.tech.tenthirty.tvpackages.queue.payloads.NotifyInvoiceRequest;
 import lombok.RequiredArgsConstructor;
 
 @Service

src/main/java/ada/tech/tenthirty/tvpackages/queue/ScheduleTechnicalVisitProducer.java → src/main/java/ada/tech/tenthirty/tvpackages/infra/queue/ScheduleTechnicalVisitProducer.java

@@ -1,12 +1,12 @@
-package ada.tech.tenthirty.tvpackages.queue;
+package ada.tech.tenthirty.tvpackages.infra.queue;
 
+import ada.tech.tenthirty.tvpackages.infra.queue.payloads.ScheduleTechnicalVisitRequest;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.amqp.core.Queue;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import ada.tech.tenthirty.tvpackages.queue.payloads.ScheduleTechnicalVisitRequest;
 import lombok.RequiredArgsConstructor;
 
 @Service
@@ -21,4 +21,3 @@ public void execute(ScheduleTechnicalVisitRequest ScheduleTechnicalVisit) throws
     rabbitTemplate.convertSendAndReceive(queue.getName(), message);
   }
 }
-

src/main/java/ada/tech/tenthirty/tvpackages/queue/payloads/NotifyInvoiceRequest.java → src/main/java/ada/tech/tenthirty/tvpackages/infra/queue/payloads/NotifyInvoiceRequest.java

@@ -1,12 +1,12 @@
-package ada.tech.tenthirty.tvpackages.queue.payloads;
-import java.time.LocalDateTime;
+package ada.tech.tenthirty.tvpackages.infra.queue.payloads;
 import java.util.List;
 
+import ada.tech.tenthirty.tvpackages.domain.Package;
 import lombok.Data;
 
 @Data
 public class NotifyInvoiceRequest {
     private String idUser;
-    private LocalDateTime issueDate;
+    private String issueDate;
     private List<Package> listPackage;
 }

src/main/java/ada/tech/tenthirty/tvpackages/queue/payloads/ScheduleTechnicalVisitRequest.java → src/main/java/ada/tech/tenthirty/tvpackages/infra/queue/payloads/ScheduleTechnicalVisitRequest.java

@@ -1,4 +1,4 @@
-package ada.tech.tenthirty.tvpackages.queue.payloads;
+package ada.tech.tenthirty.tvpackages.infra.queue.payloads;
 
 import lombok.Data;
 

src/main/java/ada/tech/tenthirty/tvpackages/repository/SubscriptionRepository.java → src/main/java/ada/tech/tenthirty/tvpackages/infra/repository/SubscriptionRepository.java

@@ -1,6 +1,6 @@
-package ada.tech.tenthirty.tvpackages.repository;
+package ada.tech.tenthirty.tvpackages.infra.repository;
 
-import ada.tech.tenthirty.tvpackages.entity.Subscription;
+import ada.tech.tenthirty.tvpackages.domain.Subscription;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 

src/main/java/ada/tech/tenthirty/tvpackages/repository/UserRepository.java → src/main/java/ada/tech/tenthirty/tvpackages/infra/repository/UserRepository.java

@@ -1,6 +1,6 @@
-package ada.tech.tenthirty.tvpackages.repository;
+package ada.tech.tenthirty.tvpackages.infra.repository;
 
-import ada.tech.tenthirty.tvpackages.entity.User;
+import ada.tech.tenthirty.tvpackages.domain.User;
 import org.springframework.data.jpa.repository.JpaRepository;
 
 public interface UserRepository extends JpaRepository<User, String> {