Blame | Last modification | View Log | RSS feed
package in.shop2020;import in.shop2020.model.v1.catalog.CatalogService;import in.shop2020.model.v1.catalog.CatalogServiceException;import in.shop2020.model.v1.catalog.Item;import in.shop2020.model.v1.catalog.SnapdealItem;import in.shop2020.model.v1.inventory.InventoryService;import in.shop2020.model.v1.inventory.InventoryServiceException;import in.shop2020.model.v1.inventory.InventoryType;import in.shop2020.model.v1.inventory.VendorItemPricing;import in.shop2020.model.v1.inventory.Warehouse;import in.shop2020.model.v1.inventory.WarehouseType;import in.shop2020.model.v1.order.FlipkartOrder;import in.shop2020.model.v1.order.LineItem;import in.shop2020.model.v1.order.OrderStatus;import in.shop2020.model.v1.order.OrderType;import in.shop2020.model.v1.order.SourceDetail;import in.shop2020.model.v1.order.Transaction;import in.shop2020.model.v1.order.TransactionServiceException;import in.shop2020.model.v1.order.TransactionStatus;import in.shop2020.model.v1.order.TransactionService.Client;import in.shop2020.model.v1.user.User;import in.shop2020.payments.PaymentException;import in.shop2020.payments.PaymentStatus;import order.Order;import order.OrderItems;import in.shop2020.thrift.clients.CatalogClient;import in.shop2020.thrift.clients.InventoryClient;import in.shop2020.thrift.clients.PaymentClient;import in.shop2020.thrift.clients.TransactionClient;import in.shop2020.thrift.clients.UserClient;import in.shop2020.utils.GmailUtils;import java.io.BufferedReader;import java.io.File;import java.io.FileInputStream;import java.io.IOException;import java.io.InputStreamReader;import java.text.ParseException;import java.text.SimpleDateFormat;import java.util.ArrayList;import java.util.Calendar;import java.util.Collections;import java.util.Date;import java.util.GregorianCalendar;import java.util.List;import org.apache.http.client.HttpClient;import org.apache.http.client.entity.UrlEncodedFormEntity;import org.apache.http.client.methods.HttpGet;import org.apache.http.client.methods.HttpPost;import org.apache.http.impl.client.DefaultHttpClient;import org.apache.http.message.BasicNameValuePair;import org.apache.http.HttpResponse;import org.apache.http.NameValuePair;import org.apache.thrift.TException;import org.apache.thrift.transport.TTransportException;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import com.google.gson.Gson;public class FetchNewFlipCartOrders {private static final long FLIPKART_SOURCE_ID = 8;private static final int FLIPKART_GATEWAY_ID = 17;private static final int FLIPKART_LOGISTICS_ID = 19;private static String transactionId;private static Logger logger = LoggerFactory.getLogger(FetchNewFlipCartOrders .class);private static long paymentId;public static void main(String[] args) throws CatalogServiceException, TException, IOException {HttpClient client = new DefaultHttpClient();HttpPost post = new HttpPost("https://seller.flipkart.com/login");BufferedReader rd= null;try {List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();nameValuePairs.add(new BasicNameValuePair("authName","flipkart"));nameValuePairs.add(new BasicNameValuePair("username","flipkart-support@saholic.com"));nameValuePairs.add(new BasicNameValuePair("password","076c27ee24d7596b06608a8ed2559f87"));post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));HttpResponse response = client.execute(post);rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));String line = "";Gson gson;List<Order> orders = new ArrayList<Order>();OrderItems new_orders;OrderItems conf_orders;HttpGet get_new;HttpGet get_conf;long time;int i=1;while ((line = rd.readLine()) != null) {System.out.println(line);}time = System.currentTimeMillis();while(true){get_new = new HttpGet("https://seller.flipkart.com/dashboard/som/new_order_items?status=on_hold%2Capproved.payment_approved&sort=confirm_by_date&page="+i+"&page_size=100&_="+time);response = client.execute(get_new);rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));line = "";gson = new Gson();new_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);if(new_orders.getOrder_items().size()>0){orders.addAll(new_orders.getOrder_items());}else{break;}i++;}i=1;time = System.currentTimeMillis();while(true){get_conf = new HttpGet("https://seller.flipkart.com/dashboard/som/confirmed_order_items?status=approved.seller_approved&sort=confirm_by_date&page="+i+"&page_size=100&_="+time);response = client.execute(get_conf);rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));line = "";gson = new Gson();conf_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);if(conf_orders.getOrder_items().size()>0){orders.addAll(conf_orders.getOrder_items());}else{break;}i++;}for(Order order:orders){System.out.println("Order " + order.getExternalId() +" "+order.getOrderItemId() + " : "+ order.getStatus() + " "+order.getStatusDateMessage() + " "+ order.getStatusLabel() + " " + order.getPickup_by_date() + " "+ order.getTrackingId());}processOrders(orders);} catch (IOException e) {e.printStackTrace();}}public static void processOrders(List<Order> orders) throws IOException, CatalogServiceException, TException{logger.info("Before Processing orders ");StringBuffer sb = new StringBuffer();int orders_processed = 0;String order_string = "";User user = null;TransactionClient tsc = null;SourceDetail sourceDetail = null;logger.info("Before Fetching sourcedetail");try {tsc = new TransactionClient();sourceDetail = tsc.getClient().getSourceDetail(FLIPKART_SOURCE_ID);logger.info("Flipkart sourcedetail " + sourceDetail.getEmail() + " " + sourceDetail.getName());} catch (Exception e) {logger.error("Unable to establish connection to the transaction service while getting Flipkart Source Detail ", e);}try {in.shop2020.model.v1.user.UserContextService.Client userClient = new UserClient().getClient();logger.info("Before Fetching User by Email");user = userClient.getUserByEmail(sourceDetail.getEmail());logger.info("User is " + user.getEmail());} catch (Exception e) {logger.error("Unable to establish connection to the User service ", e);}logger.info("Before iterating orders in file");SnapdealItem snapdealItem;for(Order order : orders){String orderId,subOrderId,create_date,ship_date = null;long sku;if(order.getExternalId().length()==0 || order.getOrderItemId().length()==0 ){sb.append(" Could not parse order id " + order.getExternalId()+ " " + order.getExternalId() + "\n");continue;}else{logger.info("Processing Order " + order.getExternalId() + " " + order.getOrderItemId());orderId = order.getExternalId();subOrderId = order.getOrderItemId();}if(order.getCreatedDate()!=null){create_date = order.getCreatedDate()+" "+order.getCreatedTime();}else{sb.append(orderId+" "+subOrderId + " Could not parse order date" +"\n");logger.info(orderId+" "+subOrderId + " Could not parse order date");continue;}if(order.getPickup_by_date()!=null){ship_date = order.getPickup_by_date();}if(order.getSku()==0L){sb.append(orderId+" "+subOrderId + " Could not parse sku" +"\n");logger.info(orderId+" "+subOrderId + " Could not parse sku");continue;}else{sku = order.getSku();if(sku ==827100000){sku = 8271;}logger.info(orderId+" "+subOrderId + " Processing sku " + sku);}if(order.getStatusLabel().length()!=0 && (order.getStatusLabel().equalsIgnoreCase("Approved") || order.getStatusLabel().equalsIgnoreCase("confirmed"))){String status = order.getStatus();}else{if(order.getStatus().length()==0){sb.append(orderId+" "+subOrderId + " Could not parse status " + "\n");logger.info(orderId+" "+subOrderId + " Could not parse status " +"\n");}else{sb.append(orderId+" "+subOrderId + " Order not Approved" +"\n");logger.info(orderId+" "+subOrderId + " Order not Approved" +"\n");}continue;}double unitSellingPrice,shippingPrice,octroiFee,emiFee;if(order.getListPrice()!=0 ){if(order.getListPrice() > 0){unitSellingPrice = order.getListPrice();}else{sb.append(orderId+" "+subOrderId + " Unit Price set to 0 " +"\n");logger.info(orderId+" "+subOrderId + " Unit Price set to 0 " +"\n");continue;}}else{sb.append(orderId+" "+subOrderId + " Unit Price not set " +"\n");logger.info(orderId+" "+subOrderId + " Unit Price not set " +"\n");continue;}if(order.getShippingFees() > 0){shippingPrice = order.getShippingFees();sb.append(orderId+" "+subOrderId + " Shipping Fee :"+ shippingPrice +"\n");logger.info(orderId+" "+subOrderId + " Shipping Fee :"+ shippingPrice +"\n");}else{shippingPrice=0;}if(order.getOctroi()!=0){octroiFee = order.getOctroi();if(octroiFee >0){sb.append(orderId+" "+subOrderId + " OctroiFee :"+ octroiFee +"\n");logger.info(orderId+" "+subOrderId + " OctroiFee :"+ octroiFee +"\n");}}else{octroiFee=0;}if(order.getEmi()!=0){emiFee = order.getEmi();if(emiFee >0){sb.append(orderId+" "+subOrderId + " EMI :"+ emiFee +"\n");logger.info(orderId+" "+subOrderId + " EMI :"+ emiFee +"\n");}}else{emiFee = 0;}int quantity;if(order.getQuantity()!=0){quantity = order.getQuantity();if(quantity > 1){sb.append(orderId+" "+subOrderId + " Quantity > 1 " +quantity+"\n");logger.info(orderId+" "+subOrderId + " Quantity > 1 " +quantity+"\n");}else{if(quantity==0){sb.append(orderId+" "+subOrderId + " Quantity not set " +quantity+"\n");logger.info(orderId+" "+subOrderId + " Quantity not set " +quantity+"\n");continue;}}}else{sb.append(orderId+" "+subOrderId + " Quantity not set " + "0" +"\n");logger.info(orderId+" "+subOrderId + " Quantity not set " +"0"+"\n");continue;}double totalsellingPrice;if(order.getTotalPrice()!=0){totalsellingPrice= order.getTotalPrice();if(totalsellingPrice==0){sb.append(orderId+" "+subOrderId + " Total Selling Price set to 0 " +"\n");logger.info(orderId+" "+subOrderId + " Total Selling Price set to 0 " +"\n");continue;}}else{sb.append(orderId+" "+subOrderId + " Total Selling Price not set " +"\n");logger.info(orderId+" "+subOrderId + " Total Selling Price not set " +"\n");continue;}String shipToName,addressLine1,addressLine2,city,state,pincode,buyerName="unknown";if(order.getCustomerName().length() > 0){buyerName = order.getCustomerName();}else{sb.append(orderId+" "+subOrderId + " Buyer Name not set " +"\n");logger.info(orderId+" "+subOrderId + " Buyer Name not set " +"\n");}if(order.getShippingAddressName().length() > 0){shipToName = order.getShippingAddressName();}else{sb.append(orderId+" "+subOrderId + " Ship to Name not set " +"\n");logger.info(orderId+" "+subOrderId + " Ship to Name not set " +"\n");continue;}if(buyerName.contains("unknown")){buyerName = shipToName;}if(order.getShippingAddressLine1()!=null && order.getShippingAddressLine1().length() > 0){addressLine1 = order.getShippingAddressLine1();}else{addressLine1 ="";}if(order.getShippingAddressLine2()!=null && order.getShippingAddressLine2().length() > 0){addressLine2 = order.getShippingAddressLine2();}else{addressLine2 ="";}if(order.getShippingAddressCity()!=null && order.getShippingAddressCity().length()>0){city = order.getShippingAddressCity();}else{sb.append(orderId+" "+subOrderId + " City not set " +"\n");logger.info(orderId+" "+subOrderId + " City not set " +"\n");continue;}if(order.getShippingAddressState().length()>0){state = order.getShippingAddressState();}else{sb.append(orderId+" "+subOrderId + " State not set " +"\n");logger.info(orderId+" "+subOrderId + " State not set " +"\n");continue;}if(order.getShippingAddressPincode().length()>0){pincode = order.getShippingAddressPincode();}else{sb.append(orderId+" "+subOrderId + " Pincode not set " +"\n");logger.info(orderId+" "+subOrderId + " Pincode not set " +"\n");continue;}int sla;if(order.getSla()>0){sla = order.getSla();}else{sb.append(orderId+" "+subOrderId + " Ship to date not available " +"\n");logger.info(orderId+" "+subOrderId + " Ship to date not available " +"\n");continue;}//String shipByDate = nextLine[26];SimpleDateFormat createDateFormatter = new SimpleDateFormat("MMM dd, yyyy hh:mm aaa");SimpleDateFormat shipDateFormatter = new SimpleDateFormat("MMM dd, yyyy");Date flipkartTxnDate = null;Date shipByDate = null;try {flipkartTxnDate = createDateFormatter.parse(create_date);} catch (ParseException e) {logger.error(orderId+" "+subOrderId + " Could not parse flipkart order date from file " , e);sb.append(orderId+" "+subOrderId + " Could not parse order date" +"\n");continue;}if(ship_date!=null){try {shipByDate = shipDateFormatter.parse(ship_date);} catch (ParseException e) {logger.error(orderId+" "+subOrderId + " ship date " , e);sb.append(orderId+" "+subOrderId + "cannot parse ship date" +"\n");continue;}}Client transaction_client = null;try {transaction_client = new TransactionClient().getClient();if(transaction_client.flipkartOrderExists(orderId,subOrderId)) {if(shipByDate!=null && order.getTrackingId()!=null){transaction_client.updateFlipkartOrderDatesAndAWB(orderId, subOrderId, shipByDate.getTime(), order.getTrackingId());logger.error("Order exists updating info " + "id : " + orderId + " suborder id : " + subOrderId);sb.append("Order exists updating info " + orderId+" "+subOrderId+"\n");}else{logger.error("Flipkart order exists " + "id : " + orderId + " suborder id : " + subOrderId);sb.append("Flipkart order exists " + orderId+" "+subOrderId+"\n");}continue;}} catch (TTransportException e1) {logger.error("Problem with Transaction service " , e1);e1.printStackTrace();} catch (TException e) {logger.error("Problem.. thrift exception with Transaction service " , e);e.printStackTrace();}Transaction txn = new Transaction();txn.setShoppingCartid(user.getActiveCartId());txn.setCustomer_id(user.getUserId());System.out.println("User Id is " + user.getUserId());txn.setCreatedOn(new Date().getTime());txn.setTransactionStatus(TransactionStatus.INIT);txn.setStatusDescription("Order for flipkart ");List<in.shop2020.model.v1.order.Order> orderlist = new ArrayList<in.shop2020.model.v1.order.Order>();double total_price=0;InventoryService.Client inventoryClient = null;Warehouse fulfillmentWarehouse= null;boolean exit = false;LineItem lineItem = null;lineItem = createLineItem(sku,unitSellingPrice,quantity);logger.info(orderId+" "+subOrderId + "sku and Price " + sku + " " + unitSellingPrice);lineItem.setExtra_info("flipkartOrderId = " + orderId + " flipkartsubOrderId = " + subOrderId);in.shop2020.model.v1.order.Order t_order = new in.shop2020.model.v1.order.Order();t_order.setCustomer_id(user.getUserId());t_order.setCustomer_email(sourceDetail.getEmail());t_order.setCustomer_mobilenumber("+91-9999999999");t_order.setCustomer_name(shipToName);t_order.setCustomer_address1(addressLine1);t_order.setCustomer_address2(addressLine2);t_order.setCustomer_city(city);t_order.setCustomer_state(state);t_order.setCustomer_pincode(pincode);t_order.setTotal_weight(lineItem.getTotal_weight());t_order.setLineitems(Collections.singletonList(lineItem));t_order.setStatus(OrderStatus.PAYMENT_PENDING);t_order.setStatusDescription("In Process");t_order.setCreated_timestamp(new Date().getTime());t_order.setOrderType(OrderType.B2C);t_order.setCod(false);if(shipByDate!=null){t_order.setPromised_shipping_time(shipByDate.getTime());t_order.setExpected_shipping_time(shipByDate.getTime());t_order.setPromised_delivery_time(shipByDate.getTime()+ 4*24*60*60);t_order.setExpected_delivery_time(shipByDate.getTime()+ 4*24*60*60);}else{try {Date shipDate = new Date();shipDate.setTime( flipkartTxnDate.getTime() + sla*24*60*60*1000);Calendar calendar = Calendar.getInstance();calendar.setTime(shipDate);if(calendar.get(Calendar.DAY_OF_WEEK)!=1){t_order.setPromised_shipping_time(shipDate.getTime());t_order.setExpected_shipping_time(shipDate.getTime());}else{t_order.setPromised_shipping_time(shipDate.getTime()+24*60*60*1000);t_order.setExpected_shipping_time(shipDate.getTime()+24*60*60*1000);}calendar = Calendar.getInstance();calendar.add(Calendar.DAY_OF_MONTH, 4);t_order.setPromised_delivery_time(calendar.getTimeInMillis());t_order.setExpected_delivery_time(calendar.getTimeInMillis());} catch(Exception e) {logger.error("Error in updating Shipping or Delivery Time for suborderid " + subOrderId);sb.append(orderId + " "+ subOrderId + " Could not update delivery time" + " " + "\n");exit = true;continue;}}snapdealItem = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient().getSnapdealItem(sku);inventoryClient = new InventoryClient().getClient();try {logger.info("Snapdeal Item id is " + snapdealItem.getItem_id());if(snapdealItem.getItem_id()!=0 && snapdealItem.getWarehouseId()!=0) {logger.info("SnapdealItem Warehouse Id " + snapdealItem.getWarehouseId());fulfillmentWarehouse = inventoryClient.getWarehouse(snapdealItem.getWarehouseId());logger.info("fulfillmentWarehouse is " + fulfillmentWarehouse.getId() + " " + fulfillmentWarehouse.getDisplayName() );} else {List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(sku, 1);fulfillmentWarehouse = inventoryClient.getWarehouse(itemAvailability.get(0));if(fulfillmentWarehouse.getStateId()!=0){fulfillmentWarehouse = inventoryClient.getWarehouse(7);}}t_order.setFulfilmentWarehouseId(fulfillmentWarehouse.getId());long billingWarehouseId = 0;if(fulfillmentWarehouse.getBillingWarehouseId()== 0) {inventoryClient = new InventoryClient().getClient();List<Warehouse> warehouses = inventoryClient.getWarehouses(WarehouseType.OURS, InventoryType.GOOD, fulfillmentWarehouse.getVendor().getId(), 0, 0);for(Warehouse warehouse : warehouses) {if(warehouse.getBillingWarehouseId()!=0) {billingWarehouseId = warehouse.getBillingWarehouseId();break;}}}else {billingWarehouseId = fulfillmentWarehouse.getBillingWarehouseId();}//logger.info("Billing warehouse id for suborderid " + order.getSuborderId() + " is " + fulfillmentWarehouse.getBillingWarehouseId());t_order.setWarehouse_id(billingWarehouseId);VendorItemPricing vendorItemPricing = new VendorItemPricing();if(fulfillmentWarehouse.getId()==7) {Item item = new CatalogClient().getClient().getItem(lineItem.getItem_id());vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), item.getPreferredVendor());} else {vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), fulfillmentWarehouse.getVendor().getId());}t_order.getLineitems().get(0).setTransfer_price(vendorItemPricing.getTransferPrice());t_order.getLineitems().get(0).setNlc(vendorItemPricing.getNlc());} catch (InventoryServiceException e) {logger.error("Error connecting inventory service for suborderid " + orderId + " " + subOrderId , e);sb.append(orderId + " " + subOrderId+ " Inventory Service Exception" + " " + "\n");exit = true;continue;} catch (TTransportException e) {logger.error("Transport Exception with Inventory Service for suborderid " + orderId + " " + subOrderId , e);sb.append(orderId + " " + subOrderId + " Transport Exception with Inventory Service" + " " + "\n");exit = true;continue;} catch (TException e) {logger.error("Exception with Inventory Service for suborderid " + orderId + " " + subOrderId , e);sb.append(orderId + " " + subOrderId + " Exception in Inventory Service" + " " + "\n");exit = true;continue;} catch (CatalogServiceException e) {logger.error("Exception with Catalog Service for " + orderId + " " + subOrderId + " while getting item " + lineItem.getItem_id(), e);sb.append(orderId + " " + subOrderId + " Exception in Catalog Service" + " " + "\n");exit = true;continue;}t_order.setLogistics_provider_id(FLIPKART_LOGISTICS_ID);t_order.setAirwaybill_no("");t_order.setTracking_id("");t_order.setTotal_amount(unitSellingPrice*quantity);t_order.setOrderType(OrderType.B2C);t_order.setSource(FLIPKART_SOURCE_ID);t_order.setOrderType(OrderType.B2C);total_price = unitSellingPrice*quantity;orderlist.add(t_order);if(exit){continue;}txn.setOrders(orderlist);try {transactionId = String.valueOf(transaction_client.createTransaction(txn));logger.info("Transaction id is : " + transactionId);} catch (TransactionServiceException e) {logger.error(orderId+" "+subOrderId + " Could not create transaction " , e);sb.append(orderId+" "+subOrderId + " Could not create transaction" +"\n");continue;} catch (TException e) {sb.append(orderId+" "+subOrderId + " Transaction Service Exception could not create transaction" +"\n");logger.info(orderId+" "+subOrderId + " Transaction Service Exception could not create transaction" +"\n" , e);continue;}try{logger.info("Creating payment for suborder id " + subOrderId +" ");paymentId = createPayment(user,subOrderId,total_price);}catch (NumberFormatException e) {logger.error("Could not create payment",e);sb.append(orderId+" "+subOrderId + " Could not create payment");e.printStackTrace();continue;} catch (PaymentException e) {logger.error("Could not create payment payment exception",e);sb.append(orderId+" "+subOrderId + " Could not create payment Payment exception");e.printStackTrace();continue;} catch (TException e) {logger.error("Could not create payment thrift exception",e);sb.append(orderId+" "+subOrderId + " Could not create payment Thrift exception"+"\n");e.printStackTrace();continue;}Transaction transaction = null;try {transaction_client = tsc.getClient();transaction = transaction_client.getTransaction(Long.parseLong(transactionId));} catch (NumberFormatException e) {logger.error("Problem parsing transaction id " + transactionId +" ", e);sb.append(orderId+" "+subOrderId + " Problem parsing transaction id "+ transactionId +"\n");e.printStackTrace();continue;} catch (TransactionServiceException e) {logger.error("Problem getting transaction from service transaction id " + transactionId +" ",e);sb.append(orderId+" "+subOrderId + " Problem getting transaction id "+ transactionId +"\n");e.printStackTrace();continue;} catch (TException e) {logger.error(" " + transactionId + " " , e);sb.append(orderId+" "+subOrderId + " Problem with transaction service while getting transaction id "+ transactionId +"\n");e.printStackTrace();continue;}List<in.shop2020.model.v1.order.Order> flipkartorders = transaction.getOrders();for(in.shop2020.model.v1.order.Order flipkartorder:flipkartorders){try {List<in.shop2020.model.v1.order.Attribute> attributeList = new ArrayList<in.shop2020.model.v1.order.Attribute>();inventoryClient = new InventoryClient().getClient();inventoryClient.reserveItemInWarehouse(flipkartorder.getLineitems().get(0).getItem_id(), fulfillmentWarehouse.getId(), 1,flipkartorder.getId(), flipkartorder.getCreated_timestamp(), flipkartorder.getPromised_shipping_time(), flipkartorder.getLineitems().get(0).getQuantity());FlipkartOrder flipkartOrder = new FlipkartOrder();flipkartOrder.setOrderId(flipkartorder.getId());flipkartOrder.setFlipkartOrderId(orderId);flipkartOrder.setFlipkartSubOrderId(subOrderId);flipkartOrder.setFlipkartTxnDate(flipkartTxnDate.getTime());flipkartOrder.setEmiFee(emiFee);flipkartOrder.setOctroiFee(octroiFee);flipkartOrder.setShippingPrice(shippingPrice);flipkartOrder.setMaxNlc(snapdealItem.getMaxNlc());in.shop2020.model.v1.order.Attribute attribute = new in.shop2020.model.v1.order.Attribute();attribute.setName("Buyer Name");attribute.setValue(buyerName);attributeList.add(attribute);try {transaction_client.createFlipkartOrder(flipkartOrder);transaction_client.setOrderAttributes(flipkartOrder.getOrderId(),attributeList);logger.info("transaction id : " + Long.valueOf(transactionId) + " Payment id : " + paymentId);new PaymentClient().getClient().updatePaymentDetails(paymentId, null, null, null, null, null, null, subOrderId, null, PaymentStatus.SUCCESS, null, null);orders_processed++;} catch (TException e) {logger.error("Could not create flipkart order ",e);sb.append(orderId+" "+subOrderId + " Could not create flipkart order"+"\n");continue;} catch (PaymentException e) {logger.error("Could not update flipkart order payment ",e);sb.append(orderId+" "+subOrderId + " Could not update flipkart order payment"+"\n");continue;}} catch (InventoryServiceException e1) {logger.error("Problem while reserving item in inventory service" + flipkartorder.getId() + " ",e1);sb.append(orderId+" "+subOrderId + " Could not reserve inventory for sku "+ sku +"\n");continue;} catch (TException e1) {logger.error("Problem with inventory service" + flipkartorder.getId()+" ",e1);sb.append(orderId+" "+subOrderId + " Problem with inventory service while reserving inventory for sku "+ sku +"\n");continue;}}}if(orders_processed==1){order_string = "Order";}else{order_string = "Orders";}java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");Calendar cal=GregorianCalendar.getInstance();String emailFromAddress = "build@shop2020.in";String password = "cafe@nes";GmailUtils mailer = new GmailUtils();//String sendTo[] = new String[]{"vikram.raghav@shop2020.in"};String sendTo[] = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in","khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com","yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};try {logger.info("Before Sending Emails");if(sb.toString().equalsIgnoreCase("")){if(orders_processed!=0){String emailSubjectTxt = orders_processed + " Flipkart " + order_string + " Created "+sdf.format(cal.getTime());mailer.sendSSLMessage(sendTo, emailSubjectTxt,"Orders Created Successfully (No Alerts)", emailFromAddress, password, new ArrayList<File>());logger.info("Sending Email Flipkart Orders Created Successfully (No Alerts)");}else{String emailSubjectTxt = "No new orders created "+sdf.format(cal.getTime());mailer.sendSSLMessage(sendTo, emailSubjectTxt,"No new orders created", emailFromAddress, password, new ArrayList<File>());logger.info("Sending Email Flipkart Orders Created Successfully (No Alerts)");}}else{if(orders_processed!=0){String emailSubjectTxt = orders_processed + " Flipkart " + order_string + " Created (Check Alerts) "+sdf.format(cal.getTime());mailer.sendSSLMessage(sendTo, emailSubjectTxt,sb.toString(), emailFromAddress, password, new ArrayList<File>());logger.info("Sending Email Flipkart Orders Created Successfully (Check Alerts)");}else{String emailSubjectTxt = "No new Flipkart orders created "+sdf.format(cal.getTime());mailer.sendSSLMessage(sendTo, emailSubjectTxt,sb.toString(), emailFromAddress, password, new ArrayList<File>());logger.info("Sending Email Flipkart Orders Created Successfully (Check Alerts)");}}}catch (Exception e) {e.printStackTrace();logger.error("Exception ",e);}}public static LineItem createLineItem(long itemId, double amount,int qty) throws CatalogServiceException, TException {LineItem lineItem = new LineItem();CatalogService.Client catalogClient = new CatalogClient().getClient();Item item = catalogClient.getItem(itemId);if(item.getId()==0){//in case item id is incorrect..return null;}lineItem.setProductGroup(item.getProductGroup());lineItem.setBrand(item.getBrand());lineItem.setModel_number(item.getModelNumber());lineItem.setModel_name(item.getModelName());lineItem.setExtra_info(item.getFeatureDescription());lineItem.setQuantity(qty);lineItem.setItem_id(item.getId());lineItem.setUnit_weight(item.getWeight());lineItem.setTotal_weight(item.getWeight());lineItem.setUnit_price(amount);lineItem.setTotal_price(amount*qty);if (item.getColor() == null || "NA".equals(item.getColor())) {lineItem.setColor("");} else {lineItem.setColor(item.getColor());}return lineItem;}public static long createPayment(User user, String subOrderId, double amount) throws PaymentException, TException {in.shop2020.payments.PaymentService.Client client = new PaymentClient().getClient();logger.info("Creating payment for user id " + user.getUserId() + " Gateway id " + FLIPKART_GATEWAY_ID);logger.info("Long value of transaction id : " + Long.valueOf(transactionId));long paymentId = client.createPayment(user.getUserId(), amount, FLIPKART_GATEWAY_ID, Long.valueOf(transactionId), false);return paymentId;}}