Subversion Repositories SmartDukaan

Rev

Rev 10869 | Rev 10894 | 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;
8890 amar.kumar 9 
import in.shop2020.model.v1.inventory.InventoryType;
10 
import in.shop2020.model.v1.inventory.WarehouseType;
8759 vikram.rag 11 
 
8616 vikram.rag 12 
import in.shop2020.model.v1.inventory.VendorItemPricing;
13 
import in.shop2020.model.v1.inventory.Warehouse;
14 
import in.shop2020.model.v1.order.LineItem;
15 
import in.shop2020.model.v1.order.OrderStatus;
16 
import in.shop2020.model.v1.order.OrderType;
17 
import in.shop2020.model.v1.order.SnapdealOrder;
18 
import in.shop2020.model.v1.order.SourceDetail;
19 
import in.shop2020.model.v1.order.Transaction;
8651 vikram.rag 20 
import in.shop2020.model.v1.order.TransactionServiceException;
8616 vikram.rag 21 
import in.shop2020.model.v1.order.TransactionStatus;
22 
import in.shop2020.model.v1.order.TransactionService.Client;
23 
import in.shop2020.model.v1.user.User;
24 
import in.shop2020.payments.PaymentException;
25 
import in.shop2020.payments.PaymentStatus;
26 
import in.shop2020.thrift.clients.CatalogClient;
27 
import in.shop2020.thrift.clients.InventoryClient;
28 
import in.shop2020.thrift.clients.PaymentClient;
29 
import in.shop2020.thrift.clients.TransactionClient;
30 
import in.shop2020.thrift.clients.UserClient;
31 
 
32 
import java.io.File;
8651 vikram.rag 33 
import java.text.ParseException;
8616 vikram.rag 34 
import java.text.SimpleDateFormat;
35 
import java.util.ArrayList;
36 
import java.util.Calendar;
37 
import java.util.Collections;
38 
import java.util.Date;
8773 vikram.rag 39 
import java.util.GregorianCalendar;
8616 vikram.rag 40 
import java.util.List;
41 
import javax.xml.bind.JAXBContext;
42 
import javax.xml.bind.JAXBException;
43 
import javax.xml.bind.Marshaller;
44 
import javax.xml.bind.Unmarshaller;
8739 vikram.rag 45 
 
8616 vikram.rag 46 
import org.apache.thrift.TException;
47 
import org.apache.thrift.transport.TTransportException;
8645 vikram.rag 48 
import org.slf4j.Logger;
49 
import org.slf4j.LoggerFactory;
8773 vikram.rag 50 
import in.shop2020.utils.GmailUtils;
8616 vikram.rag 51 
 
52 
import order.SaholicAPI;
53 
import order.SaholicAPI.Order;
54 
 
