Subversion Repositories SmartDukaan

Rev

Rev 19034 | Rev 19052 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
493 rajveer 1
package in.shop2020.hotspot.dashbaord.server;
2
 
19015 manish.sha 3
import in.shop2020.hotspot.dashbaord.server.OrderPromisedShippingComparator;
493 rajveer 4
import in.shop2020.hotspot.dashbaord.shared.actions.Order;
19032 manish.sha 5
import in.shop2020.hotspot.dashbaord.shared.actions.OrderAlert;
493 rajveer 6
import in.shop2020.hotspot.dashbaord.shared.actions.OrderType;
2697 chandransh 7
import in.shop2020.hotspot.dashbaord.shared.actions.ReturnOrder;
5945 mandeep.dh 8
import in.shop2020.model.v1.inventory.InventoryType;
18100 manish.sha 9
import in.shop2020.model.v1.inventory.WarehouseType;
5110 mandeep.dh 10
import in.shop2020.model.v1.catalog.Item;
11
import in.shop2020.model.v1.catalog.ItemType;
5945 mandeep.dh 12
import in.shop2020.model.v1.inventory.Warehouse;
914 chandransh 13
import in.shop2020.model.v1.order.LineItem;
7422 rajveer 14
import in.shop2020.model.v1.order.OrderSource;
493 rajveer 15
import in.shop2020.model.v1.order.OrderStatus;
16
import in.shop2020.model.v1.order.TransactionService.Client;
19050 manish.sha 17
import in.shop2020.hotspot.dashbaord.server.EhcacheWrapper;
5110 mandeep.dh 18
import in.shop2020.thrift.clients.CatalogClient;
5948 mandeep.dh 19
import in.shop2020.thrift.clients.InventoryClient;
3132 rajveer 20
import in.shop2020.thrift.clients.TransactionClient;
13146 manish.sha 21
import in.shop2020.thrift.clients.LogisticsClient;
493 rajveer 22
 
4411 rajveer 23
import java.io.ByteArrayOutputStream;
24
import java.io.File;
25
import java.io.FileNotFoundException;
26
import java.io.FileOutputStream;
27
import java.io.IOException;
18938 manish.sha 28
import java.text.DecimalFormat;
29
import java.text.NumberFormat;
493 rajveer 30
import java.util.ArrayList;
4411 rajveer 31
import java.util.Calendar;
19004 manish.sha 32
import java.util.Collections;
493 rajveer 33
import java.util.Date;
4411 rajveer 34
import java.util.GregorianCalendar;
35
import java.util.HashMap;
493 rajveer 36
import java.util.List;
4411 rajveer 37
import java.util.Map;
19004 manish.sha 38
import java.util.Map.Entry;
493 rajveer 39
 
19050 manish.sha 40
import net.sf.ehcache.CacheManager;
41
 
4411 rajveer 42
import org.slf4j.Logger;
43
import org.slf4j.LoggerFactory;
44
 
19017 manish.sha 45
import com.google.gwt.i18n.client.DateTimeFormat;
46
 
2449 chandransh 47
/**
48
 * This class is a facade to the Transaction service and should be used to
4133 chandransh 49
 * access all order specific data which requires some kind of transformation.
2449 chandransh 50
 * 
51
 * @author Chandranshu
52
 * 
53
 */
