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

 codesys = [alphalist, alphalist, numList, numList, numList]
 newcodesys = alphalist + numList
 CONTACT_PRIORITY = ['sms', 'called', 'ringing']
 RETRY_MAP = {'fresh':'retry', 'followup':'fretry', 'onboarding':'oretry'}
 ASSIGN_MAP = {'retry':'assigned', 'fretry':'fassigned', 'oretry':'oassigned'}
+CRM_PROJECTS_USER_AVAILABILITY = {1:{'cooldown':30, 'isrepeat':True}, 2:{'cooldown':15,'isrepeat': False}, 3:{'cooldown':2,'isrepeat': True}, 5:{'cooldown':15,'isrepeat': True}}
 sticky_agents = [17,29]
 def getNextRandomCode(newcodesys,size=6):
     return ''.join(random.choice(newcodesys) for _ in range(size))
 USER_DETAIL_MAP={}
 USER_DETAIL_MAP['accs_cart']=0
 USER_DETAIL_MAP['accs_active']=0
 USER_DETAIL_MAP['accs_order']=0
 USER_DETAIL_MAP['accs_cashback_scheme']=0
+# change 1
+USER_DETAIL_MAP['inactive_users']=0
 lgr = getLogger('/var/log/retailer-acquisition-api.log')
 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'))
             project_id=2
         elif project_name == 'accs_order':
             project_id=3
         elif project_name == 'accs_cashback_scheme':
             project_id=4
+        elif project_name == 'inactive_users':
+            project_id=5
         if retryFlag:
             user = self.getRetryUser(project_id)
         else:
             user = self.getNewUser(project_id)
             project_id=2
         elif project_name == 'accs_order':
             project_id=3
         elif project_name == 'accs_cashback_scheme':
             project_id=4
+        elif project_name == 'inactive_users':
+            project_id=5
         jsonReq = json.loads(req.stream.read(), encoding='utf-8')
         lgr.info( "Request ----\n"  + str(jsonReq))
         self.jsonReq = jsonReq
         self.callType="default"
         callLaterAccs = self.callLaterAccs
+        invalidNumber = self.invalidNumber
         accsDisposition = self.accsDisposition
         accsOrderDisposition=self.accsOrderDisposition
+        otherreason = self.otherreason
+        willplaceorder = self.willplaceorder
+        orderdiffaccount = self.orderdiffaccount
+        businessclosed = self.businessclosed
+        appuninstalled = self.appuninstalled
         self.userId = int(jsonReq.get('user_id'))
         try:
             self.user = session.query(UserCrmCallingData).filter_by(user_id=self.userId).filter(UserCrmCallingData.project_id==project_id).first()
             self.callDisposition = jsonReq.get('calldispositiontype')
             self.callHistoryCrm = CallHistoryCrm()
                         'already_purchased':accsOrderDisposition,
                         'product_quality_issue':accsOrderDisposition,
                         'delayed_delivery':accsOrderDisposition,
                         'other_complaint':accsOrderDisposition,
                         'scheme_not_clear':accsOrderDisposition,
-                        'not_dealing_accessories':accsOrderDisposition
+                        'not_dealing_accessories':accsOrderDisposition,
+                        'other_reason':otherreason,
+                        'app_uninstalled':appuninstalled,
+                        'will_place_order':willplaceorder,
+                        'order_diff_acc':orderdiffaccount,
+                        'not_retailer':invalidNumber,
+                        'business_closed':businessclosed,
+                        'invalid_no':invalidNumber,
+                        'wrong_no':invalidNumber,
+                        'hang_up':invalidNumber,
+                        'service_center_retailer':invalidNumber,
+                        'recharge_retailer':invalidNumber
+                      }
             returned = dispositionMap[jsonReq.get('calldispositiontype')]()
         finally:
             session.close()
                     productpricingInputs.product_input = key
                     productpricingInputs.pricing_input = value
             session.commit()
         return True
