Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
8961 vikram.rag 1 
package in.shop2020.support.controllers;
2 
 
3 
import in.shop2020.model.v1.catalog.Amazonlisted;
4 
import in.shop2020.model.v1.catalog.CatalogService;
5 
import in.shop2020.model.v1.catalog.CatalogServiceException;
6 
import in.shop2020.model.v1.catalog.Item;
8994 vikram.rag 7 
import in.shop2020.model.v1.catalog.SnapdealItem;
8961 vikram.rag 8 
import in.shop2020.model.v1.inventory.InventoryService;
9 
import in.shop2020.model.v1.inventory.InventoryServiceException;
10 
import in.shop2020.model.v1.inventory.InventoryType;
11 
import in.shop2020.model.v1.inventory.VendorItemPricing;
12 
import in.shop2020.model.v1.inventory.Warehouse;
13 
import in.shop2020.model.v1.inventory.WarehouseType;
14 
import in.shop2020.model.v1.order.AmazonFbaSalesSnapshot;
15 
import in.shop2020.model.v1.order.FlipkartOrder;
16 
import in.shop2020.model.v1.order.LineItem;
17 
import in.shop2020.model.v1.order.OrderStatus;
18 
import in.shop2020.model.v1.order.OrderType;
19 
import in.shop2020.model.v1.order.SourceDetail;
20 
import in.shop2020.model.v1.order.Transaction;
21 
import in.shop2020.model.v1.order.TransactionServiceException;
22 
import in.shop2020.model.v1.order.TransactionStatus;
23 
import in.shop2020.model.v1.order.TransactionService.Client;
24 
import in.shop2020.model.v1.user.User;
25 
import in.shop2020.payments.PaymentException;
26 
import in.shop2020.payments.PaymentStatus;
27 
import in.shop2020.support.utils.ReportsUtils;
28 
import in.shop2020.thrift.clients.CatalogClient;
29 
import in.shop2020.thrift.clients.InventoryClient;
30 
import in.shop2020.thrift.clients.PaymentClient;
31 
import in.shop2020.thrift.clients.TransactionClient;
32 
import in.shop2020.thrift.clients.UserClient;
8995 vikram.rag 33 
import in.shop2020.utils.GmailUtils;
8961 vikram.rag 34 
 
35 
import java.io.BufferedInputStream;
36 
import java.io.BufferedReader;
37 
import java.io.File;
38 
import java.io.FileInputStream;
39 
import java.io.FileNotFoundException;
40 
import java.io.FileOutputStream;
41 
import java.io.FileReader;
42 
import java.io.FileWriter;
43 
import java.io.IOException;
44 
import java.io.InputStream;
45 
import java.io.Writer;
46 
import java.text.ParseException;
47 
import java.text.SimpleDateFormat;
48 
import java.util.ArrayList;
49 
import java.util.Arrays;
50 
import java.util.Calendar;
51 
import java.util.Collections;
52 
import java.util.Date;
8995 vikram.rag 53 
import java.util.GregorianCalendar;
8961 vikram.rag 54 
import java.util.HashMap;
55 
import java.util.List;
56 
import java.util.Map;
57 
 
58 
import javax.servlet.ServletContext;
59 
import javax.servlet.ServletOutputStream;
60 
import javax.servlet.http.HttpServletRequest;
61 
import javax.servlet.http.HttpServletResponse;
62 
import javax.servlet.http.HttpSession;
63 
 
64 
import org.apache.commons.io.FileUtils;
65 
import org.apache.commons.lang.xwork.StringUtils;
66 
import org.apache.poi.hssf.usermodel.HSSFRow;
67 
import org.apache.poi.hssf.usermodel.HSSFSheet;
68 
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
69 
import org.apache.poi.ss.usermodel.Cell;
70 
import org.apache.struts2.convention.annotation.InterceptorRef;
71 
import org.apache.struts2.convention.annotation.InterceptorRefs;
72 
import org.apache.struts2.interceptor.ServletRequestAware;
73 
import org.apache.struts2.interceptor.ServletResponseAware;
74 
import org.apache.struts2.util.ServletContextAware;
75 
import org.apache.thrift.TException;
76 
import org.apache.thrift.transport.TTransportException;
77 
import org.slf4j.Logger;
78 
import org.slf4j.LoggerFactory;
79 
 
80 
import au.com.bytecode.opencsv.CSVReader;
81 
 
82 
import com.opensymphony.xwork2.ValidationAwareSupport;
83 
 
84 
public class FlipkartDashboardController extends ValidationAwareSupport implements ServletRequestAware ,ServletResponseAware, ServletContextAware{
85 
	private static Logger logger = LoggerFactory.getLogger(FlipkartDashboardController.class);
86 
	private static final int FLIPKART_SOURCE_ID = 8;
8963 vikram.rag 87 
	private static final int FLIPKART_GATEWAY_ID = 17;
8962 vikram.rag 88 
	private static final int FLIPKART_LOGISTICS_ID = 19;
8961 vikram.rag 89 
	private HttpServletRequest request;
90 
	private HttpServletResponse response;
91 
	private HttpSession session;
92 
	private ServletContext context;
93 
	private String url;
94 
	private File file;
95 
	private String errMsg;
96 
	private String id;
97 
	private static String transactionId;
98 
	public String uploadorders(){
99 
		if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0])) {
100 
			logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1].split("!")[0]);
101 
			return "authfail";
102 
		}
103 
		return "flipkart-upload-orders";
104 
	}
105 
	public String show() {
106 
		logger.info("Before fetching role");
107 
		logger.info(request.getSession().toString());
108 
		logger.info(ReportsUtils.ROLE);
109 
		logger.info(session.getAttribute(ReportsUtils.ROLE).toString());
110 
		logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1]);
111 
		if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getRequestURI().substring(request.getContextPath().length()).split("/")[1])) {
112 
			logger.info(request.getRequestURI().substring(request.getContextPath().length()).split("/")[1]);
113 
			return "authfail";
114 
		}
115 
 
116 
		if (StringUtils.equals(id, "flipkart-options")){
117 
			return "flipkart-options";
118 
		}
119 
 
120 
		return "id";
121 
	}
122 
	public void uploadOrdersFile() throws IOException, CatalogServiceException, TException{
123 
		File fileToCreate = new File("/tmp/", "Flipkart-Orders.csv");
124 
		FileUtils.copyFile(this.file, fileToCreate);
125 
		FileInputStream iFile = new FileInputStream(new File(file.getAbsolutePath()));
126 
		CSVReader orderfilereader = null;
127 
		replacecommas(fileToCreate);
128 
		try {
129 
			orderfilereader = new CSVReader(new FileReader("/tmp/formatted.csv"),'$');
130 
		} catch (FileNotFoundException e) {
131 
			// TODO Auto-generated catch block
132 
			e.printStackTrace();
133 
		}
134 
		logger.info("Before Processing orders ");
135 
		String [] nextLine;
8971 vikram.rag 136 
		StringBuffer sb = new StringBuffer();
8974 vikram.rag 137 
		int orders_processed = 0;
8961 vikram.rag 138 
		try {
139 
			User user = null;
140 
			TransactionClient tsc = null;
141 
			SourceDetail sourceDetail = null;
142 
			logger.info("Before Fetching sourcedetail");
143 
			try {
144 
				tsc = new TransactionClient();
145 
				sourceDetail = tsc.getClient().getSourceDetail(FLIPKART_SOURCE_ID);
146 
				logger.info("Flipkart sourcedetail " + sourceDetail.getEmail() + " " + sourceDetail.getName());
147 
			} catch (Exception e) {
148 
				logger.error("Unable to establish connection to the transaction service while getting Flipkart Source Detail ", e);
149 
			}
150 
			try {
151 
				in.shop2020.model.v1.user.UserContextService.Client userClient = new UserClient().getClient();
152 
				logger.info("Before Fetching User by Email");
153 
				user = userClient.getUserByEmail(sourceDetail.getEmail());
154 
				logger.info("User is " + user.getEmail());
155 
			} catch (Exception e) {
156 
				logger.error("Unable to establish connection to the User service ", e);
157 
			}
158 
			logger.info("Before iterating orders in file");
8970 vikram.rag 159 
			while ((nextLine = orderfilereader.readNext()) != null && nextLine.length!=0) {
8973 vikram.rag 160 
				logger.info("Order file entry  " + nextLine + " Length " + nextLine.length);
8961 vikram.rag 161 
				String orderId,subOrderId,create_date;
162 
				long sku;
163 
				logger.info("Processing order " + nextLine[3]+ " " + nextLine[4]);
164 
				if(nextLine[3].length()==0 || nextLine[4].length()==0 ){
165 
					sb.append(" Could not parse order id " + nextLine[3]+ " " + nextLine[4] + "\n");
166 
					logger.info("Processing order " + nextLine[3]+ " " + nextLine[4]);
167 
					continue;
168 
				}
169 
				else{
170 
					orderId = nextLine[3];
171 
					subOrderId = nextLine[4];
172 
				}
173 
 
174 
				if(nextLine[0].length()!=0){
175 
					create_date = nextLine[0];
176 
				}
177 
				else{
178 
					sb.append(orderId+" "+subOrderId + " Could not parse order date" +"\n");
179 
					logger.info(orderId+" "+subOrderId + " Could not parse order date");
180 
					continue;
8970 vikram.rag 181 
				}
8961 vikram.rag 182 
				if(nextLine[5].length()==0){
183 
					sb.append(orderId+" "+subOrderId + " Could not parse sku" +"\n");
184 
					logger.info(orderId+" "+subOrderId + " Could not parse sku");
185 
					continue;
186 
				}
187 
				else{
188 
					sku =  Long.parseLong(nextLine[5]);
189 
					logger.info(orderId+" "+subOrderId + " Processing  sku " + sku);
190 
				}
191 
				if(nextLine[6].length()!=0 && nextLine[6].equalsIgnoreCase("Approved")){
192 
					String status = nextLine[6];
193 
				}
194 
				else{
195 
					if(nextLine[6].length()==0){
9007 vikram.rag 196 
						sb.append(orderId+" "+subOrderId + " Could not parse status" +"\n");
197 
						logger.info(orderId+" "+subOrderId + " Could not parse status" +"\n");
8961 vikram.rag 198 
					}
9007 vikram.rag 199 
					else{
200 
						sb.append(orderId+" "+subOrderId + "Order not Approved" +"\n");
201 
						logger.info(orderId+" "+subOrderId + "Order not Approved" +"\n");
202 
					}
8961 vikram.rag 203 
					continue;
204 
				}
205 
				double unitSellingPrice,shippingPrice,octroiFee,emiFee;
206 
				if(nextLine[7].length()!=0 ){
207 
					if(Double.parseDouble(nextLine[7]) > 0){
208 
						unitSellingPrice =  Double.parseDouble(nextLine[7]);
209 
					}
210 
					else{
211 
						sb.append(orderId+" "+subOrderId + " Unit Price set to 0 " +"\n");
212 
						logger.info(orderId+" "+subOrderId + " Unit Price set to 0 " +"\n");
213 
						continue;
214 
					}
215 
				}
216 
				else{
217 
					sb.append(orderId+" "+subOrderId + " Unit Price not set " +"\n");
218 
					logger.info(orderId+" "+subOrderId + " Unit Price not set " +"\n");
219 
					continue;
220 
				}
221 
				if(nextLine[8].length()!=0){
222 
					shippingPrice  =  Double.parseDouble(nextLine[8]);
223 
				}
224 
				else{
225 
					shippingPrice=0;
226 
				}
227 
				if(nextLine[9].length()!=0){
228 
					octroiFee =  Double.parseDouble(nextLine[9]);
229 
					if(octroiFee >0){
230 
						sb.append(orderId+" "+subOrderId + " OctroiFee :"+ octroiFee +"\n");
231 
						logger.info(orderId+" "+subOrderId + " OctroiFee :"+ octroiFee +"\n");
232 
					}
233 
				}
234 
				else{
235 
					octroiFee=0;
236 
				}
237 
				if(nextLine[10].length()!=0){
238 
					emiFee =  Double.parseDouble(nextLine[10]);
239 
					if(emiFee >0){
240 
						sb.append(orderId+" "+subOrderId + " EMI :"+ emiFee +"\n");
241 
						logger.info(orderId+" "+subOrderId + " EMI :"+ emiFee +"\n");
242 
					}
243 
				}
244 
				else{
245 
					emiFee = 0;
246 
				}
247 
				int quantity;
248 
				if(nextLine[11].length()!=0){
249 
					quantity = Integer.parseInt(nextLine[11]);
250 
					if(quantity > 1){
251 
						sb.append(orderId+" "+subOrderId + " Quantity > 1 " +"\n");
252 
						logger.info(orderId+" "+subOrderId + " Quantity > 1 " +"\n");
253 
					}
254 
					else{
255 
						if(quantity==0){
256 
							sb.append(orderId+" "+subOrderId + " Quantity not set " +"\n");
257 
							logger.info(orderId+" "+subOrderId + " Quantity not set " +"\n");
258 
							continue;
259 
						}
260 
					}
261 
				}
262 
				else{
263 
					sb.append(orderId+" "+subOrderId + " Quantity not set " +"\n");
264 
					logger.info(orderId+" "+subOrderId + " Quantity not set " +"\n");
265 
					continue;
266 
				}
267 
				double totalsellingPrice;
268 
				if(nextLine[12].length()!=0){
269 
					totalsellingPrice= Double.parseDouble(nextLine[12]);
270 
					if(totalsellingPrice==0){
271 
						sb.append(orderId+" "+subOrderId + " Total Selling Price set to 0 " +"\n");
272 
						logger.info(orderId+" "+subOrderId + " Total Selling Price set to 0 " +"\n");
273 
						continue;
274 
					}
275 
				}
276 
				else{
277 
					sb.append(orderId+" "+subOrderId + " Total Selling Price not set " +"\n");
278 
					logger.info(orderId+" "+subOrderId + " Total Selling Price not set " +"\n");
279 
					continue;
280 
				}
8973 vikram.rag 281 
 
282 
				String shipToName,addressLine1,addressLine2,city,state,pincode,buyerName="unknown";
283 
				if(nextLine[17].length()>0){
284 
					buyerName = nextLine[17];
285 
				}
286 
				else{
287 
					sb.append(orderId+" "+subOrderId + " Buyer Name not set " +"\n");
288 
					logger.info(orderId+" "+subOrderId + " Buyer Name not set " +"\n");
289 
				}
8961 vikram.rag 290 
				if(nextLine[18].length()>0){
291 
					shipToName = nextLine[18];
292 
				}
293 
				else{
294 
					sb.append(orderId+" "+subOrderId + " Ship to Name not set " +"\n");
295 
					logger.info(orderId+" "+subOrderId + " Ship to Name not set " +"\n");
296 
					continue;
297 
				}
8973 vikram.rag 298 
				if(buyerName.contains("unknown")){
299 
		    		buyerName = shipToName;
300 
		    	}
8961 vikram.rag 301 
				if(nextLine[19].length()>0){
302 
					addressLine1 = nextLine[19];
303 
				}
304 
				else{
305 
					addressLine1 ="";
306 
				}
307 
				if(nextLine[20].length()>0){
308 
					addressLine2 = nextLine[20];
309 
				}
310 
				else{
311 
					addressLine2 ="";
312 
				}
313 
				if(nextLine[21].length()>0){
314 
					city = nextLine[21];
315 
				}
316 
				else{
317 
					sb.append(orderId+" "+subOrderId + " City not set " +"\n");
318 
					logger.info(orderId+" "+subOrderId + " City not set " +"\n");
319 
					continue;
320 
				}
321 
				if(nextLine[22].length()>0){
322 
					state = nextLine[22];
323 
				}
324 
				else{
325 
					sb.append(orderId+" "+subOrderId + " State not set " +"\n");
326 
					logger.info(orderId+" "+subOrderId + " State not set " +"\n");
327 
					continue;
328 
				}
329 
				if(nextLine[23].length()>0){
330 
					pincode = nextLine[23];
331 
				}
332 
				else{
333 
					sb.append(orderId+" "+subOrderId + " Pincode not set " +"\n");
334 
					logger.info(orderId+" "+subOrderId + " Pincode not set " +"\n");
335 
					continue;
336 
				}
337 
				int sla;
338 
				if(nextLine[23].length()>0){
339 
					sla = Integer.parseInt(nextLine[24]);
340 
				}
341 
				else{
342 
					sb.append(orderId+" "+subOrderId + " Ship to date not available " +"\n");
343 
					logger.info(orderId+" "+subOrderId + " Ship to date not available " +"\n");
344 
					continue;
345 
				}
346 
				//String shipByDate = nextLine[26];
347 
				Client transaction_client = null;
348 
				try {
349 
					transaction_client = new TransactionClient().getClient();
350 
					if(transaction_client.flipkartOrderExists(orderId,subOrderId)) {
351 
						logger.error("Flipkart order exists " + "id : " + orderId + " suborder id : ");
352 
						continue;
353 
					}
354 
 
355 
				} catch (TTransportException e1) {
356 
					logger.error("Problem with Transaction service " , e1);
357 
					e1.printStackTrace();
358 
				} catch (TException e) {
359 
					logger.error("Problem.. thrift exception with Transaction service " , e);
360 
					e.printStackTrace();
361 
				}
362 
				SimpleDateFormat istFormatter = new SimpleDateFormat("MMM dd, yyyy");
363 
				Date flipkartTxnDate = null;
364 
				try {
365 
					create_date = create_date.replaceAll("\"","");
366 
					flipkartTxnDate = istFormatter.parse(create_date);
367 
				} catch (ParseException e) {
368 
					logger.error(orderId+" "+subOrderId + " Could not parse flipkart order date from file " , e);
369 
					sb.append(orderId+" "+subOrderId + " Could not parse order date" +"\n");
370 
					continue;
371 
				}
372 
				Transaction txn = new Transaction();
373 
				txn.setShoppingCartid(user.getActiveCartId());
374 
				txn.setCustomer_id(user.getUserId());
375 
				System.out.println("User Id is " + user.getUserId());
376 
				txn.setCreatedOn(new Date().getTime());
377 
				txn.setTransactionStatus(TransactionStatus.INIT);
378 
				txn.setStatusDescription("Order for flipkart ");
379 
				List<in.shop2020.model.v1.order.Order> orderlist = new ArrayList<in.shop2020.model.v1.order.Order>();
380 
				double total_price=0;
381 
				InventoryService.Client inventoryClient = null;
382 
				Warehouse fulfillmentWarehouse= null;
383 
				for(int i=0;i<quantity;i++){
384 
					LineItem lineItem = null;
385 
					lineItem = createLineItem(sku,unitSellingPrice);
8965 vikram.rag 386 
					logger.info(orderId+" "+subOrderId + "sku and Price " + sku + " " + unitSellingPrice);
8961 vikram.rag 387 
					lineItem.setExtra_info("flipkartOrderId = " + orderId + " flipkartsubOrderId = " + subOrderId);
388 
					in.shop2020.model.v1.order.Order t_order = new in.shop2020.model.v1.order.Order();
389 
					t_order.setCustomer_id(user.getUserId());
390 
					t_order.setCustomer_email(sourceDetail.getEmail());
391 
					t_order.setCustomer_name(shipToName);
392 
					addressLine1 = addressLine1.replaceAll("\"","");
393 
					t_order.setCustomer_address1(addressLine1);
394 
					addressLine2 = addressLine2.replaceAll("\"","");
395 
					t_order.setCustomer_address2(addressLine2);
396 
					t_order.setCustomer_city(city);
397 
					t_order.setCustomer_state(state);
398 
					t_order.setCustomer_pincode(pincode);
399 
					t_order.setTotal_amount(unitSellingPrice);
400 
					t_order.setTotal_weight(lineItem.getTotal_weight());
401 
					t_order.setLineitems(Collections.singletonList(lineItem));
402 
					t_order.setStatus(OrderStatus.PAYMENT_PENDING);
9003 vikram.rag 403 
					t_order.setStatusDescription("In Process");
8961 vikram.rag 404 
					t_order.setCreated_timestamp(new Date().getTime());
405 
					t_order.setOrderType(OrderType.B2C);
406 
					t_order.setCod(false);
407 
					try {
408 
						Date shipDate = new Date();
409 
						shipDate.setTime( flipkartTxnDate.getTime() + sla*24*60*60*1000);
410 
						Calendar time = Calendar.getInstance();
411 
						t_order.setPromised_shipping_time(shipDate.getTime());
412 
						t_order.setExpected_shipping_time(shipDate.getTime());
413 
						time.add(Calendar.DAY_OF_MONTH, 4);
414 
						t_order.setPromised_delivery_time(time.getTimeInMillis());
415 
						t_order.setExpected_delivery_time(time.getTimeInMillis());
416 
					} catch(Exception e) {
417 
						logger.error("Error in updating Shipping or Delivery Time for suborderid  " + subOrderId);
418 
						sb.append(orderId + " "+ subOrderId  + " Could not update delivery time" + " " + "\n");
419 
						continue;
420 
					}
9001 vikram.rag 421 
					SnapdealItem snapdealItem = new CatalogClient().getClient().getSnapdealItem(sku);
422 
					inventoryClient = new InventoryClient().getClient();
8961 vikram.rag 423 
					try {
8999 vikram.rag 424 
						logger.info("Snapdeal Item id is " + snapdealItem.getItem_id());
8994 vikram.rag 425 
						if(snapdealItem.getItem_id()!=0 && snapdealItem.getWarehouseId()!=0) {
8999 vikram.rag 426 
							logger.info("SnapdealItem Warehouse Id " + snapdealItem.getWarehouseId());
8994 vikram.rag 427 
							fulfillmentWarehouse = inventoryClient.getWarehouse(snapdealItem.getWarehouseId());
8999 vikram.rag 428 
							logger.info("fulfillmentWarehouse is " + fulfillmentWarehouse.getId() + " " + fulfillmentWarehouse.getDisplayName() );
429 
 
8994 vikram.rag 430 
						} else {
431 
							List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(sku, 1);
432 
							fulfillmentWarehouse = inventoryClient.getWarehouse(itemAvailability.get(0));
433 
							if(fulfillmentWarehouse.getStateId()!=0){
434 
								fulfillmentWarehouse = inventoryClient.getWarehouse(7);
435 
							}
8961 vikram.rag 436 
						}
437 
						t_order.setFulfilmentWarehouseId(fulfillmentWarehouse.getId());
438 
						long billingWarehouseId = 0;
439 
						if(fulfillmentWarehouse.getBillingWarehouseId()== 0) {
440 
							inventoryClient = new InventoryClient().getClient();
441 
							List<Warehouse> warehouses = inventoryClient.getWarehouses(WarehouseType.OURS, InventoryType.GOOD, fulfillmentWarehouse.getVendor().getId(), 0, 0);
442 
							for(Warehouse warehouse : warehouses) {
443 
								if(warehouse.getBillingWarehouseId()!=0) {
444 
									billingWarehouseId = warehouse.getBillingWarehouseId();
8994 vikram.rag 445 
					                break;
8961 vikram.rag 446 
								}
447 
							}
448 
						}else {
449 
							billingWarehouseId = fulfillmentWarehouse.getBillingWarehouseId();
450 
						}
8994 vikram.rag 451 
 
452 
						//logger.info("Billing warehouse id for suborderid  " + order.getSuborderId() + " is " + fulfillmentWarehouse.getBillingWarehouseId());
8961 vikram.rag 453 
						t_order.setWarehouse_id(billingWarehouseId);
454 
						VendorItemPricing vendorItemPricing = new VendorItemPricing();
455 
						if(fulfillmentWarehouse.getId()==7) {
456 
							Item item = new CatalogClient().getClient().getItem(lineItem.getItem_id());
457 
							vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), item.getPreferredVendor());
458 
						} else {
459 
							vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), fulfillmentWarehouse.getVendor().getId());
460 
						}
8994 vikram.rag 461 
 
8961 vikram.rag 462 
						t_order.getLineitems().get(0).setTransfer_price(vendorItemPricing.getTransferPrice());
463 
						t_order.getLineitems().get(0).setNlc(vendorItemPricing.getNlc());
464 
					} catch (InventoryServiceException e) {
465 
						logger.error("Error connecting inventory service for suborderid  " + orderId + " " + subOrderId , e);
466 
						sb.append(orderId + " " + subOrderId+ " Inventory Service Exception" + " " + "\n");
467 
						continue;
468 
					} catch (TTransportException e) {
469 
						logger.error("Transport Exception with Inventory Service for suborderid  " + orderId + " " + subOrderId , e);
470 
						sb.append(orderId + " " + subOrderId + " Transport Exception with Inventory Service" + " " + "\n");
471 
						continue;
472 
					} catch (TException e) {
473 
						logger.error("Exception with Inventory Service for suborderid  " + orderId + " " + subOrderId , e);
474 
						sb.append(orderId + " " + subOrderId + " Exception in Inventory Service" + " " + "\n");
475 
						continue;
476 
					} catch (CatalogServiceException e) {
477 
						logger.error("Exception with Catalog Service for   " + orderId + " " + subOrderId + " while getting item " + lineItem.getItem_id(), e);
478 
						sb.append(orderId + " " + subOrderId + " Exception in Catalog Service" + " " + "\n");
479 
						continue;
480 
					}
