Subversion Repositories SmartDukaan

Rev

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

Rev 17166 Rev 17234
Line 101... Line 101...
101
            fileobj = open(filename,"wb")
101
            fileobj = open(filename,"wb")
102
            fileobj.write(utils.ungzipResponse(br.open(reportUrl)))
102
            fileobj.write(utils.ungzipResponse(br.open(reportUrl)))
103
            fileobj.close()
103
            fileobj.close()
104
            with open(filename, 'rb') as csvfile:
104
            with open(filename, 'rb') as csvfile:
105
                reader = csv.reader(csvfile)
105
                reader = csv.reader(csvfile)
106
                self._saveToAffiliate(reader)
106
                self._saveToAffiliate(reader, status)
107
    
107
    
108
    def _setLastSaleDate(self, saleDate):
108
    def _setLastSaleDate(self, saleDate):
109
        self.db.lastSaleDtate.update({'storeId':self.store_id}, {'$set':{'saleDate':saleDate}})
109
        self.db.lastSaleDtate.update({'storeId':self.store_id}, {'$set':{'saleDate':saleDate}})
110
    
110
    
111
        
111
        
Line 621... Line 621...
621
        bulk.find({'orderId': order['orderId']}).update({'$set':{'closed': closed,"parseError":False}})
621
        bulk.find({'orderId': order['orderId']}).update({'$set':{'closed': closed,"parseError":False}})
622
        result = bulk.execute()
622
        result = bulk.execute()
623
        tprint(result)
623
        tprint(result)
624
 
624
 
625
    
625
    
626
    def _saveToAffiliate(self, offers):
626
    def _saveToAffiliate(self, offers, status):
627
        collection = self.db.snapdealOrderAffiliateInfo1
627
        collection = self.db.snapdealOrderAffiliateInfo1
628
        #mcollection = self.db.merchantOrder
628
        #mcollection = self.db.merchantOrder
629
        for offer in offers:
629
        for offer in offers:
630
            count = 0
630
            count = 0
631
            for row in offers:
631
            for row in offers:
Line 634... Line 634...
634
                    continue
634
                    continue
635
                offer = self.covertToObj(row)
635
                offer = self.covertToObj(row)
636
                if offer.orderId:
636
                if offer.orderId:
637
                    dict1 = todict(offer)
637
                    dict1 = todict(offer)
638
                    dict1["_id"] = dict1["orderId"] + "-" + dict1["productCode"]
638
                    dict1["_id"] = dict1["orderId"] + "-" + dict1["productCode"]
-
 
639
                    dict1['status'] = status
639
                    collection.save(dict1)
640
                    collection.save(dict1)
640
#    def _saveToAffiliate(self, offers):
641
#    def _saveToAffiliate(self, offers):
641
#        collection = self.db.snapdealOrderAffiliateInfo
642
#        collection = self.db.snapdealOrderAffiliateInfo
642
#        mcollection = self.db.merchantOrder
643
#        mcollection = self.db.merchantOrder
643
#        for offer in offers:
644
#        for offer in offers: