Subversion Repositories bacoAlunos

package pt.estgp.estgweb.web.controllers.bpmn;

import com.orsoncharts.util.json.parser.JSONParser;

import com.orsoncharts.util.json.parser.ParseException;

import jomm.dao.impl.AbstractDao;

import org.apache.log4j.Logger;

import org.apache.struts.action.ActionForm;

import org.json.JSONArray;

import org.json.JSONException;

import org.json.JSONObject;

import pt.estgp.estgweb.domain.*;

import pt.estgp.estgweb.domain.typesgen.ConnectorSoa;

import pt.estgp.estgweb.domain.typesgen.Todos;

import pt.estgp.estgweb.domain.typesgen.VariableType;

import pt.estgp.estgweb.domain.dao.DaoFactory;

import pt.estgp.estgweb.services.ServiceFinder;

import pt.estgp.estgweb.web.controllers.utils.AbstractWidgetAjaxController;

import pt.estgp.estgweb.web.utils.JspInterfacesJsonGen;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.util.Iterator;

import java.util.List;

import static org.hibernate.criterion.Restrictions.eq;

/**

 * @author Jorge Machado

 * @date 26/Fev/2008

 * @time 18:01:54

 * @see pt.estgp.estgweb.web

 */

public class BpmnController extends AbstractWidgetAjaxController

{

    private static final 1.5.0/docs/api/java/util/logging/Logger.html">Logger logger = 1.5.0/docs/api/java/util/logging/Logger.html">Logger.getLogger(BpmnController.class);

    static JSONObject jspInterfaces = null;

    static JSONObject servicesSoa = null;

    private static synchronized JSONObject loadJsps()

