| Line 935... |
Line 935... |
| 935 |
jsonReq = json.loads(req.stream.read(), encoding='utf-8')
|
935 |
jsonReq = json.loads(req.stream.read(), encoding='utf-8')
|
| 936 |
lgr.info( "Request ----\n" + str(jsonReq))
|
936 |
lgr.info( "Request ----\n" + str(jsonReq))
|
| 937 |
email=jsonReq.get('email')
|
937 |
email=jsonReq.get('email')
|
| 938 |
password = jsonReq.get('password')
|
938 |
password = jsonReq.get('password')
|
| 939 |
role=jsonReq.get('role')
|
939 |
role=jsonReq.get('role')
|
| 940 |
checkUser = session.query(Agents.id).filter(and_(Agents.email==email,Agents.password==password)).first()
|
940 |
agent = session.query(Agents).filter(and_(Agents.email==email,Agents.password==password)).first()
|
| 941 |
if checkUser is None:
|
941 |
if agent is None:
|
| 942 |
print checkUser
|
- |
|
| 943 |
resp.body = json.dumps({"result":{"success":"false","message":"Invalid User"}}, encoding='utf-8')
|
942 |
resp.body = json.dumps({"result":{"success":"false","message":"Invalid User"}}, encoding='utf-8')
|
| 944 |
else:
|
943 |
else:
|
| 945 |
print checkUser[0]
|
944 |
print agent.id
|
| 946 |
checkRole = session.query(Agent_Roles.id).filter(and_(Agent_Roles.agent_id==checkUser[0],Agent_Roles.role==role)).first()
|
945 |
checkRole = session.query(Agent_Roles.id).filter(and_(Agent_Roles.agent_id==agent.id,Agent_Roles.role==role)).first()
|
| 947 |
if checkRole is None:
|
946 |
if checkRole is None:
|
| 948 |
resp.body = json.dumps({"result":{"success":"false","message":"Invalid Role"}}, encoding='utf-8')
|
947 |
resp.body = json.dumps({"result":{"success":"false","message":"Invalid Role"}}, encoding='utf-8')
|
| 949 |
else:
|
948 |
else:
|
| 950 |
session.query(Agents).filter_by(id = checkUser[0]).update({"last_login":datetime.now()})
|
949 |
agent.last_login = datetime.now()
|
| - |
|
950 |
agent.login_type = role
|
| 951 |
resp.body = json.dumps({"result":{"success":"true","message":"Valid User","id":checkUser[0]}}, encoding='utf-8')
|
951 |
resp.body = json.dumps({"result":{"success":"true","message":"Valid User","id":agent.id}}, encoding='utf-8')
|
| 952 |
#session.query(Agents).filter_by(id = checkUser[0]).
|
- |
|
| 953 |
session.commit()
|
952 |
session.commit()
|
| - |
|
953 |
#session.query(Agents).filter_by(id = checkUser[0]).
|
| 954 |
finally:
|
954 |
finally:
|
| 955 |
session.close()
|
955 |
session.close()
|
| 956 |
|
956 |
|
| 957 |
def test(self,email,password,role):
|
957 |
def test(self,email,password,role):
|
| 958 |
checkUser = session.query(Agents.id).filter(and_(Agents.email==email,Agents.password==password)).first()
|
958 |
checkUser = session.query(Agents.id).filter(and_(Agents.email==email,Agents.password==password)).first()
|