Mercurial > dive4elements > river
view flys-artifacts/src/main/java/de/intevation/flys/artifacts/services/MetaDataService.java @ 1077:3067e700fc13
Minor cosmetics and docs.
flys-artifacts/trunk@2574 c6561f87-3c4e-4783-a992-168aeb5c3f6f
author | Felix Wolfsteller <felix.wolfsteller@intevation.de> |
---|---|
date | Thu, 25 Aug 2011 10:34:20 +0000 |
parents | 3f3988bb6284 |
children | f84ddc205c8b |
line wrap: on
line source
package de.intevation.flys.artifacts.services; import org.w3c.dom.Document; import org.apache.log4j.Logger; import java.util.Map; import java.util.HashMap; import de.intevation.artifacts.Artifact; import de.intevation.artifacts.CallMeta; import de.intevation.artifacts.GlobalContext; import de.intevation.artifacts.ArtifactDatabase; import de.intevation.artifacts.ArtifactDatabaseException; import de.intevation.artifactdatabase.DefaultService; import de.intevation.artifacts.common.utils.XMLUtils; import de.intevation.artifacts.common.utils.StringUtils; import de.intevation.artifacts.common.ArtifactNamespaceContext; import de.intevation.flys.artifacts.datacage.Recommendations; import de.intevation.flys.artifacts.FLYSArtifact; public class MetaDataService extends DefaultService { private static Logger log = Logger.getLogger(MetaDataService.class); public static final String XPATH_ARTIFACT_ID = "/art:meta/art:artifact-id/@value"; public static final String XPATH_USER_ID = "/art:meta/art:user-id/@value"; public static final String XPATH_OUTS = "/art:meta/art:outs/@value"; public static final String XPATH_PARAMETERS = "/art:meta/art:parameters/@value"; /** The global context key of the artifact database. */ public static final String ARTIFACT_DATA_BASE_KEY = "global.artifact.database"; public MetaDataService() { } @Override public Document process( Document data, GlobalContext globalContext, CallMeta callMeta ) { log.debug("MetaDataService.process"); String artifactId = XMLUtils.xpathString( data, XPATH_ARTIFACT_ID, ArtifactNamespaceContext.INSTANCE); if (artifactId != null && (artifactId = artifactId.trim()).length() == 0) { artifactId = null; } String userId = XMLUtils.xpathString( data, XPATH_USER_ID, ArtifactNamespaceContext.INSTANCE); if (userId != null && (userId = userId.trim()).length() == 0) { userId = null; } String outs = XMLUtils.xpathString( data, XPATH_OUTS, ArtifactNamespaceContext.INSTANCE); String parameters = XMLUtils.xpathString( data, XPATH_PARAMETERS, ArtifactNamespaceContext.INSTANCE); return doService( artifactId, userId, outs, parameters, globalContext); } protected static Map<String, Object> splitParameters( String parameters, Map<String, Object> data ) { if (parameters != null) { String [] parts = parameters.split("\\s*;\\s*"); for (String part: parts) { String [] kv = part.split("\\s*:\\s*"); if (kv.length < 2 || (kv[0] = kv[0].trim()).length() == 0) { continue; } String [] values = kv[1].split("\\s*,\\s*"); data.put(kv[0], values.length == 1 ? values[0] : values); } } return data; } protected Document doService( String artifactId, String userId, String outsString, String parameters, GlobalContext globalContext ) { Document result = XMLUtils.newDocument(); FLYSArtifact flysArtifact; if (log.isDebugEnabled()) { log.debug("artifact : " + artifactId); log.debug("user : " + userId); log.debug("outs : " + outsString); log.debug("parameters: " + parameters); } if (userId != null && !StringUtils.checkUUID(userId)) { log.warn("'" + userId + "' is not a UUID"); return result; } if (artifactId != null) { if (!StringUtils.checkUUID(artifactId)) { log.warn("'" + artifactId + "' is not a UUID"); return result; } Object dbObject = (ArtifactDatabase)globalContext.get(ARTIFACT_DATA_BASE_KEY); if (!(dbObject instanceof ArtifactDatabase)) { log.error("Cannot find artifact database"); return result; } ArtifactDatabase db = (ArtifactDatabase)dbObject; Artifact artifact; try { artifact = db.getRawArtifact(artifactId); } catch (ArtifactDatabaseException adbe) { log.warn("fetching artifact failed", adbe); return result; } if (!(artifact instanceof FLYSArtifact)) { log.warn("artifact is not a FLYS artifact."); return result; } flysArtifact = (FLYSArtifact)artifact; } else { flysArtifact = null; } Map<String, Object> data = splitParameters( parameters, new HashMap<String, Object>()); String [] outs = outsString == null ? new String [0] : outsString.split("\\s*,\\s*"); Recommendations rec = Recommendations.getInstance(); rec.recommend( flysArtifact, userId, outs, data, result); return result; } } // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :