Changeset 15098

Timestamp:

03/14/10 09:12:55 (5 months ago)

Author:

sys

Message:

Copy / move by id.

Location:

trunk

Files:

• Jav_Src/src/com/scenari/src/feature/ids/IFindNodeByIdAspect.java (modified) (1 diff)
• Jav_Src/src/com/scenari/src/feature/ids/IFindUriByIdAspect.java (modified) (1 diff)
• Jav_Src/src/com/scenari/src/feature/ids/SrcFeatureIds.java (modified) (3 diffs)
• Jav_Wsp/src/com/scenari/m/bdp/item/fs/HWorkspaceFs.java (modified) (7 diffs)
• Jav_Wsp/src/com/scenari/m/bdp/item/fs/WspSrcNodeItem.java (modified) (3 diffs)
• Jav_Wsp/src/com/scenari/m/bdp/item/fs/XItemCache.java (modified) (10 diffs)
• Jav_Wsp/src/com/scenari/m/bdp/module/rename/HRenamingPlanSpace.java (modified) (1 diff)

trunk/Jav_Src/src/com/scenari/src/feature/ids/IFindNodeByIdAspect.java

@@ -57 +57 @@
         /**
          * Recherche un {@link ISrcNode} par son Id.
+         * 
+         * @return <code>null</code> si l'id n'existe pas.
          */
         public ISrcNode findNodeById(String pId) throws Exception;

trunk/Jav_Src/src/com/scenari/src/feature/ids/IFindUriByIdAspect.java

@@ -58 +58 @@
         /**
          * Recherche une Uri par son Id.
+         * 
+         * @return <code>null</code> si cet Id n'existe pas.
          */
         public String findUriById(String pId) throws Exception;

trunk/Jav_Src/src/com/scenari/src/feature/ids/SrcFeatureIds.java

@@ -73 +73 @@
          * <p>Recherche un {@link ISrcNode} via un srcId.</p>
          *
-         * @return {@link ISrcContent} trouv�u <code>null</code> si pSrcId est <code>null</code>.
+         * @return {@link ISrcNode} trouv�u <code>null</code> si pSrcId est <code>null</code> ou si cet Id n'existe pas.
          * @throws AspectNotFoundException si aucun aspect ne permettant la r�lution de l'Id n'a � trouv�
          */
@@ -83 +83 @@
                 //Recherche une Uri
                 IFindUriByIdAspect vFindUriAspect = pSrc.getAspect(IFindUriByIdAspect.TYPE);
-                if (vFindUriAspect != null) return pSrc.findNodeByUri(vFindUriAspect.findUriById(pSrcId));
+                if (vFindUriAspect != null) {
+                        String vUri = vFindUriAspect.findUriById(pSrcId);
+                        return vUri != null ? pSrc.findNodeByUri(vUri) : null;
+                }
                 //Echec de la recherche par Id.
                 throw new AspectNotFoundException(IFindNodeByIdAspect.class.getName());
@@ -183 +186 @@
          * <p>Si la source est dans un �t nul {@link ISrcContent#STATUS_NONE}, force la cr�ion d'un Id pour cette Uri.</p>
          * 
+         * @param pAsFolder Si <code>true</code> cr�ISrcContent de type folder si n�ssaire (de type file sinon).
          * @return L'id de la source ou <code>null</code> si aucun aspect de type {@link IIdAspect} n'a � trouv�
          */
-        public static String getOrCreateSrcId(ISrcContent pSrcContent) throws Exception {
+        public static String getOrCreateSrcId(ISrcContent pSrcContent, boolean pAsFolder) throws Exception {
                 IIdAspect vIdAspect = pSrcContent.getAspect(IIdAspect.TYPE);
-                if (vIdAspect != null) return vIdAspect.getSrcId(ISrcContent.STATUS_NONE);
+                if (vIdAspect != null) return vIdAspect.getSrcId(pAsFolder ? ISrcContent.STATUS_FOLDER : ISrcContent.STATUS_FILE);
                 return null;
         }

trunk/Jav_Wsp/src/com/scenari/m/bdp/item/fs/HWorkspaceFs.java

@@ -555 +555 @@
                                 fFireDiscoveredItems = vOld;
                         }
+                        break;
+
+                case space:
+                case wsp:
+                        //not implemented
+                        assert (false);
                 }
         }
