Subversion Repositories SmartDukaan

Rev

Rev 9097 | Rev 9104 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 9097 Rev 9102
Line 67... Line 67...
67 
 
 67 
 
68 
	private static Logger logger = LoggerFactory.getLogger(FetchNewFlipCartOrders .class);
68 
	private static Logger logger = LoggerFactory.getLogger(FetchNewFlipCartOrders .class);
69 
	public static void main(String[] args) throws  CatalogServiceException, TException, IOException {
 69 
	public static void main(String[] args) throws  CatalogServiceException, TException, IOException {
70 
		HttpClient client = new DefaultHttpClient();
 70 
		HttpClient client = new DefaultHttpClient();
71 
		HttpPost post = new HttpPost("https://seller.flipkart.com/login");
 71 
		HttpPost post = new HttpPost("https://seller.flipkart.com/login");
72 
		//HttpGet get = new HttpGet("https://seller.flipkart.com/dashboard/som/shipped_order_items?status=ready_to_ship%2Cdispatched%2Cshipped%2Cdispute_created%2Cdispute_closed%2Creturn_cancelled%2Cdelivered&page=1&page_size=25&_=1386575219023");
 - 
 
73 
		HttpGet get_new = new HttpGet("https://seller.flipkart.com/dashboard/som/new_order_items?status=on_hold%2Capproved.payment_approved&sort=confirm_by_date&page=1&page_size=25&_=1386574724458");
 - 
 
74 
		HttpGet get_conf = new HttpGet("https://seller.flipkart.com/dashboard/som/confirmed_order_items?status=approved.seller_approved&sort=confirm_by_date&page=1&page_size=25&_=1386748820761");
 - 
 
75 
		BufferedReader rd= null;
 72 
		BufferedReader rd= null;
76 
		try {
 73 
		try {
77 
			List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
 74 
			List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
78 
			nameValuePairs.add(new BasicNameValuePair("authName",
 75 
			nameValuePairs.add(new BasicNameValuePair("authName",
79 
			"flipkart"));
 76 
			"flipkart"));
Line 83... Line 80...
83 
			"076c27ee24d7596b06608a8ed2559f87"));
 80 
			"076c27ee24d7596b06608a8ed2559f87"));
84 
			post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
 81 
			post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
85 
			HttpResponse response = client.execute(post);
 82 
			HttpResponse response = client.execute(post);
86 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 83 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
87 
			String line = "";
 84 
			String line = "";
- 
 
 85 
			Gson gson;
- 
 
 86 
			List<Order> orders = new ArrayList<Order>();
- 
 
 87 
			OrderItems new_orders;
- 
 
 88 
			OrderItems conf_orders;
- 
 
 89 
			HttpGet get_new;
- 
 
 90 
			HttpGet get_conf;
- 
 
 91 
			long time;
- 
 
 92 
			int i=1;
88 
			while ((line = rd.readLine()) != null) {
 93 
			while ((line = rd.readLine()) != null) {
89 
				System.out.println(line);
 94 
				System.out.println(line);
90 
			}
 95 
			}
- 
 
 96 
			time = System.currentTimeMillis();
- 
 
 97 
			while(true){
- 
 
 98 
				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);
91 
			response = client.execute(get_new);
 99 
				response = client.execute(get_new);
92 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 100 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
93 
			line = "";
 101 
				line = "";
- 
 
 102 
				gson = new Gson();
- 
 
 103 
				new_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
94 
			/*while ((line = rd.readLine()) != null) {
 104 
				if(new_orders.getOrder_items().size()>0){
95 
				System.out.println(line);
 105 
					orders.addAll(new_orders.getOrder_items());
- 
 
 106 
				}
- 
 
 107 
				else{
- 
 
 108 
					break;
- 
 
 109 
				}
- 
 
 110 
				i++;
96 
			}*/
 111 
			}
97 
			Gson gson = new Gson();
 112 
			i=1;
98 
			OrderItems new_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
 113 
			time = System.currentTimeMillis();
99 
			List<Order> orders = new_orders.getOrder_items();
 114 
			while(true){
- 
 
 115 
				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);
100 
			response = client.execute(get_conf);
 116 
				response = client.execute(get_conf);
101 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 117 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
102 
			line = "";
 118 
				line = "";
- 
 
 119 
				gson = new Gson();
- 
 
 120 
				conf_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
103 
			/*while ((line = rd.readLine()) != null) {
 121 
				if(conf_orders.getOrder_items().size()>0){
- 
 
 122 
					orders.addAll(conf_orders.getOrder_items());
- 
 
 123 
				}
- 
 
 124 
				else{
- 
 
 125 
					break;
- 
 
 126 
				}
- 
 
 127 
				i++;
- 
 
 128 
			}
104 
				System.out.println(line);
 129 
			/*for(Order order:orders){
- 
 
 130 
				System.out.println("Order  " + order.getExternalId() +" "+order.getOrderItemId() + " : "+ order.getStatus());
105 
			}*/
 131 
			}*/
106 
			gson = new Gson();
 - 
 
107 
			OrderItems conf_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
 - 
 
108 
			orders.addAll(conf_orders.getOrder_items());
 - 
 
109 
			processOrders(orders);
 132 
			processOrders(orders);
110 
		} catch (IOException e) {
 133 
		} catch (IOException e) {
111 
			e.printStackTrace();
 134 
			e.printStackTrace();
112 
		}
 135 
		}
113 
		/*for(Order order:orders.getOrder_items()){
 - 
 
114 
			System.out.println("Order  " + order.getSku());
 - 
 
115 
			System.out.println("ID  " + order.getOrderItemId());
 - 
 
116 
			String create_date = order.getCreatedDate()+" "+order.getCreatedTime();
 - 
 
117 
			System.out.println("Order Created date "+ create_date);
 - 
 
118 
			System.out.println("Customer Name "+ order.getCustomerName());
 - 
 
119 
			System.out.println("Total Price "+ order.getTotalPrice());
 - 
 
120 
			System.out.println("Unit Price "+ order.getListPrice());
 - 
 
121 
			System.out.println("Shipping Address Name "+ order.getShippingAddressName());
 - 
 
122 
			System.out.println("Shipping Address "+ order.getShippingAddressLine1() +" "+order.getShippingAddressLine2()+
 - 
 
123 
					" "+order.getShippingAddressCity()+" "+order.getShippingAddressState()+" "+order.getShippingAddressPincode());
 - 
 
124 
		}*/
 - 
 
125 
	}
 136 
	}
126 
 
 137 
 
127 
	public static void processOrders(List<Order> orders) throws IOException, CatalogServiceException, TException{
 138 
	public static void processOrders(List<Order> orders) throws IOException, CatalogServiceException, TException{
128 
		logger.info("Before Processing orders ");
 139 
		logger.info("Before Processing orders ");
129 
		StringBuffer sb = new StringBuffer();
 140 
		StringBuffer sb = new StringBuffer();