diff --git a/AUTH_FOOTER_INTEGRATION.md b/docs/AUTH_FOOTER_INTEGRATION.md
similarity index 100%
rename from AUTH_FOOTER_INTEGRATION.md
rename to docs/AUTH_FOOTER_INTEGRATION.md
diff --git a/CALENDAR_FEATURE_README.md b/docs/CALENDAR_FEATURE_README.md
similarity index 100%
rename from CALENDAR_FEATURE_README.md
rename to docs/CALENDAR_FEATURE_README.md
diff --git a/CALENDAR_SWITCHER_ICON_ONLY.md b/docs/CALENDAR_SWITCHER_ICON_ONLY.md
similarity index 100%
rename from CALENDAR_SWITCHER_ICON_ONLY.md
rename to docs/CALENDAR_SWITCHER_ICON_ONLY.md
diff --git a/CALENDAR_SWITCHER_MULTILINGUAL.md b/docs/CALENDAR_SWITCHER_MULTILINGUAL.md
similarity index 100%
rename from CALENDAR_SWITCHER_MULTILINGUAL.md
rename to docs/CALENDAR_SWITCHER_MULTILINGUAL.md
diff --git a/CALENDAR_SWITCHER_REDESIGN.md b/docs/CALENDAR_SWITCHER_REDESIGN.md
similarity index 100%
rename from CALENDAR_SWITCHER_REDESIGN.md
rename to docs/CALENDAR_SWITCHER_REDESIGN.md
diff --git a/CALENDAR_SWITCHER_UPDATE.md b/docs/CALENDAR_SWITCHER_UPDATE.md
similarity index 100%
rename from CALENDAR_SWITCHER_UPDATE.md
rename to docs/CALENDAR_SWITCHER_UPDATE.md
diff --git a/FLUTTER_MIRROR_SETUP.md b/docs/FLUTTER_MIRROR_SETUP.md
similarity index 100%
rename from FLUTTER_MIRROR_SETUP.md
rename to docs/FLUTTER_MIRROR_SETUP.md
diff --git a/FLUTTER_WEB_TROUBLESHOOTING.md b/docs/FLUTTER_WEB_TROUBLESHOOTING.md
similarity index 100%
rename from FLUTTER_WEB_TROUBLESHOOTING.md
rename to docs/FLUTTER_WEB_TROUBLESHOOTING.md
diff --git a/JALALI_CALENDAR_FINAL.md b/docs/JALALI_CALENDAR_FINAL.md
similarity index 100%
rename from JALALI_CALENDAR_FINAL.md
rename to docs/JALALI_CALENDAR_FINAL.md
diff --git a/JALALI_CALENDAR_IMPLEMENTATION.md b/docs/JALALI_CALENDAR_IMPLEMENTATION.md
similarity index 100%
rename from JALALI_CALENDAR_IMPLEMENTATION.md
rename to docs/JALALI_CALENDAR_IMPLEMENTATION.md
diff --git a/LOGIN_PAGE_LAYOUT_FIX.md b/docs/LOGIN_PAGE_LAYOUT_FIX.md
similarity index 100%
rename from LOGIN_PAGE_LAYOUT_FIX.md
rename to docs/LOGIN_PAGE_LAYOUT_FIX.md
diff --git a/MARKETING_CALENDAR_INTEGRATION.md b/docs/MARKETING_CALENDAR_INTEGRATION.md
similarity index 100%
rename from MARKETING_CALENDAR_INTEGRATION.md
rename to docs/MARKETING_CALENDAR_INTEGRATION.md
diff --git a/hesabixAPI/=3.1.0 b/hesabixAPI/=3.1.0
new file mode 100644
index 0000000..1b5b713
--- /dev/null
+++ b/hesabixAPI/=3.1.0
@@ -0,0 +1,9 @@
+Collecting openpyxl
+ Downloading openpyxl-3.1.5-py2.py3-none-any.whl.metadata (2.5 kB)
+Collecting et-xmlfile (from openpyxl)
+ Downloading et_xmlfile-2.0.0-py3-none-any.whl.metadata (2.7 kB)
+Downloading openpyxl-3.1.5-py2.py3-none-any.whl (250 kB)
+Downloading et_xmlfile-2.0.0-py3-none-any.whl (18 kB)
+Installing collected packages: et-xmlfile, openpyxl
+
+Successfully installed et-xmlfile-2.0.0 openpyxl-3.1.5
diff --git a/hesabixAPI/adapters/api/v1/auth.py b/hesabixAPI/adapters/api/v1/auth.py
index 1fc5be0..a2c48a6 100644
--- a/hesabixAPI/adapters/api/v1/auth.py
+++ b/hesabixAPI/adapters/api/v1/auth.py
@@ -1,13 +1,16 @@
from __future__ import annotations
+import datetime
from fastapi import APIRouter, Depends, Request
+from fastapi.responses import Response
from sqlalchemy.orm import Session
from adapters.db.session import get_db
from app.core.responses import success_response, format_datetime_fields
from app.services.captcha_service import create_captcha
-from app.services.auth_service import register_user, login_user, create_password_reset, reset_password, change_password, referral_stats, referral_list
-from .schemas import RegisterRequest, LoginRequest, ForgotPasswordRequest, ResetPasswordRequest, ChangePasswordRequest, CreateApiKeyRequest
+from app.services.auth_service import register_user, login_user, create_password_reset, reset_password, change_password, referral_stats
+from app.services.pdf import PDFService
+from .schemas import RegisterRequest, LoginRequest, ForgotPasswordRequest, ResetPasswordRequest, ChangePasswordRequest, CreateApiKeyRequest, QueryInfo, FilterItem
from app.core.auth_dependency import get_current_user, AuthContext
from app.services.api_key_service import list_personal_keys, create_personal_key, revoke_key
@@ -96,13 +99,13 @@ def reset_password_endpoint(payload: ResetPasswordRequest, db: Session = Depends
@router.get("/api-keys", summary="List personal API keys")
-def list_keys(ctx: AuthContext = Depends(get_current_user), db: Session = Depends(get_db)) -> dict:
+def list_keys(request: Request, ctx: AuthContext = Depends(get_current_user), db: Session = Depends(get_db)) -> dict:
items = list_personal_keys(db, ctx.user.id)
return success_response(items)
@router.post("/api-keys", summary="Create personal API key")
-def create_key(payload: CreateApiKeyRequest, ctx: AuthContext = Depends(get_current_user), db: Session = Depends(get_db)) -> dict:
+def create_key(request: Request, payload: CreateApiKeyRequest, ctx: AuthContext = Depends(get_current_user), db: Session = Depends(get_db)) -> dict:
id_, api_key = create_personal_key(db, ctx.user.id, payload.name, payload.scopes, None)
return success_response({"id": id_, "api_key": api_key})
@@ -124,13 +127,13 @@ def change_password_endpoint(request: Request, payload: ChangePasswordRequest, c
@router.delete("/api-keys/{key_id}", summary="Revoke API key")
-def delete_key(key_id: int, ctx: AuthContext = Depends(get_current_user), db: Session = Depends(get_db)) -> dict:
+def delete_key(request: Request, key_id: int, ctx: AuthContext = Depends(get_current_user), db: Session = Depends(get_db)) -> dict:
revoke_key(db, ctx.user.id, key_id)
return success_response({"ok": True})
@router.get("/referrals/stats", summary="Referral stats for current user")
-def get_referral_stats(ctx: AuthContext = Depends(get_current_user), db: Session = Depends(get_db), start: str | None = None, end: str | None = None) -> dict:
+def get_referral_stats(request: Request, ctx: AuthContext = Depends(get_current_user), db: Session = Depends(get_db), start: str | None = None, end: str | None = None) -> dict:
from datetime import datetime
start_dt = datetime.fromisoformat(start) if start else None
end_dt = datetime.fromisoformat(end) if end else None
@@ -138,19 +141,292 @@ def get_referral_stats(ctx: AuthContext = Depends(get_current_user), db: Session
return success_response(stats)
-@router.get("/referrals/list", summary="Referral list for current user")
-def get_referral_list(
+@router.post("/referrals/list", summary="Referral list with advanced filtering")
+def get_referral_list_advanced(
+ request: Request,
+ query_info: QueryInfo,
ctx: AuthContext = Depends(get_current_user),
- db: Session = Depends(get_db),
- start: str | None = None,
- end: str | None = None,
- search: str | None = None,
- page: int = 1,
- limit: int = 20,
+ db: Session = Depends(get_db)
) -> dict:
+ """
+ دریافت لیست معرفیها با قابلیت فیلتر پیشرفته
+
+ پارامترهای QueryInfo:
+ - sort_by: فیلد مرتبسازی (مثال: created_at, first_name, last_name, email)
+ - sort_desc: ترتیب نزولی (true/false)
+ - take: تعداد رکورد در هر صفحه (پیشفرض: 10)
+ - skip: تعداد رکورد صرفنظر شده (پیشفرض: 0)
+ - search: عبارت جستجو
+ - search_fields: فیلدهای جستجو (مثال: ["first_name", "last_name", "email"])
+ - filters: آرایه فیلترها با ساختار:
+ [
+ {
+ "property": "created_at",
+ "operator": ">=",
+ "value": "2024-01-01T00:00:00"
+ },
+ {
+ "property": "first_name",
+ "operator": "*",
+ "value": "احمد"
+ }
+ ]
+ """
+ from adapters.db.repositories.user_repo import UserRepository
+ from adapters.db.models.user import User
from datetime import datetime
- start_dt = datetime.fromisoformat(start) if start else None
- end_dt = datetime.fromisoformat(end) if end else None
- resp = referral_list(db=db, user_id=ctx.user.id, start=start_dt, end=end_dt, search=search, page=page, limit=limit)
- return success_response(resp)
+
+ # Create a custom query for referrals
+ repo = UserRepository(db)
+
+ # Add filter for referrals only (users with referred_by_user_id = current user)
+ referral_filter = FilterItem(
+ property="referred_by_user_id",
+ operator="=",
+ value=ctx.user.id
+ )
+
+ # Add referral filter to existing filters
+ if query_info.filters is None:
+ query_info.filters = [referral_filter]
+ else:
+ query_info.filters.append(referral_filter)
+
+ # Set default search fields for referrals
+ if query_info.search_fields is None:
+ query_info.search_fields = ["first_name", "last_name", "email"]
+
+ # Execute query with filters
+ referrals, total = repo.query_with_filters(query_info)
+
+ # Convert to dictionary format
+ referral_dicts = [repo.to_dict(referral) for referral in referrals]
+
+ # Format datetime fields
+ formatted_referrals = format_datetime_fields(referral_dicts, request)
+
+ # Calculate pagination info
+ page = (query_info.skip // query_info.take) + 1
+ total_pages = (total + query_info.take - 1) // query_info.take
+
+ return success_response({
+ "items": formatted_referrals,
+ "total": total,
+ "page": page,
+ "limit": query_info.take,
+ "total_pages": total_pages,
+ "has_next": page < total_pages,
+ "has_prev": page > 1
+ }, request)
+
+
+@router.post("/referrals/export/pdf", summary="Export referrals to PDF")
+def export_referrals_pdf(
+ request: Request,
+ query_info: QueryInfo,
+ selected_only: bool = False,
+ selected_indices: str | None = None,
+ ctx: AuthContext = Depends(get_current_user),
+ db: Session = Depends(get_db)
+) -> Response:
+ """
+ خروجی PDF لیست معرفیها
+
+ پارامترها:
+ - selected_only: آیا فقط سطرهای انتخاب شده export شوند
+ - selected_indices: لیست ایندکسهای انتخاب شده (JSON string)
+ - سایر پارامترهای QueryInfo برای فیلتر
+ """
+ from app.services.pdf import PDFService
+ from app.services.auth_service import referral_stats
+ import json
+
+ # Parse selected indices if provided
+ indices = None
+ if selected_only and selected_indices:
+ try:
+ indices = json.loads(selected_indices)
+ except (json.JSONDecodeError, TypeError):
+ indices = None
+
+ # Get stats for the report
+ stats = None
+ try:
+ # Extract date range from filters if available
+ start_date = None
+ end_date = None
+ if query_info.filters:
+ for filter_item in query_info.filters:
+ if filter_item.property == 'created_at':
+ if filter_item.operator == '>=':
+ start_date = filter_item.value
+ elif filter_item.operator == '<':
+ end_date = filter_item.value
+
+ stats = referral_stats(
+ db=db,
+ user_id=ctx.user.id,
+ start=start_date,
+ end=end_date
+ )
+ except Exception:
+ pass # Continue without stats
+
+ # Get calendar type from request headers
+ calendar_header = request.headers.get("X-Calendar-Type", "jalali")
+ calendar_type = "jalali" if calendar_header.lower() in ["jalali", "persian", "shamsi"] else "gregorian"
+
+ # Generate PDF using new modular service
+ pdf_service = PDFService()
+
+ # Get locale from request headers
+ locale_header = request.headers.get("Accept-Language", "fa")
+ locale = "fa" if locale_header.startswith("fa") else "en"
+
+ pdf_bytes = pdf_service.generate_pdf(
+ module_name='marketing',
+ data={}, # Empty data - module will fetch its own data
+ calendar_type=calendar_type,
+ locale=locale,
+ db=db,
+ user_id=ctx.user.id,
+ query_info=query_info,
+ selected_indices=indices,
+ stats=stats
+ )
+
+ # Return PDF response
+ from fastapi.responses import Response
+ import datetime
+
+ filename = f"referrals_export_{datetime.datetime.now().strftime('%Y%m%d_%H%M%S')}.pdf"
+
+ return Response(
+ content=pdf_bytes,
+ media_type="application/pdf",
+ headers={
+ "Content-Disposition": f"attachment; filename={filename}",
+ "Content-Length": str(len(pdf_bytes))
+ }
+ )
+
+
+@router.post("/referrals/export/excel", summary="Export referrals to Excel")
+def export_referrals_excel(
+ request: Request,
+ query_info: QueryInfo,
+ selected_only: bool = False,
+ selected_indices: str | None = None,
+ ctx: AuthContext = Depends(get_current_user),
+ db: Session = Depends(get_db)
+) -> Response:
+ """
+ خروجی Excel لیست معرفیها (فایل Excel واقعی برای دانلود)
+
+ پارامترها:
+ - selected_only: آیا فقط سطرهای انتخاب شده export شوند
+ - selected_indices: لیست ایندکسهای انتخاب شده (JSON string)
+ - سایر پارامترهای QueryInfo برای فیلتر
+ """
+ from app.services.pdf import PDFService
+ import json
+ import io
+ from openpyxl import Workbook
+ from openpyxl.styles import Font, Alignment, PatternFill, Border, Side
+
+ # Parse selected indices if provided
+ indices = None
+ if selected_only and selected_indices:
+ try:
+ indices = json.loads(selected_indices)
+ except (json.JSONDecodeError, TypeError):
+ indices = None
+
+ # Get calendar type from request headers
+ calendar_header = request.headers.get("X-Calendar-Type", "jalali")
+ calendar_type = "jalali" if calendar_header.lower() in ["jalali", "persian", "shamsi"] else "gregorian"
+
+ # Generate Excel data using new modular service
+ pdf_service = PDFService()
+
+ # Get locale from request headers
+ locale_header = request.headers.get("Accept-Language", "fa")
+ locale = "fa" if locale_header.startswith("fa") else "en"
+
+ excel_data = pdf_service.generate_excel_data(
+ module_name='marketing',
+ data={}, # Empty data - module will fetch its own data
+ calendar_type=calendar_type,
+ locale=locale,
+ db=db,
+ user_id=ctx.user.id,
+ query_info=query_info,
+ selected_indices=indices
+ )
+
+ # Create Excel workbook
+ wb = Workbook()
+ ws = wb.active
+ ws.title = "Referrals"
+
+ # Define styles
+ header_font = Font(bold=True, color="FFFFFF")
+ header_fill = PatternFill(start_color="366092", end_color="366092", fill_type="solid")
+ header_alignment = Alignment(horizontal="center", vertical="center")
+ border = Border(
+ left=Side(style='thin'),
+ right=Side(style='thin'),
+ top=Side(style='thin'),
+ bottom=Side(style='thin')
+ )
+
+ # Add headers
+ if excel_data:
+ headers = list(excel_data[0].keys())
+ for col, header in enumerate(headers, 1):
+ cell = ws.cell(row=1, column=col, value=header)
+ cell.font = header_font
+ cell.fill = header_fill
+ cell.alignment = header_alignment
+ cell.border = border
+
+ # Add data rows
+ for row, data in enumerate(excel_data, 2):
+ for col, header in enumerate(headers, 1):
+ cell = ws.cell(row=row, column=col, value=data.get(header, ""))
+ cell.border = border
+ # Center align for numbers and dates
+ if header in ["ردیف", "Row", "تاریخ ثبت", "Registration Date"]:
+ cell.alignment = Alignment(horizontal="center")
+
+ # Auto-adjust column widths
+ for column in ws.columns:
+ max_length = 0
+ column_letter = column[0].column_letter
+ for cell in column:
+ try:
+ if len(str(cell.value)) > max_length:
+ max_length = len(str(cell.value))
+ except:
+ pass
+ adjusted_width = min(max_length + 2, 50)
+ ws.column_dimensions[column_letter].width = adjusted_width
+
+ # Save to BytesIO
+ excel_buffer = io.BytesIO()
+ wb.save(excel_buffer)
+ excel_buffer.seek(0)
+
+ # Generate filename
+ filename = f"referrals_export_{datetime.datetime.now().strftime('%Y%m%d_%H%M%S')}.xlsx"
+
+ # Return Excel file as response
+ return Response(
+ content=excel_buffer.getvalue(),
+ media_type="application/vnd.openxmlformats-officedocument.spreadsheetml.sheet",
+ headers={
+ "Content-Disposition": f"attachment; filename={filename}",
+ "Content-Type": "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet"
+ }
+ )
diff --git a/hesabixAPI/adapters/api/v1/schemas.py b/hesabixAPI/adapters/api/v1/schemas.py
index b0e9afa..07f806b 100644
--- a/hesabixAPI/adapters/api/v1/schemas.py
+++ b/hesabixAPI/adapters/api/v1/schemas.py
@@ -1,8 +1,25 @@
from __future__ import annotations
+from typing import Any
from pydantic import BaseModel, EmailStr, Field
+class FilterItem(BaseModel):
+ property: str = Field(..., description="نام فیلد مورد نظر برای اعمال فیلتر")
+ operator: str = Field(..., description="نوع عملگر: =, >, >=, <, <=, !=, *, ?*, *?, in")
+ value: Any = Field(..., description="مقدار مورد نظر")
+
+
+class QueryInfo(BaseModel):
+ sort_by: str | None = Field(default=None, description="نام فیلد مورد نظر برای مرتب سازی")
+ sort_desc: bool = Field(default=False, description="false = مرتب سازی صعودی، true = مرتب سازی نزولی")
+ take: int = Field(default=10, ge=1, le=1000, description="حداکثر تعداد رکورد بازگشتی")
+ skip: int = Field(default=0, ge=0, description="تعداد رکوردی که از ابتدای لیست صرف نظر می شود")
+ search: str | None = Field(default=None, description="عبارت جستجو")
+ search_fields: list[str] | None = Field(default=None, description="آرایه ای از فیلدهایی که جستجو در آن انجام می گیرد")
+ filters: list[FilterItem] | None = Field(default=None, description="آرایه ای از اشیا برای اعمال فیلتر بر روی لیست")
+
+
class CaptchaSolve(BaseModel):
captcha_id: str = Field(..., min_length=8)
captcha_code: str = Field(..., min_length=3, max_length=8)
diff --git a/hesabixAPI/adapters/api/v1/users.py b/hesabixAPI/adapters/api/v1/users.py
new file mode 100644
index 0000000..3e837a8
--- /dev/null
+++ b/hesabixAPI/adapters/api/v1/users.py
@@ -0,0 +1,144 @@
+from __future__ import annotations
+
+from fastapi import APIRouter, Depends, Request, Query
+from sqlalchemy.orm import Session
+
+from adapters.db.session import get_db
+from adapters.db.repositories.user_repo import UserRepository
+from adapters.api.v1.schemas import QueryInfo
+from app.core.responses import success_response, format_datetime_fields
+from app.core.auth_dependency import get_current_user, AuthContext
+
+
+router = APIRouter(prefix="/users", tags=["users"])
+
+
+@router.get("", summary="لیست کاربران با فیلتر پیشرفته")
+def list_users(
+ request: Request,
+ query_info: QueryInfo = Depends(),
+ ctx: AuthContext = Depends(get_current_user),
+ db: Session = Depends(get_db)
+) -> dict:
+ """
+ دریافت لیست کاربران با قابلیت فیلتر، جستجو، مرتبسازی و صفحهبندی
+
+ پارامترهای QueryInfo:
+ - sort_by: فیلد مرتبسازی (مثال: created_at, first_name)
+ - sort_desc: ترتیب نزولی (true/false)
+ - take: تعداد رکورد در هر صفحه (پیشفرض: 10)
+ - skip: تعداد رکورد صرفنظر شده (پیشفرض: 0)
+ - search: عبارت جستجو
+ - search_fields: فیلدهای جستجو (مثال: ["first_name", "last_name", "email"])
+ - filters: آرایه فیلترها با ساختار:
+ [
+ {
+ "property": "is_active",
+ "operator": "=",
+ "value": true
+ },
+ {
+ "property": "first_name",
+ "operator": "*",
+ "value": "احمد"
+ }
+ ]
+
+ عملگرهای پشتیبانی شده:
+ - = : برابر
+ - > : بزرگتر از
+ - >= : بزرگتر یا مساوی
+ - < : کوچکتر از
+ - <= : کوچکتر یا مساوی
+ - != : نامساوی
+ - * : شامل (contains)
+ - ?* : خاتمه یابد (ends with)
+ - *? : شروع شود (starts with)
+ - in : در بین مقادیر آرایه
+ """
+ repo = UserRepository(db)
+ users, total = repo.query_with_filters(query_info)
+
+ # تبدیل User objects به dictionary
+ user_dicts = [repo.to_dict(user) for user in users]
+
+ # فرمت کردن تاریخها
+ formatted_users = [format_datetime_fields(user_dict, request) for user_dict in user_dicts]
+
+ # محاسبه اطلاعات صفحهبندی
+ page = (query_info.skip // query_info.take) + 1
+ total_pages = (total + query_info.take - 1) // query_info.take
+
+ response_data = {
+ "items": formatted_users,
+ "pagination": {
+ "total": total,
+ "page": page,
+ "per_page": query_info.take,
+ "total_pages": total_pages,
+ "has_next": page < total_pages,
+ "has_prev": page > 1
+ },
+ "query_info": {
+ "sort_by": query_info.sort_by,
+ "sort_desc": query_info.sort_desc,
+ "search": query_info.search,
+ "search_fields": query_info.search_fields,
+ "filters": [{"property": f.property, "operator": f.operator, "value": f.value} for f in (query_info.filters or [])]
+ }
+ }
+
+ return success_response(response_data, request)
+
+
+@router.get("/{user_id}", summary="دریافت اطلاعات یک کاربر")
+def get_user(
+ user_id: int,
+ request: Request,
+ ctx: AuthContext = Depends(get_current_user),
+ db: Session = Depends(get_db)
+) -> dict:
+ """دریافت اطلاعات یک کاربر بر اساس ID"""
+ repo = UserRepository(db)
+ user = repo.get_by_id(user_id)
+
+ if not user:
+ from fastapi import HTTPException
+ raise HTTPException(status_code=404, detail="کاربر یافت نشد")
+
+ user_dict = repo.to_dict(user)
+ formatted_user = format_datetime_fields(user_dict, request)
+
+ return success_response(formatted_user, request)
+
+
+@router.get("/stats/summary", summary="آمار کلی کاربران")
+def get_users_summary(
+ request: Request,
+ ctx: AuthContext = Depends(get_current_user),
+ db: Session = Depends(get_db)
+) -> dict:
+ """دریافت آمار کلی کاربران"""
+ repo = UserRepository(db)
+
+ # تعداد کل کاربران
+ total_users = repo.count_all()
+
+ # تعداد کاربران فعال
+ active_users = repo.query_with_filters(QueryInfo(
+ filters=[{"property": "is_active", "operator": "=", "value": True}]
+ ))[1]
+
+ # تعداد کاربران غیرفعال
+ inactive_users = total_users - active_users
+
+ response_data = {
+ "total_users": total_users,
+ "active_users": active_users,
+ "inactive_users": inactive_users,
+ "active_percentage": round((active_users / total_users * 100), 2) if total_users > 0 else 0
+ }
+
+ return success_response(response_data, request)
+
+
diff --git a/hesabixAPI/adapters/db/repositories/base_repo.py b/hesabixAPI/adapters/db/repositories/base_repo.py
new file mode 100644
index 0000000..2b6109f
--- /dev/null
+++ b/hesabixAPI/adapters/db/repositories/base_repo.py
@@ -0,0 +1,55 @@
+from __future__ import annotations
+
+from typing import Type, TypeVar, Generic, Any
+from sqlalchemy.orm import Session
+from sqlalchemy import select, func
+
+from app.services.query_service import QueryService
+from adapters.api.v1.schemas import QueryInfo
+
+T = TypeVar('T')
+
+
+class BaseRepository(Generic[T]):
+ """کلاس پایه برای Repository ها با قابلیت فیلتر پیشرفته"""
+
+ def __init__(self, db: Session, model_class: Type[T]) -> None:
+ self.db = db
+ self.model_class = model_class
+
+ def query_with_filters(self, query_info: QueryInfo) -> tuple[list[T], int]:
+ """
+ اجرای کوئری با فیلتر و بازگرداندن نتایج و تعداد کل
+
+ Args:
+ query_info: اطلاعات کوئری شامل فیلترها، مرتبسازی و صفحهبندی
+
+ Returns:
+ tuple: (لیست نتایج, تعداد کل رکوردها)
+ """
+ return QueryService.query_with_filters(self.model_class, self.db, query_info)
+
+ def get_by_id(self, id: int) -> T | None:
+ """دریافت رکورد بر اساس ID"""
+ stmt = select(self.model_class).where(self.model_class.id == id)
+ return self.db.execute(stmt).scalars().first()
+
+ def get_all(self, limit: int = 100, offset: int = 0) -> list[T]:
+ """دریافت تمام رکوردها با محدودیت"""
+ stmt = select(self.model_class).offset(offset).limit(limit)
+ return list(self.db.execute(stmt).scalars().all())
+
+ def count_all(self) -> int:
+ """شمارش تمام رکوردها"""
+ stmt = select(func.count()).select_from(self.model_class)
+ return int(self.db.execute(stmt).scalar() or 0)
+
+ def exists(self, **filters) -> bool:
+ """بررسی وجود رکورد بر اساس فیلترهای مشخص شده"""
+ stmt = select(self.model_class)
+ for field, value in filters.items():
+ if hasattr(self.model_class, field):
+ column = getattr(self.model_class, field)
+ stmt = stmt.where(column == value)
+
+ return self.db.execute(stmt).scalars().first() is not None
diff --git a/hesabixAPI/adapters/db/repositories/user_repo.py b/hesabixAPI/adapters/db/repositories/user_repo.py
index 28cb64b..f75faa5 100644
--- a/hesabixAPI/adapters/db/repositories/user_repo.py
+++ b/hesabixAPI/adapters/db/repositories/user_repo.py
@@ -6,11 +6,13 @@ from sqlalchemy import select, func, and_, or_
from sqlalchemy.orm import Session
from adapters.db.models.user import User
+from adapters.db.repositories.base_repo import BaseRepository
+from adapters.api.v1.schemas import QueryInfo
-class UserRepository:
+class UserRepository(BaseRepository[User]):
def __init__(self, db: Session) -> None:
- self.db = db
+ super().__init__(db, User)
def get_by_email(self, email: str) -> Optional[User]:
stmt = select(User).where(User.email == email)
@@ -71,5 +73,20 @@ class UserRepository:
stmt = stmt.where(or_(User.first_name.ilike(like), User.last_name.ilike(like), User.email.ilike(like)))
stmt = stmt.order_by(User.created_at.desc()).offset(offset).limit(limit)
return self.db.execute(stmt).scalars().all()
+
+ def to_dict(self, user: User) -> dict:
+ """تبدیل User object به dictionary برای API response"""
+ return {
+ "id": user.id,
+ "email": user.email,
+ "mobile": user.mobile,
+ "first_name": user.first_name,
+ "last_name": user.last_name,
+ "is_active": user.is_active,
+ "referral_code": user.referral_code,
+ "referred_by_user_id": user.referred_by_user_id,
+ "created_at": user.created_at,
+ "updated_at": user.updated_at,
+ }
diff --git a/hesabixAPI/app/core/auth_dependency.py b/hesabixAPI/app/core/auth_dependency.py
index da7b1a9..7ee65ab 100644
--- a/hesabixAPI/app/core/auth_dependency.py
+++ b/hesabixAPI/app/core/auth_dependency.py
@@ -1,8 +1,7 @@
from __future__ import annotations
from typing import Optional
-
-from fastapi import Depends, Header
+from fastapi import Depends, Header, Request
from sqlalchemy.orm import Session
from adapters.db.session import get_db
@@ -10,15 +9,99 @@ from adapters.db.repositories.api_key_repo import ApiKeyRepository
from adapters.db.models.user import User
from app.core.security import hash_api_key
from app.core.responses import ApiError
+from app.core.i18n import negotiate_locale, Translator
+from app.core.calendar import get_calendar_type_from_header, CalendarType
class AuthContext:
- def __init__(self, user: User, api_key_id: int) -> None:
+ """کلاس مرکزی برای نگهداری اطلاعات کاربر کنونی و تنظیمات"""
+
+ def __init__(
+ self,
+ user: User,
+ api_key_id: int,
+ language: str = "fa",
+ calendar_type: CalendarType = "jalali",
+ timezone: Optional[str] = None,
+ business_id: Optional[int] = None,
+ fiscal_year_id: Optional[int] = None
+ ) -> None:
self.user = user
self.api_key_id = api_key_id
+ self.language = language
+ self.calendar_type = calendar_type
+ self.timezone = timezone
+ self.business_id = business_id
+ self.fiscal_year_id = fiscal_year_id
+
+ # ایجاد translator برای زبان تشخیص داده شده
+ self._translator = Translator(language)
+
+ def get_translator(self) -> Translator:
+ """دریافت translator برای ترجمه"""
+ return self._translator
+
+ def get_calendar_type(self) -> CalendarType:
+ """دریافت نوع تقویم"""
+ return self.calendar_type
+
+ def get_user_id(self) -> int:
+ """دریافت ID کاربر"""
+ return self.user.id
+
+ def get_user_email(self) -> Optional[str]:
+ """دریافت ایمیل کاربر"""
+ return self.user.email
+
+ def get_user_mobile(self) -> Optional[str]:
+ """دریافت شماره موبایل کاربر"""
+ return self.user.mobile
+
+ def get_user_name(self) -> str:
+ """دریافت نام کامل کاربر"""
+ first_name = self.user.first_name or ""
+ last_name = self.user.last_name or ""
+ return f"{first_name} {last_name}".strip()
+
+ def get_referral_code(self) -> Optional[str]:
+ """دریافت کد معرف کاربر"""
+ return getattr(self.user, "referral_code", None)
+
+ def is_user_active(self) -> bool:
+ """بررسی فعال بودن کاربر"""
+ return self.user.is_active
+
+ def to_dict(self) -> dict:
+ """تبدیل به dictionary برای استفاده در API"""
+ return {
+ "user": {
+ "id": self.user.id,
+ "first_name": self.user.first_name,
+ "last_name": self.user.last_name,
+ "email": self.user.email,
+ "mobile": self.user.mobile,
+ "referral_code": getattr(self.user, "referral_code", None),
+ "is_active": self.user.is_active,
+ "created_at": self.user.created_at.isoformat() if self.user.created_at else None,
+ "updated_at": self.user.updated_at.isoformat() if self.user.updated_at else None,
+ },
+ "api_key_id": self.api_key_id,
+ "settings": {
+ "language": self.language,
+ "calendar_type": self.calendar_type,
+ "timezone": self.timezone,
+ "business_id": self.business_id,
+ "fiscal_year_id": self.fiscal_year_id,
+ }
+ }
-def get_current_user(authorization: Optional[str] = Header(default=None), db: Session = Depends(get_db)) -> AuthContext:
+def get_current_user(
+ request: Request,
+ authorization: Optional[str] = Header(default=None),
+ db: Session = Depends(get_db)
+) -> AuthContext:
+ """دریافت اطلاعات کامل کاربر کنونی و تنظیمات از درخواست"""
if not authorization or not authorization.startswith("ApiKey "):
raise ApiError("UNAUTHORIZED", "Missing or invalid API key", http_status=401)
@@ -34,6 +117,68 @@ def get_current_user(authorization: Optional[str] = Header(default=None), db: Se
if not user or not user.is_active:
raise ApiError("UNAUTHORIZED", "Invalid API key", http_status=401)
- return AuthContext(user=user, api_key_id=obj.id)
+ # تشخیص زبان از هدر Accept-Language
+ language = _detect_language(request)
+
+ # تشخیص نوع تقویم از هدر X-Calendar-Type
+ calendar_type = _detect_calendar_type(request)
+
+ # تشخیص منطقه زمانی از هدر X-Timezone (اختیاری)
+ timezone = _detect_timezone(request)
+
+ # تشخیص کسب و کار از هدر X-Business-ID (آینده)
+ business_id = _detect_business_id(request)
+
+ # تشخیص سال مالی از هدر X-Fiscal-Year-ID (آینده)
+ fiscal_year_id = _detect_fiscal_year_id(request)
+
+ return AuthContext(
+ user=user,
+ api_key_id=obj.id,
+ language=language,
+ calendar_type=calendar_type,
+ timezone=timezone,
+ business_id=business_id,
+ fiscal_year_id=fiscal_year_id
+ )
+
+
+def _detect_language(request: Request) -> str:
+ """تشخیص زبان از هدر Accept-Language"""
+ accept_language = request.headers.get("Accept-Language")
+ return negotiate_locale(accept_language)
+
+
+def _detect_calendar_type(request: Request) -> CalendarType:
+ """تشخیص نوع تقویم از هدر X-Calendar-Type"""
+ calendar_header = request.headers.get("X-Calendar-Type")
+ return get_calendar_type_from_header(calendar_header)
+
+
+def _detect_timezone(request: Request) -> Optional[str]:
+ """تشخیص منطقه زمانی از هدر X-Timezone"""
+ return request.headers.get("X-Timezone")
+
+
+def _detect_business_id(request: Request) -> Optional[int]:
+ """تشخیص ID کسب و کار از هدر X-Business-ID (آینده)"""
+ business_id_str = request.headers.get("X-Business-ID")
+ if business_id_str:
+ try:
+ return int(business_id_str)
+ except ValueError:
+ pass
+ return None
+
+
+def _detect_fiscal_year_id(request: Request) -> Optional[int]:
+ """تشخیص ID سال مالی از هدر X-Fiscal-Year-ID (آینده)"""
+ fiscal_year_id_str = request.headers.get("X-Fiscal-Year-ID")
+ if fiscal_year_id_str:
+ try:
+ return int(fiscal_year_id_str)
+ except ValueError:
+ pass
+ return None
diff --git a/hesabixAPI/app/core/calendar.py b/hesabixAPI/app/core/calendar.py
index a48de03..27c10f1 100644
--- a/hesabixAPI/app/core/calendar.py
+++ b/hesabixAPI/app/core/calendar.py
@@ -41,7 +41,7 @@ class CalendarConverter:
"date_only": jalali.strftime("%Y/%m/%d"),
"time_only": jalali.strftime("%H:%M:%S"),
"is_leap_year": jalali.isleap(),
- "month_days": jalali.days_in_month,
+ "month_days": jdatetime.j_days_in_month[jalali.month - 1],
}
@staticmethod
diff --git a/hesabixAPI/app/core/i18n.py b/hesabixAPI/app/core/i18n.py
index b38f25d..54d59ce 100644
--- a/hesabixAPI/app/core/i18n.py
+++ b/hesabixAPI/app/core/i18n.py
@@ -46,3 +46,8 @@ async def locale_dependency(request: Request) -> Translator:
return Translator(lang)
+def get_translator(locale: str = "fa") -> Translator:
+ """Get translator for the given locale"""
+ return Translator(locale)
+
+
diff --git a/hesabixAPI/app/core/responses.py b/hesabixAPI/app/core/responses.py
index 1ad10c1..c8752fc 100644
--- a/hesabixAPI/app/core/responses.py
+++ b/hesabixAPI/app/core/responses.py
@@ -29,7 +29,11 @@ def format_datetime_fields(data: Any, request: Request) -> Any:
for key, value in data.items():
if isinstance(value, datetime):
formatted_data[key] = CalendarConverter.format_datetime(value, calendar_type)
- formatted_data[f"{key}_raw"] = value.isoformat() # Keep original for reference
+ # Convert raw date to the same calendar type as the formatted date
+ if calendar_type == "jalali":
+ formatted_data[f"{key}_raw"] = CalendarConverter.to_jalali(value)["formatted"]
+ else:
+ formatted_data[f"{key}_raw"] = value.isoformat()
elif isinstance(value, (dict, list)):
formatted_data[key] = format_datetime_fields(value, request)
else:
diff --git a/hesabixAPI/app/main.py b/hesabixAPI/app/main.py
index 0dabbfd..a96093c 100644
--- a/hesabixAPI/app/main.py
+++ b/hesabixAPI/app/main.py
@@ -5,6 +5,7 @@ from app.core.settings import get_settings
from app.core.logging import configure_logging
from adapters.api.v1.health import router as health_router
from adapters.api.v1.auth import router as auth_router
+from adapters.api.v1.users import router as users_router
from app.core.i18n import negotiate_locale, Translator
from app.core.error_handlers import register_error_handlers
from app.core.smart_normalizer import smart_normalize_json, SmartNormalizerConfig
@@ -60,6 +61,7 @@ def create_app() -> FastAPI:
application.include_router(health_router, prefix=settings.api_v1_prefix)
application.include_router(auth_router, prefix=settings.api_v1_prefix)
+ application.include_router(users_router, prefix=settings.api_v1_prefix)
register_error_handlers(application)
diff --git a/hesabixAPI/app/services/pdf/README.md b/hesabixAPI/app/services/pdf/README.md
new file mode 100644
index 0000000..52962c0
--- /dev/null
+++ b/hesabixAPI/app/services/pdf/README.md
@@ -0,0 +1,148 @@
+# PDF Service - Modular Architecture
+
+## Overview
+This is a modular PDF generation service designed for scalability and AI integration. Each module handles specific business domains and can be easily extended.
+
+## Structure
+```
+app/services/pdf/
+├── __init__.py
+├── base_pdf_service.py # Base classes and main service
+├── modules/ # Business domain modules
+│ ├── __init__.py
+│ └── marketing/ # Marketing & referrals module
+│ ├── __init__.py
+│ ├── marketing_module.py # Module implementation
+│ └── templates/ # HTML templates
+│ └── marketing_referrals.html
+└── README.md
+```
+
+## Adding New Modules
+
+### 1. Create Module Directory
+```bash
+mkdir -p app/services/pdf/modules/your_module/templates
+```
+
+### 2. Implement Module Class
+```python
+# app/services/pdf/modules/your_module/your_module.py
+from ..base_pdf_service import BasePDFModule
+from app.core.calendar import CalendarType
+
+class YourModulePDFModule(BasePDFModule):
+ def __init__(self):
+ super().__init__("your_module")
+
+ def generate_pdf(self, data, calendar_type="jalali", locale="fa"):
+ # Your PDF generation logic
+ pass
+
+ def generate_excel_data(self, data, calendar_type="jalali", locale="fa"):
+ # Your Excel data generation logic
+ pass
+```
+
+### 3. Register Module
+Add to `base_pdf_service.py`:
+```python
+def _register_modules(self):
+ from .modules.marketing.marketing_module import MarketingPDFModule
+ from .modules.your_module.your_module import YourModulePDFModule
+ self.modules['marketing'] = MarketingPDFModule()
+ self.modules['your_module'] = YourModulePDFModule()
+```
+
+## Usage
+
+### Generate PDF
+```python
+from app.services.pdf import PDFService
+
+pdf_service = PDFService()
+pdf_bytes = pdf_service.generate_pdf(
+ module_name='marketing',
+ data=your_data,
+ calendar_type='jalali',
+ locale='fa'
+)
+```
+
+### Generate Excel Data
+```python
+excel_data = pdf_service.generate_excel_data(
+ module_name='marketing',
+ data=your_data,
+ calendar_type='jalali',
+ locale='fa'
+)
+```
+
+## Features
+
+### 1. Calendar Support
+- Automatic Jalali/Gregorian conversion
+- Configurable via `calendar_type` parameter
+
+### 2. Internationalization
+- Built-in translation support
+- Template-level translation integration
+- Configurable via `locale` parameter
+
+### 3. Modular Design
+- Easy to add new business domains
+- Clean separation of concerns
+- Reusable base classes
+
+### 4. AI Integration Ready
+- Function calling compatible
+- Clear module boundaries
+- Extensible architecture
+
+## Template Development
+
+### Using Translations
+```html
+
+{{ t('yourTranslationKey') }}
+{{ t('anotherKey') }}
+```
+
+### Calendar Formatting
+```python
+# In your module
+formatted_date = self.format_datetime(datetime_obj, calendar_type)
+```
+
+### Data Formatting
+```python
+# In your module
+formatted_data = self._format_data_for_template(data, calendar_type, translator)
+```
+
+## Future Extensions
+
+### AI Integration
+Each module can be exposed as a function for AI systems:
+```python
+# Example AI function definition
+{
+ "name": "generate_marketing_pdf",
+ "description": "Generate marketing referrals PDF report",
+ "parameters": {
+ "type": "object",
+ "properties": {
+ "user_id": {"type": "integer"},
+ "filters": {"type": "object"},
+ "calendar_type": {"type": "string", "enum": ["jalali", "gregorian"]}
+ }
+ }
+}
+```
+
+### Additional Modules
+- `invoices/` - Invoice generation
+- `reports/` - General reports
+- `analytics/` - Analytics dashboards
+- `notifications/` - Notification templates
diff --git a/hesabixAPI/app/services/pdf/__init__.py b/hesabixAPI/app/services/pdf/__init__.py
new file mode 100644
index 0000000..23f103e
--- /dev/null
+++ b/hesabixAPI/app/services/pdf/__init__.py
@@ -0,0 +1,6 @@
+"""
+PDF Service Package
+"""
+from .base_pdf_service import PDFService
+
+__all__ = ['PDFService']
diff --git a/hesabixAPI/app/services/pdf/base_pdf_service.py b/hesabixAPI/app/services/pdf/base_pdf_service.py
new file mode 100644
index 0000000..d732522
--- /dev/null
+++ b/hesabixAPI/app/services/pdf/base_pdf_service.py
@@ -0,0 +1,135 @@
+"""
+Base PDF Service for modular PDF generation
+"""
+import os
+from abc import ABC, abstractmethod
+from typing import Dict, Any, Optional, List
+from datetime import datetime
+from pathlib import Path
+
+from weasyprint import HTML, CSS
+from weasyprint.text.fonts import FontConfiguration
+from jinja2 import Environment, FileSystemLoader, select_autoescape
+
+from app.core.calendar import CalendarConverter, CalendarType
+from app.core.i18n import get_translator
+from adapters.api.v1.schemas import QueryInfo
+
+
+class BasePDFModule(ABC):
+ """Base class for PDF modules"""
+
+ def __init__(self, module_name: str):
+ self.module_name = module_name
+ self.template_dir = Path(__file__).parent / "modules" / module_name / "templates"
+ self.jinja_env = Environment(
+ loader=FileSystemLoader(str(self.template_dir)),
+ autoescape=select_autoescape(['html', 'xml'])
+ )
+ self.font_config = FontConfiguration()
+
+ @abstractmethod
+ def generate_pdf(
+ self,
+ data: Dict[str, Any],
+ calendar_type: CalendarType = "jalali",
+ locale: str = "fa"
+ ) -> bytes:
+ """Generate PDF for this module"""
+ pass
+
+ @abstractmethod
+ def generate_excel_data(
+ self,
+ data: Dict[str, Any],
+ calendar_type: CalendarType = "jalali",
+ locale: str = "fa"
+ ) -> list:
+ """Generate Excel data for this module"""
+ pass
+
+ def format_datetime(self, dt: datetime, calendar_type: CalendarType) -> str:
+ """Format datetime based on calendar type"""
+ if dt is None:
+ return ""
+
+ formatted_date = CalendarConverter.format_datetime(dt, calendar_type)
+ return formatted_date['formatted']
+
+ def get_translator(self, locale: str = "fa"):
+ """Get translator for the given locale"""
+ return get_translator(locale)
+
+ def render_template(self, template_name: str, context: Dict[str, Any]) -> str:
+ """Render template with context"""
+ template = self.jinja_env.get_template(template_name)
+ return template.render(**context)
+
+
+class PDFService:
+ """Main PDF Service that manages modules"""
+
+ def __init__(self):
+ self.modules: Dict[str, BasePDFModule] = {}
+ self._register_modules()
+
+ def _register_modules(self):
+ """Register all available modules"""
+ from .modules.marketing.marketing_module import MarketingPDFModule
+ self.modules['marketing'] = MarketingPDFModule()
+
+ def generate_pdf(
+ self,
+ module_name: str,
+ data: Dict[str, Any],
+ calendar_type: CalendarType = "jalali",
+ locale: str = "fa",
+ db=None,
+ user_id: Optional[int] = None,
+ query_info: Optional[QueryInfo] = None,
+ selected_indices: Optional[List[int]] = None,
+ stats: Optional[Dict[str, Any]] = None
+ ) -> bytes:
+ """Generate PDF using specified module"""
+ if module_name not in self.modules:
+ raise ValueError(f"Module '{module_name}' not found")
+
+ return self.modules[module_name].generate_pdf_content(
+ db=db,
+ user_id=user_id,
+ query_info=query_info,
+ selected_indices=selected_indices,
+ stats=stats,
+ calendar_type=calendar_type,
+ locale=locale,
+ common_data=data
+ )
+
+ def generate_excel_data(
+ self,
+ module_name: str,
+ data: Dict[str, Any],
+ calendar_type: CalendarType = "jalali",
+ locale: str = "fa",
+ db=None,
+ user_id: Optional[int] = None,
+ query_info: Optional[QueryInfo] = None,
+ selected_indices: Optional[List[int]] = None
+ ) -> list:
+ """Generate Excel data using specified module"""
+ if module_name not in self.modules:
+ raise ValueError(f"Module '{module_name}' not found")
+
+ return self.modules[module_name].generate_excel_content(
+ db=db,
+ user_id=user_id,
+ query_info=query_info,
+ selected_indices=selected_indices,
+ calendar_type=calendar_type,
+ locale=locale,
+ common_data=data
+ )
+
+ def list_modules(self) -> list:
+ """List all available modules"""
+ return list(self.modules.keys())
diff --git a/hesabixAPI/app/services/pdf/modules/__init__.py b/hesabixAPI/app/services/pdf/modules/__init__.py
new file mode 100644
index 0000000..7d39827
--- /dev/null
+++ b/hesabixAPI/app/services/pdf/modules/__init__.py
@@ -0,0 +1,3 @@
+"""
+PDF Modules Package
+"""
diff --git a/hesabixAPI/app/services/pdf/modules/marketing/__init__.py b/hesabixAPI/app/services/pdf/modules/marketing/__init__.py
new file mode 100644
index 0000000..9088041
--- /dev/null
+++ b/hesabixAPI/app/services/pdf/modules/marketing/__init__.py
@@ -0,0 +1,6 @@
+"""
+Marketing PDF Module
+"""
+from .marketing_module import MarketingPDFModule
+
+__all__ = ['MarketingPDFModule']
diff --git a/hesabixAPI/app/services/pdf/modules/marketing/marketing_module.py b/hesabixAPI/app/services/pdf/modules/marketing/marketing_module.py
new file mode 100644
index 0000000..e55a5b4
--- /dev/null
+++ b/hesabixAPI/app/services/pdf/modules/marketing/marketing_module.py
@@ -0,0 +1,441 @@
+"""
+Marketing PDF Module for referrals and marketing reports
+"""
+from typing import Dict, Any, List
+from datetime import datetime
+
+from ...base_pdf_service import BasePDFModule
+from app.core.calendar import CalendarType
+
+
+class MarketingPDFModule(BasePDFModule):
+ """PDF Module for marketing and referrals"""
+
+ def __init__(self):
+ super().__init__("marketing")
+ self.template_name = 'marketing_referrals.html'
+
+ def generate_pdf(
+ self,
+ data: Dict[str, Any],
+ calendar_type: CalendarType = "jalali",
+ locale: str = "fa"
+ ) -> bytes:
+ """Generate marketing referrals PDF"""
+ # Get translator
+ t = self.get_translator(locale)
+
+ # Format data with translations and calendar
+ formatted_data = self._format_data_for_template(data, calendar_type, t)
+
+ # Render template
+ html_content = self.render_template('marketing_referrals.html', formatted_data)
+
+ # Generate PDF
+ html_doc = HTML(string=html_content)
+ pdf_bytes = html_doc.write_pdf(font_config=self.font_config)
+
+ return pdf_bytes
+
+ def generate_excel_data(
+ self,
+ data: Dict[str, Any],
+ calendar_type: CalendarType = "jalali",
+ locale: str = "fa"
+ ) -> list:
+ """Generate marketing referrals Excel data"""
+ # Get translator
+ t = self.get_translator(locale)
+
+ # Format data
+ items = data.get('items', [])
+ excel_data = []
+
+ for i, item in enumerate(items, 1):
+ # Format created_at based on calendar type
+ created_at = item.get('created_at', '')
+ if created_at and isinstance(created_at, datetime):
+ created_at = self.format_datetime(created_at, calendar_type)
+ elif created_at and isinstance(created_at, str):
+ try:
+ dt = datetime.fromisoformat(created_at.replace('Z', '+00:00'))
+ created_at = self.format_datetime(dt, calendar_type)
+ except:
+ pass
+
+ excel_data.append({
+ t('row_number'): i,
+ t('first_name'): item.get('first_name', ''),
+ t('last_name'): item.get('last_name', ''),
+ t('email'): item.get('email', ''),
+ t('registration_date'): created_at,
+ t('referral_code'): item.get('referral_code', ''),
+ t('status'): t('active') if item.get('is_active', False) else t('inactive')
+ })
+
+ return excel_data
+
+ def _format_data_for_template(
+ self,
+ data: Dict[str, Any],
+ calendar_type: CalendarType,
+ translator
+ ) -> Dict[str, Any]:
+ """Format data for template rendering"""
+ # Format items
+ items = data.get('items', [])
+ formatted_items = []
+
+ for item in items:
+ formatted_item = item.copy()
+ if item.get('created_at'):
+ if isinstance(item['created_at'], datetime):
+ formatted_item['created_at'] = self.format_datetime(item['created_at'], calendar_type)
+ elif isinstance(item['created_at'], str):
+ try:
+ dt = datetime.fromisoformat(item['created_at'].replace('Z', '+00:00'))
+ formatted_item['created_at'] = self.format_datetime(dt, calendar_type)
+ except:
+ pass
+ formatted_items.append(formatted_item)
+
+ # Format current date
+ now = datetime.now()
+ formatted_now = self.format_datetime(now, calendar_type)
+
+ # Prepare template data with translations
+ template_data = {
+ 'items': formatted_items,
+ 'total_count': data.get('total_count', 0),
+ 'report_date': formatted_now.split(' ')[0] if ' ' in formatted_now else formatted_now,
+ 'report_time': formatted_now.split(' ')[1] if ' ' in formatted_now else '',
+ 'selected_only': data.get('selected_only', False),
+ 'stats': data.get('stats', {}),
+ 'filters': self._format_filters(data.get('filters', []), translator),
+ 'calendar_type': calendar_type,
+ 'locale': translator.locale,
+ 't': translator, # Pass translator to template
+ }
+
+ return template_data
+
+ def _format_filters(self, query_info, locale: str, calendar_type: CalendarType = "jalali") -> List[str]:
+ """Format query filters for display in PDF"""
+ formatted_filters = []
+ translator = self.get_translator(locale)
+
+ # Add search filter
+ if query_info.search and query_info.search.strip():
+ search_fields = ', '.join(query_info.search_fields) if query_info.search_fields else translator.t('allFields')
+ formatted_filters.append(f"{translator.t('search')}: '{query_info.search}' {translator.t('in')} {search_fields}")
+
+ # Add column filters
+ if query_info.filters:
+ for filter_item in query_info.filters:
+ if filter_item.property == "referred_by_user_id":
+ continue # Skip internal filter
+
+ # Get translated column name
+ column_name = self._get_column_translation(filter_item.property, translator)
+ operator_text = self._get_operator_translation(filter_item.operator, translator)
+
+ # Format value based on column type and calendar
+ formatted_value = self._format_filter_value(filter_item.property, filter_item.value, calendar_type, translator)
+
+ formatted_filters.append(f"{column_name} {operator_text} '{formatted_value}'")
+
+ return formatted_filters
+
+ def _get_operator_translation(self, op: str, translator) -> str:
+ """Convert operator to translated text"""
+ operator_map = {
+ '=': translator.t('equals'),
+ '>': translator.t('greater_than'),
+ '>=': translator.t('greater_equal'),
+ '<': translator.t('less_than'),
+ '<=': translator.t('less_equal'),
+ '!=': translator.t('not_equals'),
+ '*': translator.t('contains'),
+ '*?': translator.t('starts_with'),
+ '?*': translator.t('ends_with'),
+ 'in': translator.t('in_list')
+ }
+
+ operator_text = operator_map.get(op, op)
+ return operator_text
+
+ def _get_column_translation(self, property_name: str, translator) -> str:
+ """Get translated column name"""
+ column_map = {
+ 'first_name': translator.t('firstName'),
+ 'last_name': translator.t('lastName'),
+ 'email': translator.t('email'),
+ 'created_at': translator.t('registrationDate'),
+ 'referral_code': translator.t('referralCode'),
+ 'is_active': translator.t('status'),
+ }
+ return column_map.get(property_name, property_name)
+
+ def _format_filter_value(self, property_name: str, value: Any, calendar_type: CalendarType, translator) -> str:
+ """Format filter value based on column type and calendar"""
+ # Handle date fields
+ if property_name == 'created_at':
+ try:
+ if isinstance(value, str):
+ # Try to parse ISO format
+ dt = datetime.fromisoformat(value.replace('Z', '+00:00'))
+ elif isinstance(value, datetime):
+ dt = value
+ else:
+ return str(value)
+
+ # Format based on calendar type - only date, no time
+ from app.core.calendar import CalendarConverter
+ formatted_date = CalendarConverter.format_datetime(dt, calendar_type)
+ return formatted_date['date_only'] # Only show date, not time
+ except:
+ return str(value)
+
+ # Handle boolean fields
+ elif property_name == 'is_active':
+ if isinstance(value, bool):
+ return translator.t('active') if value else translator.t('inactive')
+ elif str(value).lower() in ['true', '1', 'yes']:
+ return translator.t('active')
+ elif str(value).lower() in ['false', '0', 'no']:
+ return translator.t('inactive')
+ else:
+ return str(value)
+
+ # Default: return as string
+ return str(value)
+
+ def _get_referral_data(self, db, user_id: int, query_info, selected_indices: List[int] | None = None) -> tuple[List[Dict[str, Any]], int]:
+ """Get referral data from database"""
+ from adapters.db.repositories.user_repo import UserRepository
+ from adapters.api.v1.schemas import FilterItem
+ from sqlalchemy.orm import Session
+ from adapters.db.models.user import User
+
+ repo = UserRepository(db)
+
+ # Add filter for referrals only (users with referred_by_user_id = current user)
+ referral_filter = FilterItem(
+ property="referred_by_user_id",
+ operator="=",
+ value=user_id
+ )
+
+ # Create a mutable copy of query_info.filters
+ current_filters = list(query_info.filters) if query_info.filters else []
+ current_filters.append(referral_filter)
+
+ # For export, we need to get all data without take limit
+ # Use the repository's direct query method
+ try:
+ # Get all referrals for the user without pagination
+ query = db.query(User).filter(User.referred_by_user_id == user_id)
+
+ # Apply search if provided
+ if query_info.search and query_info.search.strip():
+ search_term = f"%{query_info.search}%"
+ if query_info.search_fields:
+ search_conditions = []
+ for field in query_info.search_fields:
+ if hasattr(User, field):
+ search_conditions.append(getattr(User, field).ilike(search_term))
+ if search_conditions:
+ from sqlalchemy import or_
+ query = query.filter(or_(*search_conditions))
+ else:
+ # Search in common fields
+ query = query.filter(
+ (User.first_name.ilike(search_term)) |
+ (User.last_name.ilike(search_term)) |
+ (User.email.ilike(search_term))
+ )
+
+ # Apply additional filters
+ for filter_item in current_filters:
+ if filter_item.property == "referred_by_user_id":
+ continue # Already applied
+
+ if hasattr(User, filter_item.property):
+ field = getattr(User, filter_item.property)
+ if filter_item.operator == "=":
+ query = query.filter(field == filter_item.value)
+ elif filter_item.operator == "!=":
+ query = query.filter(field != filter_item.value)
+ elif filter_item.operator == ">":
+ query = query.filter(field > filter_item.value)
+ elif filter_item.operator == ">=":
+ query = query.filter(field >= filter_item.value)
+ elif filter_item.operator == "<":
+ query = query.filter(field < filter_item.value)
+ elif filter_item.operator == "<=":
+ query = query.filter(field <= filter_item.value)
+ elif filter_item.operator == "*": # contains
+ query = query.filter(field.ilike(f"%{filter_item.value}%"))
+ elif filter_item.operator == "*?": # starts with
+ query = query.filter(field.ilike(f"{filter_item.value}%"))
+ elif filter_item.operator == "?*": # ends with
+ query = query.filter(field.ilike(f"%{filter_item.value}"))
+ elif filter_item.operator == "in":
+ query = query.filter(field.in_(filter_item.value))
+
+ # Apply sorting
+ if query_info.sort_by and hasattr(User, query_info.sort_by):
+ sort_field = getattr(User, query_info.sort_by)
+ if query_info.sort_desc:
+ query = query.order_by(sort_field.desc())
+ else:
+ query = query.order_by(sort_field.asc())
+ else:
+ # Default sort by created_at desc
+ query = query.order_by(User.created_at.desc())
+
+ # Execute query
+ referrals = query.all()
+ total = len(referrals)
+ referral_dicts = [repo.to_dict(referral) for referral in referrals]
+
+ # Apply selected indices filter if provided
+ if selected_indices is not None:
+ filtered_referrals = [referral_dicts[i] for i in selected_indices if i < len(referral_dicts)]
+ return filtered_referrals, len(filtered_referrals)
+
+ return referral_dicts, total
+
+ except Exception as e:
+ print(f"Error in _get_referral_data: {e}")
+ # Fallback to repository method with max take
+ data_query_info = query_info.__class__(
+ sort_by=query_info.sort_by,
+ sort_desc=query_info.sort_desc,
+ search=query_info.search,
+ search_fields=query_info.search_fields,
+ filters=current_filters,
+ take=1000,
+ skip=0,
+ )
+
+ referrals, total = repo.query_with_filters(data_query_info)
+ referral_dicts = [repo.to_dict(referral) for referral in referrals]
+
+ if selected_indices is not None:
+ filtered_referrals = [referral_dicts[i] for i in selected_indices if i < len(referral_dicts)]
+ return filtered_referrals, len(filtered_referrals)
+
+ return referral_dicts, total
+
+ def generate_pdf_content(
+ self,
+ db,
+ user_id: int,
+ query_info,
+ selected_indices: List[int] | None = None,
+ stats: Dict[str, Any] | None = None,
+ calendar_type: CalendarType = "jalali",
+ locale: str = "fa",
+ common_data: Dict[str, Any] = None
+ ) -> bytes:
+ """Generate PDF content using the new signature"""
+ # Get referral data
+ referrals_data, total_count = self._get_referral_data(db, user_id, query_info, selected_indices)
+
+ # Format datetime fields for display in PDF
+ for item in referrals_data:
+ if 'created_at' in item and item['created_at']:
+ if isinstance(item['created_at'], datetime):
+ from app.core.calendar import CalendarConverter
+ formatted_date = CalendarConverter.format_datetime(item['created_at'], calendar_type)
+ item['formatted_created_at'] = formatted_date['formatted']
+ else:
+ try:
+ dt = datetime.fromisoformat(item['created_at'].replace('Z', '+00:00'))
+ from app.core.calendar import CalendarConverter
+ formatted_date = CalendarConverter.format_datetime(dt, calendar_type)
+ item['formatted_created_at'] = formatted_date['formatted']
+ except:
+ item['formatted_created_at'] = str(item['created_at'])
+ else:
+ item['formatted_created_at'] = '-'
+
+ # Prepare context for template
+ from app.core.calendar import CalendarConverter
+ current_time = datetime.now()
+ formatted_current_time = CalendarConverter.format_datetime(current_time, calendar_type)
+
+ context = {
+ 'items': referrals_data,
+ 'total_count': total_count,
+ 'stats': stats,
+ 'filters': self._format_filters(query_info, locale, calendar_type),
+ 'report_date': formatted_current_time['date_only'],
+ 'report_time': formatted_current_time['time_only'],
+ 'locale': locale,
+ 'selected_only': selected_indices is not None and len(selected_indices) > 0,
+ }
+
+ # Include common data if provided
+ if common_data:
+ context.update(common_data)
+
+ # Get translator
+ t = self.get_translator(locale)
+ context['t'] = t.t # Pass the t method instead of the object
+
+ # Render template
+ html_content = self.render_template(self.template_name, context)
+
+ # Generate PDF from HTML
+ from weasyprint import HTML
+ from pathlib import Path
+ pdf_file = HTML(string=html_content, base_url=str(Path(__file__).parent / "templates")).write_pdf(font_config=self.font_config)
+ return pdf_file
+
+ def generate_excel_content(
+ self,
+ db,
+ user_id: int,
+ query_info,
+ selected_indices: List[int] | None = None,
+ calendar_type: CalendarType = "jalali",
+ locale: str = "fa",
+ common_data: Dict[str, Any] = None
+ ) -> List[Dict[str, Any]]:
+ """Generate Excel content using the new signature"""
+ # Get referral data
+ referrals_data, total_count = self._get_referral_data(db, user_id, query_info, selected_indices)
+
+ # Format data for Excel with calendar support
+ excel_data = []
+ t = self.get_translator(locale)
+
+ for i, item in enumerate(referrals_data, 1):
+ # Format created_at based on calendar type
+ created_at = item.get('created_at', '')
+ if created_at and isinstance(created_at, datetime):
+ from app.core.calendar import CalendarConverter
+ formatted_date = CalendarConverter.format_datetime(created_at, calendar_type)
+ created_at = formatted_date['formatted']
+ elif created_at and isinstance(created_at, str):
+ try:
+ dt = datetime.fromisoformat(created_at.replace('Z', '+00:00'))
+ from app.core.calendar import CalendarConverter
+ formatted_date = CalendarConverter.format_datetime(dt, calendar_type)
+ created_at = formatted_date['formatted']
+ except:
+ pass
+
+ excel_data.append({
+ t.t('rowNumber'): i,
+ t.t('firstName'): item.get('first_name', ''),
+ t.t('lastName'): item.get('last_name', ''),
+ t.t('email'): item.get('email', ''),
+ t.t('registrationDate'): created_at,
+ t.t('referralCode'): item.get('referral_code', ''),
+ t.t('status'): t.t('active') if item.get('is_active', False) else t.t('inactive')
+ })
+
+ return excel_data
diff --git a/hesabixAPI/app/services/pdf/modules/marketing/templates/marketing_referrals.html b/hesabixAPI/app/services/pdf/modules/marketing/templates/marketing_referrals.html
new file mode 100644
index 0000000..31717ba
--- /dev/null
+++ b/hesabixAPI/app/services/pdf/modules/marketing/templates/marketing_referrals.html
@@ -0,0 +1,331 @@
+
+
+
+
+
+ {{ t('marketingReport') }} - {{ t('referralList') }}
+
+
+
+
+
+ {% if stats %}
+
+
+
{{ stats.today or 0 }}
+
{{ t('today') }}
+
+
+
{{ stats.this_month or 0 }}
+
{{ t('thisMonth') }}
+
+
+
{{ stats.total or 0 }}
+
{{ t('total') }}
+
+ {% if stats.range %}
+
+
{{ stats.range }}
+
{{ t('selectedRange') }}
+
+ {% endif %}
+
+
+
{{ t('reportDate') }}
+
{{ report_date }}
+
+
+
{{ t('totalRecords') }}
+
{{ total_count }}
+
+
+
{{ t('displayedRecords') }}
+
{{ items|length }}
+
+ {% if selected_only %}
+
+
{{ t('outputType') }}
+
{{ t('selectedOnly') }}
+
+ {% endif %}
+
+
{{ t('activeFilters') }}:
+ {% for filter in filters %}
+ {{ filter }}
+ {% endfor %}
+
+ {% endif %}
+
+
+ {% if items %}
+
+
+
+ | {{ t('rowNumber') }} |
+ {{ t('firstName') }} |
+ {{ t('lastName') }} |
+ {{ t('email') }} |
+ {{ t('registrationDate') }} |
+
+
+
+ {% for item in items %}
+
+ | {{ loop.index }} |
+ {{ item.first_name or '-' }} |
+ {{ item.last_name or '-' }} |
+ {{ item.email or '-' }} |
+ {{ item.formatted_created_at }} |
+
+ {% endfor %}
+
+
+ {% else %}
+
+
📊
+
{{ t('noDataFound') }}
+
+ {% endif %}
+
+
+
{{ stats.today or 0 }}
+
امروز
+
+
+
{{ stats.this_month or 0 }}
+
این ماه
+
+
+
{{ stats.total or 0 }}
+
کل
+
+ {% if stats.range %}
+
+
{{ stats.range }}
+
بازه انتخابی
+
+ {% endif %}
+
+
+
تاریخ گزارش
+
{{ report_date }}
+
+
+
تعداد کل رکوردها
+
{{ total_count }}
+
+
+
تعداد نمایش داده شده
+
{{ items|length }}
+
+ {% if selected_only %}
+
+
نوع خروجی
+
انتخاب شدهها
+
+ {% endif %}
+
+
فیلترهای اعمال شده:
+ {% for filter in filters %}
+ {{ filter }}
+ {% endfor %}
+
+ {% endif %}
+
+
+ {% if items %}
+
+
+
+ | ردیف |
+ نام |
+ نام خانوادگی |
+ ایمیل |
+ تاریخ ثبت |
+
+
+
+ {% for item in items %}
+
+ | {{ loop.index }} |
+ {{ item.first_name or '-' }} |
+ {{ item.last_name or '-' }} |
+ {{ item.email or '-' }} |
+ {{ item.created_at }} |
+
+ {% endfor %}
+
+
+ {% else %}
+
+
📊
+
هیچ دادهای برای نمایش وجود ندارد
+
+ {% endif %}
+