Subversion Repositories SmartDukaan

package in.shop2020.inventory.controllers;


import in.shop2020.logistics.DeliveryType;
import in.shop2020.logistics.LogisticsService;
import in.shop2020.model.v1.catalog.CatalogService;
import in.shop2020.model.v1.catalog.CatalogServiceException;
import in.shop2020.model.v1.catalog.Item;
import in.shop2020.model.v1.catalog.ProductFeedSubmit;
import in.shop2020.logistics.ItemText;
import in.shop2020.thrift.clients.CatalogClient;
import in.shop2020.thrift.clients.LogisticsClient;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;

import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.thrift.TException;
import org.apache.thrift.transport.TTransportException;

import com.google.api.services.content.handler.ContentFeedsHandler;
import com.google.api.services.content.model.Product;


public class ProductFeedsController extends BaseController{
        
        private String cataLogItemId;
        private String sentFeedResult;
        private String catalogItemIdDelete;
        private String deleteFeedResult;
        private String stockLinkFeed;
        private boolean stockLinkedFeed = false;
        public String index() {
                return "index";
        }
        
        public void downloadAllProductFeeds() throws IOException{
                File file = new File("/tmp/Product-Feeds.xls");
                HSSFWorkbook hwb=new HSSFWorkbook();
                HSSFSheet sheet =  hwb.createSheet("Product Feeds");
                HSSFRow rowhead=   sheet.createRow(0);
                rowhead.createCell(0).setCellValue("Catalog Item Id");
                rowhead.createCell(1).setCellValue("Product Name");
                rowhead.createCell(2).setCellValue("Stock Linked");
                
                CatalogClient catalogClient = null;
                try {
                        catalogClient = new CatalogClient();
                } catch (Exception e1) {
                        e1.printStackTrace();
                }
                
                List<ProductFeedSubmit> feedSubmits = new ArrayList<ProductFeedSubmit>();
                
                try{
                        feedSubmits = catalogClient.getClient().getAllProductFeedSubmit();
                } catch(Exception e){
                        e.printStackTrace();
                }
                
                int i = 1;
                try{
                        for(ProductFeedSubmit feedSubmit : feedSubmits){
                                HSSFRow rowToAdd = sheet.createRow(i);
                                rowToAdd.createCell(0).setCellValue(feedSubmit.getCatalogItemId());
                                Item item = catalogClient.getClient().getItemsByCatalogId(feedSubmit.getCatalogItemId()).get(0);
                                rowToAdd.createCell(1).setCellValue(item.getBrand() + " "+ item.getModelName() + " " + item.getModelNumber());
                                rowToAdd.createCell(2).setCellValue(feedSubmit.isStockLinkedFeed());
                                i++;
                        }
                } catch(Exception e){
                        e.printStackTrace();
                }
                
                FileOutputStream fileOut = null;
                try {
                        fileOut = new FileOutputStream(file);
                } catch (FileNotFoundException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                try {
                        hwb.write(fileOut);
                } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                try {
                        fileOut.close();
                } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                byte[] buffer = new byte[(int)file.length()];
                InputStream input = null;
                try {
                        int totalBytesRead = 0;
                        input = new BufferedInputStream(new FileInputStream(file));
                        while(totalBytesRead < buffer.length){
                                int bytesRemaining = buffer.length - totalBytesRead;
                                int bytesRead = input.read(buffer, totalBytesRead, bytesRemaining); 
                                if (bytesRead > 0){
                                        totalBytesRead = totalBytesRead + bytesRead;
                                }
                        }
                }
                finally {
                        input.close();
                        file.delete();
                }

                response.setHeader("Content-Disposition", "attachment; filename=\"Product-Feeds.xls\"");
                response.setContentType("application/octet-stream");
                ServletOutputStream sos;
                try {
                        sos = response.getOutputStream();
                        sos.write(buffer);
                        sos.flush();
                } catch (IOException e) {
                        System.out.println("Unable to stream the manifest file");
                }   
        }
        
        public String sendProductFeeds(){
                //boolean sendFeedsResult = false;
                processStockLinkFeed();
                Product insertedProduct = null;
                CatalogClient catalogClient = null;
                try {
                        catalogClient = new CatalogClient();
                } catch (TTransportException e1) {
                        e1.printStackTrace();
                }
                
                if(cataLogItemId!=null && !("").equalsIgnoreCase(cataLogItemId)){
                        List<Long> itemIdList = getEntityLogisticsEstimation(Long.parseLong(cataLogItemId));
                        ContentFeedsHandler sample = new ContentFeedsHandler();
                        
                        if(catalogClient!= null){
                                if(itemIdList!=null && itemIdList.size()>0){
                                        try {
                                                Item item = catalogClient.getClient().getItem(itemIdList.get(0));
                                                insertedProduct = sample.sendProductFeed(item);
                                        } catch (IOException e) {
                                                e.printStackTrace();
                                        } catch (CatalogServiceException e) {
                                                e.printStackTrace();
                                        } catch (TException e) {
                                                e.printStackTrace();
                                        }
                                }
                                else{
                                        sentFeedResult = "Error: There is No Product avaliable for given Catalog Item Id.";
                                        return "output";
                                }
                        }
                }
                if(insertedProduct!=null){
                        if(insertedProduct.getDescription()!=null && insertedProduct.getDescription().indexOf("Error:")>-1){
                                sentFeedResult = insertedProduct.getDescription();
                                return "output";
                        }
                        
                        sentFeedResult = "Product Feeds are sent Successfully and Product Details are Given Below:\nProduct Id- "
                                +insertedProduct.getId()+" Product Title- "+insertedProduct.getTitle();
                        
                        if(catalogClient!=null){
                                ProductFeedSubmit feedSubmit = null;
                                try {
                                        feedSubmit= catalogClient.getClient().getProductFeedSubmit(Long.parseLong(cataLogItemId));
                                        if(feedSubmit!=null && feedSubmit.getCatalogItemId() > 0l){
                                                System.out.println("Comes into Update ");
                                                feedSubmit.setCatalogItemId(Long.parseLong(cataLogItemId));
                                                feedSubmit.setStockLinkedFeed(stockLinkedFeed);
                                                boolean resultUpdate = catalogClient.getClient().updateProductFeedSubmit(feedSubmit);
                                                if(resultUpdate){
                                                        sentFeedResult = sentFeedResult + "\n And Updated to Our System Successfully ";
                                                }
                                        }
                                        else{
                                                System.out.println("Comes into Add ");
                                                feedSubmit = new ProductFeedSubmit();
                                                feedSubmit.setCatalogItemId(Long.parseLong(cataLogItemId));
                                                feedSubmit.setStockLinkedFeed(stockLinkedFeed);
                                                boolean resultUpdate = catalogClient.getClient().addProductFeedSubmit(feedSubmit);
                                                if(resultUpdate){
                                                        sentFeedResult = sentFeedResult + "\n And Added to Our System Successfully ";
                                                }
                                        }
                                } catch (CatalogServiceException e) {
                                        e.printStackTrace();
                                } catch (TException e) {
                                        e.printStackTrace();
                                }
                        }
                        return "output";
                }
                else{
                        sentFeedResult = "Some Error occured while sending feeds. Please contact concerned Team";
                        return "output";
                }
                /*if(sendFeedsResult){
                        successmsg = "Product Feeds are sent Successfully";
                        return index();
                }
                else{
                        errorMsg = "Some Error occured while sending feeds. Please contact concerned Team";
                        return index();
                }*/
        }
        
        public String deleteProductFeeds(){
                CatalogClient catalogClient = null;
                try {
                        catalogClient = new CatalogClient();
                } catch (TTransportException e1) {
                        e1.printStackTrace();
                }
                if(catalogClient!=null){
                        ProductFeedSubmit feedSubmit = null;
                        try {
                                feedSubmit= catalogClient.getClient().getProductFeedSubmit(Long.parseLong(catalogItemIdDelete));
                                if(feedSubmit!=null && feedSubmit.getCatalogItemId() > 0l){
                                        
                                        ContentFeedsHandler sample = new ContentFeedsHandler();
                                        boolean deleteFeedResultBool = sample.deleteProductFeed(Long.parseLong(catalogItemIdDelete));
                                        if(deleteFeedResultBool){
                                                deleteFeedResult = "Product Feeds are deleted Successfully For Product Id "+ catalogItemIdDelete;
                                                boolean deleteResult = catalogClient.getClient().deleteProductFeedSubmit(Long.parseLong(catalogItemIdDelete));
                                                if(deleteResult){
                                                        deleteFeedResult = deleteFeedResult + "\n And Deleted from our System Successfully";
                                                }
                                        }
                                        else{
                                                deleteFeedResult = "Error Occurred: Product Feeds Deletion Unsuccessful";
                                        }
                                }
                        } catch (CatalogServiceException e) {
                                e.printStackTrace();
                        } catch (TException e) {
                                e.printStackTrace();
                        }
                }       
                
                return "output";
        }
        
        public List<Long> getEntityLogisticsEstimation(long productId){
        List<ItemText> items=null;
        List<Long> itemIds = new ArrayList<Long>();
        try {
                LogisticsClient cl = new LogisticsClient();
            LogisticsService.Client client = cl.getClient();
            items = client.getEntityLogisticsEstimation(productId, "110001", DeliveryType.PREPAID );
            for(ItemText text : items)
                itemIds.add(text.getItemId());
        } catch (Exception e1) {
            System.out.println("Unable to get items by catalog item id"+e1.getMessage());
        }
        return itemIds;
    }
        
        public void processStockLinkFeed(){
                if(stockLinkFeed!=null && ("on").equalsIgnoreCase(stockLinkFeed)){
                        stockLinkedFeed = true;
                }
        }
        
        public String getCatalogItemIdDelete() {
                return catalogItemIdDelete;
        }

        public void setCatalogItemIdDelete(String catalogItemIdDelete) {
                this.catalogItemIdDelete = catalogItemIdDelete;
        }

        public String getDeleteFeedResult() {
                return deleteFeedResult;
        }

        public void setDeleteFeedResult(String deleteFeedResult) {
                this.deleteFeedResult = deleteFeedResult;
        }

        public String getCataLogItemId() {
                return cataLogItemId;
        }

        public void setCataLogItemId(String cataLogItemId) {
                this.cataLogItemId = cataLogItemId;
        }
        
        public String getSentFeedResult() {
                return sentFeedResult;
        }

        public void setSentFeedResult(String sentFeedResult) {
                this.sentFeedResult = sentFeedResult;
        }

        public String getStockLinkFeed() {
                return stockLinkFeed;
        }

        public void setStockLinkFeed(String stockLinkFeed) {
                this.stockLinkFeed = stockLinkFeed;
        }
}