Subversion Repositories SmartDukaan

package in.shop2020.warehouse.util;

import java.util.Arrays;
import java.util.Date;
import java.util.Hashtable;
import java.util.List;
import java.util.Map;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.util.ArrayList;

import in.shop2020.model.v1.inventory.InventoryService;
import in.shop2020.model.v1.inventory.Warehouse;
import in.shop2020.model.v1.order.LineItem;
import in.shop2020.model.v1.order.Order;
import in.shop2020.model.v1.order.OrderStatus;
import in.shop2020.model.v1.order.TransactionService;
import in.shop2020.model.v1.order.TransactionServiceException;
import in.shop2020.thrift.clients.InventoryClient;
import in.shop2020.thrift.clients.TransactionClient;
import in.shop2020.thrift.clients.WarehouseClient;
import in.shop2020.utils.GmailUtils;
import in.shop2020.warehouse.WarehouseService;

import javax.mail.MessagingException;

import org.apache.commons.lang.StringUtils;
import org.apache.thrift.TException;
import org.apache.thrift.transport.TTransportException;

public class HotspotStockReportSender {

        private static final String[] mailTo = {"aman.kumar@shop2020.in","amit.gupta@shop2020.in","chaitnaya.vats@shop2020.in", "raj.kumar@spiceretail.co.in"};
        private static final String senderAccountMail = "cnc.center@shop2020.in";
        private static final String senderAccountPswd = "5h0p2o2o";
        private static final List<Long> hotspotVendors = new ArrayList<Long>(Arrays.asList(1L,38L,64L));
        private static Map<Long, Warehouse> warehouseMap = new Hashtable<Long, Warehouse>(50);
        private static List<OrderStatus> undeliveredStatuses;
        private static List<OrderStatus> retInTransitStatuses;
        static {
                undeliveredStatuses = new ArrayList<OrderStatus>();
                undeliveredStatuses.add(OrderStatus.BILLED);
                undeliveredStatuses.add(OrderStatus.DELIVERED_AT_STORE);
                undeliveredStatuses.add(OrderStatus.SHIPPED_FROM_WH);
                undeliveredStatuses.add(OrderStatus.SHIPPED_TO_DESTINATION_CITY);
                undeliveredStatuses.add(OrderStatus.SHIPPED_TO_LOGST);
                undeliveredStatuses.add(OrderStatus.REACHED_DESTINATION_CITY);
                undeliveredStatuses.add(OrderStatus.RECEIVED_AT_STORE);
                
                retInTransitStatuses = new ArrayList<OrderStatus>(20);
                retInTransitStatuses.add(OrderStatus.RTO_IN_TRANSIT);
                retInTransitStatuses.add(OrderStatus.RET_PICKUP_CONFIRMED);
                retInTransitStatuses.add(OrderStatus.RET_PICKUP_REQUEST_RAISED);
                retInTransitStatuses.add(OrderStatus.RET_REQUEST_RECEIVED);
                retInTransitStatuses.add(OrderStatus.RET_REQUEST_AUTHORIZED);
                retInTransitStatuses.add(OrderStatus.RET_PICKUP_CONFIRMED);
                retInTransitStatuses.add(OrderStatus.RET_RETURN_IN_TRANSIT);
                retInTransitStatuses.add(OrderStatus.DOA_REQUEST_RECEIVED);
                retInTransitStatuses.add(OrderStatus.DOA_REQUEST_AUTHORIZED);
                retInTransitStatuses.add(OrderStatus.DOA_PICKUP_REQUEST_RAISED);
                retInTransitStatuses.add(OrderStatus.DOA_PICKUP_CONFIRMED);
                retInTransitStatuses.add(OrderStatus.DOA_PICKUP_DENIED);
                retInTransitStatuses.add(OrderStatus.DOA_RETURN_IN_TRANSIT);
                
                InventoryService.Client inventoryClient;
                try {
                        inventoryClient = new InventoryClient().getClient();
                        List<Warehouse> warehouses = inventoryClient.getWarehouses(null, null, 1L, 0L, 0L);
                        for(Warehouse warehouse : warehouses) {
                                if(warehouse.getVendor().getId()==1L||warehouse.getVendor().getId()==38L||warehouse.getVendor().getId()==64L) {
                                        warehouseMap.put(warehouse.getId(), warehouse);
                                }
                        }
                } catch (TException e) {
                        e.printStackTrace();
                }
                
        }
        
