Subversion Repositories SmartDukaan

Rev

Rev 5055 | Rev 5864 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
353 ashish 1 
'''
2 
Created on 14-Jul-2010
3 
 
4 
@author: ashish
5 
'''
4691 mandeep.dh 6 
from shop2020.config.client.ConfigClient import ConfigClient
353 ashish 7 
from shop2020.helpers.impl import DataAccessor
4691 mandeep.dh 8 
from shop2020.helpers.impl.Converters import to_t_luser, to_t_useremail, \
4806 varun.gupt 9 
    to_t_suser, to_t_ruser, to_t_report, to_t_catalog_user, to_t_quicklink
4691 mandeep.dh 10 
from shop2020.helpers.impl.DataAccessor import getSubstitutedMessage, getMessage, \
4806 varun.gupt 11 
    updateMessage, addMessage, add_user, delete_user, update_password, share_entities, \
4691 mandeep.dh 12 
    save_user_email_for_sending, get_emails_to_be_sent, mark_email_as_sent, \
4806 varun.gupt 13 
    initialize, close_session, get_reports, authenticate_dashboard_user, is_alive,\
5110 mandeep.dh 14 
    save_quick_link, get_quick_links, update_quicklink, \
15 
    get_emails_for_notifications_sent, update_password_for_agent
4691 mandeep.dh 16 
from shop2020.helpers.impl.DataService import LogisticsUser, StatisticsUser, \
2025 ankur.sing 17 
    ReportUser, CatalogDashboardUser
4754 mandeep.dh 18 
from shop2020.helpers.impl.model.Agent import Agent, User_Roles, Roles_Permissions
759 chandransh 19 
from shop2020.thriftpy.utils.ttypes import HelperServiceException
5055 varun.gupt 20 
from shop2020.utils.Utils import to_py_date
353 ashish 21 
 
900 rajveer 22 
 
353 ashish 23 
class HelperServiceHandler():
24 
 
25 
 
3187 rajveer 26 
    def __init__(self, dbname='helper', db_hostname='localhost'):
27 
        initialize(dbname, db_hostname)
900 rajveer 28 
 
29 
        '''
30 
        try:
31 
            config_client = ConfigClient()
32 
            self.customer_care_mail = config_client.get_property('saholic_customer_care_mail')
33 
        except:
34 
            self.customer_care_mail = "help@saholic.com"
35 
        '''
353 ashish 36 
 
1395 varun.gupt 37 
    def saveUserEmailForSending(self, emailTo, emailFrom, subject, body, source, emailType):
38 
        try:
3206 mandeep.dh 39 
            return save_user_email_for_sending(emailTo, emailFrom, subject, body, source, emailType)
1395 varun.gupt 40 
        finally:
41 
            close_session()
42 
 
3086 rajveer 43 
    def getEmailsToBeSent(self):
1422 varun.gupt 44 
        try:
3086 rajveer 45 
            return [to_t_useremail(user_email) for user_email in get_emails_to_be_sent()]
1422 varun.gupt 46 
        finally:
47 
            close_session()
48 
 
49 
    def markEmailAsSent(self, emailId):
50 
        try:
51 
            mark_email_as_sent(emailId)
52 
        finally:
53 
            close_session()
54 
 
353 ashish 55 
    def sendMail(self, mail):
766 rajveer 56 
        try:
57 
            DataAccessor.sendMail(mail)
58 
        finally:
59 
            close_session()
60 
 
353 ashish 61 
    def sendText(self, message):
62 
        """
63 
        Parameters:
64 
         - message
65 
        """
766 rajveer 66 
        try:
67 
            DataAccessor.sendText(message)
68 
        finally:
69 
            close_session()
70 
 
353 ashish 71 
    def addMessage(self, message):
72 
        """
73 
        Parameters:
74 
         - message
75 
        """
766 rajveer 76 
        try:
77 
            addMessage(message)
78 
        finally:
79 
            close_session()
80 
 
353 ashish 81 
    def updateMessage(self, id, message):
82 
        """
83 
        Parameters:
84 
         - id
85 
         - message
86 
        """