55 
public class ProcessSnapdealOrder {
56 
	private static final int SNAPDEAL_SOURCE_ID = 7;
57 
	private static final String FIRSTFLIGHT = "First Flight";
8627 vikram.rag 58 
	private static final String DELHIVERY = "DELHIVERY";
59 
	private static final String BLUEDART = "Bluedart";
8715 vikram.rag 60 
	private static final String CHHOTU = "CHHOTU";
61 
	private static final String LAST_MILE = "LAST_MILE";
8844 amar.kumar 62 
	private static final String  ECOMM_EXP = "Ecom Express";
8715 vikram.rag 63 
	private static final String  EWINGS = "EWINGS";
64 
	private static final String DTDC = "DTDC";
9187 vikram.rag 65 
	private static final String WAREOLOG = "Wareolog";
8715 vikram.rag 66 
	private static final String  MIRAKLE = "MIRAKLE";
67 
	private static final String RAJIV_TRANSPORT = "RAJIV_TRANSPORT";
68 
	private static final String BLUEDART_HIGH_VALUE = "BLUEDART_HIGH_VALUE";
69 
	private static final String BLUEDART_SURFACE = "BLUEDART_SURFACE";
9187 vikram.rag 70 
	private static final String BLUEDART_APEX = "BLUEDART APEX";
8715 vikram.rag 71 
	private static final String ARAMEX = "ARAMEX";
9120 vikram.rag 72 
	private static final String GATI = "GATI";
9879 rajveer 73 
	private static final String INDIA_POST = "INDIA POST";
8715 vikram.rag 74 
	private static final String FEDEX = "FEDEX";
75 
	private static final String IOT = "IOT";
9148 vikram.rag 76 
	private static final String RED_EXP = "Red Express";
8715 vikram.rag 77 
	private static final String GHARPAY = "GHARPAY";
9128 vikram.rag 78 
	private static final String QUANTIUM = "Quantium Solutions";
9120 vikram.rag 79 
	private static final String GATI_AIR = "GATI AIR";
8715 vikram.rag 80 
	private static final String VDELIVER = "VDELIVER";
9137 vikram.rag 81 
	private static final String OVERNITE_EXP = "Overnite Express";
10235 vikram.rag 82 
	private static final String BIBHA_CARGO =  "BIBHA CARGO AND COURIER PVT LTD";
10570 manish.sha 83 
	private static final String FF_DELHI = "FF-Delhi";
10574 vikram.rag 84 
	private static final String FF_GURGAON = "FF-GURGAON";
10761 kshitij.so 85 
	private static final String TANVI_EXPRESS = "Tanvi Express";
86 
	private static final String VELIX = "Velex Logistics Pvt. Ltd";
10768 manish.sha 87 
	private static final String XPRESSBEES = "XPRESSBEES";
8627 vikram.rag 88 
	private static String transactionId;
9151 vikram.rag 89 
	private static long paymentId;
8627 vikram.rag 90 
	private static final int SNAPDEAL_GATEWAY_ID = 18;
8646 vikram.rag 91 
	private static Logger logger;
8627 vikram.rag 92 
 
8616 vikram.rag 93 
	public static void processSnapdealOrders(File file) throws JAXBException{
8646 vikram.rag 94 
		logger = LoggerFactory.getLogger(ProcessSnapdealOrder.class);
8616 vikram.rag 95 
		JAXBContext jc = JAXBContext.newInstance(SaholicAPI.class);
96 
		Unmarshaller unmarshaller = jc.createUnmarshaller();
97 
		SaholicAPI orders = (SaholicAPI) unmarshaller.unmarshal(file);
98 
		Marshaller marshaller = jc.createMarshaller();
99 
		marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
100 
		marshaller.marshal(orders, System.out);
101 
		SourceDetail sourceDetail = null;
102 
		User user = null;
103 
		TransactionClient tsc = null;
104 
		try {
105 
			tsc = new TransactionClient();
106 
			sourceDetail = tsc.getClient().getSourceDetail(SNAPDEAL_SOURCE_ID);
107 
		} catch (Exception e) {
8773 vikram.rag 108 
			logger.error("Unable to establish connection to the transaction service while getting Snapdeal Source Detail ", e);
8616 vikram.rag 109 
		}
110 
		try {
111 
			in.shop2020.model.v1.user.UserContextService.Client userClient = new UserClient().getClient();
112 
			user = userClient.getUserByEmail(sourceDetail.getEmail());
113 
		} catch (Exception e) {
8773 vikram.rag 114 
			logger.error("Unable to establish connection to the User service ", e);
8616 vikram.rag 115 
		}
8800 vikram.rag 116 
		int duplicate_orders = 0;
117 
		int new_orders = 0;
8773 vikram.rag 118 
		int processed_orders = 0;
119 
		StringBuffer sb = new StringBuffer();
9456 vikram.rag 120 
		LineItem lineItem = null;
121 
		CatalogService.Client catalogClient = null;
122 
		SnapdealItem snapdealItem = null;
123 
		double SellingPrice = 0;
124 
		long sku;
9630 vikram.rag 125 
		String subOrderId;
8616 vikram.rag 126 
		for(Order order:orders.getOrder()){
9629 vikram.rag 127 
			subOrderId = order.getSuborderId();
8627 vikram.rag 128 
			Client transaction_client = null;
129 
			try {
130 
				transaction_client = new TransactionClient().getClient();
8802 amar.kumar 131 
				if(transaction_client.snapdealOrderExists(subOrderId, order.getReferenceCode())) {
8739 vikram.rag 132 
					logger.error("Snapdeal suborder id exists " + subOrderId);
8800 vikram.rag 133 
					duplicate_orders++;
8627 vikram.rag 134 
					continue;
135 
				}
136 
 
137 
			} catch (TTransportException e1) {
10893 vikram.rag 138 
				try {
139 
					transaction_client = new TransactionClient().getClient();
140 
				} catch (TTransportException e2) {
141 
					e2.printStackTrace();
142 
				}
143 
				try {
144 
					if(transaction_client.snapdealOrderExists(subOrderId, order.getReferenceCode())) {
145 
						logger.error("Snapdeal suborder id exists " + subOrderId);
146 
						duplicate_orders++;
147 
						continue;
148 
					}
149 
				} catch (TException e) {
150 
					e.printStackTrace();
151 
				}
152 
 
8773 vikram.rag 153 
				logger.error("Problem with Transaction service " , e1);
8627 vikram.rag 154 
				e1.printStackTrace();
155 
			} catch (TException e) {
8773 vikram.rag 156 
				logger.error("Problem.. thrift exception with Transaction service " , e);
8627 vikram.rag 157 
				e.printStackTrace();
158 
			}
8800 vikram.rag 159 
			new_orders++;
8616 vikram.rag 160 
			Transaction txn = new Transaction();
161 
			txn.setShoppingCartid(user.getActiveCartId());
162 
			txn.setCustomer_id(user.getUserId());
8627 vikram.rag 163 
			System.out.println("User Id is " + user.getUserId());
8616 vikram.rag 164 
			txn.setCreatedOn(new Date().getTime());
165 
			txn.setTransactionStatus(TransactionStatus.INIT);
166 
			txn.setStatusDescription("Order for Snapdeal ");
167 
			List<in.shop2020.model.v1.order.Order> orderlist = new ArrayList<in.shop2020.model.v1.order.Order>();
168 
			try {
9240 vikram.rag 169 
				catalogClient =  new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
9573 vikram.rag 170 
				snapdealItem = catalogClient.getSnapdealItembySkuAtSnapdeal(order.getSKUCode());
171 
				if(snapdealItem.getItem_id()!=0){
172 
					sku = snapdealItem.getItem_id();
9456 vikram.rag 173 
				}
9573 vikram.rag 174 
				else{
175 
					sb.append(order.getSuborderId() +" "+"SKU not found "+"\n");
176 
					continue;
9456 vikram.rag 177 
				}
8886 vikram.rag 178 
				if(snapdealItem.getExceptionPrice()!=0 && snapdealItem.getItem_id()!=0 && (order.getSellingPricePerItem() <  snapdealItem.getExceptionPrice())){
8739 vikram.rag 179 
					SellingPrice = snapdealItem.getExceptionPrice();
180 
				}
181 
				else{
182 
					SellingPrice = order.getSellingPricePerItem();
183 
				}
9456 vikram.rag 184 
				lineItem = createLineItem(sku,SellingPrice);
8773 vikram.rag 185 
				if(lineItem == null){
8854 vikram.rag 186 
					sb.append(order.getSuborderId() +" "+"SKU not found "+"\n");
8773 vikram.rag 187 
					continue;
188 
				}
8846 vikram.rag 189 
				lineItem.setExtra_info("SubOrderId = " + order.getSuborderId() + " ReferenceCode = " + order.getReferenceCode());
8616 vikram.rag 190 
			} catch (CatalogServiceException e) {
8773 vikram.rag 191 
				logger.error("Unable to create order for suborderid  " + order.getSuborderId() , e);
8616 vikram.rag 192 
				e.printStackTrace();
8773 vikram.rag 193 
				sb.append(order.getSuborderId() + " " + "Problem with catalog service" + "\n");
8744 vikram.rag 194 
				continue;
8616 vikram.rag 195 
			} catch (TException e) {
8773 vikram.rag 196 
				logger.error("Unable to create order for suborderid  " + order.getSuborderId() , e);
8616 vikram.rag 197 
				e.printStackTrace();
8773 vikram.rag 198 
				sb.append(order.getSuborderId() + " " + "Thrift Exception in Catalog Service" + "\n");
8744 vikram.rag 199 
				continue;
8616 vikram.rag 200 
			}
201 
			in.shop2020.model.v1.order.Order t_order = new in.shop2020.model.v1.order.Order();
8627 vikram.rag 202 
			t_order.setCustomer_id(user.getUserId());
203 
			t_order.setCustomer_email(sourceDetail.getEmail());
204 
			t_order.setCustomer_name(order.getCustomerName());
205 
			t_order.setCustomer_address1("");
206 
			t_order.setCustomer_address2("");
207 
			t_order.setCustomer_city(order.getCity());
9214 vikram.rag 208 
			t_order.setCustomer_mobilenumber("+91-9999999999");
8627 vikram.rag 209 
			t_order.setCustomer_state(order.getState());
210 
			t_order.setCustomer_pincode(String.valueOf(order.getPINCode()));
8742 vikram.rag 211 
			t_order.setTotal_amount(SellingPrice);
8627 vikram.rag 212 
			t_order.setTotal_weight(lineItem.getTotal_weight());
213 
			t_order.setLineitems(Collections.singletonList(lineItem));
8759 vikram.rag 214 
			t_order.setStatus(OrderStatus.PAYMENT_PENDING);
8890 amar.kumar 215 
			t_order.setStatusDescription("Payment Pending");
8627 vikram.rag 216 
			t_order.setCreated_timestamp(new Date().getTime());
217 
			t_order.setOrderType(OrderType.B2C);
218 
			t_order.setCod(false);
219 
			System.out.println("t order created");
220 
			try {
8804 vikram.rag 221 
				SimpleDateFormat istFormatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
8661 vikram.rag 222 
				Date shipDate = null;
223 
				try {
224 
					shipDate= istFormatter.parse(order.getShipByDate());
225 
				} catch (ParseException e) {
8773 vikram.rag 226 
					logger.error("Could not parse order ship date from file " , e);
8661 vikram.rag 227 
					e.printStackTrace();
8775 vikram.rag 228 
					sb.append(order.getSuborderId() + " Could not parse ship date" + " " + "\n");
8744 vikram.rag 229 
					continue;
8661 vikram.rag 230 
				}
8627 vikram.rag 231 
				Calendar time = Calendar.getInstance();
8661 vikram.rag 232 
				t_order.setPromised_shipping_time(shipDate.getTime());
233 
				t_order.setExpected_shipping_time(shipDate.getTime());
8744 vikram.rag 234 
				time.add(Calendar.DAY_OF_MONTH, 4);
8627 vikram.rag 235 
				t_order.setPromised_delivery_time(time.getTimeInMillis());
236 
				t_order.setExpected_delivery_time(time.getTimeInMillis());
237 
				System.out.println("Dates set in transaction");
8697 vikram.rag 238 
			} catch(Exception e) {
8645 vikram.rag 239 
				logger.error("Error in updating Shipping or Delivery Time for suborderid  " + order.getSuborderId());
8775 vikram.rag 240 
				sb.append(order.getSuborderId() + " Could not update delivery time" + " " + "\n");
8627 vikram.rag 241 
				continue;
242 
			}
8657 vikram.rag 243 
			InventoryService.Client inventoryClient = null;
8739 vikram.rag 244 
			Warehouse fulfillmentWarehouse= null;
245 
			try {
246 
				inventoryClient = new InventoryClient().getClient();
247 
				if(snapdealItem.getItem_id()!=0 && snapdealItem.getWarehouseId()!=0) {
248 
					fulfillmentWarehouse = inventoryClient.getWarehouse(snapdealItem.getWarehouseId());
249 
				} else {
9456 vikram.rag 250 
					List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(sku, 1);
8739 vikram.rag 251 
					fulfillmentWarehouse = inventoryClient.getWarehouse(itemAvailability.get(0));
8789 vikram.rag 252 
					if(fulfillmentWarehouse.getStateId()!=0){
253 
						fulfillmentWarehouse = inventoryClient.getWarehouse(7);
254 
					}
8739 vikram.rag 255 
				}
256 
				t_order.setFulfilmentWarehouseId(fulfillmentWarehouse.getId());
8890 amar.kumar 257 
				long billingWarehouseId = 0;
258 
				if(fulfillmentWarehouse.getBillingWarehouseId()== 0) {
259 
					inventoryClient = new InventoryClient().getClient();
260 
					List<Warehouse> warehouses = inventoryClient.getWarehouses(WarehouseType.OURS, InventoryType.GOOD, fulfillmentWarehouse.getVendor().getId(), 0, 0);
261 
					for(Warehouse warehouse : warehouses) {
262 
						if(warehouse.getBillingWarehouseId()!=0) {
263 
							billingWarehouseId = warehouse.getBillingWarehouseId();
9573 vikram.rag 264 
							break;
8890 amar.kumar 265 
						}
266 
					}
8891 amar.kumar 267 
				}else {
268 
					billingWarehouseId = fulfillmentWarehouse.getBillingWarehouseId();
8890 amar.kumar 269 
				}
9573 vikram.rag 270 
 
8890 amar.kumar 271 
				//logger.info("Billing warehouse id for suborderid  " + order.getSuborderId() + " is " + fulfillmentWarehouse.getBillingWarehouseId());
272 
				t_order.setWarehouse_id(billingWarehouseId);
8845 amar.kumar 273 
				VendorItemPricing vendorItemPricing = new VendorItemPricing();
274 
				if(fulfillmentWarehouse.getId()==7) {
275 
					Item item = new CatalogClient().getClient().getItem(lineItem.getItem_id());
276 
					vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), item.getPreferredVendor());
277 
				} else {
278 
					vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), fulfillmentWarehouse.getVendor().getId());
279 
				}
