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

 import gdshortener
 from dtr.dao import AppOfferObj, UserAppBatchDrillDown, UserAppBatchDateDrillDown
 import base64
 from falcon.util.uri import decode
 import MySQLdb
+from shop2020.clients.CatalogClient import CatalogClient
 alphalist = list(string.uppercase)
 alphalist.remove('O')
 numList = ['1','2','3','4','5','6','7','8','9']
 codesys = [alphalist, alphalist, numList, numList, numList]
 CONTACT_PRIORITY = ['sms', 'called', 'ringing']
         lgr.info( "USER_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 == 'accs_cart':
-            if retryFlag:
+            project_id=1
-                user = self.getRetryUser(1)
-            else:
-                user = self.getNewUser(1)
-            if user is None:
-                resp.body ={}
-            else:
-                user.status =  'assigned'
-                user.agent_id = req.get_param("agent_id")
-                user.counter=1
-                user.modified = datetime.now()
-                session.commit()
-                resp.body = json.dumps(todict(getUserObject(user)), encoding='utf-8')
-                session.close()
-        if project_name == 'accs_active':
+        elif project_name == 'accs_active':
-            if retryFlag:
+            project_id=2
-                user = self.getRetryUser(2)
-            else:
-                user = self.getNewUser(2)
-            if user is None:
-                resp.body ={}
-            else:
-                user.status =  'assigned'
+        elif project_name == 'accs_order':
-                user.agent_id = req.get_param("agent_id")
-                user.counter=1
+            project_id=3
-                user.modified = datetime.now()
-                session.commit()
-                resp.body = json.dumps(todict(getUserObject(user)), encoding='utf-8')
-                session.close()
-        if project_name == 'accs_order':
-            if retryFlag:
+        if retryFlag:
-                user = self.getRetryUser(3)
+            user = self.getRetryUser(project_id)
-            else:
+        else:
-                user = self.getNewUser(3)
+            user = self.getNewUser(project_id)
-            if user is None:
+        if user is None:
-                resp.body ={}
+            resp.body ={}
-            else:
+        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()
+            session.close()
     def getRetryUser(self,projectId,failback=True):
         status = "retry"
         user = session.query(UserCrmCallingData).filter_by(status=status,project_id=projectId).filter(UserCrmCallingData.next_call_time<=datetime.now()).filter(~(UserCrmCallingData.contact1).like('')).order_by(UserCrmCallingData.next_call_time).with_lockmode("update").first()
                     if userPresent.project_id==project_id:
                         if userPresent.modified.date()>=(datetime.now().date()-timedelta(days=30)):
                             continue
                         else:
                             pass
-                    elif userPresent.modified.date()>=(datetime.now().date()-timedelta(days=3)):
+                    elif userPresent.modified.date()>=(datetime.now().date()-timedelta(days=30)):
                         continue
                 else:
                     continue
             counter=counter+1
             userMasterData = UserCrmCallingData()
     userList=[]
     orderUserList=[]
     userMasterMap={}
     queryfilter = {"$and":
+                   [
-                    {'created':{"$gte":(to_java_date(datetime.now())-2*86400000)}},
+                    {'created':{"$gte":(to_java_date(datetime.now())-3*86400000)}},
                     {'created':{"$lte":(to_java_date(datetime.now())- 43200000)}},
                     {"url":{"$regex" : "http://api.profittill.com/cartdetails"}}
+                    ]
+                   }
     result = get_mongo_connection_dtr_data().User.browsinghistories.find(queryfilter).distinct('user_id')
     result = fetchResult(myquery)
     for r in result:
         orderUserList.append(r[0])
     finalUserList  = list(set(userList) - set(orderUserList))
+    userCartIdMap={}
+    fetchCartId = "select user_id,account_key from user_accounts where account_type='cartId' and user_id in (%s)" % ",".join(map(str,finalUserList))
+    result = fetchResult(fetchCartId)
+    for r in result:
+        userCartIdMap[r[1]] = r[0]
+    client = CatalogClient().get_client()
+    userMapReturned = client.getCartByValue(userCartIdMap.keys())
+    print userMapReturned
-    queryfilternew = {"$and":
+#     queryfilternew = {"$and":
-                   [
+#                    [
-                    {'user_id':{"$in":finalUserList}},
+#                     {'user_id':{"$in":finalUserList}},
-                    {'created':{"$gte":(to_java_date(datetime.now())-2*86400000)}},
+#                     {'created':{"$gte":(to_java_date(datetime.now())-2*86400000)}},
-                    {'created':{"$lte":(to_java_date(datetime.now())- 43200000)}},
+#                     {'created':{"$lte":(to_java_date(datetime.now())- 43200000)}},
-                    {"url":{"$regex" : "http://api.profittill.com/cartdetails"}}
+#                     {"url":{"$regex" : "http://api.profittill.com/cartdetails"}}
-                    ]
+#                     ]
-                   }
+#                    }
-    itemIds = list(get_mongo_connection_dtr_data().User.browsinghistories.find(queryfilternew))
+#     itemIds = list(get_mongo_connection_dtr_data().User.browsinghistories.find(queryfilternew))
+#
-    for i in itemIds:
+#     for i in itemIds:
-        if(userMasterMap.has_key(i.get('user_id'))):
+#         if(userMasterMap.has_key(i.get('user_id'))):
-            if userMasterMap.get(i.get('user_id')) > i.get('created'):
+#             if userMasterMap.get(i.get('user_id')) > i.get('created'):
-                userMasterMap[i.get('user_id')]=i.get('created')
+#                 userMasterMap[i.get('user_id')]=i.get('created')
-        else:
+#         else:
-            userMasterMap[i.get('user_id')]=i.get('created')
+#             userMasterMap[i.get('user_id')]=i.get('created')
+#
-    d_sorted = sorted(zip(userMasterMap.values(), userMasterMap.keys()))
+#     d_sorted = sorted(zip(userMasterMap.values(), userMasterMap.keys()))
-    addUserToTable(d_sorted,1)
+#     addUserToTable(d_sorted,1)
 def addUserToTable(userList,projectId):
     counter=0
     for i in userList:
         try:
-            userId=i[1]
+            userId=i
             if counter==20:
                 break
             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==projectId:
                         continue
-                    elif userPresent.modified.date()>=(datetime.now().date()-timedelta(days=3)):
+                    elif userPresent.modified.date()>=(datetime.now().date()-timedelta(days=30)):
                         continue
                 else:
                     continue
             counter=counter+1
             userMasterData = UserCrmCallingData()
                 userMasterMap[i.get('user_id')]=i.get('created')
         else:
             userMasterMap[i.get('user_id')]=i.get('created')
     d_sorted = sorted(zip(userMasterMap.values(), userMasterMap.keys()))
+    userFinalList=[]
+    for i in d_sorted:
+        userFinalList.append(i[1])
-    addUserToTable(d_sorted,2)
+    addUserToTable(userFinalList,2)
 def getUserContactDetails(userId):
-    try:
-        r = session.query(Users.mobile_number).filter_by(id=userId).first()
+    r = session.query(Users.mobile_number).filter_by(id=userId).first()
-        if r is None:
+    if r is None:
-            return None
+        return None
-        else:
+    else:
-            return r[0]
+        return r[0]
-    finally:
-        session.close()
 def getUsername(userId):
-    try:
-        r = session.query(Users.first_name).filter_by(id=userId).first()
+    r = session.query(Users.first_name).filter_by(id=userId).first()
-        if r is None:
+    if r is None:
-            return None
+        return None
-        else:
+    else:
-            return r[0]
+        return r[0]
-    finally:
-        session.close()
 def checkPincodeServicable(userId):
     checkAddressUser = "select distinct pincode from all_user_addresses where user_id= (%s)"
     result = fetchResult(checkAddressUser,userId)
     if len(result)==0:
         return True
     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')
 #     a = GetUserCrmApplication()
-#     a.getUser("accs_cart", 1)
+#     a.getUser("accs_active", 2)
 if __name__ == '__main__':
     main()

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/api/Service.py – Rev 18716 → 18792