        public static void main(String[] args){
                HotspotStockReportSender reportSender = new HotspotStockReportSender();
                List<File> files = new ArrayList<File>(5);
                try {
                        //File hotspotStockInWarehouseFile = reportSender.getHotspotStockInOurWarehouse();
                        File hotspotStockRetInTransitFile = reportSender.getHotspotStockRetInTransit();
                        File undeliveredHotspotStockFile = reportSender.getUndeliveredHotspotStock();
                        
                        //files.add(hotspotStockInWarehouseFile);
                        files.add(hotspotStockRetInTransitFile);
                        files.add(undeliveredHotspotStockFile);
                } catch (Exception e) {
                        e.printStackTrace();
                }
                
                GmailUtils mailer = new GmailUtils();
                try{
                        mailer.sendSSLMessage(mailTo, "Undelivered Hotspot Stock(Billed by Saholic) IMEI details ", "", senderAccountMail, senderAccountPswd, files);
                } catch (MessagingException e1) {
                        e1.printStackTrace();
                }
        }

        private File getUndeliveredHotspotStock() throws TransactionServiceException, TException, IOException {
                TransactionService.Client transactionClient = new TransactionClient().getClient();
                List<Order> orders = transactionClient.getOrdersByVendor(hotspotVendors, undeliveredStatuses);
                File file = new File("/tmp/undeliveredHotspotStock-"+(new Date()).toString()+".xls");
                BufferedWriter bufferedWriter = new BufferedWriter(new FileWriter(file));
                bufferedWriter.write(StringUtils.join(new String[] { "Warehouse", "ItemId",
                "Brand", "Model Name", "Model Number",
                "Color", "SerialNumber", "Status", "COD" }, '\t'));
                for (Order order : orders) {
                        bufferedWriter.newLine();
                        LineItem lineItem  = order.getLineitems().get(0);
                bufferedWriter.write(StringUtils.join(new String[] {warehouseMap.get(order.getWarehouse_id()).getDisplayName(),
                                String.valueOf(lineItem.getItem_id()), lineItem.getBrand(), lineItem.getModel_name(), 
                                lineItem.getModel_number(), lineItem.getColor(), lineItem.getSerial_number(), order.getStatus().toString(),
                                (order.isCod()==false?"0":"1") }, "\t"));
                }
                bufferedWriter.close();
                return file;
        }

        private File getHotspotStockRetInTransit() throws TransactionServiceException, TException, IOException {
                TransactionService.Client transactionClient = new TransactionClient().getClient();
                List<Order> orders = transactionClient.getOrdersByVendor(hotspotVendors, retInTransitStatuses);
                File file = new File("/tmp/hotspotStockRetInTransit-"+(new Date()).toString()+".xls");
                BufferedWriter bufferedWriter = new BufferedWriter(new FileWriter(file));
                bufferedWriter.write(StringUtils.join(new String[] {"Warehouse", "ItemId",
                "Brand", "Model Name", "Model Number",
                "Color", "SerialNumber", "Status", "COD" }, '\t'));
                for (Order order : orders) {
                        bufferedWriter.newLine();
                        LineItem lineItem  = order.getLineitems().get(0);
                bufferedWriter.write(StringUtils.join(new String[] {warehouseMap.get(order.getWarehouse_id()).getDisplayName(),
                                String.valueOf(lineItem.getItem_id()), lineItem.getBrand(), lineItem.getModel_name(), 
                                lineItem.getModel_number(), lineItem.getColor(), lineItem.getSerial_number(), order.getStatus().toString(),
                                (order.isCod()==false?"0":"1") }, "\t"));
                }
                bufferedWriter.close();
                return file;
        }

        /*private File getHotspotStockInOurWarehouse() throws TException {
                WarehouseService.Client warehouseClient = new WarehouseClient().getClient();
                warehouseClient.get
                
        }*/
        
        
}