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

     TransactionStatus, OrderStatus, DelayReason, ExtraTransactionProcessingType, \
     HotspotAction, TimeoutSummary, OrderStatusGroups, OrderType, RechargeOrderStatus, \
     RechargeType, RechargeStatistics, DeviceNumberInfo, EmiChargeType, PayMethod, \
     OrderSource, StorePaymentStatus, ProductCondition, TaxType, \
     AmazonFCWarehouseLocation
+#from shop2020.thriftpy.utils.ttypes import UserSmsInfo, SmsType
 from shop2020.thriftpy.model.v1.user.ttypes import VoucherType, CouponCategory, \
     User, Sex
 from shop2020.thriftpy.payments.ttypes import PaymentException
 from shop2020.thriftpy.warehouse.ttypes import ScanType, \
     WarehouseServiceException
     return diff - (non_business_days + sundays)
 def enqueue_transaction_info_email(transaction_id):
     transaction = get_transaction(transaction_id)
+    '''
+    smsText = "Thanks for ordering "
+    otgSms = False
+    mobileNo = None
+    customerId = 0
+    '''
     subject = source_name + " - Order Details"
     orders = transaction.orders
     advance_amount = orders[0].advanceAmount
     saddress = ""
     bcc = []
     otgLink = ""
     inOrderOtg = "<div>On Time Guarantee<br><span style=color:red>We pay if we delay</span></div>"
     if len(transaction.orders) == 1:
         inOrderOtg = ""
         if transaction.orders[0].otg :
