WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py

 from shop2020.thriftpy.model.v1.order.ttypes import TransactionServiceException, \
     TransactionStatus, OrderStatus, DelayReason, ExtraTransactionProcessingType, \
     HotspotAction, TimeoutSummary, OrderStatusGroups, OrderType, RechargeOrderStatus, \
     RechargeType, RechargeStatistics, DeviceNumberInfo, EmiChargeType, PayMethod, OrderSource,\
     StorePaymentStatus, ProductCondition, TaxType
-from shop2020.thriftpy.model.v1.user.ttypes import VoucherType, CouponCategory
+from shop2020.thriftpy.model.v1.user.ttypes import VoucherType, CouponCategory, User, Sex
 from shop2020.thriftpy.payments.ttypes import PaymentException
 #Start:- Added By Manish Sharma for Creating a new Ticket: Category- RTO Refund on 21-Jun-2013
 from shop2020.thriftpy.crm.ttypes import *
 #End:- Added By Manish Sharma for Creating a new Ticket: Category- RTO Refund on 21-Jun-2013
 from shop2020.thriftpy.warehouse.ttypes import ScanType, \
 import sys
 import time
 import traceback
 import urllib
 import base64
+from _pydev_xmlrpclib import long
 logging.basicConfig(level=logging.DEBUG)
 sourceId = int(ConfigClient().get_property("sourceid"))
     snapdealOrder.listingPrice = t_snapdeal_order.listingPrice
     snapdealOrder.snapdealTxnDate = to_py_date(t_snapdeal_order.snapdealTxnDate)
     snapdealOrder.maxNlc = t_snapdeal_order.maxNlc
     order = Order.get_by(id=t_snapdeal_order.orderId)
     order.status = OrderStatus.ACCEPTED
+    user = None
+    try:
+        user_client = UserClient().get_client()
+        user_to_add = User()
+        user_to_add.email = 'SD.'+ t_snapdeal_order.orderId + '@mailinator.com'
+        user_to_add.password = 'hSp5gvCsrrhZcceE6mzzOQ'
+        user_to_add.communicationEmail = user.email
+        user_to_add.sourceStartTime = int(round(time.time() * 1000))
+        user_to_add.source = 'SNAPDEAL'
+        user_to_add.sex = Sex.WONT_SAY
+        user_to_add = user_client.createUser(user_to_add)
+        user = user_to_add
+    except:
+        pass
+    if user:
+        order.customer_id = user.userId
+        order.customer_email = user.email
     session.commit()
 def get_snapdeal_order(order_id, reference_code, subOrder_id):
     query = SnapdealOrder.query
     if order_id:
     order.octroiFee = flipkartorder.octroiFee
     order.emiFee = flipkartorder.emiFee
     order.maxNlc = flipkartorder.maxNlc
     s_order = Order.get_by(id=flipkartorder.orderId)
     s_order.status = OrderStatus.SUBMITTED_FOR_PROCESSING
+    user = None
+    try:
+        user_client = UserClient().get_client()
+        user_to_add = User()
+        user_to_add.email = 'FK.'+ flipkartorder.orderId + '@mailinator.com'
+        user_to_add.password = 'gR9zF-Ish2im6tbYFNivgA'
+        user_to_add.communicationEmail = user.email
+        user_to_add.sourceStartTime = int(round(time.time() * 1000))
+        user_to_add.source = 'FLIPKART'
+        user_to_add.sex = Sex.WONT_SAY
+        user_to_add = user_client.createUser(user_to_add)
+        user = user_to_add
+    except:
+        pass
+    if user:
+        s_order.customer_id = user.userId
+        s_order.customer_email = user.email
     session.commit()
 def get_flipkart_order(orderid):
     flipkartorder = FlipkartOrder.query.filter_by(orderId=orderid).first()
     if not flipkartorder:
         print item[1]
         item_ordercount[item[0]] = item[1]
     return item_ordercount
+def get_min_created_timestamp_undelivered_orders_for_source(source):
+    order = order = Order.query.filter(Order.source== OrderSource.SNAPDEAL).filter(Order.delivery_timestamp == None).limit(1).one()
+    print to_java_date(order.created_timestamp)
+    return to_java_date(order.created_timestamp)
+def update_snapdeal_orders_status(delivered_orders):
+    for del_order in delivered_orders:
+        ref_code = del_order[0]
+        sub_order_code = long(del_order[1])
+        dlvry_timestamp = del_order[2]
+        if snapdeal_order_exists(sub_order_code, ref_code):
+            snapdeal_order = get_snapdeal_order(None, ref_code, sub_order_code)
+            order = get_order(snapdeal_order.orderId)
+            order.delivery_timestamp = datetime.datetime.strptime(dlvry_timestamp, "%Y-%m-%d %H:%M:%S")
+            order.receiver = order.customer_name
+            order.status = OrderStatus.DELIVERY_SUCCESS
+            order.statusDescription = "Order delivered"
+            session.commit()
+def update_flipkart_orders_status(delivered_orders):
+    for del_order in delivered_orders:
+        flipkart_order_id = del_order[0]
+        sub_order_code = long(del_order[1])
+        dlvry_timestamp = del_order[2]
+        if flipkart_order_exists(flipkart_order_id,sub_order_code):
+            flipkart_order = get_flipkart_order_by_subOrderId(sub_order_code)
+            order = get_order(flipkart_order.orderId)
+            if order.status != OrderStatus.DELIVERY_SUCCESS:
+                order.delivery_timestamp = datetime.datetime.strptime(dlvry_timestamp, "%Y-%m-%d %H:%M:%S")
+                order.receiver = order.customer_name
+                order.status = OrderStatus.DELIVERY_SUCCESS
+                order.statusDescription = "Order delivered"
+                session.commit()
+    '''
+    order_ids = delivered_orders.keys()
+    for orderId in order_ids:
+        order = Order.query.filter(Order.id == orderId).first()
+        order.status = OrderStatus.DELIVERY_SUCCESS
+        order.statusDescription = "Order delivered"
+        order.delivery_timestamp = datetime.datetime.strptime(delivered_orders.get(orderId), "%Y-%m-%d %H:%M:%S")
+        session.commit()
+    '''
 if __name__ == '__main__':
     print get_orders_by_mobile_number("9650889334")

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/model/v1/order/impl/DataAccessors.py – Rev 9633 → 9651