9573 vikram.rag 280 
 
8739 vikram.rag 281 
				t_order.getLineitems().get(0).setTransfer_price(vendorItemPricing.getTransferPrice());
282 
				t_order.getLineitems().get(0).setNlc(vendorItemPricing.getNlc());
8616 vikram.rag 283 
			} catch (InventoryServiceException e) {
8846 vikram.rag 284 
				logger.error("Error connecting inventory service for suborderid  " + order.getSuborderId() , e);
8775 vikram.rag 285 
				sb.append(order.getSuborderId() + " Inventory Service Exception" + " " + "\n");
8739 vikram.rag 286 
				continue;
8616 vikram.rag 287 
			} catch (TTransportException e) {
8773 vikram.rag 288 
				logger.error("Transport Exception with Inventory Service for suborderid  " + order.getSuborderId() , e);
8775 vikram.rag 289 
				sb.append(order.getSuborderId() + " Transport Exception with Inventory Service" + " " + "\n");
8744 vikram.rag 290 
				continue;
8616 vikram.rag 291 
			} catch (TException e) {
8773 vikram.rag 292 
				logger.error("Exception with Inventory Service for suborderid  " + order.getSuborderId() , e);
8775 vikram.rag 293 
				sb.append(order.getSuborderId() + " Exception in Inventory Service" + " " + "\n");
8744 vikram.rag 294 
				continue;
8845 amar.kumar 295 
			} catch (CatalogServiceException e) {
296 
				logger.error("Exception with Catalog Service for suborderid  " + order.getSuborderId() + " while getting item " + lineItem.getItem_id(), e);
297 
				sb.append(order.getSuborderId() + " Exception in Catalog Service" + " " + "\n");
298 
				continue;
8657 vikram.rag 299 
			}
