Subversion Repositories SmartDukaan

Rev

Rev 12256 | Rev 12261 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 12256 Rev 12260
Line 28... Line 28...
28 
import org.apache.commons.io.FileUtils;
 28 
import org.apache.commons.io.FileUtils;
29 
import org.apache.poi.hssf.usermodel.HSSFRow;
 29 
import org.apache.poi.hssf.usermodel.HSSFRow;
30 
import org.apache.poi.hssf.usermodel.HSSFSheet;
 30 
import org.apache.poi.hssf.usermodel.HSSFSheet;
31 
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
 31 
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
32 
import org.apache.poi.ss.usermodel.Cell;
 32 
import org.apache.poi.ss.usermodel.Cell;
- 
 
 33 
import org.apache.struts2.convention.annotation.InterceptorRef;
- 
 
 34 
import org.apache.struts2.convention.annotation.InterceptorRefs;
- 
 
 35 
import org.apache.struts2.convention.annotation.Result;
- 
 
 36 
import org.apache.struts2.convention.annotation.Results;
33 
import org.apache.struts2.interceptor.ServletRequestAware;
 37 
import org.apache.struts2.interceptor.ServletRequestAware;
34 
import org.apache.struts2.interceptor.ServletResponseAware;
 38 
import org.apache.struts2.interceptor.ServletResponseAware;
35 
import org.apache.struts2.util.ServletContextAware;
 39 
import org.apache.struts2.util.ServletContextAware;
36 
import org.apache.thrift.TException;
 40 
import org.apache.thrift.TException;
37 
import org.apache.thrift.transport.TTransportException;
 41 
import org.apache.thrift.transport.TTransportException;
38 
import org.slf4j.Logger;
 42 
import org.slf4j.Logger;
39 
import org.slf4j.LoggerFactory;
 43 
import org.slf4j.LoggerFactory;
40 
 
 44 
 
41 
import com.opensymphony.xwork2.ValidationAwareSupport;
 45 
import com.opensymphony.xwork2.ValidationAwareSupport;
42 
 
 46 
 
- 
 
 47 
@SuppressWarnings({"unused","deprecation"})
- 
 
 48 
 
- 
 
 49 
@InterceptorRefs({
- 
 
 50 
    @InterceptorRef("defaultStack"),
- 
 
 51 
    @InterceptorRef("login")
- 
 
 52 
})
- 
 
 53 
@Results({
- 
 
 54 
    @Result(name = "redirect", location = "${url}", type = "redirect"),
- 
 
 55 
    @Result(name="authsuccess", type="redirectAction", params = {"actionName" , "reports"})
- 
 
 56 
})
- 
 
 57 
 
43 
public class CompetitionScrapingController extends ValidationAwareSupport implements ServletRequestAware ,ServletResponseAware, ServletContextAware{
 58 
public class CompetitionScrapingController extends ValidationAwareSupport implements ServletRequestAware ,ServletResponseAware, ServletContextAware{
44 
 
 59 
 
45 
    /**
 60 
    /**
46 
     *
61 
     *
47 
     */
 62 
     */
Line 64... Line 79...
64
79
65
80
66 
    public String processItems() throws TException{
 81 
    public String processItems() throws TException{
67 
        long uploadId = getTimeInMilliseconds();
 82 
        long uploadId = getTimeInMilliseconds();
68 
        String userEmail = getUserEmail();
 83 
        String userEmail = getUserEmail();
69 
        for(int i=0;i<snapdeal.length;i++){
 - 
 
70 
            logger.info(itemId[i]);
 - 
 
71 
            logger.info(snapdeal[i]);
 - 
 
72 
        }
 - 
 
73 
        for(int i=0;i<flipkart.length;i++){
 - 
 
74 
            logger.info(itemId[i]);
 - 
 
75 
            logger.info(flipkart[i]);
 - 
 
76 
        }
 - 
 
77 
        for(int i=0;i<amazon.length;i++){
 - 
 
78 
            logger.info(itemId[i]);
 - 
 
79 
            logger.info(amazon[i]);
 - 
 
80 
        }
 - 
 
81 
        Map<Long,CompetitorPricing> itemScrapingMap = new HashMap<Long,CompetitorPricing>();
 84 
        Map<Long,CompetitorPricing> itemScrapingMap = new HashMap<Long,CompetitorPricing>();
82 
        for(int i=0;i<itemId.length;i++){
 85 
        for(int i=0;i<itemId.length;i++){
83 
            CompetitorPricing cp = new CompetitorPricing();
86 
            CompetitorPricing cp = new CompetitorPricing();
84 
            cp.setItem_id(Long.valueOf(itemId[i]));
 87 
            cp.setItem_id(Long.valueOf(itemId[i]));
85 
            cp.setUploadId(uploadId);
 88 
            cp.setUploadId(uploadId);
Line 93... Line 96...
93 
        cc.addCompetitorScraping(itemScrapingMap);
 96 
        cc.addCompetitorScraping(itemScrapingMap);
94 
        return getPreviousData();
 97 
        return getPreviousData();
95 
    }
 98 
    }
96 
 
 99 
 
97 
    public String index() throws TException{
 100 
    public String index() throws TException{
- 
 
 101 
        if (!ReportsUtils.canAccessReport((Long) session.getAttribute(ReportsUtils.ROLE),request.getServletPath())) {
- 
 
 102 
            return "authfail";
- 
 
 103 
        }
98 
        return "index";
 104 
        return "index";
99 
    }
 105 
    }
100
106
101 
    public String getUploadData() throws NumberFormatException, TException{
 107 
    public String getUploadData() throws NumberFormatException, TException{
- 
 
 108 
        if (!ReportsUtils.canAccessReport((Long) session.getAttribute(ReportsUtils.ROLE),request.getServletPath())) {
- 
 
 109 
            return "authfail";
- 
 
 110 
        }
102 
        Client cc = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
 111 
        Client cc = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient();
103 
        data = cc.getUploadResultById(Long.valueOf(this.requestId));
 112 
        data = cc.getUploadResultById(Long.valueOf(this.requestId));
104 
        return "show";
 113 
        return "show";
105 
    }
 114 
    }
106
115