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.MovementClient;
  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.movement.MovementResource;
  15 import org.collectionspace.services.movement.nuxeo.MovementBotGardenConstants;
  16
  17 import org.slf4j.Logger;
  18 import org.slf4j.LoggerFactory;
  19
  20 public class ClearLocationLabelRequestBatchJob extends AbstractBatchJob {
  21         final Logger logger = LoggerFactory.getLogger(ClearLocationLabelRequestBatchJob.class);
  22
  23         public ClearLocationLabelRequestBatchJob() {
  24                 setSupportedInvocationModes(Arrays.asList(INVOCATION_MODE_SINGLE, INVOCATION_MODE_LIST, INVOCATION_MODE_NO_CONTEXT));
  25         }
  26
  27         public void run() {
  28                 setCompletionStatus(STATUS_MIN_PROGRESS);
  29
  30                 try {
  31                         /*
  32                          * For now, treat any mode as if it were no context.
  33                          */
  34
  35                         setResults(clearLabelRequests());
  36                         setCompletionStatus(STATUS_COMPLETE);
  37                 }
  38                 catch(Exception e) {
  39                         setCompletionStatus(STATUS_ERROR);
  40                         setErrorInfo(new InvocationError(INT_ERROR_STATUS, e.getMessage()));
  41                 }
  42         }
  43
  44         public InvocationResults clearLabelRequests() throws URISyntaxException  {
  45                 List<String> movementCsids = findLabelRequests();
  46                 InvocationResults results = null;
  47
  48                 if (movementCsids.size() > 0) {
  49                         results = clearLabelRequests(movementCsids);
  50                 }
  51                 else {
  52                         results = new InvocationResults();
  53                         results.setUserNote("No label requests found");
  54                 }
  55
  56                 return results;
  57         }
  58
  59         public InvocationResults clearLabelRequests(String movementCsid) throws URISyntaxException  {
  60                 return clearLabelRequests(Arrays.asList(movementCsid));
  61         }
  62
  63         public InvocationResults clearLabelRequests(List<String> movementCsids) throws URISyntaxException  {
  64                 InvocationResults results = new InvocationResults();
  65                 long numAffected = 0;
  66
  67                 for (String movementCsid : movementCsids) {
  68                         clearLabelRequest(movementCsid);
  69                         numAffected = numAffected + 1;
  70                 }
  71
  72                 results.setNumAffected(numAffected);
  73                 results.setUserNote("Removed " + numAffected + " label " + (numAffected == 1 ? "request" : "requests"));
  74
  75                 return results;
  76         }
  77
  78         private void clearLabelRequest(String movementCsid) throws URISyntaxException {
  79                 logger.debug("clear label request: movementCsid=" + movementCsid);
  80
  81                 final String updatePayload =
  82                         "<?xml version=\"1.0\" encoding=\"UTF-8\"?>" +
  83                         "<document name=\"movements\">" +
  84                                 "<ns2:movements_common xmlns:ns2=\"http://collectionspace.org/services/movement\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\">" +
  85                                         getFieldXml("reasonForMove", MovementBotGardenConstants.OTHER_ACTION_CODE) +
  86                                 "</ns2:movements_common>" +
  87                                 "<ns2:movements_botgarden xmlns:ns2=\"http://collectionspace.org/services/movement/local/botgarden\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\">" +
  88                                         getFieldXml("labelRequested", MovementBotGardenConstants.LABEL_REQUESTED_NO_VALUE) +
  89                                         getFieldXml("labelSize", "") +
  90                                         getFieldXml("labelStandType", "") +
  91                                         getFieldXml("labelCount", "") +
  92                                 "</ns2:movements_botgarden>" +
  93                         "</document>";
  94
  95                 NuxeoBasedResource resource = (NuxeoBasedResource) getResourceMap().get(MovementClient.SERVICE_NAME);
  96                 resource.update(getResourceMap(), createUriInfo(), movementCsid, updatePayload);
  97         }
  98
  99         private List<String> findLabelRequests() throws URISyntaxException {
 100                 List<String> csids = new ArrayList<String>();
 101                 MovementResource movementResource = (MovementResource) getResourceMap().get(MovementClient.SERVICE_NAME);
 102                 AbstractCommonList movementList = movementResource.getList(createLabelRequestSearchUriInfo());
 103
 104                 for (AbstractCommonList.ListItem item : movementList.getListItem()) {
 105                         for (org.w3c.dom.Element element : item.getAny()) {
 106                                 if (element.getTagName().equals("csid")) {
 107                                         csids.add(element.getTextContent());
 108                                         break;
 109                                 }
 110                         }
 111                 }
 112
 113                 return csids;
 114         }
 115
 116         private UriInfo createLabelRequestSearchUriInfo() throws URISyntaxException {
 117                 return createKeywordSearchUriInfo(MovementBotGardenConstants.LABEL_REQUESTED_SCHEMA_NAME, MovementBotGardenConstants.LABEL_REQUESTED_FIELD_NAME,
 118                                 MovementBotGardenConstants.LABEL_REQUESTED_YES_VALUE);
 119         }
 120 }