8616 vikram.rag 300 
			if(order.getCourier().equalsIgnoreCase(FIRSTFLIGHT)) {
301 
				t_order.setLogistics_provider_id(12);
302 
			} else if(order.getCourier().equalsIgnoreCase(DELHIVERY)) {
303 
				t_order.setLogistics_provider_id(13);
304 
			} else if(order.getCourier().equalsIgnoreCase(BLUEDART)) {
305 
				t_order.setLogistics_provider_id(14);
8642 vikram.rag 306 
			}else if(order.getCourier().equalsIgnoreCase(CHHOTU)) {
307 
				t_order.setLogistics_provider_id(16);
8715 vikram.rag 308 
			}
309 
			else if(order.getCourier().equalsIgnoreCase(LAST_MILE)){
310 
				t_order.setLogistics_provider_id(17);
311 
			}
312 
			else if(order.getCourier().equalsIgnoreCase(ECOMM_EXP)){
313 
				t_order.setLogistics_provider_id(18);
314 
			}
315 
			else if(order.getCourier().equalsIgnoreCase(EWINGS)){
316 
				t_order.setLogistics_provider_id(19);
317 
			}
318 
			else if(order.getCourier().equalsIgnoreCase(DTDC)){
319 
				t_order.setLogistics_provider_id(20);
320 
			}