@@ -641 +647 @@
                                 vResult = new XItemCache(this, vSrcNode);
                                 fItemsByUri.put(pUri, vResult);
-                                String vId = SrcFeatureIds.getSrcId(vSrcNode);
-                                if (vId != null) {
-                                        fItemsById.put(vId, vResult);
-                                }
                                 vResult.refresh(true);
                         }
@@ -657 +659 @@
          * L'itemCache a � rafraichit.
          * 
-         * Retourne null si l'uri n'est pas une uri d'item.
+         * Retourne null si l'id n'existe pas.
          */
         protected XItemCache xGetItemCacheById(String pSrcId, boolean pRefresh) throws Exception {
@@ -665 +667 @@
                         ISrcNode vSrcNode = SrcFeatureIds.findNodeById(fSubSrcNode, pSrcId);
                         if (vSrcNode != null) {
-                                vResult = new XItemCache(this, vSrcNode);
-                                fItemsByUri.put(vSrcNode.getSrcUri(), vResult);
-                                //Mutualisation des strings, on reprend la String de l'id de la source.
-                                String vId = SrcFeatureIds.getSrcId(vSrcNode);
-                                if (vId != null) {
-                                        fItemsById.put(vId, vResult);
-                                }
-                        }
-                }
-                if (pRefresh && vResult != null) vResult.refresh(true);
+                                String vSrcId = SrcFeatureIds.getSrcId(vSrcNode);
+                                if (vSrcId != null && vSrcId.equals(pSrcId)) {
+                                        vResult = new XItemCache(this, vSrcNode);
+                                        fItemsByUri.put(vSrcNode.getSrcUri(), vResult);
+                                        if (!pRefresh) vResult.setId(vSrcNode);
+                                } else if (vSrcId != null) {
+                                        //pSrcId �it un alias vers le "bon id". 
+                                        return xGetItemCacheById(vSrcId, pRefresh);
+                                }
+                        }
+                }
+                if (pRefresh && vResult != null) {
+                        String vId = vResult.fId;
+                        vResult.refresh(true);
+                        if (vId != null && (vResult.fId == null || !vResult.fId.equals(vId))) {
+                                //L'id a � modifi�u refresh...
+                                return xGetItemCacheById(pSrcId, pRefresh);
+                        }
+                }
                 return vResult;
         }
@@ -691 +702 @@
                         vResult = new XItemCache(this, pSubSrcNode);
                         fItemsByUri.put(pSubSrcNode.getSrcUri(), vResult);
-                        String vId = SrcFeatureIds.getSrcId(pSubSrcNode);
-                        if (vId != null) {
-                                fItemsById.put(vId, vResult);
-                        }
                 }
                 vResult.refresh(true);
@@ -713 +720 @@
                         vResult = new XItemCache(this, vSrcNode);
                         fItemsByUri.put(pUri, vResult);
-                        String vId = SrcFeatureIds.getSrcId(vSrcNode);
-                        if (vId != null) {
-                                fItemsById.put(vId, vResult);
-                        }
+                        if (!pRefresh) vResult.setId(vSrcNode);
                 }
                 if (pRefresh) vResult.refresh(true);
@@ -728 +732 @@
                 assert Thread.holdsLock(this);
                 fItemsByUri.remove(pItemCache.fUri);
-                XItemCacheData vDatas = pItemCache.getDatasIfExist();
-                if (vDatas != null) {
-                        ISrcNode vSrcNode = vDatas.getWspSrcNodeItem();
-                        try {
-                                String vId = SrcFeatureIds.getSrcId(vSrcNode);
-                                if (vId != null) {
-                                        fItemsById.remove(vId);
-                                }
-                        } catch (Exception e) {
-                                LogMgr.publishException(e);
-                        }
+                if (pItemCache.fId != null) {
+                        fItemsById.remove(pItemCache.fId);
                 }
         }

