Add servlets for queries with IP

[proteocache.git] / server / compbio / controllers / IPStatisticsController.java

diff --git a/server/compbio/controllers/IPStatisticsController.java b/server/compbio/controllers/IPStatisticsController.java
new file mode 100644 (file)
index 0000000..75615f9
--- /dev/null
+++ b/server/compbio/controllers/IPStatisticsController.java
@@ -0,0 +1,62 @@
+package compbio.controllers;
+
+import java.util.List;
+import java.util.Map;
+
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import compbio.cassandra.DataBase;
+import compbio.statistic.CassandraRequester;
+
+/**
+ * @author Alexander Sherstnev
+ * @author Natasha Sherstneva
+ */
+@Controller
+public class IPStatisticsController {
+
+       @RequestMapping(value = "/ip/stat", method = RequestMethod.GET)
+       public String initStatisticsForm(Map<String, Object> model) {
+               return "queryIPStatistics";
+       }
+
+       @RequestMapping(value = "/ip", method = RequestMethod.GET)
+       public String initOneIPForm(Map<String, Object> model) {
+               return "queryIP";
+       }
+       
+       @RequestMapping(value = "/ip/stat/querycounter", method = RequestMethod.GET)
+       public String findIPwithCounter(@RequestParam("JobCounter") int counter, Map<String, Object> model) {
+               final long startTime = System.currentTimeMillis();
+               CassandraRequester cr = new CassandraRequester();
+               List<DataBase> r = cr.readIpByCounter(counter);
+               model.put("results", r);
+               model.put("njobs", 0);
+               if (null != r) {
+                       model.put("njobs", r.size());
+               }
+               final long endTime = System.currentTimeMillis();
+               model.put("timeExecution", (endTime - startTime));
+               model.put("counter", counter);
+               return "reportIPstatistics";
+       }
+
+       @RequestMapping(value = "/ip/query", method = RequestMethod.GET)
+       public String findIP(@RequestParam("ip") String ip, Map<String, Object> model) {
+               final long startTime = System.currentTimeMillis();
+               CassandraRequester cr = new CassandraRequester();
+               List<DataBase> r = cr.readIp(ip);
+               model.put("results", r);
+               model.put("njobs", 0);
+               if (null != r) {
+                       model.put("njobs", r.size());
+               }
+               final long endTime = System.currentTimeMillis();
+               model.put("timeExecution", (endTime - startTime));
+               model.put("ip", ip);
+               return "reportIP";
+       }
+}