[UCOD][23]- onboarding/digital/UcoCustomerAccount

src/main/java/com/mfsys/uco/service/UcoAccountService.java

@@ -191,12 +191,12 @@ public class UcoAccountService {
                 }
             });
         }
-        String accountNumber = webClientDeposit.createUcoAccount(JsonToString(Map.of("payload",preparePayloadForAccount(customerProfile,addAccountRequestModel.getTitle()),
+        String accountNumber = webClientDeposit.createUcoAccount(JsonToString(Map.of("payload",preparePayloadForAccount(customerProfile,addAccountRequestModel.getTitle(), addAccountRequestModel.getDmpProdcode()),
                 "uniqueConstraints",List.of(List.of(String.valueOf(addAccountRequestModel.getDmpProdcode()))))),UCOURI.UCO_CUSTOMER_ACCOUNT,porOrgacode);
         saveCustomerAccountDetails(porOrgacode,customerProfile.getCmpCustcode(),accountNumber);
     }
 
-public void saveCustomerAccountDetails(String porOrgacode, String cmpCustcode,String accountNumber){
+    public void saveCustomerAccountDetails(String porOrgacode, String cmpCustcode,String accountNumber){
         fetchdepositAccountFromCiihive(porOrgacode, cmpCustcode).stream().forEach(k -> {
             if(k.getMbmBkmsnumber().equals(accountNumber)){
                 UcoAccount ucoAccount = UcoAccount.builder()
@@ -214,16 +214,19 @@ public void saveCustomerAccountDetails(String porOrgacode, String cmpCustcode,St
                 ucoAccountRepository.save(ucoAccount);
             }
         });
-}
+    }
-    public String preparePayloadForAccount(CustomerProfile customerProfile,String title){
+
-        Map<String,Object> jsonMap = new HashMap<>();
+    public String preparePayloadForAccount(CustomerProfile customerProfile, String title, String dmpProdcode) {
+        System.out.println(customerProfile);
+        Map<String, Object> jsonMap = new HashMap<>();
         jsonMap.put("SUS_USERCODE", "01");
-        jsonMap.put("CMP_CUSTCODE",customerProfile.getCmpCustcode());
+        jsonMap.put("CMP_CUSTCODE", customerProfile.getCmpCustcode());
         jsonMap.put("CMP_FULLNAME", title);
-        jsonMap.put("PLC_LOCACODE", "2003");
+        jsonMap.put("PLC_LOCACODE", "0010");
         jsonMap.put("workFlowStage", "BN_WF_CP_AUTHORIZATION");
         jsonMap.put("PCT_CSTYCODE", "I");
         jsonMap.put("POR_ORGACODE", customerProfile.getPorOrgacode());
+        jsonMap.put("DMP_PRODCODE", dmpProdcode);
         List<Map<String, Object>> workFlowLog = new ArrayList<>();
         Map<String, Object> logEntry = new HashMap<>();
         logEntry.put("susUsercode", "01");
@@ -251,7 +254,8 @@ public void saveCustomerAccountDetails(String porOrgacode, String cmpCustcode,St
         jsonMap.put("@_CREATEDATE", createdDateMap);
         return JsonToString(jsonMap);
     }
-    public  String JsonToString(Object jsonMap){
+
+    public String JsonToString(Object jsonMap) {
         try {
             return this.objectMapper.writeValueAsString(jsonMap);
         } catch (JsonProcessingException var3) {

src/main/java/com/mfsys/uco/service/WebClientDepositService.java

@@ -4,6 +4,7 @@ import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.mfsys.comm.exception.ApplicationException;
 import com.mfsys.comm.exception.ApplicationExceptionMapper;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Service;
@@ -14,6 +15,7 @@ import reactor.core.publisher.Mono;
 import java.io.IOException;
 
 @Service
+@Slf4j
 public class WebClientDepositService {
     private final WebClient webClientDeposit;
 
@@ -70,6 +72,9 @@ public class WebClientDepositService {
             return response.getBody();
         } catch (WebClientResponseException e) {
             ApplicationExceptionMapper.APIError errorDetails = parseErrorDetails(e);
+            log.error("UCO Error Status: {}", e.getStatusCode());
+            log.error("UCO Error Body: {}", e.getResponseBodyAsString());
+            log.error("UCO Request Headers: {}", e.getRequest().getHeaders());
             throw new ApplicationException(porgaCode, errorDetails.getErrorCode(), errorDetails.getArguments());
         }
     }