Added new enum as FUNDED

Author: pratikb0501

investmentservice/pom.xml

@@ -98,6 +98,12 @@
             <artifactId>spring-security-test</artifactId>
             <scope>test</scope>
         </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+        </dependency>
+
     </dependencies>
 
     <build>

investmentservice/src/main/java/com/p2plending/investmentservice/config/WebClientConfig.java

@@ -0,0 +1,16 @@
+package com.p2plending.investmentservice.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.reactive.function.client.WebClient;
+
+@Configuration
+public class WebClientConfig {
+
+    @Bean
+    public WebClient webClient() {
+        return WebClient.builder()
+                .baseUrl("http://p2p-lending-loan-service:8082") // Update if needed
+                .build();
+    }
+}

investmentservice/src/main/java/com/p2plending/investmentservice/controller/InvestmentController.java

@@ -17,7 +17,7 @@
 public class InvestmentController {
     private final InvestmentService investmentService;
 
-    @PostMapping
+    @PostMapping("/create")
     public InvestmentResponse create(@RequestBody InvestmentRequest request) {
         Investment investment = investmentService.createInvestment(request);
         return toResponse(investment);

investmentservice/src/main/java/com/p2plending/investmentservice/dto/LoanResponse.java

@@ -0,0 +1,21 @@
+package com.p2plending.investmentservice.dto;
+
+import com.p2plending.investmentservice.dto.LoanStatus;
+import lombok.Builder;
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.time.LocalDateTime;
+import java.util.UUID;
+
+@Data
+@Builder
+public class LoanResponse {
+    private UUID id;
+    private UUID userId;
+    private BigDecimal amount;
+    private Integer tenure;
+    private Double interestRate;
+    private LoanStatus status;
+    private LocalDateTime createdAt;
+}

investmentservice/src/main/java/com/p2plending/investmentservice/dto/LoanStatus.java

@@ -0,0 +1,9 @@
+package com.p2plending.investmentservice.dto;
+
+public enum LoanStatus {
+    PENDING,
+    APPROVED,
+    FUNDED,
+    REJECTED,
+    PAID
+}

investmentservice/src/main/java/com/p2plending/investmentservice/dto/UpdateLoanStatusRequest.java

@@ -0,0 +1,12 @@
+package com.p2plending.investmentservice.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class UpdateLoanStatusRequest {
+    private LoanStatus status;
+}

investmentservice/src/main/java/com/p2plending/investmentservice/service/serviceimpl/InvestmentServiceImpl.java

@@ -1,12 +1,18 @@
 package com.p2plending.investmentservice.service.serviceimpl;
 
 import com.p2plending.investmentservice.dto.InvestmentRequest;
+import com.p2plending.investmentservice.dto.LoanResponse;
+import com.p2plending.investmentservice.dto.LoanStatus;
+import com.p2plending.investmentservice.dto.UpdateLoanStatusRequest;
 import com.p2plending.investmentservice.model.Investment;
 import com.p2plending.investmentservice.repository.InvestmentRepository;
 import com.p2plending.investmentservice.service.InvestmentService;
 import lombok.RequiredArgsConstructor;
+import org.springframework.http.MediaType;
 import org.springframework.stereotype.Service;
+import org.springframework.web.reactive.function.client.WebClient;
 
+import java.math.BigDecimal;
 import java.util.List;
 import java.util.UUID;
 
@@ -18,7 +24,33 @@ public class InvestmentServiceImpl implements InvestmentService {
 
     @Override
     public Investment createInvestment(InvestmentRequest request) {
-        return null;
+        if (request.getAmount() <= 0) {
+            throw new IllegalArgumentException("Investment amount must be greater than zero.");
+        }
+
+        LoanResponse loan = fetchLoanDetails(request.getLoanId());
+
+        if (loan == null || loan.getStatus() != LoanStatus.APPROVED) {
+            throw new IllegalArgumentException("Loan not available for investment.");
+        }
+
+        if (BigDecimal.valueOf(request.getAmount()).compareTo(loan.getAmount()) != 0) {
+            throw new IllegalArgumentException("Investment must match loan amount exactly.");
+        }
+        // Create and save investment
+        Investment investment = Investment.builder()
+                .userId(request.getUserId())
+                .loanId(request.getLoanId())
+                .amount(request.getAmount())
+                .investedAt(java.time.LocalDateTime.now())
+                .build();
+
+        Investment savedInvestment = investmentRepository.save(investment);
+
+        // TODO: Update loan's funded amount in Loan Service
+        updateLoanStatusToFunded(request.getLoanId());
+
+        return savedInvestment;
     }
 
     @Override
@@ -30,4 +62,35 @@ public List<Investment> getInvestmentsByUserId(UUID userId) {
     public List<Investment> getInvestmentsByLoanId(UUID loanId) {
         return investmentRepository.findByLoanId(loanId);
     }
+
+    private final WebClient webClient = WebClient.create("http://loanservice-service:8082");
+
+    private LoanResponse fetchLoanDetails(UUID loanId) {
+        try {
+            return webClient.get()
+                    .uri("/api/v1/loans/" + loanId)
+                    .retrieve()
+                    .bodyToMono(LoanResponse.class)
+                    .block();
+        } catch (Exception e) {
+            throw new RuntimeException("Failed to fetch loan details from Loan Service.", e);
+        }
+    }
+
+    private void updateLoanStatusToFunded(UUID loanId) {
+        try {
+
+            UpdateLoanStatusRequest request = new UpdateLoanStatusRequest(LoanStatus.FUNDED);
+
+            webClient.put()
+                    .uri("/api/v1/loans/" + loanId + "/status")
+                    .contentType(MediaType.APPLICATION_JSON)
+                    .bodyValue(request)
+                    .retrieve()
+                    .bodyToMono(Void.class)
+                    .block();
+        } catch (Exception e) {
+            throw new RuntimeException("Failed to update loan status to FUNDED in Loan Service.", e);
+        }
+    }
 }

loanservice/src/main/java/com/p2plending/loanservice/controller/LoanController.java

@@ -52,6 +52,13 @@ public LoanResponse rejectLoan(@PathVariable("id") UUID id) {
         return mapToResponse(loan);
     }
 
+    @PostMapping("/{id}/fund")
+    public LoanResponse fundLoan(@PathVariable("id") UUID id) {
+        Loan loan = loanService.fundLoan(id);
+        return mapToResponse(loan);
+    }
+
+
     @PostMapping("/{id}/pay")
     public LoanResponse payLoan(@PathVariable("id") UUID id) {
         Loan loan = loanService.payLoan(id);

loanservice/src/main/java/com/p2plending/loanservice/model/LoanStatus.java

@@ -3,6 +3,7 @@
 public enum LoanStatus {
     PENDING,
     APPROVED,
+    FUNDED,
     REJECTED,
     PAID
 }

loanservice/src/main/java/com/p2plending/loanservice/service/LoanService.java

@@ -19,5 +19,7 @@ public interface LoanService {
 
     Loan rejectLoan(UUID loanId);
 
+    Loan fundLoan(UUID loanId);
+
     Loan payLoan(UUID loanId);
 }