8962 vikram.rag 481 
					t_order.setLogistics_provider_id(FLIPKART_LOGISTICS_ID);
8961 vikram.rag 482 
					t_order.setAirwaybill_no("");
483 
					t_order.setTracking_id("");
484 
					t_order.setTotal_amount(unitSellingPrice);
485 
					t_order.setOrderType(OrderType.B2C);
486 
					t_order.setSource(FLIPKART_SOURCE_ID);
487 
					t_order.setOrderType(OrderType.B2C);
488 
					total_price = total_price + unitSellingPrice;
489 
					orderlist.add(t_order);
490 
				}
491 
				txn.setOrders(orderlist);
492 
				try {
493 
					transactionId =  String.valueOf(transaction_client.createTransaction(txn));
8965 vikram.rag 494 
					logger.info("Transaction id is : " + transactionId);
8961 vikram.rag 495 
				} catch (TransactionServiceException e) {
496 
					logger.error(orderId+" "+subOrderId + " Could not create transaction " , e);
497 
					sb.append(orderId+" "+subOrderId + " Could not create transaction" +"\n");
498 
					logger.info(orderId+" "+subOrderId + " Could not create transaction" +"\n");
499 
					continue;
500 
				} catch (TException e) {
501 
					logger.error("Problem with transaction service while creating transaction", e);
502 
					sb.append(orderId+" "+subOrderId + " Transaction Service Exception could not create transaction" +"\n");
503 
					logger.info(orderId+" "+subOrderId + " Transaction Service Exception could not create transaction" +"\n");
504 
					continue;
505 
				}
506 
				try{
8965 vikram.rag 507 
					logger.info("Creating payment for suborder id " + subOrderId);
8964 vikram.rag 508 
					createPayment(user,subOrderId,unitSellingPrice);
8961 vikram.rag 509 
				}
510 
				catch (NumberFormatException e) {
511 
					logger.error("Could not create payment",e);
512 
					sb.append(orderId+" "+subOrderId + " Could not create payment");
513 
					e.printStackTrace();
514 
					continue;
515 
				} catch (PaymentException e) {
516 
					logger.error("Could not create payment payment exception",e);
517 
					sb.append(orderId+" "+subOrderId + " Could not create payment Payment exception");
518 
					e.printStackTrace();
519 
					continue;
520 
				} catch (TException e) {
521 
					logger.error("Could not create payment thrift exception",e);
522 
					sb.append(orderId+" "+subOrderId + " Could not create payment Thrift exception");
523 
					e.printStackTrace();
524 
					continue;
525 
				}
526 
				Transaction transaction = null;
527 
				try {
528 
					transaction = transaction_client.getTransaction(Long.parseLong(transactionId));
529 
				} catch (NumberFormatException e) {
530 
					logger.error("Problem parsing transaction id " + transactionId);
531 
					sb.append(orderId+" "+subOrderId  + " Problem parsing transaction id "+ transactionId +"\n");
532 
					e.printStackTrace();
533 
					continue;
534 
				} catch (TransactionServiceException e) {
535 
					logger.error("Problem getting transaction from service transaction id " + transactionId);
536 
					sb.append(orderId+" "+subOrderId  + " Problem getting transaction id "+ transactionId +"\n");
537 
					e.printStackTrace();
538 
					continue;
539 
				} catch (TException e) {
540 
					logger.error("Problem with transaction service while getting transaction id " + transactionId);
541 
					sb.append(orderId+" "+subOrderId + " Problem with transaction service while getting transaction id "+ transactionId +"\n");
542 
					e.printStackTrace();
543 
					continue;
544 
				}
