| Line 6... |
Line 6... |
| 6 |
from dtr.config import PythonPropertyReader
|
6 |
from dtr.config import PythonPropertyReader
|
| 7 |
from dtr.storage import Mongo
|
7 |
from dtr.storage import Mongo
|
| 8 |
from dtr.storage.DataService import Retailers, Users, CallHistory, RetryConfig, \
|
8 |
from dtr.storage.DataService import Retailers, Users, CallHistory, RetryConfig, \
|
| 9 |
RetailerLinks, Activation_Codes, Agents, Agent_Roles, AgentLoginTimings, \
|
9 |
RetailerLinks, Activation_Codes, Agents, Agent_Roles, AgentLoginTimings, \
|
| 10 |
FetchDataHistory, RetailerContacts, Orders, OnboardedRetailerChecklists,\
|
10 |
FetchDataHistory, RetailerContacts, Orders, OnboardedRetailerChecklists,\
|
| 11 |
RetailerAddresses
|
11 |
RetailerAddresses, Pincodeavailability
|
| 12 |
from dtr.storage.Mongo import get_mongo_connection
|
12 |
from dtr.storage.Mongo import get_mongo_connection
|
| 13 |
from dtr.storage.Mysql import fetchResult
|
13 |
from dtr.storage.Mysql import fetchResult
|
| 14 |
from dtr.utils import FetchLivePrices, DealSheet as X_DealSheet, \
|
14 |
from dtr.utils import FetchLivePrices, DealSheet as X_DealSheet, \
|
| 15 |
UserSpecificDeals
|
15 |
UserSpecificDeals
|
| 16 |
from dtr.utils.utils import getLogger
|
16 |
from dtr.utils.utils import getLogger
|
| Line 592... |
Line 592... |
| 592 |
while(retry):
|
592 |
while(retry):
|
| 593 |
lgr.info( "Calltype " + self.callType)
|
593 |
lgr.info( "Calltype " + self.callType)
|
| 594 |
status=self.callType
|
594 |
status=self.callType
|
| 595 |
query = session.query(Retailers).filter(Retailers.status==status).filter(or_(Retailers.agent_id==self.agentId, Retailers.agent_id==None))
|
595 |
query = session.query(Retailers).filter(Retailers.status==status).filter(or_(Retailers.agent_id==self.agentId, Retailers.agent_id==None))
|
| 596 |
if status=='fresh':
|
596 |
if status=='fresh':
|
| 597 |
query = query.filter_by(is_or=False, is_std=False).filter(Retailers.cod_limit > 19999).order_by(Retailers.is_elavated.desc(), Retailers.agent_id.desc())
|
597 |
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())
|
| 598 |
elif status=='followup':
|
598 |
elif status=='followup':
|
| 599 |
query = query.filter(Retailers.next_call_time<=datetime.now()).order_by(Retailers.agent_id.desc(),Retailers.next_call_time)
|
599 |
query = query.filter(Retailers.next_call_time<=datetime.now()).order_by(Retailers.agent_id.desc(),Retailers.next_call_time)
|
| 600 |
else:
|
600 |
else:
|
| 601 |
query = query.filter(Retailers.modified<=datetime.now()).order_by(Retailers.agent_id.desc(), Retailers.modified)
|
601 |
query = query.filter(Retailers.modified<=datetime.now()).order_by(Retailers.agent_id.desc(), Retailers.modified)
|
| 602 |
|
602 |
|