Subversion Repositories SmartDukaan

package in.shop2020.support.controllers;

import in.shop2020.model.v1.catalog.CatalogService.Client;

import in.shop2020.model.v1.catalog.CompetitorPricing;

import in.shop2020.model.v1.catalog.Item;

import in.shop2020.support.utils.ReportsUtils;

import in.shop2020.thrift.clients.CatalogClient;

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.Calendar;

import java.util.GregorianCalendar;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import javax.servlet.ServletContext;

import javax.servlet.ServletOutputStream;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.servlet.http.HttpSession;

import org.apache.commons.io.FileUtils;

import org.apache.poi.hssf.usermodel.HSSFRow;

import org.apache.poi.hssf.usermodel.HSSFSheet;

import org.apache.poi.hssf.usermodel.HSSFWorkbook;

import org.apache.poi.ss.usermodel.Cell;

import org.apache.struts2.interceptor.ServletRequestAware;

import org.apache.struts2.interceptor.ServletResponseAware;

import org.apache.struts2.util.ServletContextAware;

import org.apache.thrift.TException;

import org.apache.thrift.transport.TTransportException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import com.opensymphony.xwork2.ValidationAwareSupport;

public class CompetitionScrapingController extends ValidationAwareSupport implements ServletRequestAware ,ServletResponseAware, ServletContextAware{

    /**

     * 

     */

    private static Logger logger = LoggerFactory.getLogger(CompetitionScrapingController.class);

    private HttpServletRequest request;

    private HttpServletResponse response;

    private HttpSession session;

    private ServletContext context;

    private static final long serialVersionUID = -4056242323967836986L;

    private File file;

    private List<CompetitorPricing> previousUploads;

    private String[] snapdeal;

    private String[] flipkart;

    private String[] amazon;

    private String[] itemId;

    private String requestId;

    private List<CompetitorPricing> data;

    public String processItems() throws TException{

        long uploadId = getTimeInMilliseconds();

        String userEmail = getUserEmail();

        for(int i=0;i<snapdeal.length;i++){

            logger.info(itemId[i]);

            logger.info(snapdeal[i]);

        }

        for(int i=0;i<flipkart.length;i++){

            logger.info(itemId[i]);

            logger.info(flipkart[i]);

        }

        for(int i=0;i<amazon.length;i++){

            logger.info(itemId[i]);

            logger.info(amazon[i]);

        }

        Map<Long,CompetitorPricing> itemScrapingMap = new HashMap<Long,CompetitorPricing>();

        for(int i=0;i<itemId.length;i++){

            CompetitorPricing cp = new CompetitorPricing(); 

            cp.setItem_id(Long.valueOf(itemId[i]));

            cp.setUploadId(uploadId);

            cp.setUserEmail(userEmail);

            cp.setIsSnapdeal(Boolean.valueOf(snapdeal[i]));

            cp.setIsFlipkart(Boolean.valueOf(flipkart[i]));

            cp.setIsAmazon(Boolean.valueOf(amazon[i]));

            itemScrapingMap.put(cp.getItem_id(), cp);

        }

        Client cc = new CatalogClient().getClient();

        cc.addCompetitorScraping(itemScrapingMap);

        return getPreviousData();

    }

    public String index() throws TException{

        return "index";

    }

    public String getUploadData() throws NumberFormatException, TException{

        Client cc = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();

        data = cc.getUploadResultById(Long.valueOf(this.requestId));

        return "show";

    }

    public String getPreviousData() throws TException{

        Client cc = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();

        setPreviousUploads(cc.getPreviousCompetitorScraping(10));

        return "previous";

    }

