Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
8616 vikram.rag 1 
package in.shop2020;
2 
 
3 
import in.shop2020.model.v1.catalog.CatalogService;
8739 vikram.rag 4 
import in.shop2020.model.v1.catalog.SnapdealItem;
8616 vikram.rag 5 
import in.shop2020.model.v1.catalog.CatalogServiceException;
6 
import in.shop2020.model.v1.catalog.Item;
7 
import in.shop2020.model.v1.inventory.InventoryService;
8 
import in.shop2020.model.v1.inventory.InventoryServiceException;
9 
import in.shop2020.model.v1.inventory.VendorItemPricing;
10 
import in.shop2020.model.v1.inventory.Warehouse;
11 
import in.shop2020.model.v1.order.LineItem;
12 
import in.shop2020.model.v1.order.OrderStatus;
13 
import in.shop2020.model.v1.order.OrderType;
14 
import in.shop2020.model.v1.order.SnapdealOrder;
15 
import in.shop2020.model.v1.order.SourceDetail;
16 
import in.shop2020.model.v1.order.Transaction;
8651 vikram.rag 17 
import in.shop2020.model.v1.order.TransactionServiceException;
8616 vikram.rag 18 
import in.shop2020.model.v1.order.TransactionStatus;
19 
import in.shop2020.model.v1.order.TransactionService.Client;
20 
import in.shop2020.model.v1.user.User;
21 
import in.shop2020.payments.PaymentException;
22 
import in.shop2020.payments.PaymentStatus;
23 
import in.shop2020.thrift.clients.CatalogClient;
24 
import in.shop2020.thrift.clients.InventoryClient;
25 
import in.shop2020.thrift.clients.PaymentClient;
26 
import in.shop2020.thrift.clients.TransactionClient;
27 
import in.shop2020.thrift.clients.UserClient;
28 
 
29 
import java.io.File;
8651 vikram.rag 30 
import java.text.ParseException;
8616 vikram.rag 31 
import java.text.SimpleDateFormat;
32 
import java.util.ArrayList;
33 
import java.util.Calendar;
34 
import java.util.Collections;
35 
import java.util.Date;
36 
import java.util.List;
37 
import javax.xml.bind.JAXBContext;
38 
import javax.xml.bind.JAXBException;
39 
import javax.xml.bind.Marshaller;
40 
import javax.xml.bind.Unmarshaller;
8739 vikram.rag 41 
 
8616 vikram.rag 42 
import org.apache.thrift.TException;
43 
import org.apache.thrift.transport.TTransportException;
8645 vikram.rag 44 
import org.slf4j.Logger;
45 
import org.slf4j.LoggerFactory;
8616 vikram.rag 46 
 
47 
import order.SaholicAPI;
48 
import order.SaholicAPI.Order;
49 
 