321 
			else if(order.getCourier().equalsIgnoreCase(WAREOLOG)){
322 
				t_order.setLogistics_provider_id(21);
323 
			}
324 
			else if(order.getCourier().equalsIgnoreCase(MIRAKLE)){
325 
				t_order.setLogistics_provider_id(22);
326 
			}
327 
			else if(order.getCourier().equalsIgnoreCase(RAJIV_TRANSPORT)){
328 
				t_order.setLogistics_provider_id(23);
329 
			}
330 
			else if(order.getCourier().equalsIgnoreCase(BLUEDART_HIGH_VALUE)){
331 
				t_order.setLogistics_provider_id(24);
332 
			}
333 
			else if(order.getCourier().equalsIgnoreCase(BLUEDART_SURFACE)){
334 
				t_order.setLogistics_provider_id(25);
335 
			}
336 
			else if(order.getCourier().equalsIgnoreCase(BLUEDART_APEX)){
337 
				t_order.setLogistics_provider_id(26);
338 
			}
339 
			else if(order.getCourier().equalsIgnoreCase(ARAMEX)){
340 
				t_order.setLogistics_provider_id(27);
341 
			}
342 
			else if(order.getCourier().equalsIgnoreCase(GATI)){
343 
				t_order.setLogistics_provider_id(28);
344 
			}
345 
			else if(order.getCourier().equalsIgnoreCase(INDIA_POST)){
346 
				t_order.setLogistics_provider_id(29);
347 
			}
348 
			else if(order.getCourier().equalsIgnoreCase(FEDEX)){
349 
				t_order.setLogistics_provider_id(30);
350 
			}
351 
			else if(order.getCourier().equalsIgnoreCase(IOT)){
352 
				t_order.setLogistics_provider_id(31);
353 
			}
354 
			else if(order.getCourier().equalsIgnoreCase(RED_EXP)){
355 
				t_order.setLogistics_provider_id(32);
356 
			}
357 
			else if(order.getCourier().equalsIgnoreCase(VDELIVER)){
358 
				t_order.setLogistics_provider_id(33);
359 
			}
360 
			else if(order.getCourier().equalsIgnoreCase(GHARPAY)){
361 
				t_order.setLogistics_provider_id(34);
362 
			}
363 
			else if(order.getCourier().equalsIgnoreCase(QUANTIUM)){
364 
				t_order.setLogistics_provider_id(35);
365 
			}
366 
			else if(order.getCourier().equalsIgnoreCase(GATI_AIR)){
367 
				t_order.setLogistics_provider_id(36);
368 
			}
