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

 global RETAILER_DETAIL_CALL_COUNTER
 RETAILER_DETAIL_CALL_COUNTER = 0
+global USER_DETAIL_MAP
+USER_DETAIL_MAP['accs_cart']=0
+USER_DETAIL_MAP['accs_active']=0
+USER_DETAIL_MAP['accs_order']=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'))
 TOTAL = DEALER_RETRY_FACTOR + DEALER_FRESH_FACTOR
+TOTAL_USER = USER_CRM_DEFAULT_FRESH_FACTOR + USER_CRM_DEFAULT_RETRY_FACTOR
 class CategoryDiscountInfo(object):
     def on_get(self, req, resp):
         result = Mongo.getAllCategoryDiscount()
             resp.body = json.dumps({}, encoding='utf-8')
 class GetUserCrmApplication:
     def on_get(self,req,resp):
+        global USER_DETAIL_MAP
         project_name = req.get_param("project_name")
+        USER_DETAIL_MAP[project_name]+=1
+        lgr.info( "RETAILER_DETAIL_CALL_COUNTER " +  str(USER_DETAIL_MAP[project_name]))
+        retryFlag=False
+        if USER_DETAIL_MAP[project_name] % TOTAL_USER >= USER_CRM_DEFAULT_FRESH_FACTOR:
+                retryFlag=True
-        if project_name == 'accessories':
+        if project_name == 'accs_cart':
+            if retryFlag:
+                user = self.getRetryUser(1)
+            else:
+                user = self.getNewUser(1)
-            user = session.query(UserCrmCallingData).filter_by(project_id=1).filter(or_(UserCrmCallingData.next_call_time<=datetime.now(),UserCrmCallingData.status=='new')).filter(UserCrmCallingData.pincode_servicable==True).filter(UserCrmCallingData.user_available==0).filter(UserCrmCallingData.contact1!=None).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
             if user is None:
-                project_id=1
+                resp.body ={}
-                insertUserCrmData(project_id)
-                user = session.query(UserCrmCallingData).filter_by(project_id=1).filter(or_(UserCrmCallingData.next_call_time<=datetime.now(),UserCrmCallingData.status=='new')).filter(UserCrmCallingData.pincode_servicable==True).filter(UserCrmCallingData.user_available==0).filter(UserCrmCallingData.contact1!=None).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
+            else:
-            user.status =  'assigned'
+                user.status =  'assigned'
-            user.agent_id = req.get_param("agent_id")
+                user.agent_id = req.get_param("agent_id")
-            user.counter=1
+                user.counter=1
-            user.modified = datetime.now()
+                user.modified = datetime.now()
-            session.commit()
+                session.commit()
-            resp.body = json.dumps(todict(getUserObject(user)), encoding='utf-8')
+                resp.body = json.dumps(todict(getUserObject(user)), encoding='utf-8')
+                session.close()
+    def getRetryUser(self,projectId,failback=True):
+        status = "retry"
-            session.close()
+        user = session.query(UserCrmCallingData).filter_by(status=status,project_id=projectId).filter(UserCrmCallingData.next_call_time<=datetime.now()).filter(or_(UserCrmCallingData.agent_id==self.agentId, UserCrmCallingData.agent_id==None)).order_by(UserCrmCallingData.next_call_time).with_lockmode("update").first()
+        if user is not None:
+            lgr.info( "getRetryRetailer " + str(user.id))
+        else:
+            if failback:
+                user = self.getNewUser(False)
+                return user
+            else:
+                return None
+        return user
+    def getNewUser(self,failback=True,projectId):
+            retry = True
+            user = None
+            try:
+                while(retry):
+                    user = session.query(UserCrmCallingData).filter_by(project_id=projectId).filter(or_(UserCrmCallingData.next_call_time<=datetime.now(),UserCrmCallingData.status=='new')).filter(UserCrmCallingData.pincode_servicable==True).filter(UserCrmCallingData.user_available==0).filter(UserCrmCallingData.contact1!=None).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
+                    if user is None:
+                        insertUserCrmData(projectId)
+                        user = session.query(UserCrmCallingData).filter_by(project_id=projectId).filter(or_(UserCrmCallingData.next_call_time<=datetime.now(),UserCrmCallingData.status=='new')).filter(UserCrmCallingData.pincode_servicable==True).filter(UserCrmCallingData.user_available==0).filter(UserCrmCallingData.contact1!=None).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
+                    retry=False
+            except:
+                print traceback.print_exc()
+            return user
     def on_post(self, req, resp):
         returned = False
         self.agentId = req.get_param("agent_id")
         project_name = req.get_param("project_name")
-        if project_name == 'accessories':
+        if project_name == 'accs_cart':
             jsonReq = json.loads(req.stream.read(), encoding='utf-8')
             lgr.info( "Request ----\n"  + str(jsonReq))
             self.jsonReq = jsonReq
             self.callType="default"
             callLaterAccs = self.callLaterAccs
             self.callHistoryCrm.disposition_description='Will Place Order'
         session.commit()
         return True
     def callLaterAccs(self):
+        self.user.status='retry'
+        self.user.modified = datetime.now()
         if self.callDisposition == 'call_later':
             if self.callHistoryCrm.disposition_comments is not None:
                 self.user.next_call_time = datetime.strptime(self.callHistoryCrm.disposition_comments, '%d/%m/%Y %H:%M:%S')
                 self.callHistoryCrm.disposition_description = 'User requested to call'
                 self.callHistoryCrm.disposition_comments = self.callHistoryCrm.disposition_comments
                 self.user.next_call_time = self.callHistoryCrm.call_time + timedelta(minutes = retryConfig.minutes_ahead)
                 self.callHistoryCrm.disposition_description = 'Call scheduled on ' + datetime.strftime(self.user.next_call_time, '%d/%m/%Y %H:%M:%S')
             else:
                 self.user.status = 'failed'
                 self.callHistoryCrm.disposition_description = 'Call failed as all attempts exhausted'
-        self.user.status='retry'
         self.user.disposition=self.callDisposition
-        self.user.modified = datetime.now()
         session.commit()
         return True
 def insertUserCrmData(project_id):
     if project_id==1:

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/api/Service.py – Rev 18321 → 18329