SendControl

build.gradle

+apply plugin: 'java'
+
+buildscript {
+    repositories {
+        maven {
+            url 'http://192.168.1.30:8081/artifactory/synergy-libs'
+        }
+        mavenCentral()
+    }
+
+}
+
+
+sourceSets {
+    main {
+        resources.srcDirs = ["src/main/java", "src/main/resources"]
+    }
+
+}
+dependencies {
+    compile fileTree(dir: 'libs/',
+            includes: ['slf4j-api-1.6.1.jar', 'data-source.jar', 'db-generator.jar', 'gson-1.7.1.jar', 'integration-api.jar'])
+
+}
\ No newline at end of file

gradle/wrapper/gradle-wrapper.properties

+#Sat Mar 28 05:57:18 ALMT 2015
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
+distributionUrl=http\://services.gradle.org/distributions/gradle-1.11-bin.zip

gradle/wrapper/gradle-wrapper_en.properties

+#Mon Mar 31 23:52:06 ALMT 2014
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
+distributionUrl=http://services.gradle.org/distributions/gradle-1.11-all.zip

gradle/wrapper/gradle-wrapper_kz.properties

+#Mon Mar 31 23:52:06 ALMT 2014
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
+distributionUrl=http://services.gradle.org/distributions/gradle-1.11-all.zip

gradle/wrapper/gradle-wrapper_ru.properties

+#Mon Mar 31 23:52:06 ALMT 2014
+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists
+distributionUrl=http://services.gradle.org/distributions/gradle-1.11-all.zip

gradlew

