| Line 68... |
Line 68... |
| 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");
|
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 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");
|
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");
|
| 74 |
BufferedReader rd= null;
|
75 |
BufferedReader rd= null;
|
| 75 |
try {
|
76 |
try {
|
| 76 |
List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
|
77 |
List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
|
| 77 |
nameValuePairs.add(new BasicNameValuePair("authName",
|
78 |
nameValuePairs.add(new BasicNameValuePair("authName",
|
| 78 |
"flipkart"));
|
79 |
"flipkart"));
|
| Line 85... |
Line 86... |
| 85 |
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
|
86 |
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
|
| 86 |
String line = "";
|
87 |
String line = "";
|
| 87 |
while ((line = rd.readLine()) != null) {
|
88 |
while ((line = rd.readLine()) != null) {
|
| 88 |
System.out.println(line);
|
89 |
System.out.println(line);
|
| 89 |
}
|
90 |
}
|
| 90 |
response = client.execute(get);
|
91 |
response = client.execute(get_new);
|
| 91 |
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
|
92 |
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
|
| 92 |
line = "";
|
93 |
line = "";
|
| 93 |
/* while ((line = rd.readLine()) != null) {
|
94 |
/*while ((line = rd.readLine()) != null) {
|
| 94 |
System.out.println(line);
|
95 |
System.out.println(line);
|
| 95 |
}
|
96 |
}*/
|
| - |
|
97 |
Gson gson = new Gson();
|
| - |
|
98 |
OrderItems new_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
|
| - |
|
99 |
List<Order> orders = new_orders.getOrder_items();
|
| - |
|
100 |
response = client.execute(get_conf);
|
| - |
|
101 |
rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
|
| - |
|
102 |
line = "";
|
| - |
|
103 |
/*while ((line = rd.readLine()) != null) {
|
| - |
|
104 |
System.out.println(line);
|
| - |
|
105 |
}*/
|
| - |
|
106 |
gson = new Gson();
|
| - |
|
107 |
OrderItems conf_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
|
| - |
|
108 |
orders.addAll(conf_orders.getOrder_items());
|
| - |
|
109 |
processOrders(orders);
|
| 96 |
*/ } catch (IOException e) {
|
110 |
} catch (IOException e) {
|
| 97 |
e.printStackTrace();
|
111 |
e.printStackTrace();
|
| 98 |
}
|
112 |
}
|
| 99 |
Gson gson = new Gson();
|
- |
|
| 100 |
OrderItems orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
|
- |
|
| 101 |
processOrders(orders.getOrder_items());
|
- |
|
| 102 |
/*for(Order order:orders.getOrder_items()){
|
113 |
/*for(Order order:orders.getOrder_items()){
|
| 103 |
System.out.println("Order " + order.getSku());
|
114 |
System.out.println("Order " + order.getSku());
|
| 104 |
System.out.println("ID " + order.getOrderItemId());
|
115 |
System.out.println("ID " + order.getOrderItemId());
|
| 105 |
String create_date = order.getCreatedDate()+" "+order.getCreatedTime();
|
116 |
String create_date = order.getCreatedDate()+" "+order.getCreatedTime();
|
| 106 |
System.out.println("Order Created date "+ create_date);
|
117 |
System.out.println("Order Created date "+ create_date);
|
| Line 168... |
Line 179... |
| 168 |
}
|
179 |
}
|
| 169 |
else{
|
180 |
else{
|
| 170 |
sku = order.getSku();
|
181 |
sku = order.getSku();
|
| 171 |
logger.info(orderId+" "+subOrderId + " Processing sku " + sku);
|
182 |
logger.info(orderId+" "+subOrderId + " Processing sku " + sku);
|
| 172 |
}
|
183 |
}
|
| 173 |
if(order.getStatus().length()!=0 && order.getStatus().equalsIgnoreCase("Approved")){
|
184 |
if(order.getStatus().length()!=0 && (order.getStatus().equalsIgnoreCase("Approved") || order.getStatus().equalsIgnoreCase("confirmed"))){
|
| 174 |
String status = order.getStatus();
|
185 |
String status = order.getStatus();
|
| 175 |
}
|
186 |
}
|
| 176 |
else{
|
187 |
else{
|
| 177 |
if(order.getStatus().length()==0){
|
188 |
if(order.getStatus().length()==0){
|
| 178 |
sb.append(orderId+" "+subOrderId + " Could not parse status " + "\n");
|
189 |
sb.append(orderId+" "+subOrderId + " Could not parse status " + "\n");
|
| Line 585... |
Line 596... |
| 585 |
GmailUtils mailer = new GmailUtils();
|
596 |
GmailUtils mailer = new GmailUtils();
|
| 586 |
String sendTo[] = new String[]{"vikram.raghav@shop2020.in"};
|
597 |
String sendTo[] = new String[]{"vikram.raghav@shop2020.in"};
|
| 587 |
/*String sendTo[] = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
|
598 |
/*String sendTo[] = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
|
| 588 |
"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
|
599 |
"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
|
| 589 |
"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};
|
600 |
"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};
|
| 590 |
*/try {
|
601 |
*/try {
|
| 591 |
logger.info("Before Sending Emails");
|
602 |
logger.info("Before Sending Emails");
|
| 592 |
|
603 |
|
| 593 |
if(sb.toString().equalsIgnoreCase("")){
|
604 |
if(sb.toString().equalsIgnoreCase("")){
|
| 594 |
if(orders_processed!=0){
|
605 |
if(orders_processed!=0){
|
| 595 |
String emailSubjectTxt = orders_processed + " Flipkart " + order_string + " Created "+sdf.format(cal.getTime());
|
606 |
String emailSubjectTxt = orders_processed + " Flipkart " + order_string + " Created "+sdf.format(cal.getTime());
|
| 596 |
mailer.sendSSLMessage(sendTo, emailSubjectTxt,"Orders Created Successfully (No Alerts)", emailFromAddress, password, new ArrayList<File>());
|
607 |
mailer.sendSSLMessage(sendTo, emailSubjectTxt,"Orders Created Successfully (No Alerts)", emailFromAddress, password, new ArrayList<File>());
|
| 597 |
logger.info("Sending Email Flipkart Orders Created Successfully (No Alerts)");
|
608 |
logger.info("Sending Email Flipkart Orders Created Successfully (No Alerts)");
|
| 598 |
}
|
609 |
}
|
| 599 |
else{
|
610 |
else{
|
| 600 |
String emailSubjectTxt = "No new orders created "+sdf.format(cal.getTime());
|
611 |
String emailSubjectTxt = "No new orders created "+sdf.format(cal.getTime());
|
| 601 |
mailer.sendSSLMessage(sendTo, emailSubjectTxt,"No new orders created", emailFromAddress, password, new ArrayList<File>());
|
612 |
mailer.sendSSLMessage(sendTo, emailSubjectTxt,"No new orders created", emailFromAddress, password, new ArrayList<File>());
|
| 602 |
logger.info("Sending Email Flipkart Orders Created Successfully (No Alerts)");
|
613 |
logger.info("Sending Email Flipkart Orders Created Successfully (No Alerts)");
|
| 603 |
}
|
614 |
}
|
| 604 |
}
|
615 |
}
|
| 605 |
else{
|
616 |
else{
|
| 606 |
if(orders_processed!=0){
|
617 |
if(orders_processed!=0){
|
| 607 |
String emailSubjectTxt = orders_processed + " Flipkart " + order_string + " Created (Check Alerts) "+sdf.format(cal.getTime());
|
618 |
String emailSubjectTxt = orders_processed + " Flipkart " + order_string + " Created (Check Alerts) "+sdf.format(cal.getTime());
|
| 608 |
mailer.sendSSLMessage(sendTo, emailSubjectTxt,sb.toString(), emailFromAddress, password, new ArrayList<File>());
|
619 |
mailer.sendSSLMessage(sendTo, emailSubjectTxt,sb.toString(), emailFromAddress, password, new ArrayList<File>());
|
| 609 |
logger.info("Sending Email Flipkart Orders Created Successfully (Check Alerts)");
|
620 |
logger.info("Sending Email Flipkart Orders Created Successfully (Check Alerts)");
|
| 610 |
}
|
621 |
}
|
| 611 |
else{
|
622 |
else{
|
| 612 |
String emailSubjectTxt = "No new Flipkart orders created "+sdf.format(cal.getTime());
|
623 |
String emailSubjectTxt = "No new Flipkart orders created "+sdf.format(cal.getTime());
|
| 613 |
mailer.sendSSLMessage(sendTo, emailSubjectTxt,sb.toString(), emailFromAddress, password, new ArrayList<File>());
|
624 |
mailer.sendSSLMessage(sendTo, emailSubjectTxt,sb.toString(), emailFromAddress, password, new ArrayList<File>());
|
| 614 |
logger.info("Sending Email Flipkart Orders Created Successfully (Check Alerts)");
|
625 |
logger.info("Sending Email Flipkart Orders Created Successfully (Check Alerts)");
|
| 615 |
}
|
626 |
}
|
| 616 |
}
|
627 |
}
|
| 617 |
}
|
628 |
}
|
| 618 |
catch (Exception e) {
|
629 |
catch (Exception e) {
|
| 619 |
e.printStackTrace();
|
630 |
e.printStackTrace();
|
| 620 |
logger.error("Exception ",e);
|
631 |
logger.error("Exception ",e);
|
| 621 |
}
|
632 |
}
|
| 622 |
|
633 |
|
| 623 |
}
|
634 |
}
|
| 624 |
|
635 |
|
| 625 |
public static LineItem createLineItem(long itemId, double amount) throws CatalogServiceException, TException {
|
636 |
public static LineItem createLineItem(long itemId, double amount) throws CatalogServiceException, TException {
|
| 626 |
LineItem lineItem = new LineItem();
|
637 |
LineItem lineItem = new LineItem();
|