WebSVN – SmartDukaan – Diff – //trunk/PyDTR/src/dtr/api/Service.py

     def accsOrderDisposition(self):
         self.user.status='done'
         self.user.user_available = 1
         self.user.disposition=self.callDisposition
         self.user.modified = datetime.now()
+        a = CrmTicketDtr()
         if self.callDisposition == 'product_availability':
             self.callHistoryCrm.disposition_description='Product Not available'
         elif self.callDisposition == 'return_replacement':
             self.callHistoryCrm.disposition_description='Return or replacement pending'
             utils.sendCrmProjectMail(self.userId,self.callHistoryCrm.disposition_description,self.callHistoryCrm.disposition_comments)
-            CrmTicketDtr.addTicket(self, self.userId, self.callHistoryCrm.disposition_description, self.callHistoryCrm.disposition_comments)
+            a.addTicket(self, self.userId, self.callHistoryCrm.disposition_description, self.callHistoryCrm.disposition_comments)
         elif self.callDisposition == 'already_purchased':
             self.callHistoryCrm.disposition_description='Already purchased required stock'
         elif self.callDisposition == 'product_quality_issue':
             self.callHistoryCrm.disposition_description='Product Quality issue'
             utils.sendCrmProjectMail(self.userId,self.callHistoryCrm.disposition_description,self.callHistoryCrm.disposition_comments)
+            a.addTicket(self, self.userId, self.callHistoryCrm.disposition_description, self.callHistoryCrm.disposition_comments)
         elif self.callDisposition == 'delayed_delivery':
             self.callHistoryCrm.disposition_description='Delayed Delivery'
             utils.sendCrmProjectMail(self.userId,self.callHistoryCrm.disposition_description,self.callHistoryCrm.disposition_comments)
+            a.addTicket(self, self.userId, self.callHistoryCrm.disposition_description, self.callHistoryCrm.disposition_comments)
         elif self.callDisposition == 'other_complaint':
             self.callHistoryCrm.disposition_description='Other complaint with profitmandi'
             utils.sendCrmProjectMail(self.userId,self.callHistoryCrm.disposition_description,self.callHistoryCrm.disposition_comments)
+            a.addTicket(self, self.userId, self.callHistoryCrm.disposition_description, self.callHistoryCrm.disposition_comments)
         elif self.callDisposition == 'not_dealing_accessories':
             self.callHistoryCrm.disposition_description='Not Dealing in Accessories/Not Interested'
         session.commit()
         jdata = self.inputs
         jdata = json.loads(jdata)
                     if userPresent.project_id==project_id:
                         if userPresent.modified.date()>=(datetime.now().date()-timedelta(days=30)):
                             continue
                         else:
                             pass
-                    elif userPresent.modified.date()>=(datetime.now().date()-timedelta(days=3)):
+                    elif userPresent.modified.date()>=(datetime.now().date()-timedelta(days=30)):
                         continue
                 else:
                     continue
             counter=counter+1
             userMasterData = UserCrmCallingData()
     d_sorted = sorted(zip(userMasterMap.values(), userMasterMap.keys()))
     addUserToTable(d_sorted,2)
 def getUserContactDetails(userId):
+    try:
-    r = session.query(Users.mobile_number).filter_by(id=userId).first()
+        r = session.query(Users.mobile_number).filter_by(id=userId).first()
-    if r is None:
+        if r is None:
-        return None
+            return None
-    else:
+        else:
-        return r[0]
+            return r[0]
+    finally:
+        session.close()
 def getUsername(userId):
+    try:
-    r = session.query(Users.first_name).filter_by(id=userId).first()
+        r = session.query(Users.first_name).filter_by(id=userId).first()
-    if r is None:
+        if r is None:
-        return None
+            return None
-    else:
+        else:
-        return r[0]
+            return r[0]
+    finally:
+        session.close()
 def checkPincodeServicable(userId):
     checkAddressUser = "select distinct pincode from all_user_addresses where user_id= (%s)"
     result = fetchResult(checkAddressUser,userId)
     if len(result)==0:
         return True
         if result ==():
             obj.lastActiveCartTime = None
         else:
             print result
             obj.lastActiveCartTime =datetime.strftime(result[0][0], '%d/%m/%Y %H:%M:%S')
