Subversion Repositories SmartDukaan

Rev

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