diff --git a/app/api/services/account.py b/app/api/services/account.py index 25c2880..4498894 100644 --- a/app/api/services/account.py +++ b/app/api/services/account.py @@ -3,7 +3,8 @@ from app.utils.logger import logger from app.api.services.base_service import BaseService from marshmallow import ValidationError from app.extensions import db -from app.models import Members, MembersActions, MembersProfile, Payments, MembersProducts, ProvisionActions +from app.models import Members, MembersActions, MembersProfile, Payments, MembersProducts, ProvisionActions, \ + ProductsContacts from app.api.helpers.response_helper import ResponseHelper from app.api.schemas.user import UserSchema from app.api.schemas.start_profile import StartProfileSchema @@ -57,6 +58,8 @@ class AccountService(BaseService): user_token = validated_data.get('token') uid = str(validated_data.get('uid')) member_data = Members.get_member_by_uid(uid) + logger.error(f"Member_Data ID ::: {member_data.id}") + member_id = member_data.id option_name = member_data.option_name # "Free Trial" if option_name is not None and option_name != "": @@ -68,11 +71,13 @@ class AccountService(BaseService): next_bill = f"Ends: {member_data.trial_end}" view_sub = "Upgrade Account" bill_style = " billing " - - contacts_count = 0 # random.randint(0, 10) +# int(member_data.id) + contacts_count = ProductsContacts.get_member_contact_count(member_id,90) + # contacts_count = 0 # random.randint(0, 10) appointments_count = 0 site_traffic_count = 0 + bar_data = { "last_update": datetime.datetime.utcnow(), "top_bar": [ diff --git a/app/models/products_contacts.py b/app/models/products_contacts.py index 87b959f..0c05863 100644 --- a/app/models/products_contacts.py +++ b/app/models/products_contacts.py @@ -63,6 +63,14 @@ class ProductsContacts(db.Model): raise ValueError(f"Database integrity error: {err}") return product_contact_data + @classmethod + def get_member_contact_count(cls,member_id, day_limit): + logger.info(f"Counting Contact Data {member_id} for {day_limit} days -- ") + query = cls.query + query = query.filter(cls.member_id == member_id) + total_count = query.count() + return total_count + @classmethod def get_all_contacts(cls,member_id, page=1, limit=20):