Updated RejectTransactionService from Rest Template to Web Client

WebClient
Wasiullah Khan 5 days ago
parent 2c894f6c33
commit f6030e3f9b

@ -4,9 +4,7 @@ import com.mfsys.aconnect.client.dto.DepositRejectDTO;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.*;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import java.util.Map;
import com.mfsys.aconnect.configuration.config.WebClientConfig;
import static com.mfsys.common.configuration.constant.AconnectURI.ACONNECT;
@ -19,12 +17,12 @@ public class RejectTransactionService {
@Value("${app.generalledger.uri}")
private String generalledgerURI;
private final RestTemplate restTemplate;
public RejectTransactionService(RestTemplate restTemplate) {
this.restTemplate = restTemplate;
private final WebClientConfig webClientConfig;
public RejectTransactionService(WebClientConfig webClientConfig) {
this.webClientConfig = webClientConfig;
}
public Object processDepositRejectionTransaction(DepositRejectDTO rejectRequest, String tokenHeader) {
public ResponseEntity<Object> processDepositRejectionTransaction(DepositRejectDTO rejectRequest, String tokenHeader) {
String porOrgacode = rejectRequest.getPorOrgacode();
String url = depositURI + "/deposit/" + "/organizations/" + porOrgacode + "/transactions" + ACONNECT +"/rejection";
HttpHeaders headers = new HttpHeaders();
@ -33,19 +31,14 @@ public class RejectTransactionService {
headers.set("SUS_USERCODE", rejectRequest.getSusUsercode());
headers.setContentType(MediaType.APPLICATION_JSON);
HttpEntity<DepositRejectDTO> entity = new HttpEntity<>(rejectRequest, headers);
ResponseEntity<Map> response = restTemplate.exchange(
return webClientConfig.post(
url,
HttpMethod.POST,
entity,
Map.class
rejectRequest,
headers
);
return ResponseEntity.status(response.getStatusCode()).body(response.getBody());
}
public Object processGLRejectionTransaction(DepositRejectDTO rejectRequest, String tokenHeader) {
public ResponseEntity<Object> processGLRejectionTransaction(DepositRejectDTO rejectRequest, String tokenHeader) {
String porOrgacode = rejectRequest.getPorOrgacode();
String url = generalledgerURI + "/generalledger/" + "/organizations/" + porOrgacode + "/transactions" + ACONNECT +"/rejection";
HttpHeaders headers = new HttpHeaders();
@ -54,16 +47,11 @@ public class RejectTransactionService {
headers.set("SUS_USERCODE", rejectRequest.getSusUsercode());
headers.setContentType(MediaType.APPLICATION_JSON);
HttpEntity<DepositRejectDTO> entity = new HttpEntity<>(rejectRequest, headers);
ResponseEntity<Map> response = restTemplate.exchange(
return webClientConfig.post(
url,
HttpMethod.POST,
entity,
Map.class
rejectRequest,
headers
);
return ResponseEntity.status(response.getStatusCode()).body(response.getBody());
}
}

Loading…
Cancel
Save