545 
				List<in.shop2020.model.v1.order.Order> flipkartorders = transaction.getOrders();
546 
				for(in.shop2020.model.v1.order.Order flipkartorder:flipkartorders){
547 
					try {
8973 vikram.rag 548 
						List<in.shop2020.model.v1.order.Attribute> attributeList = new ArrayList<in.shop2020.model.v1.order.Attribute>();
8961 vikram.rag 549 
						inventoryClient.reserveItemInWarehouse(flipkartorder.getLineitems().get(0).getItem_id(), fulfillmentWarehouse.getId(), 1,
550 
								flipkartorder.getId(), flipkartorder.getCreated_timestamp(), flipkartorder.getPromised_shipping_time(), flipkartorder.getLineitems().get(0).getQuantity());
551 
						FlipkartOrder flipkartOrder = new FlipkartOrder();
552 
						flipkartOrder.setOrderId(flipkartorder.getId());
553 
						flipkartOrder.setFlipkartOrderId(orderId);
554 
						flipkartOrder.setFlipkartSubOrderId(subOrderId);
555 
						flipkartOrder.setFlipkartTxnDate(flipkartTxnDate.getTime());
556 
						flipkartOrder.setEmiFee(emiFee);
557 
						flipkartOrder.setOctroiFee(octroiFee);
558 
						flipkartOrder.setShippingPrice(shippingPrice);
8973 vikram.rag 559 
						in.shop2020.model.v1.order.Attribute attribute = new in.shop2020.model.v1.order.Attribute();
560 
						attribute.setName("Buyer Name");
561 
						attribute.setValue(buyerName);
562 
						attributeList.add(attribute);
8961 vikram.rag 563 
						try {
564 
							transaction_client.createFlipkartOrder(flipkartOrder);
8973 vikram.rag 565 
							transaction_client.setOrderAttributes(flipkartOrder.getOrderId(),attributeList);
8974 vikram.rag 566 
							orders_processed++;
8961 vikram.rag 567 
						} catch (TException e) {
568 
							logger.error("Could not create flipkart order");
569 
							sb.append(orderId+" "+subOrderId + " Could not create flipkart order"+"\n");
570 
							continue;
571 
						}
572 
 
573 
					} catch (InventoryServiceException e1) {
574 
						logger.error("Problem while reserving item in inventory service" + flipkartorder.getId());
575 
						sb.append(orderId+" "+subOrderId + " Could not reserve inventory for sku "+ sku +"\n");
576 
						continue;
577 
					} catch (TException e1) {
578 
						logger.error("Problem with inventory service" + flipkartorder.getId());
579 
						sb.append(orderId+" "+subOrderId + " Problem with inventory service while reserving inventory for sku "+ sku +"\n");
580 
						continue;
581 
					}
582 
				}
583 
			}
584 
			response.setHeader("Content-Type", "text/javascript");
585 
 
586 
			ServletOutputStream sos;
587 
			try {
588 
				sos = response.getOutputStream();
9007 vikram.rag 589 
				if(sb!=null){
8968 vikram.rag 590 
					sos.write(sb.toString().getBytes());
591 
				}
592 
				else{
8974 vikram.rag 593 
					if(orders_processed!=0){
594 
						sos.write("Orders Created Successfully".toString().getBytes());
595 
					}
596 
					else{
597 
						sos.write("Zero Approved Orders".toString().getBytes());
598 
					}
8968 vikram.rag 599 
				}
8961 vikram.rag 600 
				sos.flush();
601 
			} catch (IOException e) {
602 
				System.out.println("Unable to stream the manifest file");
603 
			}
604 
 
605 
		}
606 
		catch (FileNotFoundException e) {
607 
			// TODO Auto-generated catch block
608 
			e.printStackTrace();
609 
		}
8995 vikram.rag 610 
		java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
611 
		Calendar cal=GregorianCalendar.getInstance();
9007 vikram.rag 612 
		String emailFromAddress = "build@shop2020.in";
8995 vikram.rag 613 
		String password = "cafe@nes";
614 
		GmailUtils mailer = new GmailUtils();