50 
public class ProcessSnapdealOrder {
51 
	private static final int SNAPDEAL_SOURCE_ID = 7;
52 
	private static final String FIRSTFLIGHT = "First Flight";
8627 vikram.rag 53 
	private static final String DELHIVERY = "DELHIVERY";
54 
	private static final String BLUEDART = "Bluedart";
8715 vikram.rag 55 
	private static final String CHHOTU = "CHHOTU";
56 
	private static final String LAST_MILE = "LAST_MILE";
57 
	private static final String  ECOMM_EXP = "ECOMM_EXP";
58 
	private static final String  EWINGS = "EWINGS";
59 
	private static final String DTDC = "DTDC";
60 
	private static final String WAREOLOG = "DTDC";
61 
	private static final String  MIRAKLE = "MIRAKLE";
62 
	private static final String RAJIV_TRANSPORT = "RAJIV_TRANSPORT";
63 
	private static final String BLUEDART_HIGH_VALUE = "BLUEDART_HIGH_VALUE";
64 
	private static final String BLUEDART_SURFACE = "BLUEDART_SURFACE";
65 
	private static final String BLUEDART_APEX = "BLUEDART_APEX";
66 
	private static final String ARAMEX = "ARAMEX";
67 
	private static final String GATI = "GATI";
68 
	private static final String INDIA_POST = "INDIA_POST";
69 
	private static final String FEDEX = "FEDEX";
70 
	private static final String IOT = "IOT";
71 
	private static final String RED_EXP = "RED_EXP";
72 
	private static final String GHARPAY = "GHARPAY";
73 
	private static final String QUANTIUM = "QUANTIUM";
74 
	private static final String GATI_AIR = "GATI_AIR`";
75 
	private static final String VDELIVER = "VDELIVER";
8627 vikram.rag 76 
	private static String transactionId;
77 
	private static final int SNAPDEAL_GATEWAY_ID = 18;
8646 vikram.rag 78 
	private static Logger logger;
8627 vikram.rag 79 
 
8616 vikram.rag 80 
	public static void processSnapdealOrders(File file) throws JAXBException{
8646 vikram.rag 81 
		logger = LoggerFactory.getLogger(ProcessSnapdealOrder.class);
8616 vikram.rag 82 
		JAXBContext jc = JAXBContext.newInstance(SaholicAPI.class);
83 
		Unmarshaller unmarshaller = jc.createUnmarshaller();
84 
		SaholicAPI orders = (SaholicAPI) unmarshaller.unmarshal(file);
85 
		Marshaller marshaller = jc.createMarshaller();
86 
		marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
87 
		marshaller.marshal(orders, System.out);
88 
		SourceDetail sourceDetail = null;
89 
		User user = null;
90 
		TransactionClient tsc = null;
91 
		try {
92 
			tsc = new TransactionClient();
93 
			sourceDetail = tsc.getClient().getSourceDetail(SNAPDEAL_SOURCE_ID);
94 
		} catch (Exception e) {
8645 vikram.rag 95 
			logger.error("Unable to establish connection to the transaction service while getting Snapdeal Source Detail", e);
8616 vikram.rag 96 
		}
97 
		try {
98 
			in.shop2020.model.v1.user.UserContextService.Client userClient = new UserClient().getClient();
99 
			user = userClient.getUserByEmail(sourceDetail.getEmail());
100 
		} catch (Exception e) {
8649 vikram.rag 101 
			logger.error("Unable to establish connection to the User service", e);
8616 vikram.rag 102 
		}
103 
		for(Order order:orders.getOrder()){
8627 vikram.rag 104 
			long subOrderId = (long) order.getSuborderId();
105 
			Client transaction_client = null;
106 
			try {
107 
				transaction_client = new TransactionClient().getClient();
108 
				System.out.println("Suborder id " + subOrderId);
109 
				if(transaction_client.snapdealOrderExists(subOrderId)) {
8739 vikram.rag 110 
					logger.error("Snapdeal suborder id exists " + subOrderId);
8627 vikram.rag 111 
					System.out.println("Suborder id exists");
112 
					continue;
113 
				}
114 
 
115 
			} catch (TTransportException e1) {
116 
				// TODO Auto-generated catch block
117 
				e1.printStackTrace();
118 
			} catch (TException e) {
119 
				// TODO Auto-generated catch block
120 
				e.printStackTrace();
121 
			}
8739 vikram.rag 122 
			//System.out.println("Inside Order Parsing");
8616 vikram.rag 123 
			Transaction txn = new Transaction();
8739 vikram.rag 124 
			//System.out.println("User details are " + user.getActiveCartId());
8616 vikram.rag 125 
			txn.setShoppingCartid(user.getActiveCartId());
8739 vikram.rag 126 
			//System.out.println("creating transaction");
8616 vikram.rag 127 
			txn.setCustomer_id(user.getUserId());
8627 vikram.rag 128 
			System.out.println("User Id is " + user.getUserId());
8616 vikram.rag 129 
			txn.setCreatedOn(new Date().getTime());
130 
			txn.setTransactionStatus(TransactionStatus.INIT);
131 
			txn.setStatusDescription("Order for Snapdeal ");
132 
			List<in.shop2020.model.v1.order.Order> orderlist = new ArrayList<in.shop2020.model.v1.order.Order>();
133 
			LineItem lineItem = null;
8739 vikram.rag 134 
			CatalogService.Client catalogClient = null;
135 
			SnapdealItem snapdealItem = null;
136 
			double SellingPrice = 0;
8616 vikram.rag 137 
			try {
8739 vikram.rag 138 
				catalogClient =  new CatalogClient().getClient();
139 
				snapdealItem = catalogClient.getSnapdealItem(order.getSKUCode());
140 
				if(order.getSellingPricePerItem() <  snapdealItem.getExceptionPrice()){
141 
					SellingPrice = snapdealItem.getExceptionPrice();
142 
				}
143 
				else{
144 
					SellingPrice = order.getSellingPricePerItem();
145 
				}
146 
				lineItem = createLineItem(order.getSKUCode(),SellingPrice);
8627 vikram.rag 147 
				System.out.println("Line item created");
8616 vikram.rag 148 
			} catch (CatalogServiceException e) {
8645 vikram.rag 149 
				logger.error("Unable to create order for suborderid  " + order.getSuborderId());
8616 vikram.rag 150 
				e.printStackTrace();
151 
			} catch (TException e) {
8645 vikram.rag 152 
				logger.error("Unable to create order for suborderid  " + order.getSuborderId());
8616 vikram.rag 153 
				e.printStackTrace();
154 
			}
155 
			in.shop2020.model.v1.order.Order t_order = new in.shop2020.model.v1.order.Order();
8627 vikram.rag 156 
			t_order.setCustomer_id(user.getUserId());
157 
			t_order.setCustomer_email(sourceDetail.getEmail());
158 
			t_order.setCustomer_name(order.getCustomerName());
159 
			t_order.setCustomer_address1("");
160 
			t_order.setCustomer_address2("");
161 
			t_order.setCustomer_city(order.getCity());
162 
			t_order.setCustomer_state(order.getState());
163 
			t_order.setCustomer_pincode(String.valueOf(order.getPINCode()));
164 
			t_order.setTotal_amount(lineItem.getTotal_price());
165 
			t_order.setTotal_weight(lineItem.getTotal_weight());
166 
			t_order.setLineitems(Collections.singletonList(lineItem));
167 
			t_order.setStatus(OrderStatus.SUBMITTED_FOR_PROCESSING);
168 
			t_order.setStatusDescription("In Process");
169 
			t_order.setCreated_timestamp(new Date().getTime());
170 
			t_order.setOrderType(OrderType.B2C);
171 
			t_order.setCod(false);
172 
			System.out.println("t order created");
173 
			try {
8661 vikram.rag 174 
				SimpleDateFormat istFormatter = new SimpleDateFormat("yyyy-MM-dd");
175 
				Date shipDate = null;
176 
				try {
177 
					shipDate= istFormatter.parse(order.getShipByDate());
178 
				} catch (ParseException e) {
179 
					logger.error("Could not parse order date from file ");
180 
					e.printStackTrace();
181 
				}
8627 vikram.rag 182 
				Calendar time = Calendar.getInstance();
183 
				time.add(Calendar.DAY_OF_MONTH, 1);
8661 vikram.rag 184 
				t_order.setPromised_shipping_time(shipDate.getTime());
185 
				t_order.setExpected_shipping_time(shipDate.getTime());
8627 vikram.rag 186 
				time.add(Calendar.DAY_OF_MONTH, 3);
187 
				t_order.setPromised_delivery_time(time.getTimeInMillis());
188 
				t_order.setExpected_delivery_time(time.getTimeInMillis());
189 
				System.out.println("Dates set in transaction");
8697 vikram.rag 190 
			} catch(Exception e) {
8645 vikram.rag 191 
				logger.error("Error in updating Shipping or Delivery Time for suborderid  " + order.getSuborderId());
8627 vikram.rag 192 
				continue;
193 
			}
8657 vikram.rag 194 
			InventoryService.Client inventoryClient = null;
8739 vikram.rag 195 
			Warehouse fulfillmentWarehouse= null;
196 
			try {
197 
				inventoryClient = new InventoryClient().getClient();
198 
				if(snapdealItem.getItem_id()!=0 && snapdealItem.getWarehouseId()!=0) {
199 
					fulfillmentWarehouse = inventoryClient.getWarehouse(snapdealItem.getWarehouseId());
200 
				} else {
201 
					List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(order.getSKUCode(), 1);
202 
					fulfillmentWarehouse = inventoryClient.getWarehouse(itemAvailability.get(0));
203 
				}
204 
				logger.info("Fulfillment warehouse id for suborderid  " + order.getSuborderId() + " is " + fulfillmentWarehouse.getId());
205 
				t_order.setFulfilmentWarehouseId(fulfillmentWarehouse.getId());
206 
				logger.info("Billing warehouse id for suborderid  " + order.getSuborderId() + " is " + fulfillmentWarehouse.getBillingWarehouseId());
207 
				t_order.setWarehouse_id(fulfillmentWarehouse.getBillingWarehouseId());
208 
				VendorItemPricing vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), fulfillmentWarehouse.getVendor().getId());
209 
				t_order.getLineitems().get(0).setTransfer_price(vendorItemPricing.getTransferPrice());
210 
				t_order.getLineitems().get(0).setNlc(vendorItemPricing.getNlc());
8616 vikram.rag 211 
			} catch (InventoryServiceException e) {
8662 vikram.rag 212 
				logger.error("Error connecting inventory service for suborderid  " + order.getSuborderId());
8739 vikram.rag 213 
				continue;
8616 vikram.rag 214 
			} catch (TTransportException e) {
215 
				// TODO Auto-generated catch block
216 
				e.printStackTrace();
217 
			} catch (TException e) {
218 
				// TODO Auto-generated catch block
219 
				e.printStackTrace();
8657 vikram.rag 220 
			}
8616 vikram.rag 221 
			if(order.getCourier().equalsIgnoreCase(FIRSTFLIGHT)) {
222 
				t_order.setLogistics_provider_id(12);
223 
			} else if(order.getCourier().equalsIgnoreCase(DELHIVERY)) {
224 
				t_order.setLogistics_provider_id(13);
225 
			} else if(order.getCourier().equalsIgnoreCase(BLUEDART)) {
226 
				t_order.setLogistics_provider_id(14);
8642 vikram.rag 227 
			}else if(order.getCourier().equalsIgnoreCase(CHHOTU)) {
228 
				t_order.setLogistics_provider_id(16);
8715 vikram.rag 229 
			}
230 
			else if(order.getCourier().equalsIgnoreCase(LAST_MILE)){
231 
				t_order.setLogistics_provider_id(17);
232 
			}
233 
			else if(order.getCourier().equalsIgnoreCase(ECOMM_EXP)){
234 
				t_order.setLogistics_provider_id(18);
235 
			}
236 
			else if(order.getCourier().equalsIgnoreCase(EWINGS)){
237 
				t_order.setLogistics_provider_id(19);
238 
			}
239 
			else if(order.getCourier().equalsIgnoreCase(DTDC)){
240 
				t_order.setLogistics_provider_id(20);
241 
			}
242 
			else if(order.getCourier().equalsIgnoreCase(WAREOLOG)){
243 
				t_order.setLogistics_provider_id(21);
244 
			}
245 
			else if(order.getCourier().equalsIgnoreCase(MIRAKLE)){
246 
				t_order.setLogistics_provider_id(22);
247 
			}
248 
			else if(order.getCourier().equalsIgnoreCase(RAJIV_TRANSPORT)){
249 
				t_order.setLogistics_provider_id(23);
250 
			}
251 
			else if(order.getCourier().equalsIgnoreCase(BLUEDART_HIGH_VALUE)){
252 
				t_order.setLogistics_provider_id(24);
253 
			}
254 
			else if(order.getCourier().equalsIgnoreCase(BLUEDART_SURFACE)){
255 
				t_order.setLogistics_provider_id(25);
256 
			}
257 
			else if(order.getCourier().equalsIgnoreCase(BLUEDART_APEX)){
258 
				t_order.setLogistics_provider_id(26);
259 
			}
260 
			else if(order.getCourier().equalsIgnoreCase(ARAMEX)){
261 
				t_order.setLogistics_provider_id(27);
262 
			}
263 
			else if(order.getCourier().equalsIgnoreCase(GATI)){
264 
				t_order.setLogistics_provider_id(28);
265 
			}
266 
			else if(order.getCourier().equalsIgnoreCase(INDIA_POST)){
267 
				t_order.setLogistics_provider_id(29);
268 
			}
269 
			else if(order.getCourier().equalsIgnoreCase(FEDEX)){
270 
				t_order.setLogistics_provider_id(30);
271 
			}
272 
			else if(order.getCourier().equalsIgnoreCase(IOT)){
273 
				t_order.setLogistics_provider_id(31);
274 
			}
275 
			else if(order.getCourier().equalsIgnoreCase(RED_EXP)){
276 
				t_order.setLogistics_provider_id(32);
277 
			}
278 
			else if(order.getCourier().equalsIgnoreCase(VDELIVER)){
279 
				t_order.setLogistics_provider_id(33);
280 
			}
281 
			else if(order.getCourier().equalsIgnoreCase(GHARPAY)){
282 
				t_order.setLogistics_provider_id(34);
283 
			}
284 
			else if(order.getCourier().equalsIgnoreCase(QUANTIUM)){
285 
				t_order.setLogistics_provider_id(35);
286 
			}
287 
			else if(order.getCourier().equalsIgnoreCase(GATI_AIR)){
288 
				t_order.setLogistics_provider_id(36);
289 
			}
290 
			else {
8652 vikram.rag 291 
				logger.error("Error No Courier Match please add courier to our system for suborderid  " + order.getSuborderId() + "Courier Name " + order.getCourier());
8627 vikram.rag 292 
				continue;
8616 vikram.rag 293 
			}
8627 vikram.rag 294 
 
8616 vikram.rag 295 
			t_order.setAirwaybill_no(String.valueOf(order.getAWBNumber()));
296 
			t_order.setTracking_id(String.valueOf(order.getAWBNumber()));
8739 vikram.rag 297 
			t_order.setTotal_amount(SellingPrice);
8627 vikram.rag 298 
			t_order.setOrderType(OrderType.B2C);
299 
			t_order.setSource(SNAPDEAL_SOURCE_ID);
300 
			t_order.setOrderType(OrderType.B2C);
301 
			orderlist.add(t_order);
302 
			txn.setOrders(orderlist);
8739 vikram.rag 303 
			String referenceCode = order.getReferenceCode();
304 
			String productName = order.getProduct();
305 
			SimpleDateFormat istFormatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
306 
			Date snapdealTxnDate = null;
307 
			try {
308 
				snapdealTxnDate = istFormatter.parse(order.getOrderPlacedDate());
309 
			} catch (ParseException e) {
310 
				logger.error("Could not parse order date from file ");
311 
				e.printStackTrace();
312 
			}
313 
			try {
314 
				transactionId =  String.valueOf(transaction_client.createTransaction(txn));
315 
			} catch (TransactionServiceException e) {
316 
				logger.error("Could not create transaction ");
317 
				e.printStackTrace();
318 
			} catch (TException e) {
319 
				logger.error("Problem with transaction service while creating transaction");
320 
				e.printStackTrace();
321 
			}
322 
			createPayment(user, (new Long(subOrderId)).toString(),lineItem.getTotal_price());
8627 vikram.rag 323 
 
8739 vikram.rag 324 
			Transaction transaction = null;
325 
			try {
326 
				transaction = transaction_client.getTransaction(Long.parseLong(transactionId));
327 
			} catch (NumberFormatException e) {
328 
				logger.error("Problem parsing transaction id " + transactionId);
329 
				e.printStackTrace();
330 
			} catch (TransactionServiceException e) {
331 
				logger.error("Problem getting transaction from service transaction id " + transactionId);
332 
				e.printStackTrace();
333 
			} catch (TException e) {
334 
				logger.error("Problem with transaction service while getting transaction id " + transactionId);
335 
				e.printStackTrace();
336 
			}
337 
			in.shop2020.model.v1.order.Order snapdealorder = transaction.getOrders().get(0);
8627 vikram.rag 338 
 
8739 vikram.rag 339 
			//inventoryClient.reserveItemInWarehouse(lineItem.getItem_id(), fulfillmentWarehouse.getId(), 1,
340 
			//		snapdealorder.getId(), snapdealorder.getCreated_timestamp(), snapdealorder.getPromised_shipping_time(), snapdealorder.getLineitems().get(0).getQuantity());
8627 vikram.rag 341 
 
342 
 
8739 vikram.rag 343 
			SnapdealOrder snapdealOrder = new SnapdealOrder();
344 
			snapdealOrder.setOrderId(snapdealorder.getId());
345 
			snapdealOrder.setSubOrderId(subOrderId);
346 
			snapdealOrder.setReferenceCode(referenceCode);
347 
			snapdealOrder.setProductName(productName);
348 
			snapdealOrder.setSnapdealTxnDate(snapdealTxnDate.getTime());
349 
			snapdealOrder.setListingPrice(order.getSellingPricePerItem());
350 
			try {
351 
				transaction_client.createSnapdealOrder(snapdealOrder);
352 
			} catch (TException e) {
353 
				logger.error("Could not create Snapdeal Order");
354 
				e.printStackTrace();
355 
			}
8627 vikram.rag 356 
 
8739 vikram.rag 357 
		}
