| Line 557... |
Line 557... |
| 557 |
retailer = None
|
557 |
retailer = None
|
| 558 |
try:
|
558 |
try:
|
| 559 |
while(retry):
|
559 |
while(retry):
|
| 560 |
lgr.info( "Calltype " + self.callType)
|
560 |
lgr.info( "Calltype " + self.callType)
|
| 561 |
status=self.callType
|
561 |
status=self.callType
|
| 562 |
query = session.query(Retailers).filter(Retailers.status==status)
|
562 |
query = session.query(Retailers).filter(Retailers.status==status).filter(or_(Retailers.agent_id==self.agentId, Retailers.agent_id==None))
|
| 563 |
if status=='fresh':
|
563 |
if status=='fresh':
|
| 564 |
query = query.filter_by(is_or=False, is_std=False).filter(Retailers.cod_limit != None).filter(or_(Retailers.agent_id==self.agentId, Retailers.agent_id==None)).order_by(Retailers.is_elavated.desc(), -Retailers.agent_id)
|
564 |
query = query.filter_by(is_or=False, is_std=False).filter(Retailers.cod_limit != None).order_by(Retailers.is_elavated.desc(), -Retailers.agent_id)
|
| 565 |
elif status=='followup':
|
565 |
elif status=='followup':
|
| 566 |
query = query.filter(Retailers.next_call_time<=datetime.now()).order_by(Retailers.next_call_time)
|
566 |
query = query.filter(Retailers.next_call_time<=datetime.now()).order_by(-Retailers.agent_id,Retailers.next_call_time)
|
| 567 |
else:
|
567 |
else:
|
| 568 |
query = query.filter(Retailers.modified<=datetime.now()).order_by(Retailers.modified)
|
568 |
query = query.filter(Retailers.modified<=datetime.now()).order_by(-Retailers.agent_id, Retailers.modified)
|
| 569 |
|
569 |
|
| 570 |
retailer = query.with_lockmode("update").first()
|
570 |
retailer = query.with_lockmode("update").first()
|
| 571 |
if retailer is not None:
|
571 |
if retailer is not None:
|
| 572 |
lgr.info( "retailer " +str(retailer.id))
|
572 |
lgr.info( "retailer " +str(retailer.id))
|
| 573 |
if status=="fresh":
|
573 |
if status=="fresh":
|