assignment bug

src/main/java/kz/arta/synergy/astdev/custom_bp/Main.java

@@ -9,6 +9,7 @@ import com.sun.org.apache.xerces.internal.impl.dv.util.Base64;
 import com.fasterxml.jackson.core.JsonFactory;
 import com.fasterxml.jackson.core.JsonParser;
 import com.fasterxml.jackson.core.JsonToken;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -23,30 +24,30 @@ import javax.ejb.ActivationConfigProperty;
 import javax.ejb.MessageDriven;
 
 @MessageDriven(name = "CustomBP", activationConfig = {
-        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
+    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
         @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:jboss/queues/Integration/CustomBP"),
         @ActivationConfigProperty(propertyName = "reconnectAttempts", propertyValue = "32"),
         @ActivationConfigProperty(propertyName = "reconnectInterval", propertyValue = "4000"),
-        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge") })
+        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge")})
 
 public class Main implements MessageListener {
+
     private static final Logger LOGGER = LoggerFactory.getLogger(Main.class);
 
     @Override
     public void onMessage(Message message) {
-        
-        LOGGER.error("CWM work starts"); 
 
-        String dataUUID = null;
-        String executionID = null;
-        String documentID = null;
+        LOGGER.error("CWM work starts");
+
+        String dataUUID = null; // идентификатор данных по форме записи реестра
+        String executionID = null;  // идентификатор блокирующего процесса
+        String documentID = null;   // идентификатор документа реестра
 
         if (!(message instanceof TextMessage)) {
             return;
         }
 
         try {
-
             JsonFactory factory = new JsonFactory();
             JsonParser parser = factory.createParser(((TextMessage) message).getText());
             JsonToken token = null;
@@ -72,55 +73,89 @@ public class Main implements MessageListener {
                 }
             }
 
-            // Выполнение каких-либо действий
-            // 
+            // Получение данных исходной формы
+            URL getFormDataURL = new URL("http://127.0.0.1:8080/Synergy/rest/api/asforms/data/" + dataUUID);
+            JsonParser sourceFormData = synergyApiGet(getFormDataURL);
+            
+            // Получение значений текущих дат исходной формы
+            String b2b1, b4b1, b5b1;
+            
+            String t4b1, t6b1, t2b1;
+            String t10b1, t12b1, t8b1;
+            
+            String t18b1, t20b1, t16b1;
+            String t26b1, t24b1, t22b1;
+            String t32b1, t30b1, t28b1;
+            
+            b2b1 = getDateKeyByFieldName(sourceFormData, "b2-b1");
+            b4b1 = getDateKeyByFieldName(sourceFormData, "b4-b1");
+            
+            LOGGER.info(getDateKeyByFieldName(sourceFormData, "b2-b1"));
+            
+            // Получение данных целевой карточки
+            
+
             // Разблокировка маршрута
             String address = "http://127.0.0.1:8080/Synergy";
-            String login = "1";
-            String password = "1";
             String signal = "got_agree";
-            boolean isSuccess = false;
-
-            try {
-                URL url = new URL(address + "/rest/api/processes/signal?signal=" + signal + "&executionID=" + executionID + "&param1=resolution&value1=signal_is_" + signal);
-
-                HttpURLConnection conn = (HttpURLConnection) url.openConnection();
-                conn.setRequestMethod("GET");
-                conn.setRequestProperty("Accept", "application/json; charset=utf-8");
+            URL url = new URL(address + "/rest/api/processes/signal?signal=" + signal + "&executionID=" + executionID + "&param1=resolution&value1=signal_is_" + signal);
+            synergyApiGet(url);
 
-                String encoded = Base64.encode((login + ":" + password).getBytes());
-                conn.setRequestProperty("Authorization", "Basic " + encoded);
-
-                String output;
-                StringBuffer result = new StringBuffer();
+        } catch (Exception exc) {
+            LOGGER.error(exc.getMessage(), exc);
+        }
+    }
 
-                BufferedReader br = new BufferedReader(new InputStreamReader((conn.getInputStream())));
+    private String getDateKeyByFieldName(final JsonParser formJson, final String fieldName) {
+        String value = new String();
+        try {
+            while (!formJson.isClosed()) {
+                if (JsonToken.FIELD_NAME.equals(formJson.nextToken())) {
+                    if ("id".equals(formJson.getCurrentName()) && fieldName.equals(formJson.nextTextValue())) {
+                        formJson.nextToken();
+                        formJson.nextToken();
+                        formJson.nextToken();
+                        LOGGER.info(fieldName + ": " + formJson.nextTextValue());
+                        value = formJson.nextTextValue();
+                        break;
+                    }
 
-                while ((output = br.readLine()) != null) {
-                    result.append(output);
                 }
+            }
+        } catch (Exception exc) {
+            LOGGER.error(exc.getMessage(), exc);
+        }
+        return value;
+    }
+    
+    private static JsonParser synergyApiGet(final URL requestURL) {
+        String login = "Ипатьев";
+        String password = "1";
 
-                conn.disconnect();
+        try {
+            String output;
 
-                factory = new JsonFactory();
-                parser = factory.createParser(result.toString());
-                token = null;
+            HttpURLConnection conn = (HttpURLConnection) requestURL.openConnection();
+            conn.setRequestMethod("GET");
+            conn.setRequestProperty("Accept", "application/json; charset=utf-8");
 
-                while ((token = parser.nextToken()) != null) {
-                    if (token == JsonToken.FIELD_NAME) {
-                        String fieldName = parser.getText();
-                        token = parser.nextToken();
-                        if (fieldName.equals("errorCode") && parser.getText().equals("0")) {
-                            isSuccess = true;
-                        }
-                    }
-                }
-            } catch (Exception exc) {
-                LOGGER.error(exc.getMessage(), exc);
+            String encoded = Base64.encode((login + ":" + password).getBytes());
+            conn.setRequestProperty("Authorization", "Basic " + encoded);
+
+            BufferedReader br = new BufferedReader(new InputStreamReader((conn.getInputStream())));
+            StringBuilder result = new StringBuilder();
+            while ((output = br.readLine()) != null) {
+                result.append(output);
             }
 
+            conn.disconnect();
+
+            JsonFactory factory = new JsonFactory();
+            return factory.createParser(result.toString());
         } catch (Exception exc) {
             LOGGER.error(exc.getMessage(), exc);
         }
+
+        return null;
     }
-}
+}
\ No newline at end of file