inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-07-31 17:39:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

[MNT-22353]- Removed Hold cases to be processed.

Browse Source
This commit is contained in:
pjoshi31
2022-11-02 14:52:35 +05:30
parent 7cb98f2d5d
commit 1339dd59a9
1 changed files with 15 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
amps/ags/rm-community/rm-community-repo/source/java/org/alfresco/module/org_alfresco_module_rm/job/DispositionLifecycleJobExecuter.java
View File

@@ -30,6 +30,7 @@ package org.alfresco.module.org_alfresco_module_rm.job;
import static org.alfresco.module.org_alfresco_module_rm.action.RMDispositionActionExecuterAbstractBase.PARAM_NO_ERROR_CHECK; import static org.alfresco.module.org_alfresco_module_rm.action.RMDispositionActionExecuterAbstractBase.PARAM_NO_ERROR_CHECK;
import java.io.Serializable; import java.io.Serializable;
import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@@ -194,6 +195,7 @@ public class DispositionLifecycleJobExecuter extends RecordsManagementJobExecute
boolean hasMore = true; boolean hasMore = true;
int skipCount = 0; int skipCount = 0;
List<NodeRef> resultList = new ArrayList<>();
if (batchSize < 1) if (batchSize < 1)
{ {
@@ -214,17 +216,23 @@ public class DispositionLifecycleJobExecuter extends RecordsManagementJobExecute
// execute search // execute search
ResultSet results = searchService.query(params); ResultSet results = searchService.query(params);
List<NodeRef> resultNodes = results.getNodeRefs(); if(results.length() != 0) {
for (NodeRef nodeRef : results.getNodeRefs()) {
log.info("Freeze service: "+(freezeService.isFrozenOrHasFrozenChildren(nodeService.getPrimaryParent(nodeRef).getParentRef())? MSG_NODE_FROZEN: "Node is not freezed"));
if (!freezeService.isFrozenOrHasFrozenChildren(nodeService.getPrimaryParent(nodeRef).getParentRef())) {
resultList.add(nodeRef);
}
}
hasMore = results.hasMore(); hasMore = results.hasMore();
skipCount += resultNodes.size(); // increase by page size }
skipCount += resultList.size(); // increase by page size
results.close(); results.close();
log.debug("Processing " + resultNodes.size() + " nodes"); log.debug("Processing " + resultList.size() + " nodes");
// process search results // process search results
if (!resultNodes.isEmpty()) if (!resultList.isEmpty())
{ {
executeAction(resultNodes); executeAction(resultList);
} }
} }
log.debug("Job Finished"); log.debug("Job Finished");
@@ -265,12 +273,6 @@ public class DispositionLifecycleJobExecuter extends RecordsManagementJobExecute
} }
Map<String, Serializable> props = Map.of(PARAM_NO_ERROR_CHECK, false); Map<String, Serializable> props = Map.of(PARAM_NO_ERROR_CHECK, false);
if (freezeService.isFrozenOrHasFrozenChildren(parent.getParentRef()))
{
log.debug(I18NUtil.getMessage(MSG_NODE_FROZEN, dispAction));
continue;
}
try try
{ {
// execute disposition action // execute disposition action