find events in xray and radio

Wsdl

Wsdl Operation

Value

Script

String goes = new String("");
sql_string = sql_base.replace("%start_date%",start_date);
sql_string = sql_string.replace("%stop_date%",stop_date);
if(goes_min.length() > 0) {
  goes = goes.concat(" AND xray_class > '"+goes_min+"'");
}
if (goes_max.length() > 0) {
   goes = goes.concat(" AND xray_class < '"+goes_max+"'");
}
sql_string = sql_string.replace("%goes%",goes);

Script

import java.io.StringReader;
import org.w3c.dom.*;
import org.xml.sax.InputSource;
import org.apache.xerces.parsers.DOMParser;

private void getPositions(){
  NodeList nodesVO = docVO.getElementsByTagName("FIELD");
  for(int i=0; i< nodesVO.getLength(); i++){
     Element voFieldNode = nodesVO.item(i);
     String name = voFieldNode.getAttribute("name");
     if(name.trim().equals("ntime_start")){
        pos_start_vo = i;
     } else if(name.trim().equals("ntime_end")){
        pos_end_vo = i;
     } else if(name.trim().equals("time_start")){
        pos_startA_vo = i;
     } else if(name.trim().equals("time_end")){
        pos_endA_vo = i;
     }
  }
}


private void findDates() {
  NodeList dataListVO = docVO.getElementsByTagName("TR");
  debug= debug.concat(" length " + dataListVO.getLength()+ "\n");
  for(int i = 0; i < dataListVO.getLength(); i++) {
     debug= debug.concat(" i " + i+ "datalength " + dataListVO.getLength() +"\n" );
     List date = new ArrayList();
     NodeList voDataChilds = dataListVO.item(i).getChildNodes();
     debug= debug.concat(" length2 " +voDataChilds.getLength()+ "\n");
     if(voDataChilds.item(pos_start_vo).getFirstChild()!= null) {
       debug= debug.concat("here 1");
       date.add(voDataChilds.item(pos_start_vo).getFirstChild().getNodeValue());
       startDates.add(voDataChilds.item(pos_start_vo).getFirstChild().getNodeValue());
       debug= debug.concat("here 1a");
     } else {
       debug= debug.concat("here 2");
       date.add(voDataChilds.item(pos_startA_vo).getFirstChild().getNodeValue());
       startDates.add(voDataChilds.item(pos_startA_vo).getFirstChild().getNodeValue());
       debug= debug.concat("here 2a");
     }
     if(voDataChilds.item(pos_end_vo).getFirstChild()!= null) {
       debug= debug.concat("here 3");
       date.add(voDataChilds.item(pos_end_vo).getFirstChild().getNodeValue());
       endDates.add(voDataChilds.item(pos_end_vo).getFirstChild().getNodeValue());
       debug= debug.concat("here 3a");
     } else {
       debug= debug.concat("here 4");
       date.add(voDataChilds.item(pos_endA_vo).getFirstChild().getNodeValue());
       endDates.add(voDataChilds.item(pos_endA_vo).getFirstChild().getNodeValue());
       debug= debug.concat("here 4a");
     }
     date.add(i);
     positions.add(i);
     dateList.add(date);
     debug= debug.concat(" end " +i + " \n");
  }
}

List dateList = new ArrayList();
List startDates = new ArrayList();
List endDates = new ArrayList();
List positions = new ArrayList();
String debug = "debug";
StringReader reader2 = new StringReader(voTable);
InputSource source2 = new InputSource(reader2);
Document docVO;
int pos_start_vo;
int pos_end_vo;
int pos_startA_vo;
int pos_endA_vo;
try {
  DOMParser parser = new DOMParser();
  parser.parse(source2);
  docVO = parser.getDocument();
  this.getPositions();
  this.findDates();
  reader2.close();
  if(dateList.size()==0){
    dateList.add(new ArrayList());
  }
  if(endDates.size()==0){
    endDates.add("2008-00-00 00:00:01");
  }
  if(startDates.size()==0){
    startDates.add("2008-00-00 00:00:00");
  }
  if(positions.size()==0){
    positions.add("0");
  }
}
catch (Exception e){
}

Wsdl

Wsdl Operation

Script

import java.io.StringReader;
import org.w3c.dom.*;
import org.xml.sax.InputSource;
import org.apache.xerces.parsers.DOMParser;
import java.io.StringWriter;
import java.util.Date;
import java.text.SimpleDateFormat;
import java.lang.*;

