| Line 1624... |
Line 1624... |
| 1624 |
class GetUserCrmApplication:
|
1624 |
class GetUserCrmApplication:
|
| 1625 |
|
1625 |
|
| 1626 |
def on_get(self,req,resp):
|
1626 |
def on_get(self,req,resp):
|
| 1627 |
project_name = req.get_param("project_name")
|
1627 |
project_name = req.get_param("project_name")
|
| 1628 |
if project_name == 'accessories':
|
1628 |
if project_name == 'accessories':
|
| 1629 |
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==1).filter(UserCrmCallingData.contact1!=None).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
|
1629 |
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()
|
| 1630 |
if user is None:
|
1630 |
if user is None:
|
| 1631 |
project_id=1
|
1631 |
project_id=1
|
| 1632 |
insertUserCrmData(project_id)
|
1632 |
insertUserCrmData(project_id)
|
| 1633 |
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==1).filter(UserCrmCallingData.contact1!=None).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
|
1633 |
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()
|
| 1634 |
user.status = 'assigned'
|
1634 |
user.status = 'assigned'
|
| 1635 |
user.agent_id = req.get_param("agent_id")
|
1635 |
user.agent_id = req.get_param("agent_id")
|
| 1636 |
user.counter=1
|
1636 |
user.counter=1
|
| 1637 |
user.modified = datetime.now()
|
1637 |
user.modified = datetime.now()
|
| 1638 |
session.commit()
|
1638 |
session.commit()
|
| Line 1696... |
Line 1696... |
| 1696 |
userId=i[1]
|
1696 |
userId=i[1]
|
| 1697 |
userMasterData = UserCrmCallingData()
|
1697 |
userMasterData = UserCrmCallingData()
|
| 1698 |
userMasterData.user_id = userId
|
1698 |
userMasterData.user_id = userId
|
| 1699 |
userMasterData.name =getUsername(userId)
|
1699 |
userMasterData.name =getUsername(userId)
|
| 1700 |
userMasterData.project_id = 1
|
1700 |
userMasterData.project_id = 1
|
| 1701 |
userMasterData.user_available=1
|
1701 |
userMasterData.user_available=0
|
| 1702 |
userMasterData.contact1 = getUserContactDetails(userId)
|
1702 |
userMasterData.contact1 = getUserContactDetails(userId)
|
| 1703 |
userMasterData.counter = 0
|
1703 |
userMasterData.counter = 0
|
| 1704 |
userMasterData.created = datetime.now()
|
1704 |
userMasterData.created = datetime.now()
|
| 1705 |
userMasterData.modified = datetime.now()
|
1705 |
userMasterData.modified = datetime.now()
|
| 1706 |
userMasterData.status = 'new'
|
1706 |
userMasterData.status = 'new'
|