Skip to content

B
bp_custom
Commit cdeba25a by everdarkgreen
Options

JsonNode: (draft12) production adaptation

parent 34167fae
Showing with 522 additions and 473 deletions
nb-configuration.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<project-shared-configuration>
<!--
This file contains additional configuration written by modules in the NetBeans IDE.
The configuration is intended to be shared among all the users of project and
therefore it is assumed to be part of version control checkout.
Without this configuration present, some functionality in the IDE may be limited or fail altogether.
-->
<libraries xmlns="http://www.netbeans.org/ns/cdnjs-libraries/1"/>
<properties xmlns="http://www.netbeans.org/ns/maven-properties-data/1">
<!--
Properties that influence various parts of the IDE, especially code formatting and the like.
You can copy and paste the single properties, into the pom.xml file and the IDE will pick them up.
That way multiple projects can share the same settings (useful for formatting rules for example).
Any value defined here will override the pom.xml file value but is only applicable to the current project.
-->
<org-netbeans-modules-maven-j2ee.netbeans_2e_hint_2e_j2eeVersion>1.6-web</org-netbeans-modules-maven-j2ee.netbeans_2e_hint_2e_j2eeVersion>
<org-netbeans-modules-maven-j2ee.netbeans_2e_hint_2e_deploy_2e_server>JBoss4</org-netbeans-modules-maven-j2ee.netbeans_2e_hint_2e_deploy_2e_server>
<netbeans.hint.jdkPlatform>JDK_1.7</netbeans.hint.jdkPlatform>
<org-netbeans-modules-css-prep.less_2e_mappings>/less:/css</org-netbeans-modules-css-prep.less_2e_mappings>
<org-netbeans-modules-css-prep.less_2e_enabled>false</org-netbeans-modules-css-prep.less_2e_enabled>
<org-netbeans-modules-css-prep.sass_2e_enabled>false</org-netbeans-modules-css-prep.sass_2e_enabled>
<org-netbeans-modules-css-prep.sass_2e_compiler_2e_options/>
<org-netbeans-modules-css-prep.less_2e_compiler_2e_options/>
<org-netbeans-modules-css-prep.sass_2e_mappings>/scss:/css</org-netbeans-modules-css-prep.sass_2e_mappings>
<org-netbeans-modules-web-clientproject-api.js_2e_libs_2e_folder>js/libs</org-netbeans-modules-web-clientproject-api.js_2e_libs_2e_folder>
<org-netbeans-modules-javascript2-requirejs.enabled>true</org-netbeans-modules-javascript2-requirejs.enabled>
</properties>
</project-shared-configuration>
nbactions.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<actions>
<action>
<actionName>build</actionName>
<packagings>
<packaging>*</packaging>
</packagings>
<goals>
<goal>install</goal>
<goal>checkstyle:check</goal>
</goals>
</action>
</actions>
pom.xml
......@@ -104,8 +104,9 @@
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-checkstyle-plugin</artifactId>
<version>${maven.checkstyle.plugin.version}</version>
<configuration>
<configLocation>config/sun_checks.xml</configLocation>
<configLocation>config/google_checks.xml</configLocation>
</configuration>
</plugin>
</plugins>
......
src/main/java/kz/arta/synergy/astdev/custom_bp/Main.java
package kz.arta.synergy.astdev.custom_bp;
import com.fasterxml.jackson.core.JsonFactory;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonToken;
import org.codehaus.jackson.JsonNode;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.concurrent.TimeUnit;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.naming.NameNotFoundException;
import javax.naming.directory.AttributeModificationException;
import javax.xml.bind.DatatypeConverter;
import kz.arta.synergy.api.rest.sample.asforms.APIFormsServiceSave;
import org.codehaus.jackson.map.DeserializationConfig;
import org.codehaus.jackson.map.ObjectMapper;
import org.codehaus.jackson.map.annotate.JsonSerialize;
import org.codehaus.jackson.type.TypeReference;
/**
*
* @author drpsy
*/
@MessageDriven(name = "CustomBP", activationConfig = {
@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")})
public class Main implements MessageListener {
private static final Logger LOGGER = LoggerFactory.getLogger(Main.class);
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
private static enum ObjectType {
DATE, TEXTBOX, USER
}
private static enum FieldType {
ID, TYPE, LABEL, KEY, VALUE
}
private String executionID = null; // идентификатор блокирующего процесса
private String documentID = null; // идентификатор документа реестра
private static final String LOGIN = "111111";
private static final String PASSWORD = "1";
private final String TARGET_FORM_UUID = "fb44d99d-1579-4ac3-884a-01a6d4f71f9c";
private final String SYNERGY_ADDRESS = "http://127.0.0.1:8080/Synergy";
private String SOURCE_FORM_DATA_UUID = null; // идентификатор данных по форме записи реестра
private String TARGET_FORM_DATA_UUID = null;
@JsonSerialize(using = AsNodeSerializer.class)
private List<AsNode> sourceFormData = null;
@JsonSerialize(using = AsNodeSerializer.class)
private List<AsNode> targetFormData = null;
/**
*
* @param message
*/
@Override
public void onMessage(Message message) {
// <editor-fold defaultstate="collapsed" desc=" DESCRIPTION ">
if (!(message instanceof TextMessage)) {
return;
}
try {
JsonFactory factory = new JsonFactory();
JsonParser parser = factory.createParser(((TextMessage) message).getText());
JsonToken token = null;
while ((token = parser.nextToken()) != null) {
if (token == JsonToken.FIELD_NAME) {
String fieldName = parser.getText();
parser.nextToken();
String value = parser.getText();
switch (fieldName) {
case "dataUUID":
SOURCE_FORM_DATA_UUID = value;
break;
case "executionID":
executionID = value;
break;
case "documentID":
documentID = value;
break;
default:
break;
}
}
}
// </editor-fold>
// Configure ObjectMapper
OBJECT_MAPPER.configure(DeserializationConfig.Feature.FAIL_ON_UNKNOWN_PROPERTIES, false);
// SOURCE FORM: Получение данных исходной формы (той, по которой запущен маршрут)
URL sourceFormURL = new URL(SYNERGY_ADDRESS + "/rest/api/asforms/data/" + SOURCE_FORM_DATA_UUID);
String sourceFormDataAsString = synergyApiGetString(sourceFormURL);
JsonNode SourceRootNode = OBJECT_MAPPER.readTree(sourceFormDataAsString); // read the whole tree
if (SourceRootNode.isNull()) {
throw new AttributeModificationException("GMP: Passed data has no JSON content");
}
JsonNode SourceRootDataNode = SourceRootNode.get("data"); // read single root 'data' node
if (SourceRootDataNode == null) {
throw new AttributeModificationException("GMP: Invalid form data, root \"data\" node does not exists");
}
sourceFormData = OBJECT_MAPPER.readValue(SourceRootDataNode, new TypeReference<List<AsNode>>() {}); // map content of single root 'data' node
// TARGET FORM: Получение ID пользователя указанного в форме
String userID = getComponentValueByID(this.sourceFormData, "user1", FieldType.KEY);
// По ID пользователя указанного в карточке и ID формы получаем DataUUID целевой карточки (ID for work: "04f7809d-f44c-4a2d-950d-6aa8e6c3fea1")
TARGET_FORM_DATA_UUID = getCardDataUUID(userID, TARGET_FORM_UUID);
// Получение данных целевой карточки по dataUUID
URL targetFormURL = new URL(SYNERGY_ADDRESS + "/rest/api/asforms/data/" + TARGET_FORM_DATA_UUID);
String targetFormDataAsString = synergyApiGetString(targetFormURL);
JsonNode TargetRootNode = OBJECT_MAPPER.readTree(targetFormDataAsString);
if (TargetRootNode.isNull()) {
throw new AttributeModificationException("GMP: Passed data has no JSON content");
}
JsonNode TargetRootDataNode = TargetRootNode.get("data");
if (TargetRootDataNode == null) {
throw new AttributeModificationException("GMP: Invalid form data, root \"data\" node does not exists");
}
targetFormData = OBJECT_MAPPER.readValue(TargetRootDataNode, new TypeReference<List<AsNode>>() {});
// Получение значений текущих дат исходной формы
String b5b1;
String t2b1;
String t8b1;
// String t18b1, t20b1, t16b1;
// String t26b1, t24b1, t22b1;
// String t32b1, t30b1, t28b1;
// first table
String b2b1 = getComponentValueByID(this.sourceFormData, "b2-b1-b1", FieldType.KEY);
String b4b1 = getComponentValueByID(this.sourceFormData, "b4-b1-b1", FieldType.KEY);
if (b2b1 == null || b4b1 == null) { // отображается key
throw new Exception ("Source date fields is empty");
} else {
constructNewTableRow(b2b1, b4b1);
updateTargetForm();
}
// boolean key_b2b1 = false, key_b4b1 = false, val_b2b1 = false, val_b4b1 = false;
// if (!b2b1.isEmpty() && !b4b1.isEmpty()) { // do not update with empty values
// key_b2b1 = updateFieldValue(this.targetFormData, "start-b1", FieldType.KEY, b2b1);
// key_b4b1 = updateFieldValue(this.targetFormData, "finish-b1", FieldType.KEY, b4b1);
// val_b2b1 = updateFieldValue(this.targetFormData, "start-b1", FieldType.VALUE, dateValueFromKey(b2b1));
// val_b4b1 = updateFieldValue(this.targetFormData, "finish-b1", FieldType.VALUE, dateValueFromKey(b4b1));
// }
//
// if (key_b2b1 && key_b4b1 && val_b2b1 && val_b4b1) {
// updateTargetForm();
// }
// Second table
// String t4b1 = getComponentValueByID(sourceFormData, "t2-b1", ObjectType.DATE);
// String t6b1 = getComponentValueByID(sourceFormData, "b6-b1", ObjectType.DATE);
// String t10b1 = getComponentValueByID(sourceFormData, "t10-b1", ObjectType.DATE);
// String t12b1 = getComponentValueByID(sourceFormData, "t12-b1", ObjectType.DATE);
//
// if (!t4b1.isEmpty() && !t6b1.isEmpty() && !t10b1.isEmpty() && !t12b1.isEmpty()) {
// setComponentValueByID(targetFormData, "start-b1", "key", b2b1);
// setComponentValueByID(targetFormData, "start-b1", "key", b2b1);
// setComponentValueByID(targetFormData, "start-b1", "key", b2b1);
// setComponentValueByID(targetFormData, "start-b1", "key", b2b1);
//
// unlockRoute();
// return;
// }
// Разблокировка маршрута
} catch (Exception exc) {
LOGGER.error(exc.getMessage(), exc);
} finally {
unlockRoute();
}
}
private void constructNewTableRow(String b2b1, String b4b1) throws Exception {
AsNode tableNode = findNode(targetFormData, "table");
if (tableNode != null) {
List<AsNode> tableDataNodesList = tableNode.getData();
String tablesCounter = Integer.toString(appendabeTableRowsCount(tableDataNodesList, "start", "b") + 1);
AsNode n1 = new AsNode();
AsNode n2 = new AsNode();
AsNode n3 = new AsNode();
AsNode n4 = new AsNode();
AsNode n5 = new AsNode();
AsNode n6 = new AsNode();
AsNode n7 = new AsNode();
n1.setId("start-b" + tablesCounter);
n1.setType("date");
n1.setLabel(" ");
n1.setValue(dateValueFromKey(b2b1));
n1.setKey(b2b1);
n2.setId("finish-b" + tablesCounter);
n2.setType("date");
n2.setLabel(" ");
n2.setValue(dateValueFromKey(b4b1));
n2.setKey(b4b1);
n3.setId("days-b" + tablesCounter);
n3.setType("textbox");
n3.setLabel(" ");
n3.setValue(Integer.toString(dateDiffToDays(b2b1, b4b1)));
n4.setId("matpom-b" + tablesCounter);
n4.setType("listbox");
n4.setValue("");
n4.setKey("1");
n5.setId("period_start-b" + tablesCounter);
n5.setType("date");
n6.setId("period_finish-b" + tablesCounter);
n6.setType("date");
n7.setId("otozvano-b" + tablesCounter);
n7.setType("texbox");
n7.setLabel(" ");
tableDataNodesList.add(n1);
tableDataNodesList.add(n2);
tableDataNodesList.add(n3);
tableDataNodesList.add(n4);
tableDataNodesList.add(n5);
tableDataNodesList.add(n6);
tableDataNodesList.add(n7);
}
}
private int dateDiffToDays(String dateLess, String dateMore) throws ParseException {
Date dateMore_ = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(dateMore);
Date dateLess_ = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(dateLess);
long diff = dateMore_.getTime() - dateLess_.getTime();
TimeUnit.DAYS.convert(diff, TimeUnit.MILLISECONDS);
return (int) TimeUnit.DAYS.convert(diff, TimeUnit.MILLISECONDS);
}
private int appendabeTableRowsCount(List<AsNode> lan, String tableID, String tableElementID) {
int counter = 0;
for (;;) {
String searchString = tableID + "-" + tableElementID + Integer.toString(counter + 1);
AsNode n = findNode(lan, searchString);
if (n == null) {
break;
} else {
counter++;
}
}
return counter;
}
private void updateTargetForm() throws IOException, Exception {
// SERIALIZATION
OBJECT_MAPPER.setSerializationInclusion(JsonSerialize.Inclusion.NON_NULL);
String serialData = OBJECT_MAPPER.writeValueAsString(targetFormData);
// String login, String password, String address, String formUUID, String uuid, String data
APIFormsServiceSave saver = new APIFormsServiceSave(LOGIN, PASSWORD, SYNERGY_ADDRESS, TARGET_FORM_UUID, TARGET_FORM_DATA_UUID, "\"data\": " + serialData);
saver.save();
}
/**
* Returns node which has specifies ID
* @param nodesList - List of nodes
* @param objectID - Component ID
* @return AsNode if such exists, null otherwise
*/
private static AsNode findNode(List<AsNode> nodesList, String objectID) {
AsNode result = null;
for (AsNode n : nodesList) {
if (result != null) break; // prevent relooping if result has already been found
if (objectID.equals(n.getId())) {
result = n;
} else if (n.getData() != null) {
result = findNode(n.getData(), objectID);
}
}
return result;
}
private static String dateValueFromKey (String keyValue) throws ParseException {
Date date = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(keyValue);
return new SimpleDateFormat("dd.MM.yyy").format(date);
}
/**
* Setting new value of requested field of requested component with specified ID
* @param targetJsonAsString
* @param objectID
* @param fieldType
* @param newFieldValue
* @throws AttributeModificationException
* @throws IOException
*/
private boolean updateFieldValue (List<AsNode> dataNodesList, String objectID, FieldType fieldType, String newFieldValue) {
try {
AsNode targetNode = findNode(dataNodesList, objectID);
if (targetNode == null) {
return false;
} else {
switch (fieldType) {
case ID:
targetNode.setId(newFieldValue);
break;
case TYPE:
targetNode.setType(newFieldValue);
break;
case LABEL:
targetNode.setLabel(newFieldValue);
break;
case KEY:
targetNode.setKey(newFieldValue);
break;
case VALUE:
targetNode.setValue(newFieldValue);
break;
}
}
return true;
} catch (Exception e) {
throw e;
}
}
/**
* Returns user's card data UUID by form's UUID
* @param userID - User identifier
* @param formUUID - Form's data UUID
* @return Specified user's card data UUID
*/
private static String getCardDataUUID (String userID, String formUUID) {
ObjectMapper mapper = new ObjectMapper();
try {
URL url = new URL("http://127.0.0.1:8080/Synergy/rest/api/personalrecord/forms/" + userID);
String res = synergyApiGetString(url);
List<Card> cardsList = mapper.readValue(res, new TypeReference<List<Card>>(){});
for (Card c : cardsList) {
if (formUUID.equals(c.getFormUUID())) {
return c.getDataUUID();
}
}
} catch (Exception exc) {
LOGGER.error(exc.getMessage(), exc);
}
return new String();
}
/**
* Returns value of of specified field of component with specified ID
* @param targetJsonAsString
* @param objectID
* @param fieldType
* @return
* @throws NameNotFoundException
* @throws IOException
*/
private static String getComponentValueByID(List<AsNode> dataNodesList, String objectID, FieldType fieldType) throws Exception {
String result = null;
try {
AsNode targetNode = findNode(dataNodesList, objectID);
if (targetNode == null) {
return null;
} else {
switch (fieldType) {
case ID:
result = targetNode.getId(); // may be for cheking if component with such ID exists at all
break;
case TYPE:
result = targetNode.getType();
break;
case LABEL:
result = targetNode.getLabel();
break;
case KEY:
result = targetNode.getKey();
break;
case VALUE:
result = targetNode.getValue();
break;
}
}
return result;
} catch (Exception e) {
throw e;
}
}
/**
* Route unlocking
*/
private void unlockRoute() {
try {
String address = "http://127.0.0.1:8080/Synergy";
String signal = "got_agree";
URL url = new URL(address + "/rest/api/processes/signal?signal=" + signal + "&executionID=" + this.executionID + "&param1=resolution&value1=signal_is_" + signal);
synergyApiGetString(url);
} catch (Exception exc) {
LOGGER.error(exc.getMessage(), exc);
}
}
private static String synergyApiGetString(final URL requestURL) {
try {
String output;
HttpURLConnection conn = (HttpURLConnection) requestURL.openConnection();
conn.setRequestMethod("GET");
conn.setRequestProperty("Accept", "application/json; charset=utf-8");
String encoded = DatatypeConverter.printBase64Binary((LOGIN + ":" + PASSWORD).getBytes()); // String encoded = Base64.encode((this.LOGIN + ":" + this.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 result.toString();
} catch (Exception exc) {
LOGGER.error(exc.getMessage(), exc);
}
return null;
}
}
package kz.arta.synergy.astdev.custom_bp;
import com.fasterxml.jackson.core.JsonFactory;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonToken;
import org.codehaus.jackson.JsonNode;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.concurrent.TimeUnit;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.naming.NameNotFoundException;
import javax.naming.directory.AttributeModificationException;
import javax.xml.bind.DatatypeConverter;
import kz.arta.synergy.api.rest.sample.asforms.APIFormsServiceSave;
import org.codehaus.jackson.map.DeserializationConfig;
import org.codehaus.jackson.map.ObjectMapper;
import org.codehaus.jackson.map.annotate.JsonSerialize;
import org.codehaus.jackson.type.TypeReference;
/**
*
* @author drpsy
*/
@MessageDriven(name = "CustomBP", activationConfig = {
@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")})
public class Main implements MessageListener {
private static final Logger LOGGER = LoggerFactory.getLogger(Main.class);
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
private static enum ObjectType {
DATE, TEXTBOX, USER
}
private static enum FieldType {
ID, TYPE, LABEL, KEY, VALUE
}
private String executionID = null; // идентификатор блокирующего процесса
private String documentID = null; // идентификатор документа реестра
private static final String LOGIN = "Ипатьев";
private static final String PASSWORD = "1";
private final String TARGET_FORM_UUID = "fb44d99d-1579-4ac3-884a-01a6d4f71f9c";
private final String SYNERGY_ADDRESS = "http://127.0.0.1:8080/Synergy";
private String SOURCE_FORM_DATA_UUID = null; // идентификатор данных по форме записи реестра
private String TARGET_FORM_DATA_UUID = null;
@JsonSerialize(using = AsNodeSerializer.class)
private List<AsNode> sourceFormData = null;
@JsonSerialize(using = AsNodeSerializer.class)
private List<AsNode> targetFormData = null;
/**
*
* @param message
*/
@Override
public void onMessage(Message message) {
// <editor-fold defaultstate="collapsed" desc=" DESCRIPTION ">
if (!(message instanceof TextMessage)) {
return;
}
try {
JsonFactory factory = new JsonFactory();
JsonParser parser = factory.createParser(((TextMessage) message).getText());
JsonToken token = null;
while ((token = parser.nextToken()) != null) {
if (token == JsonToken.FIELD_NAME) {
String fieldName = parser.getText();
parser.nextToken();
String value = parser.getText();
switch (fieldName) {
case "dataUUID":
SOURCE_FORM_DATA_UUID = value;
break;
case "executionID":
executionID = value;
break;
case "documentID":
documentID = value;
break;
default:
break;
}
}
}
// </editor-fold>
// Configure ObjectMapper
OBJECT_MAPPER.configure(DeserializationConfig.Feature.FAIL_ON_UNKNOWN_PROPERTIES, false);
// SOURCE FORM: Получение данных исходной формы (той, по которой запущен маршрут)
URL sourceFormURL = new URL(SYNERGY_ADDRESS + "/rest/api/asforms/data/" + SOURCE_FORM_DATA_UUID);
String sourceFormDataAsString = synergyApiGetString(sourceFormURL);
JsonNode SourceRootNode = OBJECT_MAPPER.readTree(sourceFormDataAsString); // read the whole tree
if (SourceRootNode.isNull()) {
throw new AttributeModificationException("GMP: Passed data has no JSON content");
}
JsonNode SourceRootDataNode = SourceRootNode.get("data"); // read single root 'data' node
if (SourceRootDataNode == null) {
throw new AttributeModificationException("GMP: Invalid form data, root \"data\" node does not exists");
}
sourceFormData = OBJECT_MAPPER.readValue(SourceRootDataNode, new TypeReference<List<AsNode>>() {}); // map content of single root 'data' node
// TARGET FORM: Получение ID пользователя указанного в форме
String userID = getComponentValueByID(this.sourceFormData, "user1", FieldType.KEY);
// По ID пользователя указанного в карточке и ID формы получаем DataUUID целевой карточки (ID for work: "04f7809d-f44c-4a2d-950d-6aa8e6c3fea1")
TARGET_FORM_DATA_UUID = getCardDataUUID(userID, TARGET_FORM_UUID);
// Получение данных целевой карточки по dataUUID
URL targetFormURL = new URL(SYNERGY_ADDRESS + "/rest/api/asforms/data/" + TARGET_FORM_DATA_UUID);
String targetFormDataAsString = synergyApiGetString(targetFormURL);
JsonNode TargetRootNode = OBJECT_MAPPER.readTree(targetFormDataAsString);
if (TargetRootNode.isNull()) {
throw new AttributeModificationException("GMP: Passed data has no JSON content");
}
JsonNode TargetRootDataNode = TargetRootNode.get("data");
if (TargetRootDataNode == null) {
throw new AttributeModificationException("GMP: Invalid form data, root \"data\" node does not exists");
}
targetFormData = OBJECT_MAPPER.readValue(TargetRootDataNode, new TypeReference<List<AsNode>>() {});
// common vacation period
String dateStart = getComponentValueByID(this.sourceFormData, "date_start", FieldType.KEY);
String dateFinish = getComponentValueByID(this.sourceFormData, "date_finish", FieldType.KEY);
if (dateStart == null || dateFinish == null) {
throw new Exception("Vacation period is not specified");
}
// first table
String b2b1 = getComponentValueByID(this.sourceFormData, "b2-b1", FieldType.KEY);
String b4b1 = getComponentValueByID(this.sourceFormData, "b4-b1", FieldType.KEY);
if (notNull(b2b1, b4b1)) { // отображается key
constructNewTableRow(b2b1, b4b1, dateStart, dateFinish);
updateTargetForm();
return;
}
String t4b1 = getComponentValueByID(this.sourceFormData, "t4-b1", FieldType.KEY);
String t6b1 = getComponentValueByID(this.sourceFormData, "t6-b1", FieldType.KEY);
String t10b1 = getComponentValueByID(this.sourceFormData, "t10-b1", FieldType.KEY);
String t12b1 = getComponentValueByID(this.sourceFormData, "t12-b1", FieldType.KEY);
if (notNull(t4b1, t6b1, t10b1, t12b1)) {
constructNewTableRow(t4b1, t6b1, dateStart, dateFinish);
constructNewTableRow(t10b1, t12b1, dateStart, dateFinish);
updateTargetForm();
return;
}
String t18b1 = getComponentValueByID(this.sourceFormData, "t18-b1", FieldType.KEY);
String t20b1 = getComponentValueByID(this.sourceFormData, "t20-b1", FieldType.KEY);
String t24b1 = getComponentValueByID(this.sourceFormData, "t24-b1", FieldType.KEY);
String t26b1 = getComponentValueByID(this.sourceFormData, "t26-b1", FieldType.KEY);
String t30b1 = getComponentValueByID(this.sourceFormData, "t30-b1", FieldType.KEY);
String t32b1 = getComponentValueByID(this.sourceFormData, "t32-b1", FieldType.KEY);
if (notNull(t18b1, t20b1, t24b1, t26b1, t30b1, t32b1)) {
constructNewTableRow(t18b1, t20b1, dateStart, dateFinish);
constructNewTableRow(t24b1, t26b1, dateStart, dateFinish);
constructNewTableRow(t30b1, t32b1, dateStart, dateFinish);
updateTargetForm();
return;
}
} catch (Exception exc) {
LOGGER.error(exc.getMessage(), exc);
} finally {
unlockRoute(); // Разблокировка маршрута
}
}
private static boolean notNull(Object... args) {
for (Object arg : args) {
if (arg == null) {
return false;
}
}
return true;
}
private void constructNewTableRow(String vacStart, String vacEnd, String perStart, String perEnd) throws Exception {
AsNode tableNode = findNode(targetFormData, "table");
if (tableNode != null) {
List<AsNode> tableDataNodesList = tableNode.getData();
String tablesCounter = Integer.toString(appendabeTableRowsCount(tableDataNodesList, "start", "b") + 1);
AsNode n1 = new AsNode();
AsNode n2 = new AsNode();
AsNode n3 = new AsNode();
AsNode n4 = new AsNode();
AsNode n5 = new AsNode();
AsNode n6 = new AsNode();
AsNode n7 = new AsNode();
n1.setId("start-b" + tablesCounter);
n1.setType("date");
n1.setLabel(" ");
n1.setValue(dateValueFromKey(vacStart));
n1.setKey(vacStart);
n2.setId("finish-b" + tablesCounter);
n2.setType("date");
n2.setLabel(" ");
n2.setValue(dateValueFromKey(vacEnd));
n2.setKey(vacEnd);
n3.setId("days-b" + tablesCounter);
n3.setType("textbox");
n3.setLabel(" ");
// n3.setValue(Integer.toString(dateDiffToDays(b2b1, b4b1)));
n3.setValue("");
n4.setId("matpom-b" + tablesCounter);
n4.setType("listbox");
n4.setValue("");
n4.setKey("1");
n5.setId("period_start-b" + tablesCounter);
n5.setType("date");
n5.setValue(dateValueFromKey(perStart));
n5.setKey(perStart);
n6.setId("period_finish-b" + tablesCounter);
n6.setType("date");
n6.setValue(dateValueFromKey(perEnd));
n6.setKey(perEnd);
n7.setId("otozvano-b" + tablesCounter);
n7.setType("texbox");
n7.setLabel(" ");
tableDataNodesList.add(n1);
tableDataNodesList.add(n2);
tableDataNodesList.add(n3);
tableDataNodesList.add(n4);
tableDataNodesList.add(n5);
tableDataNodesList.add(n6);
tableDataNodesList.add(n7);
}
}
private int dateDiffToDays(String dateLess, String dateMore) throws ParseException {
Date dateMore_ = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(dateMore);
Date dateLess_ = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(dateLess);
long diff = dateMore_.getTime() - dateLess_.getTime();
TimeUnit.DAYS.convert(diff, TimeUnit.MILLISECONDS);
return (int) TimeUnit.DAYS.convert(diff, TimeUnit.MILLISECONDS);
}
private int appendabeTableRowsCount(List<AsNode> lan, String tableID, String tableElementID) {
int counter = 0;
for (;;) {
String searchString = tableID + "-" + tableElementID + Integer.toString(counter + 1);
AsNode n = findNode(lan, searchString);
if (n == null) {
break;
} else {
counter++;
}
}
return counter;
}
private void updateTargetForm() throws IOException, Exception {
// SERIALIZATION
OBJECT_MAPPER.setSerializationInclusion(JsonSerialize.Inclusion.NON_NULL);
String serialData = OBJECT_MAPPER.writeValueAsString(targetFormData);
// String login, String password, String address, String formUUID, String uuid, String data
APIFormsServiceSave saver = new APIFormsServiceSave(LOGIN, PASSWORD, SYNERGY_ADDRESS, TARGET_FORM_UUID, TARGET_FORM_DATA_UUID, "\"data\": " + serialData);
saver.save();
}
/**
* Returns node which has specifies ID
* @param nodesList - List of nodes
* @param objectID - Component ID
* @return AsNode if such exists, null otherwise
*/
private static AsNode findNode(List<AsNode> nodesList, String objectID) {
AsNode result = null;
for (AsNode n : nodesList) {
if (result != null) break; // prevent relooping if result has already been found
if (objectID.equals(n.getId())) {
result = n;
} else if (n.getData() != null) {
result = findNode(n.getData(), objectID);
}
}
return result;
}
private static String dateValueFromKey (String keyValue) throws ParseException {
Date date = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(keyValue);
return new SimpleDateFormat("dd.MM.yyy").format(date);
}
/**
* Setting new value of requested field of requested component with specified ID
* @param targetJsonAsString
* @param objectID
* @param fieldType
* @param newFieldValue
* @throws AttributeModificationException
* @throws IOException
*/
private boolean updateFieldValue (List<AsNode> dataNodesList, String objectID, FieldType fieldType, String newFieldValue) {
try {
AsNode targetNode = findNode(dataNodesList, objectID);
if (targetNode == null) {
return false;
} else {
switch (fieldType) {
case ID:
targetNode.setId(newFieldValue);
break;
case TYPE:
targetNode.setType(newFieldValue);
break;
case LABEL:
targetNode.setLabel(newFieldValue);
break;
case KEY:
targetNode.setKey(newFieldValue);
break;
case VALUE:
targetNode.setValue(newFieldValue);
break;
}
}
return true;
} catch (Exception e) {
throw e;
}
}
/**
* Returns user's card data UUID by form's UUID
* @param userID - User identifier
* @param formUUID - Form's data UUID
* @return Specified user's card data UUID
*/
private static String getCardDataUUID (String userID, String formUUID) {
ObjectMapper mapper = new ObjectMapper();
try {
URL url = new URL("http://127.0.0.1:8080/Synergy/rest/api/personalrecord/forms/" + userID);
String res = synergyApiGetString(url);
List<Card> cardsList = mapper.readValue(res, new TypeReference<List<Card>>(){});
for (Card c : cardsList) {
if (formUUID.equals(c.getFormUUID())) {
return c.getDataUUID();
}
}
} catch (Exception exc) {
LOGGER.error(exc.getMessage(), exc);
}
return new String();
}
/**
* Returns value of of specified field of component with specified ID
* @param targetJsonAsString
* @param objectID
* @param fieldType
* @return
* @throws NameNotFoundException
* @throws IOException
*/
private static String getComponentValueByID(List<AsNode> dataNodesList, String objectID, FieldType fieldType) throws Exception {
String result = null;
try {
AsNode targetNode = findNode(dataNodesList, objectID);
if (targetNode == null) {
return null;
} else {
switch (fieldType) {
case ID:
result = targetNode.getId(); // may be for cheking if component with such ID exists at all
break;
case TYPE:
result = targetNode.getType();
break;
case LABEL:
result = targetNode.getLabel();
break;
case KEY:
result = targetNode.getKey();
break;
case VALUE:
result = targetNode.getValue();
break;
}
}
return result;
} catch (Exception e) {
throw e;
}
}
/**
* Route unlocking
*/
private void unlockRoute() {
try {
String address = "http://127.0.0.1:8080/Synergy";
String signal = "got_agree";
URL url = new URL(address + "/rest/api/processes/signal?signal=" + signal + "&executionID=" + this.executionID + "&param1=resolution&value1=signal_is_" + signal);
synergyApiGetString(url);
} catch (Exception exc) {
LOGGER.error(exc.getMessage(), exc);
}
}
private static String synergyApiGetString(final URL requestURL) {
try {
String output;
HttpURLConnection conn = (HttpURLConnection) requestURL.openConnection();
conn.setRequestMethod("GET");
conn.setRequestProperty("Accept", "application/json; charset=utf-8");
String encoded = DatatypeConverter.printBase64Binary((LOGIN + ":" + PASSWORD).getBytes()); // String encoded = Base64.encode((this.LOGIN + ":" + this.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 result.toString();
} catch (Exception exc) {
LOGGER.error(exc.getMessage(), exc);
}
return null;
}
}
src/main/webapp/WEB-INF/jboss-web.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<jboss-web>
<context-root>/cwm</context-root>
</jboss-web>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment