Subversion Repositories SmartDukaan

Rev

Rev 14398 | Rev 14482 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
13572 kshitij.so 1 
import json
13582 amit.gupta 2 
from dtr import main
13629 kshitij.so 3 
from dtr.storage import Mongo
4 
from bson import json_util
13827 kshitij.so 5 
import falcon
14046 kshitij.so 6 
from dtr.utils import FetchLivePrices, DealSheet as X_DealSheet, \
7 
UserSpecificDeals
13572 kshitij.so 8 
 
9 
 
10 
class CategoryDiscountInfo(object):
11 
 
12 
    def on_get(self, req, resp):
13 
 
13629 kshitij.so 14 
        result = Mongo.getAllCategoryDiscount()
15 
        json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
16 
        resp.body = json.dumps(json_docs, encoding='utf-8')
13572 kshitij.so 17 
 
18 
    def on_post(self, req, resp):
19 
        try:
20 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
21 
        except ValueError:
22 
            raise falcon.HTTPError(falcon.HTTP_400,
23 
                'Malformed JSON',
24 
                'Could not decode the request body. The '
25 
                'JSON was incorrect.')
26 
 
27 
        result = Mongo.addCategoryDiscount(result_json)
28 
        resp.body = json.dumps(result, encoding='utf-8')
13969 kshitij.so 29 
 
30 
    def on_put(self, req, resp, _id):
13970 kshitij.so 31 
        try:
32 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
33 
        except ValueError:
34 
            raise falcon.HTTPError(falcon.HTTP_400,
35 
                'Malformed JSON',
36 
                'Could not decode the request body. The '
37 
                'JSON was incorrect.')
38 
 
39 
        result = Mongo.updateCategoryDiscount(result_json, _id)
40 
        resp.body = json.dumps(result, encoding='utf-8')
41 
 
13966 kshitij.so 42 
 
13969 kshitij.so 43 
 
13572 kshitij.so 44 
class SkuSchemeDetails(object):
45 
 
46 
    def on_get(self, req, resp):
13629 kshitij.so 47 
 
14070 kshitij.so 48 
        offset = req.get_param_as_int("offset")
49 
        limit = req.get_param_as_int("limit")
50 
 
51 
        result = Mongo.getAllSkuWiseSchemeDetails(offset, limit)
13629 kshitij.so 52 
        json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
53 
        resp.body = json.dumps(json_docs, encoding='utf-8')
13572 kshitij.so 54 
 
55 
 
56 
    def on_post(self, req, resp):
57 
 
58 
        try:
59 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
60 
        except ValueError:
61 
            raise falcon.HTTPError(falcon.HTTP_400,
62 
                'Malformed JSON',
63 
                'Could not decode the request body. The '
64 
                'JSON was incorrect.')
65 
 
66 
        result = Mongo.addSchemeDetailsForSku(result_json)
67 
        resp.body = json.dumps(result, encoding='utf-8')
68 
 
69 
class SkuDiscountInfo():
70 
 
71 
    def on_get(self, req, resp):
13629 kshitij.so 72 
 
13970 kshitij.so 73 
        offset = req.get_param_as_int("offset")
74 
        limit = req.get_param_as_int("limit")
75 
        result = Mongo.getallSkuDiscountInfo(offset,limit)
13629 kshitij.so 76 
        json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
77 
        resp.body = json.dumps(json_docs, encoding='utf-8')
13572 kshitij.so 78 
 
79 
 
80 
    def on_post(self, req, resp):
81 
 
82 
        try:
83 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
84 
        except ValueError:
85 
            raise falcon.HTTPError(falcon.HTTP_400,
86 
                'Malformed JSON',
87 
                'Could not decode the request body. The '
88 
                'JSON was incorrect.')
89 
 
90 
        result = Mongo.addSkuDiscountInfo(result_json)
91 
        resp.body = json.dumps(result, encoding='utf-8')
13970 kshitij.so 92 
 
93 
    def on_put(self, req, resp, _id):
94 
        try:
95 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
96 
        except ValueError:
97 
            raise falcon.HTTPError(falcon.HTTP_400,
98 
                'Malformed JSON',
99 
                'Could not decode the request body. The '
100 
                'JSON was incorrect.')
101 
 
102 
        result = Mongo.updateSkuDiscount(result_json, _id)
103 
        resp.body = json.dumps(result, encoding='utf-8')
13572 kshitij.so 104 
 
105 
class ExceptionalNlc():
106 
 
107 
    def on_get(self, req, resp):
13629 kshitij.so 108 
 
13970 kshitij.so 109 
        offset = req.get_param_as_int("offset")
110 
        limit = req.get_param_as_int("limit")
111 
 
112 
        result = Mongo.getAllExceptionlNlcItems(offset, limit)
13629 kshitij.so 113 
        json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
114 
        resp.body = json.dumps(json_docs, encoding='utf-8')
13572 kshitij.so 115 
 
116 
    def on_post(self, req, resp):
117 
 
118 
        try:
119 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
120 
        except ValueError:
