| Line 10... |
Line 10... |
| 10 |
import in.shop2020.model.v1.inventory.Warehouse;
|
10 |
import in.shop2020.model.v1.inventory.Warehouse;
|
| 11 |
import in.shop2020.model.v1.inventory.WarehouseType;
|
11 |
import in.shop2020.model.v1.inventory.WarehouseType;
|
| 12 |
import in.shop2020.thrift.clients.CatalogClient;
|
12 |
import in.shop2020.thrift.clients.CatalogClient;
|
| 13 |
import in.shop2020.thrift.clients.InventoryClient;
|
13 |
import in.shop2020.thrift.clients.InventoryClient;
|
| 14 |
import in.shop2020.thrift.clients.TransactionClient;
|
14 |
import in.shop2020.thrift.clients.TransactionClient;
|
| - |
|
15 |
import in.shop2020.utils.GmailUtils;
|
| 15 |
import inventory.Inventory;
|
16 |
import inventory.Inventory;
|
| 16 |
import inventory.InventoryHistory;
|
17 |
import inventory.InventoryHistory;
|
| 17 |
import inventory.InventoryHistoryItems;
|
18 |
import inventory.InventoryHistoryItems;
|
| 18 |
import inventory.InventoryItems;
|
19 |
import inventory.InventoryItems;
|
| 19 |
import inventory.SnapdealItemForInventory;
|
20 |
import inventory.SnapdealItemForInventory;
|
| 20 |
|
21 |
|
| 21 |
import java.io.BufferedReader;
|
22 |
import java.io.BufferedReader;
|
| - |
|
23 |
import java.io.File;
|
| 22 |
import java.io.FileInputStream;
|
24 |
import java.io.FileInputStream;
|
| 23 |
import java.io.FileNotFoundException;
|
25 |
import java.io.FileNotFoundException;
|
| 24 |
import java.io.FileOutputStream;
|
26 |
import java.io.FileOutputStream;
|
| 25 |
import java.io.IOException;
|
27 |
import java.io.IOException;
|
| 26 |
import java.io.InputStreamReader;
|
28 |
import java.io.InputStreamReader;
|
| 27 |
import java.io.UnsupportedEncodingException;
|
29 |
import java.io.UnsupportedEncodingException;
|
| 28 |
import java.util.ArrayList;
|
30 |
import java.util.ArrayList;
|
| - |
|
31 |
import java.util.Calendar;
|
| - |
|
32 |
import java.util.GregorianCalendar;
|
| 29 |
import java.util.HashMap;
|
33 |
import java.util.HashMap;
|
| 30 |
import java.util.List;
|
34 |
import java.util.List;
|
| 31 |
import java.util.Map;
|
35 |
import java.util.Map;
|
| 32 |
|
36 |
|
| - |
|
37 |
import javax.mail.MessagingException;
|
| - |
|
38 |
|
| 33 |
import org.apache.http.HttpResponse;
|
39 |
import org.apache.http.HttpResponse;
|
| 34 |
import org.apache.http.NameValuePair;
|
40 |
import org.apache.http.NameValuePair;
|
| 35 |
import org.apache.http.client.ClientProtocolException;
|
41 |
import org.apache.http.client.ClientProtocolException;
|
| 36 |
import org.apache.http.client.HttpClient;
|
42 |
import org.apache.http.client.HttpClient;
|
| 37 |
import org.apache.http.client.entity.UrlEncodedFormEntity;
|
43 |
import org.apache.http.client.entity.UrlEncodedFormEntity;
|
| Line 476... |
Line 482... |
| 476 |
List<String> notMappedItems = new ArrayList<String>();
|
482 |
List<String> notMappedItems = new ArrayList<String>();
|
| 477 |
for(Inventory inventory:inventoryItemList){
|
483 |
for(Inventory inventory:inventoryItemList){
|
| 478 |
created_orders = 0;
|
484 |
created_orders = 0;
|
| 479 |
pending_orders = 0;
|
485 |
pending_orders = 0;
|
| 480 |
if(inventoryhistoryItemMap.get(inventory.getSellerSku())!=null && inventory.getAvailableInventory()!=Long.parseLong(inventoryhistoryItemMap.get(inventory.getSellerSku()).getNewValue())){
|
486 |
if(inventoryhistoryItemMap.get(inventory.getSellerSku())!=null && inventory.getAvailableInventory()!=Long.parseLong(inventoryhistoryItemMap.get(inventory.getSellerSku()).getNewValue())){
|
| 481 |
try {
|
487 |
try {
|
| 482 |
try{
|
488 |
try{
|
| 483 |
sku = Long.parseLong(inventory.getSellerSku());
|
489 |
sku = Long.parseLong(inventory.getSellerSku());
|
| 484 |
}
|
490 |
}
|
| 485 |
catch(NumberFormatException nfe){
|
491 |
catch(NumberFormatException nfe){
|
| 486 |
try {
|
492 |
try {
|
| 487 |
snapdealitem = catalogServiceClient.getSnapdealItembySkuAtSnapdeal(inventory.getSellerSku());
|
493 |
snapdealitem = catalogServiceClient.getSnapdealItembySkuAtSnapdeal(inventory.getSellerSku());
|
| 488 |
if(snapdealitem.getItem_id()!=0){
|
494 |
if(snapdealitem.getItem_id()!=0){
|
| 489 |
sku = snapdealitem.getItem_id();
|
495 |
sku = snapdealitem.getItem_id();
|
| 490 |
skuitemidMap.put(inventory.getSellerSku(),sku);
|
496 |
skuitemidMap.put(inventory.getSellerSku(),sku);
|
| 491 |
}
|
497 |
}
|
| 492 |
else{
|
498 |
else{
|
| 493 |
notMappedItems.add("inventory.getSellerSku() "+inventory.getProductName());
|
499 |
notMappedItems.add("inventory.getSellerSku() "+inventory.getProductName());
|
| 494 |
System.out.println();
|
500 |
System.out.println();
|
| 495 |
}
|
501 |
}
|
| 496 |
} catch (TTransportException e) {
|
502 |
} catch (TTransportException e) {
|
| 497 |
// TODO Auto-generated catch block
|
503 |
// TODO Auto-generated catch block
|
| 498 |
e.printStackTrace();
|
504 |
e.printStackTrace();
|
| 499 |
}
|
- |
|
| 500 |
}
|
- |
|
| 501 |
if(sku!=0){
|
- |
|
| 502 |
System.out.println("Fetching created orders for " + sku);
|
- |
|
| 503 |
created_orders = transactionClient.getOrdersCreatedAfterTimestampForSource(inventoryhistoryItemMap.get(inventory.getSellerSku()).getUpdateTime(), 7, sku);
|
- |
|
| 504 |
}
|
- |
|
| 505 |
else{
|
- |
|
| 506 |
continue;
|
- |
|
| 507 |
}
|
505 |
}
|
| 508 |
} catch (NumberFormatException e) {
|
- |
|
| 509 |
// TODO Auto-generated catch block
|
- |
|
| 510 |
e.printStackTrace();
|
- |
|
| 511 |
} catch (TException e) {
|
- |
|
| 512 |
// TODO Auto-generated catch block
|
- |
|
| 513 |
e.printStackTrace();
|
- |
|
| 514 |
}
|
506 |
}
|
| - |
|
507 |
if(sku!=0){
|
| - |
|
508 |
System.out.println("Fetching created orders for " + sku);
|
| - |
|
509 |
created_orders = transactionClient.getOrdersCreatedAfterTimestampForSource(inventoryhistoryItemMap.get(inventory.getSellerSku()).getUpdateTime(), 7, sku);
|
| - |
|
510 |
}
|
| - |
|
511 |
else{
|
| - |
|
512 |
continue;
|
| - |
|
513 |
}
|
| - |
|
514 |
} catch (NumberFormatException e) {
|
| - |
|
515 |
// TODO Auto-generated catch block
|
| - |
|
516 |
e.printStackTrace();
|
| - |
|
517 |
} catch (TException e) {
|
| - |
|
518 |
// TODO Auto-generated catch block
|
| - |
|
519 |
e.printStackTrace();
|
| - |
|
520 |
}
|
| 515 |
pending_orders = (inventory.getAvailableInventory() - Long.parseLong(inventoryhistoryItemMap.get(inventory.getSellerSku()).getNewValue()) - created_orders);
|
521 |
pending_orders = (inventory.getAvailableInventory() - Long.parseLong(inventoryhistoryItemMap.get(inventory.getSellerSku()).getNewValue()) - created_orders);
|
| 516 |
}
|
522 |
}
|
| 517 |
itemIdpendingOrdersMap.put(sku, pending_orders);
|
523 |
itemIdpendingOrdersMap.put(sku, pending_orders);
|
| 518 |
}
|
524 |
}
|
| 519 |
}
|
525 |
}
|
| 520 |
|
526 |
|
| Line 618... |
Line 624... |
| 618 |
row.getCell((short) 1).setCellValue(inventory.getSellerSku());
|
624 |
row.getCell((short) 1).setCellValue(inventory.getSellerSku());
|
| 619 |
row.getCell((short) 2).setCellValue(inventory.getProductName());
|
625 |
row.getCell((short) 2).setCellValue(inventory.getProductName());
|
| 620 |
row.getCell((short) 3).setCellValue(inventory.getAvailableInventory());
|
626 |
row.getCell((short) 3).setCellValue(inventory.getAvailableInventory());
|
| 621 |
row.getCell((short) 4).setCellValue(sent_inventory);
|
627 |
row.getCell((short) 4).setCellValue(sent_inventory);
|
| 622 |
if(inventory.getAvailableInventory()!=0 && sent_inventory==0){
|
628 |
if(inventory.getAvailableInventory()!=0 && sent_inventory==0){
|
| 623 |
outOfStockItems.append(sku+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+sent_inventory);
|
629 |
outOfStockItems.append(sku+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+sent_inventory+"\n");
|
| 624 |
}
|
630 |
}
|
| 625 |
if(inventory.getAvailableInventory()==0 && sent_inventory!=0){
|
631 |
if(inventory.getAvailableInventory()==0 && sent_inventory!=0){
|
| 626 |
backInStockItems.append(sku+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+sent_inventory);
|
632 |
backInStockItems.append(sku+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+sent_inventory+"\n");
|
| 627 |
}
|
633 |
}
|
| 628 |
if(inventory.isLive()){
|
634 |
if(inventory.isLive()){
|
| 629 |
row.getCell((short) 5).setCellValue("Yes");
|
635 |
row.getCell((short) 5).setCellValue("Yes");
|
| 630 |
}
|
636 |
}
|
| 631 |
else{
|
637 |
else{
|
| Line 658... |
Line 664... |
| 658 |
} catch (FileNotFoundException e) {
|
664 |
} catch (FileNotFoundException e) {
|
| 659 |
// TODO Auto-generated catch block
|
665 |
// TODO Auto-generated catch block
|
| 660 |
e.printStackTrace();
|
666 |
e.printStackTrace();
|
| 661 |
}
|
667 |
}
|
| 662 |
try {
|
668 |
try {
|
| 663 |
|
669 |
|
| 664 |
hwb.write(fileOut);
|
670 |
hwb.write(fileOut);
|
| 665 |
} catch (IOException e) {
|
671 |
} catch (IOException e) {
|
| 666 |
// TODO Auto-generated catch block
|
672 |
// TODO Auto-generated catch block
|
| 667 |
e.printStackTrace();
|
673 |
e.printStackTrace();
|
| 668 |
}
|
674 |
}
|
| Line 715... |
Line 721... |
| 715 |
} catch (IOException e) {
|
721 |
} catch (IOException e) {
|
| 716 |
// TODO Auto-generated catch block
|
722 |
// TODO Auto-generated catch block
|
| 717 |
e.printStackTrace();
|
723 |
e.printStackTrace();
|
| 718 |
}
|
724 |
}
|
| 719 |
*/
|
725 |
*/
|
| - |
|
726 |
java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
|
| - |
|
727 |
Calendar cal=GregorianCalendar.getInstance();
|
| - |
|
728 |
String emailFromAddress = "build@shop2020.in";
|
| - |
|
729 |
String password = "cafe@nes";
|
| - |
|
730 |
GmailUtils mailer = new GmailUtils();
|
| - |
|
731 |
String sendTo[] = new String[]{"vikram.raghav@shop2020.in"};
|
| - |
|
732 |
/*String sendTo[] = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
|
| - |
|
733 |
"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
|
| - |
|
734 |
"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};
|
| - |
|
735 |
*/
|
| - |
|
736 |
String emailSubjectTxt = "Products back in stock on Snapdeal "+sdf.format(cal.getTime());
|
| - |
|
737 |
String text = backInStockItems.toString();
|
| - |
|
738 |
if(text.length() > 0){
|
| - |
|
739 |
try {
|
| - |
|
740 |
mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
|
| - |
|
741 |
} catch (MessagingException e) {
|
| - |
|
742 |
e.printStackTrace();
|
| - |
|
743 |
}
|
| - |
|
744 |
}
|
| - |
|
745 |
emailSubjectTxt = "Products out of stock on Snapdeal "+sdf.format(cal.getTime());
|
| - |
|
746 |
text = outOfStockItems.toString();
|
| - |
|
747 |
if(text.length() > 0){
|
| - |
|
748 |
try {
|
| - |
|
749 |
mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
|
| - |
|
750 |
} catch (MessagingException e) {
|
| - |
|
751 |
e.printStackTrace();
|
| - |
|
752 |
}
|
| - |
|
753 |
}
|
| - |
|
754 |
|
| 720 |
}
|
755 |
}
|
| 721 |
|
756 |
|
| 722 |
}
|
757 |
}
|