Subversion Repositories SmartDukaan

Rev

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

Rev 14266 Rev 14267
Line 143... Line 143...
143
                subOrders.append(self.createSubOrder(o, items))
143
                subOrders.append(self.createSubOrder(o, items))
144
            merchantOrder.subOrders = subOrders
144
            merchantOrder.subOrders = subOrders
145
            merchantOrder.placedOn = merchantOrder.subOrders[0].placedOn
145
            merchantOrder.placedOn = merchantOrder.subOrders[0].placedOn
146
            s = todict(merchantOrder)
146
            s = todict(merchantOrder)
147
            s['sUserId'] = orders[0]['customer_id']
147
            s['sUserId'] = orders[0]['customer_id']
148
            self._saveToOrder(s)
148
            if self._saveToOrder(s):
149
            resp['result'] = 'ORDER_CREATED'
149
                resp['result'] = 'ORDER_CREATED'
-
 
150
            else:
-
 
151
                #Order already created
-
 
152
                resp['result'] = 'PARSE_ERROR'
150
        except:
153
        except:
151
            traceback.print_exc()
154
            traceback.print_exc()
152
            resp['result'] = 'PARSE_ERROR'
155
            resp['result'] = 'PARSE_ERROR'
153
        return resp
156
        return resp
154
    
157
    
Line 187... Line 190...
187
        raise ParseException("_getStatusFromDetailedStatus", "Found new order status" + detailedStatus)
190
        raise ParseException("_getStatusFromDetailedStatus", "Found new order status" + detailedStatus)
188
    
191
    
189
    
192
    
190
    def scrapeStoreOrders(self,):
193
    def scrapeStoreOrders(self,):
191
        trs = self._getActiveOrders()
194
        trs = self._getActiveOrders()
-
 
195
        bulk = self.db.merchantOrder.initialize_ordered_bulk_op()
192
        for tr in trs:
196
        for tr in trs:
193
            bulk = self.db.merchantOrder.initialize_ordered_bulk_op()
-
 
194
            try:
197
            try:
195
                orderRequest = urllib2.Request(SAHOLIC_ORDER_URL_TR %(tr['merchantOrderId'], tr['sUserId']), headers=headers)
198
                orderRequest = urllib2.Request(SAHOLIC_ORDER_URL_TR %(tr['merchantOrderId'], tr['sUserId']), headers=headers)
196
                response = urllib2.urlopen(orderRequest).read()
199
                response = urllib2.urlopen(orderRequest).read()
197
                response = json.loads(response)['response']
200
                response = json.loads(response)['response']
198
                items = response['itemsMap']
201
                items = response['itemsMap']
Line 232... Line 235...
232
                        print "Added new suborder with subOrder Id:", subOrder.merchantSubOrderId
235
                        print "Added new suborder with subOrder Id:", subOrder.merchantSubOrderId
233
                        closed = False
236
                        closed = False
234
                bulk.find({"order":order['id']}).update({'$set' : {'closed':closed}})
237
                bulk.find({"order":order['id']}).update({'$set' : {'closed':closed}})
235
            except:
238
            except:
236
                pass
239
                pass
-
 
240
            try:
-
 
241
                bulk.execute()
-
 
242
            except:
-
 
243
                pass
237
                        
244
                        
238
                
245
                
239
                    
246
                    
240
    
247
    
241
    def _saveToAffiliate(self, offers):
248
    def _saveToAffiliate(self, offers):