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

     def on_get(self, req, resp, storeId, storeSku):
         storeId = int(storeId)
         result = Mongo.getBundleBySourceSku(storeId, storeSku)
         json_docs = json.dumps(result, default=json_util.default)
         resp.body = json_docs
+class GetDtrLinks():
+    def on_get(self, req, resp, agentId, callType, userId):
+        try:
+            self.agentId = int(agentId)
+            self.callType = callType
+            if userId is not None:
+                self.userId = int(userId)
+                users_referrer, = session.query(Users.referrer).filter_by(id=self.userId).first()
+                retailerLink = session.query(RetailerLinks).filter_by(code=users_referrer).first()
+                if retailerLink is not None:
+                    code = retailerLink.code
+                else:
+                    code = self.getNewRandomCode()
+                    retailerLink = RetailerLinks()
+                    retailerLink.code = code
+                    retailerLink.agent_id = self.agentId
+                    retailerLink.retailer_id = None
+                    activationCode=Activation_Codes()
+                    activationCode.code = code
+                    activationCode.status = False
+                    session.commit()
+                session.close()
+                resp.body =  json.dumps({"result":{"code":code,"link":make_tiny(code)}}, encoding='utf-8')
+                return
+        finally:
+            session.close
+    def getNewRandomCode(self,):
+        newCode = None
+        while True:
+            newCode = getNextRandomCode(newcodesys, 6)
+            print 'NewCode',newCode
+            isCodePresent = session.query(Activation_Codes).filter_by(code=newCode).first()
+            if isCodePresent is not None:
+                continue
+            else:
+                break
+        return newCode
 class RetailerDetail():
     global RETAILER_DETAIL_CALL_COUNTER
     def getRetryRetailer(self,failback=True):
         status = RETRY_MAP.get(self.callType)
         retailer = session.query(Retailers).filter_by(status=status).filter(Retailers.next_call_time<=datetime.now()).filter(or_(Retailers.agent_id==self.agentId, Retailers.agent_id==None)).order_by(Retailers.agent_id.desc(),Retailers.call_priority).order_by(Retailers.next_call_time).with_lockmode("update").first()
         invalidNumber = self.invalidNumber
         accsDisposition = self.accsDisposition
         accsOrderDisposition=self.accsOrderDisposition
         otherreason = self.otherreason
         willplaceorder = self.willplaceorder
+        verifiedLinkSent = self.verifiedLinkSent
         orderdiffaccount = self.orderdiffaccount
         businessclosed = self.businessclosed
         appuninstalled = self.appuninstalled
         self.userId = int(jsonReq.get('user_id'))
         try:
                         'business_closed':businessclosed,
                         'invalid_no':invalidNumber,
                         'wrong_no':invalidNumber,
                         'hang_up':invalidNumber,
                         'service_center_retailer':invalidNumber,
-                        'recharge_retailer':invalidNumber
+                        'recharge_retailer':invalidNumber,
+                        'verified_link_sent':verifiedLinkSent
+                      }
             returned = dispositionMap[jsonReq.get('calldispositiontype')]()
         finally:
         if returned:
             resp.body = "{\"result\":\"success\"}"
         else:
             resp.body = "{\"result\":\"failed\"}"
+    def verifiedLinkSent(self,):
+        users_referrer, = session.query(Users.referrer).filter_by(id=self.userId).first()
+        if users_referrer is not None:
+            activationCode=session.query(Activation_Codes).filter_by(code=users_referrer).first()
+            if activationCode is not None:
+                activationCode.status = False
+        self.user.status='done'
+        self.user.modified = datetime.now()
+        self.user.disposition=self.callDisposition
+        if self.callHistoryCrm.disposition_description is not None:
+            self.callHistoryCrm.disposition_description = 'App link sent via ' + self.callHistoryCrm.disposition_description
+        else:
+            self.callHistoryCrm.disposition_description = 'App link sent'
+        session.commit()
+        return True
     def accsOrderDisposition(self):
         self.user.status='done'
         self.user.user_available = 1
         self.user.disposition=self.callDisposition
         self.user.modified = datetime.now()

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/api/Service.py – Rev 20136 → 20147