1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.kuali.ole.select.document.service.impl;
17
18
19 import org.apache.commons.lang.StringUtils;
20 import org.kuali.ole.DataCarrierService;
21 import org.kuali.ole.deliver.processor.LoanProcessor;
22 import org.kuali.ole.module.purap.PurapConstants;
23 import org.kuali.ole.module.purap.PurapConstants.PurchaseOrderStatuses;
24 import org.kuali.ole.module.purap.PurapKeyConstants;
25 import org.kuali.ole.module.purap.PurapParameterConstants;
26 import org.kuali.ole.module.purap.businessobject.PurApItem;
27 import org.kuali.ole.module.purap.businessobject.PurchaseOrderType;
28 import org.kuali.ole.module.purap.document.PurchaseOrderDocument;
29 import org.kuali.ole.module.purap.document.RequisitionDocument;
30 import org.kuali.ole.module.purap.document.service.LogicContainer;
31 import org.kuali.ole.module.purap.document.service.PaymentRequestService;
32 import org.kuali.ole.module.purap.document.service.PrintService;
33 import org.kuali.ole.module.purap.document.service.PurApWorkflowIntegrationService;
34 import org.kuali.ole.module.purap.document.service.impl.PurchaseOrderServiceImpl;
35 import org.kuali.ole.pojo.OleTxRecord;
36 import org.kuali.ole.select.OleSelectConstant;
37 import org.kuali.ole.select.document.OlePurchaseOrderDocument;
38 import org.kuali.ole.select.document.service.OlePurchaseOrderService;
39 import org.kuali.ole.select.document.service.OleSelectDocumentService;
40 import org.kuali.ole.sys.OLEConstants;
41 import org.kuali.ole.sys.context.SpringContext;
42 import org.kuali.ole.sys.document.validation.event.DocumentSystemSaveEvent;
43 import org.kuali.rice.core.api.config.property.ConfigurationService;
44 import org.kuali.rice.core.api.resourceloader.GlobalResourceLoader;
45 import org.kuali.rice.coreservice.framework.parameter.ParameterService;
46 import org.kuali.rice.kew.api.KewApiConstants;
47 import org.kuali.rice.kew.api.KewApiServiceLocator;
48 import org.kuali.rice.kew.api.action.ActionRequestType;
49 import org.kuali.rice.kew.api.document.attribute.DocumentAttributeIndexingQueue;
50 import org.kuali.rice.kew.api.exception.WorkflowException;
51 import org.kuali.rice.kew.routeheader.DocumentRouteHeaderValue;
52 import org.kuali.rice.kew.routeheader.service.RouteHeaderService;
53 import org.kuali.rice.kim.api.identity.Person;
54 import org.kuali.rice.krad.exception.ValidationException;
55 import org.kuali.rice.krad.util.ErrorMessage;
56 import org.kuali.rice.krad.util.GlobalVariables;
57 import org.kuali.rice.krad.util.ObjectUtils;
58 import org.springframework.transaction.annotation.Transactional;
59 import org.springframework.util.AutoPopulatingList;
60
61 import java.io.ByteArrayOutputStream;
62 import java.lang.reflect.InvocationTargetException;
63 import java.sql.Timestamp;
64 import java.text.MessageFormat;
65 import java.util.*;
66
67 @Transactional
68 public class OlePurchaseOrderServiceImpl extends PurchaseOrderServiceImpl implements OlePurchaseOrderService {
69
70 private static org.apache.log4j.Logger LOG = org.apache.log4j.Logger.getLogger(OlePurchaseOrderServiceImpl.class);
71
72
73 private ConfigurationService kualiConfigurationService;
74 private PrintService printService;
75 private PurApWorkflowIntegrationService purapWorkflowIntegrationService;
76 private OleSelectDocumentService oleSelectDocumentService;
77
78 @Override
79 public void setPrintService(PrintService printService) {
80 this.printService = printService;
81 }
82
83 @Override
84 public void setConfigurationService(ConfigurationService kualiConfigurationService) {
85 this.kualiConfigurationService = kualiConfigurationService;
86 }
87
88 @Override
89 public void setPurapWorkflowIntegrationService(PurApWorkflowIntegrationService purapWorkflowIntegrationService) {
90 this.purapWorkflowIntegrationService = purapWorkflowIntegrationService;
91 }
92
93
94
95
96 @Override
97 public void createAutomaticPurchaseOrderDocument(RequisitionDocument reqDocument) {
98 String newSessionUserId = getOleSelectDocumentService().getSelectParameterValue(OLEConstants.SYSTEM_USER);
99 try {
100 LogicContainer logicToRun = new LogicContainer() {
101 @Override
102 public Object runLogic(Object[] objects) throws Exception {
103 RequisitionDocument doc = (RequisitionDocument) objects[0];
104
105 doc.setPurchaseOrderAutomaticIndicator(Boolean.TRUE);
106
107 PurchaseOrderDocument po = generatePurchaseOrderFromRequisition(doc);
108 po.setDefaultValuesForAPO();
109 po.setContractManagerCode(PurapConstants.APO_CONTRACT_MANAGER);
110 populatePOValuesFromProfileAttributes(doc,po);
111 String purchaseOrderType = "";
112 if (doc.getPurchaseOrderTypeId() != null) {
113 Map purchaseOrderTypeIdMap = new HashMap();
114 purchaseOrderTypeIdMap.put("purchaseOrderTypeId", doc.getPurchaseOrderTypeId());
115 org.kuali.rice.krad.service.BusinessObjectService
116 businessObjectService = SpringContext.getBean(org.kuali.rice.krad.service.BusinessObjectService.class);
117 LOG.debug("before calling findMatching");
118 List<PurchaseOrderType> purchaseOrderTypeDocumentList = (List) businessObjectService.findMatching(PurchaseOrderType.class, purchaseOrderTypeIdMap);
119 LOG.debug("after calling findMatching");
120 if (purchaseOrderTypeDocumentList != null && purchaseOrderTypeDocumentList.size() > 0) {
121 PurchaseOrderType purchaseOrderTypeDoc = purchaseOrderTypeDocumentList.get(0);
122 purchaseOrderType = purchaseOrderTypeDoc.getPurchaseOrderType();
123 }
124 if (LOG.isDebugEnabled()) {
125 LOG.debug("purchaseOrderType >>>>>>>>>>>" + purchaseOrderType);
126 LOG.debug("purchaseOrder DocumentNumber >>>>>>>>>>>" + po.getDocumentNumber());
127 }
128 if (purchaseOrderType != null ) {
129
130 LOG.debug("before calling document service impl");
131 documentService.routeDocument(po, null, null);
132 LOG.debug("after calling document service impl ");
133 } else {
134 documentService.saveDocument(po, DocumentSystemSaveEvent.class);
135 }
136 }
137 final DocumentAttributeIndexingQueue documentAttributeIndexingQueue = KewApiServiceLocator.getDocumentAttributeIndexingQueue();
138 documentAttributeIndexingQueue.indexDocument(po.getDocumentNumber());
139 return null;
140 }
141 };
142 purapService.performLogicWithFakedUserSession(newSessionUserId, logicToRun, new Object[]{reqDocument});
143 } catch (WorkflowException e) {
144 String errorMsg = "Workflow Exception caught: " + e.getLocalizedMessage();
145 LOG.error(errorMsg, e);
146 throw new RuntimeException(errorMsg, e);
147 } catch (Exception e) {
148 throw new RuntimeException(e);
149 }
150 }
151
152 private void populatePOValuesFromProfileAttributes(RequisitionDocument doc,PurchaseOrderDocument po){
153 DataCarrierService dataCarrierService = GlobalResourceLoader.getService(org.kuali.ole.OLEConstants.DATA_CARRIER_SERVICE);
154 OleTxRecord oleTxRecord = (OleTxRecord)dataCarrierService.getData(org.kuali.ole.OLEConstants.OLE_TX_RECORD);
155 if(oleTxRecord != null && doc.getRequisitionSource() != null && doc.getRequisitionSource().getRequisitionSourceCode().equalsIgnoreCase(OleSelectConstant.REQUISITON_SRC_TYPE_AUTOINGEST)){
156 po.setPurchaseOrderConfirmedIndicator(oleTxRecord.isPurchaseOrderConfirmationIndicator());
157 if(oleTxRecord.getVendorChoice() != null){
158 po.setPurchaseOrderVendorChoiceCode(oleTxRecord.getVendorChoice());
159 }
160 if(oleTxRecord.getAssignToUser() != null){
161 po.setAssignedUserPrincipalName(oleTxRecord.getAssignToUser());
162 }
163 }
164 }
165
166
167
168
169
170 @Override
171 public void performPurchaseOrderFirstTransmitViaPrinting(String documentNumber, ByteArrayOutputStream baosPDF) {
172 PurchaseOrderDocument po = getPurchaseOrderByDocumentNumber(documentNumber);
173 String environment = kualiConfigurationService.getPropertyValueAsString(OLEConstants.ENVIRONMENT_KEY);
174 Collection<String> generatePDFErrors = printService.generatePurchaseOrderPdf(po, baosPDF, environment, null);
175 if (!generatePDFErrors.isEmpty()) {
176 addStringErrorMessagesToMessageMap(PurapKeyConstants.ERROR_PURCHASE_ORDER_PDF, generatePDFErrors);
177 throw new ValidationException("printing purchase order for first transmission failed");
178 }
179 Timestamp currentDate = dateTimeService.getCurrentTimestamp();
180 po.setPurchaseOrderFirstTransmissionTimestamp(currentDate);
181 po.setPurchaseOrderLastTransmitTimestamp(currentDate);
182 po.setOverrideWorkflowButtons(Boolean.FALSE);
183 boolean performedAction = purapWorkflowIntegrationService.takeAllActionsForGivenCriteria(po, "Action taken automatically as part of document initial print transmission", PurapConstants.PurchaseOrderStatuses.NODE_DOCUMENT_TRANSMISSION, GlobalVariables.getUserSession().getPerson(), null);
184 performedAction=true;
185 po.setApplicationDocumentStatus(PurapConstants.PurchaseOrderStatuses.APPDOC_OPEN);
186 if (!performedAction) {
187 Person systemUserPerson = getPersonService().getPersonByPrincipalName(getOleSelectDocumentService().getSelectParameterValue(OLEConstants.SYSTEM_USER));
188 purapWorkflowIntegrationService.takeAllActionsForGivenCriteria(po, "Action taken automatically as part of document initial print transmission by user " + GlobalVariables.getUserSession().getPerson().getName(), PurapConstants.PurchaseOrderStatuses.NODE_DOCUMENT_TRANSMISSION, systemUserPerson, getOleSelectDocumentService().getSelectParameterValue(OLEConstants.SYSTEM_USER));
189 }
190 po.setOverrideWorkflowButtons(Boolean.TRUE);
191 if (!po.getApplicationDocumentStatus().equals(PurapConstants.PurchaseOrderStatuses.APPDOC_OPEN)) {
192 attemptSetupOfInitialOpenOfDocument(po);
193 }
194
195 purapService.saveDocumentNoValidation(po);
196 }
197
198 @Override
199 public void purchaseOrderFirstTransmitViaPrinting(String documentNumber, ByteArrayOutputStream baosPDF) {
200 PurchaseOrderDocument po = getPurchaseOrderByDocumentNumber(documentNumber);
201 String environment = kualiConfigurationService.getPropertyValueAsString(OLEConstants.ENVIRONMENT_KEY);
202 Collection<String> generatePDFErrors = printService.generatePurchaseOrderPdf(po, baosPDF, environment, null);
203 LOG.error("PDF Errors" + generatePDFErrors);
204 if (!generatePDFErrors.isEmpty()) {
205 addStringErrorMessagesToMessageMap(PurapKeyConstants.ERROR_PURCHASE_ORDER_PDF, generatePDFErrors);
206 throw new ValidationException("printing purchase order for first transmission failed");
207 }
208 }
209
210
211
212
213
214
215
216
217 @Override
218 protected void attemptSetupOfInitialOpenOfDocument(PurchaseOrderDocument po) {
219 if (LOG.isDebugEnabled()) {
220 LOG.debug("attemptSetupOfInitialOpenOfDocument() started using document with doc id " + po.getDocumentNumber());
221 }
222
223 if (!PurchaseOrderStatuses.APPDOC_OPEN.equals(po.getApplicationDocumentStatus())) {
224 if (OLEConstants.FinancialDocumentTypeCodes.PURCHASE_ORDER_AMENDMENT.equalsIgnoreCase(po.getDocumentHeader().getWorkflowDocument().getDocumentTypeName())) {
225 po.setPurchaseOrderInitialOpenTimestamp(null);
226 }
227 if (ObjectUtils.isNull(po.getPurchaseOrderInitialOpenTimestamp())) {
228 LOG.debug("attemptSetupOfInitialOpenOfDocument() setting initial open date on document");
229 po.setPurchaseOrderInitialOpenTimestamp(dateTimeService.getCurrentTimestamp());
230 } else {
231 throw new RuntimeException("Document does not have status code '" + PurchaseOrderStatuses.APPDOC_OPEN + "' on it but value of initial open date is " + po.getPurchaseOrderInitialOpenTimestamp());
232 }
233 if (LOG.isDebugEnabled()) {
234 LOG.debug("attemptSetupOfInitialOpenOfDocument() Setting po document id " + po.getDocumentNumber() + " status from '" + po.getApplicationDocumentStatus() + "' to '" + PurchaseOrderStatuses.APPDOC_OPEN + "'");
235 }
236 po.setApplicationDocumentStatus(PurchaseOrderStatuses.APPDOC_OPEN);
237
238 } else {
239 LOG.error("attemptSetupOfInitialOpenOfDocument() Found document already in '" + PurchaseOrderStatuses.APPDOC_OPEN + "' status for PO#" + po.getPurapDocumentIdentifier() + "; will not change or update");
240 }
241 }
242
243
244 @Override
245 public void setStatusCompletePurchaseOrderAmendment(PurchaseOrderDocument poa) {
246
247 LOG.debug("setStatusCompletePurchaseOrderAmendment() started");
248 setupDocumentForPendingFirstTransmission(poa);
249 if (!PurchaseOrderStatuses.STATUSES_BY_TRANSMISSION_TYPE.values().contains(poa.getApplicationDocumentStatus())) {
250 attemptSetupOfInitialOpenOfDocument(poa);
251 } else if (PurchaseOrderStatuses.APPDOC_PENDING_PRINT.equals(poa.getApplicationDocumentStatus())) {
252
253 String userToRouteFyi = poa.getDocumentHeader().getWorkflowDocument().getRoutedByPrincipalId();
254
255
256
257
258
259
260
261
262 poa.getDocumentHeader().getWorkflowDocument().adHocToPrincipal(ActionRequestType.FYI, poa.getDocumentHeader().getWorkflowDocument().getCurrentNodeNames().iterator().next(), "This POA is ready for printing and distribution.", userToRouteFyi, "", true, "PRINT");
263 }
264 }
265
266 @Override
267 public void completePurchaseOrderAmendment(PurchaseOrderDocument poa) {
268 LOG.debug("completePurchaseOrderAmendment() started");
269
270 setCurrentAndPendingIndicatorsForApprovedPODocuments(poa);
271
272 if (SpringContext.getBean(PaymentRequestService.class).hasActivePaymentRequestsForPurchaseOrder(poa.getPurapDocumentIdentifier())) {
273 poa.setPaymentRequestPositiveApprovalIndicator(true);
274 poa.setReceivingDocumentRequiredIndicator(false);
275 }
276
277 else if (!poa.isReceivingDocumentRequiredIndicator()) {
278 setReceivingRequiredIndicatorForPurchaseOrder(poa);
279 }
280
281
282
283
284
285 DocumentRouteHeaderValue routeHeader = SpringContext.getBean(RouteHeaderService.class).getRouteHeader(poa.getDocumentNumber());
286 String status = routeHeader.getDocRouteStatus();
287 if (status.equals(KewApiConstants.ROUTE_HEADER_PROCESSED_CD)) {
288 List<PurApItem> items = poa.getItems();
289 for (PurApItem item : items) {
290 initiateTransmission(poa, item);
291 }
292
293 }
294
295 }
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318 @Override
319 public PurchaseOrderDocument createPurchaseOrderDocument(RequisitionDocument reqDocument, String newSessionUserId, Integer contractManagerCode) {
320 try {
321 LogicContainer logicToRun = new LogicContainer() {
322 @Override
323 public Object runLogic(Object[] objects) throws Exception {
324 RequisitionDocument doc = (RequisitionDocument) objects[0];
325 PurchaseOrderDocument po = generatePurchaseOrderFromRequisition(doc);
326 Integer cmCode = (Integer) objects[1];
327 po.setContractManagerCode(cmCode);
328 String paramName = PurapParameterConstants.DEFAULT_B2B_VENDOR_CHOICE;
329 String paramValue = SpringContext.getBean(ParameterService.class).getParameterValueAsString(PurchaseOrderDocument.class, paramName);
330 po.setPurchaseOrderVendorChoiceCode(paramValue);
331 purapService.saveDocumentNoValidation(po);
332 return po;
333 }
334 };
335 return (PurchaseOrderDocument) purapService.performLogicWithFakedUserSession(newSessionUserId, logicToRun, new Object[]{reqDocument, contractManagerCode});
336 } catch (WorkflowException e) {
337 String errorMsg = "Workflow Exception caught: " + e.getLocalizedMessage();
338 LOG.error(errorMsg, e);
339 throw new RuntimeException(errorMsg, e);
340 } catch (Exception e) {
341 throw new RuntimeException(e);
342 }
343 }
344
345 public String createPurchaseOrderAmendmentDocument(OlePurchaseOrderDocument olePurchaseOrderDocument,String docNumber) {
346 String errorString = null;
347 String newStatus = PurapConstants.PurchaseOrderStatuses.APPDOC_AMENDMENT;
348 String annotation = "Amended in batch by PO document "+olePurchaseOrderDocument.getDocumentNumber()+" and POBA document "+docNumber;
349 String documentType = "OLE_POA";
350
351 createNoteForAutoCloseOrders(olePurchaseOrderDocument, annotation);
352 try {
353 synchronized (this) {
354 createAndRoutePotentialChangeDocument(olePurchaseOrderDocument, documentType, annotation, null, newStatus);
355 }
356
357 } catch (Exception e) {
358 Map<String, AutoPopulatingList<ErrorMessage>> errorMessages = GlobalVariables.getMessageMap().getErrorMessages();
359 for (Iterator<String> errorMessageIterator = errorMessages.keySet().iterator(); errorMessageIterator.hasNext(); ) {
360 String errorKey = errorMessageIterator.next();
361 AutoPopulatingList<ErrorMessage> errorList = errorMessages.get(errorKey);
362 for (ErrorMessage errorMessage : errorList) {
363 if(StringUtils.isNotEmpty(errorString)){
364 errorString += MessageFormat.format(kualiConfigurationService.getPropertyValueAsString(errorMessage.getErrorKey()), errorMessage.getMessageParameters());
365 errorString += "\n";
366 }else{
367 errorString = MessageFormat.format(kualiConfigurationService.getPropertyValueAsString(errorMessage.getErrorKey()), errorMessage.getMessageParameters());
368 errorString += "\n";
369 }
370 }
371
372 }
373 GlobalVariables.getMessageMap().clearErrorMessages();
374 }
375 return errorString;
376
377 }
378
379 public boolean getIsATypeOfRCVGDoc() {
380 return false;
381 }
382
383 public boolean getIsATypeOfCORRDoc() {
384 return false;
385 }
386
387 public OleSelectDocumentService getOleSelectDocumentService() {
388 if(oleSelectDocumentService == null){
389 oleSelectDocumentService = SpringContext.getBean(OleSelectDocumentService.class);
390 }
391 return oleSelectDocumentService;
392 }
393
394 public void setOleSelectDocumentService(OleSelectDocumentService oleSelectDocumentService) {
395 this.oleSelectDocumentService = oleSelectDocumentService;
396 }
397
398 }