View Javadoc
1   /**
2    * Copyright 2005-2016 The Kuali Foundation
3    *
4    * Licensed under the Educational Community License, Version 2.0 (the "License");
5    * you may not use this file except in compliance with the License.
6    * You may obtain a copy of the License at
7    *
8    * http://www.opensource.org/licenses/ecl2.php
9    *
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS,
12   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   * See the License for the specific language governing permissions and
14   * limitations under the License.
15   */
16  package org.kuali.rice.krad.maintenance;
17  
18  import org.apache.commons.lang.StringUtils;
19  import org.kuali.rice.core.api.CoreApiServiceLocator;
20  import org.kuali.rice.core.api.util.RiceKeyConstants;
21  import org.kuali.rice.kew.api.WorkflowDocument;
22  import org.kuali.rice.krad.exception.KualiExceptionIncident;
23  import org.kuali.rice.krad.exception.ValidationException;
24  import org.kuali.rice.krad.service.KRADServiceLocatorWeb;
25  import org.kuali.rice.krad.util.GlobalVariables;
26  import org.kuali.rice.krad.util.KRADConstants;
27  import org.kuali.rice.krad.util.UrlFactory;
28  
29  import java.util.HashMap;
30  import java.util.Map;
31  import java.util.Properties;
32  
33  /**
34   * Provides static utility methods for use within the maintenance framework
35   *
36   * @author Kuali Rice Team (rice.collab@kuali.org)
37   */
38  public class MaintenanceUtils {
39      private static final org.apache.log4j.Logger LOG = org.apache.log4j.Logger.getLogger(MaintenanceUtils.class);
40  
41      /**
42       * Determines if there is another maintenance document that has a lock on the same key as the given document, and
43       * therefore will block the maintenance document from being submitted
44       *
45       * @param document - maintenance document instance to check locking for
46       * @param throwExceptionIfLocked - indicates if an exception should be thrown in the case of found locking document,
47       * if false only an error will be added
48       */
49      public static void checkForLockingDocument(MaintenanceDocument document, boolean throwExceptionIfLocked) {
50          LOG.info("starting checkForLockingDocument (by MaintenanceDocument)");
51  
52          // get the docHeaderId of the blocking docs, if any are locked and blocking
53          //String blockingDocId = getMaintenanceDocumentService().getLockingDocumentId(document);
54          String blockingDocId = document.getNewMaintainableObject().getLockingDocumentId();
55          checkDocumentBlockingDocumentId(blockingDocId, throwExceptionIfLocked);
56      }
57  
58      public static void checkDocumentBlockingDocumentId(String blockingDocId, boolean throwExceptionIfLocked) {
59          // if we got nothing, then no docs are blocking, and we're done
60          if (StringUtils.isBlank(blockingDocId)) {
61              return;
62          }
63  
64          if (MaintenanceUtils.LOG.isInfoEnabled()) {
65              MaintenanceUtils.LOG.info("Locking document found:  docId = " + blockingDocId + ".");
66          }
67  
68          // load the blocking locked document
69          WorkflowDocument lockedDocument = null;
70          try {
71              // need to perform this check to prevent an exception from being thrown by the
72              // createWorkflowDocument call - the throw itself causes transaction rollback problems to
73              // occur, even though the exception would be caught here
74              if (KRADServiceLocatorWeb.getWorkflowDocumentService().workflowDocumentExists(blockingDocId)) {
75                  lockedDocument = KRADServiceLocatorWeb.getWorkflowDocumentService()
76                          .loadWorkflowDocument(blockingDocId, GlobalVariables.getUserSession().getPerson());
77              }
78          } catch (Exception ex) {
79              // clean up the lock and notify the admins
80              MaintenanceUtils.LOG.error("Unable to retrieve locking document specified in the maintenance lock table: " +
81                      blockingDocId, ex);
82  
83              cleanOrphanLocks(blockingDocId, ex);
84              return;
85          }
86          if (lockedDocument == null) {
87              MaintenanceUtils.LOG.warn("Locking document header for " + blockingDocId + "came back null.");
88              cleanOrphanLocks(blockingDocId, null);
89          }
90  
91          // if we can ignore the lock (see method notes), then exit cause we're done
92          if (lockCanBeIgnored(lockedDocument)) {
93              return;
94          }
95  
96          // build the link URL for the blocking document
97          Properties parameters = new Properties();
98          parameters.put(KRADConstants.PARAMETER_DOC_ID, blockingDocId);
99          parameters.put(KRADConstants.PARAMETER_COMMAND, KRADConstants.METHOD_DISPLAY_DOC_SEARCH_VIEW);
100         String blockingUrl = UrlFactory.parameterizeUrl(
101                 CoreApiServiceLocator.getKualiConfigurationService().getPropertyValueAsString(
102                         KRADConstants.WORKFLOW_URL_KEY) +
103                         "/" + KRADConstants.DOC_HANDLER_ACTION, parameters);
104         if (MaintenanceUtils.LOG.isDebugEnabled()) {
105             MaintenanceUtils.LOG.debug("blockingUrl = '" + blockingUrl + "'");
106             MaintenanceUtils.LOG.debug("Maintenance record: " + lockedDocument.getApplicationDocumentId() + "is locked.");
107         }
108         String[] errorParameters = {blockingUrl, blockingDocId};
109 
110         // If specified, add an error to the ErrorMap and throw an exception; otherwise, just add a warning to the ErrorMap instead.
111         if (throwExceptionIfLocked) {
112             // post an error about the locked document
113             GlobalVariables.getMessageMap()
114                     .putError(KRADConstants.GLOBAL_ERRORS, RiceKeyConstants.ERROR_MAINTENANCE_LOCKED, errorParameters);
115             throw new ValidationException("Maintenance Record is locked by another document.");
116         } else {
117             // Post a warning about the locked document.
118             GlobalVariables.getMessageMap()
119                     .putWarning(KRADConstants.GLOBAL_MESSAGES, RiceKeyConstants.WARNING_MAINTENANCE_LOCKED,
120                             errorParameters);
121         }
122     }
123 
124     /**
125      * Guesses whether the current user should be allowed to change a document even though it is locked. It
126      * probably should use Authorization instead? See KULNRVSYS-948
127      *
128      * @param lockedDocument
129      * @return
130      * @throws org.kuali.rice.kew.api.exception.WorkflowException
131      *
132      */
133     private static boolean lockCanBeIgnored(WorkflowDocument lockedDocument) {
134         // TODO: implement real authorization for Maintenance Document Save/Route - KULNRVSYS-948
135         if (lockedDocument == null) {
136             return true;
137         }
138 
139         // get the user-id. if no user-id, then we can do this test, so exit
140         String userId = GlobalVariables.getUserSession().getPrincipalId().trim();
141         if (StringUtils.isBlank(userId)) {
142             return false; // dont bypass locking
143         }
144 
145         // if the current user is not the initiator of the blocking document
146         if (!userId.equalsIgnoreCase(lockedDocument.getInitiatorPrincipalId().trim())) {
147             return false;
148         }
149 
150         // if the blocking document hasn't been routed, we can ignore it
151         return lockedDocument.isInitiated();
152     }
153 
154     protected static void cleanOrphanLocks(String lockingDocumentNumber, Exception workflowException) {
155         // put a try/catch around the whole thing - the whole reason we are doing this is to prevent data errors
156         // from stopping a document
157         try {
158             // delete the locks for this document since it does not seem to exist
159             KRADServiceLocatorWeb.getMaintenanceDocumentService().deleteLocks(lockingDocumentNumber);
160             // notify the incident list
161             Map<String, String> parameters = new HashMap<String, String>(1);
162             parameters.put(KRADConstants.PARAMETER_DOC_ID, lockingDocumentNumber);
163             KualiExceptionIncident kei = KRADServiceLocatorWeb.getKualiExceptionIncidentService()
164                     .getExceptionIncident(workflowException, parameters);
165             KRADServiceLocatorWeb.getKualiExceptionIncidentService().report(kei);
166         } catch (Exception ex) {
167             MaintenanceUtils.LOG.error("Unable to delete and notify upon locking document retrieval failure.", ex);
168         }
169     }
170 
171    /**
172     * Determines if the maintenance document action creates a new record.
173     *
174     * <p>
175     * When taking an action on a maintenance document, some actions cause the creation of a new record, while some don't.
176     * For example, editing does not create a record, but copying does.
177     * @param maintenanceAction
178     * @return boolean
179     * </p>
180     */
181     public static boolean isMaintenanceDocumentCreatingNewRecord(String maintenanceAction) {
182         if (KRADConstants.MAINTENANCE_EDIT_ACTION.equalsIgnoreCase(maintenanceAction)) {
183             return false;
184         } else if (KRADConstants.MAINTENANCE_NEWWITHEXISTING_ACTION.equalsIgnoreCase(maintenanceAction)) {
185             return false;
186         } else if (KRADConstants.MAINTENANCE_DELETE_ACTION.equalsIgnoreCase(maintenanceAction)) {
187             return false;
188         } else if (KRADConstants.MAINTENANCE_NEW_ACTION.equalsIgnoreCase(maintenanceAction)) {
189             return true;
190         } else if (KRADConstants.MAINTENANCE_COPY_ACTION.equalsIgnoreCase(maintenanceAction)) {
191             return true;
192         } else {
193             return true;
194         }
195     }
196 }