private void write(Node node, String indent) {
        // The output depends on the type of the node
        switch(node.getNodeType()) {
        case Node.DOCUMENT_NODE: {       // If its a Document node
            Document doc = (Document)node;
            out.write(indent + "\n");  // Output header
            Node child = doc.getFirstChild();   // Get the first node
            while(child != null) {              // Loop 'till no more nodes
                write(child, indent);           // Output node
                child = child.getNextSibling(); // Get next node
            }
            break;
        } 
        case Node.DOCUMENT_TYPE_NODE: {  // It is a  tag
            DocumentType doctype = (DocumentType) node;
            // Note that the DOM Level 1 does not give us information about
            // the the public or system ids of the doctype, so we can't output
            // a complete  tag here.  We can do better with Level 2.
            out.write("\n");
            break;
        }
        case Node.ELEMENT_NODE: {        // Most nodes are Elements
            Element elt = (Element) node;
            out.write(indent + "<" + elt.getTagName());   // Begin start tag
            NamedNodeMap attrs = elt.getAttributes();     // Get attributes
            for(int i = 0; i < attrs.getLength(); i++) {  // Loop through them
                Node a = attrs.item(i);
                out.write(" " + a.getNodeName() + "='" +  // Print attr. name
                          fixup(a.getNodeValue()) + "'"); // Print attr. value
            }
            out.write(">\n");                             // Finish start tag

            String newindent = indent + "    ";           // Increase indent
            Node child = elt.getFirstChild();             // Get child
            while(child != null) {                        // Loop 
                write(child, newindent);                  // Output child
                child = child.getNextSibling();           // Get next child
            }

            out.write(indent + "\n");
            break;
        }
        case Node.TEXT_NODE: {                   // Plain text node
            Text textNode = (Text)node;
            String text = textNode.getData().trim();   // Strip off space
            if ((text != null) && text.length() > 0)   // If non-empty
                out.write(indent + fixup(text)+"\n");     // print text
            break;
        }
        case Node.PROCESSING_INSTRUCTION_NODE: {  // Handle PI nodes
            ProcessingInstruction pi = (ProcessingInstruction)node;
            out.write(indent + "\n");
            break;
        }
        case Node.ENTITY_REFERENCE_NODE: {        // Handle entities
            out.write(indent + "&" + node.getNodeName() + ";\n");
            break;
        }
        case Node.CDATA_SECTION_NODE: {           // Output CDATA sections
            CDATASection cdata = (CDATASection)node;
            // Careful! Don't put a CDATA section in the program itself!
            out.write(indent + "<" + "![CDATA[" + cdata.getData() +
                        "]]" + ">\n");
            break;
        }
        case Node.COMMENT_NODE: {                 // Comments
            Comment c = (Comment)node;
            out.write(indent + "\n");
            break;
        }
        default:   // Hopefully, this won't happen too much!
            System.err.println("Ignoring node: " + node.getClass().getName());
            break;
        }
    }

    // This method replaces reserved characters with entities.