+            #otgSms = True
             subject = "Your Order is confirmed with On Time Guarantee We Pay if we Delay"
             otgLink = ' Your Order is covered under the <a href="http://www.saholic.com/static/on-time-guarantee">On Time Guarantee, We pay If we Delay.</a>'
     customer_name = ""
     html_header = """
     if orders[0].pickupStoreId:
         random_text = str(randrange(100000, 999999))
     first = True
     for order in orders:
+        '''mobileNo = order.customer_mobilenumber
+        customerId = order.customer_id
+        '''
         customer_name = order.customer_name
         order_date = order.created_timestamp
         user_email = order.customer_email
         if first:
             first = False
             attribute.name = "SECRET_CODE"
             attribute.value = random_text
             session.commit()
         for lineitem in order.lineitems:
+            #smsText = smsText + lineitem.brand + " " + lineitem.model_name + " " + lineitem.model_number + "("+str(lineitem.quantity)+ ")" +" "
             lineitem_total_price = round(lineitem.total_price, 2)
             html_tr += "<td>" + str(lineitem) + "</td>"
             if order.otg:
                 html_tr += "<td align='center'><div>" + store_delivery_date + "</div>" + inOrderOtg + "</td>"
             html_tr += "<td align='center'>" + ("%.0f" % lineitem.quantity) + "</td>"
             html_tr += "<td align='center'> Rs. " + ("%.2f" % lineitem.unit_price) + "</td>"
             html_tr += "<td align='center'> Rs. " + ("%.2f" % lineitem_total_price) + "</td></tr>"
             total_amount += lineitem_total_price
             html_table += html_tr
+        #smsText = smsText + "Order Id: "+str(order.id)+" "
         if order.freebieItemId:
             catalog_client = CatalogClient().get_client()
             item = catalog_client.getItem(order.freebieItemId)
             html_table += "<tr><td align='center'></td><td style='font-style:italic;' colspan='5'> Free Item: "+item.brand + " " + item.modelName + " " + item.modelNumber+"</td></tr>"
         if order.insurer:
             html_table += "<tr><td colspan=6>&nbsp;</td></tr>"
             html_table += "<tr><td align='center'></td><td style='font-style:italic;'>Insured Against Theft for 1 Year. <a href='http://www.saholic.com/static/insurance-terms'>Know More</a></td><td align='center'></td><td align='center'></td><td align='center'></td>"
             html_table += "<td align='center'>" + str(order.insuranceAmount) + "</td></tr>"
             total_amount += order.insuranceAmount
+    #smsText = smsText + "Saholic.com"
     emi_amount = 0
     miscCharges = get_misc_charges(transaction_id)
     if miscCharges.get(1):
         emi_amount = miscCharges.get(1)
         return True
     except Exception as e:
         print e
         return False
+    '''
+    if otgSms:
+        smsText = smsText +" On Time Guarantee We Pay if we Delay. T&C Apply"
+    try:
+        helper_client = HelperClient().get_client()
+        helper_client.saveUserEmailForSending([user_email], "", subject, email_header + html_table + email_footer, str(transaction_id), "TransactionInfo", [], bcc, orders[0].source)
+    except Exception as e:
+        print e
+        try:
+            send_transaction_sms(customerId, mobileNo, smsText, SmsType.TRANSACTIONAL)
+            return True
+        except Exception as e:
+            print e
+            print sys.exc_info()[0]
+            return False
+    try:
+        send_transaction_sms(customerId, mobileNo, smsText, SmsType.TRANSACTIONAL)
+        return True
+    except Exception as e:
+        print e
+        print sys.exc_info()[0]
+        return True
+    '''
+def send_transaction_sms(customerId, mobileNo, smsText, smsType):
+    if mobileNo is not None:
+            helper_client = HelperClient().get_client()
+            helper_client.saveUserSmsForSending(customerId, mobileNo, smsText, SmsType.TRANSACTIONAL)
+            userSmsInfo = helper_client.getUserSmsInfo(customerId);
+            if userSmsInfo and mobileNo == userSmsInfo.mobileNo:
+                userSmsInfo.dailyCount = userSmsInfo.dailyCount +1
+                userSmsInfo.weeklyCount = userSmsInfo.weeklyCount +1
+                helper_client.updateUserSmsInfo(userSmsInfo)
+            elif userSmsInfo and mobileNo != userSmsInfo.mobileNo:
+                userSmsInfo.updateTimestamp = to_java_date(datetime.datetime.now())
+                userSmsInfo.mobileNo = mobileNo
+                userSmsInfo.dailyCount = 1
+                userSmsInfo.weeklyCount = 1
+                helper_client.updateUserSmsInfo(userSmsInfo)
+            else:
+                userSmsInfo = UserSmsInfo()
+                userSmsInfo.userId = customerId
+                userSmsInfo.mobileNo = mobileNo
+                userSmsInfo.createdTimestamp = to_java_date(datetime.datetime.now())
+                userSmsInfo.updateTimestamp = to_java_date(datetime.datetime.now())
+                helper_client.addUserSmsInfo(userSmsInfo);
 def enqueue_received_at_store_email(order):
     html_header = """
     <html>
     <body>
     email_footer = Template(html_footer).substitute(dict(total_amount = "%.2f" % total_amount, source_name = source_name, freebie_text = freebie_text))
     try:
         helper_client = HelperClient(host_key = "helper_service_server_host_prod").get_client()
         helper_client.saveUserEmailForSending([user_email], "", subject, email_header + html_table + email_footer, str(order.id), "DeliverySuccess", [], [], order.source)
+        '''
+        if order.source == OrderSource.WEBSITE:
+            send_transaction_sms(order.customer_id, order.customer_mobilenumber, "Dear "+ order.customer_name +", Your order: " + str(order.id) + " has been delivered now. For any queries please call 0120-2479977." , SmsType.TRANSACTIONAL)
+        '''
         return True
     except Exception as e:
         print e
         return False
             raise TransactionServiceException(110,'Parent order for this is COD and is still undelivered')
 #    inventoryClient = InventoryClient().get_client()
 #    if not inventoryClient.isOrderBillable(item_id, order.fulfilmentWarehouseId, sourceId, orderId):
 #        raise TransactionServiceException(101, "There are other orders to be billed before this order id " + str(orderId))
+    singleInvoiceAttr = Attribute.query.filter(Attribute.orderId == order.id).filter(Attribute.name == "Single Invoice").first()
     catalog_client = CatalogClient().get_client()
     item = catalog_client.getItem(item_id)
     if order.status == OrderStatus.ACCEPTED:
         order.jacket_number = jacketNumber
         if order.source == 6:
         if order.source == 7:
             order.jacket_number = "700"+str(orderId)
         if order.source == 8:
             order.jacket_number = "800"+str(orderId)
         if itemNumbers:
             lineitem.item_number = itemNumbers[0]
