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

 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(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 = 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==1).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:
+                project_id=1
                 insertUserCrmData(project_id)
-                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 = 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==1).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
+            user.modified = datetime.now()
             session.commit()
             resp.body = json.dumps(todict(getUserObject(user)), encoding='utf-8')
             session.close()
 def insertUserCrmData(project_id):
             userMasterMap[i.get('user_id')]=i.get('created')
     d_sorted = sorted(zip(userMasterMap.values(), userMasterMap.keys()))
     counter=0
     for i in d_sorted:
-        print counter
-        if counter==20:
+        if counter==2:
             break
-        userCheck = session.query(UserCrmCallingData).filter_by(user_id=i[1]).filter(UserCrmCallingData.user_available==1).first()
+        userCheck = session.query(UserCrmCallingData).filter_by(user_id=i[1]).filter(UserCrmCallingData.user_available==1).filter(UserCrmCallingData.modified<=(datetime.now()-timedelta(days=3))).first()
-        print userCheck
         if userCheck is None:
             counter=counter+1
             print i[0],i[1],counter
             userId=i[1]
             userMasterData = UserCrmCallingData()
             userMasterData.user_id = userId
             userMasterData.name =getUsername(userId)
             userMasterData.project_id = 1
-            userMasterData.user_available=0
+            userMasterData.user_available=1
             userMasterData.contact1 = getUserContactDetails(userId)
             userMasterData.counter = 0
             userMasterData.created = datetime.now()
             userMasterData.modified = datetime.now()
             userMasterData.status = 'new'
         obj.last_active = None
     else:
         obj.last_active =datetime.strftime(result[0][1], '%d/%m/%Y %H:%M:%S')
     obj.name = user.name
     obj.contact = user.contact1
-    obj.timeStamp=None
+    obj.lastOrderTimestamp=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()
+    details = session.query(Orders).filter_by(user_id = user.user_id).filter(~Orders.status.in_(['ORDER_NOT_CREATED_KNOWN','ORDER_NOT_CREATED_UNKNOWN', 'ORDER_ALREADY_CREATED_IGNORED'])).order_by(desc(Orders.created)).first()
     if details is None:
-        obj.timeStamp =None
+        obj.lastOrderTimestamp =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()
+    obj.totalOrders = session.query(Orders).filter_by(user_id = user.user_id).filter(~Orders.status.in_(['ORDER_NOT_CREATED_KNOWN','ORDER_NOT_CREATED_UNKNOWN', 'ORDER_ALREADY_CREATED_IGNORED'])).count()
-    cartResult = fetchResult("select * from user_accounts where account_type ='cartId' and user_id=%d"%(user.user_id))
+    cartResult = fetchResult("select account_key from user_accounts where account_type ='cartId' and user_id=%d"%(user.user_id))
     if cartResult == ():
         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]))
+        cursor.execute("select updated_on from cart where id=%s",(cartResult[0][0]))
         result = cursor.fetchall()
         if result ==():
             obj.lastActiveCartTime = None
         else:
             print result
-            obj.lastActiveCartTime =datetime.strftime(result[0][1], '%d/%m/%Y %H:%M:%S')
+            obj.lastActiveCartTime =datetime.strftime(result[0][0], '%d/%m/%Y %H:%M:%S')
         conn.close()
     return obj
 class UnitDeal():
     def on_get(self,req,resp, id):
         result = Mongo.getDealById(id)
         resp.body = dumps(result)
 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()]

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/api/Service.py – Rev 18272 → 18275