+#!/usr/bin/env bash
+
+##############################################################################
+##
+##  Gradle start up script for UN*X
+##
+##############################################################################
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS=""
+
+APP_NAME="Gradle"
+APP_BASE_NAME=`basename "$0"`
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD="maximum"
+
+warn ( ) {
+    echo "$*"
+}
+
+die ( ) {
+    echo
+    echo "$*"
+    echo
+    exit 1
+}
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+case "`uname`" in
+  CYGWIN* )
+    cygwin=true
+    ;;
+  Darwin* )
+    darwin=true
+    ;;
+  MINGW* )
+    msys=true
+    ;;
+esac
+
+# For Cygwin, ensure paths are in UNIX format before anything is touched.
+if $cygwin ; then
+    [ -n "$JAVA_HOME" ] && JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
+fi
+
+# Attempt to set APP_HOME
+# Resolve links: $0 may be a link
+PRG="$0"
+# Need this for relative symlinks.
+while [ -h "$PRG" ] ; do
+    ls=`ls -ld "$PRG"`
+    link=`expr "$ls" : '.*-> \(.*\)$'`
+    if expr "$link" : '/.*' > /dev/null; then
+        PRG="$link"
+    else
+        PRG=`dirname "$PRG"`"/$link"
+    fi
+done
+SAVED="`pwd`"
+cd "`dirname \"$PRG\"`/" >&-
+APP_HOME="`pwd -P`"
+cd "$SAVED" >&-
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+# Determine the Java command to use to start the JVM.
+if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+        # IBM's JDK on AIX uses strange locations for the executables
+        JAVACMD="$JAVA_HOME/jre/sh/java"
+    else
+        JAVACMD="$JAVA_HOME/bin/java"
+    fi
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD="java"
+    which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if [ "$cygwin" = "false" -a "$darwin" = "false" ] ; then
+    MAX_FD_LIMIT=`ulimit -H -n`
+    if [ $? -eq 0 ] ; then
+        if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
+            MAX_FD="$MAX_FD_LIMIT"
+        fi
+        ulimit -n $MAX_FD
+        if [ $? -ne 0 ] ; then
+            warn "Could not set maximum file descriptor limit: $MAX_FD"
+        fi
+    else
+        warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
+    fi
+fi
+
+# For Darwin, add options to specify how the application appears in the dock
+if $darwin; then
+    GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
+fi
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin ; then
+    APP_HOME=`cygpath --path --mixed "$APP_HOME"`
+    CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+
+    # We build the pattern for arguments to be converted via cygpath
+    ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
+    SEP=""
+    for dir in $ROOTDIRSRAW ; do
+        ROOTDIRS="$ROOTDIRS$SEP$dir"
+        SEP="|"
+    done
+    OURCYGPATTERN="(^($ROOTDIRS))"
+    # Add a user-defined pattern to the cygpath arguments
+    if [ "$GRADLE_CYGPATTERN" != "" ] ; then
+        OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
+    fi
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    i=0
+    for arg in "$@" ; do
+        CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
+        CHECK2=`echo "$arg"|egrep -c "^-"`                                 ### Determine if an option
+
+        if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then                    ### Added a condition
+            eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
+        else
+            eval `echo args$i`="\"$arg\""
+        fi
+        i=$((i+1))
+    done
+    case $i in
+        (0) set -- ;;
+        (1) set -- "$args0" ;;
+        (2) set -- "$args0" "$args1" ;;
+        (3) set -- "$args0" "$args1" "$args2" ;;
+        (4) set -- "$args0" "$args1" "$args2" "$args3" ;;
+        (5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
+        (6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
+        (7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
+        (8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
+        (9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
+    esac
+fi
+
+# Split up the JVM_OPTS And GRADLE_OPTS values into an array, following the shell quoting and substitution rules
+function splitJvmOpts() {
+    JVM_OPTS=("$@")
+}
+eval splitJvmOpts $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS
+JVM_OPTS[${#JVM_OPTS[*]}]="-Dorg.gradle.appname=$APP_BASE_NAME"
+
+exec "$JAVACMD" "${JVM_OPTS[@]}" -classpath "$CLASSPATH" org.gradle.wrapper.GradleWrapperMain "$@"

src/main/java/kz/arta/synergy/ext/blocking/SendControlHandler.java

+package kz.arta.synergy.ext.blocking;
+
+import kz.arta.synergy.ext.blocking.dao.DenyGroups;
+import kz.arta.synergy.integration.api.bp.StartHandlerIF;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Универсальный слушатель контролирующий отправку документа
+ *
+ * @author MGetmanov
+ * @since 28.04.15 11:22
+ */
+public class SendControlHandler implements StartHandlerIF {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(SendControlHandler.class);
+    private static String comment = null;
+
+    @Override
+    public boolean makeDecision(HashMap<String, String> userInfo, String host, String locale, String actorID, Map<String, ?> params) {
+        Boolean result = true;
+        try {
+            List<String> allowUserGroups = StartSendHandlersReader.getAllowList();
+            DenyGroups denyUserGroups = StartSendHandlersReader.getDenyList();
+            Collection<String> fromUserGroups = UsersGroupsLists.getUserGroups(actorID);
+            Collection<String> toUserGroups = UsersGroupsLists.getUserGroups(userInfo.get("id"));
+
+            for (String groupTo : toUserGroups) {
+                for (DenyGroups.GroupComment groupDeny : denyUserGroups) {
+                    if (groupDeny.getGroupID().equals(groupTo)) {
+                        comment = groupDeny.getComment();
+                        result = false;
+                        for (String groupFrom : fromUserGroups) {
+                            if (allowUserGroups.contains(groupFrom)) {
+                                comment = null;
+                                result = true;
+                                break;
+                            }
+                        }
+                    }
+                }
+            }
+        } catch (Exception exc) {
+            LOGGER.error(exc.getMessage(), exc);
+        }
+        return result;
+    }
+
+    @Override
+    public String getResolution() {
+        return comment;
+    }
+}
\ No newline at end of file

src/main/java/kz/arta/synergy/ext/blocking/StartSendHandlersReader.java

+package kz.arta.synergy.ext.blocking;
+
+import kz.arta.synergy.datasource.config.ConfigManager;
+import kz.arta.synergy.ext.blocking.dao.DenyGroups;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.xml.sax.Attributes;
+import org.xml.sax.SAXException;
+import org.xml.sax.helpers.DefaultHandler;
+
+import javax.xml.parsers.SAXParser;
+import javax.xml.parsers.SAXParserFactory;
+import java.io.File;
+import java.io.FileInputStream;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Класс загрузки первоначальной конфигурации библиотеки
+ * User: artur
+ * Date: 23.01.14
+ * Time: 17:40
+ */
+public class StartSendHandlersReader {
+    private static Logger LOGGER = LoggerFactory.getLogger(StartSendHandlersReader.class);
+
+    /**
+     * Лист идентификаторов пользователей которые исключаются из запрещенных групп
+     */
+    private final static List<String> ALLOW_LIST = new ArrayList<String>();
+    /**
+     * Список идентификаторов групп пользователей отправка которым запрещена.
+     * Так же в объекте запрета содержится комментарий отказа
+     */
+    private final static DenyGroups DENY_GROUPS = new DenyGroups();
+
+    static {
+        try {
+            String filePath = ConfigManager.getCfgDirectory() + "/arta/ext/send-control.xml";
+            File file = new File(filePath);
+            FileInputStream fin = new FileInputStream(file);
+            SAXParser parser = SAXParserFactory.newInstance().newSAXParser();
+            parser.parse(fin, new CfgFileHandler());
+
+        } catch (Exception exc) {
+            LOGGER.error(exc.getMessage(), exc);
+        }
+    }
+
+    public static List<String> getAllowList() {
+        return ALLOW_LIST;
+    }
+
+    public static DenyGroups getDenyList() {
+        return DENY_GROUPS;
+    }
+
+    private static class CfgFileHandler extends DefaultHandler {
+
+        String currentNameAllow;
+        String currentNameDeny;
+
+        String currentAllow;
+        String currentDeny;
+        String currentDenyComment;
+
+        @Override
+        public void startElement(String uri, String localName, String qName, Attributes attributes) throws SAXException {
+            if ("allow".equals(qName)) {
+                currentNameAllow = qName;
+            }
+            if ("deny".equals(qName)) {
+                currentNameDeny = qName;
+                currentDenyComment = attributes.getValue("comment");
+            }
+
+
+        }
+
+        @Override
+        public void characters(char[] ch, int start, int length) throws SAXException {
+            if (currentNameAllow != null) {
+                currentAllow = new String(ch, start, length);
+                if (!"".equals(currentAllow)) {
+                    ALLOW_LIST.add(currentAllow);
+                }
+            }
+            if (currentNameDeny != null) {
+                currentDeny = new String(ch, start, length);
+                if (!"".equals(currentDeny)) {
+                    DENY_GROUPS.add(DenyGroups.GroupComment.build(currentDeny, currentDenyComment));
+                }
+            }
+        }
+
+        @Override
+        public void endElement(String uri, String localName, String qName) throws SAXException {
+            currentAllow = null;
+            currentDeny = null;
+            currentNameAllow = null;
+            currentNameDeny = null;
+            currentDenyComment = null;
+        }
+    }
+}
+
+

src/main/java/kz/arta/synergy/ext/blocking/UsersGroupsLists.java

+package kz.arta.synergy.ext.blocking;
+
+import kz.arta.synergy.datasource.config.ConfigManager;
+import com.google.gson.JsonArray;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
+import com.sun.org.apache.xerces.internal.impl.dv.util.Base64;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.util.*;
+
+/**
+ * коннектор API Synergy для получения данных из платформы
+ * User: artur
+ * Date: 23.01.14
+ * Time: 17:43
+ */
+public class UsersGroupsLists {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(UsersGroupsLists.class);
+
+    /**
+     * Метод получение ID групп для пользователя
+     * @param userID    - идентификатор пользователя
+     * @return список групп
+     */
+    public static Collection<String> getUserGroups(String userID) {
+        Set<String> usersGroupsList = new HashSet<String>();
+        try {
+            String hostUrl = ConfigManager.getAPIConfProps().getProperty("host");
+            String login = ConfigManager.getAPIConfProps().getProperty("login");
+            String pass = ConfigManager.getAPIConfProps().getProperty("pass");
+
+            String urlStr = hostUrl + "/rest/api/filecabinet/user/" + userID + "?locale=ru&getGroups=true";
+
+            URL url = new URL(urlStr);
+
+            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+            conn.setRequestMethod("GET");
+            conn.setRequestProperty("Accept", "application/json; charset=utf-8");
+
+            String encoded = Base64.encode((login + ":" + pass).getBytes("UTF-8"));
+            conn.setRequestProperty("Authorization", "Basic " + encoded);
+
+            String output;
+            StringBuilder result = new StringBuilder();
+
+            BufferedReader br = new BufferedReader(new InputStreamReader((conn.getInputStream())));
+
+            while ((output = br.readLine()) != null) {
+                result.append(output);
+            }
+            conn.disconnect();
+
+            JsonParser parser = new JsonParser();
+            Object obj = parser.parse(result.toString());
+            JsonObject jsonObject = (JsonObject) obj;
+            JsonArray msg = jsonObject.get("groups").getAsJsonArray();
+
+            for (JsonElement currentGroup : msg) {
+                String name = currentGroup.getAsJsonObject().get("groupID").getAsString();
+                usersGroupsList.add(name);
+            }
+
+        } catch (Exception exc) {
+            LOGGER.error(exc.getMessage(), exc);
+        }
+        return usersGroupsList;
+    }
+}
+

src/main/java/kz/arta/synergy/ext/blocking/dao/DenyGroups.java

+package kz.arta.synergy.ext.blocking.dao;
+
+import java.util.Collection;
+import java.util.HashSet;
+import java.util.Iterator;
+
+/**
+ * Список запрещенных групп с комментариями запрещения
+ *
+ * @author MGetmanov
+ * @since 28.04.15 10:41
+ */
+public class DenyGroups implements Iterable<DenyGroups.GroupComment> {
+    Collection<GroupComment> stor = new HashSet<GroupComment>();
+
+    public void add(GroupComment groupComment) {
+        stor.add(groupComment);
+    }
+
+    @Override
+    public Iterator<GroupComment> iterator() {
+        return stor.iterator();
+    }
+
+    /**
+     * Объект группа, комментарий отказа
+     */
+    public static class GroupComment {
+        final String groupID, comment;
+
+        private GroupComment(String groupID, String comment) {
+            this.groupID = groupID;
+            this.comment = comment;
+        }
+
+        public static GroupComment build(String groupID, String comment) {
+            return new GroupComment(groupID, comment);
+        }
+
+        public String getGroupID() {
+            return groupID;
+        }
+
+        public String getComment() {
+            return comment;
+        }
+
+    }
+
+}