+    def willplaceorder(self,):
+        self.retailer.status = self.callDisposition
+        if self.callHistory.disposition_description is None:
+            self.callHistory.disposition_description = 'User will place order from now'
+        session.commit()
+        return True
+    def orderdiffaccount(self,):
+        self.retailer.status = self.callDisposition
+        if self.callHistory.disposition_description is None:
+            self.callHistory.disposition_description = 'Placing Order from Different Account'
+        session.commit()
+        return True
+    def businessclosed(self,):
+        self.retailer.status = self.callDisposition
+        if self.callHistory.disposition_description is None:
+            self.callHistory.disposition_description = 'Business Closed'
+        session.commit()
+        return True
+    def appuninstalled(self,):
+        self.retailer.status = self.callDisposition
+        if self.callHistory.disposition_description is None:
+            self.callHistory.disposition_description = 'User uninstalled application'
+        session.commit()
+        return True
+    def alReadyUser(self,):
+        self.retailer.status = self.callDisposition
+        if self.callHistory.disposition_description is None:
+            self.callHistory.disposition_description = 'Retailer already user'
+        session.commit()
+        return True
+    def invalidNumber(self,):
+        #self.retailer.status = 'retry' if self.callType == 'fresh' else 'fretry'
+#         self.user.status='retry'
+        self.user.modified = datetime.now()
+        if self.callDisposition == 'invalid_no':
+#             self.retailer.status='failed'
+            self.user.disposition=self.callDisposition
+            self.callHistoryCrm.disposition_description = 'Invalid Number'
+        elif self.callDisposition == 'wrong_no':
+#             self.retailer.status='failed'
+            self.user.disposition=self.callDisposition
+            self.callHistoryCrm.disposition_description = 'Wrong Number'
+        elif self.callDisposition == 'hang_up':
+#             self.retailer.status='failed'
+            self.user.disposition=self.callDisposition
+            self.callHistoryCrm.disposition_description = 'Hang Up'
+        elif self.callDisposition == 'retailer_not_interested':
+#             self.retailer.status='failed'
+            self.user.disposition=self.callDisposition
+            if self.callHistoryCrm.disposition_description is None:
+                self.callHistoryCrm.disposition_description = 'NA'
+            self.callHistoryCrm.disposition_description = 'Reason Retailer Not Interested ' + self.callHistoryCrm.disposition_description
+        elif self.callDisposition == 'recharge_retailer':
+#             self.retailer.status='failed'
+            self.user.disposition=self.callDisposition
+            self.callHistoryCrm.disposition_description = 'Recharge related. Not a retailer '
+        elif self.callDisposition == 'accessory_retailer':
+#             self.retailer.status='failed'
+            self.user.disposition=self.callDisposition
+            self.callHistoryCrm.disposition_description = 'Accessory related. Not a retailer'
+        elif self.callDisposition == 'service_center_retailer':
+#             self.retailer.status='failed'
+            self.user.disposition=self.callDisposition
+            self.callHistoryCrm.disposition_description = 'Service Center related. Not a retailer'
+        elif self.callDisposition == 'not_retailer':
+#             self.retailer.status='failed'
+            self.user.disposition=self.callDisposition
+            self.callHistoryCrm.disposition_description = 'Not a retailer'
+        session.commit()
+        return True
+    def otherreason(self,):
+        self.user.modified = datetime.now()
+        self.user.disposition=self.callDisposition
+        if self.callHistoryCrm.disposition_description is None:
+            self.callHistoryCrm.disposition_description = 'Other Reasons'
+        session.commit()
+        return True
     def accsDisposition(self):
         self.user.status='done'
         self.user.user_available = 1
         self.user.disposition=self.callDisposition
         self.user.modified = datetime.now()
         getCartTabsUser()
     if project_id==3:
         getAccsRepeatUsers(project_id)
     if project_id==4:
         getAccsSchemeCashback(project_id)
+    if project_id==5:
+        getInactiveUsers(project_id)
+def getInactiveUsers(project_id):
+    PRIOPRITIZING_USER_QUERY = "select d.user_id, count(d.user_id),x.totalorder from daily_visitors d join users u on d.user_id=u.id left join (select user_id,count(*) as totalorder from allorder group by user_id order by totalorder desc) as x on d.user_id=x.user_id where lower(u.referrer) not like 'emp%' and d.user_id not in (select user_id from daily_visitors where visited > '2016-03-01') group by d.user_id having count(*) >=5 order by x.totalorder desc, count(d.user_id) desc;"
+    userFinalList=[]
+    result = fetchResult(PRIOPRITIZING_USER_QUERY)
+    for r in result:
+        userFinalList.append(r[0])
+    for i in userFinalList:
+        try:
+            userId=i
+            userPresent = session.query(UserCrmCallingData).filter_by(user_id=userId).order_by(desc(UserCrmCallingData.modified)).first()
+            if userPresent is not None:
+                if userPresent.user_available==1:
+                    if userPresent.project_id==project_id:
+                        continue
+                    elif userPresent.modified.date()>=(datetime.now().date()-timedelta(days=30)):
+                        continue
+                else:
+                    continue
+            userMasterData = UserCrmCallingData()
+            userMasterData.user_id = userId
+            userMasterData.name =getUsername(userId)
+            userMasterData.project_id = project_id
+            userMasterData.user_available=0
+            userMasterData.contact1 = getUserContactDetails(userId)
+            userMasterData.counter = 0
+            userMasterData.retry_count=0
+            userMasterData.invalid_retry_count=0
+            userMasterData.created = datetime.now()
+            userMasterData.modified = datetime.now()
+            userMasterData.status = 'new'
+            userMasterData.pincode_servicable = checkPincodeServicable(userId)
+            session.commit()
+        except:
+            print traceback.print_exc()
+        finally:
+            session.close()
 def getAccsSchemeCashback(project_id):
     userMasterMap={}
     skipUserList=[]
     query = "select id from users where lower(referrer) in ('emp01','emp99','emp88')"
     for i in d_sorted:
         try:
             userId=i[1]
             if counter==20:
                 break
+#             userPresent = isUserAvailable(CRM_PROJECTS_USER_AVAILABILITY.get(project_id))
             userPresent = session.query(UserCrmCallingData).filter_by(user_id=userId).order_by(desc(UserCrmCallingData.modified)).first()
             if userPresent is not None:
                 if userPresent.user_available==1:
                     if userPresent.project_id==project_id:
                         continue

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/api/Service.py – Rev 20082 → 20133