New changes as per exception logc

src/main/java/com/nisum/offertransactionservice/controller/OfferTransactionController.java

@@ -16,6 +16,7 @@ public class OfferTransactionController {
 
     @PostMapping("offerTransactionCall")
     public OfferTransactionResponse getOfferTransactionResponse(@RequestBody OfferTransactionRequest offerTransactionRequest){
+        //TODO: validate the offerRequest
         return offerCallingPEService.getDiscountedItemList(offerTransactionRequest);
     }
 

src/main/java/com/nisum/offertransactionservice/dao/OfferDao.java

@@ -19,11 +19,9 @@ public class OfferDao {
     @Value("${promotion.engine.calculate.discount.url}")
     private String promotionEngineUrl ;
 
-    public OfferTransactionResponse convertions(OfferTransactionRequest offerTransactionRequest) {
-        return null;
-    }
-
     public PEResponse callPE(PERequest peRequest) {
+        //TODO validate PERequest and rest template is successful or not
+
         ResponseEntity<PEResponse> peResponse = restTemplate.postForEntity("http://localhost:8081"+promotionEngineUrl,peRequest,PEResponse.class);
         return peResponse.getBody();
     }

src/main/java/com/nisum/offertransactionservice/handler/MyResponseErrorHandler.java

+package com.nisum.offertransactionservice.handler;
+
+import org.springframework.http.HttpStatus;
+import org.springframework.http.client.ClientHttpResponse;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.ResponseErrorHandler;
+
+import java.io.IOException;
+import java.io.InputStream;
+
+
+@Component
+public class MyResponseErrorHandler implements ResponseErrorHandler {
+
+
+
+    @Override
+    public void handleError(ClientHttpResponse clienthttpresponse) throws IOException {
+
+        InputStream body = clienthttpresponse.getBody();
+
+    }
+
+    @Override
+    public boolean hasError(ClientHttpResponse clienthttpresponse) throws IOException {
+
+        if (clienthttpresponse.getStatusCode() != HttpStatus.OK) {
+            return true;
+
+        }
+        return false;
+    }
+}

src/main/java/com/nisum/offertransactionservice/model/OfferTransactionRequest.java

@@ -6,6 +6,7 @@ import lombok.Data;
 import lombok.NoArgsConstructor;
 import lombok.experimental.FieldDefaults;
 
+import javax.validation.constraints.NotNull;
 import java.util.List;
 
 import static com.google.common.collect.Lists.newArrayList;
@@ -16,6 +17,7 @@ import static com.google.common.collect.Lists.newArrayList;
 @FieldDefaults(level = AccessLevel.PRIVATE, makeFinal = false)
 public class OfferTransactionRequest {
 
+    @NotNull
     String hhId;
     List<Item> itemList = newArrayList();
 }

src/main/java/com/nisum/offertransactionservice/service/OfferCallingPEService.java

@@ -29,6 +29,8 @@ public class OfferCallingPEService {
         List<OfferLookup> eligibleOffer = newArrayList();
         offerLookupRepo.findAll().forEach(eligibleOffer::add);
         OfferTransactionResponse offerTransactionResponse ;
+        //TODO validate whether we got the offers from DB or not
+        //TODO DB call success or not
         PERequest peRequest = offerConverter.apply(offerTransactionRequest);
         peRequest.setEligibleOffers(eligibleOffer);
         PEResponse peResponse = offerDao.callPE(peRequest);