OrgVisualizerServerResource.java
/**
* OrgVisualizerServerResource.java This file is part of WattDepot.
*
* Copyright (C) 2014 Cam Moore
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package org.wattdepot.server.http.api;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.logging.Level;
import org.restlet.data.LocalReference;
import org.restlet.data.MediaType;
import org.restlet.data.Status;
import org.restlet.ext.freemarker.TemplateRepresentation;
import org.restlet.representation.Representation;
import org.restlet.resource.ClientResource;
import org.restlet.resource.Get;
import org.wattdepot.common.domainmodel.Depository;
import org.wattdepot.common.domainmodel.InterpolatedValue;
import org.wattdepot.common.domainmodel.Labels;
import org.wattdepot.common.domainmodel.Organization;
import org.wattdepot.common.domainmodel.Sensor;
import org.wattdepot.common.domainmodel.SensorGroup;
import org.wattdepot.common.exception.IdNotFoundException;
import org.wattdepot.common.exception.MisMatchedOwnerException;
import org.wattdepot.common.exception.NoMeasurementException;
import org.wattdepot.common.http.api.API;
/**
* OrgVisualizerServerResource - Summary Web page generator for WattDepot
* Organizations. It handles ("/wattdepot/{org-id}/visualize/").
*
* @author Cam Moore
*
*/
public class OrgVisualizerServerResource extends WattDepotServerResource {
/**
* @return The Organization summary information as an HTML Representation.
*/
@Get()
public Representation toHtml() {
getLogger().log(Level.INFO,
"GET " + API.BASE_URI + "{" + orgId + "}/" + Labels.VISUALIZE + "/");
if (isInRole(orgId) || isInRole(Organization.ADMIN_GROUP.getId())) {
Map<String, Object> dataModel = new HashMap<String, Object>();
dataModel.put("orgId", orgId);
Representation rep = null;
TemplateRepresentation template = null;
try {
// Long startTime = System.nanoTime();
depot.getOrganization(orgId, true);
List<Depository> depos = depot.getDepositories(orgId, false);
List<Sensor> sensors = depot.getSensors(orgId, false);
List<SensorGroup> sensorGroups = depot.getSensorGroups(orgId, false);
// Long endTime = System.nanoTime();
// Long diff = endTime - startTime;
// getLogger().log(Level.INFO,
// "getDepositories took " + (diff / 1E9) + " seconds");
Map<String, List<Sensor>> depoSensors = new HashMap<String, List<Sensor>>();
Map<String, Map<String, List<Date>>> depotSensorInfo = new HashMap<String, Map<String, List<Date>>>();
for (Depository d : depos) {
Map<String, List<Date>> sensorInfo = new HashMap<String, List<Date>>();
depotSensorInfo.put(d.getId(), sensorInfo);
List<Sensor> sensorList = new ArrayList<Sensor>();
depoSensors.put(d.getId(), sensorList);
long startTime = System.nanoTime();
for (String sensorId : depot.listSensors(d.getId(), orgId, false)) {
// long startTime2 = System.nanoTime();
Sensor s = depot.getSensor(sensorId, orgId, false);
// long endTime2 = System.nanoTime();
// long diff2 = endTime2 - startTime2;
// getLogger().log(Level.SEVERE, "getSensor(" + sensorId + ") took " + (diff2 / 1E9) + " seconds");
sensorList.add(s);
try {
// startTime2 = System.nanoTime();
InterpolatedValue earliest = depot.getEarliestMeasuredValue(
d.getId(), orgId, sensorId, false);
InterpolatedValue latest = depot.getLatestMeasuredValue(
d.getId(), orgId, sensorId, false);
List<Date> info = new ArrayList<Date>();
info.add(earliest.getStart());
info.add(latest.getEnd());
sensorInfo.put(sensorId, info);
// endTime2 = System.nanoTime();
// diff2 = endTime2 - startTime2;
// getLogger().log(Level.SEVERE, "Sensor earliest and latest for " + sensorId + " took " + (diff2 / 1E9) + " seconds");
}
catch (NoMeasurementException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
long endTime = System.nanoTime();
long diff = endTime - startTime;
getLogger().log(Level.SEVERE, "Depository " + d.getName() + ": Getting Sensor info took " + (diff / 1E9) + " seconds for " + sensorList.size() + " sensors.");
startTime = System.nanoTime();
int groupCount = 0;
for (String groupId : depot.getSensorGroupIds(orgId, false)) {
groupCount++;
SensorGroup group = depot.getSensorGroup(groupId, orgId, false);
List<Date> info = new ArrayList<Date>();
// InterpolatedValue earliest = null;
Date earliestDate = null;
// InterpolatedValue latest = null;
Date latestDate = null;
for (String sensorId : group.getSensors()) {
List<Date> sensorDates = sensorInfo.get(sensorId);
if (sensorDates != null) {
Date temp = sensorDates.get(0);
if (earliestDate == null) {
earliestDate = temp;
}
else if (temp.before(earliestDate)) {
earliestDate = temp;
}
temp = sensorDates.get(1);
if (latestDate == null) {
latestDate = temp;
}
else if (temp.after(latestDate)) {
latestDate = temp;
}
}
// try {
// InterpolatedValue temp = depot.getEarliestMeasuredValue(
// d.getId(), orgId, sensorId, false);
// if (temp != null) {
// if (earliest == null) {
// earliest = temp;
// }
// else if (earliest.getDate().after(temp.getDate())) {
// earliest = temp;
// }
// }
// temp = depot.getLatestMeasuredValue(d.getId(), orgId, sensorId,
// false);
// if (temp != null) {
// if (latest == null) {
// latest = temp;
// }
// else if (latest.getDate().before(temp.getDate())) {
// latest = temp;
// }
// }
// }
// catch (NoMeasurementException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
}
if (earliestDate != null) {
info.add(earliestDate);
}
else {
// CAM what is a value we can use for no data?
info.add(new Date(0l));
}
if (latestDate != null) {
info.add(latestDate);
}
else {
// CAM what is a value we can use for no data?
info.add(new Date(0l));
}
// if (earliest != null) {
// info.add(earliest.getDate());
// }
// else {
// // CAM what is a value we can use for no data?
// info.add(new Date(0l));
// }
// if (latest != null) {
// info.add(latest.getDate());
// }
// else {
// // CAM what is a value we can use for no data?
// info.add(new Date(0l));
// }
sensorInfo.put(groupId, info);
}
endTime = System.nanoTime();
diff = endTime - startTime;
getLogger().log(Level.SEVERE, "Depository " + d.getName() + ": Getting SensorGroup info took " + (diff / 1E9) + " seconds for " + groupCount + " groups.");
}
dataModel.put("depositories", depos);
dataModel.put("sensors", sensors);
dataModel.put("sensorgroups", sensorGroups);
dataModel.put("depoSensors", depoSensors);
dataModel.put("depotSensorInfo", depotSensorInfo);
rep = new ClientResource(LocalReference.createClapReference(getClass()
.getPackage()) + "/Visualizer.ftl").get();
}
catch (IdNotFoundException e) {
e.printStackTrace();
setStatus(Status.CLIENT_ERROR_BAD_REQUEST, e.getMessage());
return null;
}
catch (MisMatchedOwnerException e) {
e.printStackTrace();
setStatus(Status.CLIENT_ERROR_BAD_REQUEST, e.getMessage());
return null;
}
template = new TemplateRepresentation(rep, dataModel, MediaType.TEXT_HTML);
return template;
}
return null;
}
}