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

 global USER_DETAIL_MAP
 USER_DETAIL_MAP={}
 USER_DETAIL_MAP['accs_cart']=0
 USER_DETAIL_MAP['accs_active']=0
 USER_DETAIL_MAP['accs_order']=0
+USER_DETAIL_MAP['accs_cashback_scheme']=0
 lgr = getLogger('/var/log/retailer-acquisition-api.log')
 DEALER_RETRY_FACTOR = int(PythonPropertyReader.getConfig('DEALER_RETRY_FACTOR'))
 DEALER_FRESH_FACTOR = int(PythonPropertyReader.getConfig('DEALER_FRESH_FACTOR'))
 USER_CRM_DEFAULT_RETRY_FACTOR = int(PythonPropertyReader.getConfig('USER_CRM_DEFAULT_RETRY_FACTOR'))
 USER_CRM_DEFAULT_FRESH_FACTOR = int(PythonPropertyReader.getConfig('USER_CRM_DEFAULT_FRESH_FACTOR'))
         else:
             resp.body = json.dumps({}, encoding='utf-8')
 class GetUserCrmApplication:
     def on_get(self,req,resp):
         global USER_DETAIL_MAP
         project_name = req.get_param("project_name")
         USER_DETAIL_MAP[project_name]+=1
         lgr.info( "USER_DETAIL_CALL_COUNTER " +  str(USER_DETAIL_MAP[project_name]))
             project_id=1
         elif project_name == 'accs_active':
             project_id=2
         elif project_name == 'accs_order':
             project_id=3
+        elif project_name == 'accs_cashback_scheme':
+            project_id=4
         if retryFlag:
             user = self.getRetryUser(project_id)
         else:
             user = self.getNewUser(project_id)
             project_id=1
         elif project_name == 'accs_active':
             project_id=2
         elif project_name == 'accs_order':
             project_id=3
+        elif project_name == 'accs_cashback_scheme':
+            project_id=4
         jsonReq = json.loads(req.stream.read(), encoding='utf-8')
         lgr.info( "Request ----\n"  + str(jsonReq))
         self.jsonReq = jsonReq
         self.callType="default"
         callLaterAccs = self.callLaterAccs
                         'return_replacement':accsOrderDisposition,
                         'already_purchased':accsOrderDisposition,
                         'product_quality_issue':accsOrderDisposition,
                         'delayed_delivery':accsOrderDisposition,
                         'other_complaint':accsOrderDisposition,
+                        'scheme_not_clear':accsOrderDisposition,
                         'not_dealing_accessories':accsOrderDisposition
+                      }
             returned = dispositionMap[jsonReq.get('calldispositiontype')]()
         finally:
             session.close()
             self.callHistoryCrm.disposition_description='Return or replacement pending'
             #utils.sendCrmProjectMail(self.userId,self.callHistoryCrm.disposition_description,self.callHistoryCrm.disposition_comments)
             a.addTicket(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 == 'scheme_not_clear':
+            self.callHistoryCrm.disposition_description='Scheme Not Clear to the User'
         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.userId, self.callHistoryCrm.disposition_description, self.callHistoryCrm.disposition_comments)
         elif self.callDisposition == 'delayed_delivery':
         getCartDetailsUser()
     if project_id==2:
         getCartTabsUser()
     if project_id==3:
         getAccsRepeatUsers(project_id)
+    if project_id==4:
+        getAccsSchemeCashback(project_id)
+def getAccsSchemeCashback(project_id):
+    userMasterMap={}
+    skipUserList=[]
+    query = "select id from users where lower(referrer) in ('emp01','fos01','emp99','emp88')"
+    skipUsersresult = fetchResult(query)
+    for skipUser in skipUsersresult:
+        skipUserList.append(skipUser[0])
+    queryFilter = {"user_id":{"$nin":skipUserList}}
+    result = get_mongo_connection().Catalog.PromoOffer.find(queryFilter)
+    userMasterList =[]
+    for r in result:
+        userMasterList.append(r.get('user_id'))
+    queryfilter ={"url":{"$regex" : "http://api.profittill.com/categories/target"}}
+    result = get_mongo_connection_dtr_data().User.browsinghistories.find(queryfilter).distinct('user_id')
+    userSeenList=[]
+    for r in result:
+        userSeenList.append(r)
+    finalUserList  = list(set(userMasterList) - set(userSeenList))
+    queryFilter = {"user_id":{"$in":finalUserList}}
+    result = get_mongo_connection().Catalog.PromoOffer.find(queryFilter)
+    for r in result:
+        userMasterMap[r.get('user_id')] = r.get('target2')
+    d_sorted = sorted(zip(userMasterMap.values(), userMasterMap.keys()),reverse=True)
+    counter=0
+    for i in d_sorted:
+        try:
+            userId=i[1]
+            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:
+                        continue
+                    elif userPresent.modified.date()>=(datetime.now().date()-timedelta(days=30)):
+                        continue
+                else:
+                    continue
+            counter=counter+1
+            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()
 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)
 def main():
     a = RetailerDetail()
     retailer = a.getNotActiveRetailer()
     otherContacts = [r for r, in session.query(RetailerContacts.mobile_number).filter_by(retailer_id=retailer.id).order_by(RetailerContacts.contact_type).all()]
     print json.dumps(todict(getRetailerObj(retailer, otherContacts, 'fresh')), encoding='utf-8')
-#     a = GetUserCrmApplication()
-#     a.getUser("accs_active", 2)
 if __name__ == '__main__':
     #main()
     print getTinInfo('07740388453')

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/api/Service.py – Rev 19440 → 19442