    public void downloadReport() throws NumberFormatException, TException, IOException{

        File file = new File("/tmp/"+this.requestId+".xls");

        HSSFWorkbook hwb=new HSSFWorkbook();

        HSSFSheet sheet =  hwb.createSheet(this.requestId);

        HSSFRow rowhead=   sheet.createRow((short)0);

        rowhead.createCell((short) 0).setCellValue("ITEM-ID");

        rowhead.createCell((short) 1).setCellValue("PRODUCT");

        rowhead.createCell((short) 2).setCellValue("Our Snapdeal SP");

        rowhead.createCell((short) 3).setCellValue("Our Snapdeal Offer Price");

        rowhead.createCell((short) 4).setCellValue("Lowest Snapdeal Seller");

        rowhead.createCell((short) 5).setCellValue("Lowest Snapdeal SP");

        rowhead.createCell((short) 6).setCellValue("Lowest Offer Price");

        rowhead.createCell((short) 7).setCellValue("Our Snapdeal Inventory");

        rowhead.createCell((short) 8).setCellValue("Lowest Seller Snapdeal Inventory");

        rowhead.createCell((short) 9).setCellValue("Our Flipkart SP");

        rowhead.createCell((short) 10).setCellValue("Lowest Seller Flipkart");

        rowhead.createCell((short) 11).setCellValue("Lowest Flipkart SP");

        rowhead.createCell((short) 12).setCellValue("Our Flipkart Inventory");

        rowhead.createCell((short) 13).setCellValue("MFN Price");

        rowhead.createCell((short) 14).setCellValue("FBA Price");

        rowhead.createCell((short) 15).setCellValue("Lowest Seller Amazon");

        rowhead.createCell((short) 16).setCellValue("Lowest Amazon SP");

        rowhead.createCell((short) 17).setCellValue("MFN Inventory");

        rowhead.createCell((short) 18).setCellValue("FBA Inventory");

        Client cc = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();

        data = cc.getUploadResultById(Long.valueOf(this.requestId));

        int iterator=1;

        for (CompetitorPricing item : data){

            HSSFRow row = sheet.createRow((short)iterator);

            row.createCell((short) 0).setCellValue(item.getItem_id());

            row.createCell((short) 1).setCellValue(item.getProductName());

            row.createCell((short) 2).setCellValue(item.getOurSnapdealPrice());

            row.createCell((short) 3).setCellValue(item.getOurSnapdealOfferPrice());

            row.createCell((short) 4).setCellValue(item.getLowestSnapdealSeller());

            row.createCell((short) 5).setCellValue(item.getLowestSnapdealPrice());

            row.createCell((short) 6).setCellValue(item.getLowestSnapdealOfferPrice());

            row.createCell((short) 7).setCellValue(item.getOurSnapdealInventory());

            row.createCell((short) 8).setCellValue(item.getLowestSnapdealSellerInventory());

            row.createCell((short) 9).setCellValue(item.getOurFlipkartPrice());

            row.createCell((short) 10).setCellValue(item.getLowestFlipkartSeller());

            row.createCell((short) 11).setCellValue(item.getLowestFlipkartPrice());

            row.createCell((short) 12).setCellValue(item.getOurFlipkartInventory());

            row.createCell((short) 13).setCellValue(item.getOurMfnPrice());

            row.createCell((short) 14).setCellValue(item.getOurFbaPrice());

            row.createCell((short) 15).setCellValue(item.getLowestAmazonSeller());

            row.createCell((short) 16).setCellValue(item.getLowestAmazonPrice());

            row.createCell((short) 17).setCellValue(item.getOurMfnInventory());

            row.createCell((short) 18).setCellValue(item.getOurFbaInventory());

            iterator++;

        }

        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="+this.requestId+".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 uploadSheet(){

        return "upload";

    }

    public String addItems(){

        return "addItem";

    }

    public String uploadBulkFile() throws IOException, TException{

        long uploadId = getTimeInMilliseconds();

        String userEmail = getUserEmail();

        File fileToCreate = new File("/temp-uploads", "competition-scraping-"+String.valueOf(uploadId));

        FileUtils.copyFile(this.file, fileToCreate);

        FileInputStream iFile = new FileInputStream(new File(file.getAbsolutePath()));

        HSSFWorkbook workbook = new HSSFWorkbook(iFile);

        HSSFSheet sheet = workbook.getSheetAt(0);

        Map<Long,CompetitorPricing> itemScrapingMap = new HashMap<Long,CompetitorPricing>();

        for (int iterator=(sheet.getFirstRowNum()+1);iterator<=sheet.getLastRowNum();iterator++){

            CompetitorPricing cp = new CompetitorPricing(); 

            if (checkEmptyString(sheet.getRow(iterator).getCell(0))){

                continue;

            }

            else {

                cp.setItem_id((long) sheet.getRow(iterator).getCell(0).getNumericCellValue());

            }

            if (!checkEmptyString(sheet.getRow(iterator).getCell(1))){

                if ((long)sheet.getRow(iterator).getCell(1).getNumericCellValue()==1){

                    cp.setIsSnapdeal(true);

                }

            }

            if (!checkEmptyString(sheet.getRow(iterator).getCell(2))){

                if ((long)sheet.getRow(iterator).getCell(2).getNumericCellValue()==1){

                    cp.setIsFlipkart(true);

                }

            }

            if (!checkEmptyString(sheet.getRow(iterator).getCell(3))){

                if ((long)sheet.getRow(iterator).getCell(3).getNumericCellValue()==1){

                    cp.setIsAmazon(true);

                }

            }

            cp.setUploadId(uploadId);

            cp.setUserEmail(userEmail);

            itemScrapingMap.put(cp.getItem_id(), cp);

        }

        Client cc = new CatalogClient().getClient();

        cc.addCompetitorScraping(itemScrapingMap);

        return getPreviousData();

    }

    public boolean checkEmptyString(Cell cell){

        if (cell==null){

            return true;

        }

        return false;

    }

    public long getTimeInMilliseconds(){

        Calendar cal=GregorianCalendar.getInstance();

        return cal.getTimeInMillis();

    }

    public String getTimestamp(long timestamp){

        return new java.util.Date(timestamp).toLocaleString();

    }

    public String getUserEmail(){

        logger.info(session.getAttribute(ReportsUtils.USER_NAME).toString());

        logger.info(session.getAttribute(ReportsUtils.USER_EMAIL).toString());

        return session.getAttribute(ReportsUtils.USER_EMAIL).toString();

    }

    public File getFile() {

        return file;

    }

    public void setFile(File file) {

        this.file = file;

    }

    public void setPreviousUploads(List<CompetitorPricing> previousUploads) {

        this.previousUploads = previousUploads;

    }

    public List<CompetitorPricing> getPreviousUploads() {

        return previousUploads;

    }

    public HttpServletRequest getRequest() {

        logger.info("set request"+request.toString());

        return request;

    }

    public void setRequest(HttpServletRequest request) {

        this.request = request;

    }

    public HttpServletResponse getResponse() {

        return response;

    }

    public void setResponse(HttpServletResponse response) {

        this.response = response;

    }

    public HttpSession getSession() {

        return session;

    }

    public void setSession(HttpSession session) {

        this.session = session;

    }

    public ServletContext getContext() {

        return context;

    }

    public void setContext(ServletContext context) {

        this.context = context;

    }

    public void setServletRequest(HttpServletRequest req) {

        this.request = req;

        this.session = req.getSession();        

    }

    public void setServletContext(ServletContext arg0) {

        // TODO Auto-generated method stub

    }

    public void setServletResponse(HttpServletResponse response) {

        this.response = response;

    }

    public void setSnapdeal(String[] snapdeal) {

        this.snapdeal = snapdeal;

    }

    public String[] getSnapdeal() {

        return snapdeal;

    }

    public void setFlipkart(String[] flipkart) {

        this.flipkart = flipkart;

    }

    public String[] getFlipkart() {

        return flipkart;

    }

    public void setAmazon(String[] amazon) {

        this.amazon = amazon;

    }

    public String[] getAmazon() {

        return amazon;

    }

    public void setItemId(String[] itemId) {

        this.itemId = itemId;

    }

    public String[] getItemId() {

        return itemId;

    }

    public List<CompetitorPricing> getData() {

        return data;

    }

    public void setData(List<CompetitorPricing> data) {

        this.data = data;

    }

    public String getRequestId() {

        return requestId;

    }

    public void setRequestId(String requestId) {

        this.requestId = requestId;

    }

}