Subversion Repositories SmartDukaan

Rev

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

Rev 19932 Rev 20172
Line 196... Line 196...
196 
            subOrder.cashBackAmount = cashbackAmount*subOrder.quantity
 196 
            subOrder.cashBackAmount = cashbackAmount*subOrder.quantity
197 
            if percentage > 0:
 197 
            if percentage > 0:
198 
                subOrder.cashBackPercentage = percentage
 198 
                subOrder.cashBackPercentage = percentage
199 
            return subOrder
 199 
            return subOrder
200 
    def _getStatusFromDetailedStatus(self, detailedStatus):
 200 
    def _getStatusFromDetailedStatus(self, detailedStatus):
- 
 
 201 
        print str(detailedStatus)
201 
        for key, value in Store.OrderStatusMap.iteritems():
 202 
        for key, value in Store.OrderStatusMap.iteritems():
202 
            if detailedStatus in value:
 203 
            if detailedStatus in value:
203 
                return key
 204 
                return key
204 
        print "Detailed Status need to be mapped", detailedStatus
 205 
        print "Detailed Status need to be mapped", detailedStatus
205 
        raise ParseException("_getStatusFromDetailedStatus", "Found new order status" + str(detailedStatus))
 206 
        raise ParseException("_getStatusFromDetailedStatus", "Found new order status" + str(detailedStatus))
Line 208... Line 209...
208 
    def scrapeStoreOrders(self,):
 209 
    def scrapeStoreOrders(self,):
209 
        trs = self._getActiveOrders(collectionMap={'merchantOrderId':1, 'sUserId':1, 'userId':1})
 210 
        trs = self._getActiveOrders(collectionMap={'merchantOrderId':1, 'sUserId':1, 'userId':1})
210 
        bulk = self.db.merchantOrder.initialize_ordered_bulk_op()
 211 
        bulk = self.db.merchantOrder.initialize_ordered_bulk_op()
211 
        for tr in trs:
 212 
        for tr in trs:
212 
            self.userId = tr['userId']
 213 
            self.userId = tr['userId']
- 
 
 214 
            orderRequest = urllib2.Request(SAHOLIC_ORDER_URL_TR %(tr['merchantOrderId'], tr['sUserId']), headers=headers)
213 
            try:
 215 
            try:
214 
                orderRequest = urllib2.Request(SAHOLIC_ORDER_URL_TR %(tr['merchantOrderId'], tr['sUserId']), headers=headers)
 - 
 
215 
                response = urllib2.urlopen(orderRequest).read()
 216 
                response = urllib2.urlopen(orderRequest).read()
216 
                print "transaction_id----------", tr['merchantOrderId']
 217 
                print "transaction_id----------", tr['merchantOrderId']
217 
                response = json.loads(response)['response']
 218 
                response = json.loads(response)['response']
218 
                items = response['itemsMap']
 219 
                items = response['itemsMap']
219 
                orders = response['orders']
 220 
                orders = response['orders']
Line 302... Line 303...
302 
                    self.db.merchantOrder.update({"orderId":tr['orderId']},{'$push':{"subOrders":subOrderToClone}})
 303 
                    self.db.merchantOrder.update({"orderId":tr['orderId']},{'$push':{"subOrders":subOrderToClone}})
303
304
304
305
305 
                bulk.find({"orderId":tr['orderId']}).update({'$set' : {'closed':closed}})
 306 
                bulk.find({"orderId":tr['orderId']}).update({'$set' : {'closed':closed}})
306 
            except:
 307 
            except:
- 
 
 308 
                print "something went wrong for request", orderRequest
307 
                traceback.print_exc()
 309 
                traceback.print_exc()
308 
        try:
 310 
        try:
309 
            bulk.execute()
 311 
            bulk.execute()
310 
        except:
 312 
        except:
- 
 
 313 
            print "Could not execute bulk"
311 
            traceback.print_exc()
 314 
            traceback.print_exc()
312
315
313
316
314
317
315
318