Subversion Repositories XServices

 *   limitations under the License.

 *   limitations under the License.

 */

 */

package net.brutex.xservices.ws.impl;

import lombok.extern.slf4j.Slf4j;

import net.brutex.xservices.types.*;

import net.brutex.xservices.types.*;

import net.brutex.xservices.types.alfevent.ALFEventResponseType;

import net.brutex.xservices.types.alfevent.ALFEventResponseType;

import net.brutex.xservices.types.alfevent.ALFEventType;

import net.brutex.xservices.types.alfevent.ALFEventType;

import net.brutex.xservices.types.alfevent.ObjectFactory;

import net.brutex.xservices.types.alfevent.ObjectFactory;

import net.brutex.xservices.types.ant.FileSetResource;

import net.brutex.xservices.util.EventEmitter;

import net.brutex.xservices.util.EventEmitter;

import net.brutex.xservices.util.EventmanagerConfiguration;

import net.brutex.xservices.util.RunTask;

import net.brutex.xservices.util.RunTask;

import net.brutex.xservices.ws.MiscService;

import net.brutex.xservices.ws.MiscService;

import net.brutex.xservices.ws.XServicesFault;

import net.brutex.xservices.ws.XServicesFault;

import java.io.StringReader;

import java.io.StringReader;

import java.io.StringWriter;

import java.io.StringWriter;

import java.math.BigInteger;

import java.math.BigInteger;

import java.sql.*;

import java.sql.*;

import java.time.Instant;

import java.time.Instant;

import java.util.Date;

import java.util.Date;

import java.util.Enumeration;

import java.util.Enumeration;

import java.util.Properties;

import java.util.Properties;

import java.util.UUID;

import java.util.UUID;

import static org.quartz.TriggerBuilder.newTrigger;

import static org.quartz.TriggerBuilder.newTrigger;

/**

/**

 * Implements the web service

 * Implements the web service

 * 

 * @author Brian Rosenberger, bru@brutex.de

 * @author Brian Rosenberger, bru@brutex.de

 */

 */

@Slf4j

@WebService(targetNamespace="http://ws.xservices.brutex.net", endpointInterface="net.brutex.xservices.ws.MiscService", serviceName="MiscService")

@WebService(targetNamespace="http://ws.xservices.brutex.net", endpointInterface="net.brutex.xservices.ws.MiscService", serviceName="MiscService")

public class MiscServiceImpl

public class MiscServiceImpl

          ");" +

  implements MiscService {

          "CREATE INDEX IF NOT EXISTS brutex.btx_idx ON brutex.tbl_events (btx_obj_id, btx_obj_type, btx_event_type);" +

          "CREATE INDEX IF NOT EXISTS brutex.IDX_TO_DESC ON brutex.tbl_events (btx_timestamp ASC);";

  @Resource

  private WebServiceContext context;

  @Override

  @Override

  public ALFEventResponseType mergeALFEvent(ALFEventType event) throws XServicesFault {

  public ALFEventResponseType mergeALFEvent(ALFEventType event) throws XServicesFault {

    final Instant d = Instant.now();

    final Instant d = Instant.now();

    //System.out.println("Step 1: " + ChronoUnit.MILLIS.between(Instant.now(), d));

    //Get Parameters from the Servlet Context

            (ServletContext) context.getMessageContext().get(MessageContext.SERVLET_CONTEXT);

    log.trace("Read dbConnection from servlet context: {}", pool);

    final JdbcConnectionPool pool = (JdbcConnectionPool) servletContext.getAttribute("dbConnection");

    //System.out.println("Step 2: " + ChronoUnit.MILLIS.between(Instant.now(), d));

    //System.out.println("Step 2: " + ChronoUnit.MILLIS.between(Instant.now(), d));

    final ObjectFactory of = new ObjectFactory();

    final ObjectFactory of = new ObjectFactory();

    final String objectId = event.getBase().getObjectId();

    final String objectId = event.getBase().getObjectId();

    final String eventId = event.getBase().getEventId();

    final String eventType = event.getBase().getEventType();

    final String objectType = event.getBase().getObjectType();

    log.debug("Event id '{}', type '{}' received for object '{}' with object_id '{}'.",

            "VALUES (?,?,?,?,?,?) " +

    final String mergeStatememt = "MERGE INTO brutex.tbl_events " +

            "KEY (btx_event_type, btx_obj_type, btx_obj_id) " +

    long rows = 0L;

            "VALUES (?,?,?,?,?,?);";

    //System.out.println("Step 3: " + ChronoUnit.MILLIS.between(Instant.now(), d));

    try {

      //System.out.println("Step 4: " + ChronoUnit.MILLIS.between(Instant.now(), d));

    try {

      Marshaller m = JAXBContext.newInstance(ALFEventType.class).createMarshaller();

      Marshaller m = JAXBContext.newInstance(ALFEventType.class).createMarshaller();

      m.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, Boolean.TRUE);

      m.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, Boolean.TRUE);

      JAXBElement<ALFEventType> e = of.createEventNotice(event);

      StringWriter sw = new StringWriter();

      StringWriter sw = new StringWriter();

      m.marshal(e, sw);

      m.marshal(e, sw);

      StringBuilder sb = new StringBuilder();

      StringBuilder sb = new StringBuilder();

      sb.append(" <soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" " +

      sb.append(" <soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:ns=\"http://www.eclipse.org/alf/schema/EventBase/1\">\n");

                "xmlns:ns=\"http://www.eclipse.org/alf/schema/EventBase/1\">\n");

      sb.append("<soapenv:Body>\n");

      sb.append("<soapenv:Body>\n");

      sb.append(sw);

      sb.append(sw);

      sb.append("</soapenv:Body>");

      sb.append("</ns:EventNotice>\n");

      sb.append("</soapenv:Envelope>");

      sb.append("</soapenv:Body>");

      //System.out.println("Step 5: " + ChronoUnit.MILLIS.between(Instant.now(), d));

      sb.append("</soapenv:Envelope>");

      Connection con = pool.getConnection();

      //System.out.println("Step 6: " + ChronoUnit.MILLIS.between(Instant.now(), d));

      Connection con = pool.getConnection();

      PreparedStatement prep = con.prepareStatement(mergeStatememt);

      PreparedStatement prep = con.prepareStatement(mergeStatememt);

      prep.setString(1, eventType);

      prep.setString(1, eventType);

      prep.setString(4, objectId);

      prep.setString(2, eventId);

      prep.setLong(5, ts);

      prep.setString(3, objectType);

      prep.setClob(6, new StringReader(sb.toString()));

      prep.setString(4, objectId);

      // and start it off

      prep.setClob(6, new StringReader(sb.toString()));

      prep.execute();

      if (!scheduler.isStarted())

      con.commit();

      synchronized (scheduler) {

            job2.getJobDataMap().put("mdbConnection", pool);

            JobDetail job2 = JobBuilder.newJob(EventEmitter.class)

            job2.getJobDataMap().put("run_key", ts);

                    .withIdentity("ALFEmitter").build();

            job2.getJobDataMap().put("egres_counter", egres_counter);

            //job2.getJobDataMap().put("description", job.getDescription());

            job2.getJobDataMap().put(EventmanagerConfiguration.KEY, conf);

                    .withIdentity("ALFEmitter").startAt(Date.from(d.plusSeconds(20)))

                    .withIdentity("ALFEmitter").startAt(Date.from(d.plusSeconds(conf.getInterval())))

                    .build();

                    .build();

            scheduler.scheduleJob(job2, t);

            scheduler.scheduleJob(job2, t);

        }

          }