9137 vikram.rag 369 
			else if(order.getCourier().equalsIgnoreCase(OVERNITE_EXP)){
370 
				t_order.setLogistics_provider_id(37);
371 
			}
10235 vikram.rag 372 
			else if(order.getCourier().equalsIgnoreCase(BIBHA_CARGO)){
373 
				t_order.setLogistics_provider_id(38);
374 
			}
10570 manish.sha 375 
			else if(order.getCourier().equalsIgnoreCase(FF_DELHI)){
376 
				t_order.setLogistics_provider_id(39);
377 
			}
10574 vikram.rag 378 
			else if(order.getCourier().equalsIgnoreCase(FF_GURGAON)){
379 
				t_order.setLogistics_provider_id(40);
380 
			}
10761 kshitij.so 381 
			else if(order.getCourier().trim().equalsIgnoreCase(TANVI_EXPRESS)){
10705 manish.sha 382 
				t_order.setLogistics_provider_id(41);
383 
			}
10761 kshitij.so 384 
			else if(order.getCourier().trim().equalsIgnoreCase(VELIX)){
385 
                t_order.setLogistics_provider_id(42);
386 
            }
10768 manish.sha 387 
			else if(order.getCourier().trim().equalsIgnoreCase(XPRESSBEES)){
388 
                t_order.setLogistics_provider_id(43);
389 
            }
10574 vikram.rag 390 
 
8715 vikram.rag 391 
			else {
10869 vikram.rag 392 
				t_order.setLogistics_provider_id(44);
393 
				/*logger.error("Error No Courier Match please add courier to our system for suborderid  " + order.getSuborderId() + "Courier Name " + order.getCourier());
8773 vikram.rag 394 
				sb.append(order.getSuborderId() + " Error No Courier Match " + order.getCourier() +"\n");
8627 vikram.rag 395 
				continue;
10869 vikram.rag 396 
				 */
8616 vikram.rag 397 
			}
8627 vikram.rag 398 
 
8616 vikram.rag 399 
			t_order.setAirwaybill_no(String.valueOf(order.getAWBNumber()));
400 
			t_order.setTracking_id(String.valueOf(order.getAWBNumber()));
8739 vikram.rag 401 
			t_order.setTotal_amount(SellingPrice);
8627 vikram.rag 402 
			t_order.setOrderType(OrderType.B2C);
403 
			t_order.setSource(SNAPDEAL_SOURCE_ID);
404 
			t_order.setOrderType(OrderType.B2C);
405 
			orderlist.add(t_order);
406 
			txn.setOrders(orderlist);
8739 vikram.rag 407 
			String referenceCode = order.getReferenceCode();
408 
			String productName = order.getProduct();
409 
			SimpleDateFormat istFormatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
410 
			Date snapdealTxnDate = null;
411 
			try {
412 
				snapdealTxnDate = istFormatter.parse(order.getOrderPlacedDate());
413 
			} catch (ParseException e) {
8773 vikram.rag 414 
				logger.error(order.getSuborderId() + " Could not parse snapdeal order date from file " , e);
415 
				sb.append(order.getSuborderId() + " Could not parse order date" +"\n");
8744 vikram.rag 416 
				continue;
8739 vikram.rag 417 
			}
418 
			try {
419 
				transactionId =  String.valueOf(transaction_client.createTransaction(txn));
420 
			} catch (TransactionServiceException e) {
8773 vikram.rag 421 
				logger.error(order.getSuborderId() + " Could not create transaction " , e);
422 
				sb.append(order.getSuborderId() + " Could not create transaction" +"\n");
8744 vikram.rag 423 
				continue;
8739 vikram.rag 424 
			} catch (TException e) {
10893 vikram.rag 425 
				try {
426 
					transactionId =  String.valueOf(transaction_client.createTransaction(txn));
427 
				} catch (TransactionServiceException e1) {
428 
					e1.printStackTrace();
429 
				} catch (TException e1) {
430 
					e1.printStackTrace();
431 
				}
8773 vikram.rag 432 
				logger.error("Problem with transaction service while creating transaction", e);
8775 vikram.rag 433 
				sb.append(order.getSuborderId() + " Transaction Service Exception could not create transaction" +"\n");
8744 vikram.rag 434 
				continue;
8739 vikram.rag 435 
			}
8806 vikram.rag 436 
			try{
9151 vikram.rag 437 
				paymentId = createPayment(user, (new Long(subOrderId)).toString(),lineItem.getTotal_price());
8806 vikram.rag 438 
			}