615 
		String sendTo[] = new String[]{"vikram.raghav@shop2020.in"};
616 
		/*String sendTo[] = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
617 
				"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
618 
				"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};
619 
		*/
620 
		try {
9006 vikram.rag 621 
			logger.info("Before Sending Emails");
9007 vikram.rag 622 
			if(sb!=null){
8995 vikram.rag 623 
				String emailSubjectTxt = "Flipkart Orders Created Successfully (Check Alerts)"+sdf.format(cal.getTime());
624 
				mailer.sendSSLMessage(sendTo, emailSubjectTxt, sb.toString(), emailFromAddress, password, new ArrayList<File>());
9006 vikram.rag 625 
				logger.info("Sending Emails Flipkart Orders Created Successfully (Check Alerts)");
8995 vikram.rag 626 
			}
627 
			else{
628 
				if(orders_processed!=0){
629 
					String emailSubjectTxt = "Flipkart Orders Created Successfully"+sdf.format(cal.getTime());
630 
					mailer.sendSSLMessage(sendTo, emailSubjectTxt,"No Alerts", emailFromAddress, password, new ArrayList<File>());
9007 vikram.rag 631 
					logger.info("Sending Emails Flipkart Orders Created Successfully (Check Alerts)");
8995 vikram.rag 632 
				}
633 
				else{
634 
					String emailSubjectTxt = "No New Approved Orders"+sdf.format(cal.getTime());
635 
					mailer.sendSSLMessage(sendTo, emailSubjectTxt,"No Alerts", emailFromAddress, password, new ArrayList<File>());
636 
 
637 
				}
638 
			}
8961 vikram.rag 639 
 
8995 vikram.rag 640 
			}
641 
			catch (Exception e) {
642 
				e.printStackTrace();
9007 vikram.rag 643 
				logger.error("Exception ",e);
8995 vikram.rag 644 
			}
8961 vikram.rag 645 
	}
646 
 
647 
	public static Logger getLogger() {
648 
		return logger;
649 
	}
650 
	public static void setLogger(Logger logger) {
651 
		FlipkartDashboardController.logger = logger;
652 
	}
653 
	public HttpServletRequest getRequest() {
654 
		return request;
655 
	}
656 
	public void setRequest(HttpServletRequest request) {
657 
		this.request = request;
658 
	}
659 
	public HttpServletResponse getResponse() {
660 
		return response;
661 
	}
662 
	public void setResponse(HttpServletResponse response) {
663 
		this.response = response;
664 
	}
665 
	public HttpSession getSession() {
666 
		return session;
667 
	}
668 
	public void setSession(HttpSession session) {
669 
		this.session = session;
670 
	}
671 
	public ServletContext getContext() {
672 
		return context;
673 
	}
674 
	public void setContext(ServletContext context) {
675 
		this.context = context;
676 
	}
677 
	public String getUrl() {
678 
		return url;
679 
	}
680 
	public void setUrl(String url) {
681 
		this.url = url;
682 
	}
683 
	public File getFile() {
684 
		return file;
685 
	}
686 
	public void setFile(File file) {
687 
		this.file = file;
688 
	}
689 
	public String getErrMsg() {
690 
		return errMsg;
691 
	}