121 
            raise falcon.HTTPError(falcon.HTTP_400,
122 
                'Malformed JSON',
123 
                'Could not decode the request body. The '
124 
                'JSON was incorrect.')
125 
 
126 
        result = Mongo.addExceptionalNlc(result_json)
127 
        resp.body = json.dumps(result, encoding='utf-8')
13970 kshitij.so 128 
 
129 
    def on_put(self, req, resp, _id):
130 
        try:
131 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
132 
        except ValueError:
133 
            raise falcon.HTTPError(falcon.HTTP_400,
134 
                'Malformed JSON',
135 
                'Could not decode the request body. The '
136 
                'JSON was incorrect.')
137 
 
138 
        result = Mongo.updateExceptionalNlc(result_json, _id)
139 
        resp.body = json.dumps(result, encoding='utf-8')
13572 kshitij.so 140 
 
13772 kshitij.so 141 
class Deals():
13779 kshitij.so 142 
    def on_get(self,req, resp, userId):
143 
        categoryId = req.get_param_as_int("categoryId")
144 
        offset = req.get_param_as_int("offset")
145 
        limit = req.get_param_as_int("limit")
13798 kshitij.so 146 
        sort = req.get_param("sort")
13802 kshitij.so 147 
        direction = req.get_param_as_int("direction")
14106 kshitij.so 148 
        result = Mongo.getNewDeals(int(userId), categoryId, offset, limit, sort, direction)
13772 kshitij.so 149 
        json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
13966 kshitij.so 150 
        resp.body = json.dumps(json_docs, encoding='utf-8')
13790 kshitij.so 151 
 
152 
class MasterData():
153 
    def on_get(self,req, resp, skuId):
154 
        result = Mongo.getItem(skuId)
13798 kshitij.so 155 
        try:
156 
            json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
13966 kshitij.so 157 
            resp.body = json.dumps(json_docs, encoding='utf-8')
13798 kshitij.so 158 
        except:
159 
            json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
13966 kshitij.so 160 
            resp.body = json.dumps(json_docs, encoding='utf-8')
13790 kshitij.so 161 
 
13827 kshitij.so 162 
class LiveData():
163 
    def on_get(self,req, resp):
13865 kshitij.so 164 
        if req.get_param_as_int("id") is not None:
165 
            print "****getting only for id"
166 
            id = req.get_param_as_int("id")
167 
            try:
168 
                result = FetchLivePrices.getLatestPriceById(id)
13867 kshitij.so 169 
                json_docs = json.dumps(result, default=json_util.default)
13966 kshitij.so 170 
                resp.body = json.dumps(json_docs, encoding='utf-8')
13865 kshitij.so 171 
            except:
172 
                json_docs = json.dumps({}, default=json_util.default)
13966 kshitij.so 173 
                resp.body = json.dumps(json_docs, encoding='utf-8')
13834 kshitij.so 174 
 
13865 kshitij.so 175 
        else:
176 
            print "****getting only for skuId"
177 
            skuBundleId = req.get_param_as_int("skuBundleId")
178 
            source_id = req.get_param_as_int("source_id")
179 
            try:
180 
                result = FetchLivePrices.getLatestPrice(skuBundleId, source_id)
181 
                json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
13966 kshitij.so 182 
                resp.body = json.dumps(json_docs, encoding='utf-8')
13865 kshitij.so 183 
            except:
184 
                json_docs = [json.dumps(doc, default=json_util.default) for doc in [{}]]
13966 kshitij.so 185 
                resp.body = json.dumps(json_docs, encoding='utf-8')
13865 kshitij.so 186 
 
13834 kshitij.so 187 
class CashBack():
188 
    def on_get(self,req, resp):
189 
        identifier = req.get_param("identifier")
190 
        source_id = req.get_param_as_int("source_id")
191 
        try:
13838 kshitij.so 192 
            result = Mongo.getCashBackDetails(identifier, source_id)
13837 kshitij.so 193 
            json_docs = json.dumps(result, default=json_util.default)
13964 kshitij.so 194 
            resp.body = json_docs
13834 kshitij.so 195 
        except:
13837 kshitij.so 196 
            json_docs = json.dumps({}, default=json_util.default)
13963 kshitij.so 197 
            resp.body = json_docs
13892 kshitij.so 198 
 
14398 amit.gupta 199 
class ImgSrc():
200 
    def on_get(self,req, resp):
201 
        identifier = req.get_param("identifier")
202 
        source_id = req.get_param_as_int("source_id")
203 
        try:
204 
            result = Mongo.getImgSrc(identifier, source_id)
205 
            json_docs = json.dumps(result, default=json_util.default)
206 
            resp.body = json_docs
207 
        except:
208 
            json_docs = json.dumps({}, default=json_util.default)
209 
            resp.body = json_docs
210 
 
13892 kshitij.so 211 
class DealSheet():
212 
    def on_get(self,req, resp):
13895 kshitij.so 213 
        X_DealSheet.sendMail()