trunk/Jav_Wsp/src/com/scenari/m/bdp/item/fs/WspSrcNodeItem.java

@@ -393 +393 @@
                         try {
                                 vSubCopyMove.moveFrom(pFrom);
-                                String vIdTarget = SrcFeatureIds.getSrcId(getSubSrcNode());
-                                if (vIdTarget == null || !vIdFrom.equals(vIdTarget)) {
-                                        //L'Id n'a pas suivi, on renomme les items pointeurs...
-                                        xRenamePointers(pFrom.getSrcUri(), vIdFrom);
-                                }
                         } finally {
                                 //On force un revalidation de l'item source et target.
+                                //FIXME sauf si listener auto sur subSrc
                                 xValidateItem(pFrom);
                                 xValidateItem(this);
+                        }
+                        String vIdTarget = SrcFeatureIds.getSrcId(getSubSrcNode());
+                        if (vIdTarget == null || !vIdFrom.equals(vIdTarget)) {
+                                //L'Id n'a pas suivi, on renomme les items pointeurs...
+                                xRenamePointers(pFrom.getSrcUri(), vIdFrom);
+                        } else {
+                                //On ne fait qu'un refresh pour r�aluer les refUri
+                                xRefreshPointers(pFrom.getSrcUri());
                         }
                 } else {
@@ -428 +432 @@
         protected void xValidateItem(ISrcNode pFrom) {
                 try {
-                        IHItemDef vItemDefFrom = pFrom.getAspect(IWspSrc.ITEMDEF_ASPECT_TYPE);
-                        if (vItemDefFrom != null) {
-                                InputStream vIn = pFrom.newInputStream(false);
-                                HStreamHandler vStreamHandler = vIn != null ? new HStreamHandler(vIn) : null;
-                                try {
-                                        IHItemType vItemType = HTreatIdentif.findItemType(vItemDefFrom.hGetWorkspace(), pFrom.getSrcUri(), null, vStreamHandler);
-                                        IUser vUser = ThreadUser.getUser();
-                                        int vClientId = ContextBdp.getThreadClientInt();
-                                        vItemType.hGetModuleSave().hValidateItem(vItemDefFrom, vStreamHandler, vUser != null ? vUser.getAccount() : null, vClientId, null);
-                                } finally {
-                                        if (vStreamHandler != null) vStreamHandler.hCloseAndPurgeCache();
+                        if (pFrom.getContentStatus() <= ISrcContent.STATUS_NONE) {
+                                IHWorkspace vWspFrom = pFrom.getAspect(IWspSrc.WORKSPACE_ASPECT_TYPE);
+                                if (vWspFrom != null) {
+                                        vWspFrom.refreshUri(pFrom.getSrcUri());
+                                }
+                        } else {
+                                IHItemDef vItemDefFrom = pFrom.getAspect(IWspSrc.ITEMDEF_ASPECT_TYPE);
+                                if (vItemDefFrom != null) {
+                                        InputStream vIn = pFrom.newInputStream(false);
+                                        HStreamHandler vStreamHandler = vIn != null ? new HStreamHandler(vIn) : null;
+                                        try {
+                                                IHItemType vItemType = HTreatIdentif.findItemType(vItemDefFrom.hGetWorkspace(), pFrom.getSrcUri(), null, vStreamHandler);
+                                                IUser vUser = ThreadUser.getUser();
+                                                int vClientId = ContextBdp.getThreadClientInt();
+                                                vItemType.hGetModuleSave().hValidateItem(vItemDefFrom, vStreamHandler, vUser != null ? vUser.getAccount() : null, vClientId, null);
+                                        } finally {
+                                                if (vStreamHandler != null) vStreamHandler.hCloseAndPurgeCache();
+                                        }
                                 }
                         }
@@ -484 +495 @@
         }
 
+        /**
+         * Revalide les items pointeurs de cet item suite �n renommage.
+         */
+        protected void xRefreshPointers(String pUriFrom) throws Exception {
+                //On transforme les items pointeurs sur pFrom
+                ISearchRequestEditable vReq = SrcFeatureSearch.newRequest();
+                vReq.setMainExpression(new LinkParents().setStartPath(pUriFrom));
+                Iterator<ISearchResultRow> vIt = SrcFeatureSearch.execute(vReq, getWorkspace().findNodeByUri(URI_ROOT));
+                while (vIt.hasNext()) {
+                        XItemCache vItemCache = fItemCacheData.getItemCache().getWsp().xGetOrCreateItemCache(vIt.next().getRowUri(), false);
+                        vItemCache.xUnlinkChilds();
+                        vItemCache.xLinkChilds();
+                }
+        }
+
         public void fillFields(IFieldsCollector pFieldsToCollect) throws Exception {
                 //Fields du subSource.

trunk/Jav_Wsp/src/com/scenari/m/bdp/item/fs/XItemCache.java

@@ -44 +44 @@
 import java.util.Date;
 import java.util.Iterator;
+import java.util.Map;
 
 import org.xml.sax.Attributes;
@@ -149 +150 @@
                         if (pItemPtd != null) {
                                 //Mutualisation des instances d'objets en m�ire
-                                fRefUriPtd = pItemPtd.getUri();
+                                if (fRefUriPtd.equals(pItemPtd.getUri())) {
+                                        fRefUriPtd = pItemPtd.getUri();
+                                } else if (fRefUriPtd.equals(pItemPtd.getId())) {
+                                        fRefUriPtd = pItemPtd.getId();
+                                }
                         }
                 }
@@ -348 +353 @@
         protected XLink fFirstPointer = null;
 
-        /** Liste chain�d'items en cache (champ g� par la classe XSpace). */
-        protected XItemCache fNextItem = null;
-
         /** Uri de cet item. */
         protected String fUri = IHItem.URI_NULL;
+
+        /** Id de cet item. */
+        protected String fId = null;
 
         /** ItemType de cette item. */
@@ -398 +403 @@
         public String getUri() {
                 return fUri;
+        }
+
+        public String getId() {
+                return fId;
         }
 
@@ -645 +654 @@
                 }
                 ISrcNode vSrc = vDatas.getWspSrcNodeItem().getSubSrcNode();
+                //Refresh de l'ID.
+                this.setId(vSrc);
                 if (fStatusItem == IHItem.STATUS_UNKNOWN) {
                         xLoadItemFromSource(false, vSrc, vSrc.getLastModifWithChildren(), IContextBdp.CLIENTID_NONE);
@@ -834 +845 @@
                 XItemCacheData vItemData = getDatas();
                 vItemData.fLastRefresh = System.currentTimeMillis();
-                fMemLastModif = vItemData.getWspSrcNodeItem().getSubSrcNode().getLastModifWithChildren();
+                ISrcNode vSubSrcNode = vItemData.getWspSrcNodeItem().getSubSrcNode();
+                fMemLastModif = vSubSrcNode.getLastModifWithChildren();
+        }
+
+        /**
+         * Affectation / mise �our de l'index par ID.
+         */
+        public void setId(ISrcNode pSrcNode) throws Exception {
+                assert Thread.holdsLock(getWsp());
+                String vNewId = SrcFeatureIds.getSrcId(pSrcNode);
+                if (fId == null && vNewId == null) return;
+                if (fId == null && vNewId != null) {
+                        getWsp().fItemsById.put(vNewId, this);
+                } else if (vNewId == null) {
+                        getWsp().fItemsById.remove(fId);
+                } else if (vNewId.equals(fId)) {
+                        return;
+                } else {
+                        Map<String, XItemCache> vMap = getWsp().fItemsById;
+                        vMap.remove(fId);
+                        vMap.put(vNewId, this);
+                }
+                fId = vNewId;
         }
 
@@ -924 +957 @@
                         }
                 }
-                xRecalStatusItem();
+                xComputeItemStatus();
         }
 
