Subversion Repositories SmartDukaan

Rev

Rev 12596 | Go to most recent revision | Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
12589 manish.sha 1 
package in.shop2020.serving.services;
2 
 
3 
import java.io.BufferedReader;
4 
import java.io.IOException;
5 
import java.io.InputStreamReader;
6 
import java.util.ArrayList;
7 
import java.util.List;
8 
 
9 
import in.shop2020.model.v1.order.FlipkartOrder;
10 
import in.shop2020.model.v1.order.TransactionServiceException;
11 
 
12 
import in.shop2020.serving.model.Order;
13 
import in.shop2020.serving.model.OrderItems;
14 
import in.shop2020.thrift.clients.TransactionClient;
15 
 
16 
import org.apache.http.HttpResponse;
17 
import org.apache.http.NameValuePair;
18 
import org.apache.http.client.HttpClient;
19 
import org.apache.http.client.entity.UrlEncodedFormEntity;
20 
import org.apache.http.client.methods.HttpGet;
21 
import org.apache.http.client.methods.HttpPost;
22 
import org.apache.http.impl.client.DefaultHttpClient;
23 
import org.apache.http.message.BasicNameValuePair;
24 
import org.apache.thrift.TException;
25 
import org.apache.thrift.transport.TTransportException;
26 
import org.json.JSONArray;
27 
import org.json.JSONException;
28 
import org.json.JSONObject;
29 
 
30 
import com.google.gson.Gson;
31 
 
32 
public class FlipkartHoldOrdersReconciliation{
33 
	public static void main(String[] args) throws TException, TransactionServiceException, JSONException {
34 
		HttpClient client = new DefaultHttpClient();
35 
		HttpPost post = new HttpPost("https://seller.flipkart.com/login");
36 
		BufferedReader rd= null;
37 
		try {
38 
			List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
39 
			nameValuePairs.add(new BasicNameValuePair("authName",
40 
			"flipkart"));
41 
			nameValuePairs.add(new BasicNameValuePair("username",
42 
			"flipkart-support@saholic.com"));
43 
			nameValuePairs.add(new BasicNameValuePair("password",
44 
			"076c27ee24d7596b06608a8ed2559f87"));
45 
			post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
46 
			HttpResponse response = client.execute(post);
47 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
48 
			String line = "";
49 
			HttpGet get_new;
50 
 
51 
			while ((line = rd.readLine()) != null) {
52 
				System.out.println(line);
53 
			}
54 
 
55 
			//https://seller.flipkart.com/order_management/search_order_items?order_id=OD40827062297&sellerId=m2z93iskuj81qiid
56 
			TransactionClient transactionServiceClient = new TransactionClient();
57 
			in.shop2020.model.v1.order.TransactionService.Client tClient = transactionServiceClient.getClient();
58 
			List<FlipkartOrder> pendingFkOrdersList = tClient.getVerificationPendingOrdersFK();
59 
			StringBuffer sb = new StringBuffer();
60 
			for(FlipkartOrder fkOrder : pendingFkOrdersList){
61 
				get_new = new HttpGet("https://seller.flipkart.com/order_management/search_order_items?order_id="+fkOrder.getFlipkartOrderId()+"&sellerId=m2z93iskuj81qiid");
62 
				response = client.execute(get_new);
63 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
64 
				line = "";
65 
				line = rd.readLine();
66 
				JSONObject jsonDataObj = null;
67 
				JSONArray jsonObjArr = null;
68 
				if(line == null || line.isEmpty()){
69 
					sb.append("Flipkart Order Id -"+ fkOrder.getFlipkartOrderId()+" Response - "+line);
70 
					sb.append("\n");
71 
					continue;
72 
				} else if (!line.startsWith("{")){
73 
					sb.append("Flipkart Order Id -"+ fkOrder.getFlipkartOrderId()+" Response - "+line);
74 
					sb.append("\n");
75 
					continue;
76 
				}
77 
				else{
78 
					jsonDataObj = new JSONObject(line);
79 
				}
80 
 
81 
				if(jsonDataObj!=null){
82 
					jsonObjArr = new JSONArray(jsonDataObj.get("items").toString());
83 
				}
84 
 
85 
				if(jsonObjArr!=null && jsonObjArr.length()>0){
86 
					JSONObject jsonObj = null;
87 
					jsonObj = jsonObjArr.getJSONObject(0);
88 
					if(jsonObj!=null){
89 
						System.out.println("jsonObj..... "+ jsonObj);
90 
						if(jsonObj.get("status")!=null){
91 
							String status = jsonObj.get("status").toString();
92 
							if("on_hold".equalsIgnoreCase(status)){
93 
 
94 
							}
95 
							if("approved".equalsIgnoreCase(status)){
96 
								if(tClient ==null || !tClient.isAlive()){
97 
									tClient = transactionServiceClient.getClient();
98 
								}
99 
								tClient.verifyOrder(fkOrder.getOrderId());
100 
								tClient.acceptOrder(fkOrder.getOrderId());
101 
							}
102 
							if("cancelled".equalsIgnoreCase(status)){
103 
								if(tClient ==null || !tClient.isAlive()){
104 
									tClient = transactionServiceClient.getClient();
105 
								}
106 
								tClient.refundOrder(fkOrder.getOrderId(), "flipkart", "As per Buyer's Request");
107 
							}
108 
						}else{
109 
 
110 
						}
111 
					}
112 
				}
113 
			}
114 
 
115 
			System.out.println(sb.toString());
116 
		} catch (IOException e) {
117 
			e.printStackTrace();
118 
		}
119 
	}
120 
}