766 rajveer 87 
        try:
88 
            return updateMessage(id, message)
89 
        finally:
90 
            close_session()
91 
 
353 ashish 92 
    def getMessage(self, id):
93 
        """
94 
        Parameters:
95 
         - id
96 
        """
766 rajveer 97 
        try:
98 
            return getMessage(id)
99 
        finally:
100 
            close_session()
101 
 
353 ashish 102 
    def getSubstitutedMessage(self, id, params):
103 
        """
104 
        Parameters:
105 
         - id
106 
         - params
107 
        """
766 rajveer 108 
        try:
109 
            return getSubstitutedMessage(id, params)
110 
        finally:
111 
            close_session()
112 
 
494 rajveer 113 
    def addUser(self, username, password, warehouseId):
114 
        """
115 
        Parameters:
116 
         - username
117 
         - password
118 
         - warehouseId
119 
        """
766 rajveer 120 
        try:
121 
            return add_user(username, password, warehouseId)
122 
        finally:
123 
            close_session()
494 rajveer 124 
 
125 
    def deleteUser(self, username):
126 
        """
127 
        Parameters:
128 
         - username
129 
        """
766 rajveer 130 
        try:
131 
            return delete_user(username)
132 
        finally:
133 
            close_session()
134 
 
2445 chandransh 135 
    def authenticateDashboardUser(self, username, password):
494 rajveer 136 
        """
2445 chandransh 137 
        Returns the dashboard user if the supplied username and password match. Raises an exception otherwise.
138 
        The loggedOn timestamp for the dashboard user is updated .
139 
 
494 rajveer 140 
        Parameters:
141 
         - username
142 
         - password
143 
        """
766 rajveer 144 
        try:
2445 chandransh 145 
            return authenticate_dashboard_user(username, password)
766 rajveer 146 
        finally:
147 
            close_session()
148 
 
494 rajveer 149 
 
150 
    def updatePassword(self, username, oldPassword, newPassword):
151 
        """
152 
        Parameters:
153 
         - username
154 
         - oldPassword
155 
         - newPassword
156 
        """
766 rajveer 157 
        try:
158 
            update_password(username, oldPassword, newPassword)
159 
        finally:
160 
            close_session()
759 chandransh 161 
 
162 
    def authenticateLogisticsUser(self, username, password):
163 
        """
164 
        Returns the LogisticsUser struct associated with the given username and password if they match.
165 
        Throws an exception otherwise.
166 
 
167 
        Parameters:
168 
         - username
169 
         - password
170 
        """
171 
        try:
172 
            luser = LogisticsUser.get_by(username=username, password=password)
173 
            return to_t_luser(luser)
174 
        except:
766 rajveer 175 
            raise HelperServiceException(101, "No such user")
176 
        finally:
177 
            close_session()
178 
 
1610 ankur.sing 179 
    def authenticateStatisticsUser(self, username, password):
180 
        """
181 
        Returns the StatisticsUser struct associated with the given username and password if they match.
182 
        Throws an exception otherwise.
183 
 
184 
        Parameters:
185 
         - username
186 
         - password
187 
        """
188 
        try:
189 
            suser = StatisticsUser.get_by(username=username, password=password)
190 
            return to_t_suser(suser)
191 
        except:
192 
            raise HelperServiceException(101, "No such user")
193 
        finally:
194 
            close_session()
195 
 
1891 ankur.sing 196 
    def authenticateReportUser(self, username, password):
197 
        """
198 
        Returns the ReportUser struct associated with the given username and password if they match.
199 
        Throws an exception otherwise.
200 
 
201 
        Parameters:
202 
         - username
203 
         - password
204 
        """
205 
        try:
206 
            ruser = ReportUser.get_by(username=username, password=password)
207 
            return to_t_ruser(ruser)
208 
        except:
209 
            raise HelperServiceException(101, "No such user")
210 
        finally:
211 
            close_session()
212 
 
213 
    def getReports(self, role):
214 
        """
215 
        Returns list of reports which are configured for the given role.
216 
 
217 
        Parameters:
218 
         - role
219 
        """
