added requestBillFetch api

src/main/java/com/billpaymentservice/bbps/serviceImpl/AgentServiceImpl.java

@@ -0,0 +1,89 @@
+package com.billpaymentservice.bbps.serviceImpl;
+
+import com.billpaymentservice.bbps.dto.GeneralResponse;
+import com.billpaymentservice.bbps.dto.ResponseModel;
+import com.billpaymentservice.bbps.dto.request.FetchBillRequest;
+import com.billpaymentservice.bbps.dto.response.FetchBillResponse;
+import com.billpaymentservice.bbps.exception.CustomException;
+import com.billpaymentservice.bbps.service.AgentService;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import org.springframework.http.*;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestClient;
+
+@Service
+@Slf4j
+@RequiredArgsConstructor
+public class AgentServiceImpl implements AgentService {
+
+    private final RestClient restClient;
+      private final HttpService httpService;// ✅ injected from config
+
+      @Override
+      public ResponseModel initiateBillFetch(FetchBillRequest fetchBillRequest) {
+          String url = "https://bbps-staging.digiledge.in/agent/bill-payment-new/couapp/bills/fetch";
+
+          HttpHeaders headers = new HttpHeaders();
+          headers.set("x-digiledge-key", fetchBillRequest.getDigiledgeKey());
+          headers.set("agentId", fetchBillRequest.getAgentId());
+          headers.set("tenantId", fetchBillRequest.getTenantId());
+          headers.setContentType(MediaType.APPLICATION_JSON);
+
+          ResponseModel responseModel = new ResponseModel();
+
+          try {
+              ObjectMapper objectMapper = new ObjectMapper();
+              objectMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
+
+              // ✅ Convert request to JSON
+              String json = objectMapper.writeValueAsString(fetchBillRequest);
+
+              // ✅ Call the API using httpService
+              Map<String, String> responseMap = httpService.postRequest(url, json, headers);
+              String responseData = responseMap.get("data");
+
+              log.info("📦 Bill Fetch API Response: {}", responseData);
+
+              if (responseData == null || responseData.isEmpty()) {
+                  throw new CustomException("Empty response from BBPS server");
+              }
+
+              // ✅ Convert JSON string → Map
+              Map<String, Object> dataMap = objectMapper.readValue(responseData, new TypeReference<Map<String, Object>>() {});
+
+              // ✅ Validate generalResp
+              if (!dataMap.containsKey("genericResponse")) {
+                  throw new CustomException("Invalid response structure from BBPS");
+              }
+
+              // ✅ Convert to your custom DTO
+              FetchBillResponse fetchBillResponse = objectMapper.convertValue(dataMap, FetchBillResponse.class);
+              GeneralResponse generalResponse = fetchBillResponse.getGenericResponse();
+
+              // ✅ Build final ResponseModel
+              responseModel = new ResponseModel(
+                      generalResponse.getMessage(),
+                      generalResponse.getStatus(),
+                      Integer.parseInt(generalResponse.getStatusCode()),
+                      fetchBillResponse
+              );
+
+          } catch (Exception e) {
+              log.error("❌ Exception in initiateBillFetch(): {}", e.getMessage(), e);
+              responseModel.setStatus("500");
+              responseModel.setMessage("Exception occurred");
+              responseModel.setData(e.getMessage());
+          }
+
+          return responseModel;
+      }
+
+}

src/main/java/com/billpaymentservice/bbps/serviceImpl/HttpService.java

@@ -1,8 +1,6 @@
 package com.billpaymentservice.bbps.serviceImpl;
 
 
-import java.net.http.HttpClient;
-import java.time.Duration;
 import java.util.HashMap;
 
 import org.slf4j.Logger;
@@ -12,53 +10,64 @@ import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.http.client.JdkClientHttpRequestFactory;
 import org.springframework.stereotype.Service;
-import java.time.Duration;
 import org.springframework.web.client.HttpClientErrorException;
 import org.springframework.web.client.HttpServerErrorException;
 import org.springframework.web.client.RestClient;
 
+import com.billpaymentservice.bbps.dto.request.FetchBillRequest;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import lombok.AllArgsConstructor;
+
 @Service
+@AllArgsConstructor
 public class HttpService {
     private static final Logger log = LoggerFactory.getLogger(HttpService.class);
     private final RestClient restClient;
+    private final ObjectMapper objectMapper = new ObjectMapper();
 
-    HttpService() {
-        HttpClient httpClient = HttpClient.newBuilder()
-            .connectTimeout(Duration.ofSeconds(5))
-            .build();
+    
 
-        JdkClientHttpRequestFactory factory = new JdkClientHttpRequestFactory(httpClient);
-        factory.setReadTimeout(Duration.ofSeconds(10));
-
-        this.restClient = RestClient.builder()
-            .requestFactory(factory)
-            .build();
-    }
-
-    public HashMap<String, String> postRequest(String url, String payload) {
+    public HashMap<String, String> postRequest(String url, String payload, HttpHeaders customHeaders) {
         HashMap<String, String> response = new HashMap<>();
         try {
             HttpHeaders headers = new HttpHeaders();
+            
+            if (customHeaders != null) {
+                customHeaders.forEach((key, value) -> {
+                    if (!key.equalsIgnoreCase(HttpHeaders.CONTENT_TYPE)) {
+                        headers.addAll(key, value);
+                    }
+                });
+            }
+            
             headers.setContentType(MediaType.APPLICATION_JSON);
-            log.info("📡 Bank POST Request to URL: {}", url);
 
+            // ✅ MAKE THE REQUEST
             ResponseEntity<String> restResponse = restClient.post()
-                .uri(url)
-                .headers(h -> h.addAll(headers))
-                .body(payload)
-                .retrieve()
-                .toEntity(String.class);
+                    .uri(url)
+                    .headers(h -> h.addAll(headers))
+                    .body(payload)
+                    .retrieve()
+                    .toEntity(String.class);
 
             response.put("respCode", String.valueOf(restResponse.getStatusCode().value()));
             response.put("data", restResponse.getBody());
+            
+            log.info("✅ HttpService Response Status: {}", restResponse.getStatusCode());
 
-        } catch (HttpClientErrorException | HttpServerErrorException httpException) {
-            response.put("respCode", String.valueOf(httpException.getStatusCode()));
-            response.put("data", "Exception : " + httpException.getResponseBodyAsString());
+        } catch (HttpClientErrorException.Forbidden e) {
+            // ✅ SPECIAL 403 HANDLING
+            log.error("🚫 HttpService: 403 FORBIDDEN");
+            response.put("respCode", "403");
+            response.put("data", "FORBIDDEN - Check credentials in HttpService");
+            
         } catch (Exception e) {
-            response.put("data", "Exception :" + e.getMessage());
-            log.error("❌ Exception during POST call to {} -> {}", url, e.getMessage());
+            log.error("❌ HttpService Exception: {}", e.getMessage());
+            response.put("respCode", "500");
+            response.put("data", "HttpService Error: " + e.getMessage());
         }
+        
         return response;
     }
 

src/main/java/com/billpaymentservice/bbps/serviceImpl/MasterDataServiceImpl.java

@@ -155,7 +155,6 @@ public class MasterDataServiceImpl implements MasterDataService {
 	}
 
 
-
 	@Override
 	public ResponseModel fetchMasterDataCategoryWise(MerchantRequestModel requestModel,
 			String category, int pageStart, int pageEnd) {