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

 from dtr.storage import Mongo
 from dtr.storage.DataService import Retailers, Users, CallHistory, RetryConfig, \
     RetailerLinks, Activation_Codes, Agents, Agent_Roles, AgentLoginTimings, \
     FetchDataHistory, RetailerContacts, Orders, OnboardedRetailerChecklists,\
     RetailerAddresses, Pincodeavailability, app_offers, appmasters, user_app_cashbacks, user_app_installs,\
-    Postoffices
+    Postoffices, UserMasterData
 from dtr.storage.Mongo import get_mongo_connection
 from dtr.storage.Mysql import fetchResult
 from dtr.utils import FetchLivePrices, DealSheet as X_DealSheet, \
     UserSpecificDeals
-from dtr.utils.utils import getLogger,encryptMessage,decryptMessage
+from dtr.utils.utils import getLogger,encryptMessage,decryptMessage,\
+    get_mongo_connection_dtr_data, to_java_date
 from elixir import *
 from operator import and_
 from sqlalchemy.sql.expression import func, func, or_, desc, asc, case
 from urllib import urlencode
 import contextlib
         if classkey is not None and hasattr(obj, "__class__"):
             data[classkey] = obj.__class__.__name__
         return data
     else:
         return obj
 def getRetailerObj(retailer, otherContacts1=None, callType=None):
     print "before otherContacts1",otherContacts1
     otherContacts = [] if otherContacts1 is None else otherContacts1
     print "after otherContacts1",otherContacts
     obj = Mock()
             decrypted_data = decryptMessage(decryption_data)
             resp.body =  json.dumps({"result":{"value":decrypted_data}}, encoding='utf-8')
         else:
             resp.body = json.dumps({}, encoding='utf-8')
+class GetUserCrmApplication:
+    def on_get(self,req,resp):
+        project_name = req.get_param("project_name")
+        if project_name == 'accessories':
+            user = session.query(UserMasterData).filter_by(project_id=1).filter(or_(UserMasterData.next_call_time<=datetime.now(),UserMasterData.status=='new')).filter(UserMasterData.pincode_servicable==True).order_by(UserMasterData.next_call_time).order_by(UserMasterData.id).with_lockmode("update").first()
+            #.filter(UserMasterData.modified<=(datetime.now()-timedelta(days=3)))
+            if user is None:
+                fetchUserMasterData()
+            else:
+                resp.body = json.dumps(todict(getUserObject(user)), encoding='utf-8')
+def fetchUserMasterData():
+    #First check from the table whether data is present or not UserMasterData
+    #If Data is empty then fetch the details using getCartDetailsUser
+    getCartDetailsUser()
+def getCartDetailsUser():
+    userList=[]
+    orderUserList=[]
+    userMasterMap={}
+    queryfilter = {"$and":
+                   [
+                    {'created':{"$gte":(to_java_date(datetime.now())-5*86400000)}},
+                    {'created':{"$lte":(to_java_date(datetime.now())- 43200000)}},
+                    {"url":{"$regex" : "http://api.profittill.com/cartdetails"}}
+                    ]
+                   }
+    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))
+    result = fetchResult(myquery)
+    for r in result:
+        orderUserList.append(r)
+    finalUserList  = list(set(userList) - set(orderUserList))
+    queryfilternew = {"$and":
+                   [
+                    {'user_id':{"$in":finalUserList}},
+                    {'created':{"$gte":(to_java_date(datetime.now())-5*86400000)}},
+                    {'created':{"$lte":(to_java_date(datetime.now())- 43200000)}},
+                    {"url":{"$regex" : "http://api.profittill.com/cartdetails"}}
+                    ]
+                   }
+    itemIds = list(get_mongo_connection_dtr_data().User.browsinghistories.find(queryfilternew))
+    for i in itemIds:
+        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()))
+    for i in range(0,20):
+        userId=d_sorted[i][1]
+        userMasterData = UserMasterData()
+        userMasterData.user_id = userId
+        userMasterData.project_id = 1
+        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()
+    session.close()
+def getUserContactDetails(userId):
+    r = session.query(Users.mobile_number).filter_by(id=userId).first()
+    if r is None:
+        return None
+    else:
+        return r[0]
+def checkPincodeServicable(userId):
+    checkAddressUser = "select distinct pincode from all_user_addresses where user_id= (%s)"
+    result = fetchResult(checkAddressUser,userId)
+    if len(result)==0:
+        return True
+    else:
+        myquery = "select count(*) from (select distinct pincode from all_user_addresses where user_id= (%s))a join pincodeavailability p on a.pincode=p.code"
+        result = fetchResult(myquery,userId)
+        if result[0][0]==0:
+            return False
+        else:
+            return True
+def getUserObject(user):
+    obj = Mock()
+    obj.user_id = user.user_id
+    result = fetchResult("select * from useractive where user_id=%d"%(user.user_id))
+    if result == ():
+        obj.last_active = None
+    else:
+        obj.last_active =datetime.strftime(result[0][1], '%d/%m/%Y %H:%M:%S')
+    obj.contact = user.contact1
+    obj.timeStamp=None
+    details = get_mongo_connection().Dtr.merchantOrder.find({"userId":user.user_id}).sort([("createdOn",-1)]).limit(1)
+    for detail in details:
+        obj.timeStamp= detail.get('createdOn')
+    obj.totalOrders = get_mongo_connection().Dtr.merchantOrder.find({"userId":user.user_id}).count()
+    return obj
+def getCartTabsUser():
+    userList=[]
+    orderUserList=[]
+    userMasterMap={}
+    queryfilter = {"$and":
+                   [
+                    {'created':{"$gte":(to_java_date(datetime.now())-2*86400000)}},
+                    {'created':{"$lte":(to_java_date(datetime.now())- 43200000)}},
+                    {"url":{"$regex" : "http://api.profittill.com/category/6"}}
+                    ]
+                   }
+    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))
+    result = fetchResult(myquery)
+    for r in result:
+        orderUserList.append(r)
+    finalUserList  = list(set(userList) - set(orderUserList))
+    queryfilternew = {"$and":
+                   [
+                    {'user_id':{"$in":finalUserList}},
+                    {'created':{"$gte":(to_java_date(datetime.now())-2*86400000)}},
+                    {'created':{"$lte":(to_java_date(datetime.now())- 43200000)}},
+                    {"url":{"$regex" : "http://api.profittill.com/category/6"}}
+                    ]
+                   }
+    itemIds = list(get_mongo_connection_dtr_data().User.browsinghistories.find(queryfilternew))
+    for i in itemIds:
+        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()))
 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')
 if __name__ == '__main__':
     main()

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/api/Service.py – Rev 18101 → 18256