Subversion Repositories SmartDukaan

package in.shop2020;

import in.shop2020.model.v1.catalog.SnapdealItemDetails;
import in.shop2020.model.v1.inventory.SnapdealStockAtEOD;
import in.shop2020.thrift.clients.CatalogClient;
import in.shop2020.thrift.clients.InventoryClient;
import inventory.Inventory;
import inventory.InventoryItems;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
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.thrift.TException;
import org.apache.thrift.transport.TTransportException;

import com.google.gson.Gson;

public class SnapdealInventoryAtEOD {

        private static DefaultHttpClient client = new DefaultHttpClient();
        private static Map<Long, SnapdealItemDetails> itemSnapdealMap = new HashMap<Long, SnapdealItemDetails>();;
        private static Map<String, SnapdealItemDetails> snapdealItemMap = new HashMap<String, SnapdealItemDetails>();

        static{
                CatalogClient catalogServiceClient = null;
                try {
                        catalogServiceClient = new CatalogClient();
                } catch (TTransportException e1) {
                        e1.printStackTrace();
                }
                in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
                List<SnapdealItemDetails> allSnapdealItems = null;

                try {
                        allSnapdealItems = catalogClient.getAllSnapdealItems();
                } catch (TException e) {

                        e.printStackTrace();
                }
                for(SnapdealItemDetails snapdealItem:allSnapdealItems){
                        snapdealItemMap.put(snapdealItem.getSkuAtSnapdeal(),snapdealItem);
                        itemSnapdealMap.put(snapdealItem.getItem_id(), snapdealItem);

                }
                System.out.println("++++++++++++++++++++++++++++++");
                System.out.println("Created Item and Snapdeal Map ");
                System.out.println("++++++++++++++++++++++++++++++");

        }


        private static void fetchcurrentinventoryfromsnapdeal() throws UnsupportedEncodingException, TException{
                int i = 1;
                int items=0;
                Gson gson = new Gson();
                ArrayList<Inventory> currentInventoryItemList = new ArrayList<Inventory>();
                HttpGet get;
                HttpResponse response = null;
                BufferedReader rd= null;
                System.out.println("Fetching current inventory ");
                while(true){
                        Long time = System.currentTimeMillis();
                        //System.out.println("Fetching current inventory page " +i);
                        get = new HttpGet("http://seller.snapdeal.com/inventory/search?gridType=normal&_search=false&nd="+time+"&rows="+30+"&page="+i+"&sidx=&sord=asc");
                        try {
                                response = client.execute(get);
                        } catch (ClientProtocolException e) {

                                e.printStackTrace();
                        } catch (IOException e) {

                                e.printStackTrace();
                        }
                        try {
                                rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
                        } catch (IllegalStateException e) {

                                e.printStackTrace();
                        } catch (IOException e) {

                                e.printStackTrace();
                        }
                        InventoryItems inventoryitems = (InventoryItems) gson.fromJson(rd, InventoryItems.class);
                        if(inventoryitems.getRows().size()!=0){
                                for(Inventory inventory : inventoryitems.getRows()){
                                        if(snapdealItemMap.containsKey(inventory.getSellerSku())){
                                                currentInventoryItemList.add(inventory);
                                        }

                                        else{
                                        }
                                        items++;
                                }
                        }
                        else{
                                System.out.println("Common items  " + items);
                                System.out.println("Total Pages Fetched  " + i);
                                break;
                        }
                        i++;
                }
                int total =0;
                List<SnapdealStockAtEOD> allsnapdealstock = new ArrayList<SnapdealStockAtEOD>();
                long time = System.currentTimeMillis();
                for(Inventory inventory:currentInventoryItemList){
                        SnapdealStockAtEOD snapdealStockAtEOD = new SnapdealStockAtEOD();
                        System.out.println("Item Id " + snapdealItemMap.get(inventory.getSellerSku()).getItem_id());
                        snapdealStockAtEOD.setItem_id(snapdealItemMap.get(inventory.getSellerSku()).getItem_id());
                        System.out.println("Sku at SD " + snapdealItemMap.get(inventory.getSellerSku()).getSkuAtSnapdeal());
                        System.out.println("Inventory " + inventory.getAvailableInventory());
                        snapdealStockAtEOD.setAvailability(inventory.getAvailableInventory());
                        snapdealStockAtEOD.setDate(time);
                        allsnapdealstock.add(snapdealStockAtEOD);
                        total++; 
                }
                System.out.println("Inventory found for " + total);
                try{
                        new InventoryClient().getClient().updateSnapdealStockAtEOD(allsnapdealstock);
                }
                catch(Exception e){
                        new InventoryClient().getClient().updateSnapdealStockAtEOD(allsnapdealstock);
                }

        }


