put in the customer rate

gamification/logic.py

@@ -1,11 +1,47 @@
 
-from gamification.objects import UserFeedback, UserLevel, UserPoints
+from gamification.objects import UserFeedback, UserLevel, UserPoints,CustomerInfo,Customer
 from bson import ObjectId
 from pymongo import MongoClient
 import os
 from typing import List
 from dotenv import load_dotenv
+from datetime import datetime,timedelta
 load_dotenv()
+
+# Normal Math
+def caculate_rate_change_func(c0,c1,days_ago):
+    if c0 == 0:
+        if c1 > 0:
+            # If there are customers now, but no customers initially (c0 is 0), 
+            # we consider it as infinite growth or 100% growth
+            return {"daysAgo":days_ago,"totalCustomers": c1, "GrowthRate": 100, "GrowthRateType": "positive"}
+        elif c1 == 0:
+            # If both c0 and c1 are zero, there is no change
+            return {"daysAgo":days_ago,"totalCustomers": c1, "GrowthRate": 0.0, "GrowthRateType": "neutral"}
+        else:
+            # This case is for when c1 < 0, but it's unlikely in a customer count scenario.
+            return {"daysAgo":days_ago,"totalCustomers": c1, "GrowthRate": -100, "GrowthRateType": "negative"}
+    
+    elif c1 > c0:
+        # Positive growth rate: c1 > c0
+        e = c1 - c0
+        b = e / c0
+        d = b * 100
+        return {"daysAgo":days_ago,"totalCustomers": c1, "GrowthRate": d, "GrowthRateType": "positive"}
+    
+    elif c1 < c0:
+        # Negative growth rate: c1 < c0
+        e = c0 - c1
+        b = e / c0
+        d = b * 100
+        return {"daysAgo":days_ago,"totalCustomers": c1, "GrowthRate": d, "GrowthRateType": "negative"}        
+    
+    elif c1 == c0:
+        # No change: c1 == c0
+        return {"daysAgo":days_ago,"totalCustomers": c1, "GrowthRate": 0.0, "GrowthRateType": "neutral"}
+
+
+
 MONGO_URI = os.getenv("MONGO_URI")
 
     
@@ -208,3 +244,40 @@ def get_all_feedback_func() -> List[UserFeedback]:
 
 
 
+
+def get_all_customer_info()->List[CustomerInfo]:
+    db_uri = "mongodb+srv://groupcresearchseminar:[email protected]/?retryWrites=true&w=majority&appName=Cluster0"
+    db_name = "crayonics"
+    collection_name = "users"
+    client = MongoClient(db_uri)
+    db = client[db_name]
+    collection = db[collection_name]
+    
+    # Fetch all documents from the collection
+    customer_cursor = collection.find()  # This returns a cursor to the documents
+    
+    # Convert the cursor to a list of Customer objects, setting a default date_Joined if it's missing
+    customers = []
+    customer_info = []
+    for customer in customer_cursor:
+        # If date_Joined is missing, add the default value (current datetime)
+        if 'date_Joined' not in customer:
+            print("adding a new date")
+            customer['date_Joined'] = datetime.now()
+            collection.update_one(filter={"_id":ObjectId(customer['_id'])},update={"$set":customer})
+        
+        customers.append(Customer(**customer))  # Create Customer model with the filled data
+    dt_now = datetime.now()
+    thirty_days_ago = dt_now - timedelta(days=30)
+    sixty_days_ago = dt_now - timedelta(days=60)
+    ninty_days_ago = dt_now - timedelta(days=90)
+    all_customer_from_30_days_ago = [customer for customer in customers if customer.date_Joined <=thirty_days_ago]
+    all_customer_from_60_days_ago = [customer for customer in customers if customer.date_Joined <=sixty_days_ago]
+    all_customer_from_90_days_ago = [customer for customer in customers if customer.date_Joined <=ninty_days_ago]
+    rate_30_days = caculate_rate_change_func(c0=len(all_customer_from_30_days_ago),c1=len(customers),days_ago=30)
+    rate_60_days = caculate_rate_change_func(c0=len(all_customer_from_60_days_ago),c1=len(customers),days_ago=60)
+    rate_90_days = caculate_rate_change_func(c0=len(all_customer_from_90_days_ago),c1=len(customers),days_ago=90)
+    list_of_rates= [rate_30_days,rate_60_days,rate_90_days]
+    for rate in list_of_rates:
+        customer_info.append(CustomerInfo(**rate))
+    return customer_info

gamification/objects.py

@@ -1,3 +1,4 @@
+from datetime import datetime
 from pydantic import BaseModel
 from bson import ObjectId
 class UserLevel(BaseModel):
@@ -29,7 +30,30 @@ class UserFeedback(BaseModel):
         json_encoders = {
             ObjectId: str
         }
-
+        
+class Customer(BaseModel):
+    email:str
+    first_name:str
+    last_name:str
+    date_Joined: datetime 
+    class Config:
+        json_encoders = {
+            ObjectId: str
+        }
+        
+        
+        
+class CustomerInfo(BaseModel):
+    totalCustomers:int
+    GrowthRate: float
+    GrowthRateType:str
+    daysAgo:int
+    class Config:
+        json_encoders = {
+            ObjectId: str
+        }
+    
+    
 class IndividualUserLevel(BaseModel):
     totalpoints:int
     userId:str

gamification/routes.py

@@ -36,6 +36,14 @@ def create_feedback(user_feedback:UserFeedback)->bool:
 def get_leaderboard_details():
     pass
 
+@gamification.get("/get-customer-info",tags=["admin"])
+def get_customer_information():
+    try:
+        result = get_all_customer_info()
+        return result
+    except Exception as e:
+        raise HTTPException(status_code=500,detail=f"{e}")
+    
 
 @gamification.get("/get-feedback",tags=["admin"])
 def get_feedback()->List[UserFeedback]:

utils.py

@@ -1,5 +1,6 @@
 from bson import ObjectId
 import json
+from datetime import datetime
 import requests
 from pymongo import MongoClient
 from password import *
@@ -137,6 +138,7 @@ def create_user(db_uri: str, db_name: str, collection_name: str, document: dict)
     s = collection.find_one({"email":document.get('email')})
     password = hash_password(document.get('password'))
     document['password']= password
+    document['date_Joined'] = datetime.now()
     if s==None:
         result = collection.insert_one(document)