220 
        try:
221 
            reports = get_reports(role)
222 
            return [to_t_report(report) for report in reports]
223 
        finally:
224 
            close_session()
2025 ankur.sing 225 
 
2358 ankur.sing 226 
    def authenticateCatalogUser(self, username, password, role):
2025 ankur.sing 227 
        """
228 
        Returns the CatalogDashboardUser struct associated with the given username and password if they match.
229 
        Throws an exception otherwise.
230 
 
231 
        Parameters:
232 
         - username
233 
         - password
234 
        """
235 
        try:
2358 ankur.sing 236 
            catalog_user = CatalogDashboardUser.get_by(username=username, password=password, role=role)
2025 ankur.sing 237 
            return to_t_catalog_user(catalog_user)
238 
        except:
239 
            raise HelperServiceException(101, "No such catalog user")
240 
        finally:
4806 varun.gupt 241 
            close_session()
242 
 
243 
    def shareEntities(self, entityIds, email):
244 
        '''
245 
        Shares the entities with en email
246 
 
247 
        Parameters:
248 
         - entityIds
249 
         - email
250 
        '''
251 
        try:
252 
            share_entities(entityIds, email)
253 
        finally:
254 
            close_session()
4691 mandeep.dh 255 
 
256 
    def getAgents(self, ):
257 
        return [Agent.to_thrift_object(t) for t in Agent.query.all()]
258 
 
259 
    def validateLogIn(self, emailId, password):
260 
        """
261 
        Parameters:
262 
         - emailId
263 
         - password
264 
        """
265 
        pass
266 
 
267 
    def updatePasswordForAgent(self, agentEmailId, password):
268 
        """
269 
        Parameters:
270 
         - agentEmailId
271 
         - password
272 
        """
5110 mandeep.dh 273 
        try:
274 
            update_password_for_agent(agentEmailId, password)
275 
        finally:
276 
            close_session()
4691 mandeep.dh 277 
 
278 
    def getRoleNamesForAgent(self, agentEmailId):
279 
        """
280 
        Parameters:
281 
         - agentEmailId
282 
        """
4754 mandeep.dh 283 
        try:
284 
            agent = Agent.get_by(emailId = agentEmailId)
285 
            return [a.role_name for a in User_Roles.query.filter_by(agentId = agent.id).all()]
286 
        finally:
287 
            close_session()
4691 mandeep.dh 288 
 
289 
    def getPermissionsForRoleName(self, roleName):
290 
        """
291 
        Parameters:
292 
         - roleName
293 
        """
4754 mandeep.dh 294 
        try:
295 
            return [a.permission for a in Roles_Permissions.query.filter_by(role_name = roleName).all()]
296 
        finally:
297 
            close_session()
1610 ankur.sing 298 
 
4806 varun.gupt 299 
    def saveQuickLink(self, url, text):
300 
        try:
301 
            save_quick_link(url, text)
302 
        finally:
303 
            close_session()
304 
 
305 
    def getQuickLinks(self):
306 
        try:
307 
            return [to_t_quicklink(quicklink) for quicklink in get_quick_links()]
308 
        finally:
309 
            close_session()
310 
 
4996 varun.gupt 311 
    def updateQuickLink(self, id, url, text):
312 
        try:
313 
            update_quicklink(id, url, text)
314 
        finally:
315 
            close_session()
5055 varun.gupt 316 
 
317 
    def getEmailsForNotificationsSent(self, startDatetime, endDatetime):
318 
        '''
319 
        '''
320 
        try:
321 
            return [notification.emailTo for notification in get_emails_for_notifications_sent(to_py_date(startDatetime), to_py_date(endDatetime))]
322 
        finally:
323 
            close_session()
324 
 
766 rajveer 325 
    def closeSession(self, ):
3376 rajveer 326 
        close_session()
327 
 
328 
    def isAlive(self, ):
329 
        """
330 
        For checking weather service is active alive or not. It also checks connectivity with database
331 
        """
332 
        try:
333 
            return is_alive()
334 
        finally:
335 
            close_session()