8616 vikram.rag 358 
 
359 
	}
360 
 
8649 vikram.rag 361 
	public static void createPayment(User user, String subOrderId, double amount) {
362 
		in.shop2020.payments.PaymentService.Client client = null;
363 
		try {
364 
			client = new PaymentClient().getClient();
365 
		} catch (TTransportException e) {
366 
			logger.error("Could not connect to payment service ");
367 
			e.printStackTrace();
368 
		}
369 
		long paymentId = 0;
370 
		try {
371 
			paymentId = client.createPayment(user.getUserId(), amount, SNAPDEAL_GATEWAY_ID, Long.valueOf(transactionId), false);
372 
		} catch (NumberFormatException e) {
373 
			logger.error("Could not create payment");
374 
			e.printStackTrace();
375 
		} catch (PaymentException e) {
376 
			logger.error("Could not create payment payment exception");
377 
			e.printStackTrace();
378 
		} catch (TException e) {
379 
			logger.error("Could not create payment thrift exception");
380 
			e.printStackTrace();
381 
		}
382 
		try {
383 
			client.updatePaymentDetails(paymentId, null, null, null, null, null, null, subOrderId, null, PaymentStatus.AUTHORIZED, null, null);
384 
		} catch (PaymentException e) {
385 
			logger.error("Could not update payment to order");
386 
			e.printStackTrace();
387 
		} catch (TException e) {
388 
			logger.error("Could not update payment thrift exception");
389 
			e.printStackTrace();
390 
		}
8627 vikram.rag 391 
	}