        public static void handleLogin() throws ClientProtocolException, IOException{
                HttpGet get = new HttpGet("http://selleraccounts.snapdeal.com/keymaker/login");
                HttpResponse response = null;
                try {
                        response = client.execute(get);
                } catch (ClientProtocolException e) {

                        e.printStackTrace();
                } catch (IOException e) {

                        e.printStackTrace();
                }
                BufferedReader rd = null;
                try {
                        rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
                } catch (IllegalStateException e1) {

                        e1.printStackTrace();
                } catch (IOException e1) {

                        e1.printStackTrace();
                }
                String line = "";
                StringBuffer sb = new StringBuffer();
                try {
                        while ((line = rd.readLine()) != null) {
                                sb.append(line);
                                //System.out.println(line);
                        }
                } catch (IOException e) {

                        e.printStackTrace();
                }
                int i= sb.toString().indexOf("name=\"lt\" value=");
                char[] charArray = sb.toString().toCharArray();
                String lt = "";
                int j=0;
                for(j=i+16;j<=charArray.length;j++){

                        if(charArray[j]==' '){
                                break;
                        }
                }
                lt = sb.substring(i+17,j-1);
                System.out.println("LT VALUE " + lt);
                i= sb.toString().indexOf("name=\"execution\" value=");
                charArray = sb.toString().toCharArray();
                String ex = "";
                j=0;
                for(j=i+24;j<=charArray.length;j++){
                        if(charArray[j]==' '){
                                break;
                        }
                }
                ex = sb.substring(i+24,j-1);
                System.out.println("EXECUTION VALUE " + ex);
                HttpPost post = new HttpPost("http://selleraccounts.snapdeal.com/login?service=http%3A%2F%2Fseller.snapdeal.com%2Fj_spring_cas_security_check");
                List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
                //nameValuePairs.add(new BasicNameValuePair("username",
                //"khushal.bhatia@saholic.com"));
                nameValuePairs.add(new BasicNameValuePair("username",
                "saholic-snapdeal@saholic.com"));
                //nameValuePairs.add(new BasicNameValuePair("password",
                //"sonline"));
                nameValuePairs.add(new BasicNameValuePair("password",
                "saholic15"));
                nameValuePairs.add(new BasicNameValuePair("_eventId","submit"));
                nameValuePairs.add(new BasicNameValuePair("execution",ex));
                nameValuePairs.add(new BasicNameValuePair("lt",lt));
                nameValuePairs.add(new BasicNameValuePair("submit","LOGIN"));
                post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
                response = client.execute(post);
                rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
                line = "";
                while ((line = rd.readLine()) != null) {
                        System.out.println(line);
                }
                get = new HttpGet("http://seller.snapdeal.com/inventory/");
                response = client.execute(get);
                rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
                while ((line = rd.readLine()) != null) {
                        //System.out.println(line);
                }
        }

        public static void main(String... args) throws ClientProtocolException, IOException, TException{
                handleLogin();
                fetchcurrentinventoryfromsnapdeal();
        }


}