Subversion Repositories SmartDukaan

            global RETAILER_DETAIL_CALL_COUNTER

            RETAILER_DETAIL_CALL_COUNTER += 1

            lgr.info( "RETAILER_DETAIL_CALL_COUNTER " +  str(RETAILER_DETAIL_CALL_COUNTER))

            self.agentId = int(agentId)

            self.callType = callType

            if retailerId is not None:

                self.retailerId = int(retailerId)

                retailerLink = session.query(RetailerLinks).filter_by(retailer_id=self.retailerId).first()

                if retailerLink is not None:

                    code = retailerLink.code

                else: 

                    code = self.getCode()

                    retailerLink = RetailerLinks()

                    retailerLink.code = code

                    retailerLink.agent_id = self.agentId

                    retailerLink.retailer_id = self.retailerId

                    activationCode=Activation_Codes()

                    activationCode.code = code

                    session.commit()

                session.close()

                resp.body =  json.dumps({"result":{"code":code,"link":make_tiny(code)}}, encoding='utf-8')

                return 

            retryFlag = False 

            if RETAILER_DETAIL_CALL_COUNTER % TOTAL >= DEALER_FRESH_FACTOR:

                retryFlag=True

            try:

                if retailer is None:

                    resp.body = "{}"

                    return

                fetchInfo = FetchDataHistory()

                fetchInfo.agent_id = self.agentId

                fetchInfo.call_type = self.callType

                agent = session.query(Agents).filter_by(id=self.agentId).first()

                last_disposition = session.query(CallHistory).filter_by(agent_id=self.agentId).order_by(CallHistory.id.desc()).first()

                if last_disposition is None or last_disposition.created < agent.last_login:

                    fetchInfo.last_action = 'login'

                    fetchInfo.last_action_time = agent.last_login 

                else:

                    fetchInfo.last_action = 'disposition'

                    fetchInfo.last_action_time = last_disposition.created

                fetchInfo.retailer_id = retailer.id

                session.commit()

                otherContacts = [r for r, in session.query(RetailerContacts.mobile_number).filter_by(retailer_id=retailer.id).order_by(RetailerContacts.contact_type).all()]

                resp.body = json.dumps(todict(getRetailerObj(retailer, otherContacts, self.callType)), encoding='utf-8')

                return

            finally:

                session.close()