493 rajveer 54
public class TransactionUtils {
4411 rajveer 55
	private static String courierDetailsPath = "/CourierDetailReports";
56
	private static Logger logger = LoggerFactory.getLogger(TransactionUtils.class);
57
 
2449 chandransh 58
	/**
59
	 * The human user is concerned only with a consolidated view of actionable
60
	 * orders. Orders with different statuses in the database can be part of the
61
	 * same consolidated view. This method uses a mapping of <i>type</i> to
62
	 * <i>status</i> to get all such orders and return them as order beans.
63
	 * 
64
	 * @param type
65
	 *            The type of orders to return.
4133 chandransh 66
	 * @param offset
67
	 *            Offset to start from
68
	 * @param limit
69
	 *            No. of orders to return
2449 chandransh 70
	 * @param warehouseId
71
	 *            The warehouse for which the orders should be queried.
72
	 * @return A list of orders of the given type to be fulfilled from the given
73
	 *         warehouse
74
	 */
8303 amar.kumar 75
	public static List<Order> getOrders(OrderType type, long offset, long limit, long warehouseId, long source){
2449 chandransh 76
		List<OrderStatus> statuses = getStatuses(type);
493 rajveer 77
 
78
		List<Order> orders = new ArrayList<Order>();
79
		try{
4133 chandransh 80
			TransactionClient txnClient = new TransactionClient();
81
			Client client = txnClient.getClient();
493 rajveer 82
 
83
			List<in.shop2020.model.v1.order.Order> t_orders = new ArrayList<in.shop2020.model.v1.order.Order>();
19004 manish.sha 84
			if(type==OrderType.NEW || type==OrderType.ALL_PENDING || type ==OrderType.LOW_INVENTORY || type == OrderType.PO_RAISED
85
					|| type == OrderType.REVERSAL_INITIATED || type == OrderType.NOT_AVAILABLE){
86
				t_orders.addAll(client.getOrdersInBatchAsPromisedShipping(statuses, offset, limit, warehouseId, source));
87
			}else{
88
				t_orders.addAll(client.getOrdersInBatch(statuses, offset, limit, warehouseId, source));
89
			}
493 rajveer 90
 
91
			for (in.shop2020.model.v1.order.Order t_order: t_orders){
671 chandransh 92
				Order o = getOrderFromThriftOrder(t_order);
493 rajveer 93
				orders.add(o);
94
			}
19004 manish.sha 95
			if(type==OrderType.NEW || type==OrderType.ALL_PENDING || type ==OrderType.LOW_INVENTORY || type == OrderType.PO_RAISED
96
					|| type == OrderType.REVERSAL_INITIATED || type == OrderType.NOT_AVAILABLE){
97
				Map<Long, List<Order>> transactionOrdersMap = new HashMap<Long, List<Order>>();
98
				for(Order order : orders){
99
					if(transactionOrdersMap.containsKey(order.getTransactionId())){
100
						List<Order> txnOrders = transactionOrdersMap.get(order.getTransactionId());
101
						txnOrders.add(order);
102
						transactionOrdersMap.put(order.getTransactionId(), txnOrders);
103
					}else{
104
						List<Order> txnOrders = new ArrayList<Order>();
105
						txnOrders.add(order);
106
						transactionOrdersMap.put(order.getTransactionId(), txnOrders);
107
					}
108
				}
109
 
110
				orders = new ArrayList<Order>();
111
				for(Entry<Long, List<Order>> entry : transactionOrdersMap.entrySet()){
112
					List<Order> txnOrders = entry.getValue();
113
					Collections.sort(txnOrders,new OrderPromisedShippingComparator());
114
					transactionOrdersMap.put(entry.getKey(), txnOrders);
115
				}
116
 
117
				for(Entry<Long, List<Order>> entry : transactionOrdersMap.entrySet()){
118
					orders.addAll(entry.getValue());
119
				}
120
			}
121
 
493 rajveer 122
		}catch(Exception e){
2449 chandransh 123
			e.printStackTrace();
493 rajveer 124
		}
125
		return orders;
126
	}
127
 
2449 chandransh 128
	/**
4133 chandransh 129
	 * Wrapper around the method of same name in the transaction service. This
130
	 * method uses a mapping of <i>type</i> to <i>status</i> to get the count of
131
	 * all orders with a given status.
132
	 * 
133
	 * @param type
134
	 *            The type of orders to return.
135
	 * @param warehouseId
136
	 *            The warehouse for which the orders should be queried.
137
	 * @return The count of orders of the given type assigned to the given
138
	 *         warehouse.
139
	 */
8303 amar.kumar 140
	public static int getOrderCount(OrderType type, long warehouseId, long source){
4133 chandransh 141
		List<OrderStatus> statuses = getStatuses(type);
142
 
143
		int count = 0;
144
		try{
145
			TransactionClient txnClient = new TransactionClient();
146
			Client client = txnClient.getClient();
8303 amar.kumar 147
			count += client.getOrderCount(statuses, warehouseId, source);
4133 chandransh 148
		}catch(Exception e){
149
			e.printStackTrace();
150
		}
151
		return count;
152
	}
153
 
154
	/**
2449 chandransh 155
	 * Calls the same method of the transaction service and returns the status
156
	 * returned. Catches all exceptions that are raised and returns false in
157
	 * that case.
158
	 * 
159
	 * @param warehouseId
160
	 *            The warehouse for which the orders should be marked as
161
	 *            manifested.
162
	 * @param providerId
163
	 *            The provider for which the orders should be marked as
164
	 *            manifested.
3065 chandransh 165
	 * @param cod
166
	 *             Whether cod orders have to be marked as manifested
2449 chandransh 167
	 * @return True if everything goes fine, false otherwise.
168
	 */
5769 rajveer 169
	public static Map<Long, Long> getBilledOrders(long warehouseId, String providerId, boolean cod){
170
		Map<Long, Long> orders = new HashMap<Long, Long>();
760 chandransh 171
		try {
172
			long provider_id = Long.parseLong(providerId);
3132 rajveer 173
			TransactionClient client = new TransactionClient();
760 chandransh 174
			Client c = client.getClient();
4790 rajveer 175
 
176
			List<OrderStatus> statuses = new ArrayList<OrderStatus>();
177
			statuses.add(OrderStatus.BILLED);
8303 amar.kumar 178
			List<in.shop2020.model.v1.order.Order> torders = c.getOrdersInBatch(statuses, 0, 0, warehouseId, 0);
4790 rajveer 179
			for(in.shop2020.model.v1.order.Order torder: torders){
5556 rajveer 180
				if(torder.getLogistics_provider_id() == provider_id && torder.isLogisticsCod() == cod){
5769 rajveer 181
					orders.put(torder.getId(), torder.getPickupStoreId());
4790 rajveer 182
				}
4411 rajveer 183
			}
184
 
760 chandransh 185
		}catch(Exception e){
186
			e.printStackTrace();
187
		}
4790 rajveer 188
		return orders;
760 chandransh 189
	}
2449 chandransh 190
 
4790 rajveer 191
	public static boolean generateCourierDetailsFile(List<Long> orderIds, long providerId, long warehouseId, boolean isCod){
4411 rajveer 192
		Calendar date = new GregorianCalendar();
193
		int year = date.get(Calendar.YEAR);
194
		int month = date.get(Calendar.MONTH) +1;
195
		int day = date.get(Calendar.DAY_OF_MONTH);
196
 
197
		String fileNameSuffix = "-" + warehouseId + "-"+ providerId + "-" + year + "-" + month + "-" + day;
198
		if(isCod){
199
		    fileNameSuffix = "cod" + fileNameSuffix ;
200
		}
201
		else{
202
		    fileNameSuffix = "prepaid" + fileNameSuffix;
203
		}
204
 
205
		try {
4790 rajveer 206
			String fileName = courierDetailsPath + "/courier-details-" + fileNameSuffix + "-temp.xls";
4415 rajveer 207
			FileOutputStream f = new FileOutputStream(fileName);
4411 rajveer 208
			CourierDetailsGenerator courierDetailsGenerator = new CourierDetailsGenerator();
4790 rajveer 209
			ByteArrayOutputStream baosXLS = courierDetailsGenerator.generateCourierDetails(orderIds, warehouseId, providerId, isCod);
4411 rajveer 210
			baosXLS.writeTo(f);
211
			f.close();
212
		} catch (FileNotFoundException e) {
213
			logger.error("Unable to create the courier details file", e);
214
		} catch (IOException e) {
215
			logger.error("Unable to create the courier details file", e);
216
		}
217
 
218
		CourierDetailsReportMerger merger = new CourierDetailsReportMerger();
219
		try {
220
			Map<Long, String> warehouseIdFileNames = new HashMap<Long, String>();
4790 rajveer 221
			String fName;
222
			fName = courierDetailsPath + "/courier-details-" + fileNameSuffix + "-temp.xls";
223
			if((new File(fName)).exists()){
224
				warehouseIdFileNames.put(0L, fName);
4411 rajveer 225
			}
4790 rajveer 226
			fName = courierDetailsPath + "/courier-details-" + fileNameSuffix + ".xls";
227
			if((new File(fName)).exists()){
228
				warehouseIdFileNames.put(1L, fName);
4411 rajveer 229
			}
4790 rajveer 230
			ByteArrayOutputStream binXLS = merger.mergeCourierDetailsReports(warehouseIdFileNames);
231
			FileOutputStream f = new FileOutputStream(courierDetailsPath + "/courier-details-" + fileNameSuffix + ".xls");
4411 rajveer 232
			binXLS.writeTo(f);
233
			f.close();
4790 rajveer 234
			File tempFile = new File(courierDetailsPath + "/courier-details-" + fileNameSuffix + "-temp.xls");
235
			if(tempFile.exists()){
236
				tempFile.delete();
237
			}
4411 rajveer 238
		} catch (FileNotFoundException e) {
239
			logger.error("Error while creating the Courier Details report", e);
240
		} catch (IOException e) {
241
			logger.error("IO error while writing the Courier Details report", e);
242
		}
243
		return true;
244
	}
245
 
671 chandransh 246
	/**
2449 chandransh 247
	 * 
671 chandransh 248
	 * @param t_order
2449 chandransh 249
	 *            A thrift order object with line items.
250
	 * @return an Order bean which can be used for rendering on the client side.
671 chandransh 251
	 */
252
	public static Order getOrderFromThriftOrder(in.shop2020.model.v1.order.Order t_order) {
914 chandransh 253
		LineItem lineItem = t_order.getLineitems().get(0);
5110 mandeep.dh 254
		String pickFromWarehouse = null;
255
		Item item = null;
19004 manish.sha 256
		String warehouseType = "";
13146 manish.sha 257
 
258
	    Map<Long, Map<String, String>> acceptTogetherOrdersMap = null;
259
	    Map<Long, Map<String, String>> billTogetherOrdersMap = null;
5110 mandeep.dh 260
 
261
        try {
5945 mandeep.dh 262
            in.shop2020.model.v1.catalog.CatalogService.Client client = new CatalogClient().getClient();
5948 mandeep.dh 263
            in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = new InventoryClient().getClient();
5110 mandeep.dh 264
            item = client.getItem(lineItem.getItem_id());
265
            pickFromWarehouse = CatalogUtils.getWarehousesForBillingWarehouse(t_order.getWarehouse_id())
266
                                    .get(t_order.getFulfilmentWarehouseId());
267
 
268
            if (pickFromWarehouse == null) {
5948 mandeep.dh 269
                Warehouse warehouse = inventoryClient.getWarehouse(t_order.getFulfilmentWarehouseId());
270
                pickFromWarehouse = inventoryClient.getWarehouses(null, InventoryType.GOOD, warehouse.getVendor().getId(), t_order.getWarehouse_id(), 0).get(0).getDisplayName();
13146 manish.sha 271
            }											
272
            if(!t_order.isSetAccepted_timestamp()){
273
            	acceptTogetherOrdersMap = new HashMap<Long, Map<String, String>>();
274
            	Map<String, String> orderValuesMap = new HashMap<String, String>();
275
            	orderValuesMap.put("ProductName", getItemDisplayName(lineItem));
276
				orderValuesMap.put("Quantity", lineItem.getQuantity()+"");
18100 manish.sha 277
				if(!inventoryClient.isAlive()){
278
					inventoryClient = new InventoryClient().getClient();
279
				}
280
				Warehouse fulfillmentWarehouse = inventoryClient.getWarehouse(t_order.getFulfilmentWarehouseId());
19004 manish.sha 281
				warehouseType = fulfillmentWarehouse.getWarehouseType().toString();
18100 manish.sha 282
				orderValuesMap.put("WarehouseType", fulfillmentWarehouse.getWarehouseType().toString());
19017 manish.sha 283
				DateTimeFormat sdf = DateTimeFormat.getFormat("EEE MMM dd HH:mm:ss yyyy");
18938 manish.sha 284
				orderValuesMap.put("Promised_Shipping", sdf.format(new Date(t_order.getPromised_shipping_time())));
18964 manish.sha 285
				NumberFormat formatter = new DecimalFormat("#0.000");     
286
				orderValuesMap.put("Weight", formatter.format(t_order.getLineitems().get(0).getUnit_weight()));
287
				formatter = new DecimalFormat("#0.00");   
18938 manish.sha 288
				orderValuesMap.put("UnitPrice", formatter.format(t_order.getLineitems().get(0).getUnit_price()));
18964 manish.sha 289
				orderValuesMap.put("PackQuantity", item.getPackQuantity()+"");
13146 manish.sha 290
				acceptTogetherOrdersMap.put(t_order.getId(), orderValuesMap);
291
            	List<in.shop2020.model.v1.order.Order> taOrders = new TransactionClient().getClient().getOrdersForTransaction(t_order.getTransactionId(), t_order.getCustomer_id());
292
            	in.shop2020.logistics.Provider provider = new LogisticsClient().getClient().getProvider(t_order.getLogistics_provider_id());
293
            	for(in.shop2020.model.v1.order.Order taOrder : taOrders){
294
            		LineItem lineItem1 = taOrder.getLineitems().get(0);
295
            		if(t_order.getId()==taOrder.getId()){
296
            			continue;
13156 manish.sha 297
            		}
298
            		else if(taOrder.getSource()!=OrderSource.WEBSITE.getValue()){
299
            			continue;
300
            		}
301
            		else{
13146 manish.sha 302
            			orderValuesMap = new HashMap<String, String>();
13323 manish.sha 303
            			if(provider.isGroupShipmentAllowed() && !taOrder.isSetAccepted_timestamp() && t_order.getStatus()==taOrder.getStatus() 
304
            					&& taOrder.getLogistics_provider_id()==t_order.getLogistics_provider_id() 
305
            					&& taOrder.isLogisticsCod()==t_order.isLogisticsCod() && taOrder.getWarehouse_id() == t_order.getWarehouse_id() 
306
            					&& taOrder.getOrderType() == t_order.getOrderType() && taOrder.getPickupStoreId() == t_order.getPickupStoreId()){
13146 manish.sha 307
            				orderValuesMap.put("ProductName", getItemDisplayName(lineItem1));
308
            				orderValuesMap.put("Quantity", lineItem1.getQuantity()+"");
18100 manish.sha 309
            				if(!inventoryClient.isAlive()){
310
            					inventoryClient = new InventoryClient().getClient();
311
            				}
312
            				fulfillmentWarehouse = inventoryClient.getWarehouse(taOrder.getFulfilmentWarehouseId());
313
            				orderValuesMap.put("WarehouseType", fulfillmentWarehouse.getWarehouseType().toString());
18938 manish.sha 314
            				orderValuesMap.put("Promised_Shipping", sdf.format(new Date(taOrder.getPromised_shipping_time())));
315
            				orderValuesMap.put("UnitPrice", formatter.format(taOrder.getLineitems().get(0).getUnit_price()));
18964 manish.sha 316
            				formatter = new DecimalFormat("#0.000");   
317
            				orderValuesMap.put("Weight", formatter.format(taOrder.getLineitems().get(0).getUnit_weight()));
318
            				Item orderItem = client.getItem(taOrder.getLineitems().get(0).getItem_id());
319
            				orderValuesMap.put("PackQuantity", orderItem.getPackQuantity()+"");
13146 manish.sha 320
            			}
321
            			if(orderValuesMap!=null && orderValuesMap.size()>0){
322
            				acceptTogetherOrdersMap.put(taOrder.getId(), orderValuesMap);
323
            			}
324
            		}
325
            	}
5110 mandeep.dh 326
            }
13146 manish.sha 327
 
328
            if(t_order.isSetLogisticsTransactionId()){
329
            	billTogetherOrdersMap = new HashMap<Long, Map<String, String>>();
330
            	Map<String, String> orderValuesMap = new HashMap<String, String>();
18100 manish.sha 331
	            if(t_order.getStatus()==OrderStatus.ACCEPTED){
332
	            	orderValuesMap.put("ProductName", getItemDisplayName(lineItem));
333
	            	orderValuesMap.put("Quantity", lineItem.getQuantity()+"");
334
	            	if(ItemType.SERIALIZED==item.getType()){
335
	            		orderValuesMap.put("IsSerialized", "true");
336
	            	}else{
337
	            		orderValuesMap.put("IsSerialized", "false");
338
	            	}
339
	            	if(t_order.isSetFreebieItemId() && t_order.getFreebieItemId()!=0){
340
	            		orderValuesMap.put("IsFreebie", "true");
341
	            	} else {
342
	            		orderValuesMap.put("IsFreebie", "false");
343
	            	}
344
	            	billTogetherOrdersMap.put(t_order.getId(), orderValuesMap);
13146 manish.sha 345
            	}
346
            	Map<Long, Item> orderItemMap = new HashMap<Long, Item>();
347
            	List<in.shop2020.model.v1.order.Order> taOrders = new TransactionClient().getClient().getGroupOrdersByLogisticsTxnId(t_order.getLogisticsTransactionId());
348
            	for(in.shop2020.model.v1.order.Order ord1: taOrders){
18100 manish.sha 349
            		if(ord1.getStatus()==OrderStatus.ACCEPTED){
350
	            		if(ord1.getId()== t_order.getId()){
351
	            			orderItemMap.put(ord1.getId(), item);
352
	            		} else {
353
		            		if(!client.isAlive()){
354
		            			client = new CatalogClient().getClient();
355
		            		}
356
		            		Item it = client.getItem(ord1.getLineitems().get(0).getItem_id());
357
		            		orderItemMap.put(ord1.getId(), it);
13146 manish.sha 358
	            		}
359
            		}
360
            	}
361
 
362
            	for(in.shop2020.model.v1.order.Order taOrder: taOrders){
18100 manish.sha 363
            		if(taOrder.getStatus()==OrderStatus.ACCEPTED){
364
	            		if(taOrder.getId()==t_order.getId()){
365
	            			continue;
366
	            		} else {
367
	            			orderValuesMap = new HashMap<String, String>();
368
	            			Item orderItem = orderItemMap.get(taOrder.getId());
369
	            			orderValuesMap.put("ProductName", getProductName(orderItem));
370
	                    	orderValuesMap.put("Quantity", taOrder.getLineitems().get(0).getQuantity()+"");
371
	                    	if(ItemType.SERIALIZED==orderItem.getType()){
372
	                    		orderValuesMap.put("IsSerialized", "true");
373
	                    	}else{
374
	                    		orderValuesMap.put("IsSerialized", "false");
375
	                    	}
376
	                    	if(taOrder.isSetFreebieItemId() && taOrder.getFreebieItemId()!=0){
377
	                    		orderValuesMap.put("IsFreebie", "true");
378
	                    	} else {
379
	                    		orderValuesMap.put("IsFreebie", "false");
380
	                    	}
381
	                    	billTogetherOrdersMap.put(taOrder.getId(), orderValuesMap);
382
	            		}
13146 manish.sha 383
            		}
384
            	}
385
            }
386
            else{
387
            	billTogetherOrdersMap = new HashMap<Long, Map<String, String>>();
388
            	Map<String, String> orderValuesMap = new HashMap<String, String>();
389
            	orderValuesMap.put("ProductName", getItemDisplayName(lineItem));
390
            	orderValuesMap.put("Quantity", lineItem.getQuantity()+"");
391
            	if(ItemType.SERIALIZED==item.getType()){
392
            		orderValuesMap.put("IsSerialized", "true");
393
            	}else{
394
            		orderValuesMap.put("IsSerialized", "false");
395
            	}
396
            	if(t_order.isSetFreebieItemId() && t_order.getFreebieItemId()!=0){
397
            		orderValuesMap.put("IsFreebie", "true");
398
            	} else {
399
            		orderValuesMap.put("IsFreebie", "false");
400
            	}
401
            	billTogetherOrdersMap.put(t_order.getId(), orderValuesMap);
402
            }
5110 mandeep.dh 403
		}
404
        catch (Exception e) {
405
            logger.error("Error looking up warehouse: " + t_order.getVendorId(), e);
406
        }
407
 
3553 chandransh 408
		String delayReason = null;
409
		if(t_order.getDelayReason() != null)
7433 rajveer 410
		    delayReason = t_order.getDelayReason().name();
3553 chandransh 411
 
7556 rajveer 412
		String osource = OrderSource.findByValue((int)t_order.getSource()).toString();
7433 rajveer 413
 
966 chandransh 414
		Order order = new Order(t_order.getId(),
415
				t_order.getCustomer_id(),
416
				t_order.getCustomer_name(),
417
				t_order.getCustomer_mobilenumber(),
418
				t_order.getCustomer_pincode(),
419
				t_order.getCustomer_address1(),
420
				t_order.getCustomer_address2(),
421
				t_order.getCustomer_city(),
422
				t_order.getCustomer_state(),
423
				t_order.getCustomer_email(),
424
				t_order.getCreated_timestamp(),
4004 chandransh 425
				t_order.getShipping_timestamp(),
426
				t_order.getVerification_timestamp(),
966 chandransh 427
				t_order.getExpected_delivery_time(),
3994 chandransh 428
				t_order.getPromised_delivery_time(),
4004 chandransh 429
				t_order.getExpected_shipping_time(),
4666 rajveer 430
				t_order.getPromised_shipping_time(),
966 chandransh 431
				t_order.getStatus().getValue(),
432
				t_order.getStatusDescription(),
5527 anupam.sin 433
				t_order.getOrderType().name(),
966 chandransh 434
				lineItem.getItem_id(),
435
				lineItem.getProductGroup(),
436
				lineItem.getBrand(),
437
				lineItem.getModel_name(),
438
				lineItem.getModel_number(),
439
				lineItem.getColor(),
440
				lineItem.getExtra_info(),
4172 rajveer 441
				lineItem.getDealText(),
5387 rajveer 442
				lineItem.getQuantity(),
2782 chandransh 443
				t_order.getTotal_amount(),
444
				t_order.getTotal_weight(),
445
				t_order.getAirwaybill_no(),
446
				t_order.getBilled_by(),
447
				t_order.getInvoice_number(),
448
				t_order.getJacket_number(),
449
				lineItem.getItem_number(),
4659 mandeep.dh 450
				lineItem.getSerial_number(),
3065 chandransh 451
				t_order.getBatchNo(),
452
				t_order.getSerialNo(),
2509 chandransh 453
				t_order.isDoaFlag(),
3065 chandransh 454
				t_order.getPickupRequestNo(),
5556 rajveer 455
				t_order.isLogisticsCod(),
5110 mandeep.dh 456
				delayReason,
457
				pickFromWarehouse,
6028 rajveer 458
				ItemType.SERIALIZED.equals(item.getType()),
459
				item.isHasItemNo(),
5769 rajveer 460
				t_order.getFulfilmentWarehouseId(),
9263 amar.kumar 461
				t_order.getWarehouse_id(),
7190 amar.kumar 462
				t_order.getPickupStoreId(),
7422 rajveer 463
				t_order.getFreebieItemId(),
8717 amar.kumar 464
				osource, 
13146 manish.sha 465
				new Long(t_order.getProductCondition().getValue()),
466
				t_order.getTransactionId());
467
		if(acceptTogetherOrdersMap!=null && acceptTogetherOrdersMap.size()>0){
468
			order.setAcceptTogetherOrdersMap(acceptTogetherOrdersMap);
469
		}
470
		if(billTogetherOrdersMap!=null && billTogetherOrdersMap.size()>0){
471
			order.setBillTogetherOrdersMap(billTogetherOrdersMap);
472
		}
473
		if(t_order.isSetLogisticsTransactionId()){
474
			order.setLogisticsTransactionId(t_order.getLogisticsTransactionId());
475
		}
19032 manish.sha 476
		DateTimeFormat sdf = DateTimeFormat.getFormat("yyyy-MM-dd");
477
		Date date = new Date(System.currentTimeMillis());
478
		long currentDateTime = 0;
479
		long expectedDateShippingTime =0 ;
480
		long currentTime = date.getTime();
481
		currentDateTime = sdf.parse(sdf.format(date)).getTime();
482
		expectedDateShippingTime = sdf.parse(sdf.format(new Date(order.getExpectedShippingTime()))).getTime();
483
		if(expectedDateShippingTime >0 && order.getStatus() < 9){
484
			if(expectedDateShippingTime <= currentDateTime){
19050 manish.sha 485
				if(loadVirtualWarehouseDetails().contains(order.getFulfilmentWarehouseId())){
19032 manish.sha 486
					order.setAlert(OrderAlert.TODAY_SHIPPING_NOT_IN_STOCK);
487
				}else{
488
					order.setAlert(OrderAlert.TODAY_SHIPPING_IN_STOCK);
489
				}
490
			}else{
491
				if(order.getExpectedShippingTime() <= currentTime){
492
					order.setAlert(OrderAlert.SHIPPING_TIME_EXCEEDED);
493
				}else{
494
					order.setAlert(OrderAlert.LATER_SHIPPING);
495
				}
496
			}
497
		}
966 chandransh 498
		return order;
671 chandransh 499
	}
500
 
2449 chandransh 501
	/**
2697 chandransh 502
	 * Queries the transction server to get the list of all return orders that
503
	 * have to be processed.
504
	 * 
505
	 * @return A list of all return orders to be processed.
506
	 */
507
	public static List<ReturnOrder> getReturnOrders(long warehouseId){
508
		List<ReturnOrder> retOrders = new ArrayList<ReturnOrder>();
509
		try{
3132 rajveer 510
			TransactionClient client = new TransactionClient();
2697 chandransh 511
			Client c = client.getClient();
512
			List<in.shop2020.model.v1.order.ReturnOrder> tRetOrders =  c.getReturnOrders(warehouseId, 0L, new Date().getTime());
513
			for(in.shop2020.model.v1.order.ReturnOrder retOrder : tRetOrders){
514
				retOrders.add(getReturnOrderFromThriftRO(retOrder));
515
			}
516
		}catch(Exception e){
517
			e.printStackTrace();
518
		}
519
		return retOrders;
520
	}
521
 
2700 chandransh 522
	public static ReturnOrder getReturnOrderFromThriftRO(in.shop2020.model.v1.order.ReturnOrder tRetOrder){
523
		ReturnOrder retOrder = new ReturnOrder(tRetOrder.getOrderId(),
524
				tRetOrder.getWarehouseId(),
525
				tRetOrder.getItemId(),
526
				tRetOrder.getProductGroup(),
527
				tRetOrder.getBrand(),
528
				tRetOrder.getModelName(),
529
				tRetOrder.getModelNumber(),
530
				tRetOrder.getColor(),
531
				tRetOrder.getInvoiceNumber(),
532
				tRetOrder.getJacketNumber(),
533
				tRetOrder.getTotalPrice(),
534
				tRetOrder.getTransferPrice(),
535
				false,
536
				tRetOrder.getCreatedAt());
2697 chandransh 537
		return retOrder;
538
	}
539
 
540
	/**
2449 chandransh 541
	 * This method maps a given type to a list of statuses.
542
	 * 
543
	 * @param type
544
	 *            The type of orders to fetch.
545
	 * @return The list of Thrift statuses associated with a particular order
546
	 *         type.
547
	 */
4361 rajveer 548
	public static List<OrderStatus> getStatuses(OrderType type) {
2449 chandransh 549
		List<OrderStatus> statuses = new ArrayList<OrderStatus>();
550
 
551
		switch (type) {
552
		case ACCEPTED:
553
			statuses.add(OrderStatus.ACCEPTED);
554
			break;
555
 
4361 rajveer 556
		case ALL_PENDING:
557
			statuses.add(OrderStatus.SUBMITTED_FOR_PROCESSING);
4421 mandeep.dh 558
			statuses.add(OrderStatus.CAPTURE_IN_PROCESS);
4361 rajveer 559
			statuses.add(OrderStatus.INVENTORY_LOW);
560
			statuses.add(OrderStatus.LOW_INV_PO_RAISED);
561
			statuses.add(OrderStatus.LOW_INV_REVERSAL_IN_PROCESS);
562
			statuses.add(OrderStatus.LOW_INV_NOT_AVAILABLE_AT_HOTSPOT);
2449 chandransh 563
			break;
564
 
565
		case NEW:
566
			statuses.add(OrderStatus.SUBMITTED_FOR_PROCESSING);
4421 mandeep.dh 567
			statuses.add(OrderStatus.CAPTURE_IN_PROCESS);
2449 chandransh 568
			break;
569
 
570
		case BILLED:
571
			statuses.add(OrderStatus.BILLED);
572
			break;
573
 
4308 rajveer 574
		case LOW_INVENTORY:
2449 chandransh 575
			statuses.add(OrderStatus.INVENTORY_LOW);
576
			break;
4248 rajveer 577
 
4308 rajveer 578
		case PO_RAISED:
579
			statuses.add(OrderStatus.LOW_INV_PO_RAISED);
580
			break;
581
 
582
		case REVERSAL_INITIATED:
583
			statuses.add(OrderStatus.LOW_INV_REVERSAL_IN_PROCESS);
584
			break;
585
 
586
		case NOT_AVAILABLE:
587
			statuses.add(OrderStatus.LOW_INV_NOT_AVAILABLE_AT_HOTSPOT);
588
			break;
589
 
4248 rajveer 590
		case CANCEL_CONFIRMED:
591
			statuses.add(OrderStatus.CANCEL_REQUEST_CONFIRMED);
592
			break;
2449 chandransh 593
 
4459 rajveer 594
		case DOA_REQUEST_AUTHORIZED:
595
			statuses.add(OrderStatus.DOA_REQUEST_AUTHORIZED);
4515 mandeep.dh 596
			statuses.add(OrderStatus.DOA_PICKUP_REQUEST_RAISED);
4459 rajveer 597
			break;
598
 
4666 rajveer 599
		case LOST_IN_TRANSIT:
600
			statuses.add(OrderStatus.LOST_IN_TRANSIT);
601
			break;
602
 
4459 rajveer 603
		case DOA_LOST_IN_TRANSIT:
604
			statuses.add(OrderStatus.DOA_LOST_IN_TRANSIT);
4478 rajveer 605
			break;
606
 
607
		case DOA_RECEIVED_DAMAGED:
4459 rajveer 608
			statuses.add(OrderStatus.DOA_RECEIVED_DAMAGED);
609
			break;
4495 rajveer 610
 
611
		case RET_REQUEST_AUTHORIZED:
612
			statuses.add(OrderStatus.RET_REQUEST_AUTHORIZED);
4515 mandeep.dh 613
			statuses.add(OrderStatus.RET_PICKUP_REQUEST_RAISED);
4495 rajveer 614
			break;
615
 
616
		case RET_AWAITED:
617
			statuses.add(OrderStatus.RET_RETURN_IN_TRANSIT);
4515 mandeep.dh 618
			statuses.add(OrderStatus.RET_PICKUP_CONFIRMED);
4495 rajveer 619
			break;
4459 rajveer 620
 
4495 rajveer 621
		case RET_RECEIVED_PRESTINE:
622
			statuses.add(OrderStatus.RET_RECEIVED_PRESTINE);
4515 mandeep.dh 623
			statuses.add(OrderStatus.RET_PRODUCT_USABLE);
4495 rajveer 624
			break;
625
 
626
		case RET_LOST_IN_TRANSIT:
627
			statuses.add(OrderStatus.RET_LOST_IN_TRANSIT);
628
			break;
629
 
630
		case RET_RECEIVED_DAMAGED:
631
			statuses.add(OrderStatus.RET_RECEIVED_DAMAGED);
4515 mandeep.dh 632
			statuses.add(OrderStatus.RET_PRODUCT_UNUSABLE);
4495 rajveer 633
			break;
634
 
2449 chandransh 635
		case REJECTED:
636
			statuses.add(OrderStatus.REJECTED);
637
			break;
638
 
639
		case SHIPPED:
640
			statuses.add(OrderStatus.SHIPPED_FROM_WH);
641
			statuses.add(OrderStatus.SHIPPED_TO_LOGST);
5016 phani.kuma 642
			statuses.add(OrderStatus.SHIPPED_TO_DESTINATION_CITY);
643
			statuses.add(OrderStatus.REACHED_DESTINATION_CITY);
644
			statuses.add(OrderStatus.FIRST_DELIVERY_ATTEMPT_MADE);
2449 chandransh 645
			break;
646
 
647
		case DELIVERED:
648
			statuses.add(OrderStatus.DELIVERY_SUCCESS);
4452 rajveer 649
			statuses.add(OrderStatus.DOA_PICKUP_REQUEST_RAISED);
2449 chandransh 650
			break;
2610 chandransh 651
 
652
		case DOA_AWAITED:
4452 rajveer 653
			statuses.add(OrderStatus.DOA_PICKUP_CONFIRMED);
2610 chandransh 654
			statuses.add(OrderStatus.DOA_RETURN_IN_TRANSIT);
4452 rajveer 655
			statuses.add(OrderStatus.DOA_RECEIVED_PRESTINE);
2610 chandransh 656
			break;
2449 chandransh 657
 
4495 rajveer 658
		case RTO_AWAITED:
4484 rajveer 659
			statuses.add(OrderStatus.RTO_IN_TRANSIT);
2509 chandransh 660
			break;
661
 
4515 mandeep.dh 662
        case RTO_RECEIVED_DAMAGED:
663
            statuses.add(OrderStatus.RTO_RECEIVED_DAMAGED);
664
            break;
665
 
666
        case DOA_RECEIVED_PRESTINE:
2610 chandransh 667
			statuses.add(OrderStatus.DOA_CERT_VALID);
4515 mandeep.dh 668
			statuses.add(OrderStatus.DOA_CERT_INVALID);
2610 chandransh 669
			break;
670
 
4495 rajveer 671
		case RTO_RETURNED:
4484 rajveer 672
			statuses.add(OrderStatus.RTO_RECEIVED_PRESTINE);
2509 chandransh 673
			break;
674
 
2628 chandransh 675
		case RESHIPPED:
4484 rajveer 676
			statuses.add(OrderStatus.RTO_RESHIPPED);
2628 chandransh 677
			statuses.add(OrderStatus.DOA_INVALID_RESHIPPED);
4452 rajveer 678
			statuses.add(OrderStatus.DOA_VALID_RESHIPPED);
2628 chandransh 679
			break;
680
 
681
		case REFUNDED:
4682 rajveer 682
		    statuses.add(OrderStatus.COD_VERIFICATION_FAILED);
4484 rajveer 683
			statuses.add(OrderStatus.RTO_REFUNDED);
2628 chandransh 684
			statuses.add(OrderStatus.DOA_INVALID_REFUNDED);
685
			statuses.add(OrderStatus.DOA_VALID_REFUNDED);
4682 rajveer 686
			statuses.add(OrderStatus.CANCELLED_DUE_TO_LOW_INVENTORY);
2628 chandransh 687
			break;
2509 chandransh 688
 
3065 chandransh 689
		case VERIFICATION_PENDING:
4664 rajveer 690
		    statuses.add(OrderStatus.COD_VERIFICATION_PENDING);
3065 chandransh 691
		    break;
2449 chandransh 692
		default:
693
			break;
694
		}
695
		return statuses;
696
	}
13146 manish.sha 697
 
698
	public static List<Long> getEligibleOrdersToBeAccepted(Order order){
699
		List<Long> orders = new ArrayList<Long>();
700
		try {
701
 
702
			TransactionClient client = new TransactionClient();
703
			Client c = client.getClient();
704
 
705
			in.shop2020.model.v1.order.Order thriftOrder = c.getOrder(order.getOrderId());
706
			long provider_id = thriftOrder.getLogistics_provider_id();
707
			boolean cod = thriftOrder.isLogisticsCod();
708
 
709
			List<in.shop2020.model.v1.order.Order> torders = c.getOrdersForTransaction(thriftOrder.getTransactionId(), thriftOrder.getCustomer_id());
710
			for(in.shop2020.model.v1.order.Order torder: torders){
711
				if(torder.getLogistics_provider_id() == provider_id && torder.isLogisticsCod() == cod){
712
					orders.add(torder.getId());
713
				}
714
			}
715
 
716
		}catch(Exception e){
717
			e.printStackTrace();
718
		}
719
		return orders;
720
	}
721
 
722
	public static String getItemDisplayName(LineItem lineitem){
723
		StringBuffer itemName = new StringBuffer();
724
        if (lineitem.getBrand() != null)
725
            itemName.append(lineitem.getBrand() + " ");
726
        if (lineitem.getModel_name() != null)
727
            itemName.append(lineitem.getModel_name() + " ");
728
        if (lineitem.getModel_number() != null)
729
            itemName.append(lineitem.getModel_number() + " ");
730
        if (lineitem.getColor() != null
731
                && !lineitem.getColor().trim().equals("NA"))
732
            itemName.append("(" + lineitem.getColor() + ")");
733
 
734
        return itemName.toString();
735
	}
736
 
737
	public static String getProductName(in.shop2020.model.v1.catalog.Item item){
738
		StringBuffer itemName = new StringBuffer();
739
        if (item.getBrand() != null)
740
            itemName.append(item.getBrand() + " ");
741
        if (item.getModelName() != null)
742
            itemName.append(item.getModelName() + " ");
743
        if (item.getModelNumber() != null)
744
            itemName.append(item.getModelNumber() + " ");
745
        if (item.getColor() != null
746
                && !item.getColor().trim().equals("NA"))
747
            itemName.append("(" + item.getColor() + ")");
748
 
749
        return itemName.toString();
750
	}
19050 manish.sha 751
 
752
	public static List<Long> loadVirtualWarehouseDetails(){
753
		EhcacheWrapper<String, List<Long>> virtualWhCache = new EhcacheWrapper<String, List<Long>>(
754
				"VirtualWarehouses", CacheManager.create());
755
 
756
		List<Long> virtualWarehouseIds = virtualWhCache.get("virtual_warehouses");
757
 
758
		if(virtualWarehouseIds!=null && virtualWarehouseIds.size()>0){
759
			return virtualWarehouseIds;
760
		}else{
761
			virtualWarehouseIds = new ArrayList<Long>();
762
			try{
763
				in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = new InventoryClient().getClient();
764
				List<Warehouse> allWarehouses = inventoryClient.getWarehouses(null, null, 0, 0, 0);
765
				for(Warehouse wh:allWarehouses){
766
					if(wh.getWarehouseType()==WarehouseType.THIRD_PARTY){
767
						virtualWarehouseIds.add(wh.getId());
768
					}
769
				}
770
			}catch(Exception e){
771
				e.printStackTrace();
772
			}
773
			virtualWhCache.put("virtual_warehouses", virtualWarehouseIds);
774
		}
775
 
776
		return virtualWarehouseIds;
777
	}
493 rajveer 778
}