Subversion Repositories SmartDukaan

Rev

Rev 8616 | Rev 8642 | 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;
4 
import in.shop2020.model.v1.catalog.CatalogServiceException;
5 
import in.shop2020.model.v1.catalog.Item;
6 
import in.shop2020.model.v1.inventory.InventoryService;
7 
import in.shop2020.model.v1.inventory.InventoryServiceException;
8 
import in.shop2020.model.v1.inventory.VendorItemPricing;
9 
import in.shop2020.model.v1.inventory.Warehouse;
10 
import in.shop2020.model.v1.order.LineItem;
11 
import in.shop2020.model.v1.order.OrderStatus;
12 
import in.shop2020.model.v1.order.OrderType;
13 
import in.shop2020.model.v1.order.SnapdealOrder;
14 
import in.shop2020.model.v1.order.SourceDetail;
15 
import in.shop2020.model.v1.order.Transaction;
16 
import in.shop2020.model.v1.order.TransactionStatus;
17 
import in.shop2020.model.v1.order.TransactionService.Client;
18 
import in.shop2020.model.v1.user.User;
19 
import in.shop2020.payments.PaymentException;
20 
import in.shop2020.payments.PaymentStatus;
21 
import in.shop2020.thrift.clients.CatalogClient;
22 
import in.shop2020.thrift.clients.InventoryClient;
23 
import in.shop2020.thrift.clients.PaymentClient;
24 
import in.shop2020.thrift.clients.TransactionClient;
25 
import in.shop2020.thrift.clients.UserClient;
26 
 
27 
import java.io.File;
28 
import java.text.SimpleDateFormat;
29 
import java.util.ArrayList;
30 
import java.util.Calendar;
31 
import java.util.Collections;
32 
import java.util.Date;
33 
import java.util.List;
34 
import java.util.TimeZone;
35 
 
36 
import javax.xml.bind.JAXBContext;
37 
import javax.xml.bind.JAXBException;
38 
import javax.xml.bind.Marshaller;
39 
import javax.xml.bind.Unmarshaller;
40 
 
41 
import org.apache.thrift.TException;
42 
import org.apache.thrift.transport.TTransportException;
43 
 
44 
import order.SaholicAPI;
45 
import order.ObjectFactory;
46 
import order.SaholicAPI.Order;
47 
 
