Subversion Repositories SmartDukaan

package in.shop2020.serving.services;

import in.shop2020.thrift.clients.TransactionClient;

import in.shop2020.utils.GmailUtils;

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Calendar;

import java.util.List;

import javax.mail.MessagingException;

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 org.json.JSONArray;

import org.json.JSONObject;

public class FlipkartOrderStatusReconciliation{

	static String emailFromAddress;

	static String password;

	static GmailUtils mailer;

	static String sendTo[];

	private static String cookies;

	static {

		emailFromAddress = "build-staging@shop2020.in";

		password = "shop2020";

		mailer = new GmailUtils();

		sendTo = new String[] { "kshitij.sood@shop2020.in", "manish.sharma@shop2020.in", "amit.gupta@shop2020.in" };

	}

	public static void main(String[] args) throws MessagingException {

		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 = 1386432631000l;new TransactionClient().getClient().getMinCreatedTimeStampUndeliveredOrdersForSource(OrderSource.FLIPKART.getValue());*/

			Calendar cal = Calendar.getInstance();

			cal.add(Calendar.DAY_OF_MONTH, -30);

			minCreationDate = cal.getTimeInMillis();

			HttpGet get_new;

			get_new = new HttpGet("https://seller.flipkart.com/");

			get_new.addHeader("Host","seller.flipkart.com");

            get_new.addHeader("User-agent", "Mozilla/5.0 (X11; Linux i686) AppleWebKit/537.31 (KHTML, like Gecko) Chrome/26.0.1410.63 Safari/537.31");

            get_new.addHeader("Connection","keep-alive");

            HttpResponse response = client.execute(get_new);

            rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));

            String line = "";

            while ((line = rd.readLine()) != null) {

                System.out.println(line);

            }

            cookies = response.getFirstHeader("Set-Cookie") == null ? "" : 

                response.getFirstHeader("Set-Cookie").getValue();

            System.out.println("Cookies Before Login "+ cookies);

			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",

			"bestmobiledeals2010"));

			post.addHeader("Cookie",cookies);

			post.addHeader("User-agent", "Mozilla/4.0");

			post.addHeader("Referer", "seller.flipkart.com");

			post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));

			response = client.execute(post);

			cookies = response.getFirstHeader("Set-Cookie") == null ? "" : 

                response.getFirstHeader("Set-Cookie").getValue();

			System.out.println("Cookies After Login "+cookies);

			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));

			line = "";

			while ((line = rd.readLine()) != null) {

				System.out.println(line);

			}

			long time;

			int i=1;

			time = System.currentTimeMillis();

			outer:while(true){

				get_new = new HttpGet("https://seller.flipkart.com/dashboard/som/shipped_order_items?status=delivered&page="+i+"&page_size=50&_="+time);

				get_new.addHeader("Cookie",cookies+";  __gads=ID=dfe0374cf04d1576:T=1381304511:S=ALNI_Ma2TpDrlF9_amkoqp3MOYJBaFAOUg; km_lv=x; T=TI138130450866706710769873257251497444628820234222703981199700765991; __CG=u%3A6208250296506778000%2Cs%3A2098853214%2Ct%3A1419058011787%2Cc%3A1%2Ck%3Awww.flipkart.com/24/24/76%2Cf%3A0%2Ci%3A1; S=d1t13CXEVURPbRn%2FTAlMG9iwwwBWoS%2FUUixPxuJkY6W8pdfcWEzMG07x3EBPSRtlGHPdclpSYHdyFGacGJ0K01qpxtQ%3D%3D; __sonar=6631097455123118581; __utma=19769839.1156779613.1390806906.1432813861.1435573112.27; __utmc=19769839; __utmz=19769839.1435573112.27.15.utmcsr=zimbrasmtp.com|utmccn=(referral)|utmcmd=referral|utmcct=/ch300-3.htm; s_ch_list=%5B%5B'Affiliates'%2C'1435573117633'%5D%5D; s_cc=true; s_ppv=0; s_sq=%5B%5BB%5D%5D; SN=2.VIB4C4C187B63B4436AAE42944FD9BE1C9.SI2B008083CC2145FFB103D6E76CDB343C.VS143557310149768094467.1435573140; VID=2.VIB4C4C187B63B4436AAE42944FD9BE1C9.1435573140.VS143557310149768094467; NSID=2.SI2B008083CC2145FFB103D6E76CDB343C.1435573140.VIB4C4C187B63B4436AAE42944FD9BE1C9; sellerId=m2z93iskuj81qiid; _ga=GA1.2.1156779613.1390806906; kvcd=1435740168445; km_vs=1; km_ai=m2z93iskuj81qiid; km_ni=m2z93iskuj81qiid; _gat=1; km_uq=; __utma=143439159.1156779613.1390806906.1435737045.1435740037.94; __utmb=143439159.9.9.1435740156534; __utmc=143439159; __utmz=143439159.1390806906.1.1.utmcsr=(direct)|utmccn=(direct)|utmcmd=(none); _mkto_trk=id:021-QVV-957&token:_mch-flipkart.com-1434970574990-64308");

				get_new.addHeader("Host","seller.flipkart.com");

	            get_new.addHeader("User-agent", "Mozilla/5.0 (X11; Linux i686) AppleWebKit/537.31 (KHTML, like Gecko) Chrome/26.0.1410.63 Safari/537.31");

	            get_new.addHeader("Connection","keep-alive");

				response = client.execute(get_new);

				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));

				line = "";

				JSONObject jsonDataObj = null;

				line = rd.readLine();

				JSONArray jsonObjArr = null;

				if(line == null || line.isEmpty()){

					if(i==120)

						break;

					i++;

					continue;

				}

				jsonDataObj = new JSONObject(line);

				jsonObjArr = new JSONArray(jsonDataObj.get("order_items").toString());

				if(jsonObjArr==null || jsonObjArr.length()==0){

					break;

				}

				if(jsonObjArr!=null && jsonObjArr.length()>0){

					for(int k=0; k< jsonObjArr.length(); k++){

						JSONObject jsonObj = null;

						jsonObj = jsonObjArr.getJSONObject(k);

						if(jsonObj!=null){

							/*System.out.println("jsonObj..... "+ jsonObj);*/

							if(minCreationDate > 0l && gotFlipkartDateFormat.parse(gotFlipkartDateFormat.format(minCreationDate)).getTime() <= gotFlipkartDateFormat.parse(jsonObj.get("created_date").toString()).getTime()){

								List<String> delivered_dataList = new ArrayList<String>();

								String externalId = jsonObj.get("external_id").toString();

								String orderItemId = jsonObj.get("order_item_id").toString();

								String modifiedDate = jsonObj.get("modified_date").toString();

								delivered_dataList.add(externalId);

								delivered_dataList.add(orderItemId);

								delivered_dataList.add(ourDBDateFormat.format(gotFlipkartDateFormat.parse(modifiedDate).getTime()));

								System.out.println("Flipkart Order Id... "+externalId + " ... Flipkart Sub Order Code... "+ orderItemId +" ... Delivery Date ... "+ ourDBDateFormat.format(gotFlipkartDateFormat.parse(modifiedDate).getTime()) + "....Created Date..... "+ jsonObj.get("created_date").toString());

								deliveredOrderDataList.add(delivered_dataList);

							}

							else{

								break outer;

							}

						}

					}

				}

				i++;

			}

			System.out.println("deliveredOrderDataList size... "+deliveredOrderDataList.size());

			if(deliveredOrderDataList!=null && deliveredOrderDataList.size()>0){

				new TransactionClient().getClient().updateFlipkartOrdersStatus(deliveredOrderDataList);

			}

		} catch(Exception e){

			e.printStackTrace();

			mailer.sendSSLMessage(sendTo, "Error in Flipkart Order Status Recon", emailFromAddress, password, "<html><body><p>Please check log</p></body></html>");

		}

	}

}