392 
 
8616 vikram.rag 393 
	public static LineItem createLineItem(long itemId, double amount) throws CatalogServiceException, TException {
8627 vikram.rag 394 
		LineItem lineItem = new LineItem();
395 
		CatalogService.Client catalogClient = new CatalogClient().getClient();
396 
		Item item = catalogClient.getItem(itemId);
8616 vikram.rag 397 
 
8627 vikram.rag 398 
		lineItem.setProductGroup(item.getProductGroup());
399 
		lineItem.setBrand(item.getBrand());
400 
		lineItem.setModel_number(item.getModelNumber());
401 
		lineItem.setModel_name(item.getModelName());
402 
		lineItem.setExtra_info(item.getFeatureDescription());
403 
		lineItem.setQuantity(1);
404 
		lineItem.setItem_id(item.getId());
405 
		lineItem.setUnit_weight(item.getWeight());
406 
		lineItem.setTotal_weight(item.getWeight());
407 
		lineItem.setUnit_price(amount);
408 
		lineItem.setTotal_price(amount);
409 
 
8739 vikram.rag 410 
		if (item.getColor() == null || "NA".equals(item.getColor())) {
8627 vikram.rag 411 
			lineItem.setColor("");
412 
		} else {
413 
			lineItem.setColor(item.getColor());
414 
		}
415 
		return lineItem;
8616 vikram.rag 416 
	}
417 
 
418 
}