X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=server%2Fcompbio%2Fcontrollers%2FJobController.java;fp=server%2Fcompbio%2Fcontrollers%2FJobController.java;h=9fdc128c9624fa5a77efcf4412a24c4b933507a3;hb=2d0c3af83988ff2a68d789efb4ccf2ff3c65a88a;hp=9987bd5e5d033ec0c13ce1ac4d734805a168f0d6;hpb=7b779a07bc1815d71534d4d9fb4d5d59eff912ff;p=proteocache.git diff --git a/server/compbio/controllers/JobController.java b/server/compbio/controllers/JobController.java index 9987bd5..9fdc128 100644 --- a/server/compbio/controllers/JobController.java +++ b/server/compbio/controllers/JobController.java @@ -16,7 +16,14 @@ import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RequestParam; import compbio.statistic.CassandraRequester; +import compbio.beans.ExecutionTimeBean; +import compbio.beans.Total; +import compbio.beans.TotalExecutionTime; +import compbio.beans.TotalJobsStatisticBean; import compbio.cassandra.DataBase; +import compbio.cassandra.DateFormatter; +import compbio.cassandra.readers.CassandraReader; +import compbio.cassandra.readers.ExecutionTimeReader; import compbio.cassandra.readers.JobReader; import compbio.engine.archive.ArchivedJob; @@ -81,36 +88,51 @@ public class JobController extends BasicController { @RequestParam(value = "option", required = false) String option, Map model) { model.put("username", getPrincipalName()); final long startTime = System.currentTimeMillis(); - - CassandraRequester sp = new CassandraRequester(); + Calendar loccal = Calendar.getInstance(); + ExecutionTimeReader reader = new ExecutionTimeReader(); if (option.equals("AllDates,off")) { - Calendar cal = Calendar.getInstance(); - date1 = DateFormatYYMMDD(sp.earliestDate()); - date2 = cal.get(Calendar.YEAR) + "/" + (cal.get(Calendar.MONTH) + 1) + "/" + cal.get(Calendar.DAY_OF_MONTH); + date1 = theEaerlistDate; + date2 = theCurrentDate; + } + + // dates in string format + String trimmeddate1 = date1.replaceAll("\\s", ""); + String trimmeddate2 = date2.replaceAll("\\s", ""); + // dates in long format + long longDate1 = DateFormatter.DateParsing(date1, formaterYYMMDD); + long longDate2 = DateFormatter.DateParsing(date2, formaterYYMMDD); + String error = DateChecking(trimmeddate1, trimmeddate2, longDate1, longDate2); + if (error != null) { + model.put("error", error); + model.put("date1", date1); + model.put("date2", date2); + return "query/JobTimeExecution"; } + + if (longDate1 < CassandraReader.earliestDate()) + longDate1 = CassandraReader.earliestDate(); + if (longDate2 > loccal.getTimeInMillis()) + longDate2 = loccal.getTimeInMillis(); + + date1 = DateFormatter.DateLongToString(longDate1, formaterYYMMDD); + date2 = DateFormatter.DateLongToString(longDate2, formaterYYMMDD); model.put("date1", date1); model.put("date2", date2); model.put("option", option); - List res = sp.extractExecutionTime(date1, date2); + ExecutionTimeBean res = reader.query(longDate1, longDate2);; model.put("result", res); + Map results = res.getDateTotal(); String csvline = ""; - if (0 < res.size()) { + if (0 < res.getDateTotal().size()) { csvline = "\'Date\',\'Total\',\'0-30 sec\',\'30-60 sec\',\'1-2 min\',\'2-10 min\',\'more 10 min\'%0A"; - for (DataBase entry : res) { - List counts = entry.getTimeRez(); - int total = 0; - for (int i = 0; i < counts.size(); ++i) { - total += counts.get(i); - } - csvline += "\'" + entry.getDate() + "\',\'" + total; - for (int i = 0; i < counts.size(); ++i) { - csvline += "\',\'" + counts.get(i); - } - csvline += "\'%0A"; + for (Map.Entry entry : results.entrySet()) { + csvline += "\'" + entry.getKey() + "\',\'" + entry.getValue().getTotal() + "\',\'" + entry.getValue().getTotal0_30s() + "\',\'" + + entry.getValue().getTotal30_60s() + "\',\'" + entry.getValue().getTotal1_2m() + "\',\'" + + entry.getValue().getTotal2_10m() + "\',\'" + entry.getValue().getTotal10m() + "\'%0A"; } } model.put("csvfile", csvline); - model.put("ndays", res.size() - 1); + model.put("ndays", res.getDateTotal().size() - 1); final long endTime = System.currentTimeMillis(); model.put("timeExecution", (endTime - startTime)); return "/reports/TimeExecution";