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
}