| Line 552... |
Line 552... |
| 552 |
|
552 |
|
| 553 |
class RetailerDetail():
|
553 |
class RetailerDetail():
|
| 554 |
global RETAILER_DETAIL_CALL_COUNTER
|
554 |
global RETAILER_DETAIL_CALL_COUNTER
|
| 555 |
def getRetryRetailer(self,failback=True):
|
555 |
def getRetryRetailer(self,failback=True):
|
| 556 |
status = RETRY_MAP.get(self.callType)
|
556 |
status = RETRY_MAP.get(self.callType)
|
| 557 |
retailer = session.query(Retailers).filter_by(status=status).filter(Retailers.next_call_time<=datetime.now())\
|
557 |
retailer = session.query(Retailers).filter_by(status=status).filter(Retailers.next_call_time<=datetime.now()).filter(or_(Retailers.agent_id==self.agentId, Retailers.agent_id==None)).Retailers.agent_id.desc().order_by(Retailers.call_priority).order_by(Retailers.next_call_time).with_lockmode("update").first()
|
| 558 |
.filter(or_(Retailers.agent_id==self.agentId, Retailers.agent_id==None))\
|
- |
|
| 559 |
.Retailers.agent_id.desc().order_by(Retailers.call_priority).order_by(Retailers.next_call_time).with_lockmode("update").first()
|
- |
|
| 560 |
|
558 |
|
| 561 |
if retailer is not None:
|
559 |
if retailer is not None:
|
| 562 |
lgr.info( "getRetryRetailer " + str(retailer.id))
|
560 |
lgr.info( "getRetryRetailer " + str(retailer.id))
|
| 563 |
else:
|
561 |
else:
|
| 564 |
if failback:
|
562 |
if failback:
|
| Line 611... |
Line 609... |
| 611 |
while(retry):
|
609 |
while(retry):
|
| 612 |
lgr.info( "Calltype " + self.callType)
|
610 |
lgr.info( "Calltype " + self.callType)
|
| 613 |
status=self.callType
|
611 |
status=self.callType
|
| 614 |
query = session.query(Retailers).filter(Retailers.status==status).filter(or_(Retailers.agent_id==self.agentId, Retailers.agent_id==None))
|
612 |
query = session.query(Retailers).filter(Retailers.status==status).filter(or_(Retailers.agent_id==self.agentId, Retailers.agent_id==None))
|
| 615 |
if status=='fresh':
|
613 |
if status=='fresh':
|
| 616 |
query = query.filter_by(is_or=False, is_std=False).filter(Retailers.pin==Pincodeavailability.code)/
|
- |
|
| 617 |
.filter(Pincodeavailability.amount > 19999).order_by(Retailers.is_elavated.desc(), Retailers.agent_id.desc())
|
614 |
query = query.filter_by(is_or=False, is_std=False).filter(Retailers.pin==Pincodeavailability.code).filter(Pincodeavailability.amount > 19999).order_by(Retailers.is_elavated.desc(), Retailers.agent_id.desc())
|
| 618 |
elif status=='followup':
|
615 |
elif status=='followup':
|
| 619 |
query = query.filter(Retailers.next_call_time<=datetime.now()).order_by(Retailers.agent_id.desc(),Retailers.next_call_time)
|
616 |
query = query.filter(Retailers.next_call_time<=datetime.now()).order_by(Retailers.agent_id.desc(),Retailers.next_call_time)
|
| 620 |
else:
|
617 |
else:
|
| 621 |
query = query.filter(Retailers.modified<=datetime.now()).order_by(Retailers.agent_id.desc(), Retailers.modified)
|
618 |
query = query.filter(Retailers.modified<=datetime.now()).order_by(Retailers.agent_id.desc(), Retailers.modified)
|
| 622 |
|
619 |
|