--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/software/mpdl-services/mpiwg-mpdl-cms-web/src/de/mpg/mpiwg/berlin/mpdl/servlets/cms/GetDocumentJobs.java	Tue Nov 27 12:35:19 2012 +0100
@@ -0,0 +1,244 @@
+package de.mpg.mpiwg.berlin.mpdl.servlets.cms;
+
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.util.ArrayList;
+import java.util.Date;
+
+import javax.servlet.ServletConfig;
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import de.mpg.mpiwg.berlin.mpdl.cms.scheduler.CmsChainScheduler;
+import de.mpg.mpiwg.berlin.mpdl.cms.scheduler.CmsDocOperation;
+
+public class GetDocumentJobs extends HttpServlet {
+  private static final long serialVersionUID = 1L;
+  public GetDocumentJobs() {
+    super();
+  }
+
+  public void init(ServletConfig config) throws ServletException  {
+    super.init(config);
+  }
+
+  protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+    request.setCharacterEncoding("utf-8");
+    response.setCharacterEncoding("utf-8");
+    response.setContentType("text/xml");
+    String jobIdStr = request.getParameter("id");
+    String outputFormat = request.getParameter("outputFormat");
+    if (outputFormat == null)
+      outputFormat = "xml";
+    try {
+      boolean getAllJobs = false;
+      if (jobIdStr == null)
+        getAllJobs = true;
+      CmsChainScheduler scheduler = CmsChainScheduler.getInstance();
+      ArrayList<CmsDocOperation> docOperations = new ArrayList<CmsDocOperation>();
+      if (getAllJobs) {
+        docOperations = scheduler.getDocOperations();
+      } else {
+        int jobId = Integer.parseInt(jobIdStr);
+        CmsDocOperation docOperation = scheduler.getDocOperation(jobId);
+        if (docOperation != null)
+          docOperations.add(docOperation);
+      }
+      PrintWriter out = response.getWriter();
+      String resultStr = "";
+      if (outputFormat.equals("xml")) {
+        response.setContentType("text/xml");
+        resultStr = createXmlString(docOperations);
+      } else if (outputFormat.equals("html")) { 
+        response.setContentType("text/html");
+        resultStr = createHtmlString(docOperations);
+      } else if (outputFormat.equals("error")) { 
+        response.setContentType("text/html");
+        resultStr = createErrorString(docOperations);
+      }
+      out.print(resultStr);
+      out.close();
+    } catch (Exception e) {
+      throw new ServletException(e);
+    }
+  }
+
+  String createXmlString(ArrayList<CmsDocOperation> docOperations) {
+    StringBuilder result = new StringBuilder();
+    if (docOperations != null && ! docOperations.isEmpty()) {
+      result.append("<docJobs>");
+      for (int i=0; i<docOperations.size(); i++) {
+        CmsDocOperation docOperation = docOperations.get(i);
+        result.append("<job>");
+        int jobId = docOperation.getOrderId();
+        result.append("<id>" + jobId + "</id>");
+        result.append("<name>" + docOperation.getName() + "</name>");
+        result.append("<status>");
+        Date start = docOperation.getStart();
+        String startStr = "No start time available because job is scheduled into server queue where other jobs have been started earlier";
+        if (start != null)
+          startStr = start.toString();
+        result.append("<started>" + startStr + "</started>");
+        Date end = docOperation.getEnd();
+        String endStr = "No end time available because job is not finished yet";
+        if (end != null)
+          endStr = end.toString();
+        result.append("<finished>" + endStr + "</finished>");
+        String status = docOperation.getStatus();
+        result.append("<description>" + status + "</description>");
+        String errorMessage = docOperation.getErrorMessage();
+        if (errorMessage == null)
+          errorMessage = "no error";
+        result.append("<error>" + errorMessage + "</error>");
+        result.append("</status>");
+        if (docOperation.getName().equals("delete")) {
+          result.append("<destination>");
+          result.append("<docId>" + docOperation.getDocIdentifier() + "</docId>");
+          result.append("</destination>");
+        } else if (docOperation.getName().equals("create")) {
+          result.append("<source>");
+          result.append("<url>" + docOperation.getSrcUrl() + "</url>");
+          result.append("<uploadFileName>" + docOperation.getUploadFileName() + "</uploadFileName>");
+          result.append("</source>");
+          result.append("<destination>");
+          result.append("<docId>" + docOperation.getDocIdentifier() + "</docId>");
+          result.append("</destination>");
+        }
+        String desc = "Document operations are maintained on server asychronously. Each operation is scheduled into a server job queue " + 
+            "and is executed when all previous started jobs in the queue are worked off. Each operation needs some execution time dependent " + 
+            "on the size and the number of pages of the document, the speed of the network connection and the performance of the " +
+            "server.";
+        result.append("<description>" + desc + "</description>");
+        result.append("</job>");
+      }
+      result.append("</docJobs>");
+    } else {
+      String message = "there are no scheduled jobs (neither finished, queued or executed)";
+      result.append("<message>" + message + "</message>");
+    }
+    return result.toString();
+  }
+  
+  String createHtmlString(ArrayList<CmsDocOperation> docOperations) {
+    // TODO all
+    StringBuilder result = new StringBuilder();
+    result.append("<html>");
+    result.append("<head>");
+    result.append("<title>" + "Document operation status" + "</title>");
+    result.append("</head>");
+    result.append("<body>");
+    result.append("<table>");
+    result.append("<h1>" + "Document operation status" + "</h1>");
+    if (docOperations != null && ! docOperations.isEmpty()) {
+      for (int i=0; i<docOperations.size(); i++) {
+        result.append("<tr>");
+        result.append("<td>");
+        CmsDocOperation docOperation = docOperations.get(i);
+        result.append("<b>Operation: </b>" + docOperation.getName());
+        int jobId = docOperation.getOrderId();
+        result.append("<p/>");
+        result.append("<b>Job id: </b>" + jobId);
+        result.append("<p/>");
+        result.append("<b>Job status: </b>");
+        result.append("<ul>");
+        Date start = docOperation.getStart();
+        String startStr = "No start time available because job is scheduled into server queue where other jobs have been started earlier";
+        if (start != null)
+          startStr = start.toString();
+        result.append("<li>");
+        result.append("<b>Started: </b>");
+        result.append("<started>" + startStr + "</started>");
+        result.append("</li>");
+        Date end = docOperation.getEnd();
+        String endStr = "No end time available because job is not finished yet";
+        if (end != null)
+          endStr = end.toString();
+        result.append("<li>");
+        result.append("<b>Finished: </b>");
+        result.append("<finished>" + endStr + "</finished>");
+        result.append("</li>");
+        String status = docOperation.getStatus();
+        result.append("<li>");
+        result.append("<b>Description: </b>");
+        result.append("<description>" + status + "</description>");
+        result.append("</li>");
+        String errorMessage = docOperation.getErrorMessage();
+        result.append("<li>");
+        if (errorMessage != null) {
+          result.append("<font color=\"#FF0000\"><b>Error: </b></font>");
+          result.append("<error>" + errorMessage + "</error>");
+        } else { 
+          result.append("<b>Error: </b>");
+          result.append("<error>" + "no error" + "</error>");
+        }
+        result.append("</li>");
+        result.append("</ul>");
+        if (docOperation.getName().equals("delete")) {
+          result.append("<b>Destination</b>");
+          result.append("<ul>");
+          result.append("<li>");
+          result.append("<b>Document identifier: </b>");
+          result.append("<docId>" + docOperation.getDocIdentifier() + "</docId>");
+          result.append("</li>");
+          result.append("</ul>");
+        } else if (docOperation.getName().equals("create")) {
+          result.append("<b>Source</b>");
+          result.append("<ul>");
+          result.append("<li>");
+          result.append("<url>" + docOperation.getSrcUrl() + "</url>");
+          String uploadFileName = docOperation.getUploadFileName();
+          if (uploadFileName != null) {
+            result.append("<li>");
+            result.append("<uploadFileName>" + uploadFileName + "</uploadFileName>");
+            result.append("</li>");
+          }
+          result.append("</li>");
+          result.append("</ul>");
+          result.append("<b>Destination</b>");
+          result.append("<ul>");
+          result.append("<li>");
+          result.append("<b>Document identifier: </b>");
+          result.append("<docId>" + docOperation.getDocIdentifier() + "</docId>");
+          result.append("</li>");
+          result.append("</ul>");
+        }
+        String desc = "Document operations are maintained on server asychronously. Each operation is scheduled into a server job queue " + 
+            "and is executed when all previous started jobs in the queue are worked off. Each operation needs some execution time dependent " + 
+            "on the size and the number of pages of the document, the speed of the network connection and the performance of the " +
+            "server."; 
+        result.append("<b>Description: </b>" + desc);
+        result.append("<p/>");
+        result.append("<hr/>");
+      }
+      result.append("</td>");
+      result.append("</tr>");
+    } else {
+      String message = "there are no scheduled jobs (neither finished, queued or executed)";
+      result.append("<message>" + message + "</message>");
+    }
+    result.append("</table>");
+    result.append("</body>");
+    result.append("</html>");
+    return result.toString();
+  }
+  
+  String createErrorString(ArrayList<CmsDocOperation> docOperations) {
+    String error = "";
+    if (docOperations != null && ! docOperations.isEmpty()) {
+      for (int i=0; i<docOperations.size(); i++) {
+        CmsDocOperation docOperation = docOperations.get(i);
+        String errorMessage = docOperation.getErrorMessage();
+        if (errorMessage != null)
+          error = errorMessage;
+      }
+    } 
+    return error;
+  }
+
+  protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+    doGet(request, response);
+  }  
+
+}