CHIEFSOFT\ameye
130 lines
5.0 KiB
Python
130 lines
5.0 KiB
Python
from flask import jsonify
|
|
from app.utils.logger import logger
|
|
from app.api.services.base_service import BaseService
|
|
from sqlalchemy import func, desc
|
|
from app.api.helpers.response_helper import ResponseHelper
|
|
from app.api.schemas.user import UserSchema
|
|
from app.models import Members, MembersProducts
|
|
from app.extensions import db
|
|
|
|
class SubscriptionService(BaseService):
|
|
# def get_all_subscriptions(cls, product_id=None, member_id=None, page=1, limit=20):
|
|
@staticmethod
|
|
def get_subscription_data(filters=None):
|
|
try:
|
|
if filters is None:
|
|
filters = {}
|
|
|
|
# Extract filters
|
|
product_id = filters.get('product_id')
|
|
member_id = filters.get('member_id')
|
|
|
|
# Extract pagination parameters
|
|
page = int(filters.get('page', 1))
|
|
limit = int(filters.get('limit', 20))
|
|
|
|
# Ensure page and limit are valid
|
|
if page < 1:
|
|
page = 1
|
|
if limit < 1 or limit > 100:
|
|
limit = 20
|
|
|
|
membersSubList, total_count = MembersProducts.get_all_subscriptions(product_id,member_id,page,limit)
|
|
# Convert loans to dictionary format
|
|
member_sub_data = []
|
|
for subs in membersSubList:
|
|
member_sub_data.append({
|
|
'id': subs.id,
|
|
'member_id': subs.member_id,
|
|
'product_id': subs.product_id,
|
|
'internal_url': subs.internal_url,
|
|
'external_url': subs.external_url,
|
|
'dns_group': subs.dns_group,
|
|
'status': subs.status,
|
|
'updated': subs.updated,
|
|
"added": subs.added,
|
|
})
|
|
|
|
# Calculate total pages
|
|
total_pages = (total_count + limit - 1) // limit
|
|
|
|
response_data = {
|
|
'subscriptions': member_sub_data,
|
|
'count': len(member_sub_data),
|
|
'pagination': {
|
|
'total_count': total_count,
|
|
'total_pages': total_pages,
|
|
'current_page': page,
|
|
'limit': limit,
|
|
'has_next': page < total_pages,
|
|
'has_prev': page > 1
|
|
}
|
|
}
|
|
|
|
return response_data
|
|
|
|
|
|
|
|
except Exception as e:
|
|
logger.error(f"An error occurred while getting dashboard data: {str(e)}", exc_info=True)
|
|
return jsonify({"message": "Internal Server Error"}), 500
|
|
|
|
@staticmethod
|
|
def subscription_available_products(data):
|
|
try:
|
|
with db.session.begin():
|
|
validated_data = SubscriptionService.validate_data(data, UserSchema())
|
|
token = validated_data.get('token')
|
|
uid = validated_data.get('uid')
|
|
member_data = Members.get_member_by_uid(uid)
|
|
member_id = member_data.id
|
|
|
|
subscription_products_data = {
|
|
"current_product": {
|
|
"display_name": "Subscriptions",
|
|
"subs":[
|
|
'Post Jobs',
|
|
'advanced instructors search',
|
|
'invite candidates',
|
|
'post events',
|
|
'Cancel anythime'
|
|
],
|
|
"next_payment":'2025-10-15 11:00:07.47214'
|
|
|
|
},
|
|
"options": {
|
|
"starter":{
|
|
"package_uid" : "cd2c0a4d-9ad4-472e-96f5-28d10c06916f",
|
|
"display_name" : "Starter",
|
|
"monthly" : 5.99,
|
|
"items" : ['Post Jobs','advanced instructors search','invite candidates','post events',
|
|
'Cancel anythime']
|
|
},
|
|
"basic": {
|
|
"package_uid": "ef2ffa1c-9272-42cd-9d33-0e614047b4f8",
|
|
"display_name": "Basic",
|
|
"monthly": 12.99,
|
|
"items": ['Post Jobs', 'advanced instructors search', 'invite candidates', 'post events',
|
|
'Cancel anythime']
|
|
},
|
|
"premium": {
|
|
"package_uid": "64bf48f6-1e7f-402e-8ff0-76f4ce0f2055",
|
|
"display_name": "Premium",
|
|
"monthly": 20.99,
|
|
"items": ['Post Jobs', 'advanced instructors search', 'invite candidates', 'post events',
|
|
'Cancel anythime']
|
|
},
|
|
}
|
|
}
|
|
|
|
|
|
return ResponseHelper.success(data=subscription_products_data)
|
|
|
|
except Exception as e:
|
|
logger.error(f"An error occurred while getting dashboard data: {str(e)}", exc_info=True)
|
|
return jsonify({"message": "Internal Server Error"}), 500
|
|
|
|
|
|
#
|
|
#
|
|
# |