Rev 12974 | Blame | Compare with Previous | Last modification | View Log | RSS feed
package in.shop2020.serving.services;import in.shop2020.model.v1.catalog.CatalogService;import in.shop2020.model.v1.catalog.CatalogServiceException;import in.shop2020.model.v1.catalog.FlipkartItem;import in.shop2020.model.v1.catalog.Item;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 in.shop2020.serving.model.Order;import in.shop2020.serving.model.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.FileReader;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 FetchNewFlipkartOrdersNew {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(FetchNewFlipkartOrdersNew .class);private static long paymentId;public static void main(String[] args) throws CatalogServiceException, TException, IOException {File fileToCreate = new File("/tmp/NewOrders.txt");try{BufferedReader rd = new BufferedReader(new FileReader(fileToCreate));String line;Gson gson;List<Order> orders = new ArrayList<Order>();OrderItems new_orders;while((line = rd.readLine())!=null){gson = new Gson();new_orders = (OrderItems) gson.fromJson(line, OrderItems.class);if(new_orders.getItems().size()>0){orders.addAll(new_orders.getItems());}else{break;}if(!new_orders.isHasMore())break;}for(Order order:orders){System.out.println("Order " + order.getOrderId() +" "+order.getOrderItemId() + " : "+ order.getStatus() + " "+ order.getStatusLabel() + " " + order.getConfirmByDate() + " "+ order.getTrackingId());/*if(order.getFreebie_items()!=null && order.getFreebie_items().size()>0){System.out.println("Freebie Item ID :"+order.getFreebie_items().get(0).getSku());}*/}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();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");FlipkartItem flipkartItem;String orderId,subOrderId,create_date,ship_date = null,skuAtFlipkart;long sku = 0;int total_orders = 0;int duplicate_orders = 0;int orders_processed = 0;int not_approved = 0;for(Order order : orders){String status = "";boolean isHold = false;total_orders++;if(order.getOrderId().length()==0 || order.getOrderItemId().length()==0 ){sb.append(" Could not parse order id " + order.getOrderId()+ " " + order.getOrderItemId() + "\n");continue;}else{logger.info("Processing Order " + order.getOrderId() + " " + order.getOrderItemId());orderId = order.getOrderId();subOrderId = order.getOrderItemId();}if(order.getOrderDate()!=null){create_date = order.getOrderDate()+" "+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.getService_profile()!=null && "NON_FBF".equalsIgnoreCase(order.getService_profile())){String fulfillByUs = order.getService_profile();} else {sb.append(orderId+" "+subOrderId + " Could not parse FBF Condition" +"\n");logger.info(orderId+" "+subOrderId + " Could not parse FBF Condition");continue;}*/if(order.getConfirmByDate()!=null && order.getConfirmByDate().length()>0){ship_date = order.getConfirmByDate();}if(order.getSku().equals("")){sb.append(orderId+" "+subOrderId + " Could not parse sku" +"\n");logger.info(orderId+" "+subOrderId + " Could not parse sku");continue;}else{skuAtFlipkart = order.getSku();logger.info(orderId+" "+subOrderId + " Processing sku " + skuAtFlipkart);}if(order.getStatusLabel().length()!=0 && (order.getStatusLabel().equalsIgnoreCase("Approved") || order.getStatusLabel().equalsIgnoreCase("On hold") || order.getStatusLabel().equalsIgnoreCase("confirmed"))){status = order.getStatus();if("on_hold".equalsIgnoreCase(status)){isHold = true;}}else{sb.append(orderId+" "+subOrderId + " Could not parse status " + "\n");logger.info(orderId+" "+subOrderId + " Could not parse status " +"\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();boolean flag = false;try{flag = transaction_client.flipkartOrderExists(orderId,subOrderId);}catch(Exception e){continue;}if(flag) {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");}duplicate_orders++;continue;}} catch (TTransportException e1) {logger.error("Problem with Transaction service " , e1);e1.printStackTrace();continue;} catch (TException e) {logger.error("Problem.. thrift exception with Transaction service " , e);e.printStackTrace();continue;}flipkartItem = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient().getFlipkartItemBySkyAtFlipkart(skuAtFlipkart);//flipkartItem = new CatalogClient().getClient().getFlipkartItemBySkyAtFlipkart(skuAtFlipkart);sku = flipkartItem.getItem_id();if(sku==0){System.out.println("SKU Mapping doesnt exists " + skuAtFlipkart);sb.append(orderId + " "+ subOrderId + " SKU Mapping doesnt exist" + " " +skuAtFlipkart+ "\n");continue;}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;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(order.getPhone());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.setCreated_timestamp(new Date().getTime());t_order.setOrderType(OrderType.B2C);/*if(order.getFreebie_items().size()>0){System.out.println("Freebie found");FlipkartItem freebieItem = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient().getFlipkartItemBySkyAtFlipkart(order.getFreebie_items().get(0).getSku());if(freebieItem.getItem_id()!=0){t_order.setFreebieItemId(freebieItem.getItem_id());}}else{System.out.println("No Freebie");}*/if(isHold){t_order.setCod(true);t_order.setStatusDescription("Cod Verification Pending");} else {t_order.setStatusDescription("In Process");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");continue;}}inventoryClient = new InventoryClient().getClient();try {logger.info("Flipkart Item id is " + flipkartItem.getItem_id());if(flipkartItem.getItem_id()!=0 && flipkartItem.getWarehouseId()!=0) {logger.info("Flipkart Warehouse Id " + flipkartItem.getWarehouseId());fulfillmentWarehouse = inventoryClient.getWarehouse(flipkartItem.getWarehouseId());logger.info("fulfillmentWarehouse is " + fulfillmentWarehouse.getId() + " " + fulfillmentWarehouse.getDisplayName() );} else {List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(sku, 1, -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) {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();Item item = new CatalogClient().getClient().getItem(lineItem.getItem_id());if(fulfillmentWarehouse.getId()==7) {try{vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), item.getPreferredVendor());}catch(TTransportException e){inventoryClient = new InventoryClient().getClient();vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), item.getPreferredVendor());}}else {try{vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), item.getPreferredVendor());}catch(TTransportException e){inventoryClient = new InventoryClient().getClient();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");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");continue;} catch (TException e) {logger.error("Exception with Inventory Service for suborderid " + orderId + " " + subOrderId , e);sb.append(orderId + " " + subOrderId + " Exception in Inventory Service" + " " + "\n");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");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);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) {transaction_client = new TransactionClient().getClient();try {transactionId = String.valueOf(transaction_client.createTransaction(txn));} catch (TransactionServiceException e1) {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>();try{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());}catch(TTransportException e){new InventoryClient().getClient().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(flipkartItem.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);} 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;}orders_processed++;}}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[]{"manish.sharama@shop2020.in"};String sendTo[] = new String[]{ "sandeep.sachdeva@shop2020.in", "rajneesh.arora@shop2020.in","khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com","yukti.jain@shop2020.in","manish.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","anikendra.das@shop2020.in"};try {logger.info("Before Sending Emails");String ordersProcessingStatus = "Total Orders : " + total_orders +"\n"+"Processed Orders : " + orders_processed +"\n"+"Existing Orders : " + duplicate_orders +"\n"+"Failed Orders :" + (total_orders - orders_processed - duplicate_orders - not_approved)+"\n"+"Unapproved Orders :" + not_approved;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)"+"\n"+ordersProcessingStatus, emailFromAddress, password, new ArrayList<File>());logger.info("Sending Email Flipkart Orders Created Successfully (No Alerts)");}else{String emailSubjectTxt = "No new Flipkart orders created "+sdf.format(cal.getTime());mailer.sendSSLMessage(sendTo, emailSubjectTxt,"No new orders created"+"\n\n"+ordersProcessingStatus, 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 "+sdf.format(cal.getTime());mailer.sendSSLMessage(sendTo, emailSubjectTxt,ordersProcessingStatus+"\n"+sb.toString(), emailFromAddress, password, new ArrayList<File>());logger.info("Sending Email Flipkart Orders Created Successfully (Check Alerts)");int failed_orders = (total_orders - orders_processed - duplicate_orders - not_approved);if(failed_orders==1){order_string = "Order";}else{order_string = "Orders";}//String emailSubjectTxt = failed_orders + " Flipkart " + order_string + " Failed while creation "+sdf.format(cal.getTime());mailer.sendSSLMessage(sendTo, emailSubjectTxt,ordersProcessingStatus+"\n"+sb.toString(), emailFromAddress, password, new ArrayList<File>());logger.info("Sending Email Flipkart Orders Failed while creation");}else{String emailSubjectTxt = "No new Flipkart orders created "+sdf.format(cal.getTime());mailer.sendSSLMessage(sendTo, emailSubjectTxt,ordersProcessingStatus+"\n"+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;}}