439 
			catch (NumberFormatException e) {
440 
				logger.error("Could not create payment",e);
441 
				sb.append(order.getSuborderId() + " Could not create payment");
442 
				e.printStackTrace();
443 
				continue;
444 
			} catch (PaymentException e) {
445 
				logger.error("Could not create payment payment exception",e);
446 
				sb.append(order.getSuborderId() + " Could not create payment Payment exception");
447 
				e.printStackTrace();
448 
				continue;
449 
			} catch (TException e) {
450 
				logger.error("Could not create payment thrift exception",e);
451 
				sb.append(order.getSuborderId() + " Could not create payment Thrift exception");
452 
				e.printStackTrace();
453 
				continue;
454 
			}
8739 vikram.rag 455 
			Transaction transaction = null;
456 
			try {
457 
				transaction = transaction_client.getTransaction(Long.parseLong(transactionId));
458 
			} catch (NumberFormatException e) {
459 
				logger.error("Problem parsing transaction id " + transactionId);
8773 vikram.rag 460 
				sb.append(order.getSuborderId() + " Problem parsing transaction id "+ transactionId +"\n");
8739 vikram.rag 461 
				e.printStackTrace();
8744 vikram.rag 462 
				continue;
8739 vikram.rag 463 
			} catch (TransactionServiceException e) {
464 
				logger.error("Problem getting transaction from service transaction id " + transactionId);
8773 vikram.rag 465 
				sb.append(order.getSuborderId() + " Problem getting transaction id "+ transactionId +"\n");
8739 vikram.rag 466 
				e.printStackTrace();
8744 vikram.rag 467 
				continue;
8739 vikram.rag 468 
			} catch (TException e) {
469 
				logger.error("Problem with transaction service while getting transaction id " + transactionId);
8773 vikram.rag 470 
				sb.append(order.getSuborderId() + " Problem with transaction service while getting transaction id "+ transactionId +"\n");
8739 vikram.rag 471 
				e.printStackTrace();
8744 vikram.rag 472 
				continue;
8739 vikram.rag 473 
			}
474 
			in.shop2020.model.v1.order.Order snapdealorder = transaction.getOrders().get(0);
8744 vikram.rag 475 
			try {
476 
				inventoryClient.reserveItemInWarehouse(lineItem.getItem_id(), fulfillmentWarehouse.getId(), 1,
8773 vikram.rag 477 
						snapdealorder.getId(), snapdealorder.getCreated_timestamp(), snapdealorder.getPromised_shipping_time(), snapdealorder.getLineitems().get(0).getQuantity());
8744 vikram.rag 478 
			} catch (InventoryServiceException e1) {
479 
				logger.error("Problem while reserving item in inventory service" + snapdealorder.getId());
9456 vikram.rag 480 
				sb.append(order.getSuborderId() + " Could not reserve inventory for sku "+ sku +"\n");
8744 vikram.rag 481 
				continue;
482 
			} catch (TException e1) {
483 
				logger.error("Problem with inventory service" + snapdealorder.getId());
9456 vikram.rag 484 
				sb.append(order.getSuborderId() + " Problem with inventory service while reserving inventory for sku "+ sku +"\n");
8744 vikram.rag 485 
				continue;
486 
			}
8739 vikram.rag 487 
			SnapdealOrder snapdealOrder = new SnapdealOrder();
488 
			snapdealOrder.setOrderId(snapdealorder.getId());
489 
			snapdealOrder.setSubOrderId(subOrderId);
490 
			snapdealOrder.setReferenceCode(referenceCode);
491 
			snapdealOrder.setProductName(productName);
492 
			snapdealOrder.setSnapdealTxnDate(snapdealTxnDate.getTime());
493 
			snapdealOrder.setListingPrice(order.getSellingPricePerItem());
9456 vikram.rag 494 
			snapdealOrder.setMaxNlc(snapdealItem.getMaxNlc());
8739 vikram.rag 495 
			try {
496 
				transaction_client.createSnapdealOrder(snapdealOrder);
9631 vikram.rag 497 
				new PaymentClient().getClient().updatePaymentDetails(paymentId, null, null, null, null, null, null, subOrderId, null, PaymentStatus.SUCCESS, null, null);
9573 vikram.rag 498 
 
8739 vikram.rag 499 
			} catch (TException e) {
500 
				logger.error("Could not create Snapdeal Order");
8773 vikram.rag 501 
				sb.append(order.getSuborderId() + " Could not create snapdeal order"+"\n");
9151 vikram.rag 502 
			} catch (PaymentException e) {
503 
				logger.error("Could not update payment for Snapdeal Order");
504 
				sb.append(order.getSuborderId() + " Could not update payment for snapdeal order"+"\n");
8739 vikram.rag 505 
			}
8773 vikram.rag 506 
			processed_orders++;
8789 vikram.rag 507 
 
8773 vikram.rag 508 
		}
509 
		java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
510 
		Calendar cal=GregorianCalendar.getInstance();
511 
		String emailFromAddress = "build@shop2020.in";
512 
		String password = "cafe@nes";
513 
		GmailUtils mailer = new GmailUtils();
8808 vikram.rag 514 
		//String sendTo[] = new String[]{"vikram.raghav@shop2020.in"};
515 
		String sendTo[] = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
516 
				"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
10253 manish.sha 517 
				"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in"};
8806 vikram.rag 518 
 
8773 vikram.rag 519 
		try {
8800 vikram.rag 520 
			if(new_orders==processed_orders && new_orders > 0){
521 
				String emailSubjectTxt = "Snapdeal Orders Created Successfully "+sdf.format(cal.getTime());
522 
				String text = "Total Orders Received : " + ( new_orders + duplicate_orders ) + "\n" +
8801 vikram.rag 523 
				"Orders Already Existing : " + duplicate_orders + "\n" +
8800 vikram.rag 524 
				"Processed Orders : " + processed_orders + "\n" +
525 
				"Failed Orders : " + (new_orders - processed_orders);
8773 vikram.rag 526 
				mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
527 
			}
8800 vikram.rag 528 
			else if(new_orders > 0){
529 
				String emailSubjectTxt = "Snapdeal Orders Failed while creation "+sdf.format(cal.getTime());
530 
				String text = "Total Orders Received : " + ( new_orders + duplicate_orders ) + "\n" +
8801 vikram.rag 531 
				"Orders Already Existing : " + duplicate_orders + "\n" +
8800 vikram.rag 532 
				"Processed Orders : " + processed_orders + "\n" +
533 
				"Failed Orders : " + (new_orders - processed_orders) + "\n"+ "\n" +
534 
				sb.toString();
8773 vikram.rag 535 
				mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
536 
			}
8800 vikram.rag 537 
			else{
8808 vikram.rag 538 
				//sendTo[] = new String[]{"vikram.raghav@shop2020.in"};
539 
				sendTo = new String[]{"engg@shop2020.in","sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
540 
						"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
541 
						"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in"};
542 
 
8800 vikram.rag 543 
				String emailSubjectTxt = "No new Snapdeal Orders " + sdf.format(cal.getTime());
544 
				String text = "Total Orders Received : " + ( new_orders + duplicate_orders ) + "\n" +
8801 vikram.rag 545 
				"Orders Already Existing : " + duplicate_orders + "\n" +
8800 vikram.rag 546 
				"Processed Orders : " + processed_orders + "\n" +
547 
				"Failed Orders : " + (new_orders - processed_orders) + "\n"+ "\n" +
548 
				sb.toString();
549 
				mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
550 
			}
8773 vikram.rag 551 
		}
552 
		catch (Exception e) {
553 
			e.printStackTrace();
554 
		}
8627 vikram.rag 555 
 
8616 vikram.rag 556 
 
8773 vikram.rag 557 
 
8616 vikram.rag 558 
	}
559 
 
9151 vikram.rag 560 
	public static long createPayment(User user, String subOrderId, double amount) throws NumberFormatException, PaymentException, TException {
9573 vikram.rag 561 
		in.shop2020.payments.PaymentService.Client client = new PaymentClient().getClient();
562 
		return client.createPayment(user.getUserId(), amount, SNAPDEAL_GATEWAY_ID, Long.valueOf(transactionId), false);
563 
 
8627 vikram.rag 564 
	}
565 
 
8616 vikram.rag 566 
	public static LineItem createLineItem(long itemId, double amount) throws CatalogServiceException, TException {
8627 vikram.rag 567 
		LineItem lineItem = new LineItem();
568 
		CatalogService.Client catalogClient = new CatalogClient().getClient();
569 
		Item item = catalogClient.getItem(itemId);
8773 vikram.rag 570 
		if(item.getId()==0){
571 
			//in case item id is incorrect..
572 
			return null;
573 
		}
8616 vikram.rag 574 
 
8627 vikram.rag 575 
		lineItem.setProductGroup(item.getProductGroup());
576 
		lineItem.setBrand(item.getBrand());
577 
		lineItem.setModel_number(item.getModelNumber());
578 
		lineItem.setModel_name(item.getModelName());
579 
		lineItem.setExtra_info(item.getFeatureDescription());
580 
		lineItem.setQuantity(1);
581 
		lineItem.setItem_id(item.getId());
582 
		lineItem.setUnit_weight(item.getWeight());
583 
		lineItem.setTotal_weight(item.getWeight());
584 
		lineItem.setUnit_price(amount);
585 
		lineItem.setTotal_price(amount);
586 
 
8739 vikram.rag 587 
		if (item.getColor() == null || "NA".equals(item.getColor())) {
8627 vikram.rag 588 
			lineItem.setColor("");
589 
		} else {
590 
			lineItem.setColor(item.getColor());
591 
		}
592 
		return lineItem;
8616 vikram.rag 593 
	}
594 
 
595 
}