| Line 8... |
Line 8... |
| 8 |
from email.mime.base import MIMEBase
|
8 |
from email.mime.base import MIMEBase
|
| 9 |
from email.mime.multipart import MIMEMultipart
|
9 |
from email.mime.multipart import MIMEMultipart
|
| 10 |
from email.mime.text import MIMEText
|
10 |
from email.mime.text import MIMEText
|
| 11 |
from shop2020.helpers.impl import DataService
|
11 |
from shop2020.helpers.impl import DataService
|
| 12 |
from shop2020.helpers.impl.DataService import Message, UserEmail, EntitiesShared, \
|
12 |
from shop2020.helpers.impl.DataService import Message, UserEmail, EntitiesShared, \
|
| 13 |
Report, ReportRoleAuthority, CatalogDashboardUser, UserEmailArchive, QuickLink
|
13 |
Report, ReportRoleAuthority, CatalogDashboardUser, UserEmailArchive, QuickLink, \
|
| - |
|
14 |
AgentWarehouseMapping
|
| 14 |
from shop2020.helpers.impl.model.Agent import Agent
|
15 |
from shop2020.helpers.impl.model.Agent import Agent
|
| 15 |
from shop2020.helpers.impl.model.DashboardUser import DashboardUser
|
16 |
from shop2020.helpers.impl.model.DashboardUser import DashboardUser
|
| 16 |
from shop2020.thriftpy.utils.ttypes import HelperServiceException, Mail, \
|
17 |
from shop2020.thriftpy.utils.ttypes import HelperServiceException, Mail, \
|
| 17 |
Message as Msg
|
18 |
Message as Msg
|
| 18 |
from shop2020.utils.Utils import log_entry, to_py_date
|
19 |
from shop2020.utils.Utils import log_entry, to_py_date
|
| Line 243... |
Line 244... |
| 243 |
|
244 |
|
| 244 |
def get_order_delivery_mail(order_id):
|
245 |
def get_order_delivery_mail(order_id):
|
| 245 |
email = UserEmailArchive.get_by(emailType = 'DeliverySuccess', source = order_id)
|
246 |
email = UserEmailArchive.get_by(emailType = 'DeliverySuccess', source = order_id)
|
| 246 |
return email.body
|
247 |
return email.body
|
| 247 |
|
248 |
|
| - |
|
249 |
def get_warehouseIds_for_agent(agent_emailId):
|
| - |
|
250 |
agent = Agent.get_by(emailId = agent_emailId)
|
| - |
|
251 |
agent_warehouse_mappings = AgentWarehouseMapping.query.filter(AgentWarehouseMapping.agentId == agent.id).all()
|
| - |
|
252 |
warehouseIds = []
|
| - |
|
253 |
for mapping in agent_warehouse_mappings:
|
| - |
|
254 |
try:
|
| - |
|
255 |
warehouseIds.append(mapping.warehouseId)
|
| - |
|
256 |
except:
|
| - |
|
257 |
raise HelperServiceException(108, "Exception while getting warehouseIds for Agent")
|
| - |
|
258 |
return warehouseIds
|
| - |
|
259 |
|
| 248 |
def close_session():
|
260 |
def close_session():
|
| 249 |
if session.is_active:
|
261 |
if session.is_active:
|
| 250 |
print "session is active. closing it."
|
262 |
print "session is active. closing it."
|
| 251 |
session.close()
|
263 |
session.close()
|
| 252 |
|
264 |
|