    {

        if(jspInterfaces == null)

        {

            try {

                BpmnController.class.getResourceAsStream(JspInterfacesJsonGen.JSON_FILE_JSPS);

                JSONParser parser = new JSONParser();

                1.5.0/docs/api/java/lang/String.html">String jspInterfacesArray = ((com.orsoncharts.util.json.JSONArray) parser.parse(new 1.5.0/docs/api/java/io/InputStreamReader.html">InputStreamReader(BpmnController.class.getResourceAsStream(JspInterfacesJsonGen.JSON_FILE_JSPS))))

                        .toJSONString();

                jspInterfaces = new JSONObject();

                jspInterfaces.put("jsps", new JSONArray(jspInterfacesArray));

            } catch (1.5.0/docs/api/java/io/IOException.html">IOException e) {

                logger.error("BACO BpmnController : Initializing jsps json file for JSP listing ");

            } catch (1.5.0/docs/api/java/text/ParseException.html">ParseException e) {

                logger.error("BACO BpmnController : Initializing jsps json file for JSP listing ");

            } catch (JSONException e) {

                logger.error("BACO BpmnController : Initializing jsps json file for JSP listing ");

            }

        }

        return jspInterfaces;

    }

    private static synchronized JSONObject loadServicesSoa()

    {

        if(servicesSoa == null)

        {

            try {

                JSONParser parser = new JSONParser();

                5+0%2Fdocs%2Fapi+InputStream">InputStream stream = BpmnController.class.getResourceAsStream(ServiceFinder.SERVICES_SOA_FILE);

                if(stream != null)

                {

                    1.5.0/docs/api/java/lang/String.html">String servicesClassesArray = ((com.orsoncharts.util.json.JSONArray) parser.parse(new 1.5.0/docs/api/java/io/InputStreamReader.html">InputStreamReader(stream))).toJSONString();

                    servicesSoa = new JSONObject();

                    servicesSoa.put("services", new JSONArray(servicesClassesArray));

                }

            } catch (1.5.0/docs/api/java/io/IOException.html">IOException e) {

                logger.error("BACO BpmnController : Initializing jsps json file for JSP listing ");

            } catch (1.5.0/docs/api/java/text/ParseException.html">ParseException e) {

                logger.error("BACO BpmnController : Initializing jsps json file for JSP listing ");

            } catch (JSONException e) {

                logger.error("BACO BpmnController : Initializing jsps json file for JSP listing ");

            }

        }

        return servicesSoa;

    }

    public JSONObject loadJspsPlugins(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        return loadJsps();

    }

    public JSONObject loadServicesSoa(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        return loadServicesSoa();

    }

    public JSONObject loadClassMethods(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        1.5.0/docs/api/java/lang/String.html">String className = request.getParameter("className");

        JSONObject classDescription = ServiceFinder.obtainClassDescription(1.5.0/docs/api/java/lang/Class.html">Class.forName(className));

        return classDescription;

    }

    public JSONObject newProcess(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnProcessImpl process = DomainObjectFactory.createBpmnProcessImpl();

        DaoFactory.getBpmnProcessDaoImpl().save(process);

        JSONObject processJson = process.toJsonObject();

        AbstractDao.getCurrentSession().getTransaction().commit();

        return processJson;

    }

    public JSONObject addActorPool(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        1.5.0/docs/api/java/lang/Long.html">Long processId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("processId"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnProcessImpl persistent = (BpmnProcessImpl) DaoFactory.getBpmnProcessDaoImpl().get(processId);

        BpmnActorPool actorPool = DomainObjectFactory.createBpmnActorPoolImpl();

        actorPool.setProcess(persistent);

        persistent.getActorPools().add(actorPool);

        DaoFactory.getBpmnActorPoolDaoImpl().save(actorPool);

        JSONObject actorPoolJson = actorPool.toJsonObject();

        AbstractDao.getCurrentSession().getTransaction().commit();

        return actorPoolJson;

    }

    public JSONObject addConnector(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        1.5.0/docs/api/java/lang/Long.html">Long taskId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("taskId"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnFlowComponentTask persistent = (BpmnFlowComponentTask) DaoFactory.getBpmnFlowComponentTaskDaoImpl().get(taskId);

        BpmnFlowConnector connector = DomainObjectFactory.createBpmnFlowConnectorImpl();

        persistent.getFlowConnectors().add(connector);

        DaoFactory.getBpmnFlowConnectorDaoImpl().save(connector);

        JSONObject connectorJson = connector.toJsonObject();

        AbstractDao.getCurrentSession().getTransaction().commit();

        return connectorJson;

    }

    public JSONObject addTaskActor(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        1.5.0/docs/api/java/lang/Long.html">Long poolId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("poolId"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnActorPoolImpl persistent = (BpmnActorPoolImpl) DaoFactory.getBpmnActorPoolDaoImpl().get(poolId);

        BpmnFlowComponentTaskActor taskActor = DomainObjectFactory.createBpmnFlowComponentTaskActorImpl();

        taskActor.setActorPool(persistent);

        persistent.getFlowComponents().add(taskActor);

        DaoFactory.getBpmnFlowComponentTaskActorDaoImpl().save(taskActor);

        JSONObject taskActorJson = taskActor.toJsonObject();

        AbstractDao.getCurrentSession().getTransaction().commit();

        return taskActorJson;

    }

    public JSONObject addConnectorSoa(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        1.5.0/docs/api/java/lang/Long.html">Long taskId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("taskId"));

        ConnectorSoa connectorSoa = ConnectorSoa.fromString(request.getParameter("connectorSoa"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnFlowComponentTask task = DaoFactory.getBpmnFlowComponentTaskDaoImpl().get(taskId);

        if(task.getTodos() == null)

            task.setTodos(new Todos());

        task.getTodos().getTodos().add(connectorSoa);

        AbstractDao.getCurrentSession().getTransaction().commit();

        return connectorSoa.toJsonObject();

    }

    public JSONObject newProcessVar(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        1.5.0/docs/api/java/lang/Long.html">Long processId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("processId"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnProcessImpl persistent = (BpmnProcessImpl) DaoFactory.getBpmnProcessDaoImpl().get(processId);

        BpmnVariableImpl var = DomainObjectFactory.createBpmnVariableImpl();

        var.setType(new VariableType(VariableType.VariableTypeEnum.1.5.0/docs/api/java/lang/Long.html">Long));

        DaoFactory.getBpmnVariableDaoImpl().save(var);

        persistent.getProcessVariables().add(var);

        JSONObject varJson = var.toJsonObject();

        AbstractDao.getCurrentSession().getTransaction().commit();

        return varJson;

    }

    public JSONObject newLocalVar(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        1.5.0/docs/api/java/lang/Long.html">Long taskId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("taskId"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnFlowComponent persistent = DaoFactory.getBpmnFlowComponentDaoImpl().get(taskId);

        BpmnVariableImpl var = DomainObjectFactory.createBpmnVariableImpl();

        var.setType(new VariableType(VariableType.VariableTypeEnum.1.5.0/docs/api/java/lang/Long.html">Long));

        DaoFactory.getBpmnVariableDaoImpl().save(var);

        persistent.getLocalVariables().add(var);

        JSONObject varJson = var.toJsonObject();

        AbstractDao.getCurrentSession().getTransaction().commit();

        return varJson;

    }

    public 1.5.0/docs/api/java/lang/Boolean.html">Boolean removeProcessVar(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        1.5.0/docs/api/java/lang/Long.html">Long processId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("processId"));

        1.5.0/docs/api/java/lang/Long.html">Long variableId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("variableId"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnProcessImpl persistent = (BpmnProcessImpl) DaoFactory.getBpmnProcessDaoImpl().get(processId);

        BpmnVariable var = DaoFactory.getBpmnVariableDaoImpl().get(variableId);

        persistent.getProcessVariables().remove(var);

        DaoFactory.getBpmnVariableDaoImpl().delete(var);

        AbstractDao.getCurrentSession().getTransaction().commit();

        return true;

    }

    public 1.5.0/docs/api/java/lang/Boolean.html">Boolean removeLocalVar(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        1.5.0/docs/api/java/lang/Long.html">Long taskId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("taskId"));

        1.5.0/docs/api/java/lang/Long.html">Long variableId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("variableId"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnFlowComponent persistent = DaoFactory.getBpmnFlowComponentDaoImpl().get(taskId);

        BpmnVariable var = DaoFactory.getBpmnVariableDaoImpl().get(variableId);

        persistent.getLocalVariables().remove(var);

        DaoFactory.getBpmnVariableDaoImpl().delete(var);

        AbstractDao.getCurrentSession().getTransaction().commit();

        return true;

    }

    public JSONObject updateProcess(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        BpmnProcessImpl view = BpmnProcessImpl.fromJson(request.getParameter("processJson"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnProcessImpl persistent = (BpmnProcessImpl) DaoFactory.getBpmnProcessDaoImpl().get(view.getId());

        persistent.setName(view.getName());

        persistent.setActive(view.isActive());

        JSONObject processJson = persistent.toJsonObject();

        AbstractDao.getCurrentSession().getTransaction().commit();

        return processJson;

    }

    public boolean updatePool(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        BpmnActorPool actorPoolView = (BpmnActorPool) DomainObject.fromJson(request.getParameter("object"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnActorPool persistent = (BpmnActorPool) DaoFactory.getBpmnActorPoolDaoImpl().get(actorPoolView.getId());

        persistent.setName(actorPoolView.getName());

        AbstractDao.getCurrentSession().getTransaction().commit();

        //return actorPoolJson;

        return true;

    }

    public boolean updateTask(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        BpmnFlowComponentTask taskView = (BpmnFlowComponentTask) DomainObject.fromJson(request.getParameter("object"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnFlowComponentTask persistent = (BpmnFlowComponentTask) DaoFactory.getBpmnFlowComponentTaskDaoImpl().get(taskView.getId());

        persistent.setTitle(taskView.getTitle());

        persistent.setDescription(taskView.getDescription());

        persistent.setTodos(taskView.getTodos());

        if(persistent instanceof BpmnFlowComponentTaskActor)

        {

            ((BpmnFlowComponentTaskActor)persistent).setInterfacePlugin(((BpmnFlowComponentTaskActor) taskView).getInterfacePlugin());

            //((BpmnFlowComponentTaskActor)persistent).set(((BpmnFlowComponentTaskActor)taskView).getInterfacePlugin());

            ((BpmnFlowComponentTaskActor)persistent).setAfterUserTodos(((BpmnFlowComponentTaskActor) taskView).getAfterUserTodos());

        }

        AbstractDao.getCurrentSession().getTransaction().commit();

        //return actorPoolJson;

        return true;

    }

    public boolean updateConnector(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        BpmnFlowConnectorImpl connectorView = (BpmnFlowConnectorImpl) DomainObject.fromJson(request.getParameter("object"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnFlowConnector persistent = DaoFactory.getBpmnFlowConnectorDaoImpl().get(connectorView.getId());

        persistent.setNameConnection(connectorView.getNameConnection());

        persistent.setKeyValue(connectorView.getKeyValue());

        persistent.setMsgEmail(connectorView.getMsgEmail());

        persistent.setSendEmail(connectorView.isSendEmail());

        //todo faltam os holders e os target types

        if(connectorView.getFlowComponentId() != null)

        {

            BpmnFlowComponent flowComponent = DaoFactory.getBpmnFlowComponentTaskDaoImpl().get(connectorView.getFlowComponentId());

            persistent.setFlowComponent(flowComponent);

        }

        else

            persistent.setFlowComponent(null);

        AbstractDao.getCurrentSession().getTransaction().commit();

        return true;

    }

    public boolean updateVariable(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        BpmnVariable variableView = (BpmnVariable) DomainObject.fromJson(request.getParameter("object"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnVariable persistent = (BpmnVariable) DaoFactory.getBpmnVariableDaoImpl().get(variableView.getId());

        persistent.setName(variableView.getName());

        persistent.setType(variableView.getType());

        AbstractDao.getCurrentSession().getTransaction().commit();

        //return actorPoolJson;

        return true;

    }

    public boolean removeActorPool(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        //TODO NO SERVICO QUANDO HOUVER CHECK PROCESSOS ABERTOS INSTANCIAS

        1.5.0/docs/api/java/lang/Long.html">Long poolId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("poolId"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnActorPool actorPool = DaoFactory.getBpmnActorPoolDaoImpl().get(poolId);

        logger.warn("Removing bpmn pool: " + poolId + " " + actorPool.getName() + " from process " + actorPool.getProcess().getId() + " " + actorPool.getProcess().getName());

        if(actorPool.getFlowComponents().size() > 0)

        {

            addErrorAsString(request,"Não pode remover uma pool com componentes de fluxo associados, remova os componentes primeiro");

            AbstractDao.getCurrentSession().getTransaction().rollback();

        }

        else

        {

            DaoFactory.getBpmnActorPoolDaoImpl().delete(actorPool);

            AbstractDao.getCurrentSession().getTransaction().commit();

        }

        return true;

    }

    public boolean removeTask(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        //TODO NO SERVICO QUANDO HOUVER CHECK PROCESSOS ABERTOS INSTANCIAS nao deixar apagar

        1.5.0/docs/api/java/lang/Long.html">Long poolId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("poolId"));

        1.5.0/docs/api/java/lang/Long.html">Long taskId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("taskId"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnActorPoolImpl poolPersistent = (BpmnActorPoolImpl) DaoFactory.getBpmnActorPoolDaoImpl().get(poolId);

        BpmnFlowComponentTask taskPersistent = DaoFactory.getBpmnFlowComponentTaskDaoImpl().get(taskId);

        List<BpmnFlowConnector> cons =

                AbstractDao.getCurrentSession()

                        .createCriteria(BpmnFlowConnector.class)

                        .add(eq("flowComponent.id", taskId))

                        .list();

        if(cons.size() > 0)

        {

            addErrorAsString(request,"Nao pode apagar esta Tarefa porque existe um connector a apontar para ela: " + cons.get(0).getNameConnection());

            return false;

        }

        logger.warn("Removing bpmn task: " + taskPersistent.getId() + " " + taskPersistent.getTitle() + " from pool " + poolPersistent.getId() + " " + poolPersistent.getName() + " from process " + poolPersistent.getProcess().getId() + " " + poolPersistent.getProcess().getName());

        if(taskPersistent.getFlowConnectors() != null)

        {

            Iterator<BpmnFlowConnector> iter = taskPersistent.getFlowConnectors().iterator();

            while(iter.hasNext())

            {

                BpmnFlowConnector con = iter.next();

                logger.warn("Removing bpmn connector: " + con.getId() + " " + con.getNameConnection() + ":" + con.getKeyValue() );

                iter.remove();

                DaoFactory.getBpmnFlowConnectorDaoImpl().delete(con);

            }

        }

        poolPersistent.getFlowComponents().remove(taskPersistent);

        DaoFactory.getBpmnFlowComponentTaskDaoImpl().delete(taskPersistent);

        AbstractDao.getCurrentSession().getTransaction().commit();

        return true;

    }

    public boolean removeConnector(ActionForm form,HttpServletRequest request, HttpServletResponse response) throws 1.5.0/docs/api/java/lang/Throwable.html">Throwable

    {

        //TODO NO SERVICO QUANDO HOUVER CHECK PROCESSOS ABERTOS INSTANCIAS

        1.5.0/docs/api/java/lang/Long.html">Long taskId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("taskId"));

        1.5.0/docs/api/java/lang/Long.html">Long connectorId = 1.5.0/docs/api/java/lang/Long.html">Long.parseLong(request.getParameter("connectorId"));

        AbstractDao.getCurrentSession().beginTransaction();

        BpmnFlowComponentTask taskPersistent = DaoFactory.getBpmnFlowComponentTaskDaoImpl().get(taskId);

        BpmnActorPoolImpl poolPersistent = taskPersistent.getActorPool();

        BpmnFlowConnector connectorPersistent = DaoFactory.getBpmnFlowConnectorDaoImpl().get(connectorId);

        logger.warn("Removing bpmn connector: " + connectorId + " " + connectorPersistent.getNameConnection() + ":" + connectorPersistent.getKeyValue() + " from task: " + taskPersistent.getId() + " " + taskPersistent.getTitle() + " from pool " + poolPersistent.getId() + " " + poolPersistent.getName() + " from process " +  poolPersistent.getProcess().getId() + " " + poolPersistent.getProcess().getName());

        taskPersistent.getFlowConnectors().remove(connectorPersistent);

        DaoFactory.getBpmnFlowConnectorDaoImpl().delete(connectorPersistent);

        AbstractDao.getCurrentSession().getTransaction().commit();

        return true;

    }

}