| Line 526... |
Line 526... |
| 526 |
while(retry):
|
526 |
while(retry):
|
| 527 |
lgr.info( "Calltype " + self.callType)
|
527 |
lgr.info( "Calltype " + self.callType)
|
| 528 |
status=self.callType
|
528 |
status=self.callType
|
| 529 |
query = session.query(Retailers).filter(Retailers.status==status)
|
529 |
query = session.query(Retailers).filter(Retailers.status==status)
|
| 530 |
if status=='fresh':
|
530 |
if status=='fresh':
|
| 531 |
query = query.filter_by(is_or=False, is_std=False).filter(or_(Retailers.agent_id==self.agentId, Retailers.agent_id==None)).order_by(-Retailers.agent_id)
|
531 |
query = query.filter_by(is_or=False, is_std=False).filter(or_(Retailers.agent_id==self.agentId, Retailers.agent_id==None)).order_by(Retailers.is_elavated.desc(), -Retailers.agent_id)
|
| 532 |
else:
|
532 |
else:
|
| 533 |
query = query.filter(Retailers.next_call_time<=datetime.now())
|
533 |
query = query.filter(Retailers.next_call_time<=datetime.now())
|
| 534 |
retailer = query.with_lockmode("update").first()
|
534 |
retailer = query.with_lockmode("update").first()
|
| 535 |
if retailer is not None:
|
535 |
if retailer is not None:
|
| 536 |
lgr.info( "retailer " +str(retailer.id))
|
536 |
lgr.info( "retailer " +str(retailer.id))
|