1 package org.kuali.ole.deliver.batch;
2
3
4 import org.apache.commons.lang.StringUtils;
5 import org.apache.log4j.Logger;
6 import org.kuali.ole.DocumentUniqueIDPrefix;
7 import org.kuali.ole.OLEConstants;
8 import org.kuali.ole.deliver.bo.OleCirculationDesk;
9 import org.kuali.ole.deliver.bo.OleRecentlyReturned;
10 import org.kuali.ole.deliver.processor.LoanProcessor;
11 import org.kuali.ole.docstore.common.client.DocstoreClientLocator;
12 import org.kuali.ole.docstore.common.document.ItemOleml;
13 import org.kuali.ole.docstore.common.search.SearchResponse;
14 import org.kuali.ole.docstore.common.search.SearchResult;
15 import org.kuali.ole.docstore.common.search.SearchResultField;
16 import org.kuali.ole.docstore.common.document.content.instance.Item;
17 import org.kuali.ole.sys.context.SpringContext;
18 import org.kuali.rice.core.api.config.property.ConfigContext;
19 import org.kuali.rice.krad.service.BusinessObjectService;
20 import org.kuali.rice.krad.service.KRADServiceLocator;
21 import java.text.DateFormat;
22 import java.text.SimpleDateFormat;
23 import java.util.Date;
24 import java.util.HashMap;
25 import java.util.concurrent.TimeUnit;
26
27
28
29
30
31
32
33
34 public class OleShelvingLagTime {
35
36 private static final Logger LOG = Logger.getLogger(OleShelvingLagTime.class);
37 private static final String solrMaxPageSize = ConfigContext.getCurrentContextConfig().getProperty(OLEConstants.OleCirculationDesk.SOLR_MAX_PAGE_SIZE);
38
39 private BusinessObjectService businessObjectService;
40
41 private DocstoreClientLocator docstoreClientLocator;
42
43 public DocstoreClientLocator getDocstoreClientLocator() {
44
45 if (docstoreClientLocator == null) {
46 docstoreClientLocator = SpringContext.getBean(DocstoreClientLocator.class);
47
48 }
49 return docstoreClientLocator;
50 }
51
52
53 public void updateStatusIntoAvailableAfterReShelving() throws Exception {
54 businessObjectService = getBusinessObjectService();
55 LoanProcessor loanProcessor = new LoanProcessor();
56 StringBuffer query = new StringBuffer("");
57 query.append("(ItemStatus_display:RECENTLY-RETURNED)");
58 org.kuali.ole.docstore.common.document.Item item = new ItemOleml();
59 org.kuali.ole.docstore.common.search.SearchParams search_Params = new org.kuali.ole.docstore.common.search.SearchParams();
60 SearchResponse searchResponse = null;
61 search_Params.getSearchConditions().add(search_Params.buildSearchCondition("", search_Params.buildSearchField(org.kuali.ole.docstore.common.document.content.enums.DocType.ITEM.getCode(), item.ITEM_STATUS, "RECENTLY-RETURNED"), ""));
62 search_Params.getSearchResultFields().add(search_Params.buildSearchResultField(org.kuali.ole.docstore.common.document.content.enums.DocType.ITEM.getCode(), "id"));
63 if (StringUtils.isNotBlank(solrMaxPageSize)) {
64 search_Params.setPageSize(Integer.parseInt(solrMaxPageSize));
65 }
66 searchResponse = getDocstoreClientLocator().getDocstoreClient().search(search_Params);
67 for (SearchResult searchResult : searchResponse.getSearchResults()) {
68 for (SearchResultField searchResultField : searchResult.getSearchResultFields()) {
69 String fieldName = searchResultField.getFieldName();
70 String fieldValue = searchResultField.getFieldValue() != null ? searchResultField.getFieldValue() : "";
71 if (fieldName.equalsIgnoreCase("id") && !fieldValue.isEmpty() && searchResultField.getDocType().equalsIgnoreCase("item")) {
72 String itemUUID = DocumentUniqueIDPrefix.getDocumentId(fieldValue);
73 HashMap<String, String> map = new HashMap<String, String>();
74 map.put("itemUuid", itemUUID);
75 OleRecentlyReturned oleRecentlyReturned = businessObjectService.findByPrimaryKey(OleRecentlyReturned.class, map);
76 if (oleRecentlyReturned != null) {
77 map = new HashMap<String, String>();
78 map.put("circulationDeskId", oleRecentlyReturned.getCirculationDeskId());
79 OleCirculationDesk oleCirculationDesk = businessObjectService.findByPrimaryKey(OleCirculationDesk.class, map);
80 if (oleCirculationDesk != null) {
81 Integer shelvingLagTime = Integer.parseInt(oleCirculationDesk.getShelvingLagTime());
82 if (LOG.isDebugEnabled()){
83 LOG.debug("shelvingLagTime" + shelvingLagTime);
84 }
85 String itemXml = loanProcessor.getItemXML(itemUUID);
86 Item oleItem = loanProcessor.getItemPojo(itemXml);
87 String dateString = oleItem.getItemStatusEffectiveDate();
88 DateFormat formatter = new SimpleDateFormat(OLEConstants.DAT_FORMAT_EFFECTIVE_NOTICE);
89 Date checkInDate = (Date) formatter.parse(dateString);
90 String diff = getMinuteDiff(checkInDate, new Date());
91 Integer diffTime = Integer.parseInt(diff);
92 if (LOG.isDebugEnabled()){
93 LOG.debug("diffTime" + diffTime);
94 LOG.debug("shelvingLagTime.compareTo(diffTime)" + shelvingLagTime.compareTo(diffTime));
95 }
96 if (shelvingLagTime.compareTo(diffTime) <= 0) {
97 loanProcessor.updateItemStatus(oleItem, OLEConstants.NOT_CHECK_OUT_STATUS);
98 businessObjectService.delete(oleRecentlyReturned);
99 }
100 }
101 }
102 }
103
104 }
105 }
106 }
107
108
109 private String getMinuteDiff(Date dateOne, Date dateTwo) {
110 String diff = "";
111 long timeDiff = Math.abs(dateOne.getTime() - dateTwo.getTime());
112 diff = String.format("%d", TimeUnit.MILLISECONDS.toMinutes(timeDiff),
113 -TimeUnit.MINUTES.toSeconds(timeDiff));
114 return diff;
115 }
116
117 public BusinessObjectService getBusinessObjectService() {
118 if (businessObjectService == null) {
119 businessObjectService = KRADServiceLocator.getBusinessObjectService();
120 }
121 return businessObjectService;
122 }
123 }