[text] ZPIRestClient.java

Viewer

copydownloadembedprintName: ZPIRestClient.java
  1. package com.xtention.drivein.driveinwebapp.zpi;
  2.  
  3. import java.util.ArrayList;
  4. import java.util.List;
  5.  
  6. import org.slf4j.Logger;
  7. import org.slf4j.LoggerFactory;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.beans.factory.annotation.Value;
  10. import org.springframework.boot.web.client.RestTemplateBuilder;
  11. import org.springframework.http.HttpEntity;
  12. import org.springframework.http.HttpHeaders;
  13. import org.springframework.http.MediaType;
  14. import org.springframework.http.ResponseEntity;
  15. import org.springframework.stereotype.Service;
  16. import org.springframework.web.client.RestTemplate;
  17.  
  18. import com.google.common.base.Strings;
  19. import com.xtention.drivein.driveinwebapp.repository.SocialSecurityCarriersRepo;
  20. import com.xtention.drivein.driveinwebapp.vdas.VDASQueryRequest;
  21. import com.xtention.drivein.driveinwebapp.vdas.VDASQueryResult;
  22. import com.xtention.drivein.driveinwebapp.vdas.VDASServerResponseHandler;
  23.  
  24. import graphql.GraphQLException;
  25.  
  26. @Service
  27. public class ZPIRestClient {
  28.  
  29.         static Logger                     logger = LoggerFactory.getLogger( ZPIRestClient.class );
  30.  
  31.         private RestTemplate      restTemplate;
  32.         private final String     zpiServiceURL;
  33.  
  34.         @Autowired
  35.         SocialSecurityCarriersRepo socialSecurityCarriersRepo;
  36.  
  37.         @Autowired
  38.         public ZPIRestClient( RestTemplateBuilder restTemplateBuilder, VDASServerResponseHandler vdasServerResponseHandler, @Value("${com.xtention.driveinwebapp.zpi.service.url}") String zpiServiceURL ) {
  39.                 super();
  40.                 this.restTemplate = restTemplateBuilder.errorHandler( vdasServerResponseHandler ).build();
  41.                 this.zpiServiceURL = zpiServiceURL;
  42.         }
  43.  
  44.         public VDASQueryResult getZPI( String ssn ) {
  45.                 VDASQueryRequest vdasRequest = new VDASQueryRequest( ssn );
  46.                 HttpHeaders headers = new HttpHeaders();
  47.                 headers.setContentType( MediaType.APPLICATION_JSON );
  48.                 List<MediaType> acceptHeaders = new ArrayList<MediaType>();
  49.                 acceptHeaders.add( MediaType.ALL );
  50.                 headers.setAccept( acceptHeaders );
  51.                 HttpEntity<VDASQueryRequest> httpenitty = new HttpEntity<VDASQueryRequest>( vdasRequest, headers );
  52.                 ResponseEntity<VDASQueryResult> zpiResult = restTemplate.postForEntity( zpiServiceURL, httpenitty, VDASQueryResult.class );
  53.                 VDASQueryResult zpiQueryResult = zpiResult.getBody();
  54.                 if ( zpiQueryResult == null || ( zpiQueryResult != null && !Strings.isNullOrEmpty( zpiQueryResult.getErrorMsg() ) ) ) {
  55.                         throw new GraphQLException( zpiQueryResult.getErrorMsg() );
  56.                 }
  57.  
  58.                 return zpiQueryResult;
  59.         }
  60.  
  61. }
  62.  

Editor

You can edit this paste and save as new:


File Description
  • ZPIRestClient.java
  • Paste Code
  • 20 Oct-2020
  • 2.46 Kb
You can Share it: