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

                 else:
                     self.user.disposition = 'not_reachable'
                 self.user.retry_count += 1
                 self.user.invalid_retry_count += 1
-            retryConfig = session.query(RetryConfig).filter_by(call_type=self.callType, disposition_type=self.retailer.disposition, retry_count=self.retailer.retry_count).first()
+            #retryConfig = session.query(RetryConfig).filter_by(call_type=self.callType, disposition_type=self.retailer.disposition, retry_count=self.retailer.retry_count).first()
-            if retryConfig is not None:
+            #if retryConfig is not None:
-                self.user.next_call_time = self.callHistoryCrm.call_time + timedelta(minutes = retryConfig.minutes_ahead)
+                #self.user.next_call_time = self.callHistoryCrm.call_time + timedelta(minutes = retryConfig.minutes_ahead)
-                self.callHistory.disposition_description = 'Call scheduled on ' + datetime.strftime(self.retailer.next_call_time, '%d/%m/%Y %H:%M:%S')
+                #self.callHistory.disposition_description = 'Call scheduled on ' + datetime.strftime(self.retailer.next_call_time, '%d/%m/%Y %H:%M:%S')
-            else:
+            #else:
-                self.user.status = 'failed'
+                #self.user.status = 'failed'
-                self.callHistoryCrm.disposition_description = 'Call failed as all attempts exhausted'
+                #self.callHistoryCrm.disposition_description = 'Call failed as all attempts exhausted'
         session.commit()
         return True
 def insertUserCrmData(project_id):
     result = get_mongo_connection_dtr_data().User.browsinghistories.find(queryfilter).distinct('user_id')
     for r in result:
         userList.append(r)
-    myquery = "select user_id from allorder where store_id='spice' and (category='Accs' or category='Accessories') and user_id in (%s)" % ",".join(map(str,userList))
+    myquery = "select a.user_id from allorder a join users u on a.user_id=u.id where a.store_id='spice' and (a.category='Accs' or a.category='Accessories') and u.referrer not like 'emp%%' and u.mobile_number IS NOT NULL and a.user_id in (%s)" % ",".join(map(str,userList)) + " UNION select id from users where lower(referrer) like 'emp%'"
     result = fetchResult(myquery)
     for r in result:
-        orderUserList.append(r)
+        orderUserList.append(r[0])
     finalUserList  = list(set(userList) - set(orderUserList))
     queryfilternew = {"$and":
+                   [
                     {'user_id':{"$in":finalUserList}},
         if(userMasterMap.has_key(i.get('user_id'))):
             if userMasterMap.get(i.get('user_id')) > i.get('created'):
                 userMasterMap[i.get('user_id')]=i.get('created')
         else:
             userMasterMap[i.get('user_id')]=i.get('created')
     d_sorted = sorted(zip(userMasterMap.values(), userMasterMap.keys()))
+    addUserToTable(d_sorted,1)
+def addUserToTable(userList,projectId):
     counter=0
-    for i in d_sorted:
+    for i in userList:
-        if counter==2:
-            break
+        try:
-        userCheck = session.query(UserCrmCallingData).filter_by(user_id=i[1]).filter(UserCrmCallingData.modified<=(datetime.now().date()-timedelta(days=3))).filter(UserCrmCallingData.project_id!=1 or UserCrmCallingData.user_available==1).first()
-        if userCheck is None:
-            counter=counter+1
-            print i[0],i[1],counter
             userId=i[1]
+            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==projectId:
+                        print 'Same project Id'
+                        continue
+                    elif userPresent.modified>=(datetime.now().date()-timedelta(days=3)):
+                        print 'Time lag'
+                        continue
+            counter=counter+1
             userMasterData = UserCrmCallingData()
             userMasterData.user_id = userId
             userMasterData.name =getUsername(userId)
-            userMasterData.project_id = 1
+            userMasterData.project_id = projectId
             userMasterData.user_available=0
             userMasterData.contact1 = getUserContactDetails(userId)
             userMasterData.counter = 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()
+            session.close()
 def getCartTabsUser():
     userList=[]
     orderUserList=[]
     userMasterMap={}
     queryfilter = {"$and":
         result = Mongo.getDealById(id)
         resp.body = dumps(result)
 def main():
     #tagActivatedReatilers()
-    a = RetailerDetail()
+    #a = RetailerDetail()
-    retailer = a.getNotActiveRetailer()
+    #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()]
+    #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')
+    #print json.dumps(todict(getRetailerObj(retailer, otherContacts, 'fresh')), encoding='utf-8')
     #print make_tiny("AA")
+    a = GetUserCrmApplication()
+    a.getUser("accessories", 2)
 if __name__ == '__main__':
     main()

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/api/Service.py – Rev 18296 → 18301