| Line 742... |
Line 742... |
| 742 |
def on_get(self, req, resp, agentId, role):
|
742 |
def on_get(self, req, resp, agentId, role):
|
| 743 |
try:
|
743 |
try:
|
| 744 |
if agentId or role is None:
|
744 |
if agentId or role is None:
|
| 745 |
resp.body = json.dumps({"result":{"success":"false","message":"Cannot not log out"}}, encoding='utf-8')
|
745 |
resp.body = json.dumps({"result":{"success":"false","message":"Cannot not log out"}}, encoding='utf-8')
|
| 746 |
else:
|
746 |
else:
|
| - |
|
747 |
agents=AgentLoginTimings()
|
| 747 |
lastLoginTime = session.query(Agents).filter(Agents.id==agentId).first()
|
748 |
lastLoginTime = session.query(Agents).filter(Agents.id==agentId).first()
|
| - |
|
749 |
print 'lastLogintime' + str(lastLoginTime)
|
| 748 |
AgentLoginTimings.loginTime=lastLoginTime.last_login
|
750 |
agents.loginTime=lastLoginTime.last_login
|
| 749 |
AgentLoginTimings.logoutTime=datetime.now()
|
751 |
agents.logoutTime=datetime.now()
|
| 750 |
AgentLoginTimings.role =role
|
752 |
agents.role =role
|
| 751 |
AgentLoginTimings.agent_id = id
|
753 |
agents.agent_id = 2
|
| - |
|
754 |
session.add(agents)
|
| 752 |
session.commit()
|
755 |
session.commit()
|
| 753 |
resp.body = json.dumps({"result":{"success":"true","message":"Success"}}, encoding='utf-8')
|
756 |
resp.body = json.dumps({"result":{"success":"true","message":"Success"}}, encoding='utf-8')
|
| 754 |
finally:
|
757 |
finally:
|
| 755 |
session.close()
|
758 |
session.close()
|
| 756 |
|
759 |
|
| Line 769... |
Line 772... |
| 769 |
print checkUser[0]
|
772 |
print checkUser[0]
|
| 770 |
checkRole = session.query(Agent_Roles.id).filter(and_(Agent_Roles.agent_id==checkUser[0],Agent_Roles.role==role)).first()
|
773 |
checkRole = session.query(Agent_Roles.id).filter(and_(Agent_Roles.agent_id==checkUser[0],Agent_Roles.role==role)).first()
|
| 771 |
if checkRole is None:
|
774 |
if checkRole is None:
|
| 772 |
resp.body = json.dumps({"result":{"success":"false","message":"Invalid Role"}}, encoding='utf-8')
|
775 |
resp.body = json.dumps({"result":{"success":"false","message":"Invalid Role"}}, encoding='utf-8')
|
| 773 |
else:
|
776 |
else:
|
| 774 |
Agents.last_login =datetime.now()
|
777 |
session.query(AgentLoginTimings).filter_by(id = checkUser[0]).update({"last_login":datetime.now()})
|
| 775 |
resp.body = json.dumps({"result":{"success":"true","message":"Valid User","id":checkUser[0]}}, encoding='utf-8')
|
778 |
resp.body = json.dumps({"result":{"success":"true","message":"Valid User","id":checkUser[0]}}, encoding='utf-8')
|
| - |
|
779 |
#session.query(Agents).filter_by(id = checkUser[0]).
|
| 776 |
session.commit()
|
780 |
session.commit()
|
| 777 |
finally:
|
781 |
finally:
|
| 778 |
session.close()
|
782 |
session.close()
|
| 779 |
|
783 |
|
| 780 |
def test(self,email,password,role,resp):
|
784 |
def test(self,email,password,role):
|
| 781 |
checkUser = session.query(Agents.id).filter(and_(Agents.email==email,Agents.password==password)).first()
|
785 |
checkUser = session.query(Agents.id).filter(and_(Agents.email==email,Agents.password==password)).first()
|
| 782 |
if checkUser is None:
|
786 |
if checkUser is None:
|
| 783 |
print checkUser
|
787 |
print checkUser
|
| 784 |
resp.body = json.dumps({"result":{"success":"false","message":"Invalid User"}}, encoding='utf-8')
|
- |
|
| - |
|
788 |
|
| 785 |
else:
|
789 |
else:
|
| 786 |
print checkUser[0]
|
790 |
print checkUser[0]
|
| 787 |
checkRole = session.query(Agent_Roles.id).filter(and_(Agent_Roles.agent_id==checkUser[0],Agent_Roles.role==role)).first()
|
791 |
checkRole = session.query(Agent_Roles.id).filter(and_(Agent_Roles.agent_id==checkUser[0],Agent_Roles.role==role)).first()
|
| 788 |
if checkRole is None:
|
792 |
if checkRole is None:
|
| 789 |
resp.body = json.dumps({"result":{"success":"false","message":"Invalid Role"}}, encoding='utf-8')
|
793 |
pass
|
| 790 |
else:
|
794 |
else:
|
| - |
|
795 |
agents=AgentLoginTimings()
|
| - |
|
796 |
agents.loginTime=datetime.now()
|
| - |
|
797 |
agents.logoutTime=datetime.now()
|
| - |
|
798 |
agents.role =role
|
| - |
|
799 |
agents.agent_id = 2
|
| - |
|
800 |
#session.query(AgentLoginTimings).filter_by(id = checkUser[0]).update({"last_login":datetime.now()}, synchronize_session=False)
|
| - |
|
801 |
session.add(agents)
|
| - |
|
802 |
session.commit()
|
| - |
|
803 |
session.close()
|
| - |
|
804 |
|
| 791 |
resp.body = json.dumps({"result":{"success":"true","message":"Valid User"}}, encoding='utf-8')
|
805 |
#session.query(Agents).filter(Agents.id==checkUser[0]).update({"last_login":Agents.last_login})
|
| 792 |
|
806 |
|
| 793 |
def todict(obj, classkey=None):
|
807 |
def todict(obj, classkey=None):
|
| 794 |
if isinstance(obj, dict):
|
808 |
if isinstance(obj, dict):
|
| 795 |
data = {}
|
809 |
data = {}
|
| 796 |
for (k, v) in obj.items():
|
810 |
for (k, v) in obj.items():
|
| Line 833... |
Line 847... |
| 833 |
|
847 |
|
| 834 |
class Mock(object):
|
848 |
class Mock(object):
|
| 835 |
pass
|
849 |
pass
|
| 836 |
|
850 |
|
| 837 |
def main():
|
851 |
def main():
|
| - |
|
852 |
l=Login()
|
| 838 |
print make_tiny("http://www.google.com")
|
853 |
l.test("manaskapoor31@gmail.com", "qwerty", "fresh")
|
| - |
|
854 |
|
| 839 |
if __name__ == '__main__':
|
855 |
if __name__ == '__main__':
|
| 840 |
main()
|
856 |
main()
|
| 841 |
|
857 |
|
| 842 |
|
858 |
|