| Line 1655... |
Line 1655... |
| 1655 |
resp.body = json.dumps(todict(getUserObject(user)), encoding='utf-8')
|
1655 |
resp.body = json.dumps(todict(getUserObject(user)), encoding='utf-8')
|
| 1656 |
session.close()
|
1656 |
session.close()
|
| 1657 |
|
1657 |
|
| 1658 |
def getRetryUser(self,projectId,failback=True):
|
1658 |
def getRetryUser(self,projectId,failback=True):
|
| 1659 |
status = "retry"
|
1659 |
status = "retry"
|
| 1660 |
user = session.query(UserCrmCallingData).filter_by(status=status,project_id=projectId).filter(UserCrmCallingData.next_call_time<=datetime.now()).order_by(UserCrmCallingData.next_call_time).with_lockmode("update").first()
|
1660 |
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()
|
| 1661 |
|
1661 |
|
| 1662 |
if user is not None:
|
1662 |
if user is not None:
|
| 1663 |
lgr.info( "getRetryUser " + str(user.id))
|
1663 |
lgr.info( "getRetryUser " + str(user.id))
|
| 1664 |
else:
|
1664 |
else:
|
| 1665 |
if failback:
|
1665 |
if failback:
|
| Line 1671... |
Line 1671... |
| 1671 |
|
1671 |
|
| 1672 |
|
1672 |
|
| 1673 |
def getNewUser(self,projectId,failback=True):
|
1673 |
def getNewUser(self,projectId,failback=True):
|
| 1674 |
user = None
|
1674 |
user = None
|
| 1675 |
try:
|
1675 |
try:
|
| 1676 |
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()
|
1676 |
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()
|
| 1677 |
if user is None:
|
1677 |
if user is None:
|
| 1678 |
insertUserCrmData(projectId)
|
1678 |
insertUserCrmData(projectId)
|
| 1679 |
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()
|
1679 |
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()
|
| 1680 |
if user is not None:
|
1680 |
if user is not None:
|
| 1681 |
lgr.info( "getNewUser " + str(user.id))
|
1681 |
lgr.info( "getNewUser " + str(user.id))
|
| 1682 |
else:
|
1682 |
else:
|
| 1683 |
if failback:
|
1683 |
if failback:
|
| 1684 |
user = self.getRetryUser(projectId,False)
|
1684 |
user = self.getRetryUser(projectId,False)
|
| Line 2042... |
Line 2042... |
| 2042 |
#retailer = a.getNotActiveRetailer()
|
2042 |
#retailer = a.getNotActiveRetailer()
|
| 2043 |
#otherContacts = [r for r, in session.query(RetailerContacts.mobile_number).filter_by(retailer_id=retailer.id).order_by(RetailerContacts.contact_type).all()]
|
2043 |
#otherContacts = [r for r, in session.query(RetailerContacts.mobile_number).filter_by(retailer_id=retailer.id).order_by(RetailerContacts.contact_type).all()]
|
| 2044 |
#print json.dumps(todict(getRetailerObj(retailer, otherContacts, 'fresh')), encoding='utf-8')
|
2044 |
#print json.dumps(todict(getRetailerObj(retailer, otherContacts, 'fresh')), encoding='utf-8')
|
| 2045 |
#print make_tiny("AA")
|
2045 |
#print make_tiny("AA")
|
| 2046 |
a = GetUserCrmApplication()
|
2046 |
a = GetUserCrmApplication()
|
| 2047 |
a.getUser("accessories", 2)
|
2047 |
a.getUser("accs_cart", 2)
|
| 2048 |
|
2048 |
|
| 2049 |
if __name__ == '__main__':
|
2049 |
if __name__ == '__main__':
|
| 2050 |
main()
|
2050 |
main()
|
| 2051 |
|
2051 |
|
| 2052 |
|
2052 |
|