private String fixup(String s) {
        StringBuffer sb = new StringBuffer();
        int len = s.length();
        for(int i = 0; i < len; i++) {
            char c = s.charAt(i);
            switch(c) {
            default: sb.append(c); break;
            case '<': sb.append("<"); break;
            case '>': sb.append(">"); break;
            case '&': sb.append("&"); break;
            case '"': sb.append("""); break;
            case '\'': sb.append("'"); break;
            }
        }
        return sb.toString();
    }

private void addTableHeaders(List instrument, String prefix){
  NodeList nodes=null;
  StringReader reader;
  InputSource source;
  for(int i = 0; i < instrument.size(); i++) {
    reader = new StringReader(instrument.get(i));
    source = new InputSource(reader);
    parser.parse(source);
    doc=parser.getDocument();
    nodes = doc.getElementsByTagName("return");
    if(nodes!= null && nodes.getLength()>=1){
      break;
    } else {
      reader.close();
    }
  }

  NodeList nodesVO = docVO.getElementsByTagName("TABLE");
  if(nodesVO.getLength() >= 1){
    Node voTableNode = nodesVO.item(0);
    if(nodes != null && nodes.getLength()>= 1){
      Node observation = nodes.item(0);
      NodeList obsChilds = observation.getChildNodes();
      for(int i=0; i< obsChilds.getLength(); i++){
        Element voFieldNode = docVO.createElement("FIELD");
        voFieldNode.setAttribute("name",prefix.concat(obsChilds.item(i).getLocalName()));
        voFieldNode.setAttribute("datatype","char");
        voFieldNode.setAttribute("arraysize","3400");
        voTableNode.insertBefore(voFieldNode, voTableNode.getLastChild());
      }
    }
  }
  reader.close();
}

private void addTableHeaderValue(String value){
  NodeList nodesVO = docVO.getElementsByTagName("TABLE");
  if(nodesVO.getLength() >= 1){
    Node voTableNode = nodesVO.item(0);
    Element voFieldNode = docVO.createElement("FIELD");
    voFieldNode.setAttribute("name", value);
    voFieldNode.setAttribute("datatype","char");
    voFieldNode.setAttribute("arraysize","3400");
    voTableNode.insertBefore(voFieldNode, voTableNode.getLastChild());
  }
}

private writeExtraFields(Node nodeVO, Node nodeHessi) {
  String debug = new String("");
  NodeList listHessi = nodeHessi.getChildNodes();
  for(int i=0; i< listHessi.getLength(); i++) {
    Node newNode = nodeVO.getFirstChild().cloneNode(false);
    Text voTextNode = docVO.createTextNode(listHessi.item(i).getFirstChild().getNodeValue());
    newNode.appendChild(voTextNode);
    nodeVO.appendChild(newNode);
  }
} 

private writeSolarMonitor(Node nodeVO, int pos) {
  NodeList nodes=null;
  StringReader reader;
  InputSource source;
  Document docSM;
  DOMParser parserSM = new DOMParser();
  reader = new StringReader(solar_monitor_data.get(pos));
  source = new InputSource(reader);
  parserSM.parse(source);
  docSM=parserSM.getDocument();
  nodes = docSM.getElementsByTagName("urlPreview");
  if(nodes!= null && nodes.getLength()>=1){
      NodeList obsChilds = nodes.item(0).getChildNodes();
      Node newNode = nodeVO.getFirstChild().cloneNode(false);
      Text voTextNode = docVO.createTextNode(obsChilds.item(0).getNodeValue());
      newNode.appendChild(voTextNode);
      nodeVO.appendChild(newNode);
  } else {

    Node newNode = nodeVO.getFirstChild().cloneNode(false);
    Text voTextNode = docVO.createTextNode("");
    newNode.appendChild(voTextNode);
    nodeVO.appendChild(newNode);
  }
  nodes = docSM.getElementsByTagName("urlPreviewThumb");
  if(nodes!= null && nodes.getLength()>=1){
      NodeList obsChilds = nodes.item(0).getChildNodes();
      Node newNode = nodeVO.getFirstChild().cloneNode(false);
      Text voTextNode = docVO.createTextNode(obsChilds.item(0).getNodeValue());
      newNode.appendChild(voTextNode);
      nodeVO.appendChild(newNode);
  } else {

    Node newNode = nodeVO.getFirstChild().cloneNode(false);
    Text voTextNode = docVO.createTextNode("");
    newNode.appendChild(voTextNode);
    nodeVO.appendChild(newNode);
  }
   reader.close();
}

private String findOverlaps() {

  NodeList nodesHessi=null;
  NodeList nodesPhoenix=null;
  StringReader reader;
  StringReader readerPhoenix;
  InputSource source;
  InputSource sourcePhoenix;
  String debug = new String("");
  NodeList tableListVO = docVO.getElementsByTagName("TABLEDATA");
  NodeList dataListVO = docVO.getElementsByTagName("TR");
  if(dataListVO == null) {
    debug="dataListVO = null";
    return debug;
  }
  SimpleDateFormat date = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss'Z'");

  if(instrument_data_hessi.size() != instrument_data_phoenix.size()) {
    throw new Exception("data list lengths different -> not from same periodes");
  }

  for(int i = instrument_data_hessi.size()-1; i>=0; i--) {
    reader = new StringReader(instrument_data_hessi.get(i));
    readerPhoenix = new StringReader(instrument_data_phoenix.get(i));
    source = new InputSource(reader);
    sourcePhoenix = new InputSource(readerPhoenix);
    parser.parse(source);
    parserPhoenix.parse(sourcePhoenix);
    doc=parser.getDocument();
    docPhoenix=parserPhoenix.getDocument();
    NodeList dataListHessi = doc.getElementsByTagName("measurementStart");
    if(dataListHessi == null){
      dataListHessi = new NodeList();
    }
    NodeList dataListHessi2 = doc.getElementsByTagName("measurementEnd");

    NodeList dataListPhoenix = docPhoenix.getElementsByTagName("measurementStart");

    if(dataListePhoenix == null) {
       dataListPhoenix = new NodeList();
    }

    NodeList dataListPhoenix2 = docPhoenix.getElementsByTagName("measurementEnd"); 

    int pos = Integer.parseInt(position.get(i)); 

    Node voDataNode = dataListVO.item(pos);
    if(voDataNode == null)
    {
      reader.close();
      readerPhoenix.close();
      return debug;
    }
    Node parent = voDataNode.getParentNode();
    for(int j = 0; j < dataListHessi.getLength(); j++) {
      Date startHessi = date.parse(dataListHessi.item(j).getFirstChild().getNodeValue());
      Date endHessi = date.parse(dataListHessi2.item(j).getFirstChild().getNodeValue());
      for(int k = 0; k < dataListPhoenix.getLength(); k++) {
        Date startPhoenix = date.parse(dataListPhoenix.item(k).getFirstChild().getNodeValue());
        Date endPhoenix = date.parse(dataListPhoenix2.item(k).getFirstChild().getNodeValue());
        if(startHessi.getTime()<= startPhoenix.getTime() && endHessi.getTime()>=startPhoenix.getTime()){
          Node voDataNodeCurrent = voDataNode.cloneNode(true);
          writeExtraFields(voDataNodeCurrent, doc.getElementsByTagName("return").item(j));
          writeExtraFields(voDataNodeCurrent, docPhoenix.getElementsByTagName("return").item(k));
          writeSolarMonitor(voDataNodeCurrent, pos);
          parent.insertBefore(voDataNodeCurrent, voDataNode);
        } else if (startHessi.getTime()<= endPhoenix.getTime() && endHessi.getTime()>=endPhoenix.getTime()){
          Node voDataNodeCurrent = voDataNode.cloneNode(true);
          writeExtraFields(voDataNodeCurrent, doc.getElementsByTagName("return").item(j));
          writeExtraFields(voDataNodeCurrent, docPhoenix.getElementsByTagName("return").item(k));
          writeSolarMonitor(voDataNodeCurrent, pos);
          parent.insertBefore(voDataNodeCurrent, voDataNode);
        }
      }

    }
    parent.removeChild(voDataNode);
    reader.close();
    readerPhoenix.close();
  }
  return debug;
}



StringWriter out= new StringWriter(); 
StringReader reader2 = new StringReader(voTable);
InputSource source2 = new InputSource(reader2);
DOMParser parser = new DOMParser();
DOMParser parserPhoenix = new DOMParser();
DOMParser parser2 = new DOMParser();
VOTable_out = new String("");
Document docVO;
Document doc;
Document docPhoenix;
//try {
  parser2.parse(source2);
  docVO = parser2.getDocument();
  this.addTableHeaders(instrument_data_hessi, "hessi_");
  this.addTableHeaders(instrument_data_phoenix, "phoenix2_");
  this.addTableHeaderValue("urlPreview");
  this.addTableHeaderValue("urlPreviewThumb");
  VOTable_out = VOTable_out.concat(this.findOverlaps());
  this.write(docVO.getDocumentElement(),"");
  VOTable_out = VOTable_out.concat(out.toString());
  reader2.close();

/*}
catch (Exception e){
  e.printStackTrace();
  StackTraceElement[] stacktrace = e.getStackTrace();
  for(int i =0 ; i< stacktrace.length; i++) {
    VOTable_out = VOTable_out.concat(stacktrace[i].toString()+"\n");                       
  }
}*/

Value

Value

Wsdl

Wsdl Operation

Wsdl

Wsdl Operation

Value

Script

import java.io.StringReader;
import org.w3c.dom.*;
import org.xml.sax.InputSource;
import org.apache.xerces.parsers.DOMParser;
import java.util.Date;
import java.text.SimpleDateFormat;

private void getPositions(){
  NodeList nodesVO = docVO.getElementsByTagName("FIELD");
  for(int i=0; i< nodesVO.getLength(); i++){
     Element voFieldNode = nodesVO.item(i);
     String name = voFieldNode.getAttribute("name");
     if(name.trim().equals("time_peak")){
        posPeak = i;
     }
  }
}

private void findDates() {
  NodeList dataListVO = docVO.getElementsByTagName("TR");
  for(int i = 0; i < dataListVO.getLength(); i++) {
    NodeList voDataChilds = dataListVO.item(i).getChildNodes();
    String date=voDataChilds.item(posPeak).getFirstChild().getNodeValue().trim();
    startDate.add(date.replaceAll("..:..:..", "00:00:00"));
    endDate.add(date.replaceAll("..:..:..", "23:59:59"));

  }
}



List startDate = new ArrayList();
List endDate = new ArrayList();
debug = new String("debug\n");

StringReader reader2 = new StringReader(voTable);
InputSource source2 = new InputSource(reader2);
DOMParser parser2 = new DOMParser();
Document docVO;

int posPeak=-1;
parser2.parse(source2);
docVO = parser2.getDocument();
getPositions();
if(posPeak >= 0){
  findDates();
}
reader2.close();

Script

progress = (Integer.parseInt(position)+1)*100/positionList.size();