13897 kshitij.so 214 
        json_docs = json.dumps({'True':'Sheet generated, mail sent.'}, default=json_util.default)
13966 kshitij.so 215 
        resp.body = json.dumps(json_docs, encoding='utf-8')
13892 kshitij.so 216 
 
13970 kshitij.so 217 
class DealerPrice():
218 
 
219 
    def on_get(self, req, resp):
220 
 
221 
        offset = req.get_param_as_int("offset")
222 
        limit = req.get_param_as_int("limit")
223 
        result = Mongo.getAllDealerPrices(offset,limit)
224 
        json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
225 
        resp.body = json.dumps(json_docs, encoding='utf-8')
226 
 
227 
    def on_post(self, req, resp):
228 
 
229 
        try:
230 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
231 
        except ValueError:
232 
            raise falcon.HTTPError(falcon.HTTP_400,
233 
                'Malformed JSON',
234 
                'Could not decode the request body. The '
235 
                'JSON was incorrect.')
236 
 
237 
        result = Mongo.addSkuDealerPrice(result_json)
238 
        resp.body = json.dumps(result, encoding='utf-8')
239 
 
240 
    def on_put(self, req, resp, _id):
241 
        try:
242 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
243 
        except ValueError:
244 
            raise falcon.HTTPError(falcon.HTTP_400,
245 
                'Malformed JSON',
246 
                'Could not decode the request body. The '
247 
                'JSON was incorrect.')
248 
 
249 
        result = Mongo.updateSkuDealerPrice(result_json, _id)
250 
        resp.body = json.dumps(result, encoding='utf-8')
251 
 
252 
 
14041 kshitij.so 253 
class ResetCache():
254 
 
255 
    def on_get(self,req, resp, userId):
14044 kshitij.so 256 
        result = Mongo.resetCache(userId)
14046 kshitij.so 257 
        resp.body = json.dumps(result, encoding='utf-8')
258 
 
259 
class UserDeals():
260 
    def on_get(self,req,resp,userId):
261 
        UserSpecificDeals.generateSheet(userId)
262 
        json_docs = json.dumps({'True':'Sheet generated, mail sent.'}, default=json_util.default)
263 
        resp.body = json.dumps(json_docs, encoding='utf-8')
14075 kshitij.so 264 
 
265 
class CommonUpdate():
266 
 
267 
    def on_post(self,req,resp):
268 
        try:
269 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
270 
        except ValueError:
271 
            raise falcon.HTTPError(falcon.HTTP_400,
272 
                'Malformed JSON',
273 
                'Could not decode the request body. The '
274 
                'JSON was incorrect.')
275 
 
276 
        result = Mongo.updateCollection(result_json)
277 
        resp.body = json.dumps(result, encoding='utf-8')
14106 kshitij.so 278 
        resp.content_type = "application/json; charset=utf-8"
14481 kshitij.so 279 
 
280 
class NegativeDeals():
281 
 
282 
    def on_get(self, req, resp):
283 
 
284 
        offset = req.get_param_as_int("offset")
285 
        limit = req.get_param_as_int("limit")
286 
 
287 
        result = Mongo.getAllNegativeDeals(offset, limit)
288 
        json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
289 
        resp.body = json_docs
290 
 
291 
 
292 
    def on_post(self, req, resp):
293 
 
294 
        try:
295 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
296 
        except ValueError:
297 
            raise falcon.HTTPError(falcon.HTTP_400,
298 
                'Malformed JSON',
299 
                'Could not decode the request body. The '
300 
                'JSON was incorrect.')
301 
 
302 
        result = Mongo.addNegativeDeals(result_json)
303 
        resp.body = json.dumps(result, encoding='utf-8')
304 
 
305 
class ManualDeals():
306 
 
307 
    def on_get(self, req, resp):
308 
 
309 
        offset = req.get_param_as_int("offset")
310 
        limit = req.get_param_as_int("limit")
311 
 
312 
        result = Mongo.getAllManualDeals(offset, limit)
313 
        json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
314 
        resp.body = json_docs
315 
 
316 
 
317 
    def on_post(self, req, resp):
318 
 
319 
        try:
320 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
321 
        except ValueError:
322 
            raise falcon.HTTPError(falcon.HTTP_400,
323 
                'Malformed JSON',
324 
                'Could not decode the request body. The '
325 
                'JSON was incorrect.')
326 
 
327 
        result = Mongo.addManualDeals(result_json)
328 
        resp.body = json.dumps(result, encoding='utf-8')
329 
 
330 
class CommonDelete():
331 
    def on_post(self,req,resp):
332 
        try:
333 
            result_json = json.loads(req.stream.read(), encoding='utf-8')
334 
        except ValueError:
335 
            raise falcon.HTTPError(falcon.HTTP_400,
336 
                'Malformed JSON',
337 
                'Could not decode the request body. The '
338 
                'JSON was incorrect.')
339 
 
340 
        result = Mongo.deleteDocument(result_json)
341 
        resp.body = json.dumps(result, encoding='utf-8')
342 
        resp.content_type = "application/json; charset=utf-8"