GOV-255: Added configuration for programId/registeringInstituteId (#94)

* Added configuration for programId/registeringInstituteId

* Added logic to support programId and registeringInstituteId header

* Updated the config for n cross n mapping b/w registeringInstituteId and program

* GOV-255.2 Publishing programName, payerIdentifierType and payerIdentifierValue as zeebe variable

* Response code changed to 202

Author: danishjamal104

src/main/java/org/mifos/processor/bulk/camel/routes/ProcessorStartRoute.java

@@ -34,8 +34,19 @@
 import static org.mifos.processor.bulk.zeebe.ZeebeVariables.PAYER_IDENTIFIER_TYPE;
 import static org.mifos.processor.bulk.zeebe.ZeebeVariables.PAYER_IDENTIFIER_VALUE;
 import static org.mifos.processor.bulk.zeebe.ZeebeVariables.NOTE;
-import java.io.*;
-import java.util.*;
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+import java.util.ArrayList;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import org.apache.camel.Exchange;
 import org.apache.camel.LoggingLevel;
@@ -162,7 +173,6 @@ private void setup() {
                 .setHeader("Content-Type", constant("application/json;charset=UTF-8"))
                 .log("Completed route direct:validate-tenant");
 
-
         // this route is responsible for editing the incoming records based on configuration
         // this step is done to make sure the file format of CSV is not altered and only the data is updated based on config
         from("direct:update-incoming-data")
@@ -257,7 +267,7 @@ private void setup() {
 
                     String nm = fileTransferService.uploadFile(file, bucketName);
 
-                    logger.info("File uploaded {}", nm);
+                    logger.debug("File uploaded {}", nm);
 
                     //extracting  and setting callback Url
                     String callbackUrl = exchange.getIn().getHeader("X-Callback-URL", String.class);
@@ -347,7 +357,7 @@ private void setup() {
             json.put("PollingPath", "/batch/Summary/" + exchange.getProperty(BATCH_ID));
             json.put("SuggestedCallbackSeconds", pollApiTimer);
             exchange.getIn().setBody(json.toString());
-
+			exchange.getIn().setHeader(Exchange.HTTP_RESPONSE_CODE, 202);
         });
 
 

src/main/java/org/mifos/processor/bulk/schema/Transaction.java

@@ -1,6 +1,5 @@
 package org.mifos.processor.bulk.schema;
 
-
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 import com.fasterxml.jackson.annotation.JsonPropertyOrder;
 import com.fasterxml.jackson.annotation.JsonProperty;

src/main/resources/application.yaml

@@ -145,7 +145,6 @@ csv:
   columnNames: "id,request_id,payment_mode,payer_identifier_type,payer_identifier,payee_identifier_type,payee_identifier,amount,currency,note"
   size : 100000 # in bytes
 
-
 budget-account:
   registeringInstitutions:
     - id: "123"