X-Git-Url: http://source.jalview.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=server%2Fcompbio%2Fcontrollers%2FDailyStatisticsController.java;h=403c220807c7f599aa00173695ae733c377d3bd4;hb=6823d2f36ff55b7ab11d674e3fe4d04dc57d6bbf;hp=a9b51f112e1253ee6f070f7603ad775d3fa85565;hpb=6ccd0c1414766d7ffa84f6594a9a14d50c5053b8;p=proteocache.git diff --git a/server/compbio/controllers/DailyStatisticsController.java b/server/compbio/controllers/DailyStatisticsController.java index a9b51f1..403c220 100644 --- a/server/compbio/controllers/DailyStatisticsController.java +++ b/server/compbio/controllers/DailyStatisticsController.java @@ -11,12 +11,14 @@ import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RequestParam; import compbio.engine.JobStatus; -import compbio.cassandra.CassandraReader; -import compbio.cassandra.DateBean; +import compbio.beans.DateBean; +import compbio.beans.TotalJobsStatisticBean; import compbio.cassandra.DateFormatter; -import compbio.cassandra.Total; -import compbio.cassandra.TotalJobsStatisticBean; -import compbio.statistic.CassandraRequester; + +import compbio.beans.Total; +import compbio.cassandra.readers.CassandraReader; +import compbio.cassandra.readers.DailyStatisticsReader; + /** * @author Alexander Sherstnev @@ -71,7 +73,7 @@ public class DailyStatisticsController extends BasicController { model.put("username", getPrincipalName()); Calendar loccal = Calendar.getInstance(); final long startTime = System.currentTimeMillis(); - CassandraRequester cr = new CassandraRequester(); + DailyStatisticsReader reader = new DailyStatisticsReader(); if (option.equals("AllDates,off")) { date1 = theEaerlistDate; date2 = theCurrentDate; @@ -100,7 +102,7 @@ public class DailyStatisticsController extends BasicController { date2 = DateFormatter.DateLongToString(longDate2, formaterYYMMDD); model.put("date1", date1); model.put("date2", date2); - TotalJobsStatisticBean res = cr.countJobs(date1, date2); + TotalJobsStatisticBean res = reader.query(longDate1, longDate2); model.put("result", res); Map results = res.getDateTotal(); String csvline = "\'Date\',\'Total\',\'OK\',\'Stopped\',\'Error\',\'Timeout\'%0A"; @@ -135,8 +137,9 @@ public class DailyStatisticsController extends BasicController { final long startTime = System.currentTimeMillis(); String realdate; + long thetime = 0; try { - long thetime = formaterYYMMDD.parse(date).getTime(); + thetime = formaterYYMMDD.parse(date).getTime(); if (thetime < 0) { realdate = date; } else { @@ -144,15 +147,16 @@ public class DailyStatisticsController extends BasicController { } } catch (ParseException e) { realdate = date; + thetime = formaterDDMMYY.parse(realdate).getTime(); } - + if (null == JobStatus.getJobStatus(status)) { return "support/Notimplemented"; } - CassandraRequester cr = new CassandraRequester(); + DailyStatisticsReader reader = new DailyStatisticsReader(); // IMPORTANT: input should be suppied in the format: DD/MM/YYYY - DateBean r = cr.readJobByDay(realdate, JobStatus.getJobStatus(status)); + DateBean r = reader.readJobByDay(thetime, realdate, JobStatus.getJobStatus(status)); model.put("results", r); if (r != null) model.put("njobs", r.getJobidAndSeq().size());