692 
	public void setErrMsg(String errMsg) {
693 
		this.errMsg = errMsg;
694 
	}
695 
	public String getId() {
696 
		return id;
697 
	}
698 
	public void setId(String id) {
699 
		this.id = id;
700 
	}
701 
	@Override
702 
	public void setServletContext(ServletContext arg0) {
703 
		// TODO Auto-generated method stub
704 
 
705 
	}
706 
	@Override
707 
	public void setServletResponse(HttpServletResponse response) {
708 
		this.response = response;
709 
	}
710 
	@Override
711 
	public void setServletRequest(HttpServletRequest request) {
712 
		this.request = request;
713 
		this.session = request.getSession();
714 
 
715 
	}
716 
	public static LineItem createLineItem(long itemId, double amount) throws CatalogServiceException, TException {
717 
		LineItem lineItem = new LineItem();
718 
		CatalogService.Client catalogClient = new CatalogClient().getClient();
719 
		Item item = catalogClient.getItem(itemId);
720 
		if(item.getId()==0){
721 
			//in case item id is incorrect..
722 
			return null;
723 
		}
724 
 
725 
		lineItem.setProductGroup(item.getProductGroup());
726 
		lineItem.setBrand(item.getBrand());
727 
		lineItem.setModel_number(item.getModelNumber());
728 
		lineItem.setModel_name(item.getModelName());
729 
		lineItem.setExtra_info(item.getFeatureDescription());
730 
		lineItem.setQuantity(1);
731 
		lineItem.setItem_id(item.getId());
732 
		lineItem.setUnit_weight(item.getWeight());
733 
		lineItem.setTotal_weight(item.getWeight());
734 
		lineItem.setUnit_price(amount);
735 
		lineItem.setTotal_price(amount);
736 
 
737 
		if (item.getColor() == null || "NA".equals(item.getColor())) {
738 
			lineItem.setColor("");
739 
		} else {
740 
			lineItem.setColor(item.getColor());
741 
		}
742 
		return lineItem;
743 
	}
744 
 
745 
	public static void replacecommas (File file) throws IOException {
746 
		BufferedReader br = null;
747 
		File tempFile = new File("/tmp/formatted.csv");
748 
		FileWriter fw = new FileWriter(tempFile);
749 
		String line;
750 
		br = new BufferedReader(new FileReader(file));
751 
		boolean replace = false;
752 
		char [] lineChars;
8991 vikram.rag 753 
		int counter=1;
9006 vikram.rag 754 
		String completeorder = "";
8961 vikram.rag 755 
		while ((line = br.readLine()) != null) {
8991 vikram.rag 756 
			if(counter!=1){
757 
				if(line.endsWith(",,,,,,,,")){
758 
					completeorder = completeorder.concat(line);
759 
					if(line.contains("Ordered On")){
760 
						continue;
8961 vikram.rag 761 
					}
8991 vikram.rag 762 
					else{
763 
						lineChars = completeorder.toCharArray();
764 
						int count = 0;
765 
						for(int i=0;i<lineChars.length;i++)
766 
						{
767 
							if(lineChars[i]=='"'){
768 
								count++;
769 
							}
770 
							if(count%2==1){
771 
								replace=false;
772 
							}
773 
							if(count%2==0){
774 
								replace=true;
775 
							}
776 
							if(replace && lineChars[i] == ','){
777 
								lineChars[i]='$';
778 
							}
779 
						}
8961 vikram.rag 780 
					}
8991 vikram.rag 781 
					line = String.valueOf(lineChars);
782 
					System.out.println(" Line and Length " + line + " " + line.length());
783 
					fw.write(line+"\n");
784 
					completeorder="";
785 
				}
786 
				else{
787 
					line = line.replace("\n","");
9006 vikram.rag 788 
					if(completeorder.equalsIgnoreCase("")){
8991 vikram.rag 789 
						completeorder = line;
8961 vikram.rag 790 
					}
8991 vikram.rag 791 
					else{
792 
						completeorder = completeorder.concat(line);;
8961 vikram.rag 793 
					}
794 
				}
795 
			}
8991 vikram.rag 796 
			counter++;
797 
		}		if (br != null)br.close();
8961 vikram.rag 798 
		if (fw != null)fw.close();
799 
	}
800 
 
8966 vikram.rag 801 
	public static void createPayment(User user, String subOrderId, double amount) throws PaymentException, TException {
8961 vikram.rag 802 
		in.shop2020.payments.PaymentService.Client client = new PaymentClient().getClient();
8967 vikram.rag 803 
		logger.info("Creating payment for user id " + user.getUserId() + " Gateway id " + FLIPKART_GATEWAY_ID);
8966 vikram.rag 804 
		logger.info("Long value of transaction id : " + Long.valueOf(transactionId));
8961 vikram.rag 805 
		long paymentId = client.createPayment(user.getUserId(), amount, FLIPKART_GATEWAY_ID, Long.valueOf(transactionId), false);
8966 vikram.rag 806 
		logger.info("transaction id : " + Long.valueOf(transactionId) + " Payment id : " + paymentId);
8961 vikram.rag 807 
		client.updatePaymentDetails(paymentId, null, null, null, null, null, null, subOrderId, null, PaymentStatus.AUTHORIZED, null, null);
808 
	}
809 
 
810 
 
811 
}