WebSVN – SmartDukaan – Diff – //trunk/PyDTR/src/dtr/api/Service.py

 from dtr.storage.DataService import Retailers, Users, CallHistory, RetryConfig, \
     RetailerLinks, Activation_Codes, Agents, Agent_Roles, AgentLoginTimings, \
     FetchDataHistory, RetailerContacts, Orders, OnboardedRetailerChecklists,\
     RetailerAddresses, Pincodeavailability, app_offers, appmasters, user_app_cashbacks, user_app_installs,\
     Postoffices, UserCrmCallingData, CallHistoryCrm, ProductPricingInputs,\
-    tinxys_stats
+    tinxys_stats, profitmandi_sms
 from dtr.storage.Mongo import get_mongo_connection
 from dtr.storage.Mysql import fetchResult
 from dtr.utils import DealSheet as X_DealSheet, \
     UserSpecificDeals, utils, ThriftUtils
 from dtr.utils.utils import getLogger,encryptMessage,decryptMessage,\
 DEALER_RETRY_FACTOR = int(PythonPropertyReader.getConfig('DEALER_RETRY_FACTOR'))
 DEALER_FRESH_FACTOR = int(PythonPropertyReader.getConfig('DEALER_FRESH_FACTOR'))
 USER_CRM_DEFAULT_RETRY_FACTOR = int(PythonPropertyReader.getConfig('USER_CRM_DEFAULT_RETRY_FACTOR'))
 USER_CRM_DEFAULT_FRESH_FACTOR = int(PythonPropertyReader.getConfig('USER_CRM_DEFAULT_FRESH_FACTOR'))
 TOTAL = DEALER_RETRY_FACTOR + DEALER_FRESH_FACTOR
 TOTAL_USER = USER_CRM_DEFAULT_FRESH_FACTOR + USER_CRM_DEFAULT_RETRY_FACTOR
+TRANSACTIONAL_SMS_SEND_URL = "http://103.15.179.45:8085/SMSGateway/sendingSMS?"
+smsText = "Dear Customer, Download Profitmandi application only for you my friend"
 class CategoryDiscountInfo(object):
     def on_get(self, req, resp):
         result = Mongo.getAllCategoryDiscount()
                 customerFeedbackBackMap['mobile_number']=user.mobile_number
                 customerFeedbackBackMap['customer_name']=user.first_name + ' ' + user.last_name
                 customerFeedbackBackMap['subject'] = req.get_param("subject")
                 customerFeedbackBackMap['message'] = req.get_param("message")
                 customerFeedbackBackMap['created'] = datetime.now()
-                if utils.generateCrmTicket(customerFeedbackBackMap):
+                if ThriftUtils.generateCrmTicket(customerFeedbackBackMap):
                     resp.body={"result":"success"}
                 else:
                     resp.body={"result":"failure"}
             else:
                 resp.body={"result":"failure"}
 class HeaderLinks():
     def on_get(self, req, resp):
         category_id = req.get_param_as_int('category_id')
         result = Mongo.getHeaderLinks(category_id)
         resp.body = dumps(result)
+class SendTransactionalSms():
+    def on_post(self,req,resp,sms_type,identifier,agentId):
+        if sms_type =='code':
+            otherMobileNumber = req.get_param('mobile_number')
+            if otherMobileNumber is None or str(otherMobileNumber).strip() is '':
+                retailerContact = session.query(RetailerContacts).filter_by(retailer_id=identifier).filter(RetailerContacts.contact_type=='sms').order_by(RetailerContacts.created.desc()).first()
+                if retailerContact is not None:
+                    if retailerContact.mobile_number is not None and len(retailerContact.mobile_number)==10:
+                        smsStatus = generateSms(identifier,retailerContact.mobile_number,agentId)
+                        if smsStatus:
+                            resp.body = "{\"result\":\"success\"}"
+                        else:
+                            resp.body = "{\"result\":\"failed\"}"
+                    else:
+                        print 'Not a valid number to send the message to '+str(retailerContact.mobile_number)
+                        resp.body = "{\"result\":\"failed\"}"
+                else:
+                    print 'No number to send the message for retailer id '+str(identifier)
+                    resp.body = "{\"result\":\"failed\"}"
+            else:
+                if len(str(otherMobileNumber).strip())==10:
+                    smsStatus = generateSms(identifier,str(otherMobileNumber).strip(),agentId)
+                    if smsStatus:
+                        resp.body = "{\"result\":\"success\"}"
+                    else:
+                        resp.body = "{\"result\":\"failed\"}"
+                else:
+                    print 'Not a valid number to send the message to '+str(retailerContact.mobile_number)
+                    resp.body = "{\"result\":\"failed\"}"
+def generateSms(self,identifier,mobile_number,agentId):
+    try:
+        retailerLink = session.query(RetailerLinks).filter_by(retailer_id=identifier).first()
+        retailer = session.query(Retailers).filter_by(id=identifier).first()
+        if retailer is not None:
+            if retailerLink is not None:
+                code = retailerLink.code
+                retailerLink.agent_id = agentId
+            else:
+                code = self.getNewRandomCode()
+                retailerLink = RetailerLinks()
+                retailerLink.code = code
+                retailerLink.agent_id = self.agentId
+                retailerLink.retailer_id = self.retailerId
+                activationCode=Activation_Codes()
+                activationCode.code = code
+            profitmandiUrl = make_tiny(code)
+            smsText = smsText + profitmandiUrl
+            url_params = { 'ani' : '91'+mobile_number,  'uname' : 'srlsaholic', 'passwd' : 'sr18mar' , 'cli' : 'PROFTM', 'message' : smsText.strip() }
+            encoded_url_params = urllib.urlencode(url_params)
+            print 'Mobile Number :- '+str(mobile_number) +' Url Params:- '+str(encoded_url_params)
+            url = TRANSACTIONAL_SMS_SEND_URL + encoded_url_params
+            response_str = None
+            try:
+                req = urllib2.Request(url)
+                response = urllib2.urlopen(req)
+                response_str = response.read()
+            except:
+                print 'Error while getting response for user id:- Mobile Number:- '+str(mobile_number)
+                traceback.print_exc()
+                return False
+            print 'Mobile Number:- '+str(mobile_number) +' Sent Response:- '+ str(response_str)
+            try:
+                sms = profitmandi_sms()
+                sms.mobile_number = mobile_number
+                sms.sms_type = 'code'
+                sms.identifier = identifier
+                if "Message sent successfully to " in response_str:
+                    response_str_vals = response_str.split('#')
+                    sms.status = "smsprocessed"
+                    sms.sms_id = response_str_vals[0]
+                else:
+                    sms.status = "smsrejected"
+                    sms.sms_id = None
+            except:
+                print 'Error while getting response for user id:- Mobile Number:- '+str(mobile_number)
+                traceback.print_exc()
+                return False
+            retailer.status='followup'
+            retailer.disposition = 'auto_text_sent'
+            retailer.next_call_time = datetime.now() + timedelta(days=1)
+            session.commit()
+            return True
+        else:
+            return False
+    except:
+        print traceback.print_exc()
+        return False
+    finally:
+        session.close()
 def main():
     a = RetailerDetail()
     retailer = a.getNotActiveRetailer()
     otherContacts = [r for r, in session.query(RetailerContacts.mobile_number).filter_by(retailer_id=retailer.id).order_by(RetailerContacts.contact_type).all()]
     print json.dumps(todict(getRetailerObj(retailer, otherContacts, 'fresh')), encoding='utf-8')

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/api/Service.py – Rev 19734 → 19761