Changeset 19591

Timestamp:

01/31/12 16:22:27 (4 months ago)

Author:

sys

Message:

WspSrcSender : format de sortie XML.

File:

• trunk/Jav_Moz_Wsp/src/eu/scenari/uimoz/services/SvcWspSrcSender.java (modified) (5 diffs)

trunk/Jav_Moz_Wsp/src/eu/scenari/uimoz/services/SvcWspSrcSender.java

@@ -51 +51 @@
 import com.scenari.m.co.univers.IWUnivers;
 import com.scenari.s.co.transform.HTransformParams;
+import com.scenari.serializer.simple.IXmlWriter;
 import com.scenari.src.ISrcNode;
 import com.scenari.src.feature.alternateurl.SrcFeatureAlternateUrl;
@@ -61 +62 @@
 import com.scenari.src.feature.uris.SrcFeatureUris;
 
+import eu.scenari.commons.log.ILogMsg.LogType;
 import eu.scenari.commons.log.LogMgr;
-import eu.scenari.commons.log.ILogMsg.LogType;
 import eu.scenari.commons.mime.MimeMgr;
 import eu.scenari.commons.stream.bytes.IBlob;
@@ -80 +81 @@
  * Un paramètre "format" spécifie le type de retour.
  * 
- * <h3>Format : JSON (par défaut)</h3>
+ * <h3>Format : JSON (par défaut) ou XML</h3>
  * Si plusieurs refUris sont requêtés, l'objet Json racine est un tableau avec autant d'entrées que de refUris 
  * demandées et dans le même ordre.
@@ -180 +181 @@
                                 } finally {
                                         vWriter.close();
+                                }
+                        } else if (vFormat.equals("XML")) {
+                                //Envoi d'un XML
+                                int vDepth = 0;
+                                String vDepthStr = pReq.getParameter("depth");
+                                if (vDepthStr != null && vDepthStr.length() > 0) vDepth = Integer.parseInt(vDepthStr);
+                                String vTargetsStr = pReq.getParameter("targets");
+                                String[] vTargets = null;
+                                if (vTargetsStr != null && vTargetsStr.length() > 0) {
+                                        vTargets = sTargetSeparator.split(vTargetsStr, 0);
+                                }
+                                IXmlWriter vXmlWriter = hGetXmlWriterUTF8(pResp, true);
+                                try {
+                                        //Construction des Fields à publier
+                                        String vFieldKeys = pReq.getParameter("fields");
+                                        if (vFieldKeys == null) vFieldKeys = sDefaultFieldKeys;
+                                        IFieldsCollector vFields = FieldsCollectorBuilder.newFieldsCollector(vFieldKeys);
+                                        if (vSrcNode == null) {
+                                                List<ISrcNode> vSrcNodes = vDialog.getSrcNodes();
+                                                if (vSrcNodes == null) {
+                                                        sendError500(null, pResp);
+                                                        return;
+                                                }
+                                                List<String> vRefUris = vDialog.getParamRefUris();
+                                                vXmlWriter.writeOpenTag("list");
+                                                for (int i = 0; i < vRefUris.size(); i++) {
+                                                        vSrcNode = vSrcNodes.get(i);
+                                                        if (vSrcNode != null) {
+                                                                vFields.resetDatas();
+                                                                SrcFeatureFields.fillFields(vSrcNode, vFields);
+                                                                writeFields(vSrcNode, vFields, vXmlWriter, vDepth, vTargets);
+                                                        } else {
+                                                                vXmlWriter.writeEmptyTag("entry");
+                                                        }
+                                                }
+                                                vXmlWriter.writeCloseTag("list");
+                                        } else {
+                                                SrcFeatureFields.fillFields(vSrcNode, vFields);
+                                                writeFields(vSrcNode, vFields, vXmlWriter, vDepth, vTargets);
+                                        }
+                                } finally {
+                                        vXmlWriter.close();
                                 }
                         } else if (vFormat.equals("stream") || vFormat.equals("download")) {
@@ -357 +400 @@
         }
 
+        protected void writeFields(ISrcNode pNode, IFieldsCollector pFields, IXmlWriter pWriter, int pDepth, String[] pUriTargets) throws Exception {
+                //Serialisation Json
+                pWriter.writeStartTag("entry");
+                pFields.startIterate();
+                for (String vKey = pFields.nextDataKey(); vKey != null; vKey = pFields.nextDataKey()) {
+                        Object vValue = pFields.getData(vKey);
+                        if (vValue != null) {
+                                pWriter.writeAttribute(vKey, vValue != null ? vValue.toString() : "");
+                        }
+                }
+                if (pDepth > 0 || isInTagerts(pNode.getSrcUri(), pUriTargets)) {
+                        List<ISrcNode> vCh = pNode.listChildrenNodes(null);
+                        if (vCh != null && vCh.size() > 0) {
+                                pWriter.writeEndOpenTag();
+                                for (ISrcNode vNode : vCh) {
+                                        try {
+                                                pFields.resetDatas();
+                                                SrcFeatureFields.fillFields(vNode, pFields);
+                                                writeFields(vNode, pFields, pWriter, pDepth - 1, pUriTargets);
+                                        } catch (Exception e) {
+                                                //En cas d'exception, on préfère perdre cet item mais préserver l'accès aux autres items de cet espace.
+                                                LogMgr.publishException(e, "Build srcFields failed for child : " + vNode.getSrcUri());
+                                        }
+                                }
+                                pWriter.writeCloseTag("entry");
+                        } else {
+                                pWriter.writeEndEmptyTag();
+                        }
+                } else {
+                        pWriter.writeEndEmptyTag();
+                }
+        }
+
         protected boolean isInTagerts(String pSrcUri, String[] pTargets) {
                 if (pTargets == null) return false;