Payment processing logic

Author: kcomhnall

src/application/PaymentController.java

@@ -1,18 +1,28 @@
 package org.nacha.paymentsystem.application;
 import org.springframework.web.bind.annotation.*;
-
+import org.nacha.paymentsystem.domain.Payment;
+import org.nacha.paymentsystem.application.PaymentService;
 
 @RestController
 @RequestMapping("/api/payments")
 public class PaymentController {
 
+    private final PaymentService paymentService;
+
     public PaymentController(PaymentService paymentService) {
         this.paymentService = paymentService;
     }
 
     @PostMapping("/process")
-    public void processPayment(@RequestBody Payment payment) {
+    public String createPayment(@RequestBody Payment payment) {
         paymentService.processPayment(payment);
+        return "Payment process successfully";
     }
 
+    @GetMapping("/{id}")
+    public Payment getPayment(@PathVariable Long id) {
+        return paymentService.getPaymentById(id);
+    }
+
+
 }

src/application/PaymentService.java

@@ -1,18 +1,31 @@
 package org.nacha.paymentsystem.application;
 
+import org.nacha.paymentsystem.domain.Payment;
+import org.nacha.paymentsystem.infrastructure.persistence.PaymentRespository;
+import org.springframework.stereotype.Service;
 
+@Service
 public class PaymentService {
+
+    private final PaymentRespository paymentRespository;
+
+    public PaymentService(PaymentRepository paymentRepository) {
+        this.paymentRespository = paymentRepository;
+    }
+
     public void processPayment(Payment payment) {
         // Business logic for processing a payment
-
         if (!payment) {
             System.out.println("No payment received");
         }
+        validatePayment(payment);
+        paymentRespository.save(payment);
+
+        // additional logic (e.g., remittance instructions, message)
+    }
 
-        // proper handling of ACH accessible transaction
-        // data can move, so must be secure
-        PaymentService p1 = new PaymentService();
-        System.out.println(int(payment));
+    public Payment getPaymentById(Long id) {
+        return paymentRespository.findById(id).orElseThrow(() -> new RuntimeException("Payment not found"));
     }
 
     public void validatePayment(Payment payment) {

src/application/WorkflowService.java

@@ -1,5 +1,8 @@
 package org.nacha.paymentsystem.application;
 
+import org.springframework.stereotype.Service;
+
+@Service
 public class WorkflowService {
 
     public void startWorkflow(Workflow workflow) {

src/domain/Payment.java

@@ -1,44 +1,50 @@
 package org.nacha.paymentsystem.application;
 
-public class Payment {
+import jakarta.persistence.*;
 
+@Entity
+public class Payment {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
     // This class represents the core business model (Payment).
-    private String paymentId;
-    private double amount;
-    private String sender;
-    private String receiver;
+
+    /id
+    private Long id;
+    public Long getId() {
+        return id;
+    }
+    public void setId(Long id) {
+        this.id = id;
+    }
 
 
-    // Getter and Setter
-    public String getPaymentId() {
-        return paymentId;
+    //payer
+    private String payer;
+    public String getPayer() {
+        return payer;
+    }
+    public void setPayer(String payer) {
+        this.payer = payer;
     }
 
-    public void setPaymentId(String paymentId) {
-        this.paymentId = paymentId;
+
+    //payee
+    private String payee;
+    public String getPayee() {
+        return payee;
     }
+    public void setPayee(String payee) {
+        this.payee = payee;
+    }
+
 
+    // amount
+    private double amount;
     public double getAmount() {
         return amount;
     }
-
     public void setAmount(double amount) {
         this.amount = amount;
     }
 
-    public String getSender() {
-        return sender;
-    }
-
-    public void setSender(String sender) {
-        this.sender = sender;
-    }
-
-    public void setReceiver(String receiver) {
-        this.receiver = receiver;
-    }
-
-    public String getReceiver() {
-        return receiver;
-    }
 }