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

 from shop2020.thriftpy.logistics.ttypes import DeliveryType
 from shop2020.thriftpy.model.v1.catalog.ttypes import BillingType, \
     InventoryServiceException
 from shop2020.thriftpy.model.v1.order.ttypes import TransactionServiceException, \
     TransactionStatus, OrderStatus, DelayReason, ExtraTransactionProcessingType, \
-    HotspotAction, TimeoutSummary
+    HotspotAction, TimeoutSummary, OrderStatusGroups
 from shop2020.thriftpy.payments.ttypes import PaymentException
 from shop2020.thriftpy.purchase.ttypes import PurchaseOrder, LineItem as POLineItem
 from shop2020.thriftpy.warehouse.ttypes import ScanType, WarehouseServiceException
 from shop2020.utils.EmailAttachmentSender import mail, get_attachment_part
 from shop2020.utils.Utils import to_py_date, to_java_date
     return order_ids
 def get_cancellable_orders_for_customer(customer_id, limit = None):
     if not customer_id:
         raise TransactionServiceException(101, "bad customer id")
+    cancellableOrderStatuses = OrderStatusGroups().codCancellable
     query = Order.query.filter(Order.customer_id == customer_id)
-    query = query.filter(Order.status != OrderStatus.PAYMENT_FAILED)
-    query = query.filter(Order.status != OrderStatus.REJECTED)
-    query = query.filter(Order.status <= OrderStatus.BILLED)
+    query = query.filter(Order.status.in_(cancellableOrderStatuses))
     orders = query.all()
     return [order.id for order in orders]
 def get_orders_by_billing_date(status, start_billing_date, end_billing_date, warehouse_id):
     if not warehouse_id:
             order.status = OrderStatus.RET_PICKUP_REQUEST_RAISED
             order.statusDescription = "Pick up requested for RETURN"
         else:
             order.status = OrderStatus.DOA_PICKUP_REQUEST_RAISED
             order.statusDescription = "Pick up requested for DOA"
+        order.doa_logistics_provider_id = providerId
         session.commit()
         return True
     except Exception as e:
         print sys.exc_info()[0]
         return False
 def authorize_pickup(order_id, pickup_number, providerId):
     order = get_order(order_id)
     if order.status not in [OrderStatus.DOA_PICKUP_REQUEST_RAISED, OrderStatus.RET_PICKUP_REQUEST_RAISED]:
         return False
