git.aero2k.de Git - tmp/jakarta-migration.git/blob

   1 package org.collectionspace.services.batch.nuxeo;
   2
   3 import java.net.URISyntaxException;
   4 import java.util.ArrayList;
   5 import java.util.Arrays;
   6 import java.util.List;
   7
   8 import javax.ws.rs.core.UriInfo;
   9
  10 import org.collectionspace.services.client.PottagClient;
  11 import org.collectionspace.services.common.NuxeoBasedResource;
  12 import org.collectionspace.services.common.invocable.InvocationResults;
  13 import org.collectionspace.services.jaxb.AbstractCommonList;
  14 import org.collectionspace.services.pottag.PottagResource;
  15 import org.collectionspace.services.pottag.nuxeo.PottagConstants;
  16 import org.slf4j.Logger;
  17 import org.slf4j.LoggerFactory;
  18
  19 public class ClearPotTagLabelRequestBatchJob extends AbstractBatchJob {
  20         final Logger logger = LoggerFactory.getLogger(ClearPotTagLabelRequestBatchJob.class);
  21
  22         public ClearPotTagLabelRequestBatchJob() {
  23                 setSupportedInvocationModes(Arrays.asList(INVOCATION_MODE_SINGLE, INVOCATION_MODE_LIST, INVOCATION_MODE_NO_CONTEXT));
  24         }
  25
  26         public void run() {
  27                 setCompletionStatus(STATUS_MIN_PROGRESS);
  28
  29                 try {
  30                         /*
  31                          * For now, treat any mode as if it were no context.
  32                          */
  33
  34                         setResults(clearLabelRequests());
  35                         setCompletionStatus(STATUS_COMPLETE);
  36                 }
  37                 catch(Exception e) {
  38                         setCompletionStatus(STATUS_ERROR);
  39                         setErrorInfo(new InvocationError(INT_ERROR_STATUS, e.getMessage()));
  40                 }
  41         }
  42
  43         public InvocationResults clearLabelRequests() throws URISyntaxException  {
  44                 List<String> potTagCsids = findLabelRequests();
  45                 InvocationResults results = null;
  46
  47                 if (potTagCsids.size() > 0) {
  48                         results = clearLabelRequests(potTagCsids);
  49                 }
  50                 else {
  51                         results = new InvocationResults();
  52                         results.setUserNote("No label requests found");
  53                 }
  54
  55                 return results;
  56         }
  57
  58         public InvocationResults clearLabelRequests(String potTagCsid) throws URISyntaxException  {
  59                 return clearLabelRequests(Arrays.asList(potTagCsid));
  60         }
  61
  62         public InvocationResults clearLabelRequests(List<String> potTagCsids) throws URISyntaxException  {
  63                 InvocationResults results = new InvocationResults();
  64                 long numAffected = 0;
  65
  66                 for (String potTagCsid : potTagCsids) {
  67                         clearLabelRequest(potTagCsid);
  68                         numAffected = numAffected + 1;
  69                 }
  70
  71                 results.setNumAffected(numAffected);
  72                 results.setUserNote("Removed " + numAffected + " label " + (numAffected == 1 ? "request" : "requests"));
  73
  74                 return results;
  75         }
  76
  77         private void clearLabelRequest(String potTagCsid) throws URISyntaxException {
  78                 logger.debug("clear label request: potTagCsid=" + potTagCsid);
  79
  80                 final String updatePayload =
  81                         "<?xml version=\"1.0\" encoding=\"UTF-8\"?>" +
  82                         "<document name=\"pottags\">" +
  83                                 "<ns2:pottags_common xmlns:ns2=\"http://collectionspace.org/services/pottag\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\">" +
  84                                         getFieldXml(PottagConstants.LABEL_REQUESTED_FIELD_NAME, PottagConstants.LABEL_REQUESTED_NO_VALUE) +
  85                                 "</ns2:pottags_common>" +
  86                         "</document>";
  87
  88                 NuxeoBasedResource resource = (NuxeoBasedResource) getResourceMap().get(PottagClient.SERVICE_NAME);
  89                 resource.update(getResourceMap(), createUriInfo(), potTagCsid, updatePayload);
  90         }
  91
  92         private List<String> findLabelRequests() throws URISyntaxException {
  93                 List<String> csids = new ArrayList<String>();
  94                 PottagResource potTagResource = (PottagResource) getResourceMap().get(PottagClient.SERVICE_NAME);
  95                 AbstractCommonList potTagList = potTagResource.getList(createLabelRequestSearchUriInfo());
  96
  97                 for (AbstractCommonList.ListItem item : potTagList.getListItem()) {
  98                         for (org.w3c.dom.Element element : item.getAny()) {
  99                                 if (element.getTagName().equals("csid")) {
 100                                         csids.add(element.getTextContent());
 101                                         break;
 102                                 }
 103                         }
 104                 }
 105
 106                 return csids;
 107         }
 108
 109         private UriInfo createLabelRequestSearchUriInfo() throws URISyntaxException {
 110                 return createKeywordSearchUriInfo(PottagConstants.LABEL_REQUESTED_SCHEMA_NAME, PottagConstants.LABEL_REQUESTED_FIELD_NAME, PottagConstants.LABEL_REQUESTED_YES_VALUE);
 111         }
 112 }