| Line 1687... |
Line 1687... |
| 1687 |
|
1687 |
|
| 1688 |
|
1688 |
|
| 1689 |
def getNewUser(self,projectId,failback=True):
|
1689 |
def getNewUser(self,projectId,failback=True):
|
| 1690 |
user = None
|
1690 |
user = None
|
| 1691 |
try:
|
1691 |
try:
|
| 1692 |
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).filter(~(UserCrmCallingData.contact1).like('')).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
|
1692 |
user = session.query(UserCrmCallingData).filter_by(project_id=projectId).filter(UserCrmCallingData.status=='new').filter(UserCrmCallingData.pincode_servicable==True).filter(UserCrmCallingData.user_available==0).filter(UserCrmCallingData.contact1!=None).filter(~(UserCrmCallingData.contact1).like('')).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
|
| 1693 |
if user is None:
|
1693 |
if user is None:
|
| 1694 |
insertUserCrmData(projectId)
|
1694 |
insertUserCrmData(projectId)
|
| 1695 |
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.contact1).like('')).filter(UserCrmCallingData.user_available==0).filter(UserCrmCallingData.contact1!=None).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
|
1695 |
user = session.query(UserCrmCallingData).filter_by(project_id=projectId).filter(UserCrmCallingData.status=='new').filter(UserCrmCallingData.pincode_servicable==True).filter(~(UserCrmCallingData.contact1).like('')).filter(UserCrmCallingData.user_available==0).filter(UserCrmCallingData.contact1!=None).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
|
| 1696 |
if user is not None:
|
1696 |
if user is not None:
|
| 1697 |
lgr.info( "getNewUser " + str(user.id))
|
1697 |
lgr.info( "getNewUser " + str(user.id))
|
| 1698 |
else:
|
1698 |
else:
|
| 1699 |
if failback:
|
1699 |
if failback:
|
| 1700 |
user = self.getRetryUser(projectId,False)
|
1700 |
user = self.getRetryUser(projectId,False)
|
| Line 1999... |
Line 1999... |
| 1999 |
}
|
1999 |
}
|
| 2000 |
result = get_mongo_connection_dtr_data().User.browsinghistories.find(queryfilterVisistedCart).distinct('user_id')
|
2000 |
result = get_mongo_connection_dtr_data().User.browsinghistories.find(queryfilterVisistedCart).distinct('user_id')
|
| 2001 |
for r in result:
|
2001 |
for r in result:
|
| 2002 |
userList.append(r)
|
2002 |
userList.append(r)
|
| 2003 |
|
2003 |
|
| 2004 |
myquery = "select user_id from allorder where store_id='spice' and (category='Accs' or category='Accessories') and user_id in (%s)" % ",".join(map(str,userList)) + " UNION select id from users where lower(referrer) like 'emp%'"
|
2004 |
myquery = "select user_id from allorder where store_id='spice' and (category='Accs' or category='Accessories') and user_id in (%s)" % ",".join(map(str,userMasterList)) + " UNION select id from users where lower(referrer) like 'emp%'"
|
| 2005 |
|
2005 |
|
| 2006 |
result = fetchResult(myquery)
|
2006 |
result = fetchResult(myquery)
|
| 2007 |
for r in result:
|
2007 |
for r in result:
|
| 2008 |
if r[0] in userList:
|
2008 |
if r[0] in userList:
|
| 2009 |
continue
|
2009 |
continue
|