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

-from bson import json_util
 from bson.json_util import dumps
 from datetime import datetime, timedelta
 from pyshorteners.shorteners  import Shortener
 from dtr import main
 from dtr.config import PythonPropertyReader
 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, UserMasterData
+    Postoffices, UserCrmCallingData
 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,\
 import urllib2
 import uuid
 import gdshortener
 from dtr.dao import AppOfferObj, UserAppBatchDrillDown, UserAppBatchDateDrillDown
 import base64
+import MySQLdb
 alphalist = list(string.uppercase)
 alphalist.remove('O')
 numList = ['1','2','3','4','5','6','7','8','9']
 codesys = [alphalist, alphalist, numList, numList, numList]
 class GetUserCrmApplication:
     def on_get(self,req,resp):
         project_name = req.get_param("project_name")
         if project_name == 'accessories':
+            project_id=1
-            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()
+            user = session.query(UserCrmCallingData).filter_by(project_id=1).filter(or_(UserCrmCallingData.next_call_time<=datetime.now(),UserCrmCallingData.status=='new')).filter(UserCrmCallingData.pincode_servicable==True).filter(UserCrmCallingData.user_available==0).filter(UserCrmCallingData.contact1!=None).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
             #.filter(UserMasterData.modified<=(datetime.now()-timedelta(days=3)))
             if user is None:
+                insertUserCrmData(project_id)
-                fetchUserMasterData()
+                user = session.query(UserCrmCallingData).filter_by(project_id=1).filter(or_(UserCrmCallingData.next_call_time<=datetime.now(),UserCrmCallingData.status=='new')).filter(UserCrmCallingData.pincode_servicable==True).filter(UserCrmCallingData.user_available==0).filter(UserCrmCallingData.contact1!=None).order_by(UserCrmCallingData.next_call_time).order_by(UserCrmCallingData.id).with_lockmode("update").first()
+            user.status =  'assigned'
+            user.agent_id = req.get_param("agent_id")
+            user.user_available= 1
+            user.counter=1
+            session.commit()
-            else:
+            session.close()
-                resp.body = json.dumps(todict(getUserObject(user)), encoding='utf-8')
+            resp.body = json.dumps(todict(getUserObject(user)), encoding='utf-8')
-def fetchUserMasterData():
+def insertUserCrmData(project_id):
-    #First check from the table whether data is present or not UserMasterData
-    #If Data is empty then fetch the details using getCartDetailsUser
+    if project_id==1:
-    getCartDetailsUser()
+        getCartDetailsUser()
 def getCartDetailsUser():
     userList=[]
     orderUserList=[]
     userMasterMap={}
                 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()))
+    counter=0
-    for i in range(0,20):
+    for i in d_sorted:
-        userId=d_sorted[i][1]
+        print counter
-        userMasterData = UserMasterData()
-        userMasterData.user_id = userId
-        userMasterData.project_id = 1
-        userMasterData.contact1 = getUserContactDetails(userId)
-        userMasterData.counter = 0
+        if counter==20:
-        userMasterData.created = datetime.now()
-        userMasterData.modified = datetime.now()
-        userMasterData.status = 'new'
-        userMasterData.pincode_servicable = checkPincodeServicable(userId)
-        session.commit()
+            break
-    session.close()
-def getUserContactDetails(userId):
-    r = session.query(Users.mobile_number).filter_by(id=userId).first()
+        userCheck = session.query(UserCrmCallingData).filter_by(user_id=i[1]).filter(UserCrmCallingData.user_available==1).first()
-    if r is None:
+        print userCheck
-        return None
+        if userCheck is None:
-    else:
-        return r[0]
+            counter=counter+1
-def checkPincodeServicable(userId):
+            print i[0],i[1],counter
-    checkAddressUser = "select distinct pincode from all_user_addresses where user_id= (%s)"
-    result = fetchResult(checkAddressUser,userId)
-    if len(result)==0:
-        return True
+            userId=i[1]
-    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)
+            userMasterData = UserCrmCallingData()
-        if result[0][0]==0:
+            userMasterData.user_id = userId
-            return False
+            userMasterData.name =getUsername(userId)
-        else:
-            return True
+            userMasterData.project_id = 1
-def getUserObject(user):
-    obj = Mock()
-    obj.user_id = user.user_id
+            userMasterData.user_available=0
-    result = fetchResult("select * from useractive where user_id=%d"%(user.user_id))
+            userMasterData.contact1 = getUserContactDetails(userId)
-    if result == ():
-        obj.last_active = None
+            userMasterData.counter = 0
-    else:
-        obj.last_active =datetime.strftime(result[0][1], '%d/%m/%Y %H:%M:%S')
+            userMasterData.created = datetime.now()
-    obj.contact = user.contact1
+            userMasterData.modified = datetime.now()
-    obj.timeStamp=None
+            userMasterData.status = 'new'
-    details = get_mongo_connection().Dtr.merchantOrder.find({"userId":user.user_id}).sort([("createdOn",-1)]).limit(1)
+            userMasterData.pincode_servicable = checkPincodeServicable(userId)
-    for detail in details:
+            session.commit()
-        obj.timeStamp= detail.get('createdOn')
+        session.close()
-    obj.totalOrders = get_mongo_connection().Dtr.merchantOrder.find({"userId":user.user_id}).count()
-    return obj
 def getCartTabsUser():
     userList=[]
     orderUserList=[]
     userMasterMap={}
                 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 getUserContactDetails(userId):
+    r = session.query(Users.mobile_number).filter_by(id=userId).first()
+    if r is None:
+        return None
+    else:
+        return r[0]
+def getUsername(userId):
+    r = session.query(Users.first_name).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')
+    details = session.query(Orders).filter_by(user_id = user.user_id).filter(~Orders.status.in_(['ORDER_NOT_CREATED_KNOWN', 'ORDER_ALREADY_CREATED_IGNORED'])).order_by(desc(Orders.created)).first()
+    if details is None:
+        obj.timeStamp =None
+    else:
+        print details.created
+    obj.totalOrders = session.query(Orders).filter_by(user_id = user.user_id).filter(~Orders.status.in_(['ORDER_NOT_CREATED_KNOWN', 'ORDER_ALREADY_CREATED_IGNORED'])).count()
+    cartResult = fetchResult("select * from user_accounts where account_type ='cartId' and user_id=%d"%(user.user_id))
+    if cartResult == ():
+        obj.obj.lastActiveCartTime = None
+    else:
+        conn = MySQLdb.connect("192.168.190.114", "root","shop2020", "user")
+        cursor = conn.cursor()
+        cursor.execute("select updated_on from cart where id=%s",(cartResult[0][1]))
+        result = cursor.fetchall()
+        if result ==():
+            obj.obj.lastActiveCartTime = None
+        else:
+            print result
+            obj.lastActiveCartTime =datetime.strftime(result[0][1], '%d/%m/%Y %H:%M:%S')
+        conn.close()
+    return obj
 def main():
     #tagActivatedReatilers()
     #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')
     #print make_tiny("AA")
     a = GetUserCrmApplication()
-    a.getUser('accessories')
+    a.getUser('accessories',2)
 if __name__ == '__main__':
     main()

Subversion Repositories SmartDukaan

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