Subversion Repositories SmartDukaan

package in.shop2020.serving.services;

import in.shop2020.model.v1.order.OrderSource;
import in.shop2020.serving.model.Order;
import in.shop2020.serving.model.OrderItems;
import in.shop2020.thrift.clients.TransactionClient;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
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 com.google.gson.Gson;

public class FlipkartOrderStatusReconciliation{
        public static void main(String[] args) {
                HttpClient client = new DefaultHttpClient();
                HttpPost post = new HttpPost("https://seller.flipkart.com/login");
                BufferedReader rd= null;
                
                List<List<String>> deliveredOrderDataList = new ArrayList<List<String>>();
                SimpleDateFormat gotFlipkartDateFormat = new SimpleDateFormat("MMM dd, yyyy");
                //SimpleDateFormat createDateFormatter = new SimpleDateFormat("MMM dd, yyyy hh:mm aaa");
                SimpleDateFormat ourDBDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                long minCreationDate = 0l;
                try {
                        minCreationDate = new TransactionClient().getClient().getMinCreatedTimeStampUndeliveredOrdersForSource(OrderSource.FLIPKART.getValue());
                        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;
                        HttpGet get_new;
                        
                        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/shipped_order_items?status=delivered&page="+i+"&page_size=100&_="+time);
                                response = client.execute(get_new);
                                rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
                                line = "";
                                gson = new Gson();
                                //System.out.println("RD....."+rd.readLine());
                                new_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
                                if(new_orders.getOrder_items().size()>0){
                                        orders.addAll(new_orders.getOrder_items());
                                }
                                else{
                                        break;
                                }
                                i++;
                        }
                        
                        for(Order order:orders){
                                if(minCreationDate > 0l && gotFlipkartDateFormat.parse(gotFlipkartDateFormat.format(minCreationDate)).getTime() <= gotFlipkartDateFormat.parse(order.getCreatedDate()).getTime()){
                                        List<String> delivered_dataList = new ArrayList<String>();
                                        delivered_dataList.add(order.getExternalId());
                                        delivered_dataList.add(order.getOrderItemId());
                                        delivered_dataList.add(ourDBDateFormat.format(gotFlipkartDateFormat.parse(order.getModifiedDate()).getTime()));
                                        System.out.println("Flipkart Order Id... "+order.getExternalId() + " ... Flipkart Sub Order Code... "+ order.getOrderItemId() +" ... Delivery Date ... "+ ourDBDateFormat.format(gotFlipkartDateFormat.parse(order.getModifiedDate()).getTime()) + "....Created Date..... "+ order.getCreatedDate());
                                        deliveredOrderDataList.add(delivered_dataList);
                                }
                        }
                        //System.out.println("deliveredOrderDataList size... "+deliveredOrderDataList.size());
                        if(deliveredOrderDataList!=null && deliveredOrderDataList.size()>0){
                                new TransactionClient().getClient().updateFlipkartOrdersStatus(deliveredOrderDataList);
                        }
                        
                } catch(Exception e){
                        e.printStackTrace();
                }
        }
}