+        if singleInvoiceAttr:
+            if singleInvoiceAttr.value == "true":
+                if serialNumbers:
+                    finalSerialNo =''
+                    for serialNumber in serialNumbers:
+                        finalSerialNo = finalSerialNo +','+ serialNumber
+                    finalSerialNo = finalSerialNo[1:]
+                    if lineitem.serial_number is None:
+                        lineitem.serial_number = finalSerialNo
+                    else:
+                        lineitem.serial_number = lineitem.serial_number + ',' + finalSerialNo
+        else:
-        if serialNumbers:
+            if serialNumbers:
-            lineitem.serial_number = serialNumbers[0]
+                lineitem.serial_number = serialNumbers[0]
         '''
         if billingType == BillingType.EXTERNAL or billingType == BillingType.OURS_EXTERNAL:
             if billedOrdersColorMap.has_key(orderId):
                 etpColor = billedOrdersColorMap.get(orderId)
             order.invoice_number = invoice_number
         if billingType == BillingType.OURS or billingType == BillingType.OURS_EXTERNAL:
             if ItemType.SERIALIZED == item.type and not (serialNumbers and serialNumbers[0]):
                 raise TransactionServiceException(110, "No Serial Number supplied")
+            if singleInvoiceAttr:
+                if singleInvoiceAttr.value == "true":
+                    if serialNumbers:
+                        finalSerialNo =''
+                        for serialNumber in serialNumbers:
+                            finalSerialNo = finalSerialNo +','+ serialNumber
+                        finalSerialNo = finalSerialNo[1:]
+                        if lineitem.serial_number is None:
+                            lineitem.serial_number = finalSerialNo
+            else:
-            if serialNumbers:
+                if serialNumbers:
-                lineitem.serial_number = serialNumbers[0]
+                    lineitem.serial_number = serialNumbers[0]
         order.status = OrderStatus.BILLED
         order.statusDescription = "Order Billed"
         order.billing_timestamp = datetime.datetime.now()
                 print e.message
                 raise TransactionServiceException(110,'Error in billing freebie for warehouseId ' + str(freebieWarehouseId))
         if order.productCondition != ProductCondition.BAD:
             __update_inventory_reservation(order)
         order.fulfilmentWarehouseId = warehouse.id
+        if singleInvoiceAttr:
+            if singleInvoiceAttr.value == "true":
+                session.commit()
+                return True
         if billingType == BillingType.OURS or billingType == BillingType.OURS_EXTERNAL:
             order.invoice_number = get_next_invoice_number(order.orderType)
         session.commit()
         return True
     else:
     helperClient = HelperClient(host_key = "helper_service_server_host_prod").get_client()
     try:
         emailSubject = 'Shipping Details for Order ID: ' + str(order.id)
         emailBody = get_shipping_confirmation_email_body(order)
         helperClient.saveUserEmailForSending([order.customer_email], None, emailSubject, emailBody, str(order.id), 'ShippingConfirmation', [], [], order.source)
+        '''
+        logistics_providers = {1: {'name': 'BlueDart', 'phone': '011-66111234'}, 6: {'name': 'RedExpress', 'phone': '8373915813'}, 3: {'name': 'Delhivery', 'phone' : '0124- 4212200'}, 7: {'name': 'FedEx', 'phone' : '0120-4354176'}}
+        provider_name = logistics_providers[order.logistics_provider_id]['name']
+        if order.source == OrderSource.WEBSITE :
+            send_transaction_sms(order.customer_id, order.customer_mobilenumber, "Dear "+ order.customer_name +", We have shipped your order: " + str(order.id) + " through "+provider_name + " AWB No. " + order.airwaybill_no, SmsType.TRANSACTIONAL)
+        '''
     except Exception as e:
         print e
 def get_order_distribution_by_status(start_date, end_date):
     query = session.query(Order.status, func.count(Order.id)).group_by(Order.status)
     FailureReasonMap = {}
     FailureReasonMap["Invalid Amount"] = "the amount you tried seems to be invalid. Please try another amount."
     FailureReasonMap["Customer Exceeded Daily Limit"] = "you have exceeded daily recharge limit for this number. Please try after 12 hours."
     FailureReasonMap["Invalid Device Number"] = "it seems that your device number is not being recognized by selected operator. Please make sure the number you tried is correct."
+    '''
+    FailureReasonMapSms = {}
+    FailureReasonMapSms["Invalid Amount"] = " invalid amount."
+    FailureReasonMapSms["Customer Exceeded Daily Limit"] = " daily limit exceeded. Please try after 12Hrs"
+    FailureReasonMapSms["Invalid Device Number"] = " invalid device number."
+    '''
     failureReason = FailureReasonMap.get(recharge_order.description)
+    '''
+    failureReasonSms = FailureReasonMapSms.get(recharge_order.description)
+    if failureReasonSms is None:
+        failureReasonSms = " network failure."
+    '''
     if failureReason is None:
         failureReason = "of network failure."
     if recharge_order.status == RechargeOrderStatus.RECHARGE_SUCCESSFUL:
         status = "Recharge Successful"
         message = ""
     formated_order_date = dt.strftime("%A, %d. %B %Y %I:%M%p")
     email_header = Template(html_header).substitute(dict(order_id = display_order_id, order_date = formated_order_date, email = email, source_url = source_url, order_amount = recharge_order.totalAmount, order_status = status, device_number = deviceNumber, service_provider = providerName, failureReason = failureReason))
     email_footer = Template(html_footer).substitute(dict(source_url = source_url, source_name = source_name))
+    '''
+    if isinstance(recharge_order, MobileRechargeOrder):
+        smsText = ""
+        if status == "Recharge Failed" and recharge_order.description == "Invalid Device Number" :
+            print "Do send Sms"
+        elif status == "Recharge Failed" and recharge_order.description != "Invalid Device Number" :
+            smsText = "Dear Customer, We could not process your recharge due to" + failureReasonSms + " We have credited the amount to your recharge wallet. You can use wallet amount to recharge again. "
+        elif status == "Recharge Successful" :
+            smsText = "Thanks for recharging your mobile for Rs. "+ str(recharge_order.totalAmount) + " from Saholic.com. Order Id is "+ display_order_id + ". Any Query? please call 0120-2479977"
+        elif status == "Recharge Under Process" :
+            smsText = "Dear Customer, Your Payment was successful but due to some internal error with the operator's system we are not sure if the recharge was successful. In case your recharge is not processed, we will credit amount to your recharge wallet. You can use wallet amount to recharge again."
+        elif status == "Recharge Failed, Amount Refunded" :
+            smsText = "Dear Customer, It seems operator could not process your recharge request. We are crediting the refund amount to your recharge wallet. You can use wallet amount to recharge again."
+        try:
+            send_transaction_sms(recharge_order.userId, deviceNumber, smsText, SmsType.TRANSACTIONAL)
+        except Exception as e:
+            print e
+            try:
+                helper_client = HelperClient().get_client()
+                helper_client.saveUserEmailForSending([email], "", source_name + " - Recharge Order Details", email_header + email_footer, str(recharge_order.id), "RechargeInfo", [], [], 1)
+                return True
+            except Exception as e:
+                print e
+                return False
+    '''
     try:
         helper_client = HelperClient().get_client()
         helper_client.saveUserEmailForSending([email], "", source_name + " - Recharge Order Details", email_header + email_footer, str(recharge_order.id), "RechargeInfo", [], [], 1)
         return True
     except Exception as e:
     s_order = Order.get_by(id=flipkartorder.orderId)
     if s_order.cod:
         s_order.status = OrderStatus.COD_VERIFICATION_PENDING
     else:
         s_order.status = OrderStatus.ACCEPTED
+        s_order.accepted_timetsmap = datetime.datetime.now()
     user = None
     try:
         user_client = UserClient().get_client()
         user_to_add = User()
         user_to_add.email = 'FK.'+ str(flipkartorder.orderId) + '@mailinator.com'
             order_ids.append(order.id)
         retFkOrders = FlipkartOrder.query.filter(FlipkartOrder.orderId.in_(tuple(order_ids)))
         if not retFkOrders:
             retFkOrders = []
     return retFkOrders
+def add_invoice_details_to_orders(transactionId, customerId):
+    orders = Order.query.filter_by(transaction_id=transactionId, customer_id=customerId).all()
+    if not orders:
+        raise TransactionServiceException(101, "No order for the transaction Unable to Print Invoice")
+    else:
+        invoiceNo = get_next_invoice_number(orders[0].orderType)
+        for order in orders:
+            order.invoice_number = invoiceNo
+            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 12619 → 12653