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

                 lgr.info( "Request ----\n"  + str(jsonReq))
                 self.jsonReq = jsonReq
                 self.callType="default"
                 callLaterAccs = self.callLaterAccs
                 accsDisposition = self.accsDisposition
+                accsOrderDisposition=self.accsOrderDisposition
                 self.userId = int(jsonReq.get('user_id'))
                 try:
                     self.user = session.query(UserCrmCallingData).filter_by(user_id=self.userId).filter(UserCrmCallingData.project_id==3).first()
                     self.callDisposition = jsonReq.get('calldispositiontype')
                     self.callHistoryCrm = CallHistoryCrm()
                     self.callHistoryCrm.user_id=self.userId
                     self.callHistoryCrm.duration_sec = int(jsonReq.get("callduration"))
                     self.callHistoryCrm.disposition_comments = jsonReq.get('calldispositioncomments')
                     self.callHistoryCrm.call_time = datetime.strptime(jsonReq.get("calltime"), '%d/%m/%Y %H:%M:%S')
                     self.callHistoryCrm.mobile_number = jsonReq.get('number')
-                    self.callHistoryCrm.feedback = jsonReq.get('feedbacks')
                     self.inputs = jsonReq.get("inputs")
                     dispositionMap = {  'call_later':callLaterAccs,
                                 'ringing_no_answer':callLaterAccs,
                                 'not_reachable':callLaterAccs,
                                 'switch_off':callLaterAccs,
                                 'technical_issue':accsDisposition,
                                 'pricing_issue':accsDisposition,
                                 'shipping_issue':accsDisposition,
+                                'product_availability':accsOrderDisposition,
-                                'internet_issue':accsDisposition,
+                                'return_replacement':accsOrderDisposition,
-                                'checking_price':accsDisposition,
+                                'already_purchased':accsOrderDisposition,
-                                'order_process':accsDisposition,
+                                'product_quality_issue':accsOrderDisposition,
-                                'placed_order':accsDisposition,
+                                'delayed_delivery':accsOrderDisposition,
-                                'place_order':accsDisposition
+                                'other_complaint':accsOrderDisposition
+                              }
                     returned = dispositionMap[jsonReq.get('calldispositiontype')]()
                 finally:
                     session.close()
                 if returned:
                     resp.body = "{\"result\":\"success\"}"
                 else:
                     resp.body = "{\"result\":\"failed\"}"
+    def accsOrderDisposition(self):
+        self.user.status='done'
+        self.user.user_available = 1
+        self.user.disposition=self.callDisposition
+        self.user.modified = datetime.now()
+        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'
+        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'
+        elif self.callDisposition == 'delayed_delivery':
+            self.callHistoryCrm.disposition_description='Delayed Delivery'
+        elif self.callDisposition == 'other_complaint':
+            self.callHistoryCrm.disposition_description='Other complaint with profitmandi'
+        session.commit()
+        jdata = self.inputs
+        jdata = json.loads(jdata)
+        if jdata:
+            for d in jdata:
+                for key, value in d.iteritems():
+                    productpricingInputs = ProductPricingInputs()
+                    productpricingInputs.user_id = self.callHistoryCrm.user_id
+                    productpricingInputs.agent_id = self.callHistoryCrm.agent_id
+                    productpricingInputs.disposition_id = self.callHistoryCrm.id
+                    productpricingInputs.user_id = self.callHistoryCrm.user_id
+                    productpricingInputs.call_disposition = self.callHistoryCrm.call_disposition
+                    productpricingInputs.project_id = self.callHistoryCrm.project_id
+                    productpricingInputs.product_input = key
+                    productpricingInputs.pricing_input = value
+            session.commit()
+        return True
     def accsDisposition(self):
         self.user.status='done'
         self.user.user_available = 1
         self.user.disposition=self.callDisposition
         self.user.modified = datetime.now()
     counter=0
     for i in userFinalList:
         try:
             userId=i
-            if counter==2:
+            if counter==20:
                 break
             userPresent = session.query(UserCrmCallingData).filter_by(user_id=userId).order_by(desc(UserCrmCallingData.modified)).first()
             if userPresent is not None:
                 if userPresent.user_available==1:
                     if userPresent.project_id==project_id:
                         if userPresent.modified.date()>=(datetime.now().date()-timedelta(days=30)):
                             continue
                         else:
                             pass
-                    elif userPresent.modified>=(datetime.now().date()-timedelta(days=3)):
+                    elif userPresent.modified.date()>=(datetime.now().date()-timedelta(days=3)):
                         continue
                 else:
                     continue
             counter=counter+1
-            lgr.info("Counter while adding",str(counter))
             userMasterData = UserCrmCallingData()
             userMasterData.user_id = userId
             userMasterData.name =getUsername(userId)
             userMasterData.project_id = project_id
             userMasterData.user_available=0
             userPresent = session.query(UserCrmCallingData).filter_by(user_id=userId).order_by(desc(UserCrmCallingData.modified)).first()
             if userPresent is not None:
                 if userPresent.user_available==1:
                     if userPresent.project_id==projectId:
                         continue
-                    elif userPresent.modified>=(datetime.now().date()-timedelta(days=3)):
+                    elif userPresent.modified.date()>=(datetime.now().date()-timedelta(days=3)):
                         continue
                 else:
                     continue
             counter=counter+1
-            lgr.info("Counter while adding",str(counter))
             userMasterData = UserCrmCallingData()
             userMasterData.user_id = userId
             userMasterData.name =getUsername(userId)
             userMasterData.project_id = projectId
             userMasterData.user_available=0

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/api/Service.py – Rev 18623 → 18628