Subversion Repositories SmartDukaan

Rev

Rev 20499 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
14364 kshitij.so 1 
package in.shop2020.dtrapi.controllers;
2 
 
3 
import java.util.List;
4 
 
5 
import org.apache.log4j.Logger;
6 
 
15272 kshitij.so 7 
import in.shop2020.dtrapi.Storage.Mongo;
8 
import in.shop2020.dtrapi.models.MasterData;
15183 kshitij.so 9 
import in.shop2020.dtrapi.services.UserMessagePojo;
14374 kshitij.so 10 
import in.shop2020.model.v1.dtr.DtrService.Client;
11 
import in.shop2020.thrift.clients.DtrClient;
14364 kshitij.so 12 
 
13 
import com.google.gson.Gson;
15272 kshitij.so 14 
import com.mongodb.DBObject;
14374 kshitij.so 15 
import com.mongodb.util.JSON;
14364 kshitij.so 16 
 
17 
 
18 
public class LivePricingController extends BaseController{
15183 kshitij.so 19 
	private static Logger log = Logger.getLogger(Class.class);
14374 kshitij.so 20 
 
15183 kshitij.so 21 
	private static final long serialVersionUID = 1L;
14374 kshitij.so 22 
 
15183 kshitij.so 23 
	private String skuBundleId;
24 
	private String source_id;
25 
	private String id;
26 
	private String url;
14385 kshitij.so 27 
 
15183 kshitij.so 28 
	public String index(){
29 
		Gson gs = new Gson();
15230 kshitij.so 30 
		DtrClient dc = null;
15183 kshitij.so 31 
		try {
15230 kshitij.so 32 
			dc = new DtrClient();
33 
			List<in.shop2020.model.v1.dtr.LivePricing> pricingObj = dc.getClient().getLatestPricing(Long.valueOf(skuBundleId), Long.valueOf(source_id));
15183 kshitij.so 34 
			setResultJson(JSON.parse(gs.toJson(pricingObj)).toString());
15230 kshitij.so 35 
 
15183 kshitij.so 36 
		} catch (Exception e) {
15238 kshitij.so 37 
			log.error("Error while get latest pricing",e);
15183 kshitij.so 38 
		}
15230 kshitij.so 39 
		finally{
40 
			dc.closeConnection();
41 
		}
15183 kshitij.so 42 
		return "index";
43 
	}
14364 kshitij.so 44 
 
15183 kshitij.so 45 
	public String latestPriceById(){
15184 kshitij.so 46 
		log.info("Inside lastestPriceById");
47 
		log.info("Id is "+id);
48 
		log.info("Source id "+source_id);
49 
		log.info("Encoded Url is "+url);
15230 kshitij.so 50 
 
51 
		DtrClient dc = null;
15186 kshitij.so 52 
		UserMessagePojo ump = new UserMessagePojo();
53 
		ump.setMessage("");
54 
		ump.setResult(false);
15183 kshitij.so 55 
		try {
15230 kshitij.so 56 
			dc = new DtrClient();
57 
			dc.getClient().updateLatestPriceForItem(Long.valueOf(id));
15183 kshitij.so 58 
			if (Long.valueOf(source_id) == 3){
59 
				SnapdealProductPageParserController spp = new SnapdealProductPageParserController();
60 
				spp.setUrl(url);
15272 kshitij.so 61 
				UserMessagePojo ump_color = spp.getColorMessage();
62 
				UserMessagePojo ump_seller = getSellerMessage(Long.valueOf(id));
63 
				ump.setResult(ump_color.isResult() || ump_seller.isResult());
64 
				ump.setMessage(ump_color.getMessage()+ump_seller.getMessage());
65 
				setResultJson(ump);
15183 kshitij.so 66 
			}
15272 kshitij.so 67 
			else if(Long.valueOf(source_id) == 2){
68 
				setResultJson(getSellerMessage(Long.valueOf(id)));
69 
			}
20499 kshitij.so 70 
			else if(Long.valueOf(source_id) == 1){
20500 kshitij.so 71 
				ump.setMessage("Amazon Prime customers are not eligible for cashbacks.");
20499 kshitij.so 72 
				ump.setResult(true);
73 
				setResultJson(ump);
74 
			}
15183 kshitij.so 75 
			else{
15186 kshitij.so 76 
				throw new Exception();
15183 kshitij.so 77 
			}
78 
		} catch (Exception e) {
15186 kshitij.so 79 
			setResultJson(ump);
15183 kshitij.so 80 
		}
15230 kshitij.so 81 
		finally{
82 
			dc.closeConnection();
83 
		}
15183 kshitij.so 84 
		return "index";
85 
	}
15272 kshitij.so 86 
 
87 
	private UserMessagePojo getSellerMessage(long item_id){
88 
		UserMessagePojo ump = new UserMessagePojo();
89 
		ump.setMessage("");
90 
		ump.setResult(false);
91 
		MasterData result;
92 
		try {
93 
			result = Mongo.getItemByID(item_id);
94 
		} catch (Exception e) {
95 
			return ump;
96 
		}
97 
		if (result.getBuyBoxFlag()==0){
98 
			ump.setResult(true);
99 
			ump.setMessage("Check all sellers to get this price");
100 
		}
101 
		return ump;
102 
	}
15183 kshitij.so 103 
 
104 
	public String getSkuBundleId() {
105 
		return skuBundleId;
106 
	}
107 
 
108 
	public void setSkuBundleId(String skuBundleId) {
109 
		this.skuBundleId = skuBundleId;
110 
	}
111 
 
112 
	public String getSource_id() {
113 
		return source_id;
114 
	}
115 
 
116 
	public void setSource_id(String source_id) {
117 
		this.source_id = source_id;
118 
	}
119 
 
15164 kshitij.so 120 
	public void setId(String id) {
121 
		this.id = id;
122 
	}
14374 kshitij.so 123 
 
15164 kshitij.so 124 
	public String getId() {
125 
		return id;
126 
	}
15183 kshitij.so 127 
 
128 
	public String getUrl() {
129 
		return url;
130 
	}
131 
 
132 
	public void setUrl(String url) {
133 
		this.url = url;
134 
	}
15233 kshitij.so 135 
 
15183 kshitij.so 136 
 
15164 kshitij.so 137 
	public static void main (String[] args){
138 
		LivePricingController live = new LivePricingController();
15272 kshitij.so 139 
		live.getSellerMessage(10000000);
15164 kshitij.so 140 
	}
15233 kshitij.so 141 
 
14364 kshitij.so 142 
}