Subversion Repositories SmartDukaan

Rev

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

Rev 14206 Rev 14207
Line 67... Line 67...
67 
            return {'_id':data['_id'],'available_price':lowestPrice,'in_stock':inStock,'source_id':1,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
 67 
            return {'_id':data['_id'],'available_price':lowestPrice,'in_stock':inStock,'source_id':1,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
68 
        except:
 68 
        except:
69 
            return {'_id':data['_id'],'available_price':data['available_price'],'in_stock':data['in_stock'],'source_id':1,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
 69 
            return {'_id':data['_id'],'available_price':data['available_price'],'in_stock':data['in_stock'],'source_id':1,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
70
70
71 
    elif source_id ==4:
 71 
    elif source_id ==4:
- 
 
 72
- 
 
 73 
        if data['identifier'] is None or len(data['identifier'].strip())==0:
- 
 
 74 
            return {}
- 
 
 75
72 
        try:
 76 
        try:
73 
            if data['identifier'] is None or len(data['identifier'].strip())==0:
 - 
 
74 
                return {}
 - 
 
75
- 
 
76 
            try:
 - 
 
77 
                if data['priceUpdatedOn'] > to_java_date(now - timedelta(minutes=5)):
 77 
            if data['priceUpdatedOn'] > to_java_date(now - timedelta(minutes=5)):
78 
                    print "sku id is already updated",data['_id']
78 
                print "sku id is already updated",data['_id']
79 
                    return {'_id':data['_id'],'available_price':data['available_price'],'in_stock':data['in_stock'],'source_id':4,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
 79 
                return {'_id':data['_id'],'available_price':data['available_price'],'in_stock':data['in_stock'],'source_id':4,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
80 
            except:
 80 
        except:
81 
                pass
 81 
            pass
82
- 
 
83 
            url = "http://109.74.200.220:8080/mobileapi/dtr-pricing?id=%s"%(data['identifier'])
 - 
 
84 
            lowestPrice = 0.0
 - 
 
85 
            instock = 0
 - 
 
86 
            req = urllib2.Request(url,headers=headers)
 - 
 
87 
            response = urllib2.urlopen(req)
 - 
 
88 
            print response.read()
 - 
 
89 
            response.close()
 - 
 
90 
            json_input = response.read()
 - 
 
91 
            priceInfo = json.loads(json_input)
 - 
 
92 
            print priceInfo
 - 
 
93 
            lowestPrice = priceInfo['response']['sellingPrice']
 - 
 
94 
            print "*****"
 - 
 
95 
            print lowestPrice
 - 
 
96 
            print instock
 - 
 
97 
            if lowestPrice > 0:
 - 
 
98 
                instock = 1
 - 
 
99 
            if instock  == 1:
 - 
 
100 
                get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice,'updatedOn':to_java_date(now),'priceUpdatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)
 - 
 
101 
                get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice , 'in_stock':inStock}}, multi=True)
 - 
 
102 
            else:
 - 
 
103 
                lowestPrice = data['available_price']
 - 
 
104 
                get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock,'priceUpdatedOn':to_java_date(now)}}, multi=True)
 - 
 
105 
                get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)
 - 
 
106
- 
 
107 
            try:
- 
 
108 
                recomputeDeal(data['skuBundleId'])
 - 
 
109 
            except:
 - 
 
110 
                print "Unable to compute deal for ",data['skuBundleId']
 - 
 
111
- 
 
112 
            return {'_id':data['_id'],'available_price':lowestPrice,'in_stock':inStock,'source_id':4,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
 - 
 
113 
        except Exception as e:
 - 
 
114 
            print e
 - 
 
115 
            return {'_id':data['_id'],'available_price':data['available_price'],'in_stock':data['in_stock'],'source_id':4,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
 - 
 
116
82
- 
 
 83 
        url = "http://109.74.200.220:8080/mobileapi/dtr-pricing?id=%s"%(data['identifier'])
- 
 
 84 
        lowestPrice = 0.0
117
85 
        instock = 0
- 
 
 86 
        req = urllib2.Request(url,headers=headers)
- 
 
 87 
        response = urllib2.urlopen(req)
- 
 
 88 
        response.close()
- 
 
 89 
        json_input = response.read()
- 
 
 90 
        priceInfo = json.loads(json_input)
- 
 
 91 
        print priceInfo
- 
 
 92 
        lowestPrice = priceInfo['response']['sellingPrice']
- 
 
 93 
        print "*****"
- 
 
 94 
        print lowestPrice
- 
 
 95 
        print instock
- 
 
 96 
        if lowestPrice > 0:
118
97 
            instock = 1
- 
 
 98 
        if instock  == 1:
- 
 
 99 
            get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice,'updatedOn':to_java_date(now),'priceUpdatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)
- 
 
 100 
            get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice , 'in_stock':inStock}}, multi=True)
119
101 
        else:
- 
 
 102 
            lowestPrice = data['available_price']
- 
 
 103 
            get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock,'priceUpdatedOn':to_java_date(now)}}, multi=True)
- 
 
 104 
            get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)
120
105
- 
 
 106 
        try:
- 
 
 107 
            recomputeDeal(data['skuBundleId'])
- 
 
 108 
        except:
- 
 
 109 
            print "Unable to compute deal for ",data['skuBundleId']
- 
 
 110
- 
 
 111 
        return {'_id':data['_id'],'available_price':lowestPrice,'in_stock':inStock,'source_id':4,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
121
112
122 
    elif source_id ==3:
 113 
    elif source_id ==3:
123 
        try:
 114 
        try:
124 
            if data['identifier'] is None or len(data['identifier'].strip())==0:
 115 
            if data['identifier'] is None or len(data['identifier'].strip())==0:
125 
                return {}
 116 
                return {}