@@ -996 +1029 @@
          * Recalcul du status global de l'item apr�validation des liens notemment.
          */
-        protected void xRecalStatusItem() {
+        protected void xComputeItemStatus() {
                 //Si les liens n'ont pas � calcul�on ne fait rien.
                 boolean fHasWarning = (fFirstContentProblem != null);
@@ -1046 +1079 @@
         public void xUnlinkChilds() throws Exception {
                 if (fAttrs == null || fStatusItem == STATUS_INTERNAL_NOTLINKED) { return; }
-                if (fAttrs != null) {
-                        for (int i = 0; i < fAttrs.length; i = i + 4) {
-                                if (fAttrs[i] == IHAttr.TYPE_REF || fAttrs[i] == IHAttr.TYPE_LINK) {
-                                        XLink vLink = (XLink) fAttrs[i + 3];
-                                        XItemCache vPtd = vLink.fPtd;
-                                        if (vPtd == null) {
-                                                continue;
+                for (int i = 0; i < fAttrs.length; i = i + 4) {
+                        if (fAttrs[i] == IHAttr.TYPE_REF || fAttrs[i] == IHAttr.TYPE_LINK) {
+                                XLink vLink = (XLink) fAttrs[i + 3];
+                                XItemCache vPtd = vLink.fPtd;
+                                if (vPtd == null) {
+                                        continue;
+                                }
+                                XLink vPrec = null;
+                                XLink vCurr = vPtd.fFirstPointer;
+                                while (vCurr != null) {
+                                        //On recherche ce pointeur dans le Ptd
+                                        if (vCurr == vLink) {
+                                                //Trouv�                                                if (vPrec != null) {
+                                                        vPrec.fNextPointer = vCurr.fNextPointer;
+                                                } else {
+                                                        vPtd.fFirstPointer = vCurr.fNextPointer;
+                                                }
+                                                break;
                                         }
-                                        XLink vPrec = null;
-                                        XLink vCurr = vPtd.fFirstPointer;
-                                        while (vCurr != null) {
-                                                //On recherche ce pointeur dans le Ptd
-                                                if (vCurr == vLink) {
-                                                        //Trouv�                                                        if (vPrec != null) {
-                                                                vPrec.fNextPointer = vCurr.fNextPointer;
-                                                        } else {
-                                                                vPtd.fFirstPointer = vCurr.fNextPointer;
-                                                        }
-                                                        break;
-                                                }
-                                                vPrec = vCurr;
-                                                vCurr = vCurr.fNextPointer;
-                                        }
+                                        vPrec = vCurr;
+                                        vCurr = vCurr.fNextPointer;
                                 }
                         }
@@ -1104 +1135 @@
                                 //On recaclule le satus de l'item pointeur si il a d� � link�sinon perte de ref lors de XSpace.xLinkAllItems).
                                 if (vPointer.fItem.fStatusItem != STATUS_INTERNAL_NOTLINKED) {
-                                        vPointer.fItem.xRecalStatusItem();
+                                        vPointer.fItem.xComputeItemStatus();
                                         if (pFireEventUpdated && vOldStatus != vPointer.fItem.fStatusItem) getWsp().xFireEventItemStatus(vPointer.fItem);
                                 }

trunk/Jav_Wsp/src/com/scenari/m/bdp/module/rename/HRenamingPlanSpace.java

@@ -75 +75 @@
                                 String vNewUri = PoolBuffers.getStringAndFreeStringBuilder(vBuf);
                                 if (vRefById) {
-                                        String vNewId = SrcFeatureIds.getSrcId(fNewSrc.findNodeByUri(vNewUri));
+                                        String vNewId = SrcFeatureIds.getOrCreateSrcId(fNewSrc.findNodeByUri(vNewUri), false);
                                         if (vNewId != null) {
                                                 return vNewId;