+        conn.close()
-        conn.close()
+    session.close()
     return obj
 class CrmTicketDtr():
     def on_post(self,req,resp):
+        try:
-        customerFeedbackBackMap = {}
+            customerFeedbackBackMap = {}
-        customerFeedbackBackMap['user_id']=req.get_param("user_id")
+            customerFeedbackBackMap['user_id']=req.get_param("user_id")
-        user = session.query(Users).filter_by(id=customerFeedbackBackMap.get('user_id')).first()
+            user = session.query(Users).filter_by(id=customerFeedbackBackMap.get('user_id')).first()
-        if user is not None:
+            if user is not None:
-            customerFeedbackBackMap['email']=user.email
+                customerFeedbackBackMap['email']=user.email
-            customerFeedbackBackMap['mobile_number']=user.mobile_number
+                customerFeedbackBackMap['mobile_number']=user.mobile_number
-            customerFeedbackBackMap['customer_name']=user.first_name + ' ' + user.last_name
+                customerFeedbackBackMap['customer_name']=user.first_name + ' ' + user.last_name
-            customerFeedbackBackMap['subject'] = req.get_param("subject")
+                customerFeedbackBackMap['subject'] = req.get_param("subject")
-            customerFeedbackBackMap['message'] = req.get_param("message")
+                customerFeedbackBackMap['message'] = req.get_param("message")
-            customerFeedbackBackMap['created'] = datetime.now()
+                customerFeedbackBackMap['created'] = datetime.now()
-            if utils.generateCrmTicket(customerFeedbackBackMap):
+                if utils.generateCrmTicket(customerFeedbackBackMap):
-                resp.body={"result":"success"}
+                    resp.body={"result":"success"}
+                else:
+                    resp.body={"result":"failure"}
             else:
                 resp.body={"result":"failure"}
-        else:
+        except:
+            print traceback.print_exc()
+        finally:
-            resp.body={"result":"failure"}
+            session.close()
     def addTicket(self,user_id,subject,message):
+        try:
-        customerFeedbackBackMap = {}
+            customerFeedbackBackMap = {}
-        customerFeedbackBackMap['user_id']=user_id
+            customerFeedbackBackMap['user_id']=user_id
-        user = session.query(Users).filter_by(id=user_id).first()
+            user = session.query(Users).filter_by(id=user_id).first()
-        if user is not None:
+            if user is not None:
-            customerFeedbackBackMap['email']=user.email
+                customerFeedbackBackMap['email']=user.email
-            customerFeedbackBackMap['mobile_number']=user.mobile_number
+                customerFeedbackBackMap['mobile_number']=user.mobile_number
-            customerFeedbackBackMap['customer_name']=user.first_name + ' ' + user.last_name
+                customerFeedbackBackMap['customer_name']=user.first_name + ' ' + user.last_name
-            customerFeedbackBackMap['subject'] = subject
+                customerFeedbackBackMap['subject'] = subject
-            customerFeedbackBackMap['message'] = message
+                customerFeedbackBackMap['message'] = message
-            customerFeedbackBackMap['created'] = datetime.now()
+                customerFeedbackBackMap['created'] = datetime.now()
-            utils.generateCrmTicket(customerFeedbackBackMap)
+                utils.generateCrmTicket(customerFeedbackBackMap)
-        else:
+            else:
-            print 'User is not present'
+                print 'User is not present'
+        except:
+            print traceback.print_exc()
+        finally:
+            session.close()
 class UnitDeal():
     def on_get(self,req,resp, id):
         result = Mongo.getDealById(id)
         resp.body = dumps(result)

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/api/Service.py – Rev 18709 → 18712