Subversion Repositories SmartDukaan

Rev

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

Rev 14985 Rev 15046
Line 84... Line 84...
84 
                        if soup.h1.text.strip() in ['This is a duplicate order', 'There was a problem with your payment.']:
 84 
                        if soup.h1.text.strip() in ['This is a duplicate order', 'There was a problem with your payment.']:
85 
                            resp['result'] = 'ORDER_NOT_CREATED_KNOWN'
 85 
                            resp['result'] = 'ORDER_NOT_CREATED_KNOWN'
86 
                        else:
 86 
                        else:
87 
                            raise
 87 
                            raise
88 
                    except:
 88 
                    except:
- 
 
 89 
                        try:
89 
                        if soup.h2.text.strip() == 'Web page not available':
 90 
                            if soup.h2.text.strip() == 'Web page not available':
90 
                            resp['result'] = 'ORDER_NOT_CREATED_KNOWN'
 91 
                                resp['result'] = 'ORDER_NOT_CREATED_KNOWN'
91 
            return resp
 92 
                            else:
- 
 
 93 
                                raise
92
94 
                        except:
- 
 
 95 
                            resp['result'] = 'ORDER_NOT_CREATED_UNKNOWN'
93 
        else:
 96 
        else:
94 
            try:
 97 
            try:
95 
                mo = self.db.merchantOrder.find_one({"orderId":orderId})
 98 
                mo = self.db.merchantOrder.find_one({"orderId":orderId})
96 
                if mo is not None:
 99 
                if mo is not None:
97 
                    merchantOrder = Order(orderId, userId, subTagId, self.store_id, orderSuccessUrl, False)
 100 
                    merchantOrder = Order(orderId, userId, subTagId, self.store_id, orderSuccessUrl, False)
Line 101... Line 104...
101 
                    print "Could not find amazon order with order Id", orderId
 104 
                    print "Could not find amazon order with order Id", orderId
102 
                    merchantOrder = Order(orderId, userId, subTagId, self.store_id, orderSuccessUrl)
 105 
                    merchantOrder = Order(orderId, userId, subTagId, self.store_id, orderSuccessUrl)
103 
                soup = BeautifulSoup(rawHtml)
 106 
                soup = BeautifulSoup(rawHtml)
104 
                try:
 107 
                try:
105 
                    self.parseNewStlye(merchantOrder, soup)
 108 
                    self.parseNewStlye(merchantOrder, soup)
- 
 
 109 
                    resp['result'] = 'DETAIL_CREATED'
106 
                except:
 110 
                except:
107 
                    try:
 111 
                    try:
108 
                        traceback.print_exc()
 112 
                        traceback.print_exc()
109 
                        self.parseOldStlye(merchantOrder, soup)
 113 
                        self.parseOldStlye(merchantOrder, soup)
- 
 
 114 
                        resp['result'] = 'DETAIL_CREATED'
110 
                    except:
 115 
                    except:
111 
                        traceback.print_exc()
 116 
                        traceback.print_exc()
112 
                        self.parseCancelled(merchantOrder, soup)
 117 
                        self.parseCancelled(merchantOrder, soup)
113 
                resp['result'] = 'ORDER_CANCELLED'
 118 
                        resp['result'] = 'ORDER_CANCELLED'
114 
                return resp
- 
 
115 
            except:
 119 
            except:
116 
                order = self.db.merchantOrder.find_one({"orderId":orderId})
 120 
                order = self.db.merchantOrder.find_one({"orderId":orderId})
117 
                if order is not None:
 121 
                if order is not None:
118 
                    self.db.merchantOrder.update({"orderId":orderId}, {"$set":{"status":"parse_failed"}})
 122 
                    self.db.merchantOrder.update({"orderId":orderId}, {"$set":{"status":"parse_failed"}})
119 
                print "Error occurred"
 123 
                print "Error occurred"
120 
                resp['result'] = 'DETAIL_NOT_CREATED'
 124 
                resp['result'] = 'DETAIL_NOT_CREATED_UNKNOWN'
121 
                traceback.print_exc()
 125 
                traceback.print_exc()
122 
            return resp
126 
        return resp
123
127
124 
    #This should be exposed from api for specific sources
 128 
    #This should be exposed from api for specific sources
125 
    def scrapeStoreOrders(self):
 129 
    def scrapeStoreOrders(self):
126 
        orders = self.db.merchantOrder.find({"storeId":1, "closed":False, "subOrders.closed":False, "subOrders.trackingUrl":{"$exists":True}})
 130 
        orders = self.db.merchantOrder.find({"storeId":1, "closed":False, "subOrders.closed":False, "subOrders.trackingUrl":{"$exists":True}})
127 
        for merchantOrder in orders:
 131 
        for merchantOrder in orders:
Line 547... Line 551...
547
551
548
552
549 
 
 553 
 
550 
 
 554 
 
551 
def main():
 555 
def main():
552 
    #readSSh("orderSummary24-04:22:22:15")
 556 
    readSSh("/jd/Kolkata/1")
553 
    readSSh("/tmp/User2/404-2225153-7073122")
 557 
    #readSSh("/tmp/User2/404-2225153-7073122")
554
558
555 
    #store = getStore(1)
 559 
    #store = getStore(1)
556 
    #store.scrapeStoreOrders()
 560 
    #store.scrapeStoreOrders()
557 
#    br = mechanize.Browser()
 561 
#    br = mechanize.Browser()
558 
#    br.addheaders = [('User-agent','Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/535.11 (KHTML, like Gecko) Chrome/17.0.963.56 Safari/535.11'),
 562 
#    br.addheaders = [('User-agent','Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/535.11 (KHTML, like Gecko) Chrome/17.0.963.56 Safari/535.11'),
Line 565... Line 569...
565 
    #store.trackOrdersForUser(94, "https://www.amazon.in/gp/css/order-history", readSSh("/tmp/User94/orderSummary24-04:08:07:34"))
 569 
    #store.trackOrdersForUser(94, "https://www.amazon.in/gp/css/order-history", readSSh("/tmp/User94/orderSummary24-04:08:07:34"))
566 
    #readSSh("/tmp/User211/2015-04-12 10:32:41.905765")
 570 
    #readSSh("/tmp/User211/2015-04-12 10:32:41.905765")
567 
    #store.scrapeAffiliate()
 571 
    #store.scrapeAffiliate()
568 
def readSSh(fileName):
 572 
def readSSh(fileName):
569 
    try:
 573 
    try:
570 
            str1 = open(fileName).read()
 574 
        str1 = open(fileName).read()
571 
            return str1
 575 
        return str1
572 
    except:
 576 
    except:
573 
        ssh_client = SSHClient()
 577 
        ssh_client = SSHClient()
574 
        str1 = ""
 578 
        str1 = ""
575 
        ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
 579 
        ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
576 
        ssh_client.connect('104.200.25.40', 22, 'root', 'ecip$dtrMay2014')
 580 
        ssh_client.connect('45.33.50.227', 22, 'root', 'ecip$db1May2014')
577 
        sftp_client = ssh_client.open_sftp()
 581 
        sftp_client = ssh_client.open_sftp()
578 
        try:
 582 
        try:
579 
            if not os.path.exists(os.path.dirname(fileName)):
 583 
            if not os.path.exists(os.path.dirname(fileName)):
580 
                os.makedirs(os.path.dirname(fileName))
 584 
                os.makedirs(os.path.dirname(fileName))
581 
            sftp_client.get(fileName, fileName)
 585 
            sftp_client.get(fileName, fileName)