48 
public class ProcessSnapdealOrder {
8627 vikram.rag 49 
	//private static final int SNAPDEAL_SOURCE_ID = 3;
8616 vikram.rag 50 
	private static final int SNAPDEAL_SOURCE_ID = 7;
51 
	private static final String FIRSTFLIGHT = "First Flight";
8627 vikram.rag 52 
	private static final String DELHIVERY = "DELHIVERY";
53 
	private static final String BLUEDART = "Bluedart";
54 
	private static String transactionId;
55 
	private static final int SNAPDEAL_GATEWAY_ID = 18;
56 
 
8616 vikram.rag 57 
	public static void processSnapdealOrders(File file) throws JAXBException{
58 
		JAXBContext jc = JAXBContext.newInstance(SaholicAPI.class);
59 
		Unmarshaller unmarshaller = jc.createUnmarshaller();
60 
		SaholicAPI orders = (SaholicAPI) unmarshaller.unmarshal(file);
61 
		Marshaller marshaller = jc.createMarshaller();
62 
		marshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
63 
		marshaller.marshal(orders, System.out);
64 
		SourceDetail sourceDetail = null;
65 
		User user = null;
66 
		TransactionClient tsc = null;
67 
		try {
68 
			tsc = new TransactionClient();
69 
			sourceDetail = tsc.getClient().getSourceDetail(SNAPDEAL_SOURCE_ID);
70 
		} catch (Exception e) {
71 
		}
72 
		try {
73 
			in.shop2020.model.v1.user.UserContextService.Client userClient = new UserClient().getClient();
74 
			user = userClient.getUserByEmail(sourceDetail.getEmail());
75 
		} catch (Exception e) {
76 
		}
77 
		for(Order order:orders.getOrder()){
8627 vikram.rag 78 
			long subOrderId = (long) order.getSuborderId();
79 
			Client transaction_client = null;
80 
			try {
81 
				transaction_client = new TransactionClient().getClient();
82 
				//transaction_client.snapdealOrderExists(subOrderId);
83 
				System.out.println("Suborder id " + subOrderId);
84 
				if(transaction_client.snapdealOrderExists(subOrderId)) {
85 
					System.out.println("Suborder id exists");
86 
					continue;
87 
				}
88 
 
89 
			} catch (TTransportException e1) {
90 
				// TODO Auto-generated catch block
91 
				e1.printStackTrace();
92 
			} catch (TException e) {
93 
				// TODO Auto-generated catch block
94 
				e.printStackTrace();
95 
			}
96 
			System.out.println("Inside Order Parsing");
8616 vikram.rag 97 
			Transaction txn = new Transaction();
8627 vikram.rag 98 
			System.out.println("User details are " + user.getActiveCartId());
8616 vikram.rag 99 
			txn.setShoppingCartid(user.getActiveCartId());
8627 vikram.rag 100 
			System.out.println("transaction created");
8616 vikram.rag 101 
			txn.setCustomer_id(user.getUserId());
8627 vikram.rag 102 
			System.out.println("User Id is " + user.getUserId());
8616 vikram.rag 103 
			txn.setCreatedOn(new Date().getTime());
104 
			txn.setTransactionStatus(TransactionStatus.INIT);
105 
			txn.setStatusDescription("Order for Snapdeal ");
106 
			List<in.shop2020.model.v1.order.Order> orderlist = new ArrayList<in.shop2020.model.v1.order.Order>();
107 
			LineItem lineItem = null;
108 
			try {
109 
				lineItem = createLineItem(order.getSKUCode(),order.getSellingPricePerItem());
8627 vikram.rag 110 
				System.out.println("Line item created");
8616 vikram.rag 111 
			} catch (CatalogServiceException e) {
112 
				// TODO Auto-generated catch block
113 
				e.printStackTrace();
114 
			} catch (TException e) {
115 
				// TODO Auto-generated catch block
116 
				e.printStackTrace();
117 
			}
118 
			in.shop2020.model.v1.order.Order t_order = new in.shop2020.model.v1.order.Order();
8627 vikram.rag 119 
			t_order.setCustomer_id(user.getUserId());
120 
			t_order.setCustomer_email(sourceDetail.getEmail());
121 
			t_order.setCustomer_name(order.getCustomerName());
122 
			t_order.setCustomer_address1("");
123 
			t_order.setCustomer_address2("");
124 
			t_order.setCustomer_city(order.getCity());
125 
			t_order.setCustomer_state(order.getState());
126 
			t_order.setCustomer_pincode(String.valueOf(order.getPINCode()));
127 
			t_order.setTotal_amount(lineItem.getTotal_price());
128 
			t_order.setTotal_weight(lineItem.getTotal_weight());
129 
			t_order.setLineitems(Collections.singletonList(lineItem));
130 
			t_order.setStatus(OrderStatus.SUBMITTED_FOR_PROCESSING);
131 
			t_order.setStatusDescription("In Process");
132 
			t_order.setCreated_timestamp(new Date().getTime());
133 
			t_order.setOrderType(OrderType.B2C);
134 
			t_order.setCod(false);
135 
			System.out.println("t order created");
136 
			try {
137 
				Calendar time = Calendar.getInstance();
138 
				time.add(Calendar.DAY_OF_MONTH, 1);
139 
				t_order.setPromised_shipping_time(time.getTimeInMillis());
140 
				t_order.setExpected_shipping_time(time.getTimeInMillis());
141 
				time.add(Calendar.DAY_OF_MONTH, 3);
142 
				t_order.setPromised_delivery_time(time.getTimeInMillis());
143 
				t_order.setExpected_delivery_time(time.getTimeInMillis());
144 
				System.out.println("Dates set in transaction");
145 
			} catch(Exception e) {
146 
				continue;
147 
			}
148 
			/*InventoryService.Client inventoryClient = null;
149 
            //Warehouse fulfillmentWarehouse= null;
8616 vikram.rag 150 
            try {
8627 vikram.rag 151 
            	//inventoryClient = new InventoryClient().getClient();
152 
        		//VendorItemPricing vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), fulfillmentWarehouse.getVendor().getId());
153 
        		//t_order.getLineitems().get(0).setTransfer_price(vendorItemPricing.getTransferPrice());
154 
        		//t_order.getLineitems().get(0).setNlc(vendorItemPricing.getNlc());
8616 vikram.rag 155 
			} catch (InventoryServiceException e) {
156 
            	continue;
157 
			} catch (TTransportException e) {
158 
				// TODO Auto-generated catch block
159 
				e.printStackTrace();
160 
			} catch (TException e) {
161 
				// TODO Auto-generated catch block
162 
				e.printStackTrace();
8627 vikram.rag 163 
			}*/
8616 vikram.rag 164 
			if(order.getCourier().equalsIgnoreCase(FIRSTFLIGHT)) {
165 
				t_order.setLogistics_provider_id(12);
166 
			} else if(order.getCourier().equalsIgnoreCase(DELHIVERY)) {
167 
				t_order.setLogistics_provider_id(13);
168 
			} else if(order.getCourier().equalsIgnoreCase(BLUEDART)) {
169 
				t_order.setLogistics_provider_id(14);
170 
			} else {
8627 vikram.rag 171 
				System.out.println("No Courier Match");
172 
				continue;
8616 vikram.rag 173 
			}
8627 vikram.rag 174 
 
8616 vikram.rag 175 
			t_order.setAirwaybill_no(String.valueOf(order.getAWBNumber()));
176 
			t_order.setTracking_id(String.valueOf(order.getAWBNumber()));
8627 vikram.rag 177 
			t_order.setTotal_amount(order.getSellingPricePerItem());
178 
			t_order.setOrderType(OrderType.B2C);
179 
			t_order.setSource(SNAPDEAL_SOURCE_ID);
180 
			t_order.setOrderType(OrderType.B2C);
181 
			orderlist.add(t_order);
182 
			txn.setOrders(orderlist);
8616 vikram.rag 183 
			try {
8627 vikram.rag 184 
				String referenceCode = order.getReferenceCode();
185 
				String productName = order.getProduct();
186 
				SimpleDateFormat istFormatter = new SimpleDateFormat("dd/mm/yyyy");
187 
				//SimpleDateFormat istFormatter = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss");
188 
				Date snapdealTxnDate = istFormatter.parse(order.getOrderPlacedDate());
189 
				transactionId =  String.valueOf(transaction_client.createTransaction(txn));
190 
				createPayment(user, (new Long(subOrderId)).toString(), lineItem.getTotal_price());
191 
 
192 
				Transaction transaction = transaction_client.getTransaction(Long.parseLong(transactionId));
193 
				in.shop2020.model.v1.order.Order snapdealorder = transaction.getOrders().get(0);
194 
 
195 
				//inventoryClient.reserveItemInWarehouse(lineItem.getItem_id(), fulfillmentWarehouse.getId(), 1,
196 
				//		snapdealorder.getId(), snapdealorder.getCreated_timestamp(), snapdealorder.getPromised_shipping_time(), snapdealorder.getLineitems().get(0).getQuantity());
197 
 
198 
 
199 
				SnapdealOrder snapdealOrder = new SnapdealOrder();
200 
				snapdealOrder.setOrderId(snapdealorder.getId());
201 
				snapdealOrder.setSubOrderId(subOrderId);
202 
				snapdealOrder.setReferenceCode(referenceCode);
203 
				snapdealOrder.setProductName(productName);
204 
				snapdealOrder.setSnapdealTxnDate(snapdealTxnDate.getTime());
205 
				snapdealOrder.setListingPrice(lineItem.getTotal_price());
206 
				transaction_client.createSnapdealOrder(snapdealOrder);
207 
 
208 
			} catch (Exception e) {
209 
				System.out.println("Exception in finding suborderid");
210 
				continue;
8616 vikram.rag 211 
			}
8627 vikram.rag 212 
 
213 
 
8616 vikram.rag 214 
		}
215 
 
216 
	}
217 
 
218 
	public static void createPayment(User user, String subOrderId, double amount) throws NumberFormatException, PaymentException, TException {
8627 vikram.rag 219 
		in.shop2020.payments.PaymentService.Client client = new PaymentClient().getClient();
220 
		long paymentId = client.createPayment(user.getUserId(), amount, SNAPDEAL_GATEWAY_ID, Long.valueOf(transactionId), false);
221 
		client.updatePaymentDetails(paymentId, null, null, null, null, null, null, subOrderId, null, PaymentStatus.AUTHORIZED, null, null);
222 
	}
223 
 
8616 vikram.rag 224 
	public static LineItem createLineItem(long itemId, double amount) throws CatalogServiceException, TException {
8627 vikram.rag 225 
		LineItem lineItem = new LineItem();
226 
		CatalogService.Client catalogClient = new CatalogClient().getClient();
227 
		Item item = catalogClient.getItem(itemId);
8616 vikram.rag 228 
 
8627 vikram.rag 229 
		lineItem.setProductGroup(item.getProductGroup());
230 
		lineItem.setBrand(item.getBrand());
231 
		lineItem.setModel_number(item.getModelNumber());
232 
		lineItem.setModel_name(item.getModelName());
233 
		lineItem.setExtra_info(item.getFeatureDescription());
234 
		lineItem.setQuantity(1);
235 
		lineItem.setItem_id(item.getId());
236 
		lineItem.setUnit_weight(item.getWeight());
237 
		lineItem.setTotal_weight(item.getWeight());
238 
		lineItem.setUnit_price(amount);
239 
		lineItem.setTotal_price(amount);
240 
 
241 
		if (item.getColor() == null || "NA".equals(item.getColor())) {
242 
			lineItem.setColor("");
243 
		} else {
244 
			lineItem.setColor(item.getColor());
245 
		}
246 
		return lineItem;
8616 vikram.rag 247 
	}
248 
 
249 
}