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.LoanoutClient;
  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.loanout.LoanoutResource;
  15 import org.collectionspace.services.loanout.nuxeo.LoanoutBotGardenConstants;
  16 import org.slf4j.Logger;
  17 import org.slf4j.LoggerFactory;
  18
  19 public class ClearVoucherLabelRequestBatchJob extends AbstractBatchJob {
  20         final Logger logger = LoggerFactory.getLogger(ClearVoucherLabelRequestBatchJob.class);
  21
  22         public ClearVoucherLabelRequestBatchJob() {
  23                 this.setSupportedInvocationModes(Arrays.asList(INVOCATION_MODE_SINGLE, INVOCATION_MODE_LIST, INVOCATION_MODE_NO_CONTEXT));
  24         }
  25
  26         @Override
  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> loanoutCsids = findLabelRequests();
  46                 InvocationResults results = null;
  47
  48                 if (loanoutCsids.size() > 0) {
  49                         results = clearLabelRequests(loanoutCsids);
  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 loanoutCsid) throws URISyntaxException  {
  60                 return clearLabelRequests(Arrays.asList(loanoutCsid));
  61         }
  62
  63         public InvocationResults clearLabelRequests(List<String> loanoutCsids) throws URISyntaxException  {
  64                 InvocationResults results = new InvocationResults();
  65                 long numAffected = 0;
  66
  67                 for (String loanoutCsid : loanoutCsids) {
  68                         clearLabelRequest(loanoutCsid);
  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 loanoutCsid) throws URISyntaxException {
  79                 logger.debug("clear label request: loanoutCsid=" + loanoutCsid);
  80
  81                 final String updatePayload =
  82                         "<?xml version=\"1.0\" encoding=\"UTF-8\"?>" +
  83                         "<document name=\"loansout\">" +
  84                                 "<ns2:loansout_botgarden xmlns:ns2=\"http://collectionspace.org/services/loanout/local/botgarden\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\">" +
  85                                         getFieldXml("labelRequested", LoanoutBotGardenConstants.LABEL_REQUESTED_NO_VALUE) +
  86                                 "</ns2:loansout_botgarden>" +
  87                         "</document>";
  88
  89                 NuxeoBasedResource resource = (NuxeoBasedResource) getResourceMap().get(LoanoutClient.SERVICE_NAME);
  90                 resource.update(getResourceMap(), createUriInfo(), loanoutCsid, updatePayload);
  91         }
  92
  93         private List<String> findLabelRequests() throws URISyntaxException {
  94                 List<String> csids = new ArrayList<String>();
  95                 LoanoutResource loanoutResource = (LoanoutResource) getResourceMap().get(LoanoutClient.SERVICE_NAME);
  96                 AbstractCommonList loanoutList = loanoutResource.getList(createLabelRequestSearchUriInfo());
  97
  98                 for (AbstractCommonList.ListItem item : loanoutList.getListItem()) {
  99                         for (org.w3c.dom.Element element : item.getAny()) {
 100                                 if (element.getTagName().equals("csid")) {
 101                                         csids.add(element.getTextContent());
 102                                         break;
 103                                 }
 104                         }
 105                 }
 106
 107                 return csids;
 108         }
 109
 110         private UriInfo createLabelRequestSearchUriInfo() throws URISyntaxException {
 111                 return createKeywordSearchUriInfo(LoanoutBotGardenConstants.LABEL_REQUESTED_SCHEMA_NAME, LoanoutBotGardenConstants.LABEL_REQUESTED_FIELD_NAME,
 112                                 LoanoutBotGardenConstants.LABEL_REQUESTED_YES_VALUE);
 113         }
 114 }