234 lines
9.1 KiB
Java
234 lines
9.1 KiB
Java
package com.billpaymentservice.bbps.serviceImpl;
|
|
|
|
import java.util.ArrayList;
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Optional;
|
|
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
import org.springframework.http.ResponseEntity;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
import com.billpaymentservice.bbps.dto.MasterApiResponse;
|
|
import com.billpaymentservice.bbps.dto.request.BillerDetailRequest;
|
|
import com.billpaymentservice.bbps.dto.request.ContactMasterRequest;
|
|
import com.billpaymentservice.bbps.dto.request.CustomerParamRequest;
|
|
import com.billpaymentservice.bbps.dto.request.MerchantRequestModel;
|
|
import com.billpaymentservice.bbps.dto.response.BillerDataResponse;
|
|
import com.billpaymentservice.bbps.dto.response.BillerResponse;
|
|
import com.billpaymentservice.bbps.dto.response.ContactMasterResponse;
|
|
import com.billpaymentservice.bbps.dto.response.CustomParamResp;
|
|
import com.billpaymentservice.bbps.entites.BBPSMerchantValidation;
|
|
import com.billpaymentservice.bbps.exception.AppException;
|
|
import com.billpaymentservice.bbps.exception.CustomException;
|
|
import com.billpaymentservice.bbps.repository.MerchantRepository;
|
|
import com.billpaymentservice.bbps.service.MasterDataService;
|
|
import com.billpaymentservice.bbps.util.BBPSConstant;
|
|
import com.billpaymentservice.bbps.util.Helper;
|
|
import com.billpaymentservice.bbps.util.ResponseParser;
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
import com.fasterxml.jackson.core.type.TypeReference;
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
|
import jakarta.servlet.http.HttpServletRequest;
|
|
|
|
@Service
|
|
public class MasterDataServiceImpl implements MasterDataService {
|
|
|
|
private static final Logger LOGGER = LoggerFactory.getLogger(MasterDataServiceImpl.class);
|
|
|
|
@Value("${master.data.url}")
|
|
private String masterRegisterUrl;
|
|
|
|
private MerchantRepository merchantRegisterRepo;
|
|
private HttpClientApi httpClientApi;
|
|
private ResponseParser responseParser;
|
|
private Helper helper;
|
|
|
|
|
|
private static final Logger log = LoggerFactory.getLogger(MasterDataServiceImpl.class);
|
|
private final HttpService httpService;
|
|
private final ObjectMapper objectMapper = new ObjectMapper();
|
|
|
|
// Inject HttpService
|
|
public MasterDataServiceImpl(MerchantRepository merchantRegisterRepo,
|
|
HttpService httpService,
|
|
HttpClientApi httpClientApi,
|
|
Helper helper,
|
|
ResponseParser responseParser) {
|
|
this.merchantRegisterRepo = merchantRegisterRepo;
|
|
this.httpService = httpService;
|
|
this.httpClientApi = httpClientApi;
|
|
this.helper = helper;
|
|
this.responseParser = responseParser;
|
|
}
|
|
@Override
|
|
public BillerDataResponse getBillerByBillerId(BillerDetailRequest billerDetailRequest) {
|
|
|
|
String billerId = billerDetailRequest.getBillerId();
|
|
String fullUrl = masterRegisterUrl + BBPSConstant.BILLER_DATA_FETCH_URL+billerId;
|
|
|
|
|
|
Map<String, String> responseMap = httpService.getRequest(fullUrl);
|
|
String responseData = responseMap.get("data");
|
|
log.info("data is :{}", responseData);
|
|
|
|
ObjectMapper objectMapper = new ObjectMapper();
|
|
|
|
try {
|
|
Map<String, Object> dataMap = objectMapper.readValue(responseData,
|
|
new TypeReference<Map<String, Object>>() {
|
|
});
|
|
if (!dataMap.containsKey("generalResp")) {
|
|
throw new CustomException(String.valueOf(dataMap.get("statusCode")),
|
|
String.valueOf(dataMap.get("status")), String.valueOf(dataMap.get("message")),
|
|
String.valueOf(dataMap.get("remarks")));
|
|
}
|
|
BillerDataResponse responseWrapper = objectMapper.convertValue(dataMap, BillerDataResponse.class);
|
|
return responseWrapper;
|
|
|
|
} catch (JsonProcessingException e) {
|
|
log.error("Error parsing responseData JSON: {}", e.getMessage());
|
|
throw new CustomException("Invalid JSON received from API");
|
|
}
|
|
|
|
}
|
|
|
|
@Override
|
|
public ResponseEntity<List<MasterApiResponse>> getMasterData(MerchantRequestModel requestModel,
|
|
HttpServletRequest request) {
|
|
LOGGER.info("Request DTO" + request);
|
|
|
|
BBPSMerchantValidation merchantValidation = merchantRegisterRepo.findByMid(requestModel.getMid());
|
|
List<MasterApiResponse> responseModel = new ArrayList<>();
|
|
// if Start merchant validations
|
|
if (Optional.ofNullable(merchantValidation).isPresent()) {
|
|
// if Start merchant active check
|
|
if (merchantValidation.isActive()) {
|
|
|
|
LOGGER.info("mid Value: " + requestModel.getMid() + " secret Value: " + requestModel.getSecretKey()
|
|
+ "txt Value: " + requestModel);
|
|
String fullUrl = masterRegisterUrl + BBPSConstant.MASTER_CATEGORY_URL;
|
|
HashMap<String, Object> response = httpClientApi.getRequestForPaymentStatus(fullUrl);
|
|
|
|
LOGGER.info("BBPS bank response data: " + response.get("data") + " code: " + response.get("respCode"));
|
|
// if Start merchant cehck response code
|
|
|
|
if (response.get("respCode") != null && response.get("respCode").toString().contains("200")) {
|
|
LOGGER.info("Response -: " + response.get("data"));
|
|
String jsonData = response.get("data").toString();
|
|
MasterApiResponse generalResponse = responseParser.parseResponse(jsonData);
|
|
|
|
LOGGER.info("kkk" + generalResponse.toString());
|
|
// 5️⃣ Prepare API response model
|
|
|
|
responseModel.add(generalResponse);
|
|
|
|
} else {
|
|
LOGGER.warn("Unexpected response code: " + response.get("respCode"));
|
|
|
|
}
|
|
|
|
} else {
|
|
LOGGER.info("Merchant Not Active for mid - " + requestModel.getMid());
|
|
throw new AppException("Merchant Not Active", BBPSConstant.CODE_MERCHANT_INACTIVE);
|
|
}
|
|
} else {
|
|
LOGGER.info("Merchant Not Valid for mid - " + requestModel.getMid());
|
|
throw new AppException("Merchant Not Valid", BBPSConstant.CODE_MERCHANT_INVALID);
|
|
}
|
|
return ResponseEntity.ok(responseModel);
|
|
|
|
}
|
|
|
|
@Override
|
|
public ResponseEntity<BillerResponse> fetchMasterDataCategoryWise(MerchantRequestModel requestModel,
|
|
String category, int pageStart, int pageEnd) {
|
|
LOGGER.info("Fetching Master Data Category-wise for MID={}, Category={}, PageStart={}, PageEnd={}",
|
|
requestModel.getMid(), category, pageStart, pageEnd);
|
|
|
|
BBPSMerchantValidation merchantValidation = merchantRegisterRepo.findByMid(requestModel.getMid());
|
|
BillerResponse responseModel = new BillerResponse();
|
|
// if Start merchant validations
|
|
if (Optional.ofNullable(merchantValidation).isPresent()) {
|
|
// if Start merchant active check
|
|
if (merchantValidation.isActive()) {
|
|
|
|
LOGGER.info("mid Value: " + requestModel.getMid() + " secret Value: " + requestModel.getSecretKey()
|
|
+ "txt Value: " + requestModel);
|
|
// 2️⃣ Build API URL
|
|
String fullUrl = String.format("%s%s?category=%s&page=%d&pagesize=%d", masterRegisterUrl,
|
|
BBPSConstant.BILLER_URL, category, pageStart, pageEnd);
|
|
|
|
LOGGER.info("Calling Master API: {}", fullUrl);
|
|
HashMap<String, Object> response = httpClientApi.getRequestForPaymentStatus(fullUrl);
|
|
|
|
LOGGER.info("BBPS bank response data: " + response.get("data") + " code: " + response.get("respCode"));
|
|
// if Start merchant cehck response code
|
|
|
|
if (response.get("respCode") != null && response.get("respCode").toString().contains("200")) {
|
|
LOGGER.info("Response -: " + response.get("data"));
|
|
String jsonData = response.get("data").toString();
|
|
responseModel = responseParser.billerResponse(jsonData);
|
|
|
|
LOGGER.info("kkk" + responseModel.toString());
|
|
// 5️⃣ Prepare API response model
|
|
|
|
} else {
|
|
LOGGER.warn("Unexpected response code: " + response.get("respCode"));
|
|
|
|
}
|
|
|
|
} else {
|
|
LOGGER.info("Merchant Not Active for mid - " + requestModel.getMid());
|
|
throw new AppException("Merchant Not Active", BBPSConstant.CODE_MERCHANT_INACTIVE);
|
|
}
|
|
} else {
|
|
LOGGER.info("Merchant Not Valid for mid - " + requestModel.getMid());
|
|
throw new AppException("Merchant Not Valid", BBPSConstant.CODE_MERCHANT_INVALID);
|
|
}
|
|
return ResponseEntity.ok(responseModel);
|
|
|
|
}
|
|
|
|
@Override
|
|
public CustomParamResp getCustomerParamByBillerId(CustomerParamRequest customerParamRequest) {
|
|
String billerId = customerParamRequest.getBillerId();
|
|
String fullUrl = masterRegisterUrl + BBPSConstant.CUSTOMPARAM_URL+billerId;
|
|
|
|
|
|
Map<String, String> responseMap = httpService.getRequest(fullUrl);
|
|
String responseData = responseMap.get("data");
|
|
log.info("data is :{}", responseData);
|
|
|
|
ObjectMapper objectMapper = new ObjectMapper();
|
|
|
|
try {
|
|
Map<String, Object> dataMap = objectMapper.readValue(responseData,
|
|
new TypeReference<Map<String, Object>>() {
|
|
});
|
|
if (!dataMap.containsKey("generalResp")) {
|
|
throw new CustomException(String.valueOf(dataMap.get("statusCode")),
|
|
String.valueOf(dataMap.get("status")), String.valueOf(dataMap.get("message")),
|
|
String.valueOf(dataMap.get("remarks")));
|
|
}
|
|
CustomParamResp responseWrapper = objectMapper.convertValue(dataMap, CustomParamResp.class);
|
|
return responseWrapper;
|
|
} catch (JsonProcessingException e) {
|
|
log.error("Error parsing responseData JSON: {}", e.getMessage());
|
|
throw new CustomException("Invalid JSON received from API");
|
|
}
|
|
|
|
}
|
|
|
|
@Override
|
|
public ContactMasterResponse getContactMaster(ContactMasterRequest contactMasterRequest) {
|
|
|
|
return null;
|
|
}
|
|
}
|