+    if order.doa_logistics_provider_id is not None:
+        providerId = order.doa_logistics_provider_id    #previously we are not storing this so data is taken from omdashboarduser
     from_user = 'help@shop2020.in'
     from_pwd = '5h0p2o2o'
     subject = 'Pickup details'
     filename = "/tmp/" +  str(order.id) +".pdf"
     try:
         today = date.today().strftime("%d-%B-%Y (%A)")
         raw_message = '''
         Dear Mr. %(customer_name)s,
-        In reference to the return of order ID %(order_id)d. We request you to kindly pack the box properly with bubble wrap, and send it along with the original "DOA" certificate (in case of DOA) and the invoice.
+        In reference to the return of order ID %(order_id)d, ''' + __generate_mail_body_for_authorize_pickup(order)
+        raw_message = raw_message + '''
         Take a printout of the attachment in this mail which contains the delivery address and paste it on the packed parcel.
         We have instructed %(provider_name)s to pick up the material from the below mentioned address on %(date)s. %(provider_name)s pickup request number is %(pickup_request_no)s. Kindly keep the parcel ready.
         Pickup will happen from the below mentioned address:-
         return False
     finally:
         if os.path.exists(filename):
             os.remove(filename)
+def __generate_mail_body_for_authorize_pickup(order):
+    brand_msgbody_map = {'Nokia' : 'we request you to kindly pack the box properly with bubble wrap, and send it along with the all original accessories, original handset and the invoice.',
+                         'Micromax' : 'we request you to kindly pack the box properly with bubble wrap, and send it along with the all original accessories, original handset and the invoice.',
+                         'Karbonn' : 'we request you to kindly pack the box properly with bubble wrap, and send it along with the all original accessories, original handset and the invoice.',
+                         'Sony Ericsson' : 'we request you to kindly pack the original DOA certificate and the invoice.',
+                         'Others Handsets' : 'we request you to kindly pack the box properly with bubble wrap, and send it along with the original "DOA" certificate and the invoice. Please paste the original DOA on the sealed box. Kindly ensure that the product is properly sealed. If we receive open sealed products, we will not be able to accept.',
+                         'Handsets Return' : 'we request you to kindly pack the box properly with bubble wrap, and send it along with the all original accessories, original handset and the invoice.',
+                         'Accessories' : 'we request you to kindly pack the box properly with bubble wrap, and send it along with the original product and the invoice.'}
+    categories = ["Handsets", "Tablets", "Laptops"]
+    lineitem = order.lineitems[0]
+    brand = lineitem.brand
+    productGroup = lineitem.productGroup
+    searchkey = None
+    if productGroup not in categories:
+        searchkey = 'Accessories'
+    elif order.status == OrderStatus.RET_PICKUP_REQUEST_RAISED:
+        searchkey = 'Handsets Return'
+    elif brand == 'Nokia':
+        searchkey = 'Nokia'
+    elif brand == 'Micromax':
+        searchkey = 'Micromax'
+    elif brand == 'Karbonn':
+        searchkey = 'Karbonn'
+    elif brand == 'Sony Ericsson':
+        searchkey = 'Sony Ericsson'
+    else:
+        searchkey = 'Others Handsets'
+    return brand_msgbody_map.get(searchkey)
 def mark_doas_as_picked_up(provider_id, pickup_details):
     for pickupNo, doa_pickup_timestamp in pickup_details.iteritems():
-        order = Order.query.filter_by(pickupRequestNo=pickupNo, logistics_provider_id = provider_id).first()
+        order = Order.query.filter_by(pickupRequestNo=pickupNo, doa_logistics_provider_id = provider_id).first()
         if order == None or order.status != OrderStatus.DOA_PICKUP_CONFIRMED:
             #raise TransactionServiceException(102, "No order found for the awb: " + awb)
             continue
         order.status = OrderStatus.DOA_RETURN_IN_TRANSIT
         order.statusDescription = "DOA picked up by Courier Company"
         order.doa_pickup_timestamp = doa_pickup_timestamp
     session.commit()
     current_time = datetime.datetime.now()
     to_datetime = datetime.datetime(current_time.year, current_time.month, current_time.day)
-    orders_not_picked_up = Order.query.filter_by(logistics_provider_id = provider_id).filter_by(status=OrderStatus.DOA_PICKUP_CONFIRMED).filter(Order.doa_auth_timestamp <= to_datetime).all()
+    orders_not_picked_up = Order.query.filter_by(doa_logistics_provider_id = provider_id).filter_by(status=OrderStatus.DOA_PICKUP_CONFIRMED).filter(Order.doa_auth_timestamp <= to_datetime).all()
     return orders_not_picked_up
 def mark_return_orders_as_picked_up(provider_id, pickup_details):
     for pickupNo, return_order_pickup_timestamp in pickup_details.iteritems():
-        order = Order.query.filter_by(pickupRequestNo=pickupNo, logistics_provider_id = provider_id).first()
+        order = Order.query.filter_by(pickupRequestNo=pickupNo, doa_logistics_provider_id = provider_id).first()
         if order == None or order.status != OrderStatus.RET_PICKUP_CONFIRMED:
             #raise TransactionServiceException(102, "No order found for the awb: " + awb)
             continue
         order.status = OrderStatus.RET_RETURN_IN_TRANSIT
         order.statusDescription = "Return order picked up by Courier Company"
         order.doa_pickup_timestamp = return_order_pickup_timestamp
     session.commit()
     current_time = datetime.datetime.now()
     to_datetime = datetime.datetime(current_time.year, current_time.month, current_time.day)
-    orders_not_picked_up = Order.query.filter_by(logistics_provider_id = provider_id).filter_by(status=OrderStatus.RET_PICKUP_CONFIRMED).filter(Order.doa_auth_timestamp <= to_datetime).all()
+    orders_not_picked_up = Order.query.filter_by(doa_logistics_provider_id = provider_id).filter_by(status=OrderStatus.RET_PICKUP_CONFIRMED).filter(Order.doa_auth_timestamp <= to_datetime).all()
     return orders_not_picked_up
 def receive_return(order_id, receiveCondition):
     order = get_order(order_id)
     address = address + order.customer_state + "\n"
     address = address + "PIN " + order.customer_pincode + "\n"
     address = address + "Phone: " + order.customer_mobilenumber
     return address
 def __generate_return_advice(order, warehouse, provider, filename):
+    if warehouse.id == 7:
+        executive = 'Amit Kumar'
+        executive_phone = 'Phone: 9911122634'
+    else:
+        executive = 'Prashant Sharma'
+        executive_phone = 'Phone: 8826894193'
     pdf = Canvas(filename)
     pdf.setFont('Times-Bold',16)
     address_text = pdf.beginText(inch, PAGE_HEIGHT - inch)
     address_text.textLine("To")
-    address_text.textLine("Parmod Kumar")
+    address_text.textLine(executive)
     for line in warehouse.location.split("\n"):
         address_text.textLine(line)
     address_text.textLine("PIN " + warehouse.pincode)
     address_text.textLine("")
-    address_text.textLine("Phone: 9971573026")
+    address_text.textLine(executive_phone)
     pdf.drawText(address_text)
     pdf.setFont('Times-Roman',12)
     order_text = pdf.beginText(inch, PAGE_HEIGHT - 4 * inch)
     order_text.textLine("Pickup CODE: " + provider.details[DeliveryType.PREPAID].accountNo)
     return order
 def get_orders_for_provider_for_status(provider_id, order_status):
     if not provider_id or not order_status:
         raise TransactionServiceException(101, "bad provider id or order status")
+    if order_status in [OrderStatus.DOA_PICKUP_CONFIRMED, OrderStatus.RET_PICKUP_CONFIRMED]:
+        query = Order.query.filter_by(doa_logistics_provider_id = provider_id, status = order_status)
+    else:
-    query = Order.query.filter_by(logistics_provider_id = provider_id, status = order_status)
+        query = Order.query.filter_by(logistics_provider_id = provider_id, status = order_status)
     return query.all()
 def get_billed_orders_for_vendor(vendor_id, billing_date_from, billing_date_to):
     query = Order.query.filter_by(vendorId = vendor_id)
     query = query.filter(Order.status != OrderStatus.PAYMENT_PENDING)

Subversion Repositories SmartDukaan

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