WebSVN – SmartDukaan – Diff – //trunk/PyDTR/src/dtr/sources/spice.py

                 print response
                 response = json.loads(response)['response']
                 items = response['itemsMap']
                 orders = response['orders']
                 closed = True
+                splitSubOrdersMap={}
+                ordersToClone = {}
                 for order in orders:
                     print "orderid---", order['id']
                     orderId = str(order['id'])
                     subOrder = self._isSubOrderActive(tr, orderId)
+                    currentQty = int(order['lineitems'][0]['quantity'])
                     if subOrder:
                         if subOrder['closed']:
                             continue
                         else:
+                            quantity = int(subOrder['quantity'])
                             findMap = {"orderId": tr['orderId'], "subOrders.merchantSubOrderId": orderId}
                             updateMap = {}
                             updateMap["subOrders.$.detailedStatus"] = order['statusDescription']
                             status = self._getStatusFromDetailedStatus(ORDERSTATUS[order['status']])
                             closedStatus = status in [Store.ORDER_DELIVERED, Store.ORDER_CANCELLED]
                             print "status---", status, order['status']
                             updateMap["subOrders.$.status"] = status
+                            #Check if split
+                            if quantity != currentQty:
+                                updateMap["subOrders.$.quantity"] = currentQty
+                                updateMap["subOrders.$.amount"] = int((subOrder['amount']*currentQty)/quantity)
+                                updateMap["subOrders.$.cashBackAmount"] = int((subOrder['cashBackAmount']*currentQty)/quantity)
+                                updateMap["subOrders.$.amountPaid"] = int((subOrder['amountPaid']*currentQty)/quantity)
+                                splitSubOrdersMap[order['id']]=subOrder
                             if closedStatus:
                                 #if status is closed then change the paybackStatus accordingly
                                 updateMap["subOrders.$.closed"] = True
                                 if status == Store.ORDER_DELIVERED:
                                     deliveredOn = datetime.strftime(datetime.fromtimestamp(order['delivery_timestamp']/1000),"%A %d %B %Y")
                                 expectedDelivery = datetime.strftime(datetime.fromtimestamp(order['promised_delivery_time']/1000),"%A %d %B %Y")
                                 updateMap["subOrders.$.estimatedDeliveryDate"] = expectedDelivery
                                 closed = False
                             bulk.find(findMap).update({'$set' : updateMap})
                     else:
+                        if order['originalOrderId']:
+                            ordersToClone[order['id']] = order
+                        else:
-                        subOrder = self.createSubOrder(order, items)
+                            subOrder = self.createSubOrder(order, items)
-                        self.db.merchantOrder.update({"orderId":tr['orderId']},{'$push':{"subOrders":todict(subOrder)}})
+                            self.db.merchantOrder.update({"orderId":tr['orderId']},{'$push':{"subOrders":todict(subOrder)}})
-                        print "Added new suborder with subOrder Id:", subOrder.merchantSubOrderId
+                            print "Added new suborder with subOrder Id:", subOrder.merchantSubOrderId
+                            closed = False
+                for order in ordersToClone.values():
+                    originalOrderId = self.getOriginalOrderId(order['id'], ordersToClone, splitSubOrdersMap)
+                    subOrderToClone = splitSubOrdersMap[originalOrderId].copy()
+                    subOrderToClone["merchantSubOrderId"] = order['id']
+                    currentQty = int(order['lineitems'][0]['quantity'])
+                    quantity = int(subOrderToClone['quantity'])
+                    subOrderToClone["detailedStatus"] = order['statusDescription']
+                    status = self._getStatusFromDetailedStatus(ORDERSTATUS[order['status']])
+                    closedStatus = status in [Store.ORDER_DELIVERED, Store.ORDER_CANCELLED]
+                    print "status---", status, order['status']
+                    subOrderToClone["status"] = status
+                    subOrderToClone["quantity"] = currentQty
+                    subOrderToClone["amount"] = int((subOrderToClone['amount']*currentQty)/quantity)
+                    subOrderToClone["cashBackAmount"] = int((subOrderToClone['cashBackAmount']*currentQty)/quantity)
+                    subOrderToClone["amountPaid"] = int((subOrderToClone['amountPaid']*currentQty)/quantity)
+                    if closedStatus:
+                        #if status is closed then change the paybackStatus accordingly
+                        subOrderToClone["closed"] = True
+                        if status == Store.ORDER_DELIVERED:
+                            deliveredOn = datetime.strftime(datetime.fromtimestamp(order['delivery_timestamp']/1000),"%A %d %B %Y")
+                            subOrderToClone['deliveredOn'] = deliveredOn
+                            if subOrderToClone.get("cashBackStatus") == Store.CB_PENDING:
+                                subOrderToClone["cashBackStatus"] = Store.CB_APPROVED
+                        elif status == Store.ORDER_CANCELLED:
+                            if subOrderToClone.get("cashBackStatus") == Store.CB_PENDING:
+                                subOrderToClone["cashBackStatus"] = Store.CB_CANCELLED
+                    else:
+                        expectedDelivery = datetime.strftime(datetime.fromtimestamp(order['promised_delivery_time']/1000),"%A %d %B %Y")
+                        subOrderToClone["estimatedDeliveryDate"] = expectedDelivery
                         closed = False
+                    self.db.merchantOrder.update({"orderId":tr['orderId']},{'$push':{"subOrders":subOrderToClone}})
                 bulk.find({"orderId":tr['orderId']}).update({'$set' : {'closed':closed}})
             except:
                 traceback.print_exc()
         try:
             bulk.execute()
             traceback.print_exc()
+    def getOriginalOrderId(self, orderId, ordersToClone, splitSubOrdersMap):
+        if splitSubOrdersMap.has_key(orderId):
+            return orderId
+        else:
+            originalOrderId = ordersToClone[orderId]['originalOrderId']
+            return self.getOriginalOrderId(originalOrderId, ordersToClone, splitSubOrdersMap)
     def _saveToAffiliate(self, offers):
         if offers is None or len(offers)==0:
             print "no affiliate have been pushed"
             return
         collection = self.db.snapdealOrderAffiliateInfo
     return urllib.urlencode(parameters)
 def main():
     store = getStore(4)
-    #store.scrapeStoreOrders()
+    store.scrapeStoreOrders()
     #store._isSubOrderActive(8, "5970688907")
     #store.scrapeAffiliate()
-    store.parseOrderRawHtml(112345, "subtagId", 1122323,  "html", 'http://www.saholic.com/pay-success?paymentId=1798123')
+    #store.parseOrderRawHtml(112345, "subtagId", 1122323,  "html", 'http://www.saholic.com/pay-success?paymentId=1798123')
     #print store.getCashbackAmount('1011378', 500)
 if __name__ == '__main__':
     main()

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/sources/spice.py – Rev 18085 → 18254