raimund@2276: package de.intevation.flys.artifacts.services; raimund@2276: raimund@2276: import java.util.List; raimund@2276: import java.util.Date; raimund@2276: import java.util.Calendar; raimund@2276: import java.util.GregorianCalendar; raimund@2276: raimund@2276: import org.apache.log4j.Logger; raimund@2276: raimund@2276: import org.w3c.dom.Document; raimund@2276: import org.w3c.dom.Element; raimund@2276: raimund@2276: import de.intevation.artifacts.CallMeta; raimund@2276: import de.intevation.artifacts.GlobalContext; raimund@2276: raimund@2276: import de.intevation.artifacts.common.ArtifactNamespaceContext; raimund@2276: import de.intevation.artifacts.common.utils.XMLUtils; raimund@2276: raimund@2276: import de.intevation.flys.model.Gauge; raimund@2276: import de.intevation.flys.model.DischargeTable; raimund@2276: import de.intevation.flys.model.TimeInterval; raimund@2276: raimund@2276: /** raimund@2276: * This service provides information about discharges at a defined gauge. raimund@2276: * raimund@2276: * @author Raimund Renkert raimund@2276: */ raimund@2276: public class DischargeInfoService extends FLYSService { raimund@2276: raimund@2276: /** The logger used in this service. */ raimund@2276: private static Logger logger = Logger.getLogger(DischargeInfoService.class); raimund@2276: raimund@2276: public static final String GAUGE_XPATH = "/art:gauge/text()"; raimund@2276: raimund@2276: public DischargeInfoService() { raimund@2276: } raimund@2276: raimund@2276: raimund@2276: @Override raimund@2276: public Document doProcess( raimund@2276: Document data, raimund@2276: GlobalContext globalContext, raimund@2276: CallMeta callMeta raimund@2276: ) { raimund@2276: logger.debug("DischargeInfoService.process"); ingo@4115: logger.debug(XMLUtils.toString(data)); raimund@2276: raimund@2276: String gaugeNumber = XMLUtils.xpathString( raimund@2276: data, GAUGE_XPATH, ArtifactNamespaceContext.INSTANCE); raimund@2276: raimund@2276: if(gaugeNumber == null || raimund@2276: (gaugeNumber = gaugeNumber.trim()).length() == 0) { raimund@2276: logger.warn("No gauge specified. Cannot return discharge info."); raimund@2276: return XMLUtils.newDocument(); raimund@2276: } raimund@2276: raimund@2276: logger.debug("Getting discharge for gauge: " + gaugeNumber); raimund@2276: raimund@2276: long gn; raimund@2276: try { raimund@2276: gn = Long.parseLong(gaugeNumber); raimund@2276: } raimund@2276: catch (NumberFormatException nfe) { raimund@2276: logger.warn("Invalid gauge number. Cannot return discharg info."); raimund@2276: return XMLUtils.newDocument(); raimund@2276: } raimund@2276: raimund@2276: Gauge gauge = Gauge.getGaugeByOfficialNumber(gn); raimund@2276: raimund@2276: logger.debug("Found gauge: " + gauge.getName()); raimund@2276: raimund@2276: return buildDocument(gauge); raimund@2276: } raimund@2276: raimund@2276: raimund@2276: protected Document buildDocument(Gauge gauge) { raimund@2276: Document result = XMLUtils.newDocument(); raimund@2276: raimund@2276: List tables =gauge.getDischargeTables(); raimund@2276: raimund@2276: Element all = result.createElement("discharges"); raimund@2276: for (DischargeTable dt: tables) { ingo@2598: if (dt.getKind() == Gauge.MASTER_DISCHARGE_TABLE) { ingo@2598: continue; ingo@2598: } ingo@2598: raimund@2276: Element discharge = result.createElement("discharge"); raimund@2276: discharge.setAttribute("description", dt.getDescription()); raimund@2276: raimund@2276: // Get time interval. raimund@2276: TimeInterval ti = dt.getTimeInterval(); ingo@2598: ingo@2598: if (ti == null) { ingo@2598: logger.warn("DischargeTable has no TimeInterval set!"); ingo@2598: continue; ingo@2598: } ingo@2598: raimund@2276: Date startTime = ti.getStartTime(); raimund@2276: Date stopTime = ti.getStopTime(); raimund@2276: raimund@2276: if (startTime != null) { ingo@4115: discharge.setAttribute("start", String.valueOf(startTime.getTime())); raimund@2276: } raimund@2276: else { ingo@4115: discharge.setAttribute("start", "-1"); raimund@2276: } ingo@4115: raimund@2276: if (stopTime != null) { ingo@4115: discharge.setAttribute("end", String.valueOf(stopTime.getTime())); raimund@2276: } raimund@2276: else { ingo@4115: discharge.setAttribute("end", "-1"); raimund@2276: } raimund@2276: raimund@2276: all.appendChild(discharge); raimund@2276: } raimund@2276: result.appendChild(all); raimund@2276: return result; raimund@2276: } raimund@2276: } sascha@3083: // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :