Subversion Repositories SmartDukaan

        if project_name == 'accs_order':

            if retryFlag:

                user = self.getRetryUser(3)

            else:

                user = self.getNewUser(3)

            if user is None:

                resp.body ={}

            else:        

                user.status =  'assigned'

                user.agent_id = req.get_param("agent_id")

                user.counter=1

                user.modified = datetime.now()

                session.commit()

                resp.body = json.dumps(todict(getUserObject(user)), encoding='utf-8')

                session.close()

        if project_name == 'accs_order':

                jsonReq = json.loads(req.stream.read(), encoding='utf-8')

                lgr.info( "Request ----\n"  + str(jsonReq))

                self.jsonReq = jsonReq

                self.callType="default"

                callLaterAccs = self.callLaterAccs

                accsDisposition = self.accsDisposition

                self.userId = int(jsonReq.get('user_id'))

                try:

                    self.user = session.query(UserCrmCallingData).filter_by(user_id=self.userId).filter(UserCrmCallingData.project_id==2).first()

                    self.callDisposition = jsonReq.get('calldispositiontype')

                    self.callHistoryCrm = CallHistoryCrm()

                    self.callHistoryCrm.agent_id=self.agentId

                    self.callHistoryCrm.project_id = 3

                    self.callHistoryCrm.call_disposition = self.callDisposition

                    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,

                                'internet_issue':accsDisposition,

                                'checking_price':accsDisposition,

                                'order_process':accsDisposition,

                                'placed_order':accsDisposition,

                                'place_order':accsDisposition

                              }

                    returned = dispositionMap[jsonReq.get('calldispositiontype')]()

                finally:

                    session.close()

                if returned:

                    resp.body = "{\"result\":\"success\"}"

                else:

                    resp.body = "{\"result\":\"failed\"}"

    if project_id==3:

        getAccsRepeatUsers(project_id)

def getAccsRepeatUsers(project_id):

    usersMasterList=[]

    ACCS_ALL_ORDERS = "select distinct user_id from allorder where category in ('Accs','Accessories') and store_id='spice';"

    result = fetchResult(ACCS_ALL_ORDERS)

    for r in result:

        usersMasterList.append(r[0])

    ACCS_LAST_FIFTEEN_DAYS = "select distinct user_id from allorder where category in ('Accs','Accessories') and store_id='spice' and (date(created_on) between date(curdate() - interval 15 day) and date(curdate())) order by user_id;"

    result = fetchResult(ACCS_LAST_FIFTEEN_DAYS)

    for r in result:

        if r[0] in usersMasterList:

            usersMasterList.remove(r[0])        

    PRIOPRITIZING_USER_QUERY = "select user_id from allorder where category in ('Accs','Accessories')and store_id ='spice' and user_id in (%s)" % ",".join(map(str,usersMasterList)) + "group by user_id order by sum(amount_paid) desc;"

    userFinalList=[]

    result = fetchResult(PRIOPRITIZING_USER_QUERY)

    for r in result:

        userFinalList.append(r[0])

    counter=0

    for i in userFinalList:

        try:

            userId=i

            if counter==2:

                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)):

                        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

            userMasterData.contact1 = getUserContactDetails(userId)

            userMasterData.counter = 0

            userMasterData.retry_count=0

            userMasterData.invalid_retry_count=0

            userMasterData.created = datetime.now()

            userMasterData.modified = datetime.now()

            userMasterData.status = 'new'

            userMasterData.pincode_servicable = checkPincodeServicable(userId)

            session.commit()

        